Asterisk Monitor 1.10 Released

I released Asterisk Monitor 1.10 on iTunes, starting from this release you should use a php proxy that I developed, to enhance the functionality of  asterisk manager with new functions. I have added more functions in the application such as the reload option for extensions, sip, voicemail, gtalk and queue. I also added the logs watch, and the cdr list. The cdr is only from the CSV file at this point.

In order to use this version and all its features, you should install the php proxy which needs a html server such as apache or lighttpd or any other one, that is able to manage the php files and also the SSL connection. I will not go over these configurations however, if you need some help let me know.  In this version, there is a little bug which is caused by the platform that I used to develop the application. At this point in time, it is not able to use the SSL connection on a different port from the 443.

First of all, edit the manager.conf that is usually under /etc/asterisk
In the general session, put yes on enabled

[general]
enabled = yes
port = 5038
bindaddr = 0.0.0.0

[myusername]
secret = mynewpass
deny=0.0.0.0/0.0.0.0
permit=127.0.0.1/0.0.0.0
write = system,call,agent,user,config,command,originate

These are the two files that you must upload on your system and also need to use the rewrite module. On the lighttpd that I used for the tests, I have used the following line in lighttpd.conf to set modrewrite.

url.rewrite = ( "^/asterisk/mxml(.*)$"  => "/mini_cmds.php$1" )

In apache you can do on httpd.conf or .htaccess. Then you need the two php files, the main file where you have the authorization part, the case switch to decide if the actions is original or if it is my function
mini_cmds.php mini_cmds.php

<?
/*
Copyright 2010  Michele Nasoni. All rights reserved.

Redistribution and use in source and binary forms, with or without modification, are
permitted provided that the following conditions are met:

 1. Redistributions of source code must retain the above copyright notice, this list of
 conditions and the following disclaimer.

 2. Redistributions in binary form must reproduce the above copyright notice, this list
 of conditions and the following disclaimer in the documentation and/or other materials
 provided with the distribution.

THIS SOFTWARE IS PROVIDED BY MICHELE NASONI (http://www.nasoni.net)  ``AS IS'' AND ANY EXPRESS OR IMPLIED
WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND
FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL MICHELE NASONI  OR
CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON
ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING
NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF
ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.

The views and conclusions contained in the software and documentation are those of the
authors and should not be interpreted as representing official policies, either expressed
or implied, of Michele Nasoni (http://www.nasoni.net).

mini_cmds.php    Version. 1.01    13-dec-2010
*/

session_start();
/*
For the moment only one account
You can transform in an array
*/
$username="YOURUSER";
$password="YOURPASS";
// I am lazy, that I prefer skip an amount of bytes in order to read the end of the file
define("READBYTES",-160*20);
// Sometime you prefer to have multiple installation or to use a different directory for you applications
define('AST_PATH','/opt/asterisk16');
// A Log can help sometime
define("DEBUG",true);
define("DEBUG_PATH",'/tmp/azione.txt');
define('DEBUG_METHOD','w');
/*
If it does not match send a 404 and wait 4 seconds
in a next mod, we can save the IP and block it, probably using fail2ban easy to do
*/

// Put a instead w if you want to append
if( DEBUG )
 $log=fopen(DEBUG_PATH,DEBUG_METHOD);

function debug($what)
{
 // Debug off and the file is open
 if( DEBUG && isset($log) )
 {
 fwrite($log,$what."\n");
 }
}

foreach($_GET as $k=>$v )
 debug("$k => $v");

include("ConnectManager.php");

$cm=new ConnectManager();

if( (!isset($_SESSION['login']) || $_SESSION['login']==0) && ( $username!=$_GET['username'] || $password!=$_GET['secret'] ) )
{
 unset( $_SESSION['login'] );
//    sleep(4);

 $cm->xml(array(array('response'=>'Error','message'=>'Authentication Problem')));
//    header("HTTP/1.0 404 Not Found");
 exit;
}
else if( $_GET['action']=='Login' )
{
 foreach($_SESSION as $k=>$v)
 unset($_SESSION[$k]);
 $_SESSION['login']=1;
}

