sdk/perl/lib/Arvados/Request.pm

   1 # Copyright (C) The Arvados Authors. All rights reserved.
   2 #
   3 # SPDX-License-Identifier: Apache-2.0
   4
   5 package Arvados::Request;
   6 use Data::Dumper;
   7 use LWP::UserAgent;
   8 use URI::Escape;
   9 use Encode;
  10 use strict;
  11 @Arvados::HTTP::ISA = qw(LWP::UserAgent);
  12
  13 sub new
  14 {
  15     my $class = shift;
  16     my $self = {};
  17     bless ($self, $class);
  18     return $self->_init(@_);
  19 }
  20
  21 sub _init
  22 {
  23     my $self = shift;
  24     $self->{'ua'} = new LWP::UserAgent(@_);
  25     $self->{'ua'}->agent ("libarvados-perl/".$Arvados::VERSION);
  26     $self;
  27 }
  28
  29 sub set_uri
  30 {
  31     my $self = shift;
  32     $self->{'uri'} = shift;
  33 }
  34
  35 sub process_request
  36 {
  37     my $self = shift;
  38     my %req;
  39     my %content;
  40     my $method = $self->{'method'};
  41     if ($method eq 'GET' || $method eq 'HEAD') {
  42         $content{'_method'} = $method;
  43         $method = 'POST';
  44     }
  45     $req{$method} = $self->{'uri'};
  46     $self->{'req'} = new HTTP::Request (%req);
  47     $self->{'req'}->header('Authorization' => ('OAuth2 ' . $self->{'authToken'})) if $self->{'authToken'};
  48     $self->{'req'}->header('Accept' => 'application/json');
  49     my ($p, $v);
  50     while (($p, $v) = each %{$self->{'queryParams'}}) {
  51         $content{$p} = (ref($v) eq "") ? $v : JSON::encode_json($v);
  52     }
  53     my $content;
  54     while (($p, $v) = each %content) {
  55         $content .= '&' unless $content eq '';
  56         $content .= uri_escape($p);
  57         $content .= '=';
  58         $content .= uri_escape($v);
  59     }
  60     $self->{'req'}->content_type("application/x-www-form-urlencoded; charset='utf8'");
  61     $self->{'req'}->content(Encode::encode('utf8', $content));
  62     $self->{'res'} = $self->{'ua'}->request ($self->{'req'});
  63 }
  64
  65 sub get_status
  66 {
  67     my $self = shift;
  68     return ($self->{'res'}->code(),
  69             $self->{'res'}->message());
  70 }
  71
  72 sub get_body
  73 {
  74     my $self = shift;
  75     return $self->{'res'}->content;
  76 }
  77
  78 sub set_method
  79 {
  80     my $self = shift;
  81     $self->{'method'} = shift;
  82 }
  83
  84 sub set_query_params
  85 {
  86     my $self = shift;
  87     $self->{'queryParams'} = shift;
  88 }
  89
  90 sub set_auth_token
  91 {
  92     my $self = shift;
  93     $self->{'authToken'} = shift;
  94 }
  95
  96 sub get_headers
  97 {
  98     ""
  99 }
 100
 101 1;