chore: alignment, move logic into logic folder and split auth and act…

…ions apart, move plugin from folder to root plugin.py

.gitignore

@@ -99,3 +99,4 @@ ENV/
 
 # mypy
 .mypy_cache/
+.idea

ckanext/validation/logic.py → ckanext/validation/logic/action.py

@@ -26,6 +26,19 @@
 log = logging.getLogger(__name__)
 
 
+def get_actions():
+    validators = (
+        resource_validation_run,
+        resource_validation_show,
+        resource_validation_delete,
+        resource_validation_run_batch,
+        resource_create,
+        resource_update,
+    )
+
+    return {"{}".format(func.__name__): func for func in validators}
+
+
 def enqueue_job(*args, **kwargs):
     try:
         return t.enqueue_job(*args, **kwargs)
@@ -34,35 +47,6 @@ def enqueue_job(*args, **kwargs):
         return enqueue_job_legacy(*args, **kwargs)
 
 
-# Auth
-
-def auth_resource_validation_run(context, data_dict):
-    if t.check_access(
-            u'resource_update', context, {u'id': data_dict[u'resource_id']}):
-        return {u'success': True}
-    return {u'success': False}
-
-
-def auth_resource_validation_delete(context, data_dict):
-    if t.check_access(
-            u'resource_update', context, {u'id': data_dict[u'resource_id']}):
-        return {u'success': True}
-    return {u'success': False}
-
-
-@t.auth_allow_anonymous_access
-def auth_resource_validation_show(context, data_dict):
-    if t.check_access(
-            u'resource_show', context, {u'id': data_dict[u'resource_id']}):
-        return {u'success': True}
-    return {u'success': False}
-
-
-def auth_resource_validation_run_batch(context, data_dict):
-    '''u Sysadmins only'''
-    return {u'success': False}
-
-
 # Actions
 
 

ckanext/validation/logic/auth.py

@@ -0,0 +1,39 @@
+import ckan.plugins.toolkit as tk
+
+
+def get_auth_functions():
+    validators = (
+        resource_validation_run,
+        resource_validation_delete,
+        resource_validation_show,
+        resource_validation_run_batch,
+    )
+
+    return {"{}".format(func.__name__): func for func in validators}
+
+
+def resource_validation_run(context, data_dict):
+    if tk.check_access(u'resource_update', context,
+                       {u'id': data_dict[u'resource_id']}):
+        return {u'success': True}
+    return {u'success': False}
+
+
+def resource_validation_delete(context, data_dict):
+    if tk.check_access(u'resource_update', context,
+                       {u'id': data_dict[u'resource_id']}):
+        return {u'success': True}
+    return {u'success': False}
+
+
+@tk.auth_allow_anonymous_access
+def resource_validation_show(context, data_dict):
+    if tk.check_access(u'resource_show', context,
+                       {u'id': data_dict[u'resource_id']}):
+        return {u'success': True}
+    return {u'success': False}
+
+
+def resource_validation_run_batch(context, data_dict):
+    '''u Sysadmins only'''
+    return {u'success': False}

ckanext/validation/plugin/__init__.py → ckanext/validation/plugin.py

@@ -10,14 +10,7 @@
 
 from ckanext.validation import settings
 from ckanext.validation.model import tables_exist
-from ckanext.validation.logic import (
-    resource_validation_run, resource_validation_show,
-    resource_validation_delete, resource_validation_run_batch,
-    auth_resource_validation_run, auth_resource_validation_show,
-    auth_resource_validation_delete, auth_resource_validation_run_batch,
-    resource_create as custom_resource_create,
-    resource_update as custom_resource_update,
-)
+from .logic import action, auth
 from ckanext.validation.helpers import (
     get_validation_badge,
     validation_extract_report_from_errors,
@@ -82,26 +75,12 @@ def update_config(self, config_):
     # IActions
 
     def get_actions(self):
-        new_actions = {
-            u'resource_validation_run': resource_validation_run,
-            u'resource_validation_show': resource_validation_show,
-            u'resource_validation_delete': resource_validation_delete,
-            u'resource_validation_run_batch': resource_validation_run_batch,
-            u'resource_create': custom_resource_create,
-            u'resource_update': custom_resource_update,
-        }
-
-        return new_actions
+        return action.get_actions()
 
     # IAuthFunctions
 
     def get_auth_functions(self):
-        return {
-            u'resource_validation_run': auth_resource_validation_run,
-            u'resource_validation_show': auth_resource_validation_show,
-            u'resource_validation_delete': auth_resource_validation_delete,
-            u'resource_validation_run_batch': auth_resource_validation_run_batch,
-        }
+        return auth.get_auth_functions()
 
     # ITemplateHelpers