blob: 9573f3f36e1c1e382ca957ad3df3db97010f7181 [file] [log] [blame]
Akron0e1ed242018-10-11 13:22:00 +02001#!/usr/bin/env perl
2use Mojolicious::Lite;
3use Mojo::ByteStream 'b';
4use Mojo::Date;
5use Mojo::JSON qw/true false encode_json decode_json/;
6use strict;
7use warnings;
8use Mojo::JWT;
Akron6d49c1f2018-10-11 14:22:21 +02009use Mojo::File qw/path/;
10use Mojo::Util qw/slugify/;
Akron0e1ed242018-10-11 13:22:00 +020011
12# This is an API fake server with fixtures
13
14my $secret = 's3cr3t';
Akron6d49c1f2018-10-11 14:22:21 +020015my $fixture_path = path(Mojo::File->new(__FILE__)->dirname);
Akron0e1ed242018-10-11 13:22:00 +020016
17helper jwt_encode => sub {
18 shift;
19 return Mojo::JWT->new(
20 secret => $secret,
21 token_type => 'api_token',
22 expires => time + (3 * 34 * 60 * 60),
23 claims => { @_ }
24 );
25};
26
27helper jwt_decode => sub {
28 my ($c, $auth) = @_;
29 $auth =~ s/\s*api_token\s+//;
30 return Mojo::JWT->new(secret => $secret)->decode($auth);
31};
32
33
Akron6d49c1f2018-10-11 14:22:21 +020034# Load fixture responses
35helper 'load_response' => sub {
36 my $c = shift;
37 my $q_name = shift;
38 my $file = $fixture_path->child("response_$q_name.json");
39 unless (-f $file) {
40 return {
41 status => 500,
42 json => {
43 errors => [[0, 'Unable to load query response from ' . $file]]
44 }
45 }
46 };
47 my $response = $file->slurp;
48 return decode_json($response);
49};
50
51
Akron0e1ed242018-10-11 13:22:00 +020052# Base page
53get '/' => sub {
Akron6d49c1f2018-10-11 14:22:21 +020054 shift->render(text => 'Fake server available');
Akron0e1ed242018-10-11 13:22:00 +020055};
56
Akron32396632018-10-11 17:08:37 +020057
Akron0e1ed242018-10-11 13:22:00 +020058# Search fixtures
59get '/search' => sub {
60 my $c = shift;
61 my $v = $c->validation;
62 $v->optional('q');
63 $v->optional('page');
64 $v->optional('ql');
65 $v->optional('count');
66 $v->optional('context');
67
Akron32396632018-10-11 17:08:37 +020068 $c->app->log->debug('Receive request');
69
Akron0e1ed242018-10-11 13:22:00 +020070 # Response q=x&ql=cosmas3
71 if ($v->param('ql') && $v->param('ql') eq 'cosmas3') {
72 return $c->render(
73 status => 400,
74 json => {
75 "\@context" => "http://korap.ids-mannheim.de/ns/koral/0.3/context.jsonld",
76 "errors" => [[307,"cosmas3 is not a supported query language!"]]
77 });
78 };
79
Akron6d49c1f2018-10-11 14:22:21 +020080 if (!$v->param('q')) {
81 return $c->render(%{$c->load_response('no_query')});
Akron0e1ed242018-10-11 13:22:00 +020082 };
83
Akron6d49c1f2018-10-11 14:22:21 +020084 # Get response based on query parameter
85 my $response = $c->load_response(slugify($v->param('q')));
Akron0e1ed242018-10-11 13:22:00 +020086
87 # Check authentification
88 if (my $auth = $c->req->headers->header('Authorization')) {
89 if (my $jwt = $c->jwt_decode($auth)) {
Akron6d49c1f2018-10-11 14:22:21 +020090 $response->{json}->{meta}->{authorized} = $jwt->{username} if $jwt->{username};
Akron0e1ed242018-10-11 13:22:00 +020091 };
92 };
93
Akron6d49c1f2018-10-11 14:22:21 +020094 # Set page parameter
Akron0e1ed242018-10-11 13:22:00 +020095 if ($v->param('page')) {
Akron6d49c1f2018-10-11 14:22:21 +020096 $response->{json}->{meta}->{startIndex} = $v->param("startIndex");
Akron0e1ed242018-10-11 13:22:00 +020097 };
98
Akron0e1ed242018-10-11 13:22:00 +020099 # Simple search fixture
Akron32396632018-10-11 17:08:37 +0200100 $c->render(%$response);
101
102 $c->app->log->debug('Rendered result');
103
104 return 1;
Akron0e1ed242018-10-11 13:22:00 +0200105};
106
107
Akronb80341d2018-10-15 19:46:23 +0200108# Matchinfo fixtures
109get '/corpus/:corpusId/:docId/:textId/:matchId/matchInfo' => sub {
110 my $c = shift;
111
112 my $file = join('_', (
113 'matchinfo',
114 $c->stash('corpusId'),
115 $c->stash('docId'),
116 $c->stash('textId'),
117 $c->stash('matchId')
118 ));
119
120 # Get response based on query parameter
121 my $response = $c->load_response(slugify($file));
122 return $c->render(%$response);
123};
124
Akron0e1ed242018-10-11 13:22:00 +0200125
126############
127# Auth API #
128############
129
130# Request API token
131get '/auth/logout' => sub {
132 my $c = shift;
133
134 if (my $auth = $c->req->headers->header('Authorization')) {
135 if (my $jwt = $c->jwt_decode($auth)) {
136 my $user = $jwt->{username} if $jwt->{username};
137
138 $c->app->log->debug('Server-Logout: ' . $user);
139 return $c->render(json => { msg => [[0, 'Fine!']]});
140 };
141 };
142
143 return $c->render(status => 400, json => { error => [[0, 'No!']]});
144};
145
146
147# Request API token
148get '/auth/apiToken' => sub {
149 my $c = shift;
150
151 # Get auth header
152 my $auth = $c->req->headers->authorization;
153
154 # Authorization missing or not basic
155 if (!$auth || $auth !~ s/\s*Basic\s+//gi) {
156 return $c->render(
157 json => {
158 error => [[2, 'x']]
159 }
160 );
161 };
162
163 # Decode header
164 my ($username, $pwd) = @{b($auth)->b64_decode->split(':')->to_array};
165
166 # the password is 'pass'
167 if ($pwd) {
168
169 # the password is 'pass'
170 if ($pwd eq 'pass') {
171
172 # Render info with token
173 my $jwt = $c->jwt_encode(username => $username);
174
175 # Render in the Kustvakt fashion:
176 return $c->render(
177 format => 'html',
178 text => encode_json({
179 %{$jwt->claims},
180 expires => $jwt->expires,
181 token => $jwt->encode,
182 token_type => 'api_token'
183 })
184 );
185 };
186
187 return $c->render(
188 json => {
189 error => [[2004, undef]]
190 }
191 );
192 };
193
194 return $c->render(
195 json => {
196 error => [[2004, undef]]
197 }
198 );
199};
200
201app->start;
202
203
204__END__
205
206
207 # Temporary:
208 my $collection_query = {
209 '@type' => "koral:docGroup",
210 "operation" => "operation:or",
211 "operands" => [
212 {
213 '@type' => "koral:docGroup",
214 "operation" => "operation:and",
215 "operands" => [
216 {
217 '@type' => "koral:doc",
218 "key" => "title",
219 "match" => "match:eq",
220 "value" => "Der Birnbaum",
221 "type" => "type:string"
222 },
223 {
224 '@type' => "koral:doc",
225 "key" => "pubPlace",
226 "match" => "match:eq",
227 "value" => "Mannheim",
228 "type" => "type:string"
229 },
230 {
231 '@type' => "koral:docGroup",
232 "operation" => "operation:or",
233 "operands" => [
234 {
235 '@type' => "koral:doc",
236 "key" => "subTitle",
237 "match" => "match:eq",
238 "value" => "Aufzucht oder Pflege",
239 "type" => "type:string"
240 },
241 {
242 '@type' => "koral:doc",
243 "key" => "subTitle",
244 "match" => "match:eq",
245 "value" => "Gedichte",
246 "type" => "type:string"
247 }
248 ]
249 }
250 ]
251 },
252 {
253 '@type' => "koral:doc",
254 "key" => "pubDate",
255 "match" => "match:geq",
256 "value" => "2015-03-05",
257 "type" => "type:date"
258 }
259 ]
260 };