Simple Channel Monitoring via Shift8

<!--?php
session_start();
 
//
// Dummy configuration
//
$config['asterisk'] = 'http://localhost:8088/mxml';
$config['manager']  = 'manager';
$config['secret']   = 'secret';
 
require_once 'Shift8-0.1.3/library/Shift8.php';
require_once 'Shift8-0.1.3/library/Debug/Listener/Html.php';
 
//
// Create a poller to retrieve the events from Shift8
//
class Poller extends Shift8_Event_Listener {
        private $events;
        private $shift8;
 
        public function __construct() {
                global $config;
 
                $this->events = array();
 
                // Construct the shift8 object and setup the event listener
                $this->shift8 = new Shift8($config['asterisk'], $config['manager'], $config['secret'], false, false);
                //Replace the above line with the next to enable debugging. (Note: this will stop the javascript from working)
                //$this->shift8 = new Shift8($config['asterisk'], $config['manager'], $config['secret'], false, new Shift8_Debug_Listener_Html());
 
                // Add the event listener
                $this->shift8->addEventListener('Poller', $this, new Poller_Filter());
 
                //
                // AJAM uses a cookie value to identify a session. In order to keep the session open
                // we pass down the cookie value in the session with the user browser
                //
                if( !isset($_SESSION['acookie']) ) {
                        // No session cookie available. Let's login to the server
                        if( !$this->shift8->login() ) {
                                throw new Exception("Unable to connect to the remote asterisk");
                        }
 
                        $_SESSION['acookie'] = $this->shift8->getCookie();
                }
                else {
                        // Session cookie already exists. Let's use this
                        $this->shift8->setCookie($_SESSION['acookie']);
                }
        }
 
        public function notify( $event ) {
                $this->events[] = $event;
        }
 
        public function getEvents() {
                if( !$this->shift8->waitEvent() ) {
                        //
                        // No events received. This could mean that our session has expired. Let's reset the
                        // cookie and on next call we will relogin on the remote asterisk
                        //
                        unset($_SESSION['acookie']);
                        return null;
                }
 
                return $this->events;
        }
}
 
//
// Create a filter to only get the events that we are interested of. In this case 'Newchannel' and 'Hangup'
//
class Poller_Filter extends Shift8_Event_Filter {
        public function filter( $event ) {
                if( $event == 'Newchannel' || $event == 'Hangup' )
                        return true;
 
                return false;
        }
}
 
//
// Ok let's start our poller here. The rest is history
//
 
try {
        $poller = new Poller();
} catch( Exception $e ) {
        echo json_encode(
                array(
                        'type'    => 'error',
                        'message' => $e->getMessage()
                )
        );
 
        return;
}
 
echo json_encode(
        array(
                'type'   => 'success',
                'events' => $poller->getEvents()
        )
);

Poller = function( container ) {
        var me = this;
        var _channels = [];
        var _stopPoll = false;
 
        this.poll = function() {
                if( _stopPoll ) {
                        return;
                }
 
                $.ajax({
                        'url': 'poller.php?randomId=' + Math.random(),
                        'dataType': 'json',
                        'success': function(data, textStatus, XMLHttpRequest) {
                                _process(data);
 
                                me.poll();
                        }
                });
        };
 
        _process = function( events ) {
                if( events.type != 'success' ) {
                        alert("Unable to communicate with the remote asterisk");
                        _stopPoll = true;                       
                }
 
                for( var i in events.events ) {
                        var event = events.events[i];
 
                        if( event['variables']['event'] == 'Newchannel' ) {
                                _newCall(event['variables']['uniqueid'], event['variables']['calleridname'] + " <" + event['variables']['calleridnum'] + ">", event['variables']['channel']);
                        }
                        else {
                                _terminateCall(event['variables']['uniqueid']);
                        }
                }
        };
 
        _newCall = function( id, caller, channel ) {
                console.log("New call (" + id + ")");
 
                _channels[id] = {'caller': caller, 'channel': channel};
                container.append("<div class=\"call\" id=\"call_" + id.replace(".", "-") + "\"><h1>" + caller + "</h1><br/><br/><div class=\"ext\">" + channel + "</div></div>");
        };
 
        _terminateCall = function( id ) {
                console.log("Call (" + id + ") terminated");
 
                $("#call_" + id.replace(".", "-")).fadeOut('slow', function() {
                        delete _channels[id];
                });
        };
};
 
$(document).ready(function() {
        var poller = new Poller($("#calls"));
        poller.poll();
});