diff options
| -rw-r--r-- | sources/ogAdmServer.cpp | 204 |
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 |