Single-file data updates

• adding debug capabilities to registrar with optional DEBUG flag
• implementing single-file scheme for registration of single files (i.e. fusion data)
• updating helm ingress scheme to v1
• updates in backend

core/registrar/scheme.py

@@ -2,7 +2,7 @@ import re
 from os.path import join, normpath, dirname
 import logging
 from typing import List, Tuple
-import datetime
+from datetime import datetime
 
 from .xml import read_xml, parse_metadata_schema, Parameter
 from .json import read_json
@@ -291,18 +291,19 @@ class STACCollectionScheme(RegistrationScheme):
         return {}
 
 
-class FusionVRTRegistrationScheme(RegistrationScheme):
-    name = "fusion-vrt"
+class SingleFileRegistrationScheme(RegistrationScheme):
+    name = "single-file"
 
-    def __init__(self, footprint: str, product_type: str="FUSION-PRODUCT", level: str='Level-3'):
+    def __init__(self, footprint: str, product_type: str, level: str, date_format: str):
         self.footprint = footprint
         self.product_type = product_type
         self.level = level
+        self.date_format = date_format
 
     def get_context(self, source: Source, path: str) -> List[Context]:
 
-        identifier = self._get_identifier(path)
-        begin_time, end_time = self._get_datetime(path)
+        begin_time, end_time = self._get_datetimes(path)
+        identifier = self._get_identifier(path, begin_time, end_time)
 
         return [
             Context(
@@ -311,36 +312,33 @@ class FusionVRTRegistrationScheme(RegistrationScheme):
                 scheme=self.name,
                 product_type=self.product_type,
                 product_level=self.level,
-                raster_files={"fusion-vrt": path},
+                raster_files={self.name: path},
                 mask_files={},
                 metadata_files=[],
                 metadata={
-                    "begin_time": begin_time,
-                    "end_time": end_time,
+                    "begin_time": isoformat(begin_time),
+                    "end_time": isoformat(end_time),
                     "footprint": self.footprint,
                 }
             )
         ]
 
-    def _get_identifier(self, path: str) -> str:
-        dt = path.split("/")[-1].split(".")[0]
-        id_date = datetime.datetime.strptime(dt, "%Y-%m-%d").strftime('%Y%m%d')
-        return f"fusion_{id_date}"
-
-    def _get_datetime(self, path: str) -> Tuple[str, str]:
+    def _get_identifier(self, path: str, begin_time: datetime, end_time: datetime) -> str:
+        return f"{self.product_type}_{isoformat(begin_time)}_{isoformat(end_time)}"
 
+    def _get_datetimes(self, path: str) -> Tuple[datetime, datetime]:
         dt = path.split("/")[-1].split(".")[0]
-        begin = datetime.datetime.strptime(dt, "%Y-%m-%d")
+        begin = datetime.strptime(dt, self.date_format)
         end = begin.replace(hour=23, minute=59, second=59)
 
-        return isoformat(begin), isoformat(end)
+        return begin, end
 
 
 REGISTRATION_SCHEMES = {
     'gsc': GSCRegistrationScheme,
     'sentinel-2': Sentinel2RegistrationScheme,
     'stac-item': STACCollectionScheme,
-    'fusion-vrt': FusionVRTRegistrationScheme,
+    'single-file': SingleFileRegistrationScheme,
 }