PortalUpdater Improvements and PackageSync Model

changes/1522.feature

@@ -0,0 +1 @@
+Added `PackageSync` model for the `package_sync` table which tracks the PortalUpdater process and saves the states for the packages.

ckanext/canada/auth.py

@@ -1,5 +1,6 @@
 from ckan.plugins.toolkit import chained_auth_function, config
 from ckan.authz import has_user_permission_for_group_or_org, is_sysadmin
+from ckan.plugins import plugin_loaded
 
 
 def _is_reporting_user(context):
@@ -10,19 +11,19 @@ def _is_reporting_user(context):
 # block datastore-modifying APIs on the portal
 @chained_auth_function
 def datastore_create(up_func, context, data_dict):
-    if 'canada_internal' not in config.get('ckan.plugins'):
+    if not plugin_loaded('canada_internal'):
         return {'success': False}
     return up_func(context, data_dict)
 
 @chained_auth_function
 def datastore_delete(up_func, context, data_dict):
-    if 'canada_internal' not in config.get('ckan.plugins'):
+    if not plugin_loaded('canada_internal'):
         return {'success': False}
     return up_func(context, data_dict)
 
 @chained_auth_function
 def datastore_upsert(up_func, context, data_dict):
-    if 'canada_internal' not in config.get('ckan.plugins'):
+    if not plugin_loaded('canada_internal'):
         return {'success': False}
     return up_func(context, data_dict)
 
@@ -51,3 +52,21 @@ def organization_list(context, data_dict):
 
 def organization_show(context, data_dict):
     return {'success': bool(context.get('user'))}
+
+
+def portal_sync_info(context, data_dict):
+    """
+    Registry users have to be logged in.
+
+    Anyone on public Portal can access.
+    """
+    if plugin_loaded('canada_internal'):
+        return {'success': bool(context.get('user'))}
+    return {'success': True}
+
+
+def list_out_of_sync_packages(context, data_dict):
+    """
+    Only sysadmins can list the out of sync packages.
+    """
+    return {'success': False}