File Coverage

blib/lib/Kubernetes/REST/ListToRequest.pm

Criterion	Covered	Total	%
statement	58	68	85.2
branch	17	26	65.3
condition			n/a
subroutine	8	8	100.0
pod	0	2	0.0
total	83	104	79.8

package Kubernetes::REST::ListToRequest;
  use Moo;
  use HTTP::Tiny;
  use JSON::MaybeXS;
  use Kubernetes::REST::Error;
  use Kubernetes::REST::HTTPRequest;
  use Module::Runtime qw/require_module/;

  has _json => (is => 'ro', default => sub { JSON::MaybeXS->new });

  sub callinfo_class {
    my ($self, $call) = @_;
    my $class = "Kubernetes::REST::Call::$call";
    require_module($class);
    return $class;
  }

  sub params2request {
    my ($self, $call_ctx) = @_;

    my $call = $call_ctx->method;

    my $call_object = eval { $self->callinfo_class($call)->new(@{ $call_ctx->params }) };
    if ($@) {
      my $msg = $@;
      Kubernetes::REST::Error->throw(
        type => 'InvalidParameters',
        message => "Error in parameters to method $call",
        detail => $msg,
      );
    }

    my $body_struct;
    if ($call_object->can('_body_params')) {
      foreach my $param (@{ $call_object->_body_params }) {
        my $key = $param->{ name };
        my $value = $call_object->$key;
        next if (not defined $value);

        $body_struct = $value;
      }
    }

    my $params;
    if ($call_object->can('_query_params')) {
      $params = {};
      foreach my $param (@{ $call_object->_query_params }) {
        my $key = $param->{ name };
        my $value = $call_object->$key;
        next if (not defined $value);

        my $location = defined $param->{ location } ? $param->{ location } : $key;
        $params->{ $location } = $value;
      }
    }

    my $url = $call_object->_url;
    my $url_params;
    if ($call_object->can('_url_params')) {
      $url_params = {};
      foreach my $param (@{ $call_object->_url_params }) {
        my $key = $param->{ name };
        my $value = $call_object->$key;
        next if (not defined $value);

        my $location = defined $param->{ location } ? $param->{ location } : $key;
        $url_params->{ $location } = $value;
      }
      $url =~ s/\{([a-z0-9_-]+)\}/$url_params->{ $1 }/ge;
    }
    my $qstring = HTTP::Tiny->www_form_urlencode($params) if (defined $params);

    my $req = Kubernetes::REST::HTTPRequest->new(
      server => $call_ctx->server,
      credentials => $call_ctx->credentials,
    );
    $req->method($call_object->_method);
    $req->uri((defined $qstring) ? "${url}?$qstring" : "${url}");
    $req->headers({
      (defined $body_struct) ? ('Content-Type' => 'application/json') : (),
      Accept => 'application/json',
    });
    $req->content($self->_json->encode($body_struct)) if (defined $body_struct);

    return $req;
  }

1;