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
|
use strict;
use warnings;
use if $^O eq 'MSWin32', 'Test::More' => skip_all => 'Forking may be problematic on Windows';
BEGIN { $ENV{MOJO_REACTOR} = 'Mojo::Reactor::Poll' }
use Test::More;
use Test::Needs { Mojolicious => '7.54' };
use Test::TCP;
use HTTP::Tiny;
use HTTP::Request;
use LWP::UserAgent;
use Mojolicious::Lite;
use Mojo::IOLoop;
use Mojo::Server::Daemon;
use Mojo::UserAgent;
use Module::Runtime 'use_module';
use WWW::OAuth::Util 'oauth_request';
my $server = Test::TCP->new(code => sub {
my $port = shift;
my $guard = Mojo::IOLoop->timer(5 => sub { Mojo::IOLoop->stop });
app->log->level('warn');
get '/' => sub {
my $c = shift;
$c->render(text => 'foo');
};
my $daemon = Mojo::Server::Daemon->new(listen => ["http://127.0.0.1:$port"], app => app);
$daemon->run;
exit;
});
my $port = $server->port;
my $req = oauth_request({method => 'GET', url => "http://127.0.0.1:$port"});
my $res = $req->request_with(HTTP::Tiny->new);
ok $res->{success}, 'request succeeded';
is $res->{content}, 'foo', 'got response';
my $http_req = oauth_request(HTTP::Request->new(GET => "http://127.0.0.1:$port"));
my $http_res = $http_req->request_with(LWP::UserAgent->new);
ok $http_res->is_success, 'request succeeded';
is $http_res->content, 'foo', 'got response';
my $ua = Mojo::UserAgent->new;
my $tx = $ua->build_tx(GET => "http://127.0.0.1:$port");
my $mojo_req = oauth_request($tx->req);
$tx = $mojo_req->request_with($ua);
ok !$tx->error, 'request succeeded';
is $tx->res->body, 'foo', 'got response';
$tx = $ua->build_tx(GET => "http://127.0.0.1:$port");
$mojo_req = oauth_request($tx->req);
my $got_response;
$mojo_req->request_with($ua, sub {
my ($ua, $tx) = @_;
ok !$tx->error, 'request succeeded';
is $tx->res->body, 'foo', 'got response';
$got_response = 1;
Mojo::IOLoop->stop;
});
my $timeout = Mojo::IOLoop->timer(1 => sub { Mojo::IOLoop->stop });
Mojo::IOLoop->start;
Mojo::IOLoop->remove($timeout);
ok $got_response, 'response was handled';
$tx = $ua->build_tx(GET => "http://127.0.0.1:$port");
$mojo_req = oauth_request($tx->req);
undef $got_response;
$mojo_req->request_with_p($ua)->then(sub {
my $tx = shift;
ok !$tx->error, 'request succeeded';
is $tx->res->body, 'foo', 'got response';
$got_response = 1;
Mojo::IOLoop->stop;
});
$timeout = Mojo::IOLoop->timer(1 => sub { Mojo::IOLoop->stop });
Mojo::IOLoop->start;
Mojo::IOLoop->remove($timeout);
ok $got_response, 'response was handled';
undef $server;
done_testing;
|
