feat: Enhance plugin integration and time range handling in RegistryUIManager

Author: dwr-psandhu

dvue/cli.py

@@ -77,9 +77,10 @@ def ui_command(files, plugins, port, desktop):
     """
     import importlib
 
+    plugin_modules = []
     for module_name in plugins:
         try:
-            importlib.import_module(module_name)
+            plugin_modules.append(importlib.import_module(module_name))
         except ImportError as exc:
             raise click.ClickException(
                 f"Could not import plugin module {module_name!r}: {exc}"
@@ -88,13 +89,24 @@ def ui_command(files, plugins, port, desktop):
     from dvue.registry_ui import RegistryUIManager
     from dvue.session_persistence import serve_session_app, serve_desktop_app
 
+    manager_cls = RegistryUIManager
+    effective_crs = None
+    for mod in plugin_modules:
+        # Optional plugin hook: module-level manager override.
+        # Last plugin wins when multiple plugins provide this symbol.
+        if hasattr(mod, "DVueUIManager"):
+            manager_cls = getattr(mod, "DVueUIManager")
+        # Optional plugin hook: module-level map CRS override.
+        if hasattr(mod, "DVueUI_CRS"):
+            effective_crs = getattr(mod, "DVueUI_CRS")
+
     file_list = list(files)
 
     def build_manager():
-        return RegistryUIManager(files=file_list)
+        return manager_cls(files=file_list)
 
     _serve = serve_desktop_app if desktop else serve_session_app
-    _serve(build_manager, title="dvue UI", port=port)
+    _serve(build_manager, title="dvue UI", port=port, crs=effective_crs)
 
 
 if __name__ == "__main__":

dvue/registry_ui.py

@@ -181,11 +181,16 @@ def normalize_ref(self, ref: "DataReference") -> None:
     def on_file_added(self, path: str, refs: List["DataReference"]) -> None:
         """Hook called after a file's refs have been successfully added.
 
-        Override to perform file-level side effects such as expanding
-        ``self.time_range``, loading geometry from a companion file, or
-        registering the source in an external index.
+        Default implementation: expands ``self.time_range`` to cover the
+        data extent of any newly added refs.  Readers declare their data's
+        time extent by storing ``time_extent_start`` and ``time_extent_end``
+        attributes (ISO-8601 strings or any ``pd.Timestamp``-coercible value)
+        on each :class:`~dvue.catalog.DataReference`.
 
-        The default is a no-op.
+        Subclasses that need additional side-effects (loading geometry,
+        registering external indices, etc.) should call
+        ``super().on_file_added(path, refs)`` so that time_range expansion
+        still happens.
 
         Parameters
         ----------
@@ -195,6 +200,37 @@ def on_file_added(self, path: str, refs: List["DataReference"]) -> None:
             All refs returned by ``ReaderRegistry.scan(path)`` for this file
             (including any that were skipped due to pk collisions).
         """
+        starts = []
+        ends = []
+        seen: set = set()
+        for ref in refs:
+            s = ref._attributes.get("time_extent_start")
+            e = ref._attributes.get("time_extent_end")
+            key = (s, e)
+            if key in seen or not s:
+                continue
+            seen.add(key)
+            try:
+                starts.append(pd.Timestamp(s))
+            except Exception:
+                pass
+            if e:
+                try:
+                    ends.append(pd.Timestamp(e))
+                except Exception:
+                    pass
+        if not starts:
+            return
+        new_start = min(starts)
+        new_end = max(ends) if ends else new_start + pd.Timedelta(days=366)
+        current = self.time_range
+        if current is None:
+            self.time_range = (new_start, new_end)
+        else:
+            self.time_range = (
+                min(current[0], new_start),
+                max(current[1], new_end),
+            )
 
     # ------------------------------------------------------------------
     # Geo / map integration