sccp_manager/Sccp_manager.inc/srvinterface.class.php

<?php
    /**
     * 
     * Core Comsnd Interface 
     * 
     * 
     */

/* !TODO!: Re-Indent this file */
namespace FreePBX\modules\Sccp_manager;

class srvinterface {

    public function __construct() {
        }
       public function info() {
           return Array('Version' => '13.0.2', 
                        'about' =>'Server interface data ver 13.0.2');
       }

/*
     Core Access Function
 */      
    public function sccp_core_commands($params = array()) {
        global $astman;
        $cmd_list = array('get_softkey' => array('cmd' => "sccp show softkeyssets", 'param' => ''),
            'get_version' => array('cmd' => "sccp show version", 'param' => ''),
            'get_device' => array('cmd' => "sccp show devices", 'param' => ''),
            'get_dev_info' => array('cmd' => "sccp show device", 'param' => 'name'),
            'get_hints' => array('cmd' => "core show hints", 'param' => ''),
            'sccp_reload' => array('cmd' => "sccp reload force", 'param' => ''),
            'reset_phone' => array('cmd' => "sccp reset ", 'param' => 'name'), // Жесткая перезагрузка 
            'reload_phone' => array('cmd' => "sccp reload device ", 'param' => 'name'),
            'reset_token' => array('cmd' => "sccp tokenack ", 'param' => 'name'),
        );
        $result = true;
        if (!empty($params['cmd'])) {
            $id_cmd = $params['cmd'];
            if (!empty($cmd_list[$id_cmd])) {
                $id_param = $cmd_list[$id_cmd]['param'];
                if (!empty($id_param)) {
                    if (!empty($params[$id_param])) {
                        $result = $astman->Command($cmd_list[$id_cmd]['cmd'] .' '. $params[$id_param]);
                    }
                } else {
                    $result = $astman->Command($cmd_list[$id_cmd]['cmd']);
                }
            } else {
                switch ($params['cmd']) {
                    case 'phone_call':
                        if (!empty($params['name'])) {
                            $result = $astman->Command('sccp call ' . $params['name'] . ' ' . $params['call']);
                        }
                        break;
                    case 'phone_message':
                        if (!empty($params['msg'])) {
                            $msg = $params['msg'];
                        } else {
                            $msg = $this->sccpvalues['servername']['data'];
                        }
                        if (!empty($params['name'])) {
                            $astman->Command('sccp device ' . $params['name'] . ' ' . $msg);
                        } else {
                            
                        }
                        break;
                    default:
                        $result = false;
                        break;
                }
            }
        }
        return $result;
    }
    
    public function sccp_getdevice_info($dev_id) {
        if (empty($dev_id)) {
            return array();
        }
        $res = $this->sccp_core_commands(array('cmd' => 'get_dev_info', 'name' => $dev_id));
        $res1 = str_replace(array("\r\n", "\r", "\n"), ';',  strip_tags((string)$res['data'])); 
        if (strpos($res1,'MAC-Address')) {
            $res2 = substr($res1,0,strpos($res1,'+--- Buttons '));
            $res1 = explode(';',substr($res2,strpos($res2,'MAC-Address')));
            foreach ($res1 as $data ){
                if (!empty($data)) {
                    $tmp = explode(':',$data);
                    $data_key =str_replace(array(" ", "-", "\t"), '_',  trim($tmp[0])); 
                    $res3[$data_key] =$tmp[1];
                }
            }
            
            $res1 = $res3['Skinny_Phone_Type'];
            $res4 = $res3['Config_Phone_Type'];
            if (!empty($res3['Addons'])) {
                $res2 = $res3['Addons'];
            } else {
                $res2 = '';
            }
            $res3['SCCP_Vendor']= Array('vendor' => strtok($res1,' '),'model' => strtok('('), 'model_id' => strtok(')'), 'vendor_addon' => strtok($res2,' '), 'model_addon' => strtok(' '));
            if (empty($res3['SCCP_Vendor']['vendor']) || $res3['SCCP_Vendor']['vendor']=='Undefined'){
                $res3['SCCP_Vendor']= Array('vendor' => 'Undefined','model' => $res4, 'model_id' => '', 'vendor_addon' => $res3['SCCP_Vendor']['vendor_addon'], 'model_addon' => $res3['SCCP_Vendor']['model_addon']);
//               return $res4;
//                return array();
            } 
            return $res3;
        } else {
            return array();
        }
    }

/*  Current not use */    
    public function sccp_list_hints() {
        $ast_out = $this->sccp_core_commands(array('cmd' => 'get_hints'));
        $ast_out = preg_split("/[\n]/", $ast_out['data']);
        $ast_key = array();
        for ($i = 0; $i < 3; $i++) {
            $ast_out[$i] = "";
        }
        $i = count($ast_out) - 1;
        $ast_out[--$i] = "";
        $ast_out[--$i] = "";
        foreach ($ast_out as $line) {
            if (strlen($line) > 3) {
                list ($line, $junk) = explode(' ', $line);
                if (isset($ast_key[$line])) {
                    if (strlen($ast_key[$line]) < 1) {
                        $ast_key[$line] = $line;
                    }
                } else {
                    $ast_key[$line] = $line;
                }
            }
        }
        return $ast_key;
    }

