OpenPKG Specs: asterisk/wakeup.agi@a2c6460cfb16 (annotated)

asterisk/wakeup.agi@a2c6460cfb16 (annotated)

asterisk/wakeup.agi

Mon, 28 Jan 2013 17:37:18 +0100

author: Michael Schloh von Bennewitz <michael@schloh.com>
date: Mon, 28 Jan 2013 17:37:18 +0100
changeset 758: a2c6460cfb16
parent 202: f29abea29121
permissions: -rw-r--r--

Correct socket error reporting improvement with IPv6 portable code,
after helpful recommendation by Saúl Ibarra Corretgé on OSips devlist.

 #! @l_prefix@/bin/perl
 #
 # wakeup.agi 1.1
 #
 # A wakeup agi script for Asterisk
 #
 # Copyright (C) 2007
 #
 # Jonas Arndt <jonas_arndt@comcast.net>
 #
 # This program is free software, distributed under the terms of the
 # GNU General Public License v2.
 #
 #
 # This program is free software: you can redistribute it and/or modify
 # it under the terms of the GNU General Public License as published by
 # the Free Software Foundation, either version 3 of the License, or
 # (at your option) any later version.
 #
 # This program is distributed in the hope that it will be useful,
 # but WITHOUT ANY WARRANTY; without even the implied warranty of
 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 # GNU General Public License for more details.
 #
 # You should have received a copy of the GNU General Public License
 # along with this program.  If not, see <http://www.gnu.org/licenses/>.
 #
 use strict;
 use Time::Local;
 $|=1;
 # Setup some variables
 my %AGI; my $DEBUG=0;
 # Some constants
 my $OUTDIR="@l_prefix@/var/asterisk/spool/outgoing";
 my $WAKEDIR="@l_prefix@/var/asterisk/spool/tmp";
 my $debugfile="@l_prefix@/var/asterisk/spool/tmp/wakeup.log";
 my $DEBUGOUT = "filehandle";
 my $CALL = "filehandle";
 my $TOUCH = "/usr/bin/touch";
 ############ check_result ##########
 # Use this to check the result of  #
 # a sent command                   #
 # I pretty much stole this from    #
 # the regular agi-test.agi         #
 ####################################
 sub checkresult {
     my ($res) = @_;
     my $retval;
     chomp $res;
     if ($res =~ /^200/) {
         $res =~ /result=(-?\d+)/;
         if (!length($1)) {
             print DEBUGOUT "FAIL ($res)\n";
             exit(1);
         } elsif ($DEBUG=1) {
             print DEBUGOUT "PASS ($1)\n";
         }
     } else {
         print STDERR "FAIL (unexpected result '$res')\n";
         exit(1);
     }
 }
 ############ send_file ####
 # Use this to send a wave #
 # file on the channel     #
 ###########################
 sub send_file {
     my ($myfile) = @_;
     chomp($myfile);
     if ($DEBUG == 1 ) {
         print DEBUGOUT "Sending stream $myfile \n";
     }
     print "STREAM FILE $myfile \"0123456789\"\n";
     my $result = <STDIN>;
     &checkresult($result);
     $result =~ /result=(-?\d+)/;
     return $1;
 }
 ############ hangup  ###############
 # Use this to hang up a channel    #
 ####################################
 sub hangup {
     if ($DEBUG == 1 ) {
         print DEBUGOUT "Hanging up \n";
     }
     print "HANGUP \"\" \n";
     my $result = <STDIN>;
     &checkresult($result);
 }
 ############ say_number ############
 # Use this to say a number         #
 # over the channel                 #
 #                                  #
 ####################################
 sub say_number {
     my ($mynumber) = @_;
     chomp($mynumber);
     if ($DEBUG == 1 ) {
         print DEBUGOUT "Saying number $mynumber \n";
     }
     print "SAY NUMBER $mynumber \"0123456789\"\n";
     my $result = <STDIN>;
     &checkresult($result);
     $result =~ /result=(-?\d+)/;
     return $1;
 }
 ############ say_digits ###################
 # Use this to say digits over the channel #
 ###########################################
 sub say_digits {
     my ($mynumber) = @_;
     chomp($mynumber);
     if ($DEBUG == 1 ) {
         print DEBUGOUT "Saying digits $mynumber \n";
     }
     print "SAY DIGITS $mynumber \"0123456789\"\n";
     my $result = <STDIN>;
     &checkresult($result);
 }
 ######## get_choice ############
 # Use this to receive a DTMF   #
 # choice from the channel      #
 ################################
 sub get_choice {
     if ($DEBUG == 1 ) {
         print DEBUGOUT "Getting choice \n";
     }
     print "WAIT FOR DIGIT 15000\n";
     my $result = <STDIN>;
     &checkresult($result);
     $result =~ /result=(-?\d+)/;
     return $1;
 }
 ###### answer  ######
 # Anser the channel #
 #####################
 sub answer {
     if ($DEBUG == 1 ) {
         print DEBUGOUT "Answering the channel \n";
     }
     print "ANSWER\n";
     my $result = <STDIN>;
     &checkresult($result);
     $result =~ /result=(-?\d+)/;
     return $1;
 }
 ######## get_data ##################
 # Feed with (file, maxnumbers)     #
 # where file is the sound file     #
 # to be played and maxnumbers is   #
 # the maximum amount of digits to  #
 # allow in the answer              #
 ####################################
 sub get_data {
     my @mydata = @_;
     my $myfile = $mydata[0];
     my $mymax = $mydata[1];
     if ($DEBUG == 1 ) {
         print DEBUGOUT "Getting data \n";
     }
     print "GET DATA $myfile 15000 $mymax \n";
     my $result = <STDIN>;
     &checkresult($result);
     $result =~ /result=(-?\d+)/;
     return $1;
 }
 ###### check_outstanding_calls #####
 # Are there any outstanding wakeup #
 # calls for this extensions?       #
 # Pass the extension to the        #
 # function. The function returns   #
 # a list of files                  #
 ####################################
 sub check_outstanding_calls {
     my $myext = @_;
     #opendir DIR, $WAKEDIR;
     opendir DIR, $OUTDIR;
     my @files = grep {/$myext/} readdir(DIR);
     closedir DIR;
     return @files;
 }
 ######## get_extension #############
 # Receive the AIG variable and     #
 # return the extension             #
 ####################################
 sub get_extension {
     my (@aig) = @_;
         if ($aig[11] == '') {
         print STDERR "No extension found in function get_exension \n";
         return "FAIL";
     }
     my $myext = $aig[11];
     return $myext;
 }
 ######## get_context ###############
 # Receive the AIG variable and     #
 # return the context               #
 ####################################
 sub get_context {
     my (@aig) = @_;
         if ($aig[8] == '') {
         print STDERR "No extension found in function get_exension \n";
         return "FAIL";
     }
     my $mycont = $aig[8];
     return $mycont;
 }
 ########### get_clid ###############
 # Receive the AIG variable and     #
 # return the clid                  #
 ####################################
 sub get_clid {
     my (@aig) = @_;
         if ($aig[1] == '') {
         print STDERR "No clid found in function get_clid \n";
         return "FAIL";
     }
     my $myext = $aig[1];
     return $myext;
 }
 ############### init_agi ##################
 # Use this to initialize the AGI variable #
 ###########################################
 sub init_agi {
     while(<STDIN>) {
         chomp;
         last unless length($_);
         if (/^agi_(\w+)\:\s+(.*)$/) {
             $AGI{$1} = $2;
         }
     }
 }
 ######### ascii2num ##########
 # Removes 48 to get a number #
 # out of the asciss return   #
 ##############################
 sub ascii2num {
     my ($asc) = @_;
     my $ret;
     $ret = $asc - 48;
     return $ret;
 }
 ############# Welcome ##############
 # This is the welcome menu         #
 ####################################
 sub welcome {
     my $ret = 0;
     $ret = &send_file("welcome");
     if ($ret == 0) {
         $ret = &send_file("for-wakeup-call");
     }
     if ($ret == 0) {
         $ret = &send_file("press-1");
     }
     if ($ret == 0) {
         $ret = &send_file("for-a-list-of");
     }
     if ($ret == 0) {
         $ret = &send_file("or");
     }
     if ($ret == 0) {
         $ret = &send_file("to-cancel-wakeup");
     }
     if ($ret != 0) {
         $ret = &ascii2num($ret);
     }
     if ($ret == 0) {
         $ret = &get_data("press-2",1);
     }
     if ($ret == 1) {
         $ret = &schedule_new();
     } elsif ($ret == 2) {
         &manage_calls();
     } else {
         $ret = &send_file("goodbye");
     }
 }
 ######### manage_calls #############
 # This is what is called if you    #
 # want to manage already scheduled #
 # wakeup calls                     #
 ####################################
 sub manage_calls {
     my $checker = "false";
     my @calls;
     my $del;
     #my $ret;
     my $hours;
     my $minutes;
     # Send out a welcome message and ask for return
     @calls = &check_outstanding_calls($AGI{callerid});
     if ($#calls + 1 == 0) {
         $del = &send_file("not-rqsted-wakeup");
         $del = &send_file("goodbye");
     } else {
         foreach (@calls) {
             $del = 0;
             my $wakefile = $_;
             my @wakeup = split /\./, $_;
             my $time = $wakeup[0];
             $_ = $time;
             /(^[0-9][0-9])/;
             my $hours = $1;
             /^[0-9][0-9]([0-9][0-9])/;
             my $minutes = $1;
             $del = &send_file("rqsted-wakeup-for");
             if ($del == 0) {
                 $del = &say_number($hours);
             }
             if ($del == 0) {
                 if ($minutes >= 10 ) {
                     $del = &say_number($minutes);
                 } elsif ($minutes > 0 && $minutes < 10) {
                     $del = &send_file("digits/oh");
                     $del = &say_number($minutes);
                 }
             }
             if ($del == 0) {
                 $del = &send_file("digits/oclock");
             }
             if ($del == 0) {
                 $del = &send_file("to-cancel-wakeup");
             }
             if ($del == 0) {
                 $del = &send_file("press-1");
             }
             if ($del == 0) {
                 $del = &send_file("otherwise-press");
             }
             if ($del != 0) {
                 $del = &ascii2num($del);
             }
             if ($del == 0) {
                 $del = &get_data("digits/2",1);
             }
             if ($del == 1) {
                 my @sysargs = ("rm", "-f", "$WAKEDIR/$wakefile", "$OUTDIR/$wakefile");
                 system(@sysargs) == 0
                 or die "system @sysargs failed: $?";
                 $del = &send_file("cancelled");
             }
         }
         $del = &send_file("goodbye");
     }
 }
 ######## schedule_new ##########
 # This is the menu to schedule #
 # a new wakeup call            #
 ################################
 sub schedule_new {
     my $checker = "false";
     my $ret_var;
     my $ret_dummy = 0;
     my $time;
     my $perm;
     my $file;
     my $calltype;
     my $extension;
     my $context;
     my $hours;
     my $minutes;
     if ($DEBUG == 1 ) {
         print DEBUGOUT "From schedule_new\n";
     }
     while ( $checker eq "false" ) {
         $ret_var = &send_file("to-rqst-wakeup-call");
         if ($ret_var != 0) {
             my $tmp = &get_data("silence/1",3);
             $ret_var = &ascii2num($ret_var);
             $ret_var = $ret_var . $tmp;
         } else {
             $ret_var = &get_data("enter-a-time",4);
         }
 #        if ($ret_var < 1300 && $ret_var >= 0100) {
 #            my $pm = &get_data("1-for-am-2-for-pm",1);
 #            if ($pm == 2 && $ret_var <= 1159) {
 #                $ret_var = $ret_var + 1200;
 #                $checker = "true";
 #            } elsif ($pm == 1 && $ret_var > 1159) {
 #                $ret_var = $ret_var - 1200;
 #                # Fix the zero
 #                $ret_var = "00" . $ret_var;
 #                $checker = "true";
 #            } else {
 #                $checker = "true";
 #            }
 #        } elsif ($ret_var > 2359) {
 #            $ret_dummy = &send_file("please-try-again");
 #        } else {
 #            $checker = "true";
 #        }
         if ($ret_var > 2359) {
             $ret_dummy = &send_file("please-try-again");
         } else {
             $checker = "true";
         }
     }
     $perm = 0;
     $perm = &send_file("wakeup-for-one-time");
     if ($perm == 0) {
         $perm = &send_file("press-1");
     }
     if ($perm == 0) {
         $perm = &send_file("for-a-daily-wakeup-call");
     }
     if ($perm != 0) {
         $perm = &ascii2num($perm);
     }
     if ($perm == 0) {
         $perm = $perm = &get_data("press-2",1);
     }
     # Open the file and populate it with data
     $extension = $AGI{callerid};
     $context = $AGI{context};
     if ($perm == 2) {
         $file = "$WAKEDIR/$ret_var.perm.1.$extension.call";
         $calltype = "perm";
         open (CALL, '>', $file) or die "Cannot open call file for write :$!";
     } else {
         $file = "$WAKEDIR/$ret_var.temp.1.$extension.call";
         $calltype = "temp";
         open (CALL, '>', $file) or die "Cannot open call file for write :$!";
     }
     my $myprint = "channel: Local" . "/" . $extension . "@" . $context . "\n";
     print CALL $myprint;
     print CALL "maxretries: 3\n";
     print CALL "retrytime: 60\n";
     print CALL "waittime: 60\n";
     print CALL "callerid: \"AsterPBX Weckruf\" <$AGI{extension}>\n";
     print CALL "application: AGI\n";
     print CALL "data: wakeup|$ret_var.$calltype.1.$extension.call\n";
     close ($CALL);
     # Now touch the file
     # Get the time variable
     $time = get_time_string($ret_var);
     my @command = ("$TOUCH", "-t", "$time", "${file}");
     system(@command) == 0
         or die "system @command failed: $?";
     # Move it to the OUT directory
     my @command = ("mv", "${file}", "${OUTDIR}/");
     system(@command) == 0
         or die "system @command failed: $?";
     # Stream out the wakeup
     $_ = $ret_var;
     /(^[0-9][0-9])/;
     my $hours = $1;
     /^[0-9][0-9]([0-9][0-9])/;
     my $minutes = $1;
     $ret_dummy = &send_file("rqsted-wakeup-for");
     $ret_dummy = &say_number($hours);
     if ($minutes >= 10 ) {
         &say_number($minutes);
     } elsif ($minutes > 0 && $minutes < 10) {
         &send_file("digits/oh");
         &say_number($minutes);
     }
     $ret_dummy = &send_file("digits/oclock");
     $ret_dummy = &send_file("goodbye");
     return $ret_var;
 }
 ######## get_time_string ###########
 # This will return the time string #
 # when inputing a string like hhmi #
 ####################################
 sub get_time_string {
     my ($intime) = @_;
     my $minutes = substr($intime, 2, 4);
     my $hours = substr($intime, 0, 2);
     my $tmpepoch;
     my $day;
     my $month;
     my $ret_val;
     my $epoch = time();
     my @timedata = localtime($epoch);
     # Insert the minutes and hours from input
     $timedata[1] = $minutes;
     $timedata[2] = $hours;
     # Get tmpepoch
     $tmpepoch = timelocal(@timedata);
     #Now compare them
     if ($tmpepoch < $epoch) { # Means it is tomorrow
         $tmpepoch += 86400; # Add 24 hours
     }
     # Now get the new timedata
     my @timedata = localtime($tmpepoch);
     $minutes = $timedata[1];
     $hours = $timedata[2];
     $day = $timedata[3];
     $month = $timedata[4] + 1;
     #Correct the "First hour after midnight" problem
     if ($minutes < 10) {
         $minutes = "0" . $minutes;
     }
     if ($hours < 10) {
         $hours = "0" . $hours;
     }
     if ($day < 10) {
         $day = "0" . $day;
     }
     if ($month < 10) {
         $month = "0" . $month;
     }
     $ret_val = $month . $day . $hours . $minutes;
     return $ret_val;
 }
 ############ new_time ################
 # This will return the time string   #
 # with a time set 10 minute into     #
 # the future. The string is MMDDhhmi #
 ######################################
 sub new_time {
     my ($input) = @_;
     my @timedata;
     my $minutes;
     my $hours;
     my $day;
     my $month;
     my $ret_val;
     my $epoc = time();
     if ($input eq "10m") {
         # add 10 minutes
         $epoc += 600;
         #$epoc += 120; #just for debugs
     } else {
         # add 24 hours
         $epoc += 86400;
     }
     @timedata = localtime($epoc);
     $minutes = $timedata[1];
     $hours = $timedata[2];
     $day = $timedata[3];
     $month = $timedata[4] + 1;
     #Correct the "First hour after midnight" problem
     if ($minutes < 10) {
         $minutes = "0" . $minutes;
     }
     if ($hours < 10) {
         $hours = "0" . $hours;
     }
     if ($day < 10) {
         $day = "0" . $day;
     }
     if ($month < 10) {
         $month = "0" . $month;
     }
     $ret_val = $month . $day . $hours . $minutes;
     return $ret_val;
 }
 ########### snooze  ##########
 # This is the menu to snooze #
 # the wakeup call            #
 ##############################
 sub snooze {
     my ($oldfile) = @_;
     my $newfile;
     my $extension;
     my $context;
     my @filestore = split (/\./, $oldfile);
     my @permstore = split (/\./, $oldfile);
     my $time;
     my $ret_var = 0;
     my $ret_dummy;
     my $myprint;
     # Answer the channel
     &answer();
     # Is this a reoccuring call, then add 24h
     if ($permstore[1] eq "perm") {
         $permstore[2] += 1; #Just to get a new file name
         $newfile = join(".",@permstore);
         $extension = $AGI{extension};
         $context = $AGI{context};
         # Open the file
         open (CALL, '>', "${WAKEDIR}/${newfile}") or die "Cannot open call file for write :$!";
         $myprint = "channel: Local" . "/" . $extension . "@" . $context . "\n";
             print CALL $myprint;
             print CALL "maxretries: 3\n";
                 print CALL "retrytime: 60\n";
         print CALL "waittime: 60\n";
                 print CALL "callerid: \"AsterPBX Weckruf\" <$AGI{callerid}>\n";
             print CALL "application: AGI\n";
             print CALL "data: wakeup|$newfile\n";
             close ($CALL);
         # Get a time 24h from now
         $time = &new_time("24h");
         # Touch the file with the new time
         my @command = ("$TOUCH", "-t", "$time", "${WAKEDIR}/${newfile}");
         system(@command) == 0
             or die "system @command failed: $?";
         # Now move it
         my @command = ("mv", "${WAKEDIR}/${newfile}", "${OUTDIR}/${newfile}");
         system(@command) == 0
             or die "system @command failed: $?";
     }
     #Replace the file name time with snooze
     $filestore[1] = "snooze";
     # Also add 10 minutes to the name
     $time = new_time("10m");
     $filestore[0] = substr($time, 4, 8);
     # Get the new file name
     $newfile = join(".",@filestore);
     $ret_var = &send_file("this-is-yr-wakeup-call");
     if ($ret_var == 0 ) {
         $ret_var = &send_file("to-confirm-wakeup");
     }
     if ($ret_var == 0 ) {
         $ret_var = &send_file("press-1");
     }
     if ($ret_var == 0 ) {
         $ret_var = &send_file("to-snooze-for");
     }
     if ($ret_var == 0 ) {
         $ret_var = &send_file("digits/10");
     }
     if ($ret_var == 0 ) {
         $ret_var = &send_file("minutes");
     }
     if ($ret_var != 0 ) {
         $ret_var = &ascii2num($ret_var);
     }
     if ($ret_var == 0 ) {
         $ret_var = &get_data("press-2",1);
     }
     if ($ret_var == 2 ) {
         # Populate some variables
         $time = &new_time("10m");
         $extension = $AGI{extension};
         $context = $AGI{context};
         # Open the file
         open (CALL, '>', "${WAKEDIR}/${newfile}") or die "Cannot open call file for write :$!";
         $myprint = "channel: Local" . "/" . $extension . "@" . $context . "\n";
             print CALL $myprint;
             print CALL "maxretries: 3\n";
                 print CALL "retrytime: 60\n";
         print CALL "waittime: 60\n";
                 print CALL "callerid: \"AsterPBX Weckruf\" <$AGI{callerid}>\n";
             print CALL "application: AGI\n";
             print CALL "data: wakeup|$newfile\n";
             close ($CALL);
         # Touch the file with the new time
         my @command = ("$TOUCH", "-t", "$time", "${WAKEDIR}/${newfile}");
         system(@command) == 0
             or die "system @command failed: $?";
         # Now move it
         my @command = ("mv", "${WAKEDIR}/${newfile}", "${OUTDIR}/${newfile}");
         system(@command) == 0
             or die "system @command failed: $?";
         $ret_dummy = &send_file("goodbye");
     } elsif ($ret_var == 1) {
         $ret_dummy = &send_file("goodbye");
     } else {
         $ret_dummy = &send_file("goodbye");
     }
     # Stream out the wakeup
     return 0;
 }
 ######## main program ########
 # Here goes the main program #
 ##############################
 my $numargs = $#ARGV + 1;
 if ($DEBUG == 1) {
     open (DEBUGOUT, '>', $debugfile) or die "Cannot open $debugfile for write :$!";
 }
 # Start by reading in the stuff Asterisk is sending
 &init_agi(); # Comment out in case of debug outside Asterisk
 # If DEBUG is set, dump the AGI variable
 if ($DEBUG == 1) {
     foreach my $i (sort keys %AGI) {
         print DEBUGOUT " -- $i = $AGI{$i}\n";
     }
 }
 if ( $numargs == 0 ) {
     &welcome();
     &hangup();
     exit(0);
 } elsif ( $ARGV[0] eq "move" ) {
     &move();
     &hangup();
     exit(0);
 } else {
     &snooze($ARGV[0]);
     &hangup();
     exit(0);
 }
 if ($DEBUG ==1) {
     close $DEBUGOUT;
 }

OpenPKG Specs / annotate

asterisk/wakeup.agi@a2c6460cfb16 (annotated)

asterisk/wakeup.agi