connect.class.php

<?php
/**
 * Connect
 *
 * Connect
 *
 * @package project
 * @author Serge J. <jey@tut.by>
 * @copyright http://www.atmatic.eu/ (c)
 * @version 0.1 (wizard, 13:07:13 [Jul 24, 2013])
 */
//
//
class connect extends module
{
    /**
     * connect
     *
     * Module class constructor
     *
     * @access private
     */
    function __construct()
    {
        $this->name = "connect";
        $this->title = "<#LANG_MODULE_CONNECT#>";
        $this->module_category = "<#LANG_SECTION_SYSTEM#>";
        $this->checkInstalled();
    }

    /**
     * saveParams
     *
     * Saving module parameters
     *
     * @access public
     */
    function saveParams($data = 0)
    {
        $p = array();
        if (IsSet($this->id)) {
            $p["id"] = $this->id;
        }
        if (IsSet($this->view_mode)) {
            $p["view_mode"] = $this->view_mode;
        }
        if (IsSet($this->edit_mode)) {
            $p["edit_mode"] = $this->edit_mode;
        }
        if (IsSet($this->tab)) {
            $p["tab"] = $this->tab;
        }
        return parent::saveParams($p);
    }

    /**
     * getParams
     *
     * Getting module parameters from query string
     *
     * @access public
     */
    function getParams()
    {
        global $id;
        global $mode;
        global $view_mode;
        global $edit_mode;
        global $tab;
        if (isset($id)) {
            $this->id = $id;
        }
        if (isset($mode)) {
            $this->mode = $mode;
        }
        if (isset($view_mode)) {
            $this->view_mode = $view_mode;
        }
        if (isset($edit_mode)) {
            $this->edit_mode = $edit_mode;
        }
        if (isset($tab)) {
            $this->tab = $tab;
        }
    }

    /**
     * Run
     *
     * Description
     *
     * @access public
     */
    function run()
    {
        global $session;
        $out = array();
        if ($this->action == 'admin') {
            $this->admin($out);
        } else {
            $this->usual($out);
        }
        if (IsSet($this->owner->action)) {
            $out['PARENT_ACTION'] = $this->owner->action;
        }
        if (IsSet($this->owner->name)) {
            $out['PARENT_NAME'] = $this->owner->name;
        }
        $out['VIEW_MODE'] = $this->view_mode;
        $out['EDIT_MODE'] = $this->edit_mode;
        $out['MODE'] = $this->mode;
        $out['ACTION'] = $this->action;
        if ($this->single_rec) {
            $out['SINGLE_REC'] = 1;
        }
        $this->data = $out;
        $p = new parser(DIR_TEMPLATES . $this->name . "/" . $this->name . ".html", $this->data, $this);
        $this->result = $p->result;
    }

    function processSubscription($event_name, &$details)
    {
        if ($event_name == 'HOURLY') {
            //...
            $this->getConfig();
            if ($this->config['CONNECT_BACKUP'] && ((int)date('H')) == (int)$this->config['CONNECT_BACKUP_HOUR']) {
                $this->cloudBackup();
            }
        }
        if ($event_name == 'SAY') {
            $level = (int)$details['level'];
            $message = $details['message'];
            $this->sendMessageToConnect($message, $level);
        }
    }

