Add first aproach to the validator

Author: chbrandt

tasks/__init__.py

@@ -0,0 +1,50 @@
+import os
+
+
+class TaskBase(object):
+    def __init__(self, **kwargs):
+        print('####################################')
+        print(self.__class__.__name__)
+        print(kwargs)
+        print('####################################')
+        self.config = kwargs['config']
+        self.logger = kwargs['logger']
+
+    def run(self):
+        raise NotImplementedError
+
+
+class TaskVector(TaskBase):
+    def __init__(self, **kwargs):
+        super().__init__(**kwargs)
+
+    def run(self):
+        geo_path = self.config['geo_path']
+        res = os.path.exists(geo_path)
+        self.logger.info('File exist? {}'.format('yes' if res else 'no'))
+        return res
+
+
+class TaskVectorTables(TaskVector):
+    def __init__(self, **kwargs):
+        super().__init__(**kwargs)
+
+    def run(self):
+        import fiona
+        geo_path = self.config['geo_path']
+        layers = fiona.listlayers(geo_path)
+        layers_in_config = self.config['geopackage_tables']
+        res = all([layer in layers_in_config for layer in layers])
+        self.logger.info(f'Do we have the layers? {res!r}')
+        return res
+
+# class TaskVectorTableColumns(TaskBase):
+#     def __init__(self, **kwargs):
+#         super().__init__(**kwargs)
+#
+#
+# class TaskVectorTableColumnsUnits(TaskBase):
+#     table = 'units'
+#     def __init__(self, **kwargs):
+#         super().__init__(**kwargs)
+#

tmp/PM-MAR-MS-Arsinoes_01.zip

@@ -0,0 +1,30 @@
+import os
+import sys
+
+_here = os.path.abspath(__file__)
+sys.path.insert(0, _here)
+
+
+config = {
+    'geo_path': 'tmp/PM-MAR-MS-Arsinoes_01/vector/PM-MAR-MS-Arsinoes_01.gpkg',
+    'geopackage_tables': ['units', 'contacts']
+}
+
+from validator import Validator
+
+def run(config, log_path):
+    validator = Validator(config, log_path)
+    res = validator.run()
+    return res
+
+
+if __name__ == '__main__':
+    from argparse import ArgumentParser
+
+    parser = ArgumentParser()
+    parser.add_argument('--log', default=None, type=str)
+    parser.add_argument('--cfg', default=None, type=str)
+
+    args = parser.parse_args()
+    # res = run(args.cfg, args.log)
+    res = run(config, 'log.log')

validate.py

@@ -0,0 +1 @@
+from .validator import Validator

validator/__init__.py

@@ -0,0 +1,35 @@
+#!/usr/bin/env python
+
+from tasks import *
+
+class Validator(object):
+    tasks = None
+
+    def __init__(self, config, log_path):
+        """
+        * 'config' is a python dict
+        * 'context' is something(?) bringing global info
+        """
+        import logging
+        logger = logging.getLogger('planmap')
+        logger.setLevel('INFO')
+        logger.addHandler(logging.FileHandler(log_path))
+        self.log = logger
+
+        self.config = config
+
+        tasks = [TaskVector, TaskVectorTables]
+        self.tasks = self.set_tasks(tasks)
+
+    def set_tasks(self, tasks):
+        return [t(config=self.config, logger=self.log) for t in tasks]
+
+    def run(self):
+        ok = True
+        for task in self.tasks:
+            res = task.run()
+            if not res:
+                self.log.error(f'Task {task} failed')
+                ok = False
+                break
+        return ok

validator/document/validator.py

@@ -0,0 +1,5 @@
+{
+    "name"= String,
+    "rgb"= String,
+    "geometry"= Polygon
+}