jaro/remotesupport
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Use go program for checks

Browse Source
This commit is contained in:
Jaroslav Drzik
2021-12-09 18:30:30 +01:00
parent 6d0f7fb392
commit 50e9338059
3 changed files with 231 additions and 27 deletions
Download Patch File Download Diff File Expand all files Collapse all files

84
inc/remotesupport.class.php
View File

@@ -60,43 +60,77 @@ class PluginRemotesupportRemotesupport extends CommonDBTM {
Toolbox::logInFile("remotsupport","Starting search of agents\n");
$agents = [];
$data_set = [];
$check_arr = [];
$comps = [];
$pfInventoryComputerComputer = new PluginFusioninventoryInventoryComputerComputer();
foreach (getAllDataFromTable(PluginFusioninventoryAgent::getTable()) as $a) {
$check = [];
$a_computerextend = $pfInventoryComputerComputer->hasAutomaticInventory($a["computers_id"]);
$check["url"] = "http://".$a_computerextend["remote_addr"].":62354/status";
$check["id"] = $a["id"];
$check["computers_id"] = $a["computers_id"];
$check["status"] = "unknown";
$check_arr[] = $check;
$comps[$a["computers_id"]] = $check;
//print_r($agent->getAgentStatusURLs());
}
$descriptorspec = array(
0 => array("pipe", "r"), // stdin is a pipe that the child will read from
1 => array("pipe", "w"), // stdout is a pipe that the child will write to
2 => array("file", "/tmp/error-output.txt", "a") // stderr is a file to write to
);
$cwd = '/tmp';
$env = array('debug' => 'false');
$process = proc_open(__DIR__.'/check_status', $descriptorspec, $pipes, $cwd, $env);
if (is_resource($process)) {
// $pipes now looks like this:
// 0 => writeable handle connected to child stdin
// 1 => readable handle connected to child stdout
// Any error output will be appended to /tmp/error-output.txt
fwrite($pipes[0], json_encode($check_arr));
fclose($pipes[0]);
$checked = json_decode(stream_get_contents($pipes[1]));
fclose($pipes[1]);
// It is important that you close any pipes before calling
// proc_close in order to avoid a deadlock
$return_value = proc_close($process);
Toolbox::logInFile("remotsupport","command returned $return_value\n");
}
$stids = self::getStatesIds();
foreach (getAllDataFromTable(PluginFusioninventoryAgent::getTable()) as $a) {
$data_set[] = $a["id"];
$agents[$a["id"]] = $a;
}
$DB->update("glpi_computers", [
'states_id' => $stids["Offline"] ] ,
[ '1' => '1' ]
);
foreach ($data_set as $id) {
$agent = new PluginFusioninventoryAgent;
$agent->getFromDB((int)$id);
$st = $agent->getStatus();
if ($st["message"] != "noanswer")
Toolbox::logInFile("remotsupport",print_r($agents[$id],true));
foreach ($checked as $s) {
$comp = new Computer();
$comp->getFromDB($agents[$id]["computers_id"]);
if ($st["message"] == "noanswer")
$comp->fields["states_id"] = $stids["Offline"];
else
$comp->fields["states_id"] = $stids["Online"];
$comp->getFromDB($s->computers_id);
$comp->fields["states_id"] = $stids["Online"];
$DB->update("glpi_computers", [
'states_id' => $comp->fields["states_id"] ],
[ 'id' => $agents[$id]["computers_id"] ]
[ 'id' => $s->computers_id ]
);
$comp->fields["contact"]."\n";
Toolbox::logInFile("remotsupport",$s->computers_id." ".$comp->fields["contact"]."\n");
}
return true;
return 0;
}
static function cronInfo($name) {