Skip to content

Commit

Permalink
Simplify logic to get user from API Key
Browse files Browse the repository at this point in the history
  • Loading branch information
pdelboca committed Jul 1, 2022
1 parent 6f3212f commit 229c613
Showing 1 changed file with 7 additions and 17 deletions.
24 changes: 7 additions & 17 deletions ckanext/xloader/jobs.py
Original file line number Diff line number Diff line change
Expand Up @@ -24,6 +24,11 @@
from . import db
from .job_exceptions import JobError, HTTPError, DataTooBigError, FileCouldNotBeLoadedError

try:
from ckan.lib.api_token import get_user_from_token
except ImportError:
get_user_from_token = None

SSL_VERIFY = asbool(config.get('ckanext.xloader.ssl_verify', True))
if not SSL_VERIFY:
requests.packages.urllib3.disable_warnings()
Expand Down Expand Up @@ -490,27 +495,12 @@ def _get_user_from_key(api_key_or_token):
only API Keys.
"""
user = None

if check_ckan_version(min_version="2.10"):
from ckan.lib.api_token import get_user_from_token
user = get_user_from_token(api_key_or_token)
return user

if check_ckan_version(min_version="2.9"):
from ckan.lib.api_token import get_user_from_token
if get_user_from_token:
user = get_user_from_token(api_key_or_token)
if not user:
user = model.Session.query(model.User).filter_by(
apikey=api_key_or_token
).first()
return user

if check_ckan_version(min_version="2.7"):
if not user:
user = model.Session.query(model.User).filter_by(
apikey=api_key_or_token
).first()
return user

return user


Expand Down

0 comments on commit 229c613

Please sign in to comment.