From 7be9fa68bef82a7576344a6e8cc1e51154c6b3bf Mon Sep 17 00:00:00 2001 From: Matias Linares Date: Mon, 11 Jan 2021 22:20:09 -0300 Subject: Response & Exception refactor --- lib/Matrix/Client/Requester.pm6 | 115 ---------------------------------------- 1 file changed, 115 deletions(-) delete mode 100644 lib/Matrix/Client/Requester.pm6 (limited to 'lib/Matrix/Client/Requester.pm6') diff --git a/lib/Matrix/Client/Requester.pm6 b/lib/Matrix/Client/Requester.pm6 deleted file mode 100644 index 36a9f69..0000000 --- a/lib/Matrix/Client/Requester.pm6 +++ /dev/null @@ -1,115 +0,0 @@ -use HTTP::UserAgent; -use HTTP::Request::Common; -use URI::Encode; -use JSON::Fast; -use Matrix::Client::Exception; - -unit role Matrix::Client::Requester; - -has $.home-server is required; -has $.access-token = ""; - -has $!ua = HTTP::UserAgent.new; -has $!client-endpoint = "/_matrix/client/r0"; -has $!url-prefix = ""; -has $!sync-since = ""; - -method !handle-error($response) is hidden-from-backtrace { - unless $response.is-success { - my $data = from-json($response.content); - X::Matrix::Response.new(:code($data), :error($data)).throw; - } - $response -} - -method !access-token-arg { - $!access-token ?? "access_token=$!access-token" !! '' -} - -method get(Str $path, :$media = False, *%data) { - my $query = "?"; - for %data.kv -> $k,$v { - $query ~= "&$k=$v" if $v.so; - } - my $encoded-path = $path.subst('#', '%23'); - my $uri = $.base-url(:$media) ~ $encoded-path ~ uri_encode($query); - - my $req = HTTP::Request.new(GET => $uri); - - if $!access-token.so { - $req.header.field(Authorization => "Bearer {$!access-token}"); - } - - return self!handle-error( - $!ua.request($req) - ); -} - -method base-url(Bool :$media? = False --> Str) { - if !$media { - "$.home-server$!client-endpoint$!url-prefix" - } else { - "$.home-server/_matrix/media/r0" - } -} - -multi method post(Str $path, Str $json, :$media = False) { - my $encoded-path = $path.subst('#', '%23'); - my $url = $.base-url(:$media) ~ $encoded-path; - my $req = HTTP::Request.new(POST => $url, - Content-Type => 'application/json'); - if $!access-token.so { - $req.header.field(Authorization => "Bearer {$!access-token}"); - } - $req.add-content($json); - return self!handle-error($!ua.request($req)); -} - -multi method post(Str $path, :$media = False, *%params) { - my $json = to-json(%params); - $.post($path, $json, :$media) -} - -method post-bin(Str $path, Buf $buf, :$content-type) { - my $encoded-path = $path.subst('#', '%23'); - my $req = POST( - $.base-url() ~ $encoded-path, - content => $buf, - Content-Type => $content-type - ); - - if $!access-token.so { - $req.header.field(Authorization => "Bearer {$!access-token}"); - } - - return self!handle-error($!ua.request($req)); -} - -multi method put(Str $path, Str $json) { - my $encoded-path = $path.subst('#', '%23'); - my $req = HTTP::Request.new(PUT => $.base-url() ~ $encoded-path, - Content-Type => 'application/json'); - if $!access-token.so { - $req.header.field(Authorization => "Bearer {$!access-token}"); - } - - $req.add-content($json); - return self!handle-error($!ua.request($req)) -} - -multi method put(Str $path, *%params) { - self.put($path, to-json(%params)) -} - -method delete(Str $path) { - my $encoded-path = $path.subst('#', '%23'); - my $req = HTTP::Request.new( - DELETE => $.base-url ~ $encoded-path, - Content-Type => 'application/json'); - if $!access-token.so { - $req.header.field( - Authorization => "Bearer $!access-token" - ); - } - return self!handle-error($!ua.request($req)) -} -- cgit v1.2.3-70-g09d2