summaryrefslogtreecommitdiffstats
path: root/sources/ogAdmServer.cpp
diff options
context:
space:
mode:
authorOpenGnSys Support Team <soporte-og@soleta.eu>2019-05-17 17:46:38 +0200
committerOpenGnSys Support Team <soporte-og@soleta.eu>2020-03-04 14:54:49 +0100
commit1d801be52c05e89532b945f58b2d302d15a55297 (patch)
treebd7e5a66704d6f1594929aeeda9d58d7537c7dfe /sources/ogAdmServer.cpp
parent39157320ecb75ce9db1983b189d999a33260e67c (diff)
#941 use dbi layer from respuestaEstandar()
And update all callers. Some of the db.Open() calls cannot be removed yet, since there are still more function dependencies that need to be converted too.
Diffstat (limited to 'sources/ogAdmServer.cpp')
-rw-r--r--sources/ogAdmServer.cpp204
1 files changed, 131 insertions, 73 deletions
diff --git a/sources/ogAdmServer.cpp b/sources/ogAdmServer.cpp
index 3425d7a..49b90ab 100644
--- a/sources/ogAdmServer.cpp
+++ b/sources/ogAdmServer.cpp
@@ -1041,12 +1041,13 @@ static bool DisponibilidadComandos(TRAMA *ptrTrama, struct og_client *cli)
// true: Si el proceso es correcto
// false: En caso de ocurrir algún error
// ________________________________________________________________________________________________________
-static bool respuestaEstandar(TRAMA *ptrTrama, char *iph, char *ido, Database db,
- Table tbl)
+static bool respuestaEstandar(TRAMA *ptrTrama, char *iph, char *ido,
+ struct og_dbi *dbi)
{
- char msglog[LONSTD], sqlstr[LONSQL];
char *res, *ids, *der;
char fechafin[LONPRM];
+ const char *msglog;
+ dbi_result result;
struct tm* st;
int idaccion;
@@ -1072,47 +1073,47 @@ static bool respuestaEstandar(TRAMA *ptrTrama, char *iph, char *ido, Database db
return true;
}
- sprintf(sqlstr,
+ result = dbi_conn_queryf(dbi->conn,
"SELECT * FROM acciones WHERE idordenador=%s"
" AND sesion=%s ORDER BY idaccion", ido,ids);
liberaMemoria(ids);
- if (!db.Execute(sqlstr, tbl)) {
- db.GetErrorErrStr(msglog);
+ if (!result) {
+ dbi_conn_error(dbi->conn, &msglog);
syslog(LOG_ERR, "failed to query database (%s:%d) %s\n",
__func__, __LINE__, msglog);
return false;
}
- if (tbl.ISEOF()) {
+ if (!dbi_result_next_row(result)) {
syslog(LOG_ERR, "no actions available\n");
+ dbi_result_free(result);
return true;
}
- if (!tbl.Get("idaccion", idaccion)) { // Toma identificador de la accion
- tbl.GetErrorErrStr(msglog); // Error al acceder al registro
- og_info(msglog);
- return false;
- }
+
+ idaccion = dbi_result_get_uint(result, "idaccion");
+ dbi_result_free(result);
+
st = tomaHora();
sprintf(fechafin, "%d/%d/%d %d:%d:%d", st->tm_year + 1900, st->tm_mon + 1,
st->tm_mday, st->tm_hour, st->tm_min, st->tm_sec);
der = copiaParametro("der",ptrTrama); // Toma descripción del error (si hubiera habido)
-
- sprintf(sqlstr,
+
+ result = dbi_conn_queryf(dbi->conn,
"UPDATE acciones"\
" SET resultado='%s',estado='%d',fechahorafin='%s',descrinotificacion='%s'"\
" WHERE idordenador=%s AND idaccion=%d",
res, ACCION_FINALIZADA, fechafin, der, ido, idaccion);
-
- if (!db.Execute(sqlstr, tbl)) { // Error al actualizar
+ if (!result) {
+ dbi_conn_error(dbi->conn, &msglog);
liberaMemoria(res);
liberaMemoria(der);
- db.GetErrorErrStr(msglog);
- og_info(msglog);
+ og_info((char *)msglog);
return false;
}
-
+ dbi_result_free(result);
+
liberaMemoria(der);
if (atoi(res) == ACCION_FALLIDA) {
@@ -1396,39 +1397,38 @@ bool WakeUp(int s, char* iph, char *mac, char *mar)
// ________________________________________________________________________________________________________
static bool RESPUESTA_Arrancar(TRAMA* ptrTrama, struct og_client *cli)
{
- char msglog[LONSTD];
- Database db;
- Table tbl;
- int i;
+ struct og_dbi *dbi;
char *iph, *ido;
char *tpc;
+ int i;
- if (!db.Open(usuario, pasguor, datasource, catalog)) {
- db.GetErrorErrStr(msglog);
- syslog(LOG_ERR, "cannot open connection database (%s:%d) %s\n",
- __func__, __LINE__, msglog);
+ dbi = og_dbi_open(&dbi_config);
+ if (!dbi) {
+ syslog(LOG_ERR, "cannot open connection database (%s:%d)\n",
+ __func__, __LINE__);
return false;
}
iph = copiaParametro("iph",ptrTrama); // Toma dirección ip
ido = copiaParametro("ido",ptrTrama); // Toma identificador del ordenador
- if (!respuestaEstandar(ptrTrama, iph, ido, db, tbl)) {
+ if (!respuestaEstandar(ptrTrama, iph, ido, dbi)) {
liberaMemoria(iph);
liberaMemoria(ido);
syslog(LOG_ERR, "failed to register notification\n");
+ og_dbi_close(dbi);
return false;
}
tpc = copiaParametro("tpc",ptrTrama); // Tipo de cliente (Plataforma y S.O.)
if (clienteExistente(iph, &i)) // Actualiza estado
strcpy(tbsockets[i].estado, tpc);
-
+
liberaMemoria(iph);
liberaMemoria(ido);
liberaMemoria(tpc);
-
- db.Close(); // Cierra conexión
+ og_dbi_close(dbi);
+
return true;
}
// ________________________________________________________________________________________________________
@@ -1445,36 +1445,35 @@ static bool RESPUESTA_Arrancar(TRAMA* ptrTrama, struct og_client *cli)
// ________________________________________________________________________________________________________
static bool RESPUESTA_Apagar(TRAMA* ptrTrama, struct og_client *cli)
{
- char msglog[LONSTD];
- Database db;
- Table tbl;
- int i;
+ struct og_dbi *dbi;
char *iph, *ido;
+ int i;
- if (!db.Open(usuario, pasguor, datasource, catalog)) {
- db.GetErrorErrStr(msglog);
- syslog(LOG_ERR, "cannot open connection database (%s:%d) %s\n",
- __func__, __LINE__, msglog);
+ dbi = og_dbi_open(&dbi_config);
+ if (!dbi) {
+ syslog(LOG_ERR, "cannot open connection database (%s:%d)\n",
+ __func__, __LINE__);
return false;
}
iph = copiaParametro("iph",ptrTrama); // Toma dirección ip
ido = copiaParametro("ido",ptrTrama); // Toma identificador del ordenador
- if (!respuestaEstandar(ptrTrama, iph, ido, db, tbl)) {
+ if (!respuestaEstandar(ptrTrama, iph, ido, dbi)) {
liberaMemoria(iph);
liberaMemoria(ido);
syslog(LOG_ERR, "failed to register notification\n");
+ og_dbi_close(dbi);
return false; // Error al registrar notificacion
}
if (clienteExistente(iph, &i)) // Actualiza estado
strcpy(tbsockets[i].estado, CLIENTE_APAGADO);
-
+
liberaMemoria(iph);
liberaMemoria(ido);
-
- db.Close(); // Cierra conexión
+ og_dbi_close(dbi);
+
return true;
}
// ________________________________________________________________________________________________________
@@ -1495,6 +1494,7 @@ static bool RESPUESTA_CrearImagen(TRAMA* ptrTrama, struct og_client *cli)
Database db;
Table tbl;
char *iph, *dsk, *par, *cpt, *ipr, *ido;
+ struct og_dbi *dbi;
char *idi;
bool res;
@@ -1505,13 +1505,22 @@ static bool RESPUESTA_CrearImagen(TRAMA* ptrTrama, struct og_client *cli)
return false;
}
+ dbi = og_dbi_open(&dbi_config);
+ if (!dbi) {
+ syslog(LOG_ERR, "cannot open connection database (%s:%d)\n",
+ __func__, __LINE__);
+ db.Close();
+ return false;
+ }
+
iph = copiaParametro("iph",ptrTrama); // Toma dirección ip
ido = copiaParametro("ido",ptrTrama); // Toma identificador del ordenador
- if (!respuestaEstandar(ptrTrama, iph, ido, db, tbl)) {
+ if (!respuestaEstandar(ptrTrama, iph, ido, dbi)) {
liberaMemoria(iph);
liberaMemoria(ido);
syslog(LOG_ERR, "failed to register notification\n");
+ og_dbi_close(dbi);
return false; // Error al registrar notificacion
}
@@ -1528,15 +1537,14 @@ static bool RESPUESTA_CrearImagen(TRAMA* ptrTrama, struct og_client *cli)
liberaMemoria(par);
liberaMemoria(cpt);
liberaMemoria(ipr);
+ og_dbi_close(dbi);
- if(!res){
+ if (!res)
syslog(LOG_ERR, "Problem processing update\n");
- db.Close();
- return false;
- }
db.Close(); // Cierra conexión
- return true;
+
+ return res;
}
// ________________________________________________________________________________________________________
// Función: actualizaCreacionImagen
@@ -1685,6 +1693,7 @@ static bool RESPUESTA_CrearSoftIncremental(TRAMA* ptrTrama, struct og_client *cl
char *iph,*par,*ido,*idf;
int ifs;
char msglog[LONSTD],sqlstr[LONSQL];
+ struct og_dbi *dbi;
if (!db.Open(usuario, pasguor, datasource, catalog)) {
db.GetErrorErrStr(msglog);
@@ -1693,10 +1702,19 @@ static bool RESPUESTA_CrearSoftIncremental(TRAMA* ptrTrama, struct og_client *cl
return false;
}
+ dbi = og_dbi_open(&dbi_config);
+ if (!dbi) {
+ syslog(LOG_ERR, "cannot open connection database (%s:%d)\n",
+ __func__, __LINE__);
+ db.Close();
+ return false;
+ }
+
iph = copiaParametro("iph",ptrTrama); // Toma dirección ip
ido = copiaParametro("ido",ptrTrama); // Toma identificador del ordenador
- if (!respuestaEstandar(ptrTrama, iph, ido, db, tbl)) {
+ if (!respuestaEstandar(ptrTrama, iph, ido, dbi)) {
+ og_dbi_close(dbi);
liberaMemoria(iph);
liberaMemoria(ido);
syslog(LOG_ERR, "failed to register notification\n");
@@ -1735,6 +1753,7 @@ static bool RESPUESTA_CrearSoftIncremental(TRAMA* ptrTrama, struct og_client *cl
__func__, __LINE__, msglog);
return false;
}
+ og_dbi_close(dbi);
db.Close(); // Cierra conexión
return true;
}
@@ -1758,6 +1777,7 @@ static bool RESPUESTA_RestaurarImagen(TRAMA* ptrTrama, struct og_client *cli)
Table tbl;
bool res;
char *iph, *ido, *idi, *dsk, *par, *ifs, *cfg;
+ struct og_dbi *dbi;
if (!db.Open(usuario, pasguor, datasource, catalog)) {
db.GetErrorErrStr(msglog);
@@ -1766,10 +1786,19 @@ static bool RESPUESTA_RestaurarImagen(TRAMA* ptrTrama, struct og_client *cli)
return false;
}
+ dbi = og_dbi_open(&dbi_config);
+ if (!dbi) {
+ syslog(LOG_ERR, "cannot open connection database (%s:%d)\n",
+ __func__, __LINE__);
+ db.Close();
+ return false;
+ }
+
iph = copiaParametro("iph",ptrTrama); // Toma dirección ip
ido = copiaParametro("ido",ptrTrama); // Toma identificador del ordenador
- if (!respuestaEstandar(ptrTrama, iph, ido, db, tbl)) {
+ if (!respuestaEstandar(ptrTrama, iph, ido, dbi)) {
+ og_dbi_close(dbi);
liberaMemoria(iph);
liberaMemoria(ido);
syslog(LOG_ERR, "failed to register notification\n");
@@ -1793,15 +1822,14 @@ static bool RESPUESTA_RestaurarImagen(TRAMA* ptrTrama, struct og_client *cli)
liberaMemoria(idi);
liberaMemoria(par);
liberaMemoria(ifs);
+ og_dbi_close(dbi);
- if(!res){
+ if(!res)
syslog(LOG_ERR, "Problem after restoring image\n");
- db.Close();
- return false;
- }
db.Close(); // Cierra conexión
- return true;
+
+ return res;
}
// ________________________________________________________________________________________________________
//
@@ -1893,6 +1921,7 @@ static bool RESPUESTA_EjecutarScript(TRAMA* ptrTrama, struct og_client *cli)
Database db;
Table tbl;
char *iph, *ido,*cfg;
+ struct og_dbi *dbi;
bool res = true;
if (!db.Open(usuario, pasguor, datasource, catalog)) {
@@ -1902,10 +1931,19 @@ static bool RESPUESTA_EjecutarScript(TRAMA* ptrTrama, struct og_client *cli)
return false;
}
+ dbi = og_dbi_open(&dbi_config);
+ if (!dbi) {
+ syslog(LOG_ERR, "cannot open connection database (%s:%d)\n",
+ __func__, __LINE__);
+ db.Close();
+ return false;
+ }
+
iph = copiaParametro("iph",ptrTrama); // Toma dirección ip
ido = copiaParametro("ido",ptrTrama); // Toma identificador del ordenador
- if (!respuestaEstandar(ptrTrama, iph, ido, db, tbl)) {
+ if (!respuestaEstandar(ptrTrama, iph, ido, dbi)) {
+ og_dbi_close(dbi);
liberaMemoria(iph);
liberaMemoria(ido);
syslog(LOG_ERR, "failed to register notification\n");
@@ -1920,14 +1958,14 @@ static bool RESPUESTA_EjecutarScript(TRAMA* ptrTrama, struct og_client *cli)
liberaMemoria(iph);
liberaMemoria(ido);
+ og_dbi_close(dbi);
- if (!res) {
+ if (!res)
syslog(LOG_ERR, "Problem updating client configuration\n");
- return false;
- }
db.Close(); // Cierra conexión
- return true;
+
+ return res;
}
// ________________________________________________________________________________________________________
// Función: RESPUESTA_InventarioHardware
@@ -1948,6 +1986,7 @@ static bool RESPUESTA_InventarioHardware(TRAMA* ptrTrama, struct og_client *cli)
Table tbl;
bool res;
char *iph, *ido, *idc, *npc, *hrd, *buffer;
+ struct og_dbi *dbi;
if (!db.Open(usuario, pasguor, datasource, catalog)) {
db.GetErrorErrStr(msglog);
@@ -1956,10 +1995,19 @@ static bool RESPUESTA_InventarioHardware(TRAMA* ptrTrama, struct og_client *cli)
return false;
}
+ dbi = og_dbi_open(&dbi_config);
+ if (!dbi) {
+ syslog(LOG_ERR, "cannot open connection database (%s:%d)\n",
+ __func__, __LINE__);
+ db.Close();
+ return false;
+ }
+
iph = copiaParametro("iph",ptrTrama); // Toma dirección ip del cliente
ido = copiaParametro("ido",ptrTrama); // Toma identificador del cliente
- if (!respuestaEstandar(ptrTrama, iph, ido, db, tbl)) {
+ if (!respuestaEstandar(ptrTrama, iph, ido, dbi)) {
+ og_dbi_close(dbi);
liberaMemoria(iph);
liberaMemoria(ido);
syslog(LOG_ERR, "failed to register notification\n");
@@ -1980,14 +2028,14 @@ static bool RESPUESTA_InventarioHardware(TRAMA* ptrTrama, struct og_client *cli)
liberaMemoria(npc);
liberaMemoria(idc);
liberaMemoria(buffer);
-
- if(!res){
+ og_dbi_close(dbi);
+
+ if (!res)
syslog(LOG_ERR, "Problem updating client configuration\n");
- return false;
- }
-
+
db.Close(); // Cierra conexión
- return true;
+
+ return res;
}
// ________________________________________________________________________________________________________
// Función: actualizaHardware
@@ -2299,6 +2347,7 @@ static bool RESPUESTA_InventarioSoftware(TRAMA* ptrTrama, struct og_client *cli)
Table tbl;
bool res;
char *iph, *ido, *npc, *idc, *par, *sft, *buffer;
+ struct og_dbi *dbi;
if (!db.Open(usuario, pasguor, datasource, catalog)) {
db.GetErrorErrStr(msglog);
@@ -2307,10 +2356,19 @@ static bool RESPUESTA_InventarioSoftware(TRAMA* ptrTrama, struct og_client *cli)
return false;
}
+ dbi = og_dbi_open(&dbi_config);
+ if (!dbi) {
+ syslog(LOG_ERR, "cannot open connection database (%s:%d)\n",
+ __func__, __LINE__);
+ db.Close();
+ return false;
+ }
+
iph = copiaParametro("iph",ptrTrama); // Toma dirección ip
ido = copiaParametro("ido",ptrTrama); // Toma identificador del ordenador
- if (!respuestaEstandar(ptrTrama, iph, ido, db, tbl)) {
+ if (!respuestaEstandar(ptrTrama, iph, ido, dbi)) {
+ og_dbi_close(dbi);
liberaMemoria(iph);
liberaMemoria(ido);
syslog(LOG_ERR, "failed to register notification\n");
@@ -2332,14 +2390,14 @@ static bool RESPUESTA_InventarioSoftware(TRAMA* ptrTrama, struct og_client *cli)
liberaMemoria(idc);
liberaMemoria(par);
liberaMemoria(sft);
+ og_dbi_close(dbi);
- if(!res){
+ if (!res)
syslog(LOG_ERR, "cannot update software\n");
- return false;
- }
db.Close(); // Cierra conexión
- return true;
+
+ return res;
}
// ________________________________________________________________________________________________________
// Función: actualizaSoftware