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
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
|
package Protocol::WebSocket::Handshake::Client;
use strict;
use warnings;
use base 'Protocol::WebSocket::Handshake';
require Carp;
use Protocol::WebSocket::URL;
use Protocol::WebSocket::Frame;
sub new {
my $self = shift->SUPER::new(@_);
$self->_set_url($self->{url}) if defined $self->{url};
if (my $version = $self->{version}) {
$self->req->version($version);
$self->res->version($version);
}
return $self;
}
sub url {
my $self = shift;
my $url = shift;
return $self->{url} unless $url;
$self->_set_url($url);
return $self;
}
sub parse {
my $self = shift;
my $req = $self->req;
my $res = $self->res;
unless ($res->is_done) {
unless ($res->parse($_[0])) {
$self->error($res->error);
return;
}
if ($res->is_done) {
if ( $req->version eq 'draft-ietf-hybi-00'
&& $req->checksum ne $res->checksum)
{
$self->error('Checksum is wrong.');
return;
}
}
}
return 1;
}
sub is_done { shift->res->is_done }
sub to_string { shift->req->to_string }
sub build_frame {
my $self = shift;
return Protocol::WebSocket::Frame->new(masked => 1, version => $self->version, @_);
}
sub _build_url { Protocol::WebSocket::URL->new }
sub _set_url {
my $self = shift;
my $url = shift;
$url = $self->_build_url->parse($url) unless ref $url;
$self->req->secure(1) if $url->secure;
my $req = $self->req;
my $host = $url->host;
$host .= ':' . $url->port
if defined $url->port
&& ($url->secure ? $url->port ne '443' : $url->port ne '80');
$req->host($host);
$req->resource_name($url->resource_name);
return $self;
}
1;
__END__
=head1 NAME
Protocol::WebSocket::Handshake::Client - WebSocket Client Handshake
=head1 SYNOPSIS
my $h =
Protocol::WebSocket::Handshake::Client->new(url => 'ws://example.com');
# Create request
$h->to_string;
# Parse server response
$h->parse(<<"EOF");
WebSocket HTTP message
EOF
$h->error; # Check if there were any errors
$h->is_done; # Returns 1
=head1 DESCRIPTION
Construct or parse a client WebSocket handshake. This module is written for
convenience, since using request and response directly requires the same code
again and again.
=head1 ATTRIBUTES
=head2 C<url>
$handshake->url('ws://example.com/demo');
Set or get WebSocket url.
=head1 METHODS
=head2 C<new>
Create a new L<Protocol::WebSocket::Handshake::Client> instance.
=head2 C<parse>
$handshake->parse($buffer);
Parse a WebSocket server response. Returns C<undef> and sets C<error> attribute
on error. Buffer is modified.
=head2 C<to_string>
Construct a WebSocket client request.
=head2 C<is_done>
Check whether handshake is done.
=cut
|
