View source for Api PHP to Javascript

Api script to call functions in Yate Javascript.

==Usage==
===Use api from yate javascript===
init.js
 
 #require "[[#Code: api.js|api.js]]"
 
 var a = 'b';
 var b = 1;
 var c = ['1',2,'3'];
 var d = {'str':'test', 'num':b, 'arr':c, 'obj':{'test':'test'}};
    
 function apiOnCommand(req){
    if(!req.act) return false;
    switch (req.act){
       case 'autodial':
    
          return createAllAD();
    
       break;
       case 'test0':
    
          return a;
    
       break;
       case 'test1':
    
          return b;
    
       break;
       case 'test2':
    
          return c;
    
       break;
       case 'test3':
    
          return d;
    
       break;
    }
    return false;
 }

===Use api from php===
api.php

 require_once('./[[#Code: yate.api.class.php|yate.api.class.php]]');
 
 $yate = new YateApi();
 
 $res = $yate->api(array('act'=>'test0'));
 print_r($res);

result:
 string(1) b

 $res = $yate->api(array('act'=>'test1'));
 print_r($res);

result:
 int(1) 1

 $res = $yate->api(array('act'=>'test2'));
 print_r($res);

result:
 Array
 (
    [0] => 1 - string(1)
    [1] => 2 - int(1)
    [2] => 3 - string(1)
 )

 $res = $yate->api(array('act'=>'test3'));
 print_r($res);

result:
 Array
 (
    [str] => test
    [num] => 1
    [arr] => Array
        (
            [0] => 1
            [1] => 2
            [2] => 3
        )
 
    [obj] => Array
        (
            [test] => test
        )
 
 )

===Yate Setup===

javascript.conf

 [general]
 scripts_dir=/your/dir/where/js/files/

 [scripts]
 init=init.js


==Code: api.js==

    function qs2obj(str){
        str = str.trim();
        var vsks = str.split("&");
        var ret = {};
        for(var kv in vsks){
            var s = vsks[kv];
            s = s.split("=");
            ret[s[0]] = s[1];
        }
        return ret;
    }
    
    function json2str(obj){
        var res = '';
        var prolog = '{';
        var epilog = '}';
        var type = 0;
        var e = [];
        switch (typeof(obj)) {
            case 'string':
                res += '"'+obj+'"';
                break;
            case 'number':
                res = obj;
                break;
            case 'object':
                for(var i in obj){
                    if(i==0){
                        prolog = '[';
                        epilog = ']';
                        type = 1;
                    }
                    if(type){
                        var o = json2str(obj[i]);
                    } else {
                        var o = '"'+i+'":'+json2str(obj[i]);
                    }
                    e.push(o);
                }
                res = prolog+e.join(',')+epilog;
                break;
        }
        return res;
    }
    
    //function apiOnCommand(res){}
    
    function apiCommand(msg){
        if(!msg.line) return false;
        var obj = qs2obj(msg.line);
        var res = apiOnCommand(obj);
        if(!res) return false;
        msg.retValue('[' + json2str(res) + ']' + "\r\n");
        return true;
    }
    Message.install(apiCommand, 'engine.command', 150);

==Code: yate.api.class.php==

    <?
    class YateApi extends Socket
    {
        /**
        Commands
        status
        uptime
        reload
        restart
        stop
        .... -> will be mapped into an engine.command
         */
        function stop()
        {
            return self::command('stop');
        }
    
        function restart()
        {
    
            return self::command('restart');
        }
    
        function reload()
        {
            return self::command('reload');
        }
    
        function api($arr = array())
        {
            $res = self::command(http_build_query($arr));
            $arr = json_decode($res, true);
            if(!json_last_error()) return $arr[0];
            return array('error'=>true, 'message'=>'invalid-json', 'response'=>$res);
        }
    
        function status()
        {
            return self::command('status');
        }
    
        function daytime($sec)
        {
            $arr = array();
            $arr['d'] = floor($sec / 86400);
            $arr['H'] = floor(($sec % 86400) / 3600);
            $arr['i'] = floor(($sec % 3600) / 60);
            $arr['s'] = $sec % 60;
            return $arr;
        }
    
        function uptime()
        {
            $return = self::command('uptime');
            if(preg_match("/\((.*)\)/",$return, $arr))
            {
                $sec = (int)$arr[1];
                return array(
                    'start' => date('d.m.Y H:i:s', time()-$sec),
                    'seconds' => $sec,
                    'daytime' => $this->daytime($sec)
                );
    
            }
            return false;
        }
    
    }
    
    class Socket
    {
        var $error = array();
        var $socket = false;
    
        function __construct($ip = '127.0.0.1', $port = '5038', $ssl = false)    // default settings
        {
            if($ssl && !in_array("ssl", stream_get_transports()))
            {
                $this->error[] = 'No support ssl protocol';
                return false;
            }
    
            if(!$this->socket = @fsockopen($ip,$port,$errno,$errstr,30))
            {
                $this->error[] = "Web page can't connect to ip=$ip, port=$port [$errno]  \"".$errstr."\"";
                return false;
            }
            else
            {
                $line1 = $this->read();
            }
            return true;
        }
    
        function read($marker_end = "\r\n")
        {
            if(!$this->socket) return false;
            $keep_trying = true;
            $line = "";
            while($keep_trying)
            {
                $line .= fgets($this->socket,8192);
                if($line === false)	continue;
                if(substr($line, -strlen($marker_end)) == $marker_end) $keep_trying = false;
            }
            $line = str_replace("\r\n", "", $line);
            return $line;
        }
    
        function write($str)
        {
            if(!$this->socket) return false;
            return fwrite($this->socket, $str."\r\n");
        }
    
        function close()
        {
            if(!$this->socket) return false;
            return fclose($this->socket);
        }
    
        function __destruct()
        {
            return $this->close();
        }
    
        function command($command, $marker_end = "\r\n")
        {
            if(!$this->socket) return false;
            $this->write($command);
            return $this->read($marker_end);
        }
    }
    
    ?>

'''See also:'''
* [[Javascript]]

[[Category:Javascript]] [[Category:PHP]]