Introduce Kalamar::Request
Change-Id: I0c21bf8521cebeedc95a4251d7abf074e30ca2a3
diff --git a/lib/Kalamar/Request.pm b/lib/Kalamar/Request.pm
new file mode 100644
index 0000000..ebe68d9
--- /dev/null
+++ b/lib/Kalamar/Request.pm
@@ -0,0 +1,82 @@
+package Kalamar::Request;
+use Mojo::Base -base;
+use Mojo::Promise;
+
+has [qw!controller ua!];
+
+has url => sub {
+ my $self = shift;
+ if (@_) {
+ $self->{url} = Mojo::URL->new(shift);
+ return $self;
+ };
+ return $self->{url};
+};
+
+has method => sub {
+ my $self = shift;
+ if (@_) {
+ $self->{method} = uc(shift);
+ return $self;
+ };
+ return $self->{method} // 'GET';
+};
+
+
+# Get or set parameters for the transaction
+sub param {
+ my $self = shift;
+ if (scalar(@_) > 0) {
+ if (defined $_[0]) {
+ $self->{param} = [@_];
+ }
+ else {
+ $self->{param} = undef;
+ }
+ return $self;
+ };
+ return $self->{param} // [];
+};
+
+
+# Start transaction and return a promise
+sub start {
+ my $self = shift;
+
+ # TODO: Better return a rejected promise
+ unless ($self->url) {
+ return Mojo::Promise->reject('No URL defined');
+ };
+
+ unless ($self->controller) {
+ return Mojo::Promise->reject('No controller defined');
+ };
+
+ unless ($self->ua) {
+ return Mojo::Promise->reject('No useragent defined');
+ };
+
+ my @param = ($self->method, $self->url);
+ push @param, @{$self->param} if scalar(@{$self->param}) > 0;
+
+ my $tx = $self->ua->build_tx(@param);
+
+ my $c = $self->controller;
+
+ # Set X-Forwarded for
+ if ($c->app->renderer->helpers->{'client_ip'}) {
+ $tx->req->headers->header(
+ 'X-Forwarded-For' => $c->client_ip
+ );
+ };
+
+ # Emit Hook to alter request
+ $c->app->plugins->emit_hook(
+ before_korap_request => ($c, $tx)
+ );
+
+ # Return promise
+ return $self->ua->start_p($tx);
+};
+
+1;