Restructure test suite
Change-Id: Ibbd4bbb27203f9ffa89ae3e3a36b16f455b3523c
diff --git a/t/server/mock.pl b/t/server/mock.pl
new file mode 100644
index 0000000..18fd05d
--- /dev/null
+++ b/t/server/mock.pl
@@ -0,0 +1,307 @@
+#!/usr/bin/env perl
+use Mojolicious::Lite;
+use Mojo::ByteStream 'b';
+use Mojo::Date;
+use Mojo::JSON qw/true false encode_json decode_json/;
+use strict;
+use warnings;
+use Mojo::JWT;
+use Mojo::File qw/path/;
+use Mojo::Util qw/slugify/;
+
+# This is an API fake server with fixtures
+
+my $secret = 's3cr3t';
+my $fixture_path = path(Mojo::File->new(__FILE__)->dirname)->child('..', 'fixtures');
+
+helper jwt_encode => sub {
+ shift;
+ return Mojo::JWT->new(
+ secret => $secret,
+ token_type => 'api_token',
+ expires => time + (3 * 34 * 60 * 60),
+ claims => { @_ }
+ );
+};
+
+helper jwt_decode => sub {
+ my ($c, $auth) = @_;
+ $auth =~ s/\s*api_token\s+//;
+ return Mojo::JWT->new(secret => $secret)->decode($auth);
+};
+
+
+# Load fixture responses
+helper 'load_response' => sub {
+ my $c = shift;
+ my $q_name = shift;
+ my $file = $fixture_path->child("response_$q_name.json");
+ $c->app->log->debug("Load response from $file");
+
+ unless (-f $file) {
+ return {
+ status => 500,
+ json => {
+ errors => [[0, 'Unable to load query response from ' . $file]]
+ }
+ }
+ };
+
+ my $response = $file->slurp;
+ return decode_json($response);
+};
+
+
+# Base page
+get '/' => sub {
+ shift->render(text => 'Fake server available');
+};
+
+
+# Search fixtures
+get '/search' => sub {
+ my $c = shift;
+ my $v = $c->validation;
+ $v->optional('q');
+ $v->optional('page');
+ $v->optional('ql');
+ $v->optional('count');
+ $v->optional('context');
+ $v->optional('offset');
+ $v->optional('cutoff')->in(qw/true false/);
+
+ $c->app->log->debug('Receive request');
+
+ # Response q=x&ql=cosmas3
+ if ($v->param('ql') && $v->param('ql') eq 'cosmas3') {
+ return $c->render(
+ status => 400,
+ json => {
+ "\@context" => "http://korap.ids-mannheim.de/ns/koral/0.3/context.jsonld",
+ "errors" => [[307,"cosmas3 is not a supported query language!"]]
+ });
+ };
+
+ if (!$v->param('q')) {
+ return $c->render(%{$c->load_response('query_no_query')});
+ };
+
+ my @slug_base = ($v->param('q'));
+ push @slug_base, 'o' . $v->param('offset') if defined $v->param('offset');
+ push @slug_base, 'c' . $v->param('count') if defined $v->param('count');
+ push @slug_base, 'co' . $v->param('cutoff') if defined $v->param('cutoff');
+
+ # Get response based on query parameter
+ my $response = $c->load_response('query_' . slugify(join('_', @slug_base)));
+
+ # Check authentification
+ if (my $auth = $c->req->headers->header('Authorization')) {
+ if (my $jwt = $c->jwt_decode($auth)) {
+ $response->{json}->{meta}->{authorized} = $jwt->{username} if $jwt->{username};
+ };
+ };
+
+ # Set page parameter
+ if ($v->param('page')) {
+ $response->{json}->{meta}->{startIndex} = $v->param("startIndex");
+ };
+
+ # Simple search fixture
+ $c->render(%$response);
+
+ $c->app->log->debug('Rendered result');
+
+ return 1;
+};
+
+# Textinfo fixtures
+get '/corpus/:corpusId/:docId/:textId' => sub {
+ my $c = shift;
+
+ my $file = join('_', (
+ 'textinfo',
+ $c->stash('corpusId'),
+ $c->stash('docId'),
+ $c->stash('textId')
+ ));
+
+ my $slug = slugify($file);
+
+ # Get response based on query parameter
+ my $response = $c->load_response($slug);
+ return $c->render(%$response);
+};
+
+
+# Matchinfo fixtures
+get '/corpus/:corpusId/:docId/:textId/:matchId/matchInfo' => sub {
+ my $c = shift;
+
+ my $file = join('_', (
+ 'matchinfo',
+ $c->stash('corpusId'),
+ $c->stash('docId'),
+ $c->stash('textId'),
+ $c->stash('matchId')
+ ));
+
+ my $slug = slugify($file);
+
+ # Get response based on query parameter
+ my $response = $c->load_response($slug);
+ return $c->render(%$response);
+};
+
+
+# Statistics endpoint
+get '/statistics' => sub {
+ my $c = shift;
+ my $v = $c->validation;
+ $v->optional('corpusQuery');
+
+ my @list = 'corpusinfo';
+ if ($v->param('corpusQuery')) {
+ push @list, $v->param('corpusQuery');
+ };
+ my $slug = slugify(join('_', @list));
+
+ # Get response based on query parameter
+ my $response = $c->load_response($slug);
+ return $c->render(%$response);
+};
+
+############
+# Auth API #
+############
+
+# Request API token
+get '/auth/logout' => sub {
+ my $c = shift;
+
+ if (my $auth = $c->req->headers->header('Authorization')) {
+ if (my $jwt = $c->jwt_decode($auth)) {
+ my $user = $jwt->{username} if $jwt->{username};
+
+ $c->app->log->debug('Server-Logout: ' . $user);
+ return $c->render(json => { msg => [[0, 'Fine!']]});
+ };
+ };
+
+ return $c->render(status => 400, json => { error => [[0, 'No!']]});
+};
+
+
+# Request API token
+get '/auth/apiToken' => sub {
+ my $c = shift;
+
+ # Get auth header
+ my $auth = $c->req->headers->authorization;
+
+ # Authorization missing or not basic
+ if (!$auth || $auth !~ s/\s*Basic\s+//gi) {
+ return $c->render(
+ json => {
+ error => [[2, 'x']]
+ }
+ );
+ };
+
+ # Decode header
+ my ($username, $pwd) = @{b($auth)->b64_decode->split(':')->to_array};
+
+ # the password is 'pass'
+ if ($pwd) {
+
+ # the password is 'pass'
+ if ($pwd eq 'pass') {
+
+ # Render info with token
+ my $jwt = $c->jwt_encode(username => $username);
+
+ # Render in the Kustvakt fashion:
+ return $c->render(
+ format => 'html',
+ text => encode_json({
+ %{$jwt->claims},
+ expires => $jwt->expires,
+ token => $jwt->encode,
+ token_type => 'api_token'
+ })
+ );
+ };
+
+ return $c->render(
+ json => {
+ error => [[2004, undef]]
+ }
+ );
+ };
+
+ return $c->render(
+ json => {
+ error => [[2004, undef]]
+ }
+ );
+};
+
+app->start;
+
+
+__END__
+
+
+ # Temporary:
+ my $collection_query = {
+ '@type' => "koral:docGroup",
+ "operation" => "operation:or",
+ "operands" => [
+ {
+ '@type' => "koral:docGroup",
+ "operation" => "operation:and",
+ "operands" => [
+ {
+ '@type' => "koral:doc",
+ "key" => "title",
+ "match" => "match:eq",
+ "value" => "Der Birnbaum",
+ "type" => "type:string"
+ },
+ {
+ '@type' => "koral:doc",
+ "key" => "pubPlace",
+ "match" => "match:eq",
+ "value" => "Mannheim",
+ "type" => "type:string"
+ },
+ {
+ '@type' => "koral:docGroup",
+ "operation" => "operation:or",
+ "operands" => [
+ {
+ '@type' => "koral:doc",
+ "key" => "subTitle",
+ "match" => "match:eq",
+ "value" => "Aufzucht oder Pflege",
+ "type" => "type:string"
+ },
+ {
+ '@type' => "koral:doc",
+ "key" => "subTitle",
+ "match" => "match:eq",
+ "value" => "Gedichte",
+ "type" => "type:string"
+ }
+ ]
+ }
+ ]
+ },
+ {
+ '@type' => "koral:doc",
+ "key" => "pubDate",
+ "match" => "match:geq",
+ "value" => "2015-03-05",
+ "type" => "type:date"
+ }
+ ]
+ };