blob: 183fff2e91404f0015c3443c1ab7e4917b9dd36e [file] [log] [blame]
package Kalamar::Plugin::Auth;
use Mojo::Base 'Mojolicious::Plugin';
use File::Basename 'dirname';
use File::Spec::Functions qw/catdir/;
use Mojo::ByteStream 'b';
use Mojo::File qw!path!;
use Mojo::Util qw!b64_encode encode!;
use Mojo::JSON qw'decode_json encode_json';
use Encode 'is_utf8';
# This is a plugin to deal with the Kustvakt OAuth server.
# All tokens are stored in the session. Access tokens are short-lived,
# which limits the effects of misuse.
# Refresh tokens are bound to client id and client secret,
# which again limits the effects of misuse.
# TODO:
# Establish a plugin 'OAuth' that works independent of 'Auth'.
# TODO:
# CSRF-protect logout!
# TODO:
# Remove the Bearer prefix from auth.
# In case no expiration time is returned by the server,
# take this time.
our $EXPECTED_EXPIRATION_IN = 259200;
# Register the plugin
sub register {
my ($plugin, $app, $param) = @_;
# Load parameter from config file
if (my $config_param = $app->config('Kalamar-Auth')) {
$param = { %$param, %$config_param };
};
if ($param->{jwt}) {
$app->log->error('JWT flow is no longer supported');
return;
};
# Load 'notifications' plugin
unless (exists $app->renderer->helpers->{notify}) {
$app->plugin(Notifications => {
HTML => 1
});
};
# Set session default timeout
for ($app->sessions) {
$_->default_expiration(60*60*24*3); # Session expires after 3 days of non-use
};
# Get client_id and client_secret from client file
if ($param->{client_file} || $main::ENV{KALAMAR_CLIENT_FILE}) {
$param->{client_file} ||= $main::ENV{KALAMAR_CLIENT_FILE};
my $client_json = decode_json(path($param->{client_file})->slurp);
$param->{client_id} //= $client_json->{client_id};
$param->{client_secret} //= $client_json->{client_secret};
};
# Get the client id and the client_secret as a requirement
unless ($param->{client_id} && $param->{client_secret}) {
$app->log->error('client_id or client_secret not defined');
};
# Load localize
$app->plugin('Localize' => {
dict => {
de => {
abort => 'Abbrechen'
},
-en => {
abort => 'Abort'
},
Auth => {
_ => sub { $_->locale },
de => {
loginPlease => 'Bitte melden Sie sich an!',
loginSuccess => 'Anmeldung erfolgreich',
loginFail => 'Anmeldung fehlgeschlagen',
logoutSuccess => 'Abmeldung erfolgreich',
logoutFail => 'Abmeldung fehlgeschlagen',
authenticationFail => 'Nicht authentifiziert',
csrfFail => 'Fehlerhafter CSRF Token',
scopeFail => 'Scope nicht definiert',
clientIDFail => 'Client ID nicht definiert',
invalidChar => 'Ungültiges Zeichen in Anfrage',
openRedirectFail => 'Weiterleitungsfehler',
tokenExpired => 'Zugriffstoken abgelaufen',
tokenInvalid => 'Zugriffstoken ungültig',
refreshFail => 'Fehlerhafter Refresh-Token',
responseError => 'Unbekannter Autorisierungsfehler',
serverError => 'Unbekannter Serverfehler',
revokeFail => 'Der Token kann nicht widerrufen werden',
revokeSuccess => 'Der Token wurde erfolgreich widerrufen',
paramError => 'Einige Eingaben sind fehlerhaft',
redirectUri => 'Weiterleitungsadresse',
pluginSrc => 'Beschreibung des Plugins (*.json-Datei)',
homepage => 'Webseite',
desc => 'Kurzbeschreibung',
revoke => 'Widerrufen',
clientCredentials => 'Client Daten',
clientType => 'Art der Client-Applikation',
clientName => 'Name der Client-Applikation',
clientID => 'ID der Client-Applikation',
clientSecret => 'Client-Secret',
clientRegister => 'Neue Client-Applikation registrieren',
registerSuccess => 'Registrierung erfolgreich',
registerFail => 'Registrierung fehlgeschlagen',
oauthSettings => 'OAuth',
#for marketplace settings
marketplace => 'Marktplatz',
mp_regby => "Registriert von",
mp_regdate => "Registrierungsdatum",
oauthUnregister => {
-long => 'Möchten sie <span class="client-name"><%= $client_name %></span> wirklich löschen?',
short => 'Löschen'
},
oauthHint => 'Die folgende Registrierung (und alle Angaben) für API-Clients folgen der <a href="https://oauth.net/" class="external">OAuth-2.0-Spezifikation</a>.',
loginHint => 'Möglicherweise müssen sie sich zunächst einloggen.',
oauthIssueToken => {
-long => 'Stelle einen neuen Token für <span class="client-name"><%= $client_name %></span> aus',
short => 'Neuen Token ausstellen'
},
accessToken => 'Access Token',
oauthRevokeToken => {
-long => 'Widerrufe einen Token für <span class="client-name"><%= $client_name %></span>',
short => 'Widerrufe'
},
oauthGrantScope => {
-long => '<span class="client-name"><%= $client_name %></span> möchte Zugriffsrechte',
short => 'Zugriffsrechte erteilen'
},
oauthGrantPublicWarn => 'Achtung - dies ist ein öffentlicher Client!',
oauthGrantRedirectWarn => 'Die Weiterleitung findet an eine unbekannte Adresse statt',
createdAt => 'Erstellt am <time datetime="<%= stash("date") %>"><%= stash("date") %></date>.',
expiresIn => 'Läuft in <%= stash("seconds") %> Sekunden ab.',
fileSizeExceeded => 'Dateigröße überschritten'
},
-en => {
loginPlease => 'Please log in!',
loginSuccess => 'Login successful',
loginFail => 'Access denied',
logoutSuccess => 'Logout successful',
logoutFail => 'Logout failed',
authenticationFail => 'Not authenticated',
csrfFail => 'Bad CSRF token',
scopeFail => 'Scope required',
clientIDFail => 'Client ID required',
invalidChar => 'Invalid character in request',
openRedirectFail => 'Redirect failure',
tokenExpired => 'Access token expired',
tokenInvalid => 'Access token invalid',
refreshFail => 'Bad refresh token',
responseError => 'Unknown authorization error',
serverError => 'Unknown server error',
revokeFail => 'Token can\'t be revoked',
revokeSuccess => 'Token was revoked successfully',
paramError => 'Some fields are invalid',
redirectUri => 'Redirect URI',
pluginSrc => 'Declaration of the plugin (*.json file)',
homepage => 'Homepage',
desc => 'Short description',
revoke => 'Revoke',
clientCredentials => 'Client Credentials',
clientType => 'Type of the client application',
clientName => 'Name of the client application',
clientID => 'ID of the client application',
clientSecret => 'Client secret',
clientRegister => 'Register new client application',
registerSuccess => 'Registration successful',
registerFail => 'Registration denied',
oauthSettings => 'OAuth',
#for marketplace settings
marketplace => 'Marketplace',
mp_regby =>"Registered by",
mp_regdate =>"Registration date",
oauthUnregister => {
-long => 'Do you really want to unregister <span class="client-name"><%= $client_name %></span>?',
short => 'Unregister'
},
oauthHint => 'The following registration of API clients follows the <a href="https://oauth.net/" class="external">OAuth 2.0 specification</a>.',
loginHint => 'Maybe you need to log in first?',
oauthIssueToken => {
-long => 'Issue a new token for <span class="client-name"><%= $client_name %></span>',
short => 'Issue new token'
},
accessToken => 'Access Token',
oauthRevokeToken => {
-long => 'Revoke a token for <span class="client-name"><%= $client_name %></span>',
short => 'Revoke'
},
oauthGrantScope => {
-long => '<span class="client-name"><%= $client_name %></span> wants to have access',
short => 'Grant access'
},
oauthGrantPublicWarn => 'Warning - this is a public client!',
oauthGrantRedirectWarn => 'The redirect points to an unknown location',
createdAt => 'Created at <time datetime="<%= stash("date") %>"><%= stash("date") %></date>.',
expiresIn => 'Expires in <%= stash("seconds") %> seconds.',
fileSizeExceeded => 'File size exceeded',
confidentialRequired => 'Plugins need to be confidential',
jsonRequired => 'Plugin declarations need to be json files',
}
}
}
});
# Add login frame to sidebar
$app->content_block(
sidebar => {
template => 'partial/auth/login'
}
);
# Add logout button to header button list
$app->content_block(
headerButtonGroup => {
template => 'partial/auth/logout'
}
);
# Add hook after search
$app->hook(
after_search => sub {
my $c = shift;
# User is not logged in
if ($c->stash('results')->size == 0 && !$c->auth->token) {
$c->content_for(
'after_search_results' =>
$c->render_to_string(
inline => '<p class="hint"><%= loc "Auth_loginHint" %></p>'
)
);
};
}
);
# The plugin path
my $path = catdir(dirname(__FILE__), 'Auth');
# Append "templates"
push @{$app->renderer->paths}, catdir($path, 'templates');
# Get or set the user token necessary for authorization
$app->helper(
'auth.token' => sub {
my ($c, $token, $expires_in) = @_;
if ($token) {
# Set auth token
$c->stash(auth => $token);
$c->session(auth => $token);
$c->session(auth_exp => time + $expires_in);
return 1;
};
# Get token from stash
$token = $c->stash('auth');
return $token if $token;
# Get auth from session
$token = $c->session('auth') or return;
$c->stash(auth => $token);
# Return stashed value
return $token;
}
);
# Log in to the system
my $r = $app->routes;
my $client_id = $param->{client_id};
my $client_secret = $param->{client_secret};
# Sets a requested token and returns
# an error, if it didn't work
$app->helper(
'auth.set_tokens_p' => sub {
my ($c, $json) = @_;
my $promise = Mojo::Promise->new;
# No json object
unless ($json) {
return $promise->reject({
message => 'Response is no valid JSON object (remote)'
});
};
# There is an error here
# Dealing with errors here
if ($json->{error} && ref $json->{error} ne 'ARRAY') {
return $promise->reject(
{
message => $json->{error} . ($json->{error_description} ? ': ' . $json->{error_description} : '')
}
);
}
# There is an array of errors
elsif (my $error = $json->{errors} // $json->{error}) {
if (ref $error eq 'ARRAY') {
my @errors = ();
foreach (@{$error}) {
if ($_->[1]) {
push @errors, { code => $_->[0], message => $_->[1]}
};
};
return $promise->reject(@errors);
};
return $promise->reject({message => $error});
};
# Everything is fine
my $access_token = $json->{access_token};
my $token_type = $json->{token_type};
my $refresh_token = $json->{refresh_token};
my $expires_in = $json->{"expires_in"} // $EXPECTED_EXPIRATION_IN;
my $auth = $token_type . ' ' . $access_token;
# my $scope = $json->{scope};
# Set session info
$c->session(auth => $auth);
# Expiration of the token minus tolerance
$c->session(auth_exp => time + $expires_in - 60);
# Set session info for refresh token
# This can be stored in the session, as it is useless
# unless the client secret is stolen
$c->session(auth_r => $refresh_token) if $refresh_token;
# Set stash info
$c->stash(auth => $auth);
return $promise->resolve;
}
);
# Refresh tokens and return a promise
$app->helper(
'auth.refresh_p' => sub {
my $c = shift;
my $refresh_token = shift;
# Get OAuth access token
state $r_url = Mojo::URL->new($c->korap->api)->path('oauth2/token');
$c->app->log->debug("Refresh at $r_url");
return $c->kalamar_ua->post_p($r_url, {} => form => {
grant_type => 'refresh_token',
client_id => $client_id,
client_secret => $client_secret,
refresh_token => $refresh_token
})->then(
sub {
my $tx = shift;
my $json = $tx->result->json;
# Response is fine
if ($tx->res->is_success) {
$c->app->log->info("Refresh was successful");
# Set the tokens and return a promise
return $c->auth->set_tokens_p($json);
};
# There is a client error - refresh fails
if ($tx->res->is_client_error && $json) {
$c->stash(auth => undef);
$c->stash(auth_exp => undef);
delete $c->session->{user};
delete $c->session->{auth};
delete $c->session->{auth_r};
delete $c->session->{auth_exp};
# Response is 400
return Mojo::Promise->reject(
$json->{error_description} // $c->loc('Auth_refreshFail')
);
};
if ($tx->res->is_server_error) {
return Mojo::Promise->reject(
'600'
)
};
$c->notify(error => $c->loc('Auth_responseError'));
return Mojo::Promise->reject;
}
)
}
);
# Get a list of registered clients
$app->helper(
'auth.client_list_p' => sub {
my $c = shift;
# Get list of registered clients
state $r_url = Mojo::URL->new($c->korap->api)->path('oauth2/client/list');
# Get the list of all clients
return $c->korap_request(post => $r_url, {} => form => {
super_client_id => $client_id,
super_client_secret => $client_secret,
authorized_only => 'no'
})->then(
sub {
my $tx = shift;
my $json = $tx->result->json;
# Response is fine
if ($tx->res->is_success) {
return Mojo::Promise->resolve($json);
};
$c->log->error($c->dumper($tx->res->to_string));
# Failure
$c->notify(error => $c->loc('Auth_responseError'));
return Mojo::Promise->reject($json // 'No response');
}
);
}
);
# Get info for registered client
$app->helper(
'auth.client_info_p' => sub {
my $c = shift;
my $req_client_id = shift;
# Get list of registered clients
my $r_url = Mojo::URL->new($c->korap->api)->path('oauth2/client/')->path($req_client_id);
my $form = {
super_client_id => $client_id,
super_client_secret => $client_secret,
};
# Get the list of all clients
return $c->korap_request(POST => $r_url, {} => form => $form)->then(
sub {
my $tx = shift;
my $json = $tx->result->json // {};
# Response is fine
if ($tx->res->is_success) {
return Mojo::Promise->resolve($json);
};
$c->log->error($c->dumper($tx->res->to_string));
# Failure
return Mojo::Promise->reject($json->{error_description} // 'Client unknown');
}
);
}
);
# Get a list of registered clients
$app->helper(
'auth.token_list_p' => sub {
my $c = shift;
my $user_client_id = shift;
# Revoke the token
state $r_url = Mojo::URL->new($c->korap->api)->path('oauth2/token/list');
my $form = {
super_client_id => $client_id,
super_client_secret => $client_secret,
token_type => 'access_token',
};
if ($user_client_id) {
$form->{client_id} = $user_client_id;
};
# Get the list of all clients
return $c->korap_request(post => $r_url, {} => form => $form)->then(
sub {
my $tx = shift;
my $json = $tx->result->json;
# Response is fine
if ($tx->res->is_success) {
return Mojo::Promise->resolve($json);
};
$c->log->error($c->dumper($tx->res->to_string));
# Failure
$c->notify(error => $c->loc('Auth_responseError'));
return Mojo::Promise->reject($json // 'No response');
}
);
}
);
# Issue a korap request with "oauth"orization
# This will override the core request helper
$app->helper(
korap_request => sub {
my $c = shift;
# Get plugin user agent
my $ua = $c->kalamar_ua;
# Override if UA is granted
if (ref $_[0] eq 'Mojo::UserAgent') {
$ua = shift;
};
my $method = shift;
my $path = shift;
my @param = @_;
# TODO:
# Check if $tx is not leaked!
my $url = Mojo::URL->new($path);
my $tx = $ua->build_tx(uc($method), $url->clone, @param);
# Set X-Forwarded for
$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)
);
my $h = $tx->req->headers;
# If the request already has an Authorization
# header, respect it!
if ($h->authorization) {
return $ua->start_p($tx);
};
# Get auth token
if (my $auth_token = $c->auth->token) {
# The token is already expired!
my $exp = $c->session('auth_exp');
if (defined $exp && $exp < time) {
# Remove auth ...
$c->stash(auth => undef);
# And get refresh token from session
if (my $refresh_token = $c->session('auth_r')) {
$c->app->log->debug("Refresh is required");
# Refresh
return $c->auth->refresh_p($refresh_token)->then(
sub {
$c->app->log->debug("Search with refreshed tokens");
# Tokens were set - now send the request the first time!
$tx->req->headers->authorization($c->stash('auth'));
return $ua->start_p($tx);
}
);
}
# The token is expired and no refresh token is
# available - issue an unauthorized request!
else {
$c->stash(auth => undef);
$c->stash(auth_exp => undef);
delete $c->session->{user};
delete $c->session->{auth};
delete $c->session->{auth_r};
delete $c->session->{auth_exp};
# Warn on Error!
$c->notify(warn => $c->loc('Auth_tokenExpired'));
return $ua->start_p($tx);
};
}
# Auth token is fine
else {
# Set auth
$h->authorization($auth_token);
}
}
# No token set
else {
# Return unauthorized request
return $ua->start_p($tx);
};
# Issue an authorized request and automatically
# refresh the token on expiration!
return $ua->start_p($tx)->then(
sub {
my $tx = shift;
# Response is fine
if ($tx->res->is_success || $tx->res->is_redirect) {
return Mojo::Promise->resolve($tx);
}
# There is a client error - maybe refresh!
elsif ($tx->res->is_client_error) {
# Check the error
my $json = $tx->res->json('/errors/0/1');
if ($json && ($json =~ /expired|invalid/)) {
$c->stash(auth => undef);
$c->stash(auth_exp => undef);
delete $c->session->{user};
delete $c->session->{auth};
# And get refresh token from session
if (my $refresh_token = $c->session('auth_r')) {
# Refresh
return $c->auth->refresh_p($refresh_token)->then(
sub {
$c->app->log->debug("Search with refreshed tokens");
my $tx = $ua->build_tx(uc($method), $url->clone, @param);
# Set X-Forwarded for
$tx->req->headers->header(
'X-Forwarded-For' => $c->client_ip
);
# Tokens were set - now send the request the first time!
$tx->req->headers->authorization($c->stash('auth'));
return $ua->start_p($tx);
}
)
};
# Reject the invalid token
$c->notify(error => $c->loc('Auth_tokenInvalid'));
return Mojo::Promise->reject;
};
return Mojo::Promise->resolve($tx);
}
# There is a server error - just report
elsif ($tx->res->is_server_error) {
my $err = $tx->res->error;
if ($err) {
return Mojo::Promise->reject($err->{code} . ': ' . $err->{message});
}
else {
$c->notify(error => $c->loc('Auth_serverError'));
return Mojo::Promise->reject;
};
};
$c->notify(error => $c->loc('Auth_responseError'));
return Mojo::Promise->reject;
}
);
}
);
# Password flow for OAuth
$r->post('/user/login')->to(
cb => sub {
my $c = shift;
# Validate input
my $v = $c->validation;
$v->required('handle_or_email', 'trim');
$v->required('pwd', 'trim');
$v->csrf_protect;
$v->optional('fwd')->closed_redirect;
my $user = check_decode($v->param('handle_or_email'));
unless ($user) {
$c->notify(error => $c->loc('Auth_invalidChar'));
$c->param(handle_or_email => '');
return $c->relative_redirect_to('index');
};
my $fwd = $v->param('fwd');
# Set flash for redirect
$c->flash(handle_or_email => $user);
if ($v->has_error || index($user, ':') >= 0) {
if ($v->has_error('fwd')) {
$c->notify(error => $c->loc('Auth_openRedirectFail'));
}
elsif ($v->has_error('csrf_token')) {
$c->notify(error => $c->loc('Auth_csrfFail'));
}
else {
$c->notify(error => $c->loc('Auth_loginFail'));
};
return $c->relative_redirect_to($fwd // 'index');
}
my $pwd = $v->param('pwd');
$c->app->log->debug("Login from user $user");
# <specific>
# Get OAuth access token
my $url = Mojo::URL->new($c->korap->api)->path('oauth2/token');
# Korap request for login
$c->korap_request('post', $url, {}, form => {
grant_type => 'password',
username => $user,
password => $pwd,
client_id => $client_id,
client_secret => $client_secret
})->then(
sub {
# Set the tokens and return a promise
return $c->auth->set_tokens_p(shift->result->json)
}
)->then(
sub {
# Set user info
$c->session(user => $user);
$c->stash(user => $user);
# Notify on success
$c->app->log->debug(qq!Login successful: "$user"!);
$c->notify(success => $c->loc('Auth_loginSuccess'));
}
)->catch(
sub {
# Notify the user on login failure
unless (@_) {
$c->notify(error => $c->loc('Auth_loginFail'));
}
# There are known errors
foreach (@_) {
if (ref $_ eq 'HASH') {
my $err = ($_->{code} ? $_->{code} . ': ' : '') .
$_->{message};
$c->notify(error => $err);
# Log failure
$c->app->log->debug($err);
}
else {
$c->notify(error => $_);
$c->app->log->debug($_);
};
};
$c->app->log->debug(qq!Login fail: "$user"!);
}
)->finally(
sub {
# Redirect to slash
return $c->relative_redirect_to($fwd // 'index');
}
)
# Start IOLoop
->wait;
return 1;
}
)->name('login');
# Log out of the session
$r->get('/user/logout')->to(
cb => sub {
my $c = shift;
# TODO: csrf-protection!
my $refresh_token = $c->session('auth_r');
# Revoke the token
state $url = Mojo::URL->new($c->korap->api)->path('oauth2/revoke');
$c->kalamar_ua->post_p($url => {} => form => {
client_id => $client_id,
client_secret => $client_secret,
token => $refresh_token,
token_type => 'refresh_token'
})->then(
sub {
my $tx = shift;
my $json = $tx->result->json;
my $promise;
# Response is fine
if ($tx->res->is_success) {
$c->app->log->info("Revocation was successful");
$c->notify(success => $c->loc('Auth_logoutSuccess'));
$c->stash(auth => undef);
$c->stash(auth_exp => undef);
$c->flash(handle_or_email => delete $c->session->{user});
delete $c->session->{auth};
delete $c->session->{auth_r};
delete $c->session->{auth_exp};
return Mojo::Promise->resolve;
};
# Token may be invalid
$c->notify('error', $c->loc('Auth_logoutFail'));
# There is a client error - refresh fails
if ($tx->res->is_client_error && $json) {
return Mojo::Promise->reject(
$json->{error_description}
);
};
# Resource may not be found (404)
return Mojo::Promise->reject
}
)->catch(
sub {
my $err = shift;
# Server may be irresponsible
$c->notify('error', $c->loc('Auth_logoutFail'));
return Mojo::Promise->reject($err);
}
)->finally(
sub {
return $c->redirect_to('index');
}
)->wait;
}
)->name('logout');
# If "experimental_registration" is set, open
# OAuth registration dialogues.
if ($param->{experimental_client_registration}) {
# Add settings
$app->navi->add(settings => (
$app->loc('Auth_oauthSettings'), 'oauth'
)
);
#$app->navi->add(settings => (
# $app->loc('Auth_marketplace'), 'marketplace'
#));
# Lists all permitted registered plugins
$app->helper(
'auth.plugin_list_m' => sub {
my $c = shift;
state $r_url = Mojo::URL->new($c->korap->api)->path('plugins');
return $c->korap_request(post => $r_url, {} => form => {
super_client_id => $client_id,
super_client_secret => $client_secret,
#list only permitted plugins
permitted_only => 'true'
})->then(
sub {
my $tx = shift;
my $json = $tx->result->json;
# Response is fine
if ($tx->res->is_success) {
return Mojo::Promise->resolve($json);
};
$c->log->error($c->dumper($tx->res->to_string));
# Failure
$c->notify(error => $c->loc('Auth_responseError'));
return Mojo::Promise->reject($json // 'No response');
}
);
}
);
# Route to marketplace settings
$r->get('/settings/marketplace')->to(
cb => sub {
my $c = shift;
_set_no_cache($c->res->headers);
unless ($c->auth->token) {
#TODO: Handle authorization (forward to Login for example)
return $c->render(
template => 'exception',
msg => $c->loc('Auth_authenticationFail'),
status => 401
);
};
$c->render_later;
$c->auth->plugin_list_m->then(
sub {
$c->stash('plugin_list' => shift);
}
)->catch(
sub {
return;
}
)->finally(
sub {
return $c->render(template => 'auth/marketplace');
}
);
}
)->name('marketplace');
# Route to OAuth settings
$r->get('/settings/oauth')->to(
cb => sub {
my $c = shift;
_set_no_cache($c->res->headers);
unless ($c->auth->token) {
return $c->render(
template => 'exception',
msg => $c->loc('Auth_authenticationFail'),
status => 401
);
};
# Wait for async result
$c->render_later;
$c->auth->client_list_p->then(
sub {
$c->stash('client_list' => shift);
}
)->catch(
sub {
return;
}
)->finally(
sub {
return $c->render(template => 'auth/clients')
}
);
}
)->name('oauth-settings');
# Route to oauth client registration
$r->post('/settings/oauth/register')->to(
cb => sub {
my $c = shift;
_set_no_cache($c->res->headers);
my $v = $c->validation;
unless ($c->auth->token) {
return $c->render(
content => 'Unauthorized',
status => 401
);
};
$v->csrf_protect;
$v->required('name', 'trim', 'not_empty')->size(3, 255);
$v->required('type')->in('PUBLIC', 'CONFIDENTIAL');
$v->required('desc', 'trim', 'not_empty')->size(3, 255);
$v->optional('url', 'trim', 'not_empty')->like(qr/^(http|$)/i);
$v->optional('redirect_uri', 'trim', 'not_empty')->like(qr/^(http|$)/i);
$v->optional('src', 'not_empty');
$c->stash(template => 'auth/clients');
# Render with error
if ($v->has_error) {
if ($v->has_error('csrf_token')) {
$c->notify(error => $c->loc('Auth_csrfFail'));
}
else {
$c->notify(error => $c->loc('Auth_paramError'));
};
return $c->render;
} elsif ($c->req->is_limit_exceeded) {
$c->notify(error => $c->loc('Auth_fileSizeExceeded'));
return $c->render;
};
my $type = $v->param('type');
my $src = $v->param('src');
my $src_json;
my $json_obj = {
name => $v->param('name'),
type => $type,
description => $v->param('desc'),
url => $v->param('url'),
redirect_uri => $v->param('redirect_uri')
};
# Check plugin source
if ($src) {
# Source need to be a file upload
if (!ref $src || !$src->isa('Mojo::Upload')) {
$c->notify(error => $c->loc('Auth_jsonRequired'));
return $c->render;
};
# Uploads can't be too large
if ($src->size > 1_000_000) {
$c->notify(error => $c->loc('Auth_fileSizeExceeded'));
return $c->render;
};
# Check upload is not empty
if ($src->size > 0 && $src->filename ne '') {
# Plugins need to be confidential
if ($type ne 'CONFIDENTIAL') {
$c->notify(error => $c->loc('Auth_confidentialRequired'));
return $c->render;
}
my $asset = $src->asset;
# Check for json
eval {
$src_json = decode_json($asset->slurp);
};
if ($@ || !ref $src_json || ref $src_json ne 'HASH') {
$c->notify(error => $c->loc('Auth_jsonRequired'));
return $c->render;
};
$json_obj->{source} = $src_json;
};
};
# Wait for async result
$c->render_later;
# Register on server
state $url = Mojo::URL->new($c->korap->api)->path('oauth2/client/register');
$c->korap_request('POST', $url => {} => json => $json_obj)->then(
sub {
my $tx = shift;
my $result = $tx->result;
if ($result->is_error) {
my $json = $result->json;
if ($json && $json->{error}) {
$c->notify(
error => $json->{error} .
($json->{error_description} ? ': ' . $json->{error_description} : '')
)
};
return Mojo::Promise->reject;
};
my $json = $result->json;
my $client_id = $json->{client_id};
my $client_secret = $json->{client_secret};
$c->stash('client_name' => $v->param('name'));
$c->stash('client_desc' => $v->param('desc'));
$c->stash('client_type' => $v->param('type'));
$c->stash('client_url' => $v->param('url'));
$c->stash('client_src' => $v->param('source'));
$c->stash('client_redirect_uri' => $v->param('redirect_uri'));
$c->stash('client_id' => $client_id);
if ($client_secret) {
$c->stash('client_secret' => $client_secret);
};
$c->notify(success => $c->loc('Auth_en_registerSuccess'));
return $c->render(template => 'auth/client');
}
)->catch(
sub {
$c->notify('error' => $c->loc('Auth_en_registerFail'));
}
)->finally(
sub {
return $c->redirect_to('settings' => { scope => 'oauth' });
}
);
}
)->name('oauth-register');
# Unregister client page
$r->get('/settings/oauth/:client_id/unregister')->to(
cb => sub {
my $c = shift;
_set_no_cache($c->res->headers);
$c->render(template => 'auth/unregister');
}
)->name('oauth-unregister');
# Unregister client
$r->post('/settings/oauth/:client_id/unregister')->to(
cb => sub {
my $c = shift;
_set_no_cache($c->res->headers);
my $v = $c->validation;
unless ($c->auth->token) {
return $c->render(
content => 'Unauthorized',
status => 401
);
};
$v->csrf_protect;
$v->required('client-name', 'trim')->size(3, 255);
# Render with error
if ($v->has_error) {
if ($v->has_error('csrf_token')) {
$c->notify(error => $c->loc('Auth_csrfFail'));
}
else {
$c->notify(error => $c->loc('Auth_paramError'));
};
return $c->redirect_to('oauth-settings');
};
my $client_id = $c->stash('client_id');
my $client_name = $v->param('client-name');
my $client_secret = $v->param('client-secret');
# Get list of registered clients
my $r_url = Mojo::URL->new($c->korap->api)->path('oauth2/client/deregister/')->path(
$client_id
);
my $send = {};
if ($client_secret) {
$send->{client_secret} = $client_secret;
};
# Get the list of all clients
return $c->korap_request(delete => $r_url, {} => form => $send)->then(
sub {
my $tx = shift;
# Response is fine
if ($tx->res->is_success) {
# Okay
$c->notify(success => 'Successfully deleted ' . $client_name);
}
else {
# Failure
my $json = $tx->result->json;
if ($json && $json->{error_description}) {
$c->notify(error => $json->{error_description});
} else {
$c->notify(error => $c->loc('Auth_responseError'));
};
};
return $c->redirect_to('oauth-settings');
}
);
}
)->name('oauth-unregister-post');
# OAuth Client authorization
$r->get('/settings/oauth/authorize')->to(
cb => sub {
my $c = shift;
_set_no_cache($c->res->headers);
my $v = $c->validation;
$v->required('client_id', 'trim');
$v->required('scope', 'trim');
$v->optional('state', 'trim');
$v->optional('redirect_uri', 'trim', 'not_empty')->like(qr/^(http|$)/i);
# Redirect with error
if ($v->has_error) {
if ($v->has_error('client_id')) {
$c->notify(error => $c->loc('Auth_clientIDFail'));
}
elsif ($v->has_error('scope')) {
$c->notify(error => $c->loc('Auth_scopeFail'));
}
else {
$c->notify(error => $c->loc('Auth_paramError'));
};
# If logged in, go to oauth settings - otherwise to index
return $c->redirect_to($c->auth->token ? 'oauth-settings' : 'index');
};
foreach (qw!scope client_id state redirect_uri!) {
$c->stash($_, $v->param($_));
};
# Wait for async result
$c->render_later;
my $client_id = $v->param('client_id');
my $client_information = $c->auth->client_info_p($client_id)->then(
sub {
my $cl = shift;
$c->stash(client_name => $cl->{'client_name'});
$c->stash(client_type => $cl->{'client_type'});
$c->stash(client_desc => $cl->{'client_description'});
$c->stash(client_url => $cl->{'client_url'});
$c->stash(redirect_uri_server => $cl->{'client_redirect_uri'});
}
)->then(
sub {
# Check, if the client redirect_uri is valid
my $redirect_uri_server = $c->stash('redirect_uri_server');
my $redirect_uri = $v->param('redirect_uri');
my ($server_o, $client_o);
# Both exist
if ($redirect_uri_server && $redirect_uri) {
$server_o = Mojo::URL->new($redirect_uri_server);
$client_o = Mojo::URL->new($redirect_uri);
# Host not valid - take registered URI
if ($server_o->host ne $client_o->host) {
$c->notify(warn => 'redirect_uri host differs from registered host');
$client_o = $server_o;
}
# Port not valid - take registered URI
elsif (($server_o->port // '') ne ($client_o->port // '')) {
$c->notify(warn => 'redirect_uri port differs from registered port');
$client_o = $server_o;
};
}
# Client sent exists
elsif ($redirect_uri) {
$client_o = Mojo::URL->new($redirect_uri);
$c->stash(redirect_warning => $c->loc('oauthGrantRedirectWarn'))
}
# Server registered exists
elsif ($redirect_uri_server) {
$client_o = Mojo::URL->new($redirect_uri_server);
}
# Redirect unknown
else {
$c->notify(error => 'redirect_uri not set');
# If logged in, go to oauth settings - otherwise to index
return $c->redirect_to($c->auth->token ? 'oauth-settings' : 'index');
};
# No userinfo allowed
if ($client_o->userinfo) {
$c->notify(warn => 'redirect_uri contains userinfo');
$client_o->userinfo('');
};
# HTTPS warning
# if ($client_o->scheme ne 'https') {
# $c->notify(warn => 'redirect_uri is not HTTPS');
# };
# Sign redirection URL
$c->stash(redirect_uri => $client_o->to_string);
$c->stash(close_redirect_uri => '' . $c->close_redirect_to($client_o));
# Get auth token
my $auth_token = $c->auth->token;
# User is not logged in - log in before!
unless ($auth_token) {
return $c->render(template => 'auth/login');
};
# Grant authorization
return $c->render(template => 'auth/grant_scope');
}
)->catch(
sub {
my $error = shift;
$c->notify(error => $error);
# If logged in, go to oauth settings - otherwise to index
return $c->redirect_to($c->auth->token ? 'oauth-settings' : 'index');
}
);
}
)->name('oauth-grant-scope');
# OAuth Client authorization
# This will return a location information including some info
$r->post('/settings/oauth/authorize')->to(
cb => sub {
my $c = shift;
_set_no_cache($c->res->headers);
# It's necessary that it's clear this was triggered by
# KorAP and not by the client!
my $v = $c->validation;
$v->csrf_protect;
$v->required('client_id', 'trim');
$v->required('scope', 'trim');
$v->optional('state', 'trim');
# Only signed redirects are allowed
$v->required('redirect_uri', 'trim', 'not_empty')->closed_redirect;
# Render with error
if ($v->has_error) {
# If logged in, go to oauth settings - otherwise to index
my $url = $c->url_for($c->auth->token ? 'oauth-settings' : 'index');
if ($v->has_error('client_id')) {
$url->query([error_description => $c->loc('Auth_clientIDFail')]);
}
elsif ($v->has_error('scope')) {
$url->query([error_description => $c->loc('Auth_scopeFail')]);
}
elsif ($v->has_error('csrf_token')) {
$url->query([error_description => $c->loc('Auth_csrfFail')]);
}
else {
$url->query([error_description => $c->loc('Auth_paramError')]);
};
return $c->redirect_to($url);
};
state $r_url = Mojo::URL->new($c->korap->api)->path('oauth2/authorize');
$c->stash(redirect_uri => Mojo::URL->new($v->param('redirect_uri')));
my $ua = Mojo::UserAgent->new(
connect_timeout => 30,
inactivity_timeout => 30,
max_redirects => 0
);
$ua->server->app($app);
return $c->korap_request($ua, post => $r_url, { } => form => {
response_type => 'code',
client_id => $v->param('client_id'),
redirect_uri => $c->stash('redirect_uri'),
state => $v->param('state'),
scope => $v->param('scope'),
})->then(
sub {
my $tx = shift;
unless (ref($tx)) {
return Mojo::Promise->reject('Something went wrong');
};
# Check for location header with code in redirects
my $loc;
# Look for code in location URL
if ($loc = $tx->res->headers->header('Location')) {
my $url = Mojo::URL->new($loc);
if ($url->query->param('code')) {
return Mojo::Promise->resolve($loc);
} elsif (my $err = $url->query->param('error_description')) {
return Mojo::Promise->reject($err);
}
};
# Check for location header with code in redirects
# This should be dead code tbh
foreach (@{$tx->redirects}) {
$loc = $_->res->headers->header('Location');
my $url = Mojo::URL->new($loc);
if ($url->query->param('code')) {
last;
} elsif (my $err = $url->query->param('error_description')) {
return Mojo::Promise->reject($err);
}
};
return Mojo::Promise->resolve($loc) if $loc;
# Failed redirect, but location set
if ($tx->res->headers->location) {
my $url = Mojo::URL->new($tx->res->headers->location);
if (my $err = $url->query->param('error_description')) {
return Mojo::Promise->reject($err);
};
}
$c->stash(redirect_uri => undef);
# Maybe json
my $json = $tx->res->json;
if ($json && $json->{error_description}) {
return Mojo::Promise->reject($json->{error_description});
};
# No location code
return Mojo::Promise->reject('no location response');
}
)->catch(
sub {
my $err_msg = shift;
my $url = $c->stash('redirect_uri');
# Redirect!
if ($url) {
if ($err_msg) {
$url = $url->query([error_description => $err_msg]);
};
}
# Do not redirect!
else {
$c->notify(error => $err_msg);
# If logged in, go to oauth settings - otherwise to index
$url = $c->url_for($c->auth->token ? 'oauth-settings' : 'index');
};
return Mojo::Promise->resolve($url);
}
)->then(
sub {
my $loc = shift;
return $c->redirect_to($loc);
}
)->wait;
return $c->rendered;
}
)->name('oauth-grant-scope-post');
# Show information of a client
$r->get('/settings/oauth/:client_id')->to(
cb => sub {
my $c = shift;
_set_no_cache($c->res->headers);
$c->render_later;
$c->auth->client_list_p->then(
sub {
my $json = shift;
my ($item) = grep {
$c->stash('client_id') eq $_->{client_id}
} @$json;
unless ($item) {
return Mojo::Promise->reject;
};
$c->stash(client_name => $item->{client_name});
$c->stash(client_desc => $item->{client_description});
$c->stash(client_url => $item->{client_url});
$c->stash(client_type => ($item->{client_type} // 'PUBLIC'));
$c->stash(client_redirect_uri => $item->{client_redirect_uri});
$c->stash(client_src => encode_json($item->{source})) if $item->{source};
$c->auth->token_list_p($c->stash('client_id'));
}
)->then(
sub {
my $json = shift;
$c->stash(tokens => $json);
return Mojo::Promise->resolve;
}
)->catch(
sub {
return $c->reply->not_found;
}
)->finally(
sub {
return $c->render(template => 'auth/client')
}
);
return;
}
)->name('oauth-tokens');
};
# Ask if new token should be issued
$r->get('/settings/oauth/:client_id/token')->to(
cb => sub {
my $c = shift;
_set_no_cache($c->res->headers);
$c->render(template => 'auth/issue-token');
}
)->name('oauth-issue-token');
# Ask if a token should be revoked
$r->post('/settings/oauth/:client_id/token/revoke')->to(
cb => sub {
shift->render(template => 'auth/revoke-token');
}
)->name('oauth-revoke-token');
# Issue new token
$r->post('/settings/oauth/:client_id/token')->to(
cb => sub {
my $c = shift;
_set_no_cache($c->res->headers);
my $v = $c->validation;
unless ($c->auth->token) {
return $c->render(
content => 'Unauthorized',
status => 401
);
};
$v->csrf_protect;
$v->optional('client-secret');
$v->required('name', 'trim');
# Render with error
if ($v->has_error) {
if ($v->has_error('csrf_token')) {
$c->notify(error => $c->loc('Auth_csrfFail'));
}
else {
$c->notify(error => $c->loc('Auth_paramError'));
};
return $c->redirect_to('oauth-settings')
};
# Get authorization token
state $r_url = Mojo::URL->new($c->korap->api)->path('oauth2/authorize');
my $client_id = $c->stash('client_id');
my $name = $v->param('name');
my $redirect_url = $c->url_for->query({name => $name});
return $c->korap_request(post => $r_url, {} => form => {
response_type => 'code',
client_id => $client_id,
redirect_uri => $redirect_url,
# TODO: State
})->then(
sub {
my $tx = shift;
# Strip the token from the location header of the fake redirect
# TODO: Alternatively redirect!
my ($code, $scope, $loc, $name);
foreach (@{$tx->redirects}) {
$loc = $_->res->headers->header('Location');
if (index($loc, 'code') > 0) {
my $q = Mojo::URL->new($loc)->query;
$code = $q->param('code');
$scope = $q->param('scope');
$name = $q->param('name');
last;
};
};
# Fine!
if ($code) {
return Mojo::Promise->resolve(
$client_id,
$redirect_url,
$code,
$scope,
$name
);
};
return Mojo::Promise->reject;
}
)->then(
sub {
my ($client_id, $redirect_url, $code, $scope, $name) = @_;
# Get OAuth access token
state $r_url = Mojo::URL->new($c->korap->api)->path('oauth2/token');
return $c->kalamar_ua->post_p($r_url, {} => form => {
client_id => $client_id,
# NO CLIENT_SECRET YET SUPPORTED
grant_type => 'authorization_code',
code => $code,
redirect_uri => $redirect_url
})->then(
sub {
my $tx = shift;
my $json = $tx->res->json;
if ($tx->res->is_error) {
$c->notify(error => 'Unable to fetch new token');
return Mojo::Promise->reject;
};
$c->notify(success => 'New access token created');
$c->redirect_to('oauth-tokens' => { client_id => $client_id })
}
)->catch(
sub {
my $err_msg = shift;
# Only raised in case of connection errors
if ($err_msg) {
$c->notify(error => { src => 'Backend' } => $err_msg)
};
$c->render(
status => 400,
template => 'failure'
);
}
)
# Start IOLoop
->wait;
}
)->catch(
sub {
my $err_msg = shift;
# Only raised in case of connection errors
if ($err_msg) {
$c->notify(error => { src => 'Backend' } => $err_msg)
};
return $c->render(
status => 400,
template => 'failure'
);
}
)
# Start IOLoop
->wait;
return 1;
}
)->name('oauth-issue-token-post');
# Revoke token
$r->delete('/settings/oauth/:client_id/token')->to(
cb => sub {
my $c = shift;
my $v = $c->validation;
unless ($c->auth->token) {
return $c->render(
content => 'Unauthorized',
status => 401
);
};
$v->csrf_protect;
$v->required('token', 'trim');
$v->optional('name', 'trim');
my $private_client_id = $c->stash('client_id');
# Render with error
if ($v->has_error) {
if ($v->has_error('csrf_token')) {
$c->notify(error => $c->loc('Auth_csrfFail'));
}
else {
$c->notify(error => $c->loc('Auth_paramError'));
};
return $c->redirect_to('oauth-tokens', client_id => $private_client_id);
};
# Revoke token using super client privileges
state $r_url = Mojo::URL->new($c->korap->api)->path('oauth2/revoke/super');
my $token = $v->param('token');
return $c->korap_request(post => $r_url, {} => form => {
super_client_id => $client_id,
super_client_secret => $client_secret,
token => $token
})->then(
sub {
my $tx = shift;
# Response is fine
if ($tx->res->is_success) {
$c->notify(success => $c->loc('Auth_revokeSuccess'));
return Mojo::Promise->resolve;
};
return Mojo::Promise->reject;
}
)->catch(
sub {
my $err_msg = shift;
if ($err_msg) {
$c->notify(error => { src => 'Backend' } => $err_msg );
}
else {
$c->notify(error => $c->loc('Auth_revokeFail'));
};
}
)->finally(
sub {
return $c->redirect_to('oauth-tokens', client_id => $private_client_id);
}
)
# Start IOLoop
->wait;
}
)->name('oauth-revoke-token-delete');
$app->log->info('Successfully registered Auth plugin');
};
# Set 'no caching' headers
sub _set_no_cache {
my $h = shift;
$h->cache_control('max-age=0, no-cache, no-store, must-revalidate');
$h->expires('Thu, 01 Jan 1970 00:00:00 GMT');
$h->header('Pragma','no-cache');
};
sub check_decode {
no warnings 'uninitialized';
my $str = shift;
my $str2 = is_utf8($str) ? b($str)->decode : $str;
if (defined($str2) && $str2 && length($str2) > 1) {
return $str2
};
return;
};
1;
__END__
=pod
=encoding utf8
=head1 NAME
Kalamar::Plugin::Auth - OAuth-2.0-based authorization plugin
=head1 DESCRIPTION
L<Kalamar::Plugin::Auth> is an OAuth-2.0-based authorization
plugin for L<Kalamar>. It requires a C<Kustvakt> full server
with OAuth 2.0 capabilities.
It is activated by loading C<Auth> as a plugin in the C<Kalamar.plugins>
parameter in the Kalamar configuration.
=head1 CONFIGURATION
L<Kalamar::Plugin::Auth> supports the following parameter for the
C<Kalamar-Auth> configuration section in the Kalamar configuration:
=over 2
=item B<client_id>
The client identifier of Kalamar to be send with every OAuth 2.0
management request.
=item B<client_secret>
The client secret of Kalamar to be send with every OAuth 2.0
management request.
=item B<experimental_client_registration>
Activates the oauth client registration flow.
=back
=head2 COPYRIGHT AND LICENSE
Copyright (C) 2015-2022, L<IDS Mannheim|http://www.ids-mannheim.de/>
Author: L<Nils Diewald|http://nils-diewald.de/>
Kalamar is developed as part of the L<KorAP|http://korap.ids-mannheim.de/>
Corpus Analysis Platform at the
L<Leibniz Institute for the German Language (IDS)|http://ids-mannheim.de/>,
member of the
L<Leibniz-Gemeinschaft|http://www.leibniz-gemeinschaft.de>
and supported by the L<KobRA|http://www.kobra.tu-dortmund.de> project,
funded by the
L<Federal Ministry of Education and Research (BMBF)|http://www.bmbf.de/en/>.
Kalamar is free software published under the
L<BSD-2 License|https://raw.githubusercontent.com/KorAP/Kalamar/master/LICENSE>.
=cut