blob: ed7ea979a5c55ba489bb8e2df7ee57dc50c203e5 (
plain)
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
|
use strict;
use warnings FATAL => 'all';
use Apache::Test;
use Apache::TestRequest;
use Apache::TestUtil;
use Apache::TestConfig ();
my $total_tests = 1;
plan tests => $total_tests, need 'AnyEvent::WebSocket::Client',
need_module('proxy_http', 'lua'), need_min_apache_version('2.4.47');
require AnyEvent;
require AnyEvent::WebSocket::Client;
my $config = Apache::Test::config();
my $hostport = Apache::TestRequest::hostport();
my $client = AnyEvent::WebSocket::Client->new(timeout => 5);
my $quit_program = AnyEvent->condvar;
my $pingok = 0;
$client->connect("ws://$hostport/proxy/wsoc")->cb(sub {
our $connection = eval { shift->recv };
t_debug("wsoc connected");
if($@) {
# handle error...
warn $@;
$quit_program->send();
return;
}
$connection->send('ping');
# recieve message from the websocket...
$connection->on(each_message => sub {
# $connection is the same connection object
# $message isa AnyEvent::WebSocket::Message
my($connection, $message) = @_;
t_debug("wsoc msg received: " . $message->body);
if ("ping" eq $message->body) {
$pingok = 1;
}
$connection->send('quit');
$quit_program->send();
});
});
$quit_program->recv;
ok t_cmp($pingok, 1);
|
