#915 Adapt web to use the new run/schedule cmd in REST API

This patch implements run/schedule in the set of available PHP functions.
It also replaces old SocketHidra commands by run/schedule in
gestor_colasacciones.php and gestor_ejecutaracciones.php.

2 files changed, 6 insertions, 71 deletions

diff --git a/admin/WebConsole/gestores/gestor_colasacciones.php b/admin/WebConsole/gestores/gestor_colasacciones.php
index 68034bd8..99c1caec 100644
--- a/admin/WebConsole/gestores/gestor_colasacciones.php
+++ b/admin/WebConsole/gestores/gestor_colasacciones.php
@@ -16,6 +16,7 @@ include_once("../includes/constantes.php");
 include_once("../includes/comunes.php");
 include_once("../includes/CreaComando.php");
 include_once("../clases/SockHidra.php");
+include_once("../includes/restfunctions.php");
 //________________________________________________________________________________________________________
 	
 $opcion=0; // Inicializa parametros
@@ -92,7 +93,7 @@ function gestiona($cmd,$opcion,$acciones){
 					$cmd->texto.=" WHERE tipoaccion=".$tipoaccion." AND idtipoaccion=".$idtipoaccion." AND sesion=".$sesion;
 				$resul=$cmd->Ejecutar();
 				if($resul)
-					$resul=enviaComandoActualizar($aplicacion);
+					run_schedule($rs->campos["cadenaip"]);
 				break;	
 				
 			case  3: // Para acciones ============================================================
@@ -139,40 +140,3 @@ function gestiona($cmd,$opcion,$acciones){
 	}
 	return($resul);
 }
-//	_________________________________________________________________________
-//
-// Envía un comando de actualizar a los ordenadores tras reinicio de acción
-//	_________________________________________________________________________
-
-function enviaComandoActualizar($aplicacion)
-{
-	global $servidorhidra;
-	global $hidraport;
-	global $LONCABECERA;
-	global $LONHEXPRM;
-	
-	$funcion="Actualizar"; // Nombre de la función que procesa la petición
-	//________________________________________________________________________________________________________
-	//
-	// Envio al servidor de la petición
-	//________________________________________________________________________________________________________
-	$trama="";
-	$shidra=new SockHidra($servidorhidra,$hidraport); 
-	if ($shidra->conectar()){ // Se ha establecido la conexión con el servidor hidra
-		$parametros="nfn=".$funcion.chr(13);
-		$parametros.=$aplicacion;
-		$shidra->envia_comando($parametros);
-		$trama=$shidra->recibe_respuesta();
-		$shidra->desconectar();
-	}
-	else
-		return(false); // Error de actualización
-	
-	$hlonprm=hexdec(substr($trama,$LONCABECERA,$LONHEXPRM));
-	$parametros=substr($trama,$LONCABECERA+$LONHEXPRM,$hlonprm);
-	$ValorParametros=extrae_parametros($parametros,chr(13),'=');
-	$trama_notificacion=$ValorParametros["res"];
-	if($trama_notificacion==1) return(true); // Devuelve respuesta	
-	return(false); // Error de actualización
-}
-
diff --git a/admin/WebConsole/gestores/gestor_ejecutaracciones.php b/admin/WebConsole/gestores/gestor_ejecutaracciones.php
index 8e27d1be..d212c57d 100644
--- a/admin/WebConsole/gestores/gestor_ejecutaracciones.php
+++ b/admin/WebConsole/gestores/gestor_ejecutaracciones.php
@@ -17,6 +17,7 @@ include_once("../includes/CreaComando.php");
 include_once("../includes/constantes.php");
 include_once("../includes/comunes.php");
 include_once("../includes/RecopilaIpesMacs.php");
+include_once("../includes/restfunctions.php");
 //________________________________________________________________________________________________________
 
 $opcion=0; // Inicializa parametros
@@ -268,43 +269,13 @@ function insertaComando($idcomando,$parametros,$idprocedimiento,$ambito,$idambit
 		$resul=$cmd->Ejecutar();
 		//echo $cmd->texto;
 		if(!$resul) return(false);
-		
-		/* Sólo envía por la red el primer comando, el resto, si hubiera, 
-		lo encontrará el cliente a través de los comandos pendientes */
+
+		// Let the clients know they can start executing pending commands.
 		if(empty($vez)){
-			if(!enviaComando($parametros,$sesion)) return(false);
+			run_schedule($cadenaip);
 			$vez++;
 		}
 	}
 	return(true);
 }
-//________________________________________________________________________________________________________
-//
-//	Envia un procedimiento a un grupo de ordenadores a través de la red
-//________________________________________________________________________________________________________
-function enviaComando($parametros,$sesion)
-{	
-	global $cadenaid;
-	global $cadenaip;
-	global $cadenamac;	
-	global $servidorhidra;		
-	global $hidraport;		
-	global $LONCABECERA;		
-	global $shidra;
-	
-	// Envio al servidor 
-
-	$aplicacion=chr(13)."ido=".$cadenaid.chr(13)."mac=".$cadenamac.chr(13)."iph=".$cadenaip.chr(13);
-	$acciones=chr(13)."ids=".$sesion.chr(13); // Para seguimiento
-	
-	if ($shidra->conectar()){ // Se ha establecido la conexión con el servidor hidra
-		$parametros.=$aplicacion;
-		$parametros.=$acciones;
-		$shidra->envia_comando($parametros);
-		$trama=$shidra->recibe_respuesta();
-		$shidra->desconectar();
-	}
-	return(true);
-}
-