if( $_SESSION['login']!=1 )
{
 sleep(4);
 header("HTTP/1.0 404 Not Found");
 exit;
}
// Load the Main Class

if( DEBUG )
{
 foreach($_GET as $k=> $v)
 debug("$k => $v");
}

if( !isset($_GET['action']))
{
 return;
}
if( $_GET['action']=='Login')
{
 $cm->xml(array(array('response'=>'Success','message'=>'Authentication accepted')));
 exit;
}

$conn=new ConnectManager();

switch($_GET['action'] )
{
 case 'cdr':
 // For now only the cvs (I should add the module for the DB)
 if( file_exists(AST_PATH.'/var/log/asterisk/cdr-csv/Master.csv'))
 {
 $fpp=fopen(AST_PATH.'/var/log/asterisk/cdr-csv/Master.csv','r');
 if( $fpp )
 {
 // If the APP reload the info start from the previous line read, with the DB I should rework this
 if( isset($_SESSION['cdr_pos'])) {
 debug('Position '.$_SESSION['cdr_pos']);
 fseek($fpp,$_SESSION['cdr_pos'] );
 }
 $rows=array();
 while (($data = fgetcsv($fpp, 1000, ",")) !== FALSE) {
 debug("Reading lines");
 array_push($rows, array( 'clid' =>$data[0], 'src' =>$data[1], 'dst' => $data[2], 'lastdata'=>$data[7], 'answer'=>$data[10], 'end'=>$data[11], 'billsec' => $data[13]) );
 }
 $cm->xml($rows, 1);
 $_SESSION['cdr_pos']=ftell($fpp);
 fclose($fpp);
 }
 }
 break;
 case 'logs':
 if(file_exists(AST_PATH.'/var/log/asterisk/'.strtolower($_GET['command']) ) )
 {
 $fpp=fopen(AST_PATH.'/var/log/asterisk/'.strtolower($_GET['command']),'r');
 if( $fpp )
 {
 $result='';
 $replace=array('"','\'');
 if( isset($_SESSION['log_'.strtolower($_GET['command']).'_pos']))
 {
 fseek($fpp,$_SESSION['log_'.strtolower($_GET['command']).'_pos']);
 }
 else
 {
 fseek($fpp,READBYTES, SEEK_END);
 }
 $res=array();
 while (! feof ($fpp)) {
 $line=fgets($fpp);
 if ( preg_match("/\[(.*)\] ([A-Z]*)\[([0-9]*)\] (.*)/",$line,$match) )
 {
 $res[]=array('date'=>$match[1], 'event' =>$match[2], 'message'=>str_replace($replace,'',$match[4]));
 }
 }
 $cm->xml($res,1);
 $_SESSION['log_'.strtolower($_GET['command']).'_pos']=ftell($fpp);
 fclose($fpp);
 }
 else
 debug('Problem opening the log');
 }
 else
 debug('The log '.AST_PATH.'/var/log/asterisk/'.strtolower($_GET['command']).' does not exist');
 break;
 default:
 // If it is not one of my actions, send it to the manager
 $cm->login();
 $st='';
 foreach($_GET as $k=>$v )
 {
 $st.=ucfirst($k).': '.$v."\r\n";
 }

 $cm->send($st."\r\n\r\n",true);
 $cm->logoff();
 break;
}
if( isset($log) )
 fclose($log);
?>

And the class that manages the connection with the manager and the xml formatting

ConnectManager.php ConnectManager.php

<?
/*
Copyright 2010  Michele Nasoni. All rights reserved.

Redistribution and use in source and binary forms, with or without modification, are
permitted provided that the following conditions are met:

 1. Redistributions of source code must retain the above copyright notice, this list of
 conditions and the following disclaimer.

 2. Redistributions in binary form must reproduce the above copyright notice, this list
 of conditions and the following disclaimer in the documentation and/or other materials
 provided with the distribution.

THIS SOFTWARE IS PROVIDED BY MICHELE NASONI (http://www.nasoni.net)  ``AS IS'' AND ANY EXPRESS OR IMPLIED
WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND
FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL MICHELE NASONI  OR
CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON
ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING
NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF
ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.

The views and conclusions contained in the software and documentation are those of the
authors and should not be interpreted as representing official policies, either expressed
or implied, of Michele Nasoni (http://www.nasoni.net).

ConnectManager.php    Version. 1.00    11-dec-2010
*/

