<?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/>.
 */

try {
    require_once dirname(__FILE__) . '/../../../../core/php/core.inc.php';
    require_once dirname(__FILE__) . '/../class/smartthings.class.php';
    include_file('core', 'authentification', 'php');

    if (!isConnect('admin')) {
        throw new Exception(__('401 - Accès non autorisé', __FILE__));
    }

    ajax::init();

    if (init('action') == 'loginSmartthings') {
        if (init('force') == 'bt_loginSmartthings') {
            if (network::getUserLocation() == 'internal') {
                ajax::success(array('error' => 'internal'));
            }
            if (network::getNetworkAccess('external') == 'http:') {
                ajax::success(array('error' => 'external'));
            }
        }
        $url = smartthings::checkAndCreateApp();
        ajax::success(array('redirect' => $url));
    }

    if (init('action') == 'updateConf') {
        smartthings::updateConf(false);
        ajax::success();
    }

    if (init('action') == 'synchronize') {
        smartthings::synchronize();
        ajax::success();
    }

    if (init('action') == 'getDevicesInfo') {
        $result = array();
        $eqLogic = smartthings::byId(init('id'));
        $result['state'] = 'NOK';
        if (is_object($eqLogic)) {
            if ($eqLogic->getConfiguration('type') == 'Location') {
                $link = smartthings::API_LOCATIONS_URL . "/" . $eqLogic->getConfiguration('locationId');
                $result['state'] = 'OK';
                $result['result'] = smartthings::sendRequest($link);
            } else {
                $link = smartthings::API_DEVICES_URL . "/" . $eqLogic->getConfiguration('deviceId') . "/status";
                $result['state'] = 'OK';
                $result['result'] = smartthings::sendRequest($link);
            }
            $result['url'] = $link;
        }
        ajax::success($result);
    }

    if (init('action') == 'deleteEquipments') {
        smartthings::deleteEquipments(init('what'));
        ajax::success();
    }

    if (init('action') == 'setOrder') {
        if (!isConnect('admin')) {
            throw new Exception(__('401 - Accès non autorisé', __FILE__));
        }
        $position = 0;
        $order = '';
        foreach (json_decode(init('objects'), true) as $id) {
            $order .= $id.'|'.$position.';';
            $position++;
        }
        config::save('catOrder', $order, 'smartthings');
        ajax::success();
    }

    if (init('action') == 'fixCategories') {
        config::remove('catOrder', 'smartthings');
        ajax::success();
    }

    if (init('action') == 'autoDetectModule') {
        $eqLogic = smartthings::byId(init('id'));
        if (!is_object($eqLogic)) {
            throw new Exception(__('SmartThings eqLogic non trouvé : ', __FILE__) . init('id'));
        }
        if (init('createcommand') == 1) {
            foreach ($eqLogic->getCmd() as $cmd) {
                $cmd->remove();
            }
        }
        $eqLogic->loadCmdFromConf('refreshInfo');
        if ($eqLogic->getConfiguration('type') == 'Location') {
            smartthings::getLocations();
        } else {
            $eqLogic->loadCmdFromConf('refreshInfo');
            $eqLogic->loadCmdFromConf('health');
            smartthings::getDevicesInfo($eqLogic, $eqLogic->getConfiguration('deviceId'));
            smartthings::fixInfoValueActionCmd($eqLogic); //màj setValue dans les cmd
        }
        ajax::success();
    }

    if (init('action') == 'removeRoom') {
        $eqLogic = smartthings::byId(init('id'));
        if (!is_object($eqLogic)) {
            throw new Exception(__('SmartThings eqLogic non trouvé : ', __FILE__) . init('id'));
        }
        $result = smartthings::manageRoom("DELETE", $eqLogic, init('roomId'));
        ajax::success($result);
    }

    if (init('action') == 'createRoom') {
        $eqLogic = smartthings::byId(init('id'));
        if (!is_object($eqLogic)) {
            throw new Exception(__('SmartThings eqLogic non trouvé : ', __FILE__) . init('id'));
        }
        $result = smartthings::manageRoom("CREATE", $eqLogic, null, init('name'));
        ajax::success($result);
    }

    if (init('action') == 'modifyRoom') {
        $eqLogic = smartthings::byId(init('id'));
        if (!is_object($eqLogic)) {
            throw new Exception(__('SmartThings eqLogic non trouvé : ', __FILE__) . init('id'));
        }
        if (init('name') == init('oldName')) {
            throw new Exception(__('Nom de pièce SmartThings inchangé : ', __FILE__) . init('name'));
        }
        $result = smartthings::manageRoom("MODIFY", $eqLogic, init('roomId'), init('name'));
        ajax::success($result);
    }

    if (init('action') == 'syncRooms') {
        $eqLogic = smartthings::byId(init('id'));
        if (!is_object($eqLogic)) {
            throw new Exception(__('SmartThings eqLogic non trouvé : ', __FILE__) . init('id'));
        }
        smartthings::getLocations();
        ajax::success();
    }

    if (init('action') == 'syncDevice') {
        $eqLogic = smartthings::byId(init('id'));
        if (!is_object($eqLogic)) {
            throw new Exception(__('SmartThings eqLogic non trouvé : ', __FILE__) . init('id'));
        }
        $result = smartthings::getDevices(false);
        ajax::success($result);
    }

    if (init('action') == 'syncHub') {
        $eqLogic = smartthings::byId(init('id'));
        if (!is_object($eqLogic)) {
            throw new Exception(__('SmartThings eqLogic non trouvé : ', __FILE__) . init('id'));
        }
        $result = $eqLogic->getHub();
        ajax::success($result);
    }

    if (init('action') == 'getPathLogo') {
        $eqLogic = smartthings::byId(init('id'));
        if (!is_object($eqLogic)) {
            throw new Exception(__('SmartThings eqLogic non trouvé : ', __FILE__) . init('id'));
        }
        $result = $eqLogic->getPathLogo();
        ajax::success($result);
    }

    if (init('action') == 'getCacheAndConfig') {
        $result = array();
        $eqLogic = smartthings::byId(init('id'));
        if (!is_object($eqLogic)) {
            throw new Exception(__('SmartThings eqLogic non trouvé : ', __FILE__) . init('id'));
        }
        $result = array("cache" => $eqLogic->getCache(),"configuration" => $eqLogic->getConfiguration());
        ajax::success($result);
    }

    if (init('action') == 'getCmdFromLogicalId') {
        $eqLogic = smartthings::byId(init('id'));
        if (!is_object($eqLogic)) {
            ajax::success();
        }
        $cmd = $eqLogic->getCmd('info', init('component').'::'. init('capability').'::'.init('command'));
        if (is_object($cmd)) {
            ajax::success(['cmd_id' => $cmd->getId(), 'cmd_name' => $cmd->getName()]);
        }
        ajax::success();
    }

    if (init('action') == 'getEqLogicByDeviceId') {
        ajax::success(smartthings::byDeviceId(init('deviceId')));
    }

    if (init('action') == 'removeOnSmartthings') {
        $eqLogic = smartthings::byId(init('id'));
        if (!is_object($eqLogic)) {
            throw new Exception(__('SmartThings eqLogic non trouvé : ', __FILE__) . init('id'));
        }
        $result = smartthings::manageDevice("DELETE", $eqLogic, init('id'));
        ajax::success($result);
    }

    if (init('action') == 'modifyLocationOnSmartthings') {
        $body = array();
        $listActions = array('name','countryCode','latitude','longitude','regionRadius','temperatureScale','timeZoneId','locale');
        $eqLogic = smartthings::byId(init('id'));
        if (!is_object($eqLogic)) {
            throw new Exception(__('SmartThings eqLogic non trouvé : ', __FILE__) . init('id'));
        }
        foreach ($listActions as $action) {
            if ($action == 'name' && init($action) !== "") {
                $body[$action] = init($action);
            } elseif (strval($eqLogic->getConfiguration($action)) !== init($action)) {
                $body[$action] = init($action);
            }
        }
        log::add('smartthings', 'debug', 'Information modifiée envoyée à Smartthings : '. json_encode($body));
        $result = smartthings::manageLocation("MODIFY", $eqLogic, init('id'), $body);
        ajax::success($result);
    }

    if (init('action') == 'modifyDeviceOnSmartthings') {
        $listActions = array('label','locationId','roomId');
        $eqLogic = smartthings::byId(init('id'));
        if (!is_object($eqLogic)) {
            throw new Exception(__('SmartThings eqLogic non trouvé : ', __FILE__) . init('id'));
        }
        foreach ($listActions as $action) {
            if (strval($eqLogic->getConfiguration($action)) !== init($action)) {
                $body[$action] = init($action);
            }
        }
        log::add('smartthings', 'debug', 'Information modifiée envoyée à Smartthings : '. json_encode($body));
        $result = smartthings::manageDevice("MODIFY", $eqLogic, init('id'), $body);
        ajax::success($result);
    }

    if (init('action') == 'getConfFile') {
        $eqLogic = smartthings::byId(init('id'));
        if (!is_object($eqLogic)) {
            ajax::success();
        }
        ajax::success($eqLogic->getConfFilePath(init('type')));
    }

    if (init('action') == 'searchCapabilityOnST') {
        $cmd = cmd::byId(init('id'));
        if (!is_object($cmd)) {
            $result['state'] = 'NOK';
            ajax::success($result);
        }
        $item = smartthings::API_CAPABILITIES_URL . "/" . init('capability');
        $result['state'] = 'NOK';
        $result['result'] = smartthings::sendRequest($item);
        if (!is_array($result['result'])) {
            $result['state'] = 'NOK';
            ajax::success($result);
        }
        $version = "1";
        if ($result['result']['items'][0]['version'] !== "" && is_numeric($result['result']['items'][0]['version'])) {
            $version = $result['result']['items'][0]['version'];
        }
        $versionItem = $item . "/" . $version;
        $result['versionResult'] = smartthings::sendRequest($versionItem);
        if (!is_array($result['versionResult'])) {
            $result['versionState'] = 'NOK';
            ajax::success($result);
        }
        $result['versionState'] = 'OK';
        if (!is_file(dirname(__FILE__) . '/../../3rdparty/capabilities/' . init('capability') . '.json')) {
            file_put_contents(dirname(__FILE__) . '/../../3rdparty/capabilities/' . init('capability') . '.json', json_encode($result['versionResult']));
        }
        log::add('smartthings', 'debug', __('Fichier téléchargé et mis dans le dossier ', __FILE__) . json_encode($result['versionResult']));
        ajax::success($result);
    }

    if (init('action') == 'listTemplate') {
        $return = smartthings::listTemplate(init('id'));
        ajax::success($return);
    }

    if (init('action') == 'getListValue') {
        $cmd = cmd::byId(init('id'));
        $list = (init('list')) ? init('list') : 'listValue';
        if (is_object($cmd)) {
            ajax::success($cmd->getConfiguration($list, false));
        }
    }

    if (init('action') == 'getWidgetHelp') {
        $filePath = dirname(__FILE__) . '/../template/dashboard/' . init('widgetName');
        $translatePath = 'plugins/smartthings/core/template/dashboard/' . init('widgetName');
        if (file_exists($filePath)) {
            $template = file_get_contents($filePath);
            if (strpos($template, '</template>') !== false) {
                $templateHelp = explode('</template>', $template)[0];
                $templateHelp = explode('<template>', $templateHelp)[1];
                $templateHelp = translate::exec($templateHelp, $translatePath);
                ajax::success($templateHelp);
            }
        }
        ajax::success();
    }

    if (init('action') == 'stream') {
        $camera = smartthings::byId(init('id'));
        if (!is_object($camera)) {
            throw new \Exception(__('Impossible de trouver la camera : ', __FILE__).init('id'));
        }
        if ($camera->getConfiguration('presentationId') == 'SmartThings-smartthings-AVPlatform_IMI_IPC019D_Camera' && $camera->getConfiguration('mnId', '') == '') {
            throw new \Exception(__('mnId vide, merci de le récupérer sur https://smartthings.developer.samsung.com/partner/dashboard ', __FILE__));
        }

        log::add('smartthings', 'debug', 'STREAM START');
        if (count(system::ps('rtsp-to-hls.sh.*'.$camera->getConfiguration('deviceId'))) == 0) {
            shell_exec('(ps ax || ps w) | grep ffmpeg.*'.$camera->getConfiguration('deviceId').' | awk \'{print $2}\' |  xargs sudo kill -9');

            $engine = config::byKey('rtsp::engine', 'smartthings', 'avconv');
            if (!file_exists(dirname(__FILE__) . '/../../data/segments')) {
                mkdir(dirname(__FILE__) . '/../../data/segments', 0777, true);
            }
            if ($camera->getConfiguration('presentationId') == 'SmartThings-smartthings-AVPlatform_IMI_IPC019D_Camera') {
                $link = preg_replace('/^rtsps:\/\//', 'rtsps://'.$camera->getConfiguration('mnId').':'.smartthings::myToken().'@', init('stream'));
            } else {
                $link = preg_replace('/^rtsp:/', 'rtsps:', init('stream'));
            }

            if ($link != '') {
                $cmd = system::getCmdSudo() . ' nohup ' . dirname(__FILE__) . '/../../3rdparty/rtsp-to-hls.sh \'' . $link .'\' ' . $camera->getConfiguration('deviceId') . ' ' . smartthings::myToken();
                exec('echo "'. date('Y-m-d H:i:s') . ' : ' . $cmd . '" >> ' . log::getPathToLog('smartthings_ffmpeg') . ' 2>&1');
                exec($cmd . ' >> ' . log::getPathToLog('smartthings_ffmpeg') . ' 2>&1 &');

                $i=0;
                while (!file_exists(__DIR__.'/../../data/'.$camera->getConfiguration('deviceId').'.m3u8')) {
                    sleep(1);
                    $i++;
                    if ($i>30) {
                        break;
                    }
                }
            }
        }

        $camera->setCache('lastStreamCall', strtotime('now'));
        shell_exec(system::getCmdSudo().' find '.__DIR__.'/../../data/segments/'.$camera->getConfiguration('deviceId').'-*.ts -mmin +5 -type f -exec rm -f {} \; 2>&1 > /dev/null');
        ajax::success();
    }

    if (init('action') == 'getAllDeviceInfo') {
        $result = array();
        $eqLogics = eqLogic::byType('smartthings');

        $plugin = plugin::byId('smartthings');
        $update = $plugin->getUpdate();
        if (is_object($update)) {
            $version = $update->getConfiguration('version');
            if ($version && $version != 'stable') $beta_version = true;
        }

        $result['plugin'] = array(
            'SmartThingsVersion' => ($beta_version ? '[beta] ' : '') . smartthings::$_pluginVersion,
            'JeedomVersion' => config::byKey('version', 'core', '#NA#'),
            'History' => config::byKey('addHistory', 'smartthings', '#NA#'),
            'Notifications' => config::byKey('addNotif', 'smartthings', '#NA#'),
            'Meteo' => config::byKey('activateMeteo', 'smartthings', '#NA#'),
            'Refresh' => config::byKey('autorefresh', 'smartthings', '#NA#'),
        );

        foreach ($eqLogics as $eqLogic) {
            foreach ($eqLogic->getCmd() as $liste_cmd) {
                $result['eqLogics'][$eqLogic->getLogicalId()][] = array($liste_cmd->getName(), $liste_cmd->getLogicalId(), $liste_cmd->getConfiguration());
            }
        }

        $eqLogics = eqLogic::byType('smartthings');
        foreach ($eqLogics as $eqLogic) {
            if ($eqLogic->getConfiguration('type') == 'Location')  continue;
            $deviceLink = smartthings::API_DEVICES_URL . "/" . $eqLogic->getConfiguration('deviceId');
            $statusLink = smartthings::API_DEVICES_URL . "/" . $eqLogic->getConfiguration('deviceId') . "/status";
            $result['devices'][$eqLogic->getConfiguration('deviceId')] =  array('device' => smartthings::sendRequest($deviceLink), 'status' => smartthings::sendRequest($statusLink));
        }
        ajax::success($result);
    }

    if (init('action') == 'sendFeedbackToDev') {
        $data = array(
            'title' => "New feedback from plugin Smartthings",
            'body' => substr(init('jsonData'),0,strpos(init('jsonData'), 'DEVICES :')),
            'labels' => ["help wanted"]
        );
        $data2 = array('body' => substr(init('jsonData'),strpos(init('jsonData'), 'DEVICES :')));
        log::add('smartthings', 'debug', "L." . __LINE__ . __(" Feedback : ", __FILE__) . json_encode($data));
        log::add('smartthings', 'debug', "L." . __LINE__ . __(" Feedback2 : ", __FILE__) . json_encode($data2));


        try {
            if ((strtotime('now') - config::byKey('lastFeedbackSent', 'smartthings', 0)) > 3600) {
                $http = new com_http('https://api.github.com/repos/Flobul/Jeedom-SmartThings/issues');
                $http->setHeader(array(
                    'User-Agent: Awesome-Octocat-App',
                    'Cookie: logged_in=no',
                    'Accept: application/vnd.github+json',
                    'Authorization: Bearer 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' //don't try to be smart, you only have one repo access
                ));
                $http->setPost(json_encode($data));
                config::save('lastFeedbackSent', strtotime('now'), 'smartthings');
            } else {
                ajax::success(array('pleaseWait' => (3600 - strtotime('now') + config::byKey('lastFeedbackSent', 'smartthings', 0))));
            }
        } catch (\Exception $e) {
            log::add('smartthings', 'debug', "L." . __LINE__ . " F." . __(" Erreur de feedback : ", __FILE__) . json_encode(utils::o2a($e)));
        }
        try {
            $result = json_decode($http->exec(10, 3), true);
            log::add('smartthings', 'debug', __LINE__ . ' : ' . __(' Fin feedback ', __FILE__) . json_encode($result));
            if (is_array($result) && array_key_exists('comments_url', $result)) {

                $comment = new com_http($result['comments_url']);
                $comment->setHeader(array(
                    'User-Agent: Awesome-Octocat-App',
                    'Cookie: logged_in=no',
                    'Accept: application/vnd.github+json',
                    'Authorization: Bearer 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' //don't try to be smart, you only have one repo access
                ));
                $comment->setPost(json_encode($data2));
                try {
                    $resultComment = json_decode($comment->exec(10, 3), true);
                    log::add('smartthings', 'debug', __LINE__ . ' : ' . __(' Fin feedback comment ', __FILE__) . json_encode($resultComment));
                } catch (\Exception $e) {
                    log::add('smartthings', 'debug', "L." . __LINE__ . __(" Erreur de feedback : ", __FILE__) . json_encode(utils::o2a($e)));
                }
                ajax::success(array('success' => true, 'result' => json_decode($result, true)));
            } else {
                ajax::success(array('success' => false, 'result' => json_decode($result, true)));
            }
        } catch (\Exception $e) {
            log::add('smartthings', 'debug', "L." . __LINE__ . __(" Erreur de feedback : ", __FILE__) . json_encode(utils::o2a($e)));
        }

    }

    throw new Exception(__('Aucune méthode correspondante à ', __FILE__) . init('action'));
    /*     * *********Catch exeption*************** */
} catch (Exception $e) {
    ajax::error(displayException($e), $e->getCode());
}