#!/usr/bin/perl -w
use strict;
use Data::Dumper;
use AnyEvent::Impl::Perl;
use AnyEvent;
use Asterisk::AMI;
use DBI;
use Socket;

my $dbhost = inet_ntoa(10.13.105.15);
my $user = "matt";
my $pass = "";
my $db = "autodial";
my $datasource = "dbi:mysql:autodial\@localhost";

my $dbh = DBI->connect (
        "dbi:mysql:database=$db:host=$dbhost",
        "$user", "$pass"
        )
        or die $DBI::errstr;

#Create your connection
my $astman = Asterisk::AMI->new(PeerAddr => '127.0.0.1',
                                PeerPort => '5038',
                                Username => 'autodial',
                                Secret => 'phone',
                                Events => 'on',
                                Handlers => { default => \&eventhandler, Hangup => \&hanguphandler }
                        );
#Alternatively you can set Blocking => 0, and set an on_error sub to catch connection errors
die "Unable to connect to asterisk" unless ($astman);

my $max = 1;
my $cv = AE::cv;
my $current = 0;
my %action =           (Action => 'Originate',
                        Channel => 'GTALK/asterisk/+13124049672@voice.google.com',
                        Context => 'local',
                        Exten => 'test',
                        Priority => 1,
                        Async => 1,
            Account => 123456678
);
#Define the subroutines for events
sub eventhandler {
    my ($ami, $event) = @_;
    print 'Got Event: ',$event->{'Event'},"\r\n";
}

sub hanguphandler {
    my ($ami, $event) = @_;
    print "Hanging up channel: $event->{'Channel'} - $event->{'Cause-txt'}\n";
    $current--;
}


#Define a subroutine for your action callback
sub actioncb {
    my ($ami, $response) = @_;
    print Dumper($response);
    #print 'Got Action Reponse: ',$response->{'Response'},"\r\n";
    #print 'Action: ',$response->{'PARSED'}->{'Ping'},"\r\n";
    #print 'Time: ',$response->{'PARSED'}->{'Timestamp'},"\r\n";
    #print "Current: $$count\n";
#   if ($response->{'Response'} eq 'Success') {
#       $current--;
#       $cv->send;
#   }
}


#Send an action
sub sendaction {
    while ( $current < $max ) {
        my $originate = buildAction();
        # send action to asterisk with the action callback &actioncb, timeout of 3 secs and passing a reference to $current.
        my $action = $astman->send_action($$originate, \&actioncb, 3);
        $current++;
        print Dumper($action);
        #print "Current count is $current\n";
    }
}

sub getNumber {
    my $number = dbh->selectrow_hashref("SELECT number FROM dial_numbers WHERE completed is null LIMIT 1");
    return $number;
}

sub buildAction {
    my $num = getNumber();
    my %action = (Action => 'Originate',
                        Channel => "GTALK/asterisk/+1$num"."voice.google.com",
                        Context => 'local',
                        Exten => 'test',
                        Priority => 1,
                        Async => 1,
                        Account => 123456678
)};

# create a timer that fires right away then every one second and calls &sendaction.
my $timer = AE::timer 0, 1, \&sendaction;

#$cv->recv;
AnyEvent::Impl::Perl::loop;