   /* !TODO!: install.php is still using the other version number*/
    public function get_compatible_sccp() {
        $res = $this-> getChanSCCPVersion();
        if (empty($res)) {
            $res = $this-> getChanSCCPVersion();
        }
        if (empty($res)) {
            return 0;
        }
        if ($res["vCode"] >= 431) {
            return 431;
        } else {
            return 430;
        }
//        return $res["vCode"];
    }

   /* !TODO!: Multiple Version functions (choose one)*/
   /* !TODO!: private ? */
   function getCoreSCCPVersion() {
        $result =  array();
        $ast_out = $this->sccp_version();
        $result["Version"] = $ast_out[0];
        $version_parts=explode(".", $ast_out[0]);
        $result["vCode"] = implode('', $version_parts);
        if (!empty($ast_out[1]) && $ast_out[1] == 'develop'){
            $result["develop"] = $ast_out[1];
            $res = 10;
            if (base_convert($ast_out[3],16,10) == base_convert('702487a',16,10)) {	/* !TODO!: This does not work as you might expect */
                $result["vCode"] = 431;
            }
            if (base_convert($ast_out[3],16,10) >= "10403") {	// new method, RevisionNum is incremental
                 $result["vCode"] = 432;
            }
        }
        return $result;
        
    }

    /* !TODO!: Old Method */
    /* !TODO!: rename public - >  private
    private function sccp_version() {
        $ast_out = $this->sccp_core_commands(array('cmd' => 'get_version'));
        if (preg_match("/Release.*\(/", $ast_out['data'] , $matches)) {
            $ast_out = substr($matches[0],9,-1);
            return explode(' ', $ast_out);
        } else {
            return aray('unknown');
        }
    }
    
   /* !TODO!: Multiple Version functions (choose one :-)*/
   /* !TODO!: private ? */
   function getChanSCCPVersion() {
    global $astman;
    $result =  array();
    if (!$astman) {
        return $result;
    }
    $metadata = $this->astman_retrieveJSFromMetaData("");
    if ($metadata && array_key_exists("Version",$metadata)) {
        $result["Version"] = $metadata["Version"];
        $version_parts=explode(".", $metadata["Version"]);
        $result["vCode"] = 0;
        
        # not sure about this sccp_ver numbering. Might be better to just check "Version" and Revision
        # $result["vCode"] = implode('', $version_parts);
        $result["vCode"] = 0;
        if ($version_parts[0] == "4") {
            $result["vCode"] = 400;
            if ($version_parts[1] == "1") {
                $result["vCode"] = 410;
            } else
            if ($version_parts[1] == "2") {
                $result["vCode"] = 420;
            } else
            if ($version_parts[1] >= "3") {
                $result["vCode"] = 430;
            }
        }

        /*
        if (array_key_exists("Branch",$metadata)) {
            if ($metadata["Branch"] == "master") {
            
            } else
            if ($metadata["Branch"] == "develop") {
            
            }
        }
        */

        /* Revision got replaced by RevisionHash in 10404 (using the hash does not work)*/
        if (array_key_exists("Revision",$metadata)) {
          if (base_convert($metadata["Revision"],16,10) == base_convert('702487a',16,10)) {
           $result["vCode"] = 431;
          }
          if (base_convert($metadata["Revision"],16,10) >= "10403") {	
           $result["vCode"] = 431;
          }
        }
        if (array_key_exists("RevisionNum",$metadata)) {
          $result["RevisionNum"]=$metadata["RevisionNum"];
          if ($metadata["RevisionNum"] >= "10403") {	// new method, RevisionNum is incremental
             $result["vCode"] = 432;
          }
        }
        if (array_key_exists("ConfigureEnabled",$metadata)) {
            $result["futures"] = implode(';', $metadata["ConfigureEnabled"]);
        }
    } else {
        die_freepbx("Version information could not be retrieved from chan-sccp, via astman::SCCPConfigMetaData");
    }
    return $result;
}
    
