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
|
package AnyEvent::Connector::Proxy::http;
use strict;
use warnings;
use AnyEvent::Handle;
sub new {
my ($class, $uri) = @_;
my $self = bless {
uri => $uri
}, $class;
return $self;
}
sub uri_string {
my ($self) = @_;
return $self->{uri}->as_string;
}
sub host {
my ($self) = @_;
return $self->{uri}->host;
}
sub port {
my ($self) = @_;
return $self->{uri}->port;
}
sub establish_proxy {
my ($self, $fh, $target_host, $target_port, $cb) = @_;
my $ah;
my $header_reader;
$ah = AnyEvent::Handle->new(
fh => $fh,
on_error => sub {
## TODO: how should we report the error detail?
undef $ah;
undef $header_reader;
$cb->(0);
},
on_eof => sub {
undef $ah;
undef $header_reader;
$cb->(0);
},
);
$ah->push_write(
"CONNECT $target_host:$target_port HTTP/1.1\r\n" .
"Host: $target_host:$target_port\r\n\r\n"
);
$header_reader = sub {
my ($h, $line) = @_;
if($line eq "") {
$ah->destroy();
undef $ah;
undef $header_reader;
$cb->(1);
return;
}
$ah->push_read(line => $header_reader);
};
$ah->push_read(line => sub {
my ($h, $line) = @_;
if($line !~ qr{^HTTP/1\S* +(\d{3})}) {
$ah->destroy();
undef $ah;
undef $header_reader;
$cb->(0);
return;
}
my $status = $1;
if(int($status / 100) != 2) {
$ah->destroy();
undef $ah;
undef $header_reader;
$cb->(0);
return;
}
$ah->push_read(line => $header_reader);
});
}
1;
__END__
=pod
=head1 NAME
AnyEvent::Connector::Proxy::http - http Proxy connector
=head1 DESCRIPTION
This module is internal. End-users should not use it directly.
=cut
|
