diff options
| -rw-r--r-- | admin/WebConsole/rest/remotepc.php | 198 |
1 files changed, 172 insertions, 26 deletions
diff --git a/admin/WebConsole/rest/remotepc.php b/admin/WebConsole/rest/remotepc.php index e11f8870..428d5252 100644 --- a/admin/WebConsole/rest/remotepc.php +++ b/admin/WebConsole/rest/remotepc.php @@ -39,13 +39,13 @@ $app->post('/ous/:ouid/images/:imageid/reserve(/)', 'validateApiKey', global $ACCION_SINRESULTADO; global $ACCION_FALLIDA; global $userid; - $response = Array(); - $ogagent = Array(); - $repo = Array(); + $response = []; + $ogagent = []; + $repo = []; if ($app->settings['debug']) writeRemotepcLog($app->request()->getResourceUri(). ": Init."); - // Checking parameters. + // Checking parameters. try { if (empty(preg_match('/^python-requests\//', $_SERVER['HTTP_USER_AGENT']))) { throw new Exception("Bad agent: sender=".$_SERVER['REMOTE_ADDR'].", agent=".$_SERVER['HTTP_USER_AGENT']); @@ -120,35 +120,35 @@ EOD; $repoip = $rs->campos["repoip"]; $repokey = $rs->campos["repokey"]; // Check client's status. - $ogagent[$clntip]['url'] = "https://$clntip:8000/opengnsys/status"; + $ogagent = [['url' => "https://$clntip:8000/opengnsys/status"]]; if ($app->settings['debug']) - writeRemotepcLog($app->request()->getResourceUri(). ": OGAgent status, url=".$ogagent[$clntip]['url']."."); + writeRemotepcLog($app->request()->getResourceUri(). ": OGAgent status, url=".$ogagent[0]['url']."."); $result = multiRequest($ogagent); - if (empty($result[$clntip]['data'])) { + if (empty($result[0]['data'])) { // Client is off, send WOL command to ogAdmServer. // TODO: if client is busy????? if ($app->settings['debug']) writeRemotepcLog($app->request()->getResourceUri(). ": Send boot command through ogAdmServer: iph=$clntip,mac=$clntmac."); wol(1, [$clntmac], [$clntip], [$clntnetmask]); // Send WOL command to client repository. - $repo[$repoip]['url'] = "https://$repoip/opengnsys/rest/repository/poweron"; - $repo[$repoip]['header'] = Array("Authorization: ".$repokey); - $repo[$repoip]['post'] = '{"macs": ["'.$clntmac.'"], "ips": ["'.$clntip.'"]}'; + $repo = [['url' => "https://$repoip/opengnsys/rest/repository/poweron", + 'header' => ["Authorization: $repokey"], + 'post' => '{"macs": ["'.$clntmac.'"], "ips": ["'.$clntip.'"]}']]; if ($app->settings['debug']) - writeRemotepcLog($app->request()->getResourceUri(). ": Send Boot command through repo: repo=$repoip, ip=$clntip,mac=$clntmac."); + writeRemotepcLog($app->request()->getResourceUri(). ": Send Boot command through repo: repo=$repoip,ip=$clntip,mac=$clntmac."); $result = multiRequest($repo); // ... (check response) - //if ($result[$repoip]['code'] != 200) { + //if ($result[0]['code'] != 200) { // ... } else { - // Client is on, send a rieboot command to its OGAgent. - $ogagent[$clntip]['url'] = "https://$clntip:8000/opengnsys/reboot"; - $ogagent[$clntip]['header'] = Array("Authorization: ".$agentkey); + // Client is on, send a reboot command to its OGAgent. + $ogagent = [['url' => "https://$clntip:8000/opengnsys/reboot", + 'header' => ["Authorization: ".$agentkey]]]; if ($app->settings['debug']) - writeRemotepcLog($app->request()->getResourceUri(). ": OGAgent reboot, url=".$ogagent[$clntip]['url']."."); + writeRemotepcLog($app->request()->getResourceUri(). ": OGAgent reboot, url=".$ogagent[0]['url']."."); $result = multiRequest($ogagent); // ... (check response) - //if ($result[$clntip]['code'] != 200) { + //if ($result[0]['code'] != 200) { // ... } // DB Transaction: mark choosed client as reserved and @@ -265,7 +265,7 @@ $app->post('/ous/:ouid/labs/:labid/clients/:clntid/events', 'validateApiKey', if ($app->settings['debug']) writeRemotepcLog($app->request()->getResourceUri(). ": Init."); - // Checking parameters. + // Checking parameters. try { if (empty(preg_match('/^python-requests\//', $_SERVER['HTTP_USER_AGENT']))) { throw new Exception("Bad agent: sender=".$_SERVER['REMOTE_ADDR'].", agent=".$_SERVER['HTTP_USER_AGENT']); @@ -359,7 +359,7 @@ $app->post('/ous/:ouid/labs/:labid/clients/:clntid/session', 'validateApiKey', if ($app->settings['debug']) writeRemotepcLog($app->request()->getResourceUri(). ": Init."); - // Checking parameters. + // Checking parameters. try { if (empty(preg_match('/^python-requests\//', $_SERVER['HTTP_USER_AGENT']))) { throw new Exception("Bad agent: sender=".$_SERVER['REMOTE_ADDR'].", agent=".$_SERVER['HTTP_USER_AGENT']); @@ -463,12 +463,12 @@ $app->delete('/ous/:ouid/labs/:labid/clients/:clntid/unreserve', 'validateApiKey global $cmd; global $userid; global $ACCION_INICIADA; - $response = Array(); - $ogagent = Array(); + $response = []; + $ogagent = []; if ($app->settings['debug']) writeRemotepcLog($app->request()->getResourceUri(). ": Init."); - // Checking parameters. + // Checking parameters. try { if (empty(preg_match('/^python-requests\//', $_SERVER['HTTP_USER_AGENT']))) { throw new Exception("Bad agent: sender=".$_SERVER['REMOTE_ADDR'].", agent=".$_SERVER['HTTP_USER_AGENT']); @@ -537,13 +537,13 @@ EOD; $cmd->texto = "COMMIT;"; $cmd->Ejecutar(); // Send a poweroff command to client's OGAgent. - $ogagent[$clntip]['url'] = "https://$clntip:8000/opengnsys/poweroff"; - $ogagent[$clntip]['header'] = Array("Authorization: ".$agentkey); + $ogagent = [['url' => "https://$clntip:8000/opengnsys/poweroff", + 'header' => ["Authorization: ".$agentkey]]]; if ($app->settings['debug']) - writeRemotepcLog($app->request()->getResourceUri(). ": OGAgent poweroff, url=".$ogagent[$clntip]['url']."."); + writeRemotepcLog($app->request()->getResourceUri(). ": OGAgent poweroff, url=".$ogagent[0]['url']."."); $result = multiRequest($ogagent); // ... (check response) - //if ($result[$clntip]['code'] != 200) { + //if ($result[0]['code'] != 200) { // ... // Confirm operation. $response = ""; @@ -562,3 +562,149 @@ EOD; } ); + +/* + * @brief Send an init operation to a client with an image installed. + * @note Route: /ous/:ouid/labs/:labid/clients/:clntid/init, Method: POST + * @param int image Image id. + */ +$app->post('/ous/:ouid/labs/:labid/clients/:clntid/init', 'validateApiKey', + function($ouid, $labid, $clntid) use ($app) { + global $cmd; + global $userid; + + if ($app->settings['debug']) + writeRemotepcLog("{$app->request()->getResourceUri()}: Init."); + // Checking parameters. + try { + if (empty(preg_match('/^python-requests\//', $_SERVER['HTTP_USER_AGENT']))) { + throw new Exception("Bad agent: sender=".$_SERVER['REMOTE_ADDR'].", agent=".$_SERVER['HTTP_USER_AGENT']); + } + if (!checkIds($ouid, $labid, $clntid)) { + throw new Exception("Ids. must be positive integers"); + } + // Reading POST parameters in JSON format. + $input = json_decode($app->request()->getBody()); + $imageid = $input->image ?? 0; + if (filter_var($imageid, FILTER_VALIDATE_INT, $opts) === false) { + throw new Exception("Image id. must be positive integer"); + } + } catch (Exception $e) { + // Communication error. + $response["message"] = $e->getMessage(); + if ($app->settings['debug']) + writeRemotepcLog("{$app->request()->getResourceUri()}: ERROR: {$response["message"]}."); + jsonResponse(400, $response); + $app->stop(); + } + + // Select data to init a session. + $cmd->texto = <<<EOD +SELECT adm.idusuario, ordenadores.ip, ordenadores.mac, ordenadores.mascara, ordenadores.agentkey, + par.numdisk, par.numpar, repo.ip AS repoip, repo.apikey AS repokey + FROM ordenadores + JOIN aulas USING(idaula) + RIGHT JOIN administradores_centros AS adm USING(idcentro) + RIGHT JOIN usuarios USING(idusuario) + RIGHT JOIN ordenadores_particiones AS par USING(idordenador) + RIGHT JOIN imagenes USING(idimagen) + RIGHT JOIN repositorios AS repo ON repo.idrepositorio = ordenadores.idrepositorio + LEFT JOIN remotepc ON remotepc.id=ordenadores.idordenador + WHERE adm.idusuario = '$userid' + AND aulas.idcentro = '$ouid' AND aulas.idaula LIKE '$labid' + AND ordenadores.idordenador = '$clntid' AND ordenadores.maintenance = 0 + AND imagenes.idimagen = '$imageid' + LIMIT 1; +EOD; + $rs=new Recordset; + $rs->Comando=&$cmd; + if (!$rs->Abrir()) return(false); // Error opening recordset. + // Check if user is admin and client exists. + $rs->Primero(); + if (checkAdmin($rs->campos["idusuario"]) and checkParameter($rs->campos["idordenador"])) { + // Read query data. + $clntip = $rs->campos["ip"]; + $clntmac = $rs->campos["mac"]; + $clntnetmask = $rs->campos["mascara"]; + $agentkey = $rs->campos["agentkey"]; + $disk = $rs->campos["numdisk"]; + $part = $rs->campos["numpar"]; + $repoip = $rs->campos["repoip"]; + $repokey = $rs->campos["repokey"]; + // Check client's status. + $ogagent = [['url' => "https://$clntip:8000/opengnsys/status"]]; + if ($app->settings['debug']) + writeRemotepcLog("{$app->request()->getResourceUri()}: OGAgent status, url={$ogagent[0]['url']}."); + $result = multiRequest($ogagent); + if (empty($result[0]['data'])) { + // Client is off, send WOL command to ogAdmServer. + // TODO: if client is busy????? + if ($app->settings['debug']) + writeRemotepcLog("{$app->request()->getResourceUri()}: Send boot command through ogAdmServer: iph=$clntip,mac=$clntmac."); + wol(1, [$clntmac], [$clntip], [$clntnetmask]); + // Send WOL command to client repository. + $repo = [['url' => "https://$repoip/opengnsys/rest/repository/poweron", + 'header' => ["Authorization: $repokey"], + 'post' => '{"macs": ["'.$clntmac.'"], "ips": ["'.$clntip.'"]}']]; + if ($app->settings['debug']) + writeRemotepcLog("{$app->request()->getResourceUri()}: Send Boot command through repo: repo=$repoip,ip=$clntip,mac=$clntmac."); + $result = multiRequest($repo); + } + // Create an init session on opertions queue. + $cmd->texto = <<<EOD +INSERT INTO acciones + SET tipoaccion=$EJECUCION_COMANDO, + idtipoaccion=9, + idcomando=9, + parametros='nfn=IniciarSesion\rdsk=$disk\rpar=$part', + descriaccion='RemotePC Session', + idordenador=$clntid, + ip='$clntip', + sesion=$timestamp, + fechahorareg=NOW(), + estado=$ACCION_INICIADA, + resultado=$ACCION_SINRESULTADO, + ambito=$AMBITO_ORDENADORES, + idambito=$clntid, + restrambito='$clntip', + idcentro=$ouid; +EOD; + $cmd->Ejecutar(); + // Create event to remove the operation on timeout (15 min.). + $timeout = "15 MINUTE"; + $cmd->texto = <<<EOD +CREATE EVENT IF NOT EXISTS e_timeout_$clntid + ON SCHEDULE AT CURRENT_TIMESTAMP + INTERVAL $timeout DO + BEGIN + SET @action_id = NULL; + UPDATE acciones + SET estado = $ACCION_FINALIZADA, resultado = $ACCION_FALLIDA, + descrinotificacion = 'Timeout' + WHERE descriaccion = 'RemotePC Session' AND estado = $ACCION_INICIADA + AND idordenador = '$clntid' + AND (SELECT @action_id := idaccion); + IF @action_id IS NOT NULL THEN + DELETE FROM acciones + WHERE idaccion = @action_id; + END IF; + END +EOD; + $cmd->Ejecutar(); + if ($app->settings['debug']) + writeRemotepcLog("{$app->request()->getResourceUri()}: DB tables and events updated, clntid=$clntid."); + // Send init session command if client is booted on ogLive. + if ($app->settings['debug']) + writeRemotepcLog("{$app->request()->getResourceUri()}: Send Init Session command to ogAdmClient, ido=$clntid,iph=$clntip,dsk=$disk,par=$part."); + session($clntip, "$disk\r$part"); + // Confirm operation. + $response = []; + jsonResponse(200, $response); + } else { + // Error message. + $response["message"] = "Client with this image not found"; + jsonResponse(404, $response); + } + $rs->Cerrar(); + } +); + |