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
|
use HTTP::Request::Common;
use URI::Encode;
use JSON::Tiny;
use Matrix::Client::Common;
use Matrix::Client::Room;
use Matrix::Client::Requester;
unit class Matrix::Client does Matrix::Client::Requester;
has Str $!user-id;
has Str $!device-id;
has Str $.state-file = 'state';
has @!rooms;
has @!users;
method user-id() {
$!user-id
}
method device-id() {
$!device-id
}
method login(Str $username, Str $pass) returns Bool {
if $.state-file.IO.e {
my $data = from-json(slurp $.state-file);
$!access-token = $data<access_token>;
$!user-id = $data<user_id>;
$!device-id = $data<device_id>;
$Matrix::Client::Common::TXN-ID = $data<txn_id> // 0;
return True
}
# Handle POST
my $data = to-json {
type => "m.login.password",
user => $username,
password => $pass
};
my $res = $.post("/login", $data);
if $res.is-success {
spurt $.state-file, $res.content;
my $data = from-json($res.content);
$!access-token = $data<access_token>;
$!user-id = $data<user_id>;
$!device-id = $data<device_id>;
True
} else {
False
}
}
method finish() {
my %data =
access_token => $!access-token,
user_id => $!user-id,
device_id => $!device-id,
txn_id => $Matrix::Client::Common::TXN-ID;
spurt $.state-file, to-json(%data);
}
method logout() {
unlink $.state-file;
$.post("/logout")
}
method register($username, $password, Bool :$bind-email? = False) {
my $res = $.post("/register",
username => $username, password => $password,
bind_email => $bind-email,
auth => {
type => "m.login.dummy"
});
if $res.is-success {
my $data = from-json $res.content;
$!access-token = $data<access_token>;
$.user-id = $data<user_id>;
} else {
die "Error with the homeserver: " ~ $res.content;
}
}
method check-res($res) {
if $res.is-success {
True
} else {
warn $res.status-line;
warn $res.content;
False
}
}
multi method sync() {
my $res = $.get("/sync",
timeout => 30000
);
$.check-res($res);
$res
}
multi method sync(Str :$sync-filter, Str :$since = "") {
my $res = $.get("/sync",
timeout => 30000,
filter => $sync-filter,
since => $since
);
$.check-res($res);
$res
}
multi method sync(:$sync-filter is copy, :$since = "") {
$.sync(sync-filter => to-json($sync-filter), since => $since)
}
method join-room($room-id!) {
$.post("/join/" ~ $room-id)
}
method rooms() {
my $res = $.get("/sync", timeout => "30000");
return () unless $res.is-success;
my $data = from-json($res.content);
for $data<rooms><join>.kv -> $id, $json {
@!rooms.push(Matrix::Client::Room.new(id => $id, json => $json, home-server => $!home-server));
}
@!rooms
}
method send(Str $room-id, Str $body, :$type? = "m.text") {
$Matrix::Client::Common::TXN-ID++;
$.put("/rooms/$room-id/send/m.room.message/{$Matrix::Client::Common::TXN-ID}", msgtype => $type, body => $body)
}
|
