use JSON::Fast; use Matrix::Client::Common; use Matrix::Client::Requester; use Matrix::Response; unit class Matrix::Client::Room does Matrix::Client::Requester; has $!name; has $.id; submethod TWEAK { $!url-prefix = "/rooms/$!id"; } method !get-name() { CATCH { when X::Matrix::Response { .code ~~ /M_NOT_FOUND/ ?? ($!name = '') !! fail } default { fail } } my $data = $.state('m.room.name'); $!name = $data; } method name(--> Str) { self!get-name; $!name } method fallback-name(--> Str) { my @members = $.joined-members.kv.map( -> $k, %v { %v // $k } ); $!name = do given @members.elems { when 1 { @members.first } when 2 { @members[0] ~ " and " ~ @members[1] } when * > 2 { @members.first ~ " and {@members.elems - 1} others" } default { "Empty room" } }; } #| GET - /_matrix/client/r0/rooms/{roomId}/aliases method aliases(--> List) { my %data = from-json($.get('/aliases').content); %data.List } # Events ## Getting events for a room #| GET - /_matrix/client/r0/rooms/{roomId}/event/{eventId} method event(Str $event-id --> Matrix::Response::RoomEvent) { my %data = from-json($.get("/event/$event-id").content); Matrix::Response::RoomEvent.new(|%data) } #| GET - /_matrix/client/r0/rooms/{roomId}/state multi method state(--> Seq) { my $data = from-json($.get('/state').content); gather for $data.List -> $event { take Matrix::Response::StateEvent.new(:room-id($.id), |$event) } } #| GET - /_matrix/client/r0/rooms/{roomId}/state/{eventType}/{stateKey} multi method state(Str $event-type, Str $state-key = "") { from-json($.get("/state/$event-type/$state-key").content) } #| GET - /_matrix/client/r0/rooms/{roomId}/joined_members method joined-members { my %data = from-json($.get("/joined_members").content); %data } #| GET - /_matrix/client/r0/rooms/{roomId}/messages method messages( Str:D :$from!, Str :$to, Str :$dir where * eq 'f'|'b' = 'f', Int :$limit = 10, :%filter, --> Matrix::Response::Messages ) { my $res = $.get( "/messages", :$from, :$to, :$dir, :$limit, :%filter ); my $data = from-json($res.content); my @messages = $data.map(-> $ev { Matrix::Response::RoomEvent.new(|$ev) }); Matrix::Response::Messages.new( start => $data, end => $data, messages => @messages ) } #| GET - /_matrix/client/r0/rooms/{roomId}/members method members(:$at, Str :$membership, Str :$not-membership --> Seq) { my %query; %query = $at with $at; %query = $membership with $membership; %query = $not-membership with $not-membership; my %data = from-json($.get('/members', |%query).content); gather for %data.List -> $ev { take Matrix::Response::MemberEvent.new(|$ev) } } ## Sending events to a room #| PUT - /_matrix/client/r0/rooms/{roomId}/send/{eventType}/{txnId} method send(Str $body!, Str :$type? = "m.text") { $Matrix::Client::Common::TXN-ID++; my $res = $.put( "/send/m.room.message/{$Matrix::Client::Common::TXN-ID}", msgtype => $type, body => $body ); from-json($res.content) } #| PUT - /_matrix/client/r0/rooms/{roomId}/state/{eventType}/{stateKey} method send-state(Str:D $event-type, :$state-key = "", *%args --> Str) { my $res = $.put( "/state/$event-type/$state-key", |%args ); from-json($res.content) } # Room membership! ## Joining rooms #| POST - /_matrix/client/r0/rooms/{roomId}/invite method invite(Str $user-id) { $.post('/invite', :$user-id) } #| POST - /_matrix/client/r0/rooms/{roomId}/join method join { $.post('/join') } ## Leaving rooms #| POST - /_matrix/client/r0/rooms/{roomId}/leave method leave { $.post('/leave') } #| POST - /_matrix/client/r0/rooms/{roomId}/forget method forget { $.post('/forget') } #| POST - /_matrix/client/r0/rooms/{roomId}/kick method kick(Str $user-id, Str $reason = "") { $.post('/kick', :$user-id, :$reason) } ## Banning users #| POST - /_matrix/client/r0/rooms/{roomId}/ban method ban(Str $user-id, $reason = "") { $.post('/ban', :$user-id, :$reason) } #| POST - /_matrix/client/r0/rooms/{roomId}/unban method unban(Str $user-id) { $.post('/unban', :$user-id) } method Str(--> Str) { "Room" }