#!/usr/bin/php -q
<?php
{
// Version 1.11 2005-Nov-15
// ------------
// CONFIG Parms
// ------------
require 'wake.inc';
//-------------------
// END CONFIG PARMS
//-------------------
GLOBAL $stdin, $stdout, $stdlog, $result, $parm_debug_on, $parm_test_mode;
// These setting are on the WIKI pages http://www.voip-info.org
ob_implicit_flush(false);
set_time_limit(30);
error_reporting(0);
$stdin = fopen( 'php://stdin', 'r' );
$stdout = fopen( 'php://stdout', 'w' );
// You will see a whole bunch of this its for development or if you change anything and
// want to write to a log file in the TMP directory
if ($parm_debug_on)
{
$stdlog = fopen( $parm_error_log, 'w' );
fputs( $stdlog, "---Start---\n" );
}
// ASTERISK * Sends in a bunch of variables, This accepts them and puts them in an array
// http://www.voip-info.org/tiki-index.php?page=Asterisk%20AGI%20php
while ( !feof($stdin) )
{
$temp = fgets( $stdin );
if ($parm_debug_on)
fputs( $stdlog, $temp );
// Strip off any new-line characters
$temp = str_replace( "\n", "", $temp );
$s = explode( ":", $temp );
$agivar[$s[0]] = trim( $s[1] );
if ( ( $temp == "") || ($temp == "\n") )
{
break;
}
}
// There are two ways to contact a phone, by its channel or by its local
// extension number. This next session will extract both sides
// split the Channel SIP/11-3ef4 or Zap/4-1 into is components
$channel = $agivar[agi_channel];
if (preg_match('.^([a-zA-Z]+)/([0-9]+)([0-9a-zA-Z-]*).', $channel, $match) )
{
$sta = trim($match[2]);
$chan = trim($match[1]);
}
// Go Split the Caller ID into its components
$callerid = $agivar[agi_callerid];
// First look for the Extension in <####>
if (preg_match('/<([ 0-9]+)>/', $callerid, $match) )
{
$cidn = trim($match[1]);
}
else // Did not find the <##...> look for the first number in the string to use as CID
{
if (preg_match('/([0-9]+)/', $callerid, $match) )
{
$cidn = trim($match[1]);
}
else
$cidn = -1; // I'm saying an error no caller id # found
}
// Check if we have an outstanding Wakeup Call file
if ( $parm_chan_ext )
$dir_check = "$chan.$sta.call";
else
$dir_check = "ext.$cidn.call";
if ($parm_debug_on)
fputs( $stdlog, "Checking Directory [$parm_call_dir] Check=[$dir_check]\n" );
// I started to think we could have many outstanding wakup calls, but then
// it got very confusing on how to delete just one of them. I wasn't about
// to prompt each and every one. So I went back to JUST ONE wakeup call
// But this will get a list of all of them incase of problems
$outc=0;
$dir_handle = opendir( $parm_call_dir );
while( $file = readdir($dir_handle ) )
{
if ($parm_debug_on)
fputs( $stdlog, "File=$file\n" );
// Check if we have an outstanding wakup call
if (strstr( $file, $dir_check ) )
$out[$outc++] = $file;
}
closedir( $dir_handle );
//=========================================================================
// This is where we interact with the caller. Answer the phone and so on
//=========================================================================
$rc = execute_agi( "ANSWER ");
sleep(1); // Wait for the channel to get created and RTP packets to be sent
// On my system the welcome you would only hear 'elcome' So I paused for 1 second
if ( !$rc[result] )
$rc = execute_agi( "STREAM FILE welcome \"\" ");
// They have an outstanding wakup call
if ( $outc )
{
$i = 0;
while ( $out[$i] )
{
$wtime = strtok( $out[$i], '.' );
if ($parm_debug_on)
fputs( $stdlog, "wakeup found=$out[0] saying time $wtime\n" );
say_wakeup( $wtime );
$i++;
}
}
// Check if any outstanding wakeup calls
if ( $outc )
{
// Start prompting them if they want to create or delete a wakeup call
while ( !$rc[result] )
{
if ( !$rc[result] )
$rc = execute_agi( "STREAM FILE for-wakeup-call \"12\" ");
if ( !$rc[result] )
$rc = execute_agi( "STREAM FILE press-1 \"12\" ");
if ( !$rc[result] )
$rc = execute_agi( "STREAM FILE to-cancel-wakeup \"12\" ");
if ( !$rc[result] )
$rc = execute_agi( "STREAM FILE press-2 \"12\" ");
if ( !$rc[result] )
{
$rc = execute_agi( "WAIT FOR DIGIT 15000");
}
if ( $rc[result] != -1 )
{
if ( $rc[result] == 49 || $rc[result] == 50 )
{
; // Do nothing
}
else
{
// This was just for fun, if they press something other than 1 or 2
$rc[result] = 0;
$rc = execute_agi( "STREAM FILE you-dialed-wrong-number \"\" ");
$rc = execute_agi( "STREAM FILE wrong-try-again-smarty \"\" ");
}
}
}
}
else // Default to Creating a wakeup call
$rc[result] = '49';
// Process which key they pressed
// I check most of my Return Codes incase the call is hung up
//
// Being a phone person, I want to be able to skip the prompts, so I allow for entry over
// The prompts. Makes for more code, but make for quicker entry after you know what to key
//
switch( $rc[result] )
{
case '49': // Pressed 1 - This is to schedule a NEW wakeup call
{
$rc[result] = 0;
while ( !$rc[result] )
{
$rc = execute_agi( "STREAM FILE please-enter-the \"0123456789\" ");
if ( !$rc[result] )
$rc = execute_agi( "STREAM FILE time \"0123456789\" ");
if ( !$rc[result] )
$rc = execute_agi( "STREAM FILE for \"0123456789\" ");
if ( !$rc[result] )
$rc = execute_agi( "STREAM FILE your \"0123456789\" ");
// If we get here, they haven't pressed anything yet.
if ( !$rc[result] )
$rc = execute_agi( "GET DATA wakeup-call 15000 4");
if ( $rc[result] != -1 )
{
if ($parm_debug_on)
fputs( $stdlog, "We have num digits:" . strlen( $rc[result]) . "- $rc[result] \r\n\r\n" );
// This check how many digits, if 2 then they pre-pressed a digit,
// Otherwise it will be 4
if ( strlen( $rc[result] ) == 2 )
{
$num= $rc[result]-48;
while ( strlen($num) < 4 && $rc[result] > 0 )
{
$rc = execute_agi( "WAIT FOR DIGIT 15000");
if ( $rc[result] >= 48 && $rc[result] <= 57 )
$num .= $rc[result] - 48;
else
$rc[result] = 0;
}
if (strlen($num) == 4 )
$rc[result] = $num;
}
if ($parm_debug_on)
fputs( $stdlog, "Checking Results [$rc[result]] \r\n\r\n" );
// They entered 4 digits, check if its a valid time or they hung up
if ( $rc[result] > 2359 || strlen( $rc[result]) < 4 || substr($rc[result],2,2) > 59 || $rc[result] < 0)
{
$rc[result] = 0;
//$rc = execute_agi( "STREAM FILE invalid \"\" ");
//$rc = execute_agi( "STREAM FILE time \"\" ");
$rc = execute_agi( "STREAM FILE please-try-again \"\" ");
}
if (strlen( $rc[result] ) == 4 && $rc[result] == 0 )
$rc[result] = -2; // Special 00:00 time
}
}
if ( $rc[result] == -2 )
$rc[result] = '0000';
else if ( $rc[result] == -1 )
exit; // The user hung up
// Save the time entered
$wtime = $rc[result];
// We don't know who the user is, so if its less than 1300 it could be AM or PM, so prompt
// them for am pm
if ( $wtime != -1 && $wtime < 1300 )
{
$rc[result] = 0;
while ( !$rc[result] )
{
if ( !$rc[result] )
$rc = execute_agi( "GET DATA 1-for-am-2-for-pm 15000 1");
}
switch( $rc[result] )
{
case '1': // Set to AM should be under 1159 or less
if ( $wtime > 1159 )
$wtime -= 1200;
$rc[result] = 0;
break;
case '2': // Set to PM should be equal or over 1200
if ( $wtime < 1159 )
$wtime += 1200;
$rc[result] = 0;
break;
}
}
// At this point we have a millitary time in the $wtime variable
if ( $parm_chan_ext )
{
$wakefile = "$parm_temp_dir/$wtime.$chan.$sta.call";
$callfile = "$parm_call_dir/$wtime.$chan.$sta.call";
}
else
{
$wakefile = "$parm_temp_dir/$wtime.ext.$cidn.call";
$callfile = "$parm_call_dir/$wtime.ext.$cidn.call";
}
if ($parm_debug_on)
fputs( $stdlog, "Wakeup File [$wakefile]\n" );
// Open up a wakeup file to write it out.
$wuc = fopen( $wakefile, 'w');
if ( $wuc )
{
// Delete any old Wakeup call files this one will override
for ($i=0; $i < $outc; $i++ )
{
if( file_exists( "$parm_call_dir/$out[$i]" ) )
{
if ($parm_debug_on)
fputs( $stdlog, "Unlinking Old File [$parm_call_dir/$out[$i]]\n" );
unlink( "$parm_call_dir/$out[$i]" );
}
}
// I've noticed that the other WAKEUP example has a different format. This worked for me
// Here is where we either make the call to the Extension or the Channel. Extension
// is the better way to go, but required the caller ID information. Where Channel
// should always get you back to where you were called from, provided its on your system
if ( $parm_chan_ext )
fputs( $wuc, "channel: $chan/$sta\n" );
else
fputs( $wuc, "channel: Local/$cidn@$agivar[agi_context]\n" );
fputs( $wuc, "maxretries: $parm_maxretries\n");
fputs( $wuc, "retrytime: $parm_retrytime\n");
fputs( $wuc, "waittime: $parm_waittime\n");
fputs( $wuc, "callerid: $parm_wakeupcallerid\n");
fputs( $wuc, "application: $parm_application\n");
fputs( $wuc, "data: $parm_data\n");
fclose( $wuc );
$w = getdate();
$w['hours'] = substr( $wtime, 0, 2 );
$w['minutes'] = substr( $wtime, 2, 2 );
$time_wakeup = mktime( substr( $wtime, 0, 2 ), substr( $wtime, 2, 2 ), 0, $w[mon], $w[mday], $w[year] );
$time_now = time( );
if ($parm_debug_on)
fputs( $stdlog, 'time_wakeup=' . date('l dS \of F Y h:i:s A', $time_wakeup) . " ($time_wakeup) | time_now=" . date('l dS \of F Y h:i:s A',$time_now) . " ($time_now)\n" );
if ( $time_wakeup <= $time_now )
$time_wakeup += 86400; // Add One Day on
if ($parm_debug_on)
fputs( $stdlog, 'Setting WAKEUP file to =' . date('l dS \of F Y h:i:s A', $time_wakeup) . " - $time_wakeup\n" );
touch( $wakefile, $time_wakeup, $time_wakeup );
rename( $wakefile, $callfile );
}
else
{
// Couldn't open the file. Make sure you created the /var/lib/asterisk/wakeups directory
if ($parm_debug_on)
fputs( $stdlog, "Error opening file [$wakefile]\n" );
$rc = execute_agi( "STREAM FILE something-terribly-wrong \"\" ");
if ( !$rc[result] )
$rc = execute_agi( "STREAM FILE goodbye \"\" ");
if ( !$rc[result] )
$rc = execute_agi( "HANGUP");
exit;
}
// If we have a caller ID and waking up by extension say the extension number
//if ( $cidn && $parm_chan_ext == 0 )
//{
// $rc = execute_agi( "STREAM FILE for \"\" ");
//
// if ( !$rc[result] )
// $rc = execute_agi( "STREAM FILE extension \"\" ");
//
//
// if ( !$rc[result] )
// $rc = execute_agi( "SAY DIGITS $cidn \"\" ");
//
//}
say_wakeup( $wtime );
$rc[result] = 0;
}
break;
// This is the END Of a new wakeup call
case '50': // Pressed 2 - Delete old wakeup calls
{
// Go through the list of old files and unlink/delete them
for ($i=0; $i < $outc; $i++ )
{
if( file_exists( "$parm_call_dir/$out[$i]" ) )
{
if ($parm_debug_on)
fputs( $stdlog, "Unlinking Wakeup File [$parm_call_dir/$out[$i]]\n" );
unlink( "$parm_call_dir/$out[$i]" );
}
}
// If Caller ID and recording by Extension then say the extension
if ( $cidn && $parm_chan_ext == 0 )
{
$rc = execute_agi( "STREAM FILE for \"\" ");
if ( !$rc[result] )
$rc = execute_agi( "STREAM FILE extension \"\" ");
$L = strlen( $cidn );
for( $i = 0; $i < $L && !$rc[result]; $i++ )
{
$cid_digits = substr( $cidn, $i, 1 );
if ( !$rc[result] )
$rc = execute_agi( "SAY NUMBER $cid_digits \"\" ");
}
}
$rc = execute_agi( "STREAM FILE wakeup-call-cancelled \"\" ");
}
break;
}
if ( !$rc[result] )
$rc = execute_agi( "STREAM FILE goodbye \"\" ");
if ( !$rc[result] )
$rc = execute_agi( "HANGUP");
if ($parm_debug_on)
fclose($stdlog);
exit;
}
// ----------------------------------------------
// This will say military time in AM/PM format
// ----------------------------------------------
function say_wakeup( $wtime )
{
GLOBAL $stdin, $stdout, $stdlog, $parm_debug_on;
$pm = 0;
if ($wtime > 1159 )
{
$wtime -=1200;
$pm = 1;
}
if ($wtime <= 59 )
$wtime += 1200;
if ( strlen( $wtime ) == 3 )
$wtime = '0' . $wtime;
$h = substr( $wtime, 0, 2 );
$h1 = substr( $wtime, 0, 1 );
$h2 = substr( $wtime, 1, 1 );
$m = substr( $wtime, 2, 2 );
$m1 = substr( $wtime, 2, 1);
$m2 = substr( $wtime, 3, 1);
if ($parm_debug_on)
fputs( $stdlog, "Wakeup time is set to $wtime\n" );
$rc = execute_agi( "STREAM FILE rqsted-wakeup-for \"\" ");
if ( !$rc[result] )
{
if ( $h1 == 0 )
$rc = execute_agi( "SAY NUMBER $h2 \"\"");
else
$rc = execute_agi( "SAY NUMBER $h \"\"");
if ( !$rc[result] )
{
if ($m == 0 )
$rc = execute_agi( "STREAM FILE digits/oclock \"\" ");
else
{
if ( $m1 == 0 )
{
$rc = execute_agi( "STREAM FILE digits/oh \"\" ");
$rc = execute_agi( "SAY NUMBER $m2 \"\" ");
}
else
$rc = execute_agi( "SAY NUMBER $m \"\"");
}
if ( !$rc[result] )
{
if ( $pm )
$rc = execute_agi( "STREAM FILE digits/p-m \"\" ");
else
$rc = execute_agi( "STREAM FILE digits/a-m \"\" ");
}
}
}
}
//--------------------------------------------------
// This function will send out the command and get
// the response back
//--------------------------------------------------
function execute_agi( $command )
{
GLOBAL $stdin, $stdout, $stdlog, $parm_debug_on;
fputs( $stdout, $command . "\n" );
fflush( $stdout );
if ($parm_debug_on)
fputs( $stdlog, $command . "\n" );
$resp = fgets( $stdin, 4096 );
if ($parm_debug_on)
fputs( $stdlog, $resp );
if ( preg_match("/^([0-9]{1,3}) (.*)/", $resp, $matches) )
{
if (preg_match('/result=([-0-9a-zA-Z]*)(.*)/', $matches[2], $match))
{
$arr['code'] = $matches[1];
$arr['result'] = $match[1];
if (isset($match[3]) && $match[3])
$arr['data'] = $match[3];
return $arr;
}
else
{
if ($parm_debug_on)
fputs( $stdlog, "Couldn't figure out returned string, Returning code=$matches[1] result=0\n" );
$arr['code'] = $matches[1];
$arr['result'] = 0;
return $arr;
}
}
else
{
if ($parm_debug_on)
fputs( $stdlog, "Could not process string, Returning -1\n" );
$arr['code'] = -1;
$arr['result'] = -1;
return $arr;
}
}
?>