root/freepbx/branches/experimental/amp_conf/htdocs/panel/managerproxy.php

<?php
/** $Id$
 * FreePBX DHTML Operator Panel
 *
 * @package     FreePBX
 * @author      Greg MacLellan
 * @copyright   Copyright (c) 2006, Greg MacLellan
 * @license     GPL
 * @link        http://www.freepbx.org/trac/wiki/DhtmlOperatorPanel
*/

class ManagerProxy {
        var $server;
        var $port;
        var $socket;

        var $handlers;
        
        var $buf = "";
        
        function ManagerProxy($server,$port) {
                $this->server = $server;
                $this->port = $port;
        }

        function connect() {
                if (!$this->socket = fsockopen($this->server, $this->port, $errno, $errstr, 10)) {
                        return false;
                }
                
        }

        function set_handler($callback) {
                $this->handler = $callback;
        }

        function wait_read($timeout = 10) {
                socket_set_timeout($this->socket, $timeout);
        
                // read up to \n , or error 
                $read = @ fgets($this->socket, 4096);
                if ($read === false) {
                        return false;
                } else if ($read === "") {
                        // timeout
                        return true;
                } else {
                        $this->buf .= $read;
                        if (($read[strlen($read)-1] == "\n") || ($read[strlen($read)-1] == "\r")) {
                                // handle it
                                $this->handle_data(trim($this->buf));
                                $this->buf = '';
                        }
                        return true;
                }
        }

        function handle_data($data) {
                if ($arr = unserialize($data)) {
                        if (!isset($arr['Event'])) {
                                return false;
                        }
                        
                        if (isset($this->handler) && function_exists($this->handler)) {
                                // have a callback
                                $handler = $this->handler;
                                // run callback
                                $handler($arr['Event'], $arr);
                        }
                }
                return false;
                
        }
}


?>