aboutsummaryrefslogtreecommitdiff
path: root/lib/Matrix/Response.pm6
diff options
context:
space:
mode:
authorMatias Linares <matiaslina@openmailbox.org>2018-02-13 20:53:53 -0300
committerMatias Linares <matiaslina@openmailbox.org>2018-02-13 20:53:53 -0300
commit94857bdff039a00b10ac6356e58edfcb3c1d26df (patch)
treed1216bc2efed4c60e399317edb7c1f50e0a9443a /lib/Matrix/Response.pm6
parent3dc7d5cba044e16776291f520fd68ac190bcbfb6 (diff)
downloadperl6-matrix-client-94857bdff039a00b10ac6356e58edfcb3c1d26df.tar.gz
Add simple responses
Diffstat (limited to 'lib/Matrix/Response.pm6')
-rw-r--r--lib/Matrix/Response.pm686
1 files changed, 86 insertions, 0 deletions
diff --git a/lib/Matrix/Response.pm6 b/lib/Matrix/Response.pm6
new file mode 100644
index 0000000..6a25bf9
--- /dev/null
+++ b/lib/Matrix/Response.pm6
@@ -0,0 +1,86 @@
+use JSON::Tiny;
+
+unit module Matrix::Response;
+
+class Matrix::Response::Event {
+ has %.content;
+ has $.type is required;
+
+ method gist(--> Str) {
+ "Event<$.type>"
+ }
+}
+
+class Matrix::Response::RoomEvent is Matrix::Response::Event {
+ has Str $.sender;
+ has Int $.origin_server_ts;
+ has $.event_id;
+ has Str $.room_id;
+
+ method id { $.event_id }
+ method timestamp { $!origin_server_ts }
+ method room-id { $.room-id }
+}
+
+class Matrix::Response::StateEvent is Matrix::Response::RoomEvent {
+ has $.prev_content;
+ has $.state_key;
+}
+
+class Matrix::Response::Timeline {
+ has Matrix::Response::Event @.events;
+ has Bool $limited;
+ has Str $prev-batch;
+}
+
+class Matrix::Response::RoomInfo {
+ has $.room-id is required;
+ has Matrix::Response::Event @.state;
+ has Matrix::Response::Timeline $.timeline;
+
+ method gist(--> Str) {
+ "<Matrix::Response::RoomInfo: $.room-id>"
+ }
+}
+
+sub gather-events($from) {
+ gather for $from<events>.List -> $ev {
+ take Matrix::Response::StateEvent.new(|$ev);
+ }
+}
+
+class Matrix::Response::Sync {
+ has Str $.next-batch;
+ has Matrix::Response::Event @.presence;
+ has Matrix::Response::RoomInfo @.joined-rooms;
+
+ multi method new(Str $json) {
+ return self.new(from-json($json));
+ }
+
+ multi method new(Hash $json) {
+ my $next-batch = $json<next_batch>;
+ my Matrix::Response::Event @presence;
+ my Matrix::Response::RoomInfo @joined-rooms;
+
+ for $json<presence><events>.List -> $ev {
+ @presence.push(Matrix::Response::Event.new(|$ev));
+ }
+
+ for $json<rooms><join>.kv -> $room-id, $data {
+ my @state = gather-events($data<state>);
+
+ my $timeline = Matrix::Response::Timeline.new(
+ limited => $data<timeline><limited>,
+ prev-batch => $data<timeline><prev_batch>,
+ events => gather-events($data<timeline>)
+ );
+
+ @joined-rooms.push(Matrix::Response::RoomInfo.new(
+ :$room-id, :$timeline, :@state
+ ));
+ }
+
+ return self.bless(:$next-batch, :@presence, :@joined-rooms);
+ }
+}