Source of file proApi.php

<?php

/* This file is part of Jeedom.

 *

 * Jeedom is free software: you can redistribute it and/or modify

 * it under the terms of the GNU General Public License as published by

 * the Free Software Foundation, either version 3 of the License, or

 * (at your option) any later version.

 *

 * Jeedom is distributed in the hope that it will be useful,

 * but WITHOUT ANY WARRANTY; without even the implied warranty of

 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the

 * GNU General Public License for more details.

 *

 * You should have received a copy of the GNU General Public License

 * along with Jeedom. If not, see <http://www.gnu.org/licenses/>.

 */

require_once __DIR__ . "/../../src/core.php";

use NextDom\Helpers\FileSystemHelper;

use NextDom\Helpers\Utils;

use NextDom\Managers\BackupManager;

use NextDom\Enums\NextDomFile;

if (isset($argv)) {

    foreach ($argv as $arg) {

        $argList = explode('=', $arg);

        if (isset($argList[0]) && isset($argList[1])) {

            $_REQUEST[$argList[0]] = $argList[1];

        }

    }

}

try {

    $IP = getClientIp();

    $request = init('request');

    if ($request == '') {

        $request = file_get_contents("php://input");

    }

    log::add('apipro', 'info', $request . ' - IP :' . $IP);

    $jsonrpc = new jsonrpc($request);

    if (!nextdom::apiModeResult(config::byKey('api::core::pro::mode', 'core', 'enable'))) {

        throw new Exception(__('Vous n\'êtes pas autorisé à effectuer cette action', __FILE__), -32001);

    }

    if ($jsonrpc->getJsonrpc() != '2.0') {

        throw new Exception(__('Requête invalide. Version JSON-RPC invalide : ' . $jsonrpc->getJsonrpc(), __FILE__), -32001);

    }

    $params = $jsonrpc->getParams();

    if (!isset($params['proapi'])) {

        throw new Exception(__('Vous n\'êtes pas autorisé à effectuer cette action', __FILE__), -32001);

    }

    if (isset($params['proapi']) && !nextdom::apiAccess($params['proapi'], 'apipro')) {

        throw new Exception(__('Vous n\'êtes pas autorisé à effectuer cette action', __FILE__), -32001);

    }

    log::add('api', 'info', __('connexion valide et verifiée : ' . $jsonrpc->getMethod(), __FILE__));

    /*             * ************************config*************************** */

    if ($jsonrpc->getMethod() == 'config::byKey') {

        $jsonrpc->makeSuccess(config::byKey($params['key'], $params['plugin'], $params['default']));

    }

    if ($jsonrpc->getMethod() == 'config::save') {

        $jsonrpc->makeSuccess(config::save($params['key'], $params['value'], $params['plugin']));

    }

    if (isset($params['plugin']) && $params['plugin'] != '') {

        log::add('api', 'info', 'Demande pour le plugin : ' . secureXSS($params['plugin']));

        include_file('core', $params['plugin'], 'api', $params['plugin']);

    } else {

        /*             * ***********************Ping********************************* */

        if ($jsonrpc->getMethod() == 'ping') {

            $jsonrpc->makeSuccess('pong');

        }

        /*             * ***********************Version********************************* */

        if ($jsonrpc->getMethod() == 'version') {

            $jsonrpc->makeSuccess(nextdom::version());

        }

        /*             * ***********************Health********************************* */

        if ($jsonrpc->getMethod() == 'health') {

            $health = [];

            $defaut = 0;

            $result = 'OK';

            $advice = '';

            $nbNeedUpdate = update::nbNeedUpdate();

            if ($nbNeedUpdate > 0) {

                $defaut = 1;

                $result = $nbNeedUpdate;

            }

            $health[] = ['plugin' => 'core', 'type' => 'Système à jour', 'defaut' => $defaut, 'result' => $result, 'advice' => $advice];

            $defaut = 0;

            $result = 'OK';

            $advice = '';

            if (config::byKey('enableCron', 'core', 1, true) == 0) {

                $defaut = 1;

                $result = 'NOK';

                $advice = __('Erreur cron : les crons sont désactivés. Allez dans Administration -> Moteur de tâches pour les réactiver', __FILE__);

            }

            $health[] = ['plugin' => 'core', 'type' => 'Cron actif', 'defaut' => $defaut, 'result' => $result, 'advice' => $advice];

            $defaut = 0;

            $result = 'OK';

            $advice = '';

            if (config::byKey('enableScenario') == 0 && count(scenario::all()) > 0) {

                $defaut = 1;

                $result = 'NOK';

                $advice = __('Erreur scénario : tous les scénarios sont désactivés. Allez dans Outils -> Scénarios pour les réactiver', __FILE__);

            }

            $health[] = ['plugin' => 'core', 'type' => 'Scénario actif', 'defaut' => $defaut, 'result' => $result, 'advice' => $advice];

            $defaut = 0;

            $result = 'OK';

            $advice = '';

            if (!nextdom::isStarted()) {

                $defaut = 1;

                $result = 'NOK';

            }

            $health[] = ['plugin' => 'core', 'type' => 'Démarré', 'defaut' => $defaut, 'result' => $result, 'advice' => $advice];

            $defaut = 0;

            $result = 'OK';

            $advice = '';

            if (!nextdom::isDateOk()) {

                $defaut = 1;

                $result = date('Y-m-d H:i:s');

            }

            $health[] = ['plugin' => 'core', 'type' => 'Date système', 'defaut' => $defaut, 'result' => $result, 'advice' => $advice];

            $defaut = 0;

            $result = 'OK';

            $advice = '';

            if (!nextdom::isCapable('sudo')) {

                $defaut = 1;

                $result = 'NOK';

                $advice = 'Donnez les droits root à NextDom.';

            }

            $health[] = ['plugin' => 'core', 'type' => 'Droits sudo', 'defaut' => $defaut, 'result' => $result, 'advice' => $advice];

            $defaut = 0;

            $result = nextdom::version();

            $advice = '';

            $health[] = ['plugin' => 'core', 'type' => 'Version NextDom', 'defaut' => $defaut, 'result' => $result, 'advice' => $advice];

            $defaut = 0;

            $result = phpversion();

            $advice = '';

            if (version_compare(phpversion(), '5.5', '<')) {

                $defaut = 1;

                $advice = __('Si vous êtes en version 5.4.x, on vous indiquera quand la version 5.5 sera obligatoire', __FILE__);

            }

            $health[] = ['plugin' => 'core', 'type' => 'Version PHP', 'defaut' => $defaut, 'result' => $result, 'advice' => $advice];

            $defaut = 0;

            $version = DB::Prepare('select version()', [], DB::FETCH_TYPE_ROW);

            $result = $version['version()'];

            $advice = '';

            $health[] = ['plugin' => 'core', 'type' => 'Version database', 'defaut' => $defaut, 'result' => $result, 'advice' => $advice];

            $defaut = 0;

            $result = nextdom::checkSpaceLeft();

            $advice = '';

            if ($result < 10) {

                $defaut = 1;

            }

            $health[] = ['plugin' => 'core', 'type' => 'Espace disque libre', 'defaut' => $defaut, 'result' => $result . ' %', 'advice' => $advice];

            $defaut = 0;

            $result = 'OK';

            $advice = '';

            if (!network::test('internal')) {

                $defaut = 1;

                $result = 'NOK';

                $advice = __('Allez sur Administration -> Configuration -> Réseaux, puis configurez correctement la partie réseau', __FILE__);

            }

            $health[] = ['plugin' => 'core', 'type' => 'Configuration réseau interne', 'defaut' => $defaut, 'result' => $result, 'advice' => $advice];

            $defaut = 0;

            $result = 'OK';

            $advice = '';

            if (!network::test('external')) {

                $defaut = 1;

                $result = 'NOK';

                $advice = __('Allez sur Administration -> Configuration -> Réseaux, puis configurez correctement la partie réseau', __FILE__);

            }

            $health[] = ['plugin' => 'core', 'type' => 'Configuration réseau externe', 'defaut' => $defaut, 'result' => $result, 'advice' => $advice];

            $defaut = 0;

            $advice = '';

            if (cache::isPersistOk()) {

                if (config::byKey('cache::engine') != 'FilesystemCache' && config::byKey('cache::engine') != 'PhpFileCache') {

                    $result = 'OK';

                } else {

                    $filename = NEXTDOM_DATA . '/' . NextDomFile::CACHE_TAR_GZ;

                    $result = 'OK (' . date('Y-m-d H:i:s', filemtime($filename)) . ')';

                }

            } else {

                $result = 'NOK';

                $defaut = 1;

                $advice = __('Votre cache n\'est pas sauvegardé. En cas de redémarrage, certaines informations peuvent être perdues. Essayez de lancer (à partir du moteur de tâches) la tâche cache::persist.', __FILE__);

            }

            $health[] = ['plugin' => 'core', 'type' => 'Persistance du cache', 'defaut' => $defaut, 'result' => $result, 'advice' => $advice];

            foreach (plugin::listPlugin(true) as $plugin) {

                $plugin_id = $plugin->getId();

                $result = 'OK';

                $defaut = 0;

                $advice = '';

                $hasSpecificHealth = 0;

                $hasSpecificHealthIcon = '';

                try {

                    if ($plugin->getHasDependency() == 1) {

                        $dependancy_info = $plugin->getDependencyInfo();

                        switch ($dependancy_info['state']) {

                            case 'ok':

                                $result = 'OK';

                                $defaut = 0;

                                break;

                            case 'nok':

                                $result = 'NOK';

                                $defaut = 1;

                                break;

                            case 'in_progress':

                                $result = 'En cours';

                                $defaut = 0;

                                break;

                            default:

                                break;

                        }

                        $health[] = ['plugin' => $plugin_id, 'type' => 'dépendance', 'defaut' => $defaut, 'result' => $result, 'advice' => $advice];

                    }

                } catch (Exception $e) {

                }

                try {

                    if ($plugin->getHasOwnDeamon() == 1) {

                        $deamon_info = $plugin->deamon_info();

                        switch ($deamon_info['launchable']) {

                            case 'ok':

                                $result = 'OK';

                                $defaut = 0;

                                break;

                            case 'nok':

                                if ($deamon_info['auto'] != 1) {

                                    $result = 'Désactivé';

                                    $defaut = 0;

                                    $advice = $deamon_info['launchable_message'];

                                } else {

                                    $result = 'NOK';

                                    $defaut = 1;

                                    $advice = $deamon_info['launchable_message'];

                                }

                                break;

                        }

                        $health[] = ['plugin' => $plugin_id, 'type' => 'Configuration démon', 'defaut' => $defaut, 'result' => $result, 'advice' => $advice];

                        switch ($deamon_info['state']) {

                            case 'ok':

                                $result = 'OK';

                                $defaut = 0;

                                break;

                            case 'nok':

                                if ($deamon_info['auto'] != 1) {

                                    $result = 'Désactivé';

                                    $defaut = 0;

                                } else {

                                    $result = 'NOK';

                                    $defaut = 1;

                                }

                                break;

                        }

                        $health[] = ['plugin' => $plugin_id, 'type' => 'Statut démon', 'defaut' => $defaut, 'result' => $result, 'advice' => $advice];

                    }

                } catch (Exception $e) {

                }

                try {

                    if (method_exists($plugin->getId(), 'health')) {

                        foreach ($plugin_id::health() as $result) {

                            if ($result['state']) {

                                $defaut = 0;

                            } else {

                                $defaut = 1;

                            }

                            $health[] = ['plugin' => $plugin_id, 'type' => $result['test'], 'defaut' => $defaut, 'result' => $result['result'], 'advice' => $result['advice']];

                        }

                    }

                } catch (Exception $e) {

                }

            }

            $jsonrpc->makeSuccess($health);

        }

        /*             * ************************Plugin*************************** */

        if ($jsonrpc->getMethod() == 'plugin::listPlugin') {

            $activateOnly = (isset($params['activateOnly']) && $params['activateOnly'] == 1) ? true : false;

            $orderByCaterogy = (isset($params['orderByCaterogy']) && $params['orderByCaterogy'] == 1) ? true : false;

            $jsonrpc->makeSuccess(utils::o2a(plugin::listPlugin($activateOnly, $orderByCaterogy)));

        }

        /*             * ************************Object*************************** */

        if ($jsonrpc->getMethod() == 'jeeObject::all') {

            $jsonrpc->makeSuccess(utils::o2a(jeeObject::all()));

        }

        if ($jsonrpc->getMethod() == 'jeeObject::byId') {

            $jeeObject = jeeObject::byId($params['id']);

            if (!is_object($jeeObject)) {

                throw new Exception('Objet introuvable : ' . secureXSS($params['id']), -32601);

            }

            $jsonrpc->makeSuccess(utils::o2a($jeeObject));

        }

        if ($jsonrpc->getMethod() == 'jeeObject::full') {

            $jsonrpc->makeSuccess(jeeObject::fullData());

        }

        if ($jsonrpc->getMethod() == 'jeeObject::fullById') {

            $jeeObject = jeeObject::byId($params['id']);

            if (!is_object($jeeObject)) {

                throw new Exception('Objet introuvable : ' . secureXSS($params['id']), -32601);

            }

            $return = utils::o2a($jeeObject);

            $return['eqLogics'] = [];

            foreach ($jeeObject->getEqLogic() as $eqLogic) {

                $eqLogic_return = utils::o2a($eqLogic);

                $eqLogic_return['cmds'] = [];

                foreach ($eqLogic->getCmd() as $cmd) {

                    $cmd_return = utils::o2a($cmd);

                    if ($cmd->getType() == 'info') {

                        $cmd_return['state'] = $cmd->execCmd();

                    }

                    $eqLogic_return['cmds'][] = $cmd_return;

                }

                $return['eqLogics'][] = $eqLogic_return;

            }

            $jsonrpc->makeSuccess($return);

        }

        /*             * ************************datastore*************************** */

        if ($jsonrpc->getMethod() == 'datastore::byTypeLinkIdKey') {

            $jsonrpc->makeSuccess(dataStore::byTypeLinkIdKey($params['type'], $params['linkId'], $params['key']));

        }

        if ($jsonrpc->getMethod() == 'datastore::save') {

            $dataStore = new dataStore();

            $dataStore->setType($params['type']);

            $dataStore->setKey($params['key']);

            $dataStore->setValue($params['value']);

            $dataStore->setLink_id($params['linkId']);

            $dataStore->save();

            $jsonrpc->makeSuccess('ok');

        }

        /*             * ************************Equipement*************************** */

        if ($jsonrpc->getMethod() == 'eqLogic::all') {

            $jsonrpc->makeSuccess(utils::o2a(eqLogic::all()));

        }

        if ($jsonrpc->getMethod() == 'eqLogic::byType') {

            $jsonrpc->makeSuccess(utils::o2a(eqLogic::byType($params['type'])));

        }

        if ($jsonrpc->getMethod() == 'eqLogic::byObjectId') {

            $jsonrpc->makeSuccess(utils::o2a(eqLogic::byObjectId($params['object_id'])));

        }

        if ($jsonrpc->getMethod() == 'eqLogic::byId') {

            $eqLogic = eqLogic::byId($params['id']);

            if (!is_object($eqLogic)) {

                throw new Exception('EqLogic introuvable : ' . secureXSS($params['id']), -32602);

            }

            $jsonrpc->makeSuccess(utils::o2a($eqLogic));

        }

        if ($jsonrpc->getMethod() == 'eqLogic::fullById') {

            $eqLogic = eqLogic::byId($params['id']);

            if (!is_object($eqLogic)) {

                throw new Exception('EqLogic introuvable : ' . secureXSS($params['id']), -32602);

            }

            $return = utils::o2a($eqLogic);

            $return['cmds'] = [];

            foreach ($eqLogic->getCmd() as $cmd) {

                $cmd_return = utils::o2a($cmd);

                if ($cmd->getType() == 'info') {

                    $cmd_return['state'] = $cmd->execCmd();

                }

                $return['cmds'][] = $cmd_return;

            }

            $jsonrpc->makeSuccess($return);

        }

        if ($jsonrpc->getMethod() == 'eqLogic::save') {

            $typeEqLogic = $params['eqType_name'];

            $typeCmd = $typeEqLogic . 'Cmd';

            if ($typeEqLogic == '' || !class_exists($typeEqLogic) || !class_exists($typeCmd)) {

                throw new Exception(__('Type incorrect (classe commande inexistante)', __FILE__) . secureXSS($typeCmd));

            }

            $eqLogic = null;

            if (isset($params['id'])) {

                $eqLogic = $typeEqLogic::byId($params['id']);

            }

            if (!is_object($eqLogic)) {

                $eqLogic = new $typeEqLogic();

                $eqLogic->setEqType_name($params['eqType_name']);

            }

            utils::a2o($eqLogic, nextdom::fromHumanReadable($params));

            $eqLogic->save();

            $dbList = $typeCmd::byEqLogicId($eqLogic->getId());

            $eqLogic->save();

            $enableList = [];

            if (isset($params['cmd'])) {

                $cmd_order = 0;

                foreach ($params['cmd'] as $cmd_info) {

                    $cmd = null;

                    if (isset($cmd_info['id'])) {

                        $cmd = $typeCmd::byId($cmd_info['id']);

                    }

                    if (!is_object($cmd)) {

                        $cmd = new $typeCmd();

                    }

                    $cmd->setEqLogic_id($eqLogic->getId());

                    $cmd->setOrder($cmd_order);

                    utils::a2o($cmd, nextdom::fromHumanReadable($cmd_info));

                    $cmd->save();

                    $cmd_order++;

                    $enableList[$cmd->getId()] = true;

                }

                //suppression des entrées inexistante.

                foreach ($dbList as $dbObject) {

                    if (!isset($enableList[$dbObject->getId()]) && !$dbObject->dontRemoveCmd()) {

                        $dbObject->remove();

                    }

                }

            }

            $jsonrpc->makeSuccess(utils::o2a($eqLogic));

        }

        if ($jsonrpc->getMethod() == 'eqLogic::byTypeAndId') {

            $return = [];

            foreach ($params['eqType'] as $eqType) {

                $info_eqLogics = [];

                foreach (eqLogic::byType($eqType) as $eqLogic) {

                    $info_cmds = [];

                    foreach ($eqLogic->getCmd() as $cmd) {

                        $info_cmd = utils::o2a($cmd);

                        if ($cmd->getType() == 'info') {

                            $info_cmd['value'] = $cmd->execCmd();

                            $info_cmd['collectDate'] = $cmd->getCollectDate();

                        }

                        $info_cmds[] = $info_cmd;

                    }

                    $info_eqLogic = utils::o2a($eqLogic);

                    $info_eqLogic['cmds'] = $info_cmds;

                    $info_eqLogics[] = $info_eqLogic;

                }

                $return[$eqType] = $info_eqLogics;

            }

            foreach ($params['id'] as $id) {

                $eqLogic = eqLogic::byId($id);

                $info_cmds = [];

                foreach ($eqLogic->getCmd() as $cmd) {

                    $info_cmd = utils::o2a($cmd);

                    if ($cmd->getType() == 'info') {

                        $info_cmd['value'] = $cmd->execCmd();

                        $info_cmd['collectDate'] = $cmd->getCollectDate();

                    }

                    $info_cmds[] = $info_cmd;

                }

                $info_eqLogic = utils::o2a($eqLogic);

                $info_eqLogic['cmds'] = $info_cmds;

                $return[$id] = $info_eqLogic;

            }

            $jsonrpc->makeSuccess($return);

        }

        /*             * ************************Commande*************************** */

        if ($jsonrpc->getMethod() == 'cmd::all') {

            $jsonrpc->makeSuccess(utils::o2a(cmd::all()));

        }

        if ($jsonrpc->getMethod() == 'cmd::byEqLogicId') {

            $jsonrpc->makeSuccess(utils::o2a(cmd::byEqLogicId($params['eqLogic_id'])));

        }

        if ($jsonrpc->getMethod() == 'cmd::byId') {

            $cmd = cmd::byId($params['id']);

            if (!is_object($cmd)) {

                throw new Exception(__('Commande introuvable : ', __FILE__) . secureXSS($params['id']), -32701);

            }

            $jsonrpc->makeSuccess(utils::o2a($cmd));

        }

        if ($jsonrpc->getMethod() == 'cmd::execCmd') {

            if (is_array($params['id'])) {

                $return = [];

                foreach ($params['id'] as $id) {

                    $cmd = cmd::byId($id);

                    if (!is_object($cmd)) {

                        throw new Exception(__('Commande introuvable : ', __FILE__) . secureXSS($id), -32702);

                    }

                    $return[$id] = ['value' => $cmd->execCmd($params['options']), 'collectDate' => $cmd->getCollectDate()];

                }

            } else {

                $cmd = cmd::byId($params['id']);

                if (!is_object($cmd)) {

                    throw new Exception(__('Commande introuvable : ', __FILE__) . secureXSS($params['id']), -32702);

                }

                $return = ['value' => $cmd->execCmd($params['options']), 'collectDate' => $cmd->getCollectDate()];

            }

            $jsonrpc->makeSuccess($return);

        }

        if ($jsonrpc->getMethod() == 'cmd::getStatistique') {

            $cmd = cmd::byId($params['id']);

            if (!is_object($cmd)) {

                throw new Exception(__('Commande introuvable : ', __FILE__) . secureXSS($params['id']), -32702);

            }

            $jsonrpc->makeSuccess($cmd->getStatistique($params['startTime'], $params['endTime']));

        }

        if ($jsonrpc->getMethod() == 'cmd::getTendance') {

            $cmd = cmd::byId($params['id']);

            if (!is_object($cmd)) {

                throw new Exception(__('Commande introuvable : ', __FILE__) . secureXSS($params['id']), -32702);

            }

            $jsonrpc->makeSuccess($cmd->getTendance($params['startTime'], $params['endTime']));

        }

        if ($jsonrpc->getMethod() == 'cmd::getHistory') {

            $cmd = cmd::byId($params['id']);

            if (!is_object($cmd)) {

                throw new Exception('Commande introuvable : ' . secureXSS($params['id']), -32702);

            }

            $jsonrpc->makeSuccess(utils::o2a($cmd->getHistory($params['startTime'], $params['endTime'])));

        }

        /*             * ************************Scénario*************************** */

        if ($jsonrpc->getMethod() == 'scenario::all') {

            $jsonrpc->makeSuccess(utils::o2a(scenario::all()));

        }

        if ($jsonrpc->getMethod() == 'scenario::byId') {

            $scenario = scenario::byId($params['id']);

            if (!is_object($scenario)) {

                throw new Exception('Scénario introuvable : ' . secureXSS($params['id']), -32703);

            }

            $jsonrpc->makeSuccess(utils::o2a($scenario));

        }

        if ($jsonrpc->getMethod() == 'scenario::changeState') {

            $scenario = scenario::byId($params['id']);

            if (!is_object($scenario)) {

                throw new Exception('Scénario introuvable : ' . secureXSS($params['id']), -32702);

            }

            if ($params['state'] == 'stop') {

                $jsonrpc->makeSuccess($scenario->stop());

            }

            if ($params['state'] == 'run') {

                $jsonrpc->makeSuccess($scenario->launch(__('Scénario exécuté sur appel API', __FILE__)));

            }

            if ($params['state'] == 'enable') {

                $scenario->setIsActive(1);

                $jsonrpc->makeSuccess($scenario->save());

            }

            if ($params['state'] == 'disable') {

                $scenario->setIsActive(0);

                $jsonrpc->makeSuccess($scenario->save());

            }

            throw new Exception(__('Le paramètre "state" ne peut être vide et doit avoir pour valeur [run,stop,enable,disable]', __FILE__));

        }

        /*             * ************************JeeNetwork*************************** */

        if ($jsonrpc->getMethod() == 'jeeNetwork::handshake') {

            if (config::byKey('jeeNetwork::mode') != 'slave') {

                throw new Exception(__('Impossible d\'ajouter une box NextDom non esclave à un réseau NextDom', __FILE__));

            }

            $auiKey = config::byKey('auiKey');

            if ($auiKey == '') {

                $auiKey = config::genKey(255);

                config::save('auiKey', $auiKey);

            }

            $return = [

                'mode' => config::byKey('jeeNetwork::mode'),

                'nbUpdate' => update::nbNeedUpdate(),

                'version' => nextdom::version(),

                'nbMessage' => message::nbMessage(),

                'auiKey' => $auiKey,

                'nextdom::url' => config::byKey('nextdom::url'),

                'ngrok::port' => config::byKey('ngrok::port'),