sdk/perl/lib/Arvados/Request.pm

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