class ConnectManager
{
 var $astmanager        ="YOURUSER";        // Asterisk Manager user
 var $astpassword    ="YOURPASS";        // Password
 var $astip        ="127.0.0.1";        // IP
 var $astport        ="5038";        // Port
 var $timeout        ="30";            // Timeout
 var $errno        ="";
 var $errstr        ="";
 var $socket;

 // Open the socket
 function __construct()
 {
 $this->socket=fsockopen($this->astip, $this->astport, $this->errno, $this->errstr, $this->timeout);
 stream_set_timeout($this->socket, $this->timeout);

 if( !$this->socket )
 {
 echo "$errstr ($errno)\n";
 exit(1);
 }
 }

 // Close the socket
 function __destruct()
 {
 fclose($this->socket);
 }

 // The login before sending the actions
 function login()
 {
 $cmd ="Action: Login\r\n";
 $cmd.="UserName: $this->astmanager\r\n";
 $cmd.="Secret: $this->astpassword\r\n";
 $cmd.="Events: off\r\n\r\n";
 $this->send($cmd,false);
 }

 // Logoff
 function logoff()
 {
 $cmd ="Action: Logoff\r\n\r\n";
 $this->send($cmd,false);
 }

 // Send the commands
 function send($cmd, $return )
 {
 fputs($this->socket,$cmd );
 if( $return )
 {
 // If you need the answer
 $this->parseXML();
 }
 else
 $this->listen();
 }

 // Listen for the answer
 private function listen()
 {
 $line='';
 $info='';
 $retInfo='';
 do {
 $line = fgets($this->socket, 4096);
 $retInfo.=$line;
 $info = stream_get_meta_data($this->socket);
 } while ($line != "\r\n" && $info['timed_out'] == false );
 return $retInfo;
 }

 //  Read the
 private function parseXML()
 {
 $res=array();
 $a=0;
 $loop=false;
 do {
 $res[$a]=array();
 $lines=$this->listen($this->socket);
 if( preg_match('/Message: .*( will follow)\r\n/',$lines, $matches) )
 {
 $loop=true;
 }
 if( preg_match('/Event: .*(EntryComplete)\r\n/',$lines, $matches) )
 {
 $loop=false;
 }
 if( preg_match('/EventList: (.*)\r\n/',$lines, $matches) )
 {
 if( $matches[1]=='start') $loop=true;
 if( $matches[1]=='Complete') $loop=false;
 }

 if( preg_match_all('/(\w*): (.*)\r\n/', $lines, $matches) )
 {
 array_shift($matches);
 for($i=0;$i<count($matches[0]);$i++)
 {
 $res[$a][strtolower($matches[0][$i])]=$matches[1][$i];
 }
 }
 $a++;
 }while($loop);
 $this->xml($res);
 }    

 // Format the array in XML
 public function xml( $vals, $force=0)
 {
 $ret='<ajax-response>'."\n";
 if($force ==1)
 {
 $ret.='<response type="object" id="unknown">'."\n";
 $ret.='<generic response="Success" message="list will follow"/>'."\n";
 $ret.='</response>'."\n";
 }
 for($i=0;$i<count($vals);$i++)
 {
 $ret.='<response type="object" id="unknown">'."\n".'<generic';
 foreach($vals[$i] as $k=>$v)
 $ret.=' '.$k.'="'.addslashes(htmlentities($v)).'"';
 $ret.='/>'."\n".'</response>'."\n";
 }
 if( $force==1)
 {
 $ret.='<response type="object" id="unknown">'."\n";
 $ret.='<generic event="EntryComplete"/>'."\n";
 $ret.='</response>'."\n";
 }
 $ret.='</ajax-response>'."\n";
 header ("content-type: text/xml");
 echo $ret;
 }
}
?>

Sorry for the quality of the source code, however, I thaught that it was more important to give you something to start.
I need to hear from you, since I do not know if the application is appreciated and if it is worthed to spend time on it.

If I do not receive feedback this means that there are no interest for it.