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
|
#!/usr/bin/perl
use strict;
use warnings;
use Test::More;
use Test::Async::HTTP 0.02; # ->GET
use lib ".";
use t::Util;
use IO::Async::Loop;
use Net::Async::Matrix;
use Future;
my $ua = Test::Async::HTTP->new;
my @rooms;
my $matrix = Net::Async::Matrix->new(
ua => $ua,
server => "localserver.test",
first_sync_limit => 20,
on_room_new => sub {
push @rooms, $_[1];
},
make_delay => sub { Future->new },
);
IO::Async::Loop->new->add( $matrix ); # for ->loop->new_future
my $login_f = $matrix->login(
user_id => '@my-test-user:localserver.test',
access_token => "0123456789ABCDEF",
);
ok( my $p = $ua->next_pending, '->start sends an HTTP request' );
my $uri = $p->request->uri;
is( $uri->authority, "localserver.test", '$req->uri->authority' );
is( $uri->path, "/_matrix/client/r0/sync", '$req->uri->path' );
is_deeply(
{ $uri->query_form },
{ access_token => "0123456789ABCDEF",
filter => '{"room":{"timeline":{"limit":20}}}' },
'$req->uri->query_form' );
respond_json( $p, {
next_batch => "next_token_here",
rooms => {
join => {
"!id-for-a-room:localserver.test" => {
timeline => {
limited => '',
prev_batch => '',
events => [],
},
state => {
events => [],
},
account_data => {
events => [],
},
ephemeral => {
events => [],
},
},
},
},
presence => {
events => [],
},
});
ok( $login_f->is_ready, '->login ready after initial sync' );
$login_f->get;
ok( $matrix->start->is_ready, '->start is already ready' );
is( scalar @rooms, 1, '@rooms has a room object' );
is( $rooms[0]->room_id, "!id-for-a-room:localserver.test", '$rooms[0]->room_id' );
# Should make a start on GET /events
ok( $p = $ua->next_pending, 'another request after initialSync' );
is( $p->request->method, "GET", 'request method is GET' );
is( $p->request->uri->path, "/_matrix/client/r0/sync", 'request path is /sync' );
# Just leave it dangling at EOF
done_testing;
|