    function sendMessageToConnect($message, $level)
    {
        $this->getConfig();
        $connect_username = $this->config['CONNECT_USERNAME']; //username
        $connect_password = $this->config['CONNECT_PASSWORD'];
        $connect_sync = $this->config['CONNECT_SYNC'];
        if (!$connect_sync || !$connect_username || !$connect_password) {
            return false;
        }
        //DebMes("Sending message to connect: $message ($level)",'connect_push');
        $fields = array(
            'message' => $message,
            'level' => (int)$level
        );
        $url = 'https://connect.smartliving.ru/sync_device_data.php';
        $ch = curl_init();
        curl_setopt($ch, CURLOPT_URL, $url);
        curl_setopt($ch, CURLOPT_POST, 1);
        curl_setopt($ch, CURLOPT_POSTFIELDS, $fields);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
        curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 60);
        curl_setopt($ch, CURLOPT_TIMEOUT, 120);
        curl_setopt($ch, CURLOPT_HTTPAUTH, CURLAUTH_BASIC);
        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);     // bad style, I know...
        curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 2);
        curl_setopt($ch, CURLOPT_USERPWD, $connect_username . ":" . $connect_password);
        $result = curl_exec($ch);
        curl_close($ch);
        //DebMes("Sending message result: $result",'connect_push');
    }

    function cloudBackup()
    {
        $connect_username = $this->config['CONNECT_USERNAME']; //username
        $connect_password = $this->config['CONNECT_PASSWORD'];
        if (!$connect_username || !$connect_password) {
            return false;
        }


        include_once(DIR_MODULES . 'saverestore/saverestore.class.php');
        $sv = new saverestore();
        global $data;
        $data = 1;
        $out = array();
        $sv->removeTree(ROOT . 'cms/saverestore/temp');
        $tar_name = $sv->dump($out);
        $sv->removeTree(ROOT . 'cms/saverestore/temp');
        $sv->removeTree(ROOT . 'cms/saverestore/temp');
        $dest_file = ROOT . 'cms/saverestore/' . $tar_name;
        if ($dest_file && file_exists($dest_file) && filesize($dest_file) > 0) {
            if (function_exists('curl_file_create')) { // php 5.6+
                $cfile = curl_file_create($dest_file);
            } else { //
                $cfile = '@' . realpath($dest_file);
            }
            $fields = array(
                'backupfile' => $cfile,
                'force_data' => '1'
            );
            $url = 'https://connect.smartliving.ru/upload/';
            $ch = curl_init();

            DebMes("Cloudbackup file $dest_file to $url", 'cloudbackup');

            curl_setopt($ch, CURLOPT_URL, $url);
            curl_setopt($ch, CURLOPT_POST, 1);
            curl_setopt($ch, CURLOPT_POSTFIELDS, $fields);
            curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
            curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 60);
            curl_setopt($ch, CURLOPT_TIMEOUT, 120);
            curl_setopt($ch, CURLOPT_HTTPAUTH, CURLAUTH_BASIC);
            curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);     // bad style, I know...
            curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 2);
            curl_setopt($ch, CURLOPT_USERPWD, $connect_username . ":" . $connect_password);

            //execute post
            $result = curl_exec($ch);
            //close connection
            curl_close($ch);

            DebMes("Cloudbackup result: " . $result, 'cloudbackup');

            //echo "POST RESULT: ".$result;
            if ($result == 'OK') {
                @unlink($dest_file);
                return true;
            } else {
                return false;
            }

        }

    }

    /**
     * BackEnd
     *
     * Module backend
     *
     * @access public
     */
    function admin(&$out)
    {


        if (gr('ok_msg')) {
            $out['OK_MSG'] = gr('ok_msg');
        }
        if (gr('err_msg')) {
            $out['ERR_MSG'] = gr('err_msg');
        }
        if (gr('status')) {
            $out['STATUS']=gr('status');
        }

        $this->getConfig();

        $out['CONNECT_USERNAME'] = $this->config['CONNECT_USERNAME'];
        $out['CONNECT_PASSWORD'] = $this->config['CONNECT_PASSWORD'];
        $out['CONNECT_SYNC'] = $this->config['CONNECT_SYNC'];
        $out['CONNECT_BACKUP'] = $this->config['CONNECT_BACKUP'];
        $out['CONNECT_INSECURE'] = $this->config['CONNECT_INSECURE'];

        $out['SEND_MENU'] = $this->config['SEND_MENU'];
        $out['SEND_CLASSES'] = $this->config['SEND_CLASSES'];
        $out['SEND_OBJECTS'] = $this->config['SEND_OBJECTS'];
        $out['SEND_SCRIPTS'] = $this->config['SEND_SCRIPTS'];
        $out['SEND_PATTERNS'] = $this->config['SEND_PATTERNS'];

        if ($this->view_mode == 'update_settings') {
            global $connect_username;
            global $connect_password;
            global $connect_sync;
            global $connect_backup;

            $this->config['CONNECT_USERNAME'] = $connect_username;
            $this->config['CONNECT_PASSWORD'] = $connect_password;
            $this->config['CONNECT_SYNC'] = (int)$connect_sync;
            $this->config['CONNECT_BACKUP'] = (int)$connect_backup;
            $this->config['CONNECT_INSECURE'] = gr('connect_insecure', 'int');
            $this->config['CONNECT_BACKUP_HOUR'] = (int)rand(0, 6);
            if ($this->config['CONNECT_BACKUP']) {
                subscribeToEvent($this->name, 'HOURLY');
                //$this->cloudBackup(); // backup now
            }
            $this->saveConfig();
            if ($this->config['CONNECT_SYNC']) {
                setGlobal('cycle_connectControl', 'restart');
            } else {
                setGlobal('cycle_connectControl', 'stop');
            }
            $status = $this->getConnectStatus();
            if (!$status) {
                $status = LANG_CONNECT_LOGIN_FAILED;
            }
            $this->redirect("?status=".urlencode($status));
        }

        if ($this->mode == 'sendbackup') {
            $result = $this->cloudBackup();
            if ($result) {
                $this->redirect("?ok_msg=" . urlencode('Backup sent'));
            } else {
                $this->redirect("?err_msg=" . urlencode('Error sending backup'));
            }
        }

        if ($this->view_mode == 'send_data') {
            $this->sendData($out);
        }

        if ($this->tab == 'calls') {

            if ($this->view_mode == 'sync') {
                if ($this->config['CONNECT_USERNAME']) {
                    $this->sendCalls();
                }
                $this->redirect("?tab=" . $this->tab);
            }

            if ($this->view_mode == 'delete_calls') {
                global $id;
                SQLExec("DELETE FROM public_calls WHERE ID='" . (int)$id . "'");
                $this->redirect("?tab=" . $this->tab . "&view_mode=sync");
            }

            if ($this->view_mode == 'edit_calls') {
                global $id;
                $rec = SQLSelectOne("SELECT * FROM public_calls WHERE ID='" . (int)$id . "'");
                if ($this->mode == 'update') {
                    $ok = 1;

                    global $title;
                    $rec['TITLE'] = $title;
                    if (!$rec['TITLE']) {
                        $out['ERR_TITLE'] = 1;
                        $ok = 0;
                    }

                    global $linked_object;
                    $rec['LINKED_OBJECT'] = $linked_object;

                    global $linked_method;
                    $rec['LINKED_METHOD'] = $linked_method;

                    global $protected;
                    $rec['PROTECTED'] = (int)$protected;

                    global $public_username;
                    $rec['PUBLIC_USERNAME'] = $public_username;

                    global $public_password;
                    $rec['PUBLIC_PASSWORD'] = $public_password;

                    if ($ok) {
                        if ($rec['ID']) {
                            SQLUpdate('public_calls', $rec);
                        } else {
                            $rec['ID'] = SQLInsert('public_calls', $rec);
                        }

                        if (preg_match_all('/%(\w+)\.(\w+)%/is', $rec['TITLE'], $m)) {
                            $total = count($m[1]);
                            for ($i = 0; $i < $total; $i++) {
                                addLinkedProperty($m[1][$i], $m[2][$i], $this->name);
                            }
                        }

                        $this->redirect("?tab=" . $this->tab . "&view_mode=sync");
                    }
                }
                outHash($rec, $out);
            }
            $calls = SQLSelect("SELECT * FROM public_calls ORDER BY ID DESC");
            $out['CALLS'] = $calls;
        }

        if ($_GET['uploaded']) {
            $out['UPLOADED'] = 1;
            $out['RESULT'] = $_GET['result'];
        }

        $out['TAB'] = $this->tab;

    }

    function getConnectStatus() {
        $url = 'https://connect.smartliving.ru/market/?op=connect_status';
        if ($this->config['CONNECT_SYNC']) {
            $url.="&sync=1";
        }
        if ($this->config['CONNECT_BACKUP']) {
            $url.="&backup=1";
        }
        $url.="&local_url=".urlencode(getLocalIp());
        $ch = curl_init();
        curl_setopt($ch, CURLOPT_URL, $url);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
        curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 30);
        curl_setopt($ch, CURLOPT_TIMEOUT, 30);
        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
        curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 2);
        curl_setopt($ch, CURLOPT_HTTPAUTH, CURLAUTH_BASIC);
        curl_setopt($ch, CURLOPT_USERPWD, $this->config['CONNECT_USERNAME'] . ":" . $this->config['CONNECT_PASSWORD']);
        $result = curl_exec($ch);
        curl_close($ch);
        return $result;
    }

    function requestReverseURL($msg) {
        ignore_user_abort(1);
        $url = BASE_URL.$msg;
        if (preg_match('/\?/',$url)) {
            $url.='&no_session=1';
        } else {
            $url.='?no_session=1';
        }
        //debmes("Sending request $url",'reverse_urls');
        $result = getURL($url);
        //debmes("Sending result to Connect",'reverse_urls');
        $this->sendReverseURL($msg,$result);
        //debmes("Sending $msg DONE",'reverse_urls');
    }

    function sendReverseURL($url_requested, $result)
    {
        // POST TO SERVER
        $url = 'https://connect.smartliving.ru/reverse_proxy.php';
        $header = array('Content-Type: multipart/form-data');
        $fields = array('url' => $url_requested);
        //$probably_binary = (is_string($result) === true && ctype_print($result) === false);
        if (preg_match('/\.css$/is', $url_requested) || preg_match('/\.js$/is', $url_requested) || !mb_detect_encoding($result)) {
            $binary_path = ROOT . 'cms/cached/reverse';
            if (!is_dir($binary_path)) {
                umask(0);
                mkdir($binary_path, 0777);
            }
            $tmpfilename = $binary_path . '/' . preg_replace('/\W/', '_', $url_requested);
            SaveFile($tmpfilename, $result);

            if (!function_exists('getCurlValue')) {
                function getCurlValue($filename, $contentType, $postname)
                {
                    if (function_exists('curl_file_create')) {
                        return curl_file_create($filename, $contentType, $postname);
                    }
                    $value = "@" . $filename . ";filename=" . $postname;
                    if ($contentType) {
                        $value .= ';type=' . $contentType;
                    }
                    return $value;
                }
            }
            $cfile = getCurlValue($tmpfilename, '', basename($tmpfilename));
            $fields['file'] = $cfile;
            $result = 'binary';
        }
        $fields['result'] = $result;

        $ch = curl_init();
        curl_setopt($ch, CURLOPT_URL, $url);
        curl_setopt($ch, CURLOPT_HTTPHEADER, $header);
        curl_setopt($ch, CURLOPT_POST, 1);
        curl_setopt($ch, CURLOPT_POSTFIELDS, $fields);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
        curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 30);
        curl_setopt($ch, CURLOPT_TIMEOUT, 30);
        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
        curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 2);
        curl_setopt($ch, CURLOPT_HTTPAUTH, CURLAUTH_BASIC);
        curl_setopt($ch, CURLOPT_USERPWD, $this->config['CONNECT_USERNAME'] . ":" . $this->config['CONNECT_PASSWORD']);
        $result = curl_exec($ch);
        curl_close($ch);
        return $result;
    }


    function sendAllDevices()
    {
// POST TO SERVER
        $url = 'https://connect.smartliving.ru/sync_device_data.php';
        $fields = array();
        $devices = SQLSelect("SELECT ID, TITLE, ALT_TITLES, TYPE, SUBTYPE, LINKED_OBJECT FROM devices WHERE 1");
        include_once(DIR_MODULES . 'classes/classes.class.php');
        $cl = new classes();

        foreach ($devices as &$device) {
            $object = getObject($device['LINKED_OBJECT']);
            if (is_object($object)) {
                $props = $cl->getParentProperties($object->class_id, '', 1);
                $my_props = SQLSelect("SELECT ID,TITLE FROM properties WHERE OBJECT_ID='" . $object->id . "'");
                if (IsSet($my_props[0])) {
                    foreach ($my_props as $p) {
                        if ($p['TITLE'] == 'updated' || $p['TITLE'] == 'updatedText') continue;
                        $props[] = $p;
                    }
                }
                foreach ($props as $k => $v) {
                    $value = $object->getProperty($v['TITLE']);
                    if ($value === '') continue;
                    $device['properties'][$v['TITLE']] = $value;
                }
            }
        }
        $fields['devices_data'] = json_encode($devices);
        $fields['local_url'] = getLocalIp();

        //DebMes("Posting all devices to $url",'device_sync');
        //DebMes($fields['devices_data'],'device_sync');
        $ch = curl_init();
        curl_setopt($ch, CURLOPT_URL, $url);
        curl_setopt($ch, CURLOPT_POST, count($fields));
        curl_setopt($ch, CURLOPT_POSTFIELDS, $fields);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
        curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 30);
        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);     // bad style, I know...
        curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 2);
        curl_setopt($ch, CURLOPT_TIMEOUT, 30);
        curl_setopt($ch, CURLOPT_HTTPAUTH, CURLAUTH_BASIC);
        curl_setopt($ch, CURLOPT_USERPWD, $this->config['CONNECT_USERNAME'] . ":" . $this->config['CONNECT_PASSWORD']);
        $result = curl_exec($ch);
        if (curl_errno($ch) && !$background) {
            $errorInfo = curl_error($ch);
            $info = curl_getinfo($ch);
            DebMes("Error: " . $errorInfo, 'device_sync');
        } else {
            //DebMes("Result : ".$result,'device_sync');
        }
        curl_close($ch);
    }

    function sendDeviceProperty($property, $value)
    {
        // POST TO SERVER
        $url = 'https://connect.smartliving.ru/sync_device_data.php';
        $fields = array();
        list($object_name, $property_name) = explode('.', $property);
        $device_rec = SQLSelectOne("SELECT ID, TITLE, TYPE, SUBTYPE FROM devices WHERE LINKED_OBJECT='" . DBSafe($object_name) . "'");
        $fields['object'] = $object_name;
        $fields['property'] = $property_name;
        $fields['value'] = $value;
        if ($device_rec['TITLE']) {
            $fields['device_data'] = json_encode($device_rec);
        }
        foreach ($fields as $k => $v) {
            $fields_string .= $k . '=' . $v . '&';
        }
        rtrim($fields_string, '&');
        //DebMes("Posting $property = $value to $url",'device_sync');
        $ch = curl_init();
        curl_setopt($ch, CURLOPT_URL, $url);
        curl_setopt($ch, CURLOPT_POST, count($fields));
        curl_setopt($ch, CURLOPT_POSTFIELDS, $fields_string);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
        curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 30);
        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);     // bad style, I know...
        curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 2);
        curl_setopt($ch, CURLOPT_TIMEOUT, 5);
        curl_setopt($ch, CURLOPT_HTTPAUTH, CURLAUTH_BASIC);
        curl_setopt($ch, CURLOPT_USERPWD, $this->config['CONNECT_USERNAME'] . ":" . $this->config['CONNECT_PASSWORD']);
        $result = curl_exec($ch);
        if (curl_errno($ch) && !$background) {
            $errorInfo = curl_error($ch);
            $info = curl_getinfo($ch);
            DebMes("Error: " . $errorInfo, 'device_sync');
        } else {
            //DebMes("Result : ".$result,'device_sync');
        }
        curl_close($ch);

    }

    function sendMenuItems($items)
    {
        // POST TO SERVER
        $url = 'https://connect.smartliving.ru/upload/';
        $fields = array('force_data' => 1, 'menu_items' => 1, 'items' => urlencode(serialize($items)));

        //url-ify the data for the POST
        foreach ($fields as $key => $value) {
            $fields_string .= $key . '=' . $value . '&';
        }
        rtrim($fields_string, '&');

        //open connection
        $ch = curl_init();
        //set the url, number of POST vars, POST data
        curl_setopt($ch, CURLOPT_URL, $url);
        curl_setopt($ch, CURLOPT_POST, count($fields));
        curl_setopt($ch, CURLOPT_POSTFIELDS, $fields_string);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
        curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 30);
        curl_setopt($ch, CURLOPT_TIMEOUT, 30);
        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);     // bad style, I know...
        curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 2);
        curl_setopt($ch, CURLOPT_HTTPAUTH, CURLAUTH_BASIC);
        curl_setopt($ch, CURLOPT_USERPWD, $this->config['CONNECT_USERNAME'] . ":" . $this->config['CONNECT_PASSWORD']);
        //execute post
        $result = curl_exec($ch);
        //close connection
        curl_close($ch);
    }

    /**
     * Title
     *
     * Description
     *
     * @access public
     */
    function sendMenu($force_data = 0)
    {
        // menu items
        $data = array();
        $data['COMMANDS'] = SQLSelect("SELECT * FROM commands");
        $total = count($data['COMMANDS']);
        for ($i = 0; $i < $total; $i++) {
            if (!$this->config['CONNECT_SYNC'] && !$force_data) {
                unset($data['COMMANDS'][$i]['CUR_VALUE']);
                unset($data['COMMANDS'][$i]['RENDER_TITLE']);
                unset($data['COMMANDS'][$i]['RENDER_DATA']);
            }
        }

        // POST TO SERVER
        $url = 'https://connect.smartliving.ru/upload/';

        $datafile_name = ROOT . 'cms/cached/connect_data.txt';
        SaveFile($datafile_name, serialize($data));

        if (!function_exists('getCurlValue')) {
            function getCurlValue($filename, $contentType, $postname)
            {
                if (function_exists('curl_file_create')) {
                    return curl_file_create($filename, $contentType, $postname);
                }
                $value = "@" . $filename . ";filename=" . $postname;
                if ($contentType) {
                    $value .= ';type=' . $contentType;
                }
                return $value;
            }
        }

        $cfile = getCurlValue($datafile_name, 'text/plain', 'datafile.txt');
        $fields = array(
            'datafile' => $cfile,
            'merge' => 1,
            'force_data' => $force_data,
            'local_url' => getLocalIp()
        );


        //open connection
        $ch = curl_init();
        curl_setopt($ch, CURLOPT_URL, $url);
        curl_setopt($ch, CURLOPT_POST, count($fields));
        curl_setopt($ch, CURLOPT_POSTFIELDS, $fields);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
        curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 30);
        curl_setopt($ch, CURLOPT_TIMEOUT, 30);
        curl_setopt($ch, CURLOPT_HEADER, 1);
        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);     // bad style, I know...
        curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 2);
        curl_setopt($ch, CURLOPT_HTTPAUTH, CURLAUTH_BASIC);
        curl_setopt($ch, CURLOPT_USERPWD, $this->config['CONNECT_USERNAME'] . ":" . $this->config['CONNECT_PASSWORD']);


        //execute post
        $result = curl_exec($ch);
        //close connection

        if (curl_errno($ch)) {
            $errorInfo = curl_error($ch);
            $info = curl_getinfo($ch);
            //DebMes("GetURL to $url (source ".$callSource.") finished with error: \n".$errorInfo."\n".json_encode($info),'connect_menu');
        }
        curl_close($ch);
        //DebMes('Connect sending menu request $url ('.$this->config['CONNECT_USERNAME'].":".$this->config['CONNECT_PASSWORD'].'): '. json_encode($fields),'connect_menu');
        //DebMes('Connect sending menu response: '.$result,'connect_menu');
    }

    function propertySetHandle($object, $property, $value)
    {
        $calls = SQLSelect("SELECT ID FROM public_calls WHERE TITLE LIKE '%" . DBSafe($object . '.' . $property) . "%'");
        if ($calls[0]['ID']) {
            $this->sendCalls();
        }
    }

    /**
     * Title
     *
     * Description
     *
     * @access public
     */
    function sendCalls()
    {

        $this->getConfig();
        // menu items
        $data = array();
        $calls = SQLSelect("SELECT * FROM public_calls");
        $total = count($calls);
        for ($i = 0; $i < $total; $i++) {
            $calls[$i]['TITLE'] = processTitle($calls[$i]['TITLE']);
        }
        $data['PUBLIC_CALLS'] = $calls;


        // POST TO SERVER
        $url = 'https://connect.smartliving.ru/upload/';
        $fields = array('merge' => 1, 'data' => urlencode(serialize($data)), 'force_data' => $force_data);

        //url-ify the data for the POST
        foreach ($fields as $key => $value) {
            $fields_string .= $key . '=' . $value . '&';
        }
        rtrim($fields_string, '&');

        //open connection
        $ch = curl_init();
        //set the url, number of POST vars, POST data
        curl_setopt($ch, CURLOPT_URL, $url);
        curl_setopt($ch, CURLOPT_POST, count($fields));
        curl_setopt($ch, CURLOPT_POSTFIELDS, $fields_string);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
        curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 30);
        curl_setopt($ch, CURLOPT_TIMEOUT, 30);
        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);     // bad style, I know...
        curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 2);
        curl_setopt($ch, CURLOPT_HTTPAUTH, CURLAUTH_BASIC);
        curl_setopt($ch, CURLOPT_USERPWD, $this->config['CONNECT_USERNAME'] . ":" . $this->config['CONNECT_PASSWORD']);

        //execute post
        $result = curl_exec($ch);

        //echo $result;exit;
        $tmp = json_decode($result, true);
        if (is_array($tmp['PUBLIC_CALLS'])) {
            $total = count($tmp['PUBLIC_CALLS']);
            for ($i = 0; $i < $total; $i++) {
                SQLExec("UPDATE public_calls SET PUBLIC_KEY='" . $tmp['PUBLIC_CALLS'][$i]['PUBLIC_KEY'] . "' WHERE ID='" . $tmp['PUBLIC_CALLS'][$i]['INTERNAL_ID'] . "'");
            }
        }

        //close connection
        curl_close($ch);


    }

    /**
     * Title
     *
     * Description
     *
     * @access public
     */
    function sendData(&$out, $silent = 0)
    {
        global $send_menu;
        global $send_objects;
        global $send_classes;
        global $send_scripts;
        global $send_patterns;

        $this->config['SEND_MENU'] = (int)$send_menu;
        $this->config['SEND_CLASSES'] = (int)$send_classes;
        $this->config['SEND_OBJECTS'] = (int)$send_objects;
        $this->config['SEND_SCRIPTS'] = (int)$send_scripts;
        $this->config['SEND_PATTERNS'] = (int)$send_patterns;
        $this->saveConfig();

        $data = array();

        if ($this->config['SEND_MENU']) {
            // menu items
            $data['COMMANDS'] = SQLSelect("SELECT * FROM commands");
            $total = count($data['COMMANDS']);
            for ($i = 0; $i < $total; $i++) {
                if (!$this->config['CONNECT_SYNC']) {
                    unset($data['COMMANDS'][$i]['CUR_VALUE']);
                    unset($data['COMMANDS'][$i]['RENDER_TITLE']);
                    unset($data['COMMANDS'][$i]['RENDER_DATA']);
                }
            }
        }

        if ($this->config['SEND_CLASSES']) {
            $data['CLASSES'] = SQLSelect("SELECT * FROM classes");
            $data['METHODS'] = SQLSelect("SELECT * FROM methods WHERE OBJECT_ID=0");
            $total = count($data['METHODS']);
            for ($i = 0; $i < $total; $i++) {
                unset($data['METHODS'][$i]['EXECUTED_PARAMS']);
                unset($data['METHODS'][$i]['EXECUTED']);
            }
            $data['PROPERTIES'] = SQLSelect("SELECT * FROM properties WHERE OBJECT_ID=0");

            if ($this->config['SEND_OBJECTS']) {
                // objects
                $data['OBJECTS'] = SQLSelect("SELECT * FROM objects");
                $add_methods = SQLSelect("SELECT * FROM methods WHERE OBJECT_ID!=0");
                foreach ($add_methods as $m) {
                    unset($m['EXECUTED_PARAMS']);
                    unset($m['EXECUTED']);
                    $data['METHODS'][] = $m;
                }
                $add_properties = SQLSelect("SELECT * FROM properties WHERE OBJECT_ID!=0");
                foreach ($add_properties as $p) {
                    $data['PROPERTIES'][] = $p;
                }
            }

        }

        if ($this->config['SEND_SCRIPTS']) {
            // objects scripts
            $data['SCRIPTS'] = SQLSelect("SELECT * FROM scripts");
            $data['SCRIPT_CATEGORIES'] = SQLSelect("SELECT * FROM script_categories");
        }

        if ($this->config['SEND_PATTERNS']) {
            // patterns
            $data['PATTERNS'] = SQLSelect("SELECT * FROM patterns");
        }

        // POST TO SERVER
        $url = 'https://connect.smartliving.ru/upload/';
        $datafile_name = ROOT . 'cms/cached/connect_data.txt';
        SaveFile($datafile_name, serialize($data));

        if (!function_exists('getCurlValue')) {
            function getCurlValue($filename, $contentType, $postname)
            {
                if (function_exists('curl_file_create')) {
                    return curl_file_create($filename, $contentType, $postname);
                }
                $value = "@" . $filename . ";filename=" . $postname;
                if ($contentType) {
                    $value .= ';type=' . $contentType;
                }
                return $value;
            }
        }

        $cfile = getCurlValue($datafile_name, 'text/plain', 'datafile.txt');

        $fields = array(
            'datafile' => $cfile
        );

        //open connection
        $ch = curl_init();
        //set the url, number of POST vars, POST data
        curl_setopt($ch, CURLOPT_URL, $url);
        curl_setopt($ch, CURLOPT_POST, count($fields));
        curl_setopt($ch, CURLOPT_POSTFIELDS, $fields);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
        curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 60);
        curl_setopt($ch, CURLOPT_TIMEOUT, 120);
        curl_setopt($ch, CURLOPT_HTTPAUTH, CURLAUTH_BASIC);
        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);     // bad style, I know...
        curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 2);
        curl_setopt($ch, CURLOPT_USERPWD, $this->config['CONNECT_USERNAME'] . ":" . $this->config['CONNECT_PASSWORD']);

        //execute post
        $result = curl_exec($ch);
        //close connection
        curl_close($ch);

        if (!$silent) {
            $this->redirect("?uploaded=1&result=" . urlencode($result));
        }

    }

    /**
     * FrontEnd
     *
     * Module frontend
     *
     * @access public
     */
    function usual(&$out)
    {
        $this->getConfig();
        if ($this->ajax) {
            $op = gr('op');
            $msg = gr('msg');
            if ($op=='reverse_request') {
               $this->requestReverseURL($msg);
            }
        }
    }

    /**
     * Install
     *
     * Module installation routine
     *
     * @access private
     */
    function install($data = '')
    {
        subscribeToEvent($this->name, 'HOURLY');
        subscribeToEvent($this->name, 'SAY');
        parent::install();
    }

    function dbInstall($data)
    {
        /*
        commands - Commands
        */
        $data = <<<EOD
 public_calls: ID int(10) unsigned NOT NULL auto_increment
 public_calls: TITLE varchar(255) NOT NULL DEFAULT ''
 public_calls: LINKED_OBJECT varchar(255) NOT NULL DEFAULT ''
 public_calls: LINKED_METHOD varchar(255) NOT NULL DEFAULT ''
 public_calls: PUBLIC_USERNAME varchar(255) NOT NULL DEFAULT ''
 public_calls: PUBLIC_PASSWORD varchar(255) NOT NULL DEFAULT ''
 public_calls: PUBLIC_KEY varchar(255) NOT NULL DEFAULT ''
 public_calls: PROTECTED int(3) NOT NULL DEFAULT '0'

EOD;
        parent::dbInstall($data);


    }
// --------------------------------------------------------------------
}

/*
*
* TW9kdWxlIGNyZWF0ZWQgSnVsIDI0LCAyMDEzIHVzaW5nIFNlcmdlIEouIHdpemFyZCAoQWN0aXZlVW5pdCBJbmMgd3d3LmFjdGl2ZXVuaXQuY29tKQ==
*
*/
?>