Registration routes

Adding implementation routes

A Route is bound to a queue and operates on a particular data-type (such as STAC Item, Collection, paths, arbitrary JSON structures).

Backends are also now generic according to its datatype and are now part of the route.

Each route also encapsulates the pre, post, and error handlers.

Example configuration:

routes:
  items:
    path: registrar.route.stac.ItemRoute
    queue: register
    output_queue: next_queue
    backends:
      - path: registrar.backend.eoxserver.ItemBackend
        kwargs:
          instance_base_path: /some/dir
          instance_name: name

    handlers:
      pre:
        - path: some.pre.handler
      post:
        - path: some.post.handler
      error:
        - path: some.error.handler

  collections:
    path: registrar.route.stac.CollectionRoute
    queue: register-collections
    backends:
      - path: registrar.backend.eoxserver.CollectionBackend

  path:
    path: registrar.route.path.PathRoute
    queue: register-paths
    backends:
      - path: some.path.backend

sources: [...]

This is how a STAC Item route can be implemented:

import json
import pystac

class ItemRoute(Route[pystac.Item]):
    """A route implementation for STAC Items"""

    def parse(self, raw: str) -> pystac.Item:
        return pystac.Item.from_dict(json.loads(raw))

    def get_source(
        self, source_cfgs: List[SourceConfig], item: pystac.Item
    ) -> Optional[Source]:
        return get_source(
            source_cfgs, [asset.href for asset in item.assets.values()]
        )

This is how the Backend interface can be satisfied:

from pystac import Item

# ...

class MyItemBackend(Backend[Item]):
    def exists(self, source: Optional[Source], item: Item) -> bool:
        ...

    def register(self, source: Optional[Source], item: Item, replace: bool):
        ...

    def deregister(self, source: Optional[Source], item: Item):
        ...

    def deregister_identifier(self, identifier: str):
        ...

registrar/backend/eoxserver.py

@@ -60,7 +60,7 @@ class ItemToProductTypeMapping(TypedDict):
     collections: List[str]
 
 
-class EOxServerBackend(Backend["Item"]):
+class ItemBackend(Backend["Item"]):
     """
     EOxServer backend allows registration to be performed on a running
     EOxServer instance
@@ -337,7 +337,7 @@ class EOxServerBackend(Backend["Item"]):
         return product
 
     @transaction.atomic
-    def register_item(self, source: Optional[Source], item: "Item", replace: bool):
+    def register(self, source: Optional[Source], item: "Item", replace: bool):
         """Registers the item to the endpoint
 
         Args:
@@ -396,8 +396,13 @@ class EOxServerBackend(Backend["Item"]):
         else:
             raise RegistrationError(f"{item} not matched to any product_type")
 
+    def deregister(self, source: Optional[Source], item: "Item"):
+        """ Defers to ``deregister_identifier`` with the items identifier
+        """
+        return self.deregister_identifier(item.id)
+
     @transaction.atomic
-    def deregister_identifier(self, identifier: str) -> Optional[str]:
+    def deregister_identifier(self, identifier: str):
         """Attempts to deregister item
 
         Args: