Context Navigation

server.php @ 6acd145

Visit:

918-git-images-111dconfigfileconfigure-oglivegit-imageslgromero-new-oglivemainmaint-cronmount-efivarfsmultivmmultivm-ogboot-installerogClonningEngineogboot-installer-jenkinsoglive-ipv6test-python-scriptsticket-301ticket-50ticket-50-oldticket-577ticket-585ticket-611ticket-612ticket-693ticket-700ubu24tplunification2use-local-agent-oglivevarios-instalacionwebconsole3

Last change on this file since 6acd145 was 606a0c7, checked in by ramon <ramongomez@…>, 8 years ago

#708: Ampliar respuestas REST:

/ous/:ouid/labs incluye datos de grupos de ordenadores.
/info incluye datos de cliente "ogclient" instalado.

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

Property mode set to 100644

File size: 33.0 KB

Rev	Line
[fb2ee20]	1	<?php
	2	/**
	3	* @file index.php
[3551804]	4	* @brief OpenGnsys Server REST API manager.
[fb2ee20]	5	* @warning All input and output messages are formatted in JSON.
	6	* @note Some ideas are based on article "How to create REST API for Android app using PHP, Slim and MySQL" by Ravi Tamada, thanx.
	7	* @license GNU GPLv3+
	8	* @author Ramón M. Gómez, ETSII Univ. Sevilla
[3551804]	9	* @version 1.1.0 - First version
[ac8b234e]	10	* @date 2016-09-19
[fb2ee20]	11	*/
	12
	13
	14	// Auxiliar functions.
	15
	16	/**
	17	* @brief Validate API key included in "Authorization" HTTP header.
	18	* @return JSON response on error.
	19	*/
	20	function validateApiKey() {
	21	global $cmd;
	22	global $userid;
	23	$response = array();
	24
	25	// Read Authorization HTTP header.
	26	$headers = apache_request_headers();
	27	if (! empty($headers['Authorization'])) {
	28	// Assign user id. that match this key to global variable.
	29	$apikey = htmlspecialchars($headers['Authorization']);
	30	$cmd->texto = "SELECT idusuario
	31	FROM usuarios
	32	WHERE apikey='$apikey'";
	33	$rs=new Recordset;
	34	$rs->Comando=&$cmd;
	35	if ($rs->Abrir()) {
	36	$rs->Primero();
	37	if (!$rs->EOF){
	38	// Fetch user id.
	39	$userid = $rs->campos["idusuario"];
	40	} else {
	41	// Credentials error.
	42	$response['message'] = 'Login failed. Incorrect credentials';
	43	jsonResponse(401, $response);
	44	$app->stop();
	45	}
	46	$rs->Cerrar();
	47	} else {
	48	// Access error.
	49	$response['message'] = "An error occurred, please try again";
	50	jsonResponse(500, $response);
	51	}
	52	} else {
	53	// Error: missing API key.
[29bc749]	54	$response['message'] = 'Missing API key';
[fb2ee20]	55	jsonResponse(400, $response);
	56	$app->stop();
	57	}
	58	}
	59
	60	/**
	61	* @brief Check if parameter is set and print error messages if empty.
	62	* @param string param Parameter to check.
	63	* @return boolean "false" if parameter is null, otherwise "true".
	64	*/
	65	function checkParameter($param) {
	66	if (isset($param)) {
	67	return true;
	68	} else {
	69	// Print error message.
	70	$response['message'] = 'Parameter not found';
	71	jsonResponse(400, $response);
	72	return false;
	73	}
	74	}
	75
	76	/**
	77	* @brief Check if user is administrator and print error messages if not.
	78	* @param int adminid Administrator id.
	79	* @return boolean "true" if admin id. is equals to global user id., otherwise "false".
	80	*/
	81	function checkAdmin($adminid) {
	82	global $userid;
	83
	84	if ($adminid == $userid) {
	85	return true;
	86	} else {
	87	// Print error message.
	88	$response['message'] = 'Cannot access this resource';
	89	jsonResponse(401, $response);
	90	return false;
	91	}
	92	}
	93
[606a0c7]	94	/**
	95	* @fn addClassroomGroup(&$classroomGroups, $rs)
	96	* @brief Funcion privada usada para añadir grupos de aulas recursivamente
	97	* @param classroomGroups Grupos de aulas que pueden contener más grupos
	98	* @param rs resultset de la consulta a la base de datos.
	99	*/
	100	function addClassroomGroup(&$classroomGroups, $rs){
	101
	102	array_walk($classroomGroups, function(&$group,$key){
	103	global $rs;
	104	if (isset($group['id']) && $group['id'] === $rs->campos["group_group_id"]) {
	105	array_push($group["classroomGroups"],array("id" => $rs->campos["group_id"],
	106	"name" => $rs->campos["nombregrupoordenador"],
	107	"comments" => $rs->campos["comentarios"],
	108	"classroomGroups" => array()));
	109	}
	110	else if(count($group["classroomGroups"]) > 0){
	111	addClassroomGroup($group["classroomGroups"], $rs);
	112	}
	113	/**/
	114	});
	115	}
[fb2ee20]	116
	117	/**
[ac8b234e]	118	* @fn sendCommand($serverip, $serverport, $reqframe, &$values)
[fb2ee20]	119	* @brief Send a command to an OpenGnsys ogAdmServer and get request.
	120	* @param string serverip Server IP address.
	121	* @param string serverport Server port.
	122	* @param string reqframe Request frame (field's separator is "\r").
	123	* @param array values Response values (out parameter).
	124	* @return boolean "true" if success, otherwise "false".
	125	*/
	126	function sendCommand($serverip, $serverport, $reqframe, &$values) {
	127	global $LONCABECERA;
	128	global $LONHEXPRM;
	129
	130	// Connect to server.
	131	$respvalues = "";
	132	$connect = new SockHidra($serverip, $serverport);
	133	if ($connect->conectar()) {
	134	// Send request frame to server.
	135	$result = $connect->envia_peticion($reqframe);
	136	if ($result) {
	137	// Parse request frame.
	138	$respframe = $connect->recibe_respuesta();
	139	$connect->desconectar();
	140	$paramlen = hexdec(substr($respframe, $LONCABECERA, $LONHEXPRM));
	141	$params = substr($respframe, $LONCABECERA+$LONHEXPRM, $paramlen);
	142	// Fetch values and return result.
	143	$values = extrae_parametros($params, "\r", '=');
	144	return ($values);
	145	} else {
	146	// Return with error.
	147	return (false);
	148	}
	149	} else {
	150	// Return with error.
	151	return (false);
	152	}
	153	}
	154
[3551804]	155	// REST routes.
[fb2ee20]	156
	157	/**
	158	* @brief user login.
	159	* @note Route: /login, Method: POST
	160	* @param string username User name.
	161	* @param string password User password.
	162	* @return string JSON response with user id. and API key.
	163	* @note User's API key is stored in a new field of "usuarios" table.
	164	*/
	165	$app->post('/login',
	166	function() use ($app) {
	167	global $cmd;
	168	global $userid;
	169
	170	$response = array();
	171
	172	// Reading JSON parameters.
	173	try {
	174	$input = json_decode($app->request()->getBody());
	175	$user = htmlspecialchars($input->username);
	176	$pass = htmlspecialchars($input->password);
	177	} catch (Exception $e) {
[29bc749]	178	// Error message.
[fb2ee20]	179	$response["message"] = $e->getMessage();
	180	jsonResponse(400, $response);
	181	$app->stop();
	182	}
	183
[3551804]	184	// Checking parameters.
[fb2ee20]	185	if (! empty($user) and ! empty($pass)) {
	186	// Database query.
	187	$cmd->texto = "SELECT idusuario, apikey
	188	FROM usuarios
	189	WHERE usuario='$user' AND pasguor='$pass'";
	190	$rs=new Recordset;
	191	$rs->Comando=&$cmd;
	192	if ($rs->Abrir()) {
	193	$rs->Primero();
	194	if (!$rs->EOF){
	195	// JSON response.
	196	$userid=$rs->campos["idusuario"];
	197	$apikey=$rs->campos["apikey"];
	198	$response['userid'] = $userid;
	199	$response['apikey'] = $apikey;
	200	jsonResponse(200, $response);
	201	} else {
	202	// Credentials error.
	203	$response['message'] = 'Login failed. Incorrect credentials';
	204	jsonResponse(401, $response);
	205	$app->stop();
	206	}
	207	$rs->Cerrar();
	208	} else {
	209	// Access error.
	210	$response['message'] = "An error occurred. Please try again";
	211	jsonResponse(500, $response);
	212	$app->stop();
	213	}
	214	} else {
	215	# Error: missing some input parameter.
	216	$response['message'] = 'Missing username or password';
	217	jsonResponse(400, $response);
	218	$app->stop();
	219	}
	220	}
	221	);
	222
	223	/**
	224	* @brief List all defined Organizational Units
	225	* @note Route: /ous, Method: GET
	226	* @param no
[1485b99]	227	* @return JSON array with id. and name for every defined OU
[fb2ee20]	228	*/
[fe5b8d2]	229	$app->get('/ous', function() {
[fb2ee20]	230	global $cmd;
	231
	232	$cmd->texto = "SELECT * FROM centros";
	233	$rs=new Recordset;
	234	$rs->Comando=&$cmd;
	235	if (!$rs->Abrir()) return(false); // Error al abrir recordset
[4a511f81]	236	$response = array();
[fb2ee20]	237	$rs->Primero();
	238	while (!$rs->EOF) {
	239	$tmp = array();
[1485b99]	240	$tmp['id'] = $rs->campos["idcentro"];
	241	$tmp['name'] = $rs->campos["nombrecentro"];
[4a511f81]	242	array_push($response, $tmp);
[fb2ee20]	243	$rs->Siguiente();
	244	}
	245	$rs->Cerrar();
	246	jsonResponse(200, $response);
[3551804]	247	}
[fb2ee20]	248	);
	249
	250	/**
	251	* @brief Get Organizational Unit data
	252	* @note Route: /ous/id, Method: GET
	253	* @param id OU id.
[1485b99]	254	* @return JSON string with OU's parameters
[fb2ee20]	255	*/
	256	$app->get('/ous/:ouid', 'validateApiKey',
	257	function($ouid) {
	258	global $cmd;
	259
	260	$ouid = htmlspecialchars($ouid);
	261	$cmd->texto = "SELECT * FROM centros WHERE idcentro='$ouid';";
	262	$rs=new Recordset;
	263	$rs->Comando=&$cmd;
	264	if (!$rs->Abrir()) return(false); // Error al abrir recordset
	265	$rs->Primero();
	266	if (checkParameter($rs->campos["nombrecentro"])) {
[bbc672f]	267	$response['id'] = $ouid;
	268	$response['name'] = $rs->campos["nombrecentro"];
[fb2ee20]	269	$response['description'] = $rs->campos["comentarios"];
	270	jsonResponse(200, $response);
	271	}
	272	$rs->Cerrar();
	273	}
	274	);
	275
[23a72c0]	276	// Listar grupos.
	277	$app->get('/ous/:ouid/groups', 'validateApiKey', function($ouid) {
	278	global $cmd;
	279	global $userid;
	280
	281	$ouid = htmlspecialchars($ouid);
	282	if(checkAdmin($userid, $ouid) == true){
	283	// Listar las salas de la UO si el usuario de la apikey es su admin.
	284	// Consulta temporal,
	285	$cmd->texto = "SELECT * FROM grupos WHERE idcentro='$ouid';";
	286	$rs=new Recordset;
	287	$rs->Comando=&$cmd;
	288	if (!$rs->Abrir()) return(false); // Error al abrir recordset
	289	$rs->Primero();
	290	// Comprobar que exista la UO.
	291	if (checkParameter($rs->campos["idcentro"])) {
	292	$response = array();
	293	while (!$rs->EOF) {
	294	$tmp = array();
	295	$tmp['id'] = $rs->campos["idgrupo"];
	296	$tmp['name'] = $rs->campos["nombregrupo"];
	297	$tmp['type'] = $rs->campos["tipo"];
	298	$tmp['comments'] = $rs->campos["comentarios"];
	299	if($rs->campos["grupoid"] != 0){
	300	$tmp['parent']['id'] = $rs->campos["grupoid"];
	301	}
	302	array_push($response, $tmp);
	303	$rs->Siguiente();
	304	}
	305	jsonResponse(200, $response);
	306	}
	307	$rs->Cerrar();
	308	}
	309	}
	310	);
	311
[ac8b234e]	312	/**
	313	* @brief List all labs defined in an OU
	314	* @note Route: /ous/id/labs, Method: GET
	315	* @param id OU id.
	316	* @return JSON string with all UO's labs parameters
	317	*/
[fb2ee20]	318	$app->get('/ous/:ouid/labs', 'validateApiKey',
	319	function($ouid) {
[606a0c7]	320	global $userid;
[fb2ee20]	321	global $cmd;
[606a0c7]	322	global $rs;
[fb2ee20]	323
	324	$ouid = htmlspecialchars($ouid);
	325	// Listar las salas de la UO si el usuario de la apikey es su admin.
	326	$cmd->texto = <<<EOD
[606a0c7]	327	SELECT aulas.*, adm.idadministradorcentro, grp.idgrupo AS group_id,
	328	grp.nombregrupoordenador, grp.grupoid AS group_group_id, grp.comentarios
[fb2ee20]	329	FROM aulas
	330	RIGHT JOIN administradores_centros AS adm USING(idcentro)
	331	RIGHT JOIN usuarios USING(idusuario)
[606a0c7]	332	LEFT JOIN gruposordenadores AS grp USING(idaula)
	333	WHERE idcentro='$ouid' AND adm.idadministradorcentro = '$userid'
	334	ORDER BY aulas.idaula, grp.idgrupo
[fb2ee20]	335	EOD;
	336	$rs=new Recordset;
	337	$rs->Comando=&$cmd;
[606a0c7]	338	if (!$rs->Abrir()) return(false); // Error opening recordset.
[fb2ee20]	339	// Comprobar que exista la UO y que el usuario sea su administrador.
	340	$rs->Primero();
	341	if (checkParameter($rs->campos["idcentro"]) and checkAdmin($rs->campos["idadministradorcentro"])) {
[4a511f81]	342	$response = array();
[fb2ee20]	343	while (!$rs->EOF) {
[606a0c7]	344	// En los resultados las aulas vienen repetidas tantas veces como grupos tengan, solo dejamos uno
	345	$classroomIndex = -1;
	346	$found=false;
	347	$index = 0;
	348	while(!$found && $index < count($response)){
	349	if(isset($response[$index]["id"]) && $response[$index]["id"] == $rs->campos["idaula"]){
	350	$classroomIndex = $index;
	351	$found = true;
	352	}
	353	$index++;
	354	}
	355	if(!$found){
	356	$tmp = array();
	357	$tmp['id'] = $rs->campos["idaula"];
	358	$tmp['name'] = $rs->campos["nombreaula"];
	359	$tmp['inremotepc'] = $rs->campos["inremotepc"]==0 ? false: true;
	360	$tmp['group']['id'] = $rs->campos["grupoid"];
	361	$tmp['ou']['id'] = $ouid;
	362	array_push($response, $tmp);
	363	}
	364	else{
	365	// Le añadimos el grupo en cuestion siempre que no sea un subgrupo
	366	if($rs->campos["group_group_id"] == 0){
	367	array_push($response[$classroomIndex]['classroomGroups'],
	368	array("id" => $rs->campos["group_id"],
	369	"name" => $rs->campos["nombregrupoordenador"],
	370	"comments" => $rs->campos["comentarios"],
	371	"classroomGroups" => array()));
	372	}
	373	else {
	374	// Buscamos el grupo donde añadir el grupo
	375	addClassroomGroup($response[$classroomIndex]['classroomGroups'], $rs);
	376	}
	377	}
[fb2ee20]	378	$rs->Siguiente();
	379	}
	380	jsonResponse(200, $response);
	381	}
	382	$rs->Cerrar();
	383	}
	384	);
	385
[ac8b234e]	386	/**
	387	* @brief Get lab data
	388	* @note Route: /ous/id1/labs/id2, Method: GET
	389	* @param id1 OU id.
	390	* @param id2 lab id.
	391	* @return JSON string with lab parameters
	392	*/
