I have two problems, first I need to open a websocket and register each socket into a struct so when an event from Asterisk AMI occurs, send some message to each one of the connected sockets from my @users array but when I open the socket and send the message the connection close.

Second problem is I cannot receive data after websocket is open, a javascript code sends a simple string and I don't know how to open it, instead I receive html headers if I print $data inside sub incoming. Something I must be doing wrong.

I have tried using other libraries, like Net::WebSocket::Server or Net::WebSocket::EV but doesn't suit me well, first one never return after start and second have no idea how to catch the ip, port, etc.

Here is the code, it is a test, not fancy or anything just testing if the solution is possible

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->{'Connect
+edLineName'},$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_STR
+EAM,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-C5AB0D
+C85B11");
          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_c
+ount, 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";
    }

[download]

In reply to Perl an array of sockets by suhijo

Title:
Use:  <p> text here (a paragraph) </p>
and:  <code> code here </code>
to format your post, it's "PerlMonks-approved HTML":


  • Posts are HTML formatted. Put <p> </p> tags around your paragraphs. Put <code> </code> tags around your code and data!
  • Titles consisting of a single word are discouraged, and in most cases are disallowed outright.
  • Read Where should I post X? if you're not absolutely sure you're posting in the right place.
  • Please read these before you post! —
  • Posts may use any of the Perl Monks Approved HTML tags:
    a, abbr, b, big, blockquote, br, caption, center, col, colgroup, dd, del, details, div, dl, dt, em, font, h1, h2, h3, h4, h5, h6, hr, i, ins, li, ol, p, pre, readmore, small, span, spoiler, strike, strong, sub, summary, sup, table, tbody, td, tfoot, th, thead, tr, tt, u, ul, wbr
  • You may need to use entities for some characters, as follows. (Exception: Within code tags, you can put the characters literally.)
            For:     Use:
    & &amp;
    < &lt;
    > &gt;
    [ &#91;
    ] &#93;
  • Link using PerlMonks shortcuts! What shortcuts can I use for linking?
  • See Writeup Formatting Tips and other pages linked from there for more info.