glpi / src / plugins / vigilo / vigilo_hooks.php @ c24d7938
History | View | Annotate | Download (6.73 KB)
1 |
<?php
|
---|---|
2 |
|
3 |
class VigiloHooks |
4 |
{ |
5 |
// Callbacks pour différents événements
|
6 |
// concernant les équipements supportés.
|
7 |
public function preItemUpdate($item) |
8 |
{ |
9 |
$index = PluginVigiloTemplate::getTemplateIndexForItem($item); |
10 |
$item->fields['vigilo_template'] = (int) $index; |
11 |
} |
12 |
|
13 |
public function itemAddOrUpdate($item) |
14 |
{ |
15 |
global $DB; |
16 |
|
17 |
$templates = PluginVigiloTemplate::getTemplates(); |
18 |
$tplId = (int) $item->input['vigilo_template']; |
19 |
|
20 |
if ($tplId > 0 && $tplId < count($templates)) { |
21 |
$id = $item->getID(); |
22 |
$template = $DB->escape($templates[$tplId]); |
23 |
$query = <<<SQL |
24 |
INSERT INTO `glpi_plugin_vigilo_template`(`id`, `template`)
|
25 |
VALUES ($id, '$template')
|
26 |
ON DUPLICATE KEY UPDATE `template` = '$template';
|
27 |
SQL;
|
28 |
$DB->query($query); |
29 |
} |
30 |
|
31 |
// Si la mise à jour modifie le technicien associé à la machine,
|
32 |
// il peut-être nécessaire de mettre à jour les groupes de Vigilo.
|
33 |
if (!empty($item->fields['users_id_tech'])) { |
34 |
$this->updateGroups(null); |
35 |
} |
36 |
|
37 |
$this->update($item); |
38 |
} |
39 |
|
40 |
public function itemPurge($item) |
41 |
{ |
42 |
global $DB; |
43 |
|
44 |
$id = $item->getID(); |
45 |
$query = "DELETE FROM `glpi_plugin_vigilo_template` WHERE `id` = $id;"; |
46 |
$DB->query($query); |
47 |
$this->unmonitor($item->getField('name')); |
48 |
|
49 |
// Si la mise à jour modifie le technicien associé à la machine,
|
50 |
// il peut-être nécessaire de mettre à jour les groupes de Vigilo.
|
51 |
if (!empty($item->fields['users_id_tech'])) { |
52 |
$this->updateGroups(null); |
53 |
} |
54 |
} |
55 |
|
56 |
// Méthodes outils / annexes
|
57 |
public function writeVigiloConfig($obj, $objtype) |
58 |
{ |
59 |
$dirs = array(VIGILO_CONFDIR, $objtype, "managed"); |
60 |
$confdir = implode(DIRECTORY_SEPARATOR, $dirs); |
61 |
$file = $confdir . DIRECTORY_SEPARATOR . $obj->getName() . ".xml"; |
62 |
|
63 |
if (!file_exists($confdir)) { |
64 |
mkdir($confdir, 0770, true); |
65 |
} |
66 |
|
67 |
$outXML = new DOMDocument(); |
68 |
$outXML->preserveWhiteSpace = false; |
69 |
$outXML->formatOutput = true; |
70 |
$outXML->loadXML((string) $obj); |
71 |
$res = file_put_contents($file, $outXML->saveXML(), LOCK_EX); |
72 |
if (false !== $res) { |
73 |
@chgrp($file, "vigiconf"); |
74 |
@chmod($file, 0660); |
75 |
} |
76 |
} |
77 |
|
78 |
// Méthodes d'ajout / mise à jour / suppression de la supervision
|
79 |
// pour un objet équipement supporté.
|
80 |
public function delete($computer) |
81 |
{ |
82 |
global $DB; |
83 |
|
84 |
$this->unmonitor($computer->fields["name"]); |
85 |
|
86 |
$query = "UPDATE `glpi_plugin_vigilo_config` SET `value` = 1 WHERE `key` = 'needs_deploy';"; |
87 |
$DB->query($query); |
88 |
} |
89 |
|
90 |
public function update($item) |
91 |
{ |
92 |
global $DB; |
93 |
|
94 |
if (isset($item->oldvalues["name"])) { |
95 |
$this->unmonitor($item->oldvalues["name"]); |
96 |
} |
97 |
|
98 |
$query = "UPDATE `glpi_plugin_vigilo_config` SET `value` = 1 WHERE `key` = 'needs_deploy';"; |
99 |
$DB->query($query); |
100 |
|
101 |
// "is_template" vaut "1" (sous forme de chaîne de caractères)
|
102 |
// lorsque l'objet passé fait référence à un modèle dans GLPI,
|
103 |
// et "0" lorsque ce n'est pas le cas.
|
104 |
// MAIS, il peut aussi valoir NOT_AVAILABLE ("N/A") lors de la création
|
105 |
// d'un nouvel objet (car l'attribut n'est pas encore défini).
|
106 |
// Le cast sur le champ permet de gérer ces 3 cas.
|
107 |
if ((int) $item->getField("is_template")) { |
108 |
return;
|
109 |
} |
110 |
|
111 |
$cls = "PluginVigiloMonitored" . $item->getType(); |
112 |
if (class_exists($cls, true)) { |
113 |
$obj = new $cls($item); |
114 |
|
115 |
// Ecriture du fichier de configuration principal (host).
|
116 |
$this->writeVigiloConfig($obj, "hosts"); |
117 |
|
118 |
// Création d'un service de haut niveau "services:<nom>"
|
119 |
// qui affichera le pire état des services de la machine "<nom>",
|
120 |
// et d'un service "machine:<nom>" qui affichera le pire état
|
121 |
// entre l'état de la machine "<nom>" et de ses services.
|
122 |
$hls = new PluginVigiloHls($obj); |
123 |
$this->writeVigiloConfig($hls, "hlservices"); |
124 |
} |
125 |
} |
126 |
|
127 |
public function unmonitor($host) |
128 |
{ |
129 |
$dirs = array( |
130 |
array(VIGILO_CONFDIR, "hosts", "managed", $host . ".xml"), |
131 |
array(VIGILO_CONFDIR, "hlservices", "managed", $host . ".xml"), |
132 |
); |
133 |
foreach ($dirs as $components) { |
134 |
$filename = implode(DIRECTORY_SEPARATOR, $components); |
135 |
if (file_exists($filename)) { |
136 |
unlink($filename); |
137 |
} |
138 |
} |
139 |
} |
140 |
|
141 |
// Méthodes de mise à jour d'un équipement
|
142 |
// lorsque l'un de ses composants change.
|
143 |
public function refreshSoftwareVersion($version) |
144 |
{ |
145 |
$computer = new Computer(); |
146 |
$computer->getFromDB($version->getField("computers_id")); |
147 |
$this->update($computer); |
148 |
} |
149 |
|
150 |
public function refreshSoftware($software) |
151 |
{ |
152 |
$softwareVer = new SoftwareVersion(); |
153 |
$versions = $softwareVer->find('softwares_id=' . $software->getID()); |
154 |
foreach ($versions as $version) { |
155 |
if (!$version['id']) { |
156 |
continue;
|
157 |
} |
158 |
|
159 |
$installations = new Computer_SoftwareVersion(); |
160 |
$filter = 'softwareversions_id=' . $version['id']; |
161 |
$installations = $installations->find($filter); |
162 |
foreach ($installations as $installation) { |
163 |
if (-1 === $installation['computers_id']) { |
164 |
continue;
|
165 |
} |
166 |
|
167 |
$computer = new Computer(); |
168 |
$computer->getFromDB($installation['computers_id']); |
169 |
$this->update($computer); |
170 |
} |
171 |
} |
172 |
} |
173 |
|
174 |
public function refreshDisk($disk) |
175 |
{ |
176 |
$id = $disk->getField('computers_id'); |
177 |
$computer = new Computer(); |
178 |
$computer->getFromDB($id); |
179 |
$this->update($computer); |
180 |
} |
181 |
|
182 |
public function refreshAddress($address) |
183 |
{ |
184 |
$id = $address->getField('mainitems_id'); |
185 |
$itemtype = $address->getField('mainitemtype'); |
186 |
$item = new $itemtype(); |
187 |
$item->getFromDB($id); |
188 |
$this->update($item); |
189 |
} |
190 |
|
191 |
public function refreshDevice($device) |
192 |
{ |
193 |
$id = $device->getField('items_id'); |
194 |
$itemtype = $device->getField('itemtype'); |
195 |
$item = new $itemtype(); |
196 |
$item->getFromDB($id); |
197 |
$this->update($item); |
198 |
} |
199 |
|
200 |
// Méthode de mise à jour en cas d'évolution de l'emplacement,
|
201 |
// de l'entité ou du fabricant d'un équipement.
|
202 |
public function updateGroups($obj) |
203 |
{ |
204 |
$groups = new PluginVigiloGroups(); |
205 |
$this->writeVigiloConfig($groups, "groups"); |
206 |
} |
207 |
} |