[fb2ee20]	393	$app->get('/ous/:ouid/labs/:labid', 'validateApiKey',
	394	function($ouid, $labid) {
	395	global $cmd;
	396
	397	$ouid = htmlspecialchars($ouid);
	398	$labid = htmlspecialchars($labid);
	399	$cmd->texto = <<<EOD
	400	SELECT COUNT(idordenador) AS defclients, aulas.*, adm.idadministradorcentro
	401	FROM aulas
	402	RIGHT JOIN administradores_centros AS adm USING(idcentro)
	403	RIGHT JOIN usuarios USING(idusuario)
	404	LEFT JOIN ordenadores USING(idaula)
	405	WHERE idcentro='$ouid'
	406	AND idaula='$labid';
	407	EOD;
	408	$rs=new Recordset;
	409	$rs->Comando=&$cmd;
	410	if (!$rs->Abrir()) return(false); // Error al abrir recordset
	411	$rs->Primero();
	412	if (checkParameter($rs->campos["idaula"]) and checkAdmin($rs->campos["idadministradorcentro"])) {
[bbc672f]	413	$response['id'] = $rs->campos["idaula"];
	414	$response['name'] = $rs->campos["nombreaula"];
	415	$response['location'] = $rs->campos["ubicacion"];
[fb2ee20]	416	$response['description'] = $rs->campos["comentarios"];
	417	$response['inremotepc'] = $rs->campos["inremotepc"]==0 ? false: true;
[bbc672f]	418	$response['capacity'] = $rs->campos["puestos"];
[fb2ee20]	419	$response['defclients'] = $rs->campos["defclients"];
	420	$response['projector'] = $rs->campos["cagnon"]==0 ? false: true;
	421	$response['board'] = $rs->campos["pizarra"]==0 ? false: true;
	422	$response['routerip'] = $rs->campos["router"];
	423	$response['netmask'] = $rs->campos["netmask"];
	424	$response['ntp'] = $rs->campos["ntp"];
	425	$response['dns'] = $rs->campos["dns"];
	426	$response['proxyurl'] = $rs->campos["proxy"];
	427	switch ($rs->campos["modomul"]) {
	428	case 1: $response['mcastmode'] = "half-duplex"; break;
	429	case 2: $response['mcastmode'] = "full-duplex"; break;
	430	default: $response['mcastmode'] = $rs->campos["modomul"];
	431	}
	432	$response['mcastip'] = $rs->campos["ipmul"];
	433	$response['mcastport'] = $rs->campos["pormul"];
	434	$response['mcastspeed'] = $rs->campos["velmul"];
	435	$response['p2pmode'] = $rs->campos["modp2p"];
	436	$response['p2ptime'] = $rs->campos["timep2p"];
[fb5338c]	437	$response['image'] = $rs->campos["urlfoto"];
[fb2ee20]	438	jsonResponse(200, $response);
	439	}
	440	$rs->Cerrar();
	441	}
	442	);
	443
	444	// Listar clientes de un aula.
	445	$app->get('/ous/:ouid/labs/:labid/clients', 'validateApiKey',
	446	function($ouid, $labid) {
	447	global $cmd;
	448
	449	$ouid = htmlspecialchars($ouid);
	450	$labid = htmlspecialchars($labid);
	451	// Listar los clientes del aula si el usuario de la apikey es admin de su UO.
[fb5338c]	452	$cmd->texto = <<<EOD
	453	SELECT ordenadores.*, adm.idadministradorcentro
	454	FROM ordenadores
	455	JOIN aulas USING(idaula)
	456	RIGHT JOIN administradores_centros AS adm USING(idcentro)
	457	RIGHT JOIN usuarios USING(idusuario)
	458	WHERE idcentro='$ouid'
	459	AND idaula='$labid';
	460	EOD;
[fb2ee20]	461	$rs=new Recordset;
	462	$rs->Comando=&$cmd;
	463	if (!$rs->Abrir()) return(false); // Recordset open error.
	464	$rs->Primero();
[fb5338c]	465	if (checkParameter($rs->campos["idaula"]) and checkAdmin($rs->campos["idadministradorcentro"])) {
[fb2ee20]	466	$response['ouid'] = $ouid;
	467	$response['labid'] = $labid;
[4a511f81]	468	$response = array();
[fb2ee20]	469	while (!$rs->EOF) {
	470	$tmp = array();
[bbc672f]	471	$tmp['id'] = $rs->campos["idordenador"];
	472	$tmp['name'] = $rs->campos["nombreordenador"];
[146d955]	473	$tmp['ip'] = $rs->campos["ip"];
	474	$tmp['mac'] = $rs->campos["mac"];
[4a511f81]	475	$tmp['ou']['id'] = $ouid;
	476	$tmp['lab']['id'] = $labid;
	477	array_push($response, $tmp);
[fb2ee20]	478	$rs->Siguiente();
	479	}
	480	jsonResponse(200, $response);
	481	}
	482	$rs->Cerrar();
	483	}
	484	);
	485
	486	// Obtener datos de un cliente.
	487	$app->get('/ous/:ouid/labs/:labid/clients/:clntid', 'validateApiKey',
	488	function($ouid, $labid, $clntid) {
	489	global $cmd;
	490
	491	$ouid = htmlspecialchars($ouid);
	492	$labid = htmlspecialchars($labid);
	493	$clntid = htmlspecialchars($clntid);
[ac8b234e]	494	// Obtener datos del cliente del aula si el usuario de la apikey es admin de su UO.
[fb5338c]	495	$cmd->texto = <<<EOD
	496	SELECT ordenadores.*, adm.idadministradorcentro
	497	FROM ordenadores
	498	JOIN aulas USING(idaula)
	499	RIGHT JOIN administradores_centros AS adm USING(idcentro)
	500	RIGHT JOIN usuarios USING(idusuario)
	501	WHERE idcentro='$ouid'
	502	AND idaula='$labid'
	503	AND idordenador='$clntid';
	504	EOD;
[fb2ee20]	505	$rs=new Recordset;
	506	$rs->Comando=&$cmd;
	507	if (!$rs->Abrir()) return(false); // Error al abrir recordset
	508	$rs->Primero();
[fb5338c]	509	if (checkParameter($rs->campos["idordenador"]) and checkParameter($rs->campos["idaula"]) and checkAdmin($rs->campos["idadministradorcentro"])) {
[bbc672f]	510	$response['id'] = $rs->campos["idordenador"];
	511	$response['name'] = $rs->campos["nombreordenador"];
	512	$response['serialno'] = $rs->campos["numserie"];
[fb2ee20]	513	$response['netiface'] = $rs->campos["netiface"];
	514	$response['netdriver'] = $rs->campos["netdriver"];
	515	$response['mac'] = $rs->campos["mac"];
	516	$response['ip'] = $rs->campos["ip"];
	517	$response['netmask'] = $rs->campos["mascara"];
	518	$response['routerip'] = $rs->campos["router"];
[4a511f81]	519	$response['repo']['id'] = $rs->campos["idrepositorio"];
	520	//$response['hardprofile']['id'] = $rs->campos["idperfilhard"];
	521	//$response['menu']['id'] = $rs->campos["idmenu"];
[fb5338c]	522	$response['validation'] = $rs->campos["validacion"]==0 ? false: true;
	523	$response['boottype'] = $rs->campos["arranque"];
	524	$response['image'] = $rs->campos["fotoord"];
[fb2ee20]	525	jsonResponse(200, $response);
	526	}
	527	$rs->Cerrar();
	528	}
	529	);
	530
	531	// Obtener la configuración de hardware de un cliente.
	532	$app->get('/ous/:ouid/labs/:labid/clients/:clntid/hardware', 'validateApiKey',
	533	function($ouid, $labid, $clntid) {
	534	global $cmd;
	535
	536	$ouid = htmlspecialchars($ouid);
	537	$labid = htmlspecialchars($labid);
	538	$clntid = htmlspecialchars($clntid);
	539	$cmd->texto = <<<EOD
	540	SELECT ordenadores.idordenador, ordenadores.nombreordenador,
	541	tipohardwares.nemonico, hardwares.descripcion
	542	FROM perfileshard
	543	RIGHT JOIN ordenadores USING(idperfilhard)
	544	JOIN perfileshard_hardwares USING(idperfilhard)
	545	JOIN hardwares ON perfileshard_hardwares.idhardware=hardwares.idhardware
	546	JOIN tipohardwares ON tipohardwares.idtipohardware=hardwares.idtipohardware
	547	WHERE ordenadores.idordenador='$clntid'
	548	EOD;
	549	$rs=new Recordset;
	550	$rs->Comando=&$cmd;
	551	if (!$rs->Abrir()) return(false); // Error al abrir recordset
	552	$rs->Primero();
	553	// if ($ouid != $rs->campos["idcentro"]) ...
	554	// if ($labid != $rs->campos["idaula"]) ...
	555	if (checkParameter($rs->campos["idordenador"])) {
[bbc672f]	556	$response['id'] = $rs->campos["idordenador"];
	557	$response['name'] = $rs->campos["nombreordenador"];
[fb2ee20]	558	$response['hardware'] = array();
	559	while (!$rs->EOF) {
	560	$tmp = array();
	561	$tmp['type'] = $rs->campos["nemonico"];
	562	$tmp['description'] = $rs->campos["descripcion"];
	563	array_push($response['hardware'], $tmp);
	564	$rs->Siguiente();
	565	}
	566	jsonResponse(200, $response);
	567	}
	568	$rs->Cerrar();
	569	}
	570	);
	571
	572	// Obtener datos de configuración de discos del cliente.
	573	$app->get('/ous/:ouid/labs/:labid/clients/:clntid/diskcfg', 'validateApiKey',
	574	function($ouid, $labid, $clntid) {
	575	global $cmd;
	576
	577	$ouid = htmlspecialchars($ouid);
	578	$labid = htmlspecialchars($labid);
	579	$clntid = htmlspecialchars($clntid);
	580	$cmd->texto = <<<EOD
	581	SELECT ordenadores.idordenador AS clientid, ordenadores.nombreordenador,
	582	ordenadores_particiones.*, tipospar.tipopar,
[208ee50]	583	sistemasficheros.nemonico, nombresos.nombreso, imagenes.nombreca,
	584	(imagenes.revision - ordenadores_particiones.revision) AS difimagen
[fb2ee20]	585	FROM ordenadores_particiones
	586	RIGHT JOIN ordenadores USING(idordenador)
	587	LEFT JOIN tipospar USING(codpar)
	588	LEFT JOIN sistemasficheros USING(idsistemafichero)
	589	LEFT JOIN nombresos USING(idnombreso)
	590	LEFT JOIN imagenes USING(idimagen)
	591	WHERE ordenadores.idordenador='$clntid'
	592	ORDER BY numdisk ASC, numpar ASC;
	593	EOD;
	594	$rs=new Recordset;
	595	$rs->Comando=&$cmd;
	596	if (!$rs->Abrir()) return(false); // Error al abrir recordset
	597	$rs->Primero();
	598	// if ($labid != $rs->campos["idaula"]) ...
	599	if (checkParameter($rs->campos["clientid"])) {
[bbc672f]	600	$response['id'] = $rs->campos["clientid"];
	601	$response['name'] = $rs->campos["nombreordenador"];
[fb2ee20]	602	$response['diskcfg'] = array();
	603	while (!$rs->EOF) {
	604	if ($rs->campos["numdisk"] == 0) {
	605	$rs->Siguiente();
	606	continue;
	607	}
	608	$tmp = array();
	609	if ($rs->campos["numpar"] == 0) {
	610	$tmp['disk'] = $rs->campos["numdisk"];
	611	switch ($rs->campos["codpar"]) {
	612	case 1: $tmp['parttable'] = "MSDOS"; break;
	613	case 2: $tmp['parttable'] = "GPT"; break;
	614	case 3: $tmp['parttable'] = "LVM"; break;
	615	case 4: $tmp['parttable'] = "ZPOOL"; break;
	616	default: $tmp['parttable'] = $rs->campos["codpar"];
	617	}
	618	$tmp['size'] = $rs->campos["tamano"];
	619	} else {
	620	$tmp['partition'] = $rs->campos["numpar"];
	621	$tmp['parttype'] = $rs->campos["tipopar"];
	622	$tmp['filesystem'] = $rs->campos["nemonico"];
	623	$tmp['size'] = $rs->campos["tamano"];
	624	$tmp['usage'] = $rs->campos["uso"];
	625	if ($rs->campos["nombreso"] != null) {
	626	$tmp['os'] = $rs->campos["nombreso"];
[df81ab78]	627	if ($rs->campos["idimagen"] > 0) {
	628	$tmp['image']['id'] = $rs->campos["idimagen"];
	629	$tmp['image']['deploydate'] = $rs->campos["fechadespliegue"];
	630	// Comprobar si la imagen está actualizada.
	631	$tmp['image']['updated'] = ($rs->campos["difimagen"]>0 ? "false" : "true");
	632	}
[fb2ee20]	633	}
	634	//$tmp['cachedata'] = $rs->campos["cache"];
	635	}
	636	array_push($response['diskcfg'], $tmp);
	637	$rs->Siguiente();
	638	}
	639	jsonResponse(200, $response);
	640	}
	641	$rs->Cerrar();
	642	}
	643	);
	644
	645	// Obtener estado de ejecución del cliente.
	646	$app->get('/ous/:ouid/labs/:labid/clients/:clntid/status', 'validateApiKey',
	647	function($ouid, $labid, $clntid) {
	648	global $cmd;
	649	global $LONCABECERA;
	650	global $LONHEXPRM;
	651
[208ee50]	652	// Status mapping.
	653	$status = array('OFF'=>"off",
	654	'INI'=>"initializing",
	655	'OPG'=>"ogclient",
	656	'BSY'=>"busy",
	657	'LNX'=>"linux",
	658	'WIN'=>"windows");
[fb2ee20]	659	// Parameters.
	660	$ouid = htmlspecialchars($ouid);
	661	$labid = htmlspecialchars($labid);
	662	$clntid = htmlspecialchars($clntid);
	663
	664	// Database query.
	665	$cmd->texto = <<<EOD
	666	SELECT serv.ipserveradm, serv.portserveradm, clnt.idordenador, clnt.ip
	667	FROM entornos AS serv, ordenadores AS clnt
	668	WHERE clnt.idordenador='$clntid';
	669	EOD;
	670	$rs=new Recordset;
	671	$rs->Comando=&$cmd;
	672	if (!$rs->Abrir()) return(false); // Error al abrir recordset
	673	$rs->Primero();
	674	if (checkParameter($rs->campos["idordenador"])) {
[353c112]	675	// First, try to connect to ogAdmCleint service.
[fb2ee20]	676	$serverip = $rs->campos["ipserveradm"];
	677	$serverport = $rs->campos["portserveradm"];
	678	$clientid = $rs->campos["idordenador"];
	679	$clientip = $rs->campos["ip"];
	680
	681	// Connect to reset client's status.
	682	$reqframe = "nfn=Sondeo\r".
	683	"ido=$clientid\r".
	684	"iph=$clientip\r";
	685	$result = sendCommand($serverip, $serverport, $reqframe, $values);
	686
	687	// Connect to fetch client's status.
	688	// Asuming client is off by default.
	689	$values["tso"]="OFF";
	690	// Iterate to check client's status.
	691	// Exit if status!=OFF or end iterations (status=OFF).
	692	$maxIter = 30;
	693	for ($i=1; $i<$maxIter and preg_match('/OFF/', $values["tso"]); $i++) {
	694	// Connect to check status.
	695	$reqframe = "nfn=respuestaSondeo\r".
	696	"ido=$clientid\r".
	697	"iph=$clientip\r";
	698	$result = sendCommand($serverip, $serverport, $reqframe, $values);
	699	// Wait until next checking (0.1 ms).
	700	usleep(100000);
	701	}
	702
	703	// Parse status response.
	704	if ($result) {
	705	// Check status type.
	706	if (checkParameter($values["tso"])) {
	707	// Compose JSON response.
[bbc672f]	708	$response['id'] = $clientid;
[fb2ee20]	709	$response['ip'] = $clientip;
	710	$stat = array();
	711	preg_match('/\/[A-Z]*;/', $values["tso"], $stat);
	712	// Check if data exists.
[208ee50]	713	if (empty($stat[0]) or preg_match('/OFF/', $stat[0])) {
[353c112]	714	// If no data, check OGAgent API connection.
	715	$url = "https://$clientip:8000/opengnsys/status";
[69052958]	716	$result = multiRequest(Array($url));
[353c112]	717	if (empty($result[0])) {
	718	// Client is off.
[208ee50]	719	$response['status'] = $status['OFF'];
[353c112]	720	} else {
[208ee50]	721	// Get status and session data.
[353c112]	722	$data = json_decode($result[0]);
[208ee50]	723	if (isset($status[$data->status])) {
	724	$response['status'] = $status[$data->status];
[353c112]	725	$response['loggedin'] = $data->loggedin;
	726	}
	727	}
[fb2ee20]	728	} else {
	729	$response['status'] = $status[substr($stat[0], 1, 3)];
[208ee50]	730	}
	731	if (empty($response['status'])) {
	732	$response['status'] = "unknown";
[fb2ee20]	733	}
	734	jsonResponse(200, $response);
	735	}
	736	} else {
	737	// Access error.
	738	$response['message'] = "Cannot access to OpenGnsys server";
	739	jsonResponse(500, $response);
	740	}
	741	}
	742	$rs->Cerrar();
	743	}
	744	);
	745
	746
	747	// Listar repositorios.
	748	$app->get('/ous/:ouid/repos', 'validateApiKey',
	749	function($ouid) {
	750	global $cmd;
	751
	752	$ouid = htmlspecialchars($ouid);
	753	// Listar las salas de la UO si el usuario de la apikey es su admin.
	754	// Consulta temporal,
	755	$cmd->texto = "SELECT * FROM repositorios WHERE idcentro='$ouid';";
	756	$rs=new Recordset;
	757	$rs->Comando=&$cmd;
	758	if (!$rs->Abrir()) return(false); // Error al abrir recordset
	759	$rs->Primero();
	760	// Comprobar que exista la UO.
	761	if (checkParameter($rs->campos["idcentro"])) {
[4a511f81]	762	$response = array();
[fb2ee20]	763	while (!$rs->EOF) {
	764	$tmp = array();
[bbc672f]	765	$tmp['id'] = $rs->campos["idrepositorio"];
	766	$tmp['name'] = $rs->campos["nombrerepositorio"];
[4a511f81]	767	$tmp['ou']['id'] = $ouid;
	768	array_push($response, $tmp);
[fb2ee20]	769	$rs->Siguiente();
	770	}
	771	jsonResponse(200, $response);
	772	}
	773	$rs->Cerrar();
	774	}
	775	);
	776
	777	// Obtener datos de un repositorio.
	778	$app->get('/ous/:ouid/repos/:repoid', 'validateApiKey',
	779	function($ouid, $repoid) {
	780	global $cmd;
	781
	782	$ouid = htmlspecialchars($ouid);
	783	$repoid = htmlspecialchars($repoid);
	784	$cmd->texto = "SELECT * FROM repositorios WHERE idrepositorio='$repoid';";
	785	$rs=new Recordset;
	786	$rs->Comando=&$cmd;
	787	if (!$rs->Abrir()) return(false); // Error al abrir recordset
	788	$rs->Primero();
	789	// Comprobar que exista el repositorio.
	790	if (checkParameter($rs->campos["idrepositorio"])) {
[bbc672f]	791	$response['id'] = $rs->campos["idrepositorio"];
	792	$response['name'] = $rs->campos["nombrerepositorio"];
[fb2ee20]	793	$response['description'] = $rs->campos["comentarios"];
[4a511f81]	794	$response['ip'] = $rs->campos["ip"];
[fb2ee20]	795	//$response['port'] = $rs->campos["puertorepo"];
	796	jsonResponse(200, $response);
	797	}
	798	$rs->Cerrar();
	799	}
	800	);
	801
	802	// Listar imágenes.
	803	$app->get('/ous/:ouid/images', 'validateApiKey',
	804	function($ouid) {
	805	global $cmd;
	806
	807	$ouid = htmlspecialchars($ouid);
	808	// Listar las salas de la UO si el usuario de la apikey es su admin.
	809	// Consulta temporal,
	810	$cmd->texto = "SELECT * FROM imagenes WHERE idcentro='$ouid';";
	811	$rs=new Recordset;
	812	$rs->Comando=&$cmd;
	813	if (!$rs->Abrir()) return(false); // Error al abrir recordset
	814	// Comprobar que exista la UO.
	815	$rs->Primero();
	816	if (checkParameter($rs->campos["idcentro"])) {
[4a511f81]	817	$response = array();
[fb2ee20]	818	while (!$rs->EOF) {
	819	$tmp = array();
[bbc672f]	820	$tmp['id'] = $rs->campos["idimagen"];
	821	$tmp['name'] = $rs->campos["nombreca"];
[fb2ee20]	822	$tmp['inremotepc'] = $rs->campos["inremotepc"]==0 ? false: true;
[4a511f81]	823	$tmp['ou']['id'] = $ouid;
	824	array_push($response, $tmp);
[fb2ee20]	825	$rs->Siguiente();
	826	}
	827	jsonResponse(200, $response);
	828	}
	829	}
	830	);
	831
	832	// Obtener datos de una imagen.
	833	$app->get('/ous/:ouid/images/:imgid', 'validateApiKey',
	834	function($ouid, $imgid) {
	835	global $cmd;
	836
	837	$ouid = htmlspecialchars($ouid);
	838	$imgid = htmlspecialchars($imgid);
	839	$cmd->texto = "SELECT * FROM imagenes WHERE idimagen='$imgid';";
	840	$rs=new Recordset;
	841	$rs->Comando=&$cmd;
	842	if (!$rs->Abrir()) return(false); // Error al abrir recordset
	843	$rs->Primero();
	844	// Comprobar que exista el repositorio.
	845	if (checkParameter($rs->campos["idimagen"])) {
[bbc672f]	846	$response['id'] = $rs->campos["idimagen"];
	847	$response['name'] = $rs->campos["nombreca"];
[fb2ee20]	848	$response['description'] = $rs->campos["descripcion"];
	849	$response['comments'] = $rs->campos["comentarios"];
	850	$response['inremotepc'] = $rs->campos["inremotepc"]==0 ? false: true;
[3b5daf8]	851	$response['repo']['id'] = $rs->campos["idrepositorio"];
[fb2ee20]	852	switch ($rs->campos["tipo"]) {
	853	case 1: $response['type'] = "monolithic"; break;
	854	case 2: $response['type'] = "base"; break;
	855	case 3: $response['type'] = "incremental";
	856	$response['baseimg'] = $rs->campos["imagenid"];
	857	$response['path'] = $rs->campos["ruta"];
	858	break;
	859	default: $response['type'] = $rs->campos["tipo"];
	860	}
	861	if ($rs->campos["idordenador"] != 0) {
[3b5daf8]	862	$response['client']['id'] = $rs->campos["idordenador"];
	863	$response['client']['disk'] = $rs->campos["numdisk"];
	864	$response['client']['partition'] = $rs->campos["numpar"];
[fb2ee20]	865	$response['creationdate'] = $rs->campos["fechacreacion"];
[bbc672f]	866	$response['release'] = $rs->campos["revision"];
[fb2ee20]	867	}
	868	jsonResponse(200, $response);
	869	}
	870	$rs->Cerrar();
	871	}
	872	);
	873
	874	// Lista de softeare instalado en una imagen.
	875	$app->get('/ous/:ouid/images/:imgid/software', 'validateApiKey',
	876	function($ouid, $imgid) {
	877	global $cmd;
	878
	879	$ouid = htmlspecialchars($ouid);
	880	$imgid = htmlspecialchars($imgid);
	881	$cmd->texto = <<<EOD
[bbc672f]	882	SELECT imagenes.idimagen, imagenes.nombreca, nombresos.nombreso, softwares.descripcion
[fb2ee20]	883	FROM perfilessoft
	884	RIGHT JOIN imagenes USING(idperfilsoft)
[bbc672f]	885	LEFT JOIN nombresos USING(idnombreso)
[fb2ee20]	886	LEFT JOIN perfilessoft_softwares USING(idperfilsoft)
	887	LEFT JOIN softwares USING(idsoftware)
	888	WHERE imagenes.idimagen='$imgid'
	889	ORDER BY softwares.descripcion ASC;
	890	EOD;
	891	$rs=new Recordset;
	892	$rs->Comando=&$cmd;
	893	if (!$rs->Abrir()) return(false); // Error al abrir recordset
	894	$rs->Primero();
	895	// Comprobar que exista el repositorio.
	896	if (checkParameter($rs->campos["idimagen"])) {
[bbc672f]	897	$response['id'] = $rs->campos["idimagen"];
	898	$response['name'] = $rs->campos["nombreca"];
	899	$response['os'] = $rs->campos["nombreso"];
	900	//$response['ostype'] = Tipo de SO (agrupar en array con nombre SO).
[fb2ee20]	901	$response['software'] = array();
	902	while (!$rs->EOF) {
	903	if ($rs->campos["descripcion"] == null) {
	904	$rs->Siguiente();
	905	continue;
	906	}
	907	$tmp = array();
	908	$tmp['application'] = $rs->campos["descripcion"];
	909	array_push($response['software'], $tmp);
	910	$rs->Siguiente();
	911	}
	912	jsonResponse(200, $response);
	913	}
	914	$rs->Cerrar();
	915	}
	916	);
	917
	918	// Arrancar un ordenador con una imagen instalada, elegido al azar.
	919	$app->get('/ous/:id1/images/:id2/boot', 'validateApiKey',
	920	function($ouid, $imageid) {
	921	global $cmd;
	922	global $AMBITO_ORDENADORES;
	923	global $EJECUCION_COMANDO;
	924	global $ACCION_INICIADA;
	925	global $ACCION_SINRESULTADO;
	926
	927	// Pparameters.
	928	$ouid = htmlspecialchars($ouid);
	929	$imegeid = htmlspecialchars($imageid);
	930	// Boot 1 client.
	931	$nclients = 1;
	932
	933	// Query: server data and all clients' boot data availabe for Remote PC with this image installed (random order).
	934	$cmd->texto = <<<EOD
	935	SELECT s.ipserveradm, s.portserveradm,
	936	c.idordenador, c.ip, c.mac, p.numdisk, p.numpar
	937	FROM entornos AS s, ordenadores AS c
	938	JOIN aulas USING(idaula)
	939	JOIN centros USING(idcentro)
	940	JOIN ordenadores_particiones AS p USING(idordenador)
	941	JOIN imagenes USING(idimagen)
	942	WHERE centros.idcentro='$ouid'
	943	AND aulas.inremotepc=1
	944	AND imagenes.idimagen='$imageid'
	945	AND imagenes.inremotepc=1
	946	ORDER BY RAND();
	947	EOD;
	948	$rs=new Recordset;
	949	$rs->Comando=&$cmd;
	950	if (!$rs->Abrir()) return(false); // Error oppening recordset.
	951	$rs->Primero();
	952	if (checkParameter($rs->campos["ipserveradm"])) {
	953
	954	$response['imageid'] = $imageid;
	955	$response['sendto'] = array();
	956
	957	// AVISO: Procesar datos del servidor (solo 1er registro).
	958
	959	$serverip = $rs->campos["ipserveradm"];
	960	$serverport = $rs->campos["portserveradm"];
	961
	962	// AVISO: Procesar datos de los clientes.
	963
	964	$clientid = array();
	965	$clientip = array();
	966	$clientmac = array();
	967	$clientdisk = array();
	968	$clientpart = array();
	969	while (!$rs->EOF) {
	970	array_push($clientid, $rs->campos["idordenador"]);
	971	array_push($clientip, $rs->campos["ip"]);
	972	array_push($clientmac, $rs->campos["mac"]);
	973	array_push($clientdisk, $rs->campos["numdisk"]);
	974	array_push($clientpart, $rs->campos["numpar"]);
	975	$rs->Siguiente();
	976	}
	977	$rs->Cerrar();
	978
	979	// AVISO: consultar el estado de todos los clientes y
	980	// quitar aquellos que no tengan "OFF", "OPG" o ""
	981	// (estudiar si incluir los "BSY")
	982
	983	// Reset clients' status.
	984	$reqframe = "nfn=Sondeo\r".
	985	"ido=".implode(',', $clientid)."\r".
	986	"iph=".implode(';', $clientip)."\r";
	987	sendCommand($serverip, $serverport, $reqframe, $values);
	988	// Wait to get response.
	989	sleep(3);
	990	// Connect to check status.
	991	$reqframe = "nfn=respuestaSondeo\r".
	992	"ido=".implode(',', $clientid)."\r".
	993	"iph=".implode(';', $clientip)."\r";
	994	sendCommand($serverip, $serverport, $reqframe, $values);
	995	// Check status type.
	996	if (isset($values["tso"])) {
	997	preg_match_all('/[A-Z]{3}/', $values["tso"], $stat);
	998	}
	999	if (isset($stat[0])) {
	1000	for ($i=0; $i<sizeof($stat[0]); $i++) {
	1001	if (! in_array($stat[0][$i], array("OFF", "OPG", ""))) {
	1002	unset($clientid[$i]);
	1003	unset($clientip[$i]);
	1004	unset($clientmac[$i]);
	1005	unset($clientdisk[$i]);
	1006	unset($clientpart[$i]);
	1007	}
	1008	}
	1009	}
	1010
	1011	// AVISO: el siguiente código inicia un único cliente.
	1012	// Para iniciar varios:
	1013	// - id. clientes separados por carácter ','.
	1014	// - IP clientes separadas por carácter ';'
	1015	// - MAC clientes separadas por carácter ';'
	1016
	1017	// Executing boot command.
	1018	$reqframe = "nfn=Arrancar\r".
	1019	"ido=".implode(',', $clientid)."\r".
	1020	"iph=".implode(';', $clientip)."\r".
	1021	"mac=".implode(';', $clientmac)."\r".
	1022	"mar=1\r";
	1023	echo "req=".str_replace("\r"," ",$reqframe).".\n";
	1024	sendCommand($serverip, $serverport, $reqframe, $values);
	1025	if ($values["res"]) {
	1026	print_r($values);
	1027	$tmp = array();
	1028	for ($i=0, $boot=0; $i<sizeof($clientid) and $boot!=1; $i++) {
	1029	$reqframe = "nfn=IniciarSesion\r".
	1030	"ido=".$clientid[$i]."\r".
	1031	"iph=".$clientip[$i]."\r".
	1032	"dsk=".$clientdisk[$i]."\r".
	1033	"par=".$clientpart[$i]."\r";
	1034	echo "i=$i: req=".str_replace("\r"," ",$reqframe).".\n";
	1035	sendCommand($serverip, $serverport, $reqframe, $values);
	1036	if ($values["res"]) {
	1037
	1038	// AVISO: incluir comando Iniciar sesión en cola de acciones.
	1039	$timestamp=time();
	1040	$cmd->texto = <<<EOD
	1041	INSERT INTO acciones
	1042	SET tipoaccion=$EJECUCION_COMANDO,
	1043	idtipoaccion=9,
	1044	idcomando=9,
	1045	parametros='nfn=IniciarSesion\rdsk=$clientdisk[$i]\rpar=$clientpart[$i]',
	1046	descriaccion='RemotePC Session',
	1047	idordenador=$clientid[$i],
	1048	ip='$clientip[$i]',
	1049	sesion=$timestamp,
	1050	fechahorareg=NOW(),
	1051	estado=$ACCION_INICIADA,
	1052	resultado=$ACCION_SINRESULTADO,
	1053	ambito=$AMBITO_ORDENADORES,
	1054	idambito=$clientid[$i],
	1055	restrambito='$clientip[$i]',
	1056	idcentro=$ouid;
	1057	EOD;
	1058	$result = $cmd->Ejecutar();
	1059	if ($result) {
[bbc672f]	1060	$tmp['id'] = $clientid[$i];
[fb2ee20]	1061	$tmp['ip'] = $clientip[$i];
	1062	$tmp['mac'] = $clientmac[$i];
	1063	array_push($response['sendto'], $tmp);
	1064	$boot = 1;
	1065	}
	1066	}
	1067	}
	1068	}
	1069	jsonResponse(200, $response);
	1070	}
	1071	}
	1072	);
	1073	// Alternativa como método GET.
	1074	//$app->get('/ous/:id1/images/:id2/boot/:number', 'validateApiKey',
	1075	// function($ouid, $imageid, $number) {
	1076	//
	1077	// }
	1078	//);
	1079
[21e5ee3]	1080	?>

Note: See TracBrowser for help on using the repository browser.

Context Navigation

source: admin/WebConsole/rest/server.php @ 6acd145

Download in other formats: