#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.

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