[DATAVIC-559] replaced xloader wrapper with datapusher plus

Author: awset

ckanext/datavic_odp_theme/plugin.py

@@ -10,7 +10,7 @@
 from ckan import model, types
 
 from ckanext.search_autocomplete.interfaces import ISearchAutocomplete
-from ckanext.xloader.plugin import xloaderPlugin
+from ckanext.datapusher_plus.plugin import DatapusherPlusPlugin
 
 from ckanext.datavic_odp_theme.logic import auth_functions, actions, get_validators
 from ckanext.datavic_odp_theme.views import get_blueprints
@@ -183,7 +183,7 @@ class DatavicODPThemeAuth(p.SingletonPlugin):
     pass
 
 
-class DatavicXLoaderPlugin(xloaderPlugin, p.SingletonPlugin):
+class DatavicDatapusherPlusPlugin(DatapusherPlusPlugin, p.SingletonPlugin):
     p.implements(p.IPackageController, inherit=True)
 
     # IPackageController
@@ -212,11 +212,11 @@ def after_dataset_update(self, context, pkg_dict):
                 group.add_package_by_name(pkg_dict.get('name'))
 
     def _submit_new_resources_only(self, pkg_dict):
-        """Submit only newly added resources to xloader during dataset update.
+        """Submit only newly added resources to datapusher during dataset update.
 
         Compares current resource IDs against the previous activity snapshot
         to detect new resources. URL changes for existing resources are
-        handled by the parent xloaderPlugin via ``notify()``.
+        handled by the parent DatapusherPlusPlugin via ``notify()``.
 
         Falls back to submitting all resources if no activity data is
         available (e.g. activity plugin disabled, data migration).
@@ -289,7 +289,7 @@ def _infer_format_and_submit(self, resource):
                 resource["format"] = (
                     url_without_params.split(".")[-1].lower()
                 )
-        self._submit_to_xloader(resource)
+        self._submit_to_datapusher(resource)
 
     def _trigger_after_resource_create(self, pkg_dict):
         """Submit all resources after dataset creation.
@@ -300,15 +300,15 @@ def _trigger_after_resource_create(self, pkg_dict):
         for resource in pkg_dict.get("resources", []):
             self._infer_format_and_submit(resource)
 
-    def _submit_to_xloader(self, resource_dict):
+    def _submit_to_datapusher(self, resource_dict):
         """Wrapper that ensures ``url_type`` and ``format`` are present
         before calling the parent, as they may be missing for resources
         created inline via ``package_create``/``package_update``.
         """
-        resource_dict.setdefault("url_type", "datavic_xloader")
+        resource_dict.setdefault("url_type", "datavic_datapusher")
         resource_dict.setdefault("format", "")
 
-        super()._submit_to_xloader(resource_dict)
+        super()._submit_to_datapusher(resource_dict)
 
-        if resource_dict["url_type"] == "datavic_xloader":
+        if resource_dict["url_type"] == "datavic_datapusher":
             resource_dict.pop("url_type")

setup.py

@@ -63,7 +63,7 @@
         [ckan.plugins]
         datavic_odp_theme=ckanext.datavic_odp_theme.plugin:DatavicODPTheme
         datavic_odp_theme_auth=ckanext.datavic_odp_theme.plugin:DatavicODPThemeAuth
-        datavic_odp_xloader=ckanext.datavic_odp_theme.plugin:DatavicXLoaderPlugin
+        datavic_odp_datapusher_plus=ckanext.datavic_odp_theme.plugin:DatavicDatapusherPlusPlugin
 
         [babel.extractors]
         ckan = ckan.lib.extract:extract_ckan