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/".$Arvados::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     $self->{'req'}->header('Accept' => 'application/json');
  39     my %content;
  40     my ($p, $v);
  41     while (($p, $v) = each %{$self->{'queryParams'}}) {
  42         $content{$p} = (ref($v) eq "") ? $v : JSON::encode_json($v);
  43     }
  44     my $content;
  45     while (($p, $v) = each %content) {
  46         $content .= '&' unless $content eq '';
  47         $content .= uri_escape($p);
  48         $content .= '=';
  49         $content .= uri_escape($v);
  50     }
  51     $self->{'req'}->content_type("application/x-www-form-urlencoded; charset='utf8'");
  52     $self->{'req'}->content(Encode::encode('utf8', $content));
  53     $self->{'res'} = $self->{'ua'}->request ($self->{'req'});
  54 }
  55
  56 sub get_status
  57 {
  58     my $self = shift;
  59     return ($self->{'res'}->code(),
  60             $self->{'res'}->message());
  61 }
  62
  63 sub get_body
  64 {
  65     my $self = shift;
  66     return $self->{'res'}->content;
  67 }
  68
  69 sub set_method
  70 {
  71     my $self = shift;
  72     $self->{'method'} = shift;
  73 }
  74
  75 sub set_query_params
  76 {
  77     my $self = shift;
  78     $self->{'queryParams'} = shift;
  79 }
  80
  81 sub set_auth_token
  82 {
  83     my $self = shift;
  84     $self->{'authToken'} = shift;
  85 }
  86
  87 sub get_headers
  88 {
  89     ""
  90 }
  91
  92 1;