    public function sccp_list_keysets() {
        $ast_out = $this->sccp_core_commands(array('cmd' => 'get_softkey'));

        $ast_out = preg_split("/[\n]/", $ast_out['data']);
        $ast_key = array();
        for ($i = 0; $i < 5; $i++) {
            $ast_out[$i] = "";
        }
        $i = count($ast_out) - 1;
        $ast_out[--$i] = "";
        foreach ($ast_out as $line) {
            if (strlen($line) > 3) {
                $line = substr($line, 2);
                list ($line, $junk) = explode(' ', $line);
                if (isset($ast_key[$line])) {
                    if (strlen($ast_key[$line]) < 1) {
                        $ast_key[$line] = $line;
                    }
                } else {
                    $ast_key[$line] = $line;
                }
            }
        }
        return $ast_key;
    }

    public function sccp_get_active_device() {
        $ast_out = $this->sccp_core_commands(array('cmd' => 'get_device'));

        $ast_out = preg_split("/[\n]/", $ast_out['data']);

        $ast_key = array();
        for ($i = 0; $i < 5; $i++) {
            $ast_out[$i] = "";
        }
        $i = count($ast_out) - 1;
        $ast_out[--$i] = "";
        foreach ($ast_out as $line) {
            if (strlen($line) > 3) {
                $line = substr($line, 2);
                $line = preg_replace("/\s{2,}/", " ", $line);
                $line_arr = explode(' ', $line);
                $it = 1;
                do {
                    if (strpos($line_arr[$it + 1], 'SEP') === false) {
                        $line_arr[0] .= ' ' . $line_arr[$it];
                        unset($line_arr[$it]);
                    } else {
                        break;
                    }
                    $it++;
                } while ((count($line_arr) > 3) and ( $it < count($line_arr)));
                explode(";|", implode(";|", $line_arr));
                list ($descr, $adress, $devname, $status, $token, $junk) = explode(";|", implode(";|", $line_arr));

//                list ($descr, $adress, $devname, $status, $junk) = $line_arr;                

//                if (strlen($ast_key[$devname]) < 1) {
                if (strlen($devname) > 1) {
                    $ast_key[$devname] = Array('name' => $devname, 'status' => $status, 'address' => $adress, 'descr' => $descr, 'token' => $token);
                }
/*
                if (isset($ast_key[$devname])) {
                    if (strlen($ast_key[$devname]) < 1) {
                        $ast_key[$devname] = Array('name' => $devname, 'status' => $status, 'address' => $adress, 'descr' => $descr, 'token' => $descr);
                    }
                } else {
                    $ast_key[$devname] = Array('name' => $devname, 'status' => $status, 'address' => $adress, 'descr' => $descr, 'token' => $token);
                }
 * 
 */
            }
        }
        return $ast_key;
    }
/*
 *  Replace  sccp_core_commands($params = array()) {
 */
    
    private function astman_retrieveJSFromMetaData($segment = "") {
        global $astman;
        $params = array();
        if ($segment != "") {
            $params["Segment"] = $segment;
        }
        $response = $astman->send_request('SCCPConfigMetaData', $params);
        if ($response["Response"] == "Success") {
            //outn(_("JSON-content:").$response["JSON"]);
            $decode=json_decode($response["JSON"], true);
            return $decode;
        } else {
            return false;
        }
    }
        
}