use IO::Socket;
use EV;
use Data::Dumper;
use Asterisk::AMI;
use Digest::SHA1  qw(sha1 sha1_hex sha1_base64);
use Encode qw(decode encode);
use threads;
use threads::shared;
use warnings;

$| = 1;
my $connection_count = 0;
my $h;
my $fh;
our @users : shared;
my $astman = Asterisk::AMI->new(PeerAddr => '127.0.0.1',
        PeerPort => '5038',
        Username => 'admin',
        Secret => 'emel1t0',
        Events => 'on',
        Handlers => { default => \&eventhandler }
        );
die "Unable to connect to asterisk" unless ($astman);

sub eventhandler {
     my ($ami, $event) = @_;
     if($event->{'Event'} eq "Dial"){
          if($event->{'SubEvent'} eq "Begin"){
               print "inicio,$event->{'CallerIDNum'},$event->{'ConnectedLineName'},$event->{'UniqueID'}\n";
               buscar_exten(10000);
               }
          if($event->{'SubEvent'} eq "End"){
               print "Fin,$event->{'UniqueID'},$event->{'DialStatus'}\n";
               }
          }
}

my $server = new IO::Socket::INET(LocalPort => 50080, Type => SOCK_STREAM,Listen => SOMAXCONN, Reuse => 1, Proto => 'tcp');
my $w = EV::io $server, EV::READ, \&incoming;

EV::loop;

sub incoming
{
      my $w=shift;
      $fh=$w->fh->accept or die;
      my $fileno = fileno $fh;
      push (@users, $fileno);
      my $cladd=$fh->peerhost();
      my $clport=$fh->peerport();
      my $claddr=$fh->peeraddr();
      print "cladd: $cladd clport :$clport claddr:\n";
      printf "$cladd: new socket connection #%d (%d)\n", ++$connection_count, +scalar keys %$h;
      $fh->recv($data, 1024);

      $data =~ /Sec-WebSocket-Key: (\S+)/;
          $str = $1;
          print "key is1 $str|\n";
          my $str = sha1_base64($str . "258EAFA5-E914-47DA-95CA-C5AB0DC85B11");
          send($fh, qq{HTTP/1.1 101 Switching Protocols\r\nConnection: Upgrade\r\nUpgrade: websocket\r\nSec-Websocket-Accept: $str=\r\n\r\n}, 0);

      $h->{$fh} = EV::io $fh, EV::READ, \&cliente;
}

sub cliente
{
     my $c=shift;
     my $fh2=$c->fh;
     my $bytes_read=sysread($fh2, my $bytes, 9_999_999);
     return if (not exists $h->{$fh});
     if (($bytes eq 'q') || ($bytes_read == 0)) {
          close($fh2);
          undef $c;
          delete $h->{$fh2};
          printf "socket connection terminated by %s (%d (%d) sockets +remaining)\n", $bytes_read == 0 ? 'peer' : 'server', --$connection_count, scalar keys %$h;
      }
}

sub buscar_exten{
     $exten=$_[0];
     print "buscando si <$exten> esta logueada-\n";
        foreach my $b (@users) {
             open my $c, ">&=$b" ;
             send($c,"mandando mensaje 1000\r\n",0);
             }
         print "}\n";
    }