#708 #743: Solo activar las rutas REST de los servicios activos.

git-svn-id: https://opengnsys.es/svn/branches/version1.1@4909 a21b9725-9963-47de-94b9-378ad31fedc9

1 files changed, 1022 insertions, 0 deletions

diff --git a/admin/WebConsole/rest/server.php b/admin/WebConsole/rest/server.php
new file mode 100644
index 00000000..fc29c517
--- /dev/null
+++ b/admin/WebConsole/rest/server.php
@@ -0,0 +1,1022 @@
+<?php
+/**
+ * @file    index.php
+ * @brief   OpenGnsys REST API manager.
+ * @warning All input and output messages are formatted in JSON.
+ * @note    Some ideas are based on article "How to create REST API for Android app using PHP, Slim and MySQL" by Ravi Tamada, thanx.
+ * @license GNU GPLv3+
+ * @author  Ramón M. Gómez, ETSII Univ. Sevilla
+ * @version 1.1
+ * @date    2015-04-16
+ */
+
+// Inclussion files.
+
+// Server access data.
+include_once("../controlacceso.php");
+include_once("../clases/AdoPhp.php");
+include_once("../includes/CreaComando.php");
+// Connection class.
+@include_once("../includes/constantes.php");
+include_once("../includes/comunes.php");
+include_once("../clases/SockHidra.php");
+		
+// Slim framework.
+include_once("Slim/Slim.php");
+\Slim\Slim::registerAutoloader();
+
+// Server access control.
+$cmd = CreaComando($cnx);
+if (!$cmd)
+	die("Access Error");
+
+// Install Slim application (development mode).
+//$app = new \Slim\Slim(array('mode' => 'production', 'debug' => false));
+$app = new \Slim\Slim(array(
+		'mode' => 'development',
+		'debug' => true));
+$app->setName('opengnsys');
+
+// Global variables.
+$userid = NULL;			// User id. with access to REST API.
+
+
+// Auxiliar functions.
+
+/**
+ * @brief   Compose JSON response.
+ * @param   int status      Status code for HTTP response.
+ * @param   array response  Response data.
+ * @return  string          JSON response.
+ */
+function jsonResponse($status, $response) {
+	$app = \Slim\Slim::getInstance();
+	// HTTP status code.
+	$app->status($status);
+	// Content-type HTTP header.
+	$app->contentType('application/json');
+	// JSON response.
+	echo json_encode($response);
+}
+
+/**
+ * @brief    Validate API key included in "Authorization" HTTP header.
+ * @return   JSON response on error.
+ */
+function validateApiKey() {
+	global $cmd;
+	global $userid;
+	$response = array();
+
+	// Read Authorization HTTP header.
+	$headers = apache_request_headers();
+	if (! empty($headers['Authorization'])) {
+		// Assign user id. that match this key to global variable.
+		$apikey = htmlspecialchars($headers['Authorization']);
+		$cmd->texto = "SELECT idusuario
+				 FROM usuarios
+				WHERE apikey='$apikey'";
+		$rs=new Recordset;
+		$rs->Comando=&$cmd;
+		if ($rs->Abrir()) {
+			$rs->Primero();
+			if (!$rs->EOF){
+				// Fetch user id.
+				$userid = $rs->campos["idusuario"];
+			} else {
+                		// Credentials error.
+                		$response['error'] = true;
+                		$response['message'] = 'Login failed. Incorrect credentials';
+				jsonResponse(401, $response);
+				$app->stop();
+			}
+			$rs->Cerrar();
+		} else {
+			// Access error.
+			$response['error'] = true;
+			$response['message'] = "An error occurred, please try again";
+			jsonResponse(500, $response);
+		}
+	} else {
+		// Error: missing API key.
+               	$response['error'] = true;
+               	$response['message'] = 'Missing API key';
+		jsonResponse(400, $response);
+		$app->stop();
+	}
+}
+
+/**
+ * @brief    Check if parameter is set and print error messages if empty.
+ * @param    string param    Parameter to check.
+ * @return   boolean         "false" if parameter is null, otherwise "true".
+ */
+function checkParameter($param) {
+	if (isset($param)) {
+		return true;
+	} else {
+		// Print error message.
+		$response['error'] = true;
+		$response['message'] = 'Parameter not found';
+		jsonResponse(400, $response);
+		return false;
+	}
+}
+
+/**
+ * @brief    Check if user is administrator and print error messages if not.
+ * @param    int adminid   Administrator id.
+ * @return   boolean       "true" if admin id. is equals to global user id., otherwise "false".
+ */
+function checkAdmin($adminid) {
+	global $userid;
+
+	if ($adminid == $userid) {
+		return true;
+	} else {
+		// Print error message.
+		$response['error'] = true;
+		$response['message'] = 'Cannot access this resource';
+		jsonResponse(401, $response);
+		return false;
+	}
+}
+
+
+/**
+ * @#fn      sendCommand($serverip, $serverport, $reqframe, &$values)
+ * @brief    Send a command to an OpenGnsys ogAdmServer and get request.
+ * @param    string serverip    Server IP address.
+ * @param    string serverport  Server port.
+ * @param    string reqframe    Request frame (field's separator is "\r").
+ * @param    array values       Response values (out parameter).
+ * @return   boolean            "true" if success, otherwise "false".
+ */
+function sendCommand($serverip, $serverport, $reqframe, &$values) {
+	global $LONCABECERA;
+	global $LONHEXPRM;
+
+	// Connect to server.
+	$respvalues = "";
+	$connect = new SockHidra($serverip, $serverport);
+	if ($connect->conectar()) {
+		// Send request frame to server.
+		$result = $connect->envia_peticion($reqframe);
+		if ($result) {
+			// Parse request frame.
+			$respframe = $connect->recibe_respuesta();
+			$connect->desconectar();
+			$paramlen = hexdec(substr($respframe, $LONCABECERA, $LONHEXPRM));
+			$params = substr($respframe, $LONCABECERA+$LONHEXPRM, $paramlen);
+			// Fetch values and return result.
+			$values = extrae_parametros($params, "\r", '=');
+			return ($values);
+		} else {
+			// Return with error.
+			return (false);
+		}
+	} else {
+		// Return with error.
+		return (false);
+	}
+}
+
+// Define REST routes.
+
+/**
+ * @brief    user login.
+ * @note     Route: /login, Method: POST
+ * @param    string username   User name.
+ * @param    string password   User password.
+ * @return   string            JSON response with user id. and API key.
+ * @note     User's API key is stored in a new field of "usuarios" table.
+ */
+$app->post('/login',
+    function() use ($app) {
+	global $cmd;
+	global $userid;
+
+	$response = array();
+
+	// Reading JSON parameters.
+	try {
+		$input = json_decode($app->request()->getBody());
+		$user = htmlspecialchars($input->username);
+		$pass = htmlspecialchars($input->password);
+	} catch (Exception $e) {
+		// Message error.
+		$response["error"] = true;
+		$response["message"] = $e->getMessage();
+		jsonResponse(400, $response);
+		$app->stop();
+	}
+
+	// Check parameters. 
+	if (! empty($user) and ! empty($pass)) {
+		// Database query.
+		$cmd->texto = "SELECT idusuario, apikey
+			 	 FROM usuarios
+				WHERE usuario='$user' AND pasguor='$pass'";
+		$rs=new Recordset;
+		$rs->Comando=&$cmd;
+		if ($rs->Abrir()) {
+			$rs->Primero();
+			if (!$rs->EOF){
+				// JSON response.
+				$userid=$rs->campos["idusuario"];
+				$apikey=$rs->campos["apikey"];
+				$response["error"] = false;
+				$response['userid'] = $userid;
+				$response['apikey'] = $apikey;
+				jsonResponse(200, $response);
+			} else {
+                		// Credentials error.
+                		$response['error'] = true;
+                		$response['message'] = 'Login failed. Incorrect credentials';
+				jsonResponse(401, $response);
+				$app->stop();
+			}
+			$rs->Cerrar();
+		} else {
+			// Access error.
+			$response['error'] = true;
+			$response['message'] = "An error occurred. Please try again";
+			jsonResponse(500, $response);
+			$app->stop();
+		}
+	} else {
+		# Error: missing some input parameter.
+              	$response['error'] = true;
+		$response['message'] = 'Missing username or password';
+		jsonResponse(400, $response);
+		$app->stop();
+	}
+    }
+);
+
+/**
+ * @brief    List all defined Organizational Units
+ * @note     Route: /ous, Method: GET
+ * @param    no
+ * @return   JSON array with ouid, ouname for every defined OU
+ */
+$app->get('/ous', 'validateApiKey', function() {
+	global $cmd;
+
+	$cmd->texto = "SELECT * FROM centros";
+	$rs=new Recordset;
+	$rs->Comando=&$cmd;
+	if (!$rs->Abrir()) return(false); // Error al abrir recordset
+	$response['error'] = false;
+	$response['ous'] = array();
+	$rs->Primero();
+	while (!$rs->EOF) {
+		$tmp = array();
+		$tmp['ouid'] = $rs->campos["idcentro"];
+		$tmp['ouname'] = $rs->campos["nombrecentro"];
+		array_push($response['ous'], $tmp);
+		$rs->Siguiente();
+	}
+	$rs->Cerrar(); 
+	jsonResponse(200, $response);
+} 
+);
+
+/**
+ * @brief    Get Organizational Unit data
+ * @note     Route: /ous/id, Method: GET
+ * @param    id      OU id.
+ * @return   JSON string with ouid, ouname and description
+ */
+$app->get('/ous/:ouid', 'validateApiKey',
+    function($ouid) {
+	global $cmd;
+
+	$ouid = htmlspecialchars($ouid);
+	$cmd->texto = "SELECT * FROM centros WHERE idcentro='$ouid';";
+	$rs=new Recordset;
+	$rs->Comando=&$cmd;
+	if (!$rs->Abrir()) return(false); // Error al abrir recordset
+	$rs->Primero();
+	if (checkParameter($rs->campos["nombrecentro"])) {
+		$response['error'] = false;
+		$response['ouid'] = $ouid;
+		$response['ouname'] = $rs->campos["nombrecentro"];
+		$response['description'] = $rs->campos["comentarios"];
+		jsonResponse(200, $response);
+	}
+	$rs->Cerrar(); 
+    }
+);
+
+// Listar aulas de una OU.
+$app->get('/ous/:ouid/labs', 'validateApiKey',
+    function($ouid) {
+	global $cmd;
+
+	$ouid = htmlspecialchars($ouid);
+	// Listar las salas de la UO si el usuario de la apikey es su admin.
+	$cmd->texto = <<<EOD
+SELECT aulas.*, adm.idadministradorcentro
+  FROM aulas
+ RIGHT JOIN administradores_centros AS adm USING(idcentro)
+ RIGHT JOIN usuarios USING(idusuario)
+ WHERE idcentro='$ouid';
+EOD;
+	$rs=new Recordset;
+	$rs->Comando=&$cmd;
+	if (!$rs->Abrir()) return(false);	// Error al abrir recordset
+	// Comprobar que exista la UO y que el usuario sea su administrador.
+	$rs->Primero();
+	if (checkParameter($rs->campos["idcentro"]) and checkAdmin($rs->campos["idadministradorcentro"])) {
+		$response['error'] = false;
+		$response['ouid'] = $ouid;
+		$response['labs'] = array();
+		while (!$rs->EOF) {
+			$tmp = array();
+			$tmp['labid'] = $rs->campos["idaula"];
+			$tmp['labname'] = $rs->campos["nombreaula"];
+			$tmp['inremotepc'] = $rs->campos["inremotepc"]==0 ? false: true;
+			array_push($response['labs'], $tmp);
+			$rs->Siguiente();
+		}
+		jsonResponse(200, $response);
+	}
+	$rs->Cerrar(); 
+    }
+);
+
+// Obtener datos de un aula.
+// Alternativa: $app->get('/lab/:labid', 'validateApiKey',
+//                  function($labid) {
+$app->get('/ous/:ouid/labs/:labid', 'validateApiKey',
+    function($ouid, $labid) {
+	global $cmd;
+
+	$ouid = htmlspecialchars($ouid);
+	$labid = htmlspecialchars($labid);
+	$cmd->texto = <<<EOD
+SELECT COUNT(idordenador) AS defclients, aulas.*, adm.idadministradorcentro
+  FROM aulas
+ RIGHT JOIN administradores_centros AS adm USING(idcentro)
+ RIGHT JOIN usuarios USING(idusuario)
+  LEFT JOIN ordenadores USING(idaula)
+ WHERE idcentro='$ouid'
+   AND idaula='$labid';
+EOD;
+	$rs=new Recordset;
+	$rs->Comando=&$cmd;
+	if (!$rs->Abrir()) return(false); // Error al abrir recordset
+	$rs->Primero();
+	if (checkParameter($rs->campos["idaula"]) and checkAdmin($rs->campos["idadministradorcentro"])) {
+		$response['error'] = false;
+		$response['labid'] = $rs->campos["idaula"];
+		$response['labname'] = $rs->campos["nombreaula"];
+		$response['description'] = $rs->campos["comentarios"];
+		$response['inremotepc'] = $rs->campos["inremotepc"]==0 ? false: true;
+		$response['maxclients'] = $rs->campos["puestos"];
+		$response['defclients'] = $rs->campos["defclients"];
+		$response['projector'] = $rs->campos["cagnon"]==0 ? false: true;
+		$response['board'] = $rs->campos["pizarra"]==0 ? false: true;
+		$response['routerip'] = $rs->campos["router"];
+		$response['netmask'] = $rs->campos["netmask"];
+		$response['ntp'] = $rs->campos["ntp"];
+		$response['dns'] = $rs->campos["dns"];
+		$response['proxyurl'] = $rs->campos["proxy"];
+		switch ($rs->campos["modomul"]) {
+			case 1:  $response['mcastmode'] = "half-duplex"; break;
+			case 2:  $response['mcastmode'] = "full-duplex"; break;
+			default: $response['mcastmode'] = $rs->campos["modomul"];
+		}
+		$response['mcastip'] = $rs->campos["ipmul"];
+		$response['mcastport'] = $rs->campos["pormul"];
+		$response['mcastspeed'] = $rs->campos["velmul"];
+		$response['p2pmode'] = $rs->campos["modp2p"];
+		$response['p2ptime'] = $rs->campos["timep2p"];
+		jsonResponse(200, $response);
+	}
+	$rs->Cerrar(); 
+    }
+);
+
+// Listar clientes de un aula.
+$app->get('/ous/:ouid/labs/:labid/clients', 'validateApiKey',
+    function($ouid, $labid) {
+	global $cmd;
+
+	$ouid = htmlspecialchars($ouid);
+	$labid = htmlspecialchars($labid);
+	// Listar los clientes del aula si el usuario de la apikey es admin de su UO.
+	// Consulta temporal,
+	$cmd->texto = "SELECT * FROM ordenadores WHERE idaula=$labid;";
+	$rs=new Recordset;
+	$rs->Comando=&$cmd;
+	if (!$rs->Abrir()) return(false);	// Recordset open error.
+	$rs->Primero();
+	if (checkParameter($rs->campos["idaula"])) {
+		$response['error'] = false;
+		$response['ouid'] = $ouid;
+		$response['labid'] = $labid;
+		$response['clients'] = array();
+		while (!$rs->EOF) {
+			$tmp = array();
+			$tmp['clientid'] = $rs->campos["idordenador"];
+			$tmp['clientname'] = $rs->campos["nombreordenador"];
+			array_push($response['clients'], $tmp);
+			$rs->Siguiente();
+		}
+		jsonResponse(200, $response);
+	}
+	$rs->Cerrar(); 
+    }
+);
+
+// Obtener datos de un cliente.
+$app->get('/ous/:ouid/labs/:labid/clients/:clntid', 'validateApiKey',
+    function($ouid, $labid, $clntid) {
+	global $cmd;
+
+	$ouid = htmlspecialchars($ouid);
+	$labid = htmlspecialchars($labid);
+	$clntid = htmlspecialchars($clntid);
+	$cmd->texto = "SELECT * FROM ordenadores WHERE idordenador='$clntid';";
+	$rs=new Recordset;
+	$rs->Comando=&$cmd;
+	if (!$rs->Abrir()) return(false); // Error al abrir recordset
+	$rs->Primero();
+//	if ($labid != $rs->campos["idaula"]) ...
+	if (checkParameter($rs->campos["idordenador"])) {
+		$response['error'] = false;
+		$response['clientid'] = $rs->campos["idordenador"];
+		$response['clientname'] = $rs->campos["nombreordenador"];
+		$response['netiface'] = $rs->campos["netiface"];
+		$response['netdriver'] = $rs->campos["netdriver"];
+		$response['mac'] = $rs->campos["mac"];
+		$response['ip'] = $rs->campos["ip"];
+		$response['netmask'] = $rs->campos["mascara"];
+		$response['routerip'] = $rs->campos["router"];
+		$response['repoid'] = $rs->campos["idrepositorio"];
+		//$response['hardprofid'] = $rs->campos["idperfilhard"];
+		//$response['menuid'] = $rs->campos["idmenu"];
+		//$response['validation'] = $rs->campos["arranque"]==0 ? false: true;
+		//$response['boottype'] = $rs->campos["arranque"];
+		jsonResponse(200, $response);
+	}
+	$rs->Cerrar(); 
+    }
+);
+
+// Obtener la configuración de hardware de un cliente.
+$app->get('/ous/:ouid/labs/:labid/clients/:clntid/hardware', 'validateApiKey',
+    function($ouid, $labid, $clntid) {
+	global $cmd;
+
+	$ouid = htmlspecialchars($ouid);
+	$labid = htmlspecialchars($labid);
+	$clntid = htmlspecialchars($clntid);
+	$cmd->texto = <<<EOD
+SELECT ordenadores.idordenador, ordenadores.nombreordenador,
+       tipohardwares.nemonico, hardwares.descripcion
+  FROM perfileshard
+ RIGHT JOIN ordenadores USING(idperfilhard)
+  JOIN perfileshard_hardwares USING(idperfilhard)
+  JOIN hardwares ON perfileshard_hardwares.idhardware=hardwares.idhardware
+  JOIN tipohardwares ON tipohardwares.idtipohardware=hardwares.idtipohardware
+ WHERE ordenadores.idordenador='$clntid'
+EOD;
+	$rs=new Recordset;
+	$rs->Comando=&$cmd;
+	if (!$rs->Abrir()) return(false); // Error al abrir recordset
+	$rs->Primero();
+//	if ($ouid != $rs->campos["idcentro"]) ...
+//	if ($labid != $rs->campos["idaula"]) ...
+	if (checkParameter($rs->campos["idordenador"])) {
+		$response['error'] = false;
+		$response['clientid'] = $rs->campos["idordenador"];
+		$response['clientname'] = $rs->campos["nombreordenador"];
+		$response['hardware'] = array();
+		while (!$rs->EOF) {
+			$tmp = array();
+			$tmp['type'] = $rs->campos["nemonico"];
+			$tmp['description'] = $rs->campos["descripcion"];
+			array_push($response['hardware'], $tmp);
+			$rs->Siguiente();
+		}
+		jsonResponse(200, $response);
+	}
+	$rs->Cerrar(); 
+    }
+);
+
+// Obtener datos de configuración de discos del cliente.
+$app->get('/ous/:ouid/labs/:labid/clients/:clntid/diskcfg', 'validateApiKey',
+    function($ouid, $labid, $clntid) {
+	global $cmd;
+
+	$ouid = htmlspecialchars($ouid);
+	$labid = htmlspecialchars($labid);
+	$clntid = htmlspecialchars($clntid);
+	$cmd->texto = <<<EOD
+SELECT ordenadores.idordenador AS clientid, ordenadores.nombreordenador,
+       ordenadores_particiones.*, tipospar.tipopar,
+       sistemasficheros.nemonico, nombresos.nombreso, imagenes.nombreca
+  FROM ordenadores_particiones
+ RIGHT JOIN ordenadores USING(idordenador)
+  LEFT JOIN tipospar USING(codpar)
+  LEFT JOIN sistemasficheros USING(idsistemafichero)
+  LEFT JOIN nombresos USING(idnombreso)
+  LEFT JOIN imagenes USING(idimagen)
+ WHERE ordenadores.idordenador='$clntid'
+ ORDER BY numdisk ASC, numpar ASC;
+EOD;
+	$rs=new Recordset;
+	$rs->Comando=&$cmd;
+	if (!$rs->Abrir()) return(false); // Error al abrir recordset
+	$rs->Primero();
+//	if ($labid != $rs->campos["idaula"]) ...
+	if (checkParameter($rs->campos["clientid"])) {
+		$response['error'] = false;
+		$response['clientid'] = $rs->campos["clientid"];
+		$response['clientname'] = $rs->campos["nombreordenador"];
+		$response['diskcfg'] = array();
+		while (!$rs->EOF) {
+			if ($rs->campos["numdisk"] == 0) {
+				$rs->Siguiente();
+				continue;
+			}
+			$tmp = array();
+			if ($rs->campos["numpar"] == 0) {
+				$tmp['disk'] = $rs->campos["numdisk"];
+				switch ($rs->campos["codpar"]) {
+					case 1:  $tmp['parttable'] = "MSDOS"; break;
+					case 2:  $tmp['parttable'] = "GPT"; break;
+					case 3:  $tmp['parttable'] = "LVM"; break;
+					case 4:  $tmp['parttable'] = "ZPOOL"; break;
+					default: $tmp['parttable'] = $rs->campos["codpar"];
+				}
+				$tmp['size'] = $rs->campos["tamano"];
+			} else {
+				$tmp['partition'] = $rs->campos["numpar"];
+				$tmp['parttype'] = $rs->campos["tipopar"];
+				$tmp['filesystem'] = $rs->campos["nemonico"];
+				$tmp['size'] = $rs->campos["tamano"];
+				$tmp['usage'] = $rs->campos["uso"];
+				if ($rs->campos["nombreso"] != null) {
+					$tmp['os'] = $rs->campos["nombreso"];
+					$tmp['imageid'] = $rs->campos["idimagen"];
+					$tmp['deploydate'] = $rs->campos["fechadespliegue"];
+					// Comprobar si la imagen está actualizada.
+					//$tmp['updated'] = indica si la imagen está actualizada
+				}
+				//$tmp['cachedata'] = $rs->campos["cache"];
+			}
+			array_push($response['diskcfg'], $tmp);
+			$rs->Siguiente();
+		}
+		jsonResponse(200, $response);
+	}
+	$rs->Cerrar(); 
+    }
+);
+
+// Obtener estado de ejecución del cliente.
+$app->get('/ous/:ouid/labs/:labid/clients/:clntid/status', 'validateApiKey',
+    function($ouid, $labid, $clntid) {
+	global $cmd;
+	global $LONCABECERA;
+	global $LONHEXPRM;
+
+	// Parameters.
+	$ouid = htmlspecialchars($ouid);
+	$labid = htmlspecialchars($labid);
+	$clntid = htmlspecialchars($clntid);
+
+	// Database query.
+	$cmd->texto = <<<EOD
+SELECT serv.ipserveradm, serv.portserveradm, clnt.idordenador, clnt.ip
+  FROM entornos AS serv, ordenadores AS clnt
+ WHERE clnt.idordenador='$clntid';
+EOD;
+	$rs=new Recordset;
+	$rs->Comando=&$cmd;
+	if (!$rs->Abrir()) return(false); // Error al abrir recordset
+	$rs->Primero();
+	if (checkParameter($rs->campos["idordenador"])) {
+		//
+		// Probar primero el estado de OGAgent y luego de ogAdmClient
+		//
+
+		$serverip = $rs->campos["ipserveradm"];
+		$serverport = $rs->campos["portserveradm"];
+		$clientid = $rs->campos["idordenador"];
+		$clientip = $rs->campos["ip"];
+
+		// Connect to reset client's status.
+		$reqframe = "nfn=Sondeo\r".
+			    "ido=$clientid\r".
+			    "iph=$clientip\r";
+		$result = sendCommand($serverip, $serverport, $reqframe, $values);
+
+		// Connect to fetch client's status.
+		// Asuming client is off by default.
+		$values["tso"]="OFF";
+		// Iterate to check client's status.
+		// Exit if status!=OFF or end iterations (status=OFF).
+		$maxIter = 30;
+		for ($i=1; $i<$maxIter and preg_match('/OFF/', $values["tso"]); $i++) {
+			// Connect to check status.
+			$reqframe = "nfn=respuestaSondeo\r".
+				    "ido=$clientid\r".
+				    "iph=$clientip\r";
+			$result = sendCommand($serverip, $serverport, $reqframe, $values);
+			// Wait until next checking (0.1 ms).
+			usleep(100000);
+		}
+
+		// Parse status response.
+		if ($result) {
+			// Check status type.
+			if (checkParameter($values["tso"])) {
+				// Compose JSON response.
+				$response['error'] = false;
+				$response['clientid'] = $clientid;
+				$response['ip'] = $clientip;
+				$stat = array();
+				preg_match('/\/[A-Z]*;/', $values["tso"], $stat);
+				// Check if data exists.
+				if (empty($stat[0])) {
+					$response['status'] = "nodata";
+				} else {
+					// Status mapping.
+					$status = array('OFF'=>"off",
+							'INI'=>"initializing",
+							'OPG'=>"ogclient",
+							'BSY'=>"busy",
+							'LNX'=>"linux",
+							'WIN'=>"windows");
+					$response['status'] = $status[substr($stat[0], 1, 3)];
+					if (empty($response['status'])) {
+						$response['status'] = "unknown";
+					}
+				}
+				jsonResponse(200, $response);
+			}
+		} else {
+			// Access error.
+			$response['error'] = true;
+			$response['message'] = "Cannot access to OpenGnsys server";
+			jsonResponse(500, $response);
+		}
+	}
+	$rs->Cerrar(); 
+    }
+);
+
+
+// Listar repositorios.
+$app->get('/ous/:ouid/repos', 'validateApiKey',
+    function($ouid) {
+	global $cmd;
+
+	$ouid = htmlspecialchars($ouid);
+	// Listar las salas de la UO si el usuario de la apikey es su admin.
+	// Consulta temporal,
+	$cmd->texto = "SELECT * FROM repositorios WHERE idcentro='$ouid';";
+	$rs=new Recordset;
+	$rs->Comando=&$cmd;
+	if (!$rs->Abrir()) return(false); // Error al abrir recordset
+	$rs->Primero();
+	// Comprobar que exista la UO.
+	if (checkParameter($rs->campos["idcentro"])) {
+		$response['error'] = false;
+		$response['ouid'] = $ouid;
+		$response['repos'] = array();
+		while (!$rs->EOF) {
+			$tmp = array();
+			$tmp['repoid'] = $rs->campos["idrepositorio"];
+			$tmp['reponame'] = $rs->campos["nombrerepositorio"];
+			array_push($response['repos'], $tmp);
+			$rs->Siguiente();
+		}
+		jsonResponse(200, $response);
+	}
+	$rs->Cerrar(); 
+    }
+);
+
+// Obtener datos de un repositorio.
+$app->get('/ous/:ouid/repos/:repoid', 'validateApiKey',
+    function($ouid, $repoid) {
+	global $cmd;
+
+	$ouid = htmlspecialchars($ouid);
+	$repoid = htmlspecialchars($repoid);
+	$cmd->texto = "SELECT * FROM repositorios WHERE idrepositorio='$repoid';";
+	$rs=new Recordset;
+	$rs->Comando=&$cmd;
+	if (!$rs->Abrir()) return(false); // Error al abrir recordset
+	$rs->Primero();
+	// Comprobar que exista el repositorio.
+	if (checkParameter($rs->campos["idrepositorio"])) {
+		$response['error'] = false;
+		$response['repoid'] = $rs->campos["idrepositorio"];
+		$response['reponame'] = $rs->campos["nombrerepositorio"];
+		$response['description'] = $rs->campos["comentarios"];
+		$response['ipaddress'] = $rs->campos["ip"];
+		//$response['port'] = $rs->campos["puertorepo"];
+		jsonResponse(200, $response);
+	}
+	$rs->Cerrar(); 
+    }
+);
+
+// Listar imágenes.
+$app->get('/ous/:ouid/images', 'validateApiKey',
+    function($ouid) {
+	global $cmd;
+
+	$ouid = htmlspecialchars($ouid);
+	// Listar las salas de la UO si el usuario de la apikey es su admin.
+	// Consulta temporal,
+	$cmd->texto = "SELECT * FROM imagenes WHERE idcentro='$ouid';";
+	$rs=new Recordset;
+	$rs->Comando=&$cmd;
+	if (!$rs->Abrir()) return(false); // Error al abrir recordset
+	// Comprobar que exista la UO.
+	$rs->Primero();
+	if (checkParameter($rs->campos["idcentro"])) {
+		$response['error'] = false;
+		$response['ouid'] = $ouid;
+		$response['images'] = array();
+		while (!$rs->EOF) {
+			$tmp = array();
+			$tmp['imageid'] = $rs->campos["idimagen"];
+			$tmp['imagename'] = $rs->campos["nombreca"];
+			$tmp['inremotepc'] = $rs->campos["inremotepc"]==0 ? false: true;
+			array_push($response['images'], $tmp);
+			$rs->Siguiente();
+		}
+		jsonResponse(200, $response);
+	}
+    }
+);
+
+// Obtener datos de una imagen.
+$app->get('/ous/:ouid/images/:imgid', 'validateApiKey',
+    function($ouid, $imgid) {
+	global $cmd;
+
+	$ouid = htmlspecialchars($ouid);
+	$imgid = htmlspecialchars($imgid);
+	$cmd->texto = "SELECT * FROM imagenes WHERE idimagen='$imgid';";
+	$rs=new Recordset;
+	$rs->Comando=&$cmd;
+	if (!$rs->Abrir()) return(false); // Error al abrir recordset
+	$rs->Primero();
+	// Comprobar que exista el repositorio.
+	if (checkParameter($rs->campos["idimagen"])) {
+		$response['error'] = false;
+		$response['imageid'] = $rs->campos["idimagen"];
+		$response['imagename'] = $rs->campos["nombreca"];
+		$response['description'] = $rs->campos["descripcion"];
+		$response['comments'] = $rs->campos["comentarios"];
+		$response['inremotepc'] = $rs->campos["inremotepc"]==0 ? false: true;
+		$response['repoid'] = $rs->campos["idrepositorio"];
+		switch ($rs->campos["tipo"]) {
+			case 1:  $response['type'] = "monolithic"; break;
+			case 2:  $response['type'] = "base"; break;
+			case 3:  $response['type'] = "incremental";
+				 $response['baseimg'] = $rs->campos["imagenid"];
+				 $response['path'] = $rs->campos["ruta"];
+				 break;
+			default: $response['type'] = $rs->campos["tipo"];
+		}
+		if ($rs->campos["idordenador"] != 0) {
+			$response['clientid'] = $rs->campos["idordenador"];
+			$response['disk'] = $rs->campos["numdisk"];
+			$response['partition'] = $rs->campos["numpar"];
+			$response['creationdate'] = $rs->campos["fechacreacion"];
+			//$response['imagerelease'] = revisión de la aimagen
+		}
+		jsonResponse(200, $response);
+	}
+	$rs->Cerrar(); 
+    }
+);
+
+// Lista de softeare instalado en una imagen.
+$app->get('/ous/:ouid/images/:imgid/software', 'validateApiKey',
+    function($ouid, $imgid) {
+	global $cmd;
+
+	$ouid = htmlspecialchars($ouid);
+	$imgid = htmlspecialchars($imgid);
+	$cmd->texto = <<<EOD
+SELECT imagenes.idimagen, imagenes.nombreca, softwares.descripcion
+  FROM perfilessoft
+ RIGHT JOIN imagenes USING(idperfilsoft)
+  LEFT JOIN perfilessoft_softwares USING(idperfilsoft)
+  LEFT JOIN softwares USING(idsoftware)
+ WHERE imagenes.idimagen='$imgid'
+ ORDER BY softwares.descripcion ASC;
+EOD;
+	$rs=new Recordset;
+	$rs->Comando=&$cmd;
+	if (!$rs->Abrir()) return(false);	// Error al abrir recordset
+	$rs->Primero();
+	// Comprobar que exista el repositorio.
+	if (checkParameter($rs->campos["idimagen"])) {
+		$response['error'] = false;
+		$response['imageid'] = $rs->campos["idimagen"];
+		$response['imagename'] = $rs->campos["nombreca"];
+		$response['software'] = array();
+		while (!$rs->EOF) {
+			if ($rs->campos["descripcion"] == null) {
+				$rs->Siguiente();
+				continue;
+			}
+			$tmp = array();
+			$tmp['application'] = $rs->campos["descripcion"];
+			array_push($response['software'], $tmp);
+			$rs->Siguiente();
+		}
+		jsonResponse(200, $response);
+	}
+	$rs->Cerrar(); 
+    }
+);
+
+// Arrancar un ordenador con una imagen instalada, elegido al azar.
+$app->get('/ous/:id1/images/:id2/boot', 'validateApiKey',
+    function($ouid, $imageid) {
+	global $cmd;
+	global $AMBITO_ORDENADORES;
+	global $EJECUCION_COMANDO;
+	global $ACCION_INICIADA;
+	global $ACCION_SINRESULTADO;
+
+	// Pparameters.
+	$ouid = htmlspecialchars($ouid);
+	$imegeid = htmlspecialchars($imageid);
+	// Boot 1 client.
+	$nclients = 1;
+
+	// Query: server data and all clients' boot data availabe for Remote PC with this image installed (random order).
+	$cmd->texto = <<<EOD
+SELECT s.ipserveradm, s.portserveradm,
+       c.idordenador, c.ip, c.mac, p.numdisk, p.numpar
+  FROM entornos AS s, ordenadores AS c
+  JOIN aulas USING(idaula)
+  JOIN centros USING(idcentro)
+  JOIN ordenadores_particiones AS p USING(idordenador)
+  JOIN imagenes USING(idimagen)
+ WHERE centros.idcentro='$ouid'
+   AND aulas.inremotepc=1
+   AND imagenes.idimagen='$imageid'
+   AND imagenes.inremotepc=1
+ ORDER BY RAND();
+EOD;
+	$rs=new Recordset;
+	$rs->Comando=&$cmd;
+	if (!$rs->Abrir()) return(false);	// Error oppening recordset.
+	$rs->Primero();
+	if (checkParameter($rs->campos["ipserveradm"])) {
+
+		$response['error'] = false;
+		$response['imageid'] = $imageid;
+		$response['sendto'] = array();
+
+		// AVISO: Procesar datos del servidor (solo 1er registro).
+
+		$serverip = $rs->campos["ipserveradm"];
+		$serverport = $rs->campos["portserveradm"];
+
+		// AVISO: Procesar datos de los clientes.
+
+		$clientid = array();
+		$clientip = array();
+		$clientmac = array();
+		$clientdisk = array();
+		$clientpart = array();
+		while (!$rs->EOF) {
+			array_push($clientid, $rs->campos["idordenador"]);
+			array_push($clientip, $rs->campos["ip"]);
+			array_push($clientmac, $rs->campos["mac"]);
+			array_push($clientdisk, $rs->campos["numdisk"]);
+			array_push($clientpart, $rs->campos["numpar"]);
+			$rs->Siguiente();
+		}
+		$rs->Cerrar(); 
+
+		// AVISO: consultar el estado de todos los clientes y
+		//        quitar aquellos que no tengan "OFF", "OPG" o ""
+		//        (estudiar si incluir los "BSY")
+
+		// Reset clients' status.
+		$reqframe = "nfn=Sondeo\r".
+			    "ido=".implode(',', $clientid)."\r".
+			    "iph=".implode(';', $clientip)."\r";
+		sendCommand($serverip, $serverport, $reqframe, $values);
+		 // Wait to get response.
+		sleep(3);
+		// Connect to check status.
+		$reqframe = "nfn=respuestaSondeo\r".
+			    "ido=".implode(',', $clientid)."\r".
+			    "iph=".implode(';', $clientip)."\r";
+		sendCommand($serverip, $serverport, $reqframe, $values);
+		// Check status type.
+		if (isset($values["tso"])) {
+			preg_match_all('/[A-Z]{3}/', $values["tso"], $stat);
+		}
+		if (isset($stat[0])) {
+			for ($i=0; $i<sizeof($stat[0]); $i++) {
+				if (! in_array($stat[0][$i], array("OFF", "OPG", ""))) {
+					unset($clientid[$i]);
+					unset($clientip[$i]);
+					unset($clientmac[$i]);
+					unset($clientdisk[$i]);
+					unset($clientpart[$i]);
+				}
+			}
+		}
+
+		// AVISO: el siguiente código inicia un único cliente.
+		//        Para iniciar varios: 
+		//	  - id. clientes separados por carácter ','.
+		//	  - IP clientes separadas por carácter ';'
+		//	  - MAC clientes separadas por carácter ';'
+
+		// Executing boot command.
+		$reqframe = "nfn=Arrancar\r".
+			    "ido=".implode(',', $clientid)."\r".
+			    "iph=".implode(';', $clientip)."\r".
+			    "mac=".implode(';', $clientmac)."\r".
+			    "mar=1\r";
+echo "req=".str_replace("\r"," ",$reqframe).".\n";
+		sendCommand($serverip, $serverport, $reqframe, $values);
+		if ($values["res"]) {
+print_r($values);
+			$tmp = array();
+			for ($i=0, $boot=0; $i<sizeof($clientid) and $boot!=1; $i++) {
+				$reqframe = "nfn=IniciarSesion\r".
+					    "ido=".$clientid[$i]."\r".
+					    "iph=".$clientip[$i]."\r".
+					    "dsk=".$clientdisk[$i]."\r".
+					    "par=".$clientpart[$i]."\r";
+echo "i=$i: req=".str_replace("\r"," ",$reqframe).".\n";
+				sendCommand($serverip, $serverport, $reqframe, $values);
+				if ($values["res"]) {
+
+					// AVISO: incluir comando Iniciar sesión en cola de acciones.
+					$timestamp=time();
+					$cmd->texto = <<<EOD
+INSERT INTO acciones
+	SET tipoaccion=$EJECUCION_COMANDO,
+	    idtipoaccion=9,
+	    idcomando=9,
+	    parametros='nfn=IniciarSesion\rdsk=$clientdisk[$i]\rpar=$clientpart[$i]',
+	    descriaccion='RemotePC Session',
+	    idordenador=$clientid[$i],
+	    ip='$clientip[$i]',
+	    sesion=$timestamp,
+	    fechahorareg=NOW(),
+	    estado=$ACCION_INICIADA,
+	    resultado=$ACCION_SINRESULTADO,
+	    ambito=$AMBITO_ORDENADORES,
+	    idambito=$clientid[$i],
+	    restrambito='$clientip[$i]',
+	    idcentro=$ouid;
+EOD;
+					$result = $cmd->Ejecutar();
+					if ($result) {
+						$tmp['clientid'] = $clientid[$i];
+						$tmp['ip'] = $clientip[$i];
+						$tmp['mac'] = $clientmac[$i];
+						array_push($response['sendto'], $tmp);
+						$boot = 1;
+					}
+				}
+			}
+		}
+		jsonResponse(200, $response);
+	}
+    }
+);
+// Alternativa como método GET.
+//$app->get('/ous/:id1/images/:id2/boot/:number', 'validateApiKey',
+//    function($ouid, $imageid, $number) {
+//
+//   }
+//);
+
+// Include repository routes.
+include("repository.php");
+
+// Include OGAgent push routes.
+include("ogagent.php");
+
+// Execute REST using Slim.
+$app->run();
+
+?>
+