1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
|
#!/usr/bin/perl
use v5.14;
use warnings;
use Test2::V0;
use IO::Async::Test;
use IO::Async::Loop;
use Net::Async::WebSocket::Server;
use Protocol::WebSocket::Frame;
use Protocol::WebSocket::Handshake::Client;
use IO::Socket::INET;
my $loop = IO::Async::Loop->new;
testing_loop( $loop );
my $serversock = IO::Socket::INET->new(
LocalHost => "127.0.0.1",
Listen => 1,
) or die "Cannot allocate listening socket - $@";
my $client;
my @frames;
my $server = Net::Async::WebSocket::Server->new(
handle => $serversock,
on_handshake => sub {
my ( $self, $stream, $hs, $continue ) = @_;
$continue->( $hs->req->origin eq "http://localhost" );
},
on_client => sub {
my ( undef, $thisclient ) = @_;
$client = $thisclient;
$thisclient->configure(
on_frame => sub {
my ( $self, $frame ) = @_;
push @frames, $frame;
},
);
},
);
ok( defined $server, '$server defined' );
isa_ok( $server, [ "Net::Async::WebSocket::Server" ], '$server' );
$loop->add( $server );
my $clientsock = IO::Socket::INET->new(
PeerHost => $serversock->sockhost,
PeerPort => $serversock->sockport,
) or die "Cannot connect to testing server - $@";
my $h = Protocol::WebSocket::Handshake::Client->new(
url => "ws://localhost/test",
);
$clientsock->write( $h->to_string );
my $stream = "";
wait_for_stream { $h->parse( $stream ); $stream = ""; $h->is_done } $clientsock => $stream;
ok( defined $client, '$client is defined' );
$clientsock->write( Protocol::WebSocket::Frame->new( "Here is my message" )->to_bytes );
wait_for { @frames };
is( \@frames, [ "Here is my message" ], 'received @frames' );
undef @frames;
$client->send_frame( "Here is my response" );
my $fb = Protocol::WebSocket::Frame->new;
$stream = "";
my $frame;
wait_for_stream { $fb->append( $stream ); $stream = ""; $frame = $fb->next } $clientsock => $stream;
is( $frame, "Here is my response", 'responded $frame' );
done_testing;
|
