[Freeswitch-svn] [commit] r5529 - freeswitch/trunk/scripts/contrib/trixter
Freeswitch SVN
trixter at freeswitch.org
Thu Jul 12 00:46:50 EDT 2007
Author: trixter
Date: Thu Jul 12 00:46:50 2007
New Revision: 5529
Added:
freeswitch/trunk/scripts/contrib/trixter/callcredit.pl (contents, props changed)
Log:
script that will query a webserver at set intervals about calls in progress so you can deduct credit in realtime for each call, typical example prepaid calling application
Added: freeswitch/trunk/scripts/contrib/trixter/callcredit.pl
==============================================================================
--- (empty file)
+++ freeswitch/trunk/scripts/contrib/trixter/callcredit.pl Thu Jul 12 00:46:50 2007
@@ -0,0 +1,190 @@
+#!/usr/bin/perl
+# -*- mode:cperl; tab-width:4; c-basic-offset:4; c-indent-level:4; indent-tabs-mode:nil; -*-
+
+#
+# this script will look for call setup/tear down events and every INTERVAL query the server for credit
+# on the calls in progress, if it gets a message saying to hangup a call it will - implying credit no
+# longer exists
+#
+# this script also informs the webserver of the call setup/tear down info so that it can keep track and
+# later only post a list of UUIDs for the webserver to process.
+#
+# the webserver should return the following
+# HANGUP: 1234-5678-90ab-cdef
+# IGNORE: fedc-ba09-8765-4321
+#
+# to hangup the first or stop getting reports about the 2nd uuid
+#
+# uuids are passed to the webserver in a php style array named uuid so its easy to loop through them and
+# check them for validity
+
+use FreeSWITCH::Client;
+use POSIX ':signal_h'; # used for alarm to ensure we get heartbeats
+use Data::Dumper; # used to print out myhash debug info
+
+# use DBI instead of these two for direct database inserts/deletes
+# which is likely to be more efficient, this is however just an example
+use LWP::UserAgent; # for posting to the webserver
+use URI::Escape ('uri_escape'); # to html encode values
+
+
+# configure these
+my $password = "ClueCon"; # the password for event socket
+my $host = "localhost"; # the hostname to connect to
+my $port = 8021; # the port to connect to
+my $timeout = 1; # when setting this make sure its low enough to detect
+ # lost heartbeats and high enough that it doesnt hose your
+ # system, also queryInterval is checked each time this runs
+ # so you should make queryInterval an interger multiple
+my $queryInterval = 3;
+my $heartbeatInterval = 30; # seconds to expect a heartbeat event or reconnect
+my $url = "http://localhost/activecalls.php"; # the url to post the data to use http://user:pass@host/script for auth credentials
+
+
+##
+# dont touch these
+##
+my $fs;
+my $lastheartbeat;
+my $lastQuery;
+my %uuids;
+my $ua = LWP::UserAgent->new;
+$ua->agent("FreeSWITCH/1.0");
+
+
+# this connects to the event socket
+sub es_connect()
+ {
+ print "Connecting to $host:$port\n";
+ eval {
+ $fs = init FreeSWITCH::Client {-password => $password, -host => $host, -port => $port};
+ if(defined $fs) {
+ # channel_create doesnt have the destination number so we wait for the codec event
+ $fs->sendmsg({'command' => 'event plain heartbeat channel_hangup codec'});
+ $lastheartbeat = time;
+ }
+ } or do {
+ print "Error connecting - waiting for retry\n";
+ }
+
+ }
+
+
+sigaction SIGALRM, new POSIX::SigAction sub {
+ if ($lastheartbeat < (time - $heartbeatInterval)) {
+ print "Did not receive a heartbeat in the specified timeout\n";
+ if (defined $fs) {
+ $fs->disconnect();
+ undef $fs;
+ }
+ es_connect();
+ }
+
+
+ # check the calls
+ $uuidstr = "";
+ $queryTime = time;
+ for my $uuid ( keys %uuids ) {
+ if($uuids{$uuid} > 2 && $uuids{$uuid}<= ($queryTime - $queryInterval)) {
+ $uuidstr .= "&uuid[]=$uuid";
+ $uuids{$uuid}=$queryTime;
+ }
+ }
+
+ if($uuidstr ne "") {
+ my $req = HTTP::Request->new(POST => $url);
+ $req->content_type('application/x-www-form-urlencoded');
+ $req->content($uuidstr);
+ my $res = $ua->request($req);
+ if(!$res->is_success) {
+ print "Error checking credit got ".$res->status_line."\n";
+ }
+ @lines = split(/\n/,$res->content);
+
+ foreach $line (@lines) {
+ if($line =~ /^HANGUP: (.*)/) {
+ print "hanging up $1\n";
+ $fs->sendmsg({'command' => "api killchan $1"});
+ } elsif ($line =~ /^IGNORE: (.*)/) {
+ delete $uuids{$1};
+ }
+
+ print "LINE: $line\n\n";
+ }
+
+ # XXX we need to figure out how to hangup calls here
+ }
+
+
+
+ # reset the alarm
+ alarm $timeout;
+} or die "Error setting SIGALRM handler: $!\n";
+
+
+
+es_connect();
+alarm $timeout;
+
+while (1) {
+ if(defined $fs) {
+ my $reply = $fs->readhash(undef);
+ if ($reply->{socketerror}) {
+ es_connect();
+ }
+
+ if ($reply->{body}) {
+ $myhash = $reply->{event};
+
+ if ($myhash->{'event-name'} eq "HEARTBEAT") { ## Deal with heartbeats
+ $lastheartbeat = time;
+ print "Got a heartbeat\n";
+
+ } elsif ($myhash->{'event-name'} eq "CODEC") { ## New call setup
+ if(!$uuids{$myhash->{'unique-id'}}) {
+ print $myhash->{'unique-id'}." has called\n";
+ $uuids{$myhash->{'unique-id'}}=time;
+ $urlstr="";
+ while ( my ($key, $value) = each(%$myhash) ) {
+ $urlstr .= "&$key=".uri_escape($value);
+ }
+
+ my $req = HTTP::Request->new(POST => $url);
+ $req->content_type('application/x-www-form-urlencoded');
+ $req->content($urlstr);
+ my $res = $ua->request($req);
+ if(!$res->is_success) {
+ print "Error posting NEWCALL to webserver got ".$res->status_line."\n";
+ }
+ }
+
+
+
+ } elsif ($myhash->{'event-name'} eq "CHANNEL_HANGUP") { ## hangup event
+ print $myhash->{'unique-id'}." has hung up\n";
+ delete $uuids{$myhash->{'unique-id'}}; # we get a codec event after hangup
+
+ $urlstr="";
+ while ( my ($key, $value) = each(%$myhash) ) {
+ $urlstr .= "&$key=".uri_escape($value);
+ }
+
+ my $req = HTTP::Request->new(POST => $url);
+ $req->content_type('application/x-www-form-urlencoded');
+ $req->content($urlstr);
+ my $res = $ua->request($req);
+ if(!$res->is_success) {
+ print "Error posting HANGUP to webserver got ".$res->status_line."\n";
+ }
+
+
+ } else { ## Unknown event
+ print "EVENT NAME: " . $myhash->{'event-name'} . "\n";
+ print Dumper $myhash;
+ # print "$reply->{body}\n"; # print out what was sent, myhash is translated by Client.pm
+ }
+
+ }
+ }
+}
+
More information about the Freeswitch-svn
mailing list