<?php

class VigiloHooks

{

    // Callbacks pour différents événements

    // concernant les équipements supportés.

    public function preItemUpdate($item)

    {

        $index = PluginVigiloTemplate::getTemplateIndexForItem($item);

        $item->fields['vigilo_template'] = (int) $index;

    }

    public function itemAddOrUpdate($item)

    {

        global $DB;

        $templates  = PluginVigiloTemplate::getTemplates();

        $tplId      = (int) $item->input['vigilo_template'];

        if ($tplId > 0 && $tplId < count($templates)) {

            $id         = $item->getID();

            $template   = $DB->escape($templates[$tplId]);

            $query      = <<<SQL

INSERT INTO `glpi_plugin_vigilo_template`(`id`, `template`)

VALUES ($id, '$template')

ON DUPLICATE KEY UPDATE `template` = '$template';

SQL;

            $DB->query($query);

        }

        // Si la mise à jour modifie le technicien associé à la machine,

        // il peut-être nécessaire de mettre à jour les groupes de Vigilo.

        if (!empty($item->fields['users_id_tech'])) {

            $this->updateGroups(null);

        }

        $this->update($item);

    }

    public function itemPurge($item)

    {

        global $DB;

        $id         = $item->getID();

        $query      = "DELETE FROM `glpi_plugin_vigilo_template` WHERE `id` = $id;";

        $DB->query($query);

        $this->unmonitor($item->getField('name'));

        // Si la mise à jour modifie le technicien associé à la machine,

        // il peut-être nécessaire de mettre à jour les groupes de Vigilo.

        if (!empty($item->fields['users_id_tech'])) {

            $this->updateGroups(null);

        }

    }

    // Méthodes outils / annexes

    public function writeVigiloConfig($obj, $objtype)

    {

        $dirs       = array(VIGILO_CONFDIR, $objtype, "managed");

        $confdir    = implode(DIRECTORY_SEPARATOR, $dirs);

        $file       = $confdir . DIRECTORY_SEPARATOR . $obj->getName() . ".xml";

        if (!file_exists($confdir)) {

            mkdir($confdir, 0770, true);

        }

        $outXML = new DOMDocument();

        $outXML->preserveWhiteSpace = false;

        $outXML->formatOutput       = true;

        $outXML->loadXML((string) $obj);

        $res = file_put_contents($file, $outXML->saveXML(), LOCK_EX);

        if (false !== $res) {

            @chgrp($file, "vigiconf");

            @chmod($file, 0660);

        }

    }

    // Méthodes d'ajout / mise à jour / suppression de la supervision

    // pour un objet équipement supporté.

    public function delete($computer)

    {

        global $DB;

        $this->unmonitor($computer->fields["name"]);

        $query = "UPDATE `glpi_plugin_vigilo_config` SET `value` = 1 WHERE `key` = 'needs_deploy';";

        $DB->query($query);

    }

    public function update($item)

    {

        global $DB;

        if (isset($item->oldvalues["name"])) {

            $this->unmonitor($item->oldvalues["name"]);

        }

        $query = "UPDATE `glpi_plugin_vigilo_config` SET `value` = 1 WHERE `key` = 'needs_deploy';";

        $DB->query($query);

        // "is_template" vaut "1" (sous forme de chaîne de caractères)

        // lorsque l'objet passé fait référence à un modèle dans GLPI,

        // et "0" lorsque ce n'est pas le cas.

        // MAIS, il peut aussi valoir NOT_AVAILABLE ("N/A") lors de la création

        // d'un nouvel objet (car l'attribut n'est pas encore défini).

        // Le cast sur le champ permet de gérer ces 3 cas.

        if ((int) $item->getField("is_template")) {

            return;

        }

        $cls = "PluginVigiloMonitored" . $item->getType();

        if (class_exists($cls, true)) {

            $obj = new $cls($item);

            // Ecriture du fichier de configuration principal (host).

            $this->writeVigiloConfig($obj, "hosts");

            /*

            @FIXME  Ce code pose encore des problèmes, et le fait de n'afficher

                    que l'état de l'hôte sur les cartes auto-générées est un

                    point bloquant. Cf. ticket #1593.

            // Création d'un service de haut niveau "services:<nom>"

            // qui affichera le pire état des services de la machine "<nom>",

            // et d'un service "machine:<nom>" qui affichera le pire état

            // entre l'état de la machine "<nom>" et de ses services.

            $hls = new PluginVigiloHls($obj);

            $this->writeVigiloConfig($hls, "hlservices");

            */

        }

    }

    public function unmonitor($host)

    {

        $dirs = array(

            array(VIGILO_CONFDIR, "hosts", "managed", $host . ".xml"),

            array(VIGILO_CONFDIR, "hlservices", "managed", $host . ".xml"),

        );

        foreach ($dirs as $components) {

            $filename = implode(DIRECTORY_SEPARATOR, $components);

            if (file_exists($filename)) {

                unlink($filename);

            }

        }

    }

    // Méthodes de mise à jour d'un équipement

    // lorsque l'un de ses composants change.

    // Mise à jour de la version d'un logiciel associé à un ordinateur

    public function refreshComputerSoftwareVersion($version)

    {

        $computer = new Computer();

        $computer->getFromDB($version->getField("computers_id"));

        $this->update($computer);

    }

    // Mise à jour (d'une version) d'un logiciel associé à un ordinateur

    public function refreshSoftware($software)

    {

        if ($software instanceof SoftwareVersion) {

            $versions = array(

                array('id' => $software->getID())

            );

        } else {

            $softwareVer    = new SoftwareVersion();

            $versions       = $softwareVer->find('softwares_id=' . $software->getID());

        }

        foreach ($versions as $version) {

            if (!$version['id']) {

                continue;

            }

            $installations  = new Computer_SoftwareVersion();

            $filter         = 'softwareversions_id=' . $version['id'];

            $installations  = $installations->find($filter);

            foreach ($installations as $installation) {

                if (-1 === $installation['computers_id']) {

                    continue;

                }

                $computer = new Computer();

                $computer->getFromDB($installation['computers_id']);

                $this->update($computer);

            }

        }

    }

    // Mise à jour d'un volume associé à un ordinateur

    public function refreshDisk($disk)

    {

        $id = $disk->getField('computers_id');

        $computer = new Computer();

        $computer->getFromDB($id);

        $this->update($computer);

    }

    // Mise à jour d'une adresse IP associées à un ordinateur

    public function refreshAddress($address)

    {

        $id         = $address->getField('mainitems_id');

        $itemtype   = $address->getField('mainitemtype');

        $item       = new $itemtype();

        $item->getFromDB($id);

        $this->update($item);

    }

    // Mise à jour d'un périphérique associé à un ordinateur

    public function refreshDevice($device)

    {

        $id         = $device->getField('items_id');

        $itemtype   = $device->getField('itemtype');

        $item       = new $itemtype();

        $item->getFromDB($id);

        $this->update($item);

    }

    // Méthode de mise à jour en cas d'évolution de l'emplacement,

    // de l'entité ou du fabricant d'un équipement.

    public function updateGroups($obj)

    {

        $groups = new PluginVigiloGroups();

        $this->writeVigiloConfig($groups, "groups");

    }

}