Translate the changes in the head repository

.coveragerc

@@ -0,0 +1,39 @@
+# .coveragerc to control coverage.py
+[run]
+branch = True
+omit =
+    ./docs/*
+    ./docker/*
+    ./examples/*
+    ./grammar/*
+    ./logs/*
+    ./tests/*
+    ./dist/*
+    ./images/*
+    ./output/*
+
+[report]
+# Regexes for lines to exclude from consideration
+exclude_lines =
+    # Have to re-enable the standard pragma
+    pragma: no cover
+
+    # Don't complain about missing debug-only code:
+    def __repr__
+    if self\.debug
+
+    # Don't complain if tests don't hit defensive assertion code:
+    raise AssertionError
+    raise NotImplementedError
+
+    # Don't complain if non-runnable code isn't run:
+    if 0:
+    if __name__ == .__main__.:
+
+    # Don't complain about abstract methods, they aren't run:
+    @(abc\.)?abstractmethod
+
+ignore_errors = True
+
+[html]
+directory = coverage_html_report

.dockerignore

@@ -1,5 +1,5 @@
 .venv/
-doc/
+docs/
 examples/
 test/
 *.jsonld
@@ -8,7 +8,6 @@ tox.ini
 test-requirements.txt
 README.md
 .stestr.conf
-.pre-commit-config.yaml
 .gitignore
 logs/access.log
 .git/

.gitignore

@@ -102,7 +102,6 @@ celerybeat.pid
 *.sage.py
 
 # Environments
-.env
 .venv
 env/
 venv/
@@ -130,8 +129,13 @@ dmypy.json
 
 # IDE
 .idea
+.vscode
 
 # Temporal generated JSON-LD documents
 *.jsonld
 output
 output/*.jsonld
+tests/test1.py
+
+# logs folder
+logs

agent.py

@@ -24,13 +24,14 @@
 from sdmx2jsonld.transform.parser import Parser
 from api.server import launch
 from sdmx2jsonld.exceptions import UnexpectedEOF, UnexpectedInput, UnexpectedToken
+from ngsild.ngsild_connector import NGSILDConnector
 
-if __name__ == '__main__':
+if __name__ == "__main__":
     args = parse_cli()
 
-    if args['run'] is True:
-        file_in = args['--input']
-        generate_files = args['--output']
+    if args["run"] is True:
+        file_in = args["--input"]
+        generate_files = args["--output"]
 
         my_parser = Parser()
 
@@ -43,10 +44,8 @@
         except UnexpectedEOF as e:
             print(e)
 
-    elif args['server'] is True:
-        port = int(args['--port'])
-        host = args['--host']
+    elif args["server"] is True:
+        port = int(args["--port"])
+        host = args["--host"]
 
-        launch(app="api.server:application",
-               host=host,
-               port=port)
+        launch(app="api.server:application", host=host, port=port)

api/custom_logging.py

@@ -30,12 +30,12 @@
 
 class InterceptHandler(Handler):
     loglevel_mapping = {
-        50: 'CRITICAL',
-        40: 'ERROR',
-        30: 'WARNING',
-        20: 'INFO',
-        10: 'DEBUG',
-        0: 'NOTSET',
+        50: "CRITICAL",
+        40: "ERROR",
+        30: "WARNING",
+        20: "INFO",
+        10: "DEBUG",
+        0: "NOTSET",
     }
 
     def emit(self, record):
@@ -49,46 +49,32 @@ def emit(self, record):
             frame = frame.f_back
             depth += 1
 
-        log = logger.bind(request_id='app')
-        log.opt(
-            depth=depth,
-            exception=record.exc_info
-        ).log(level,record.getMessage())
+        log = logger.bind(request_id="app")
+        log.opt(depth=depth, exception=record.exc_info).log(level, record.getMessage())
 
 
 class CustomizeLogger:
-
     @classmethod
     def make_logger(cls, config_path: Path):
-
         config = cls.load_logging_config(config_path)
-        logging_config = config.get('logger')
+        logging_config = config.get("logger")
 
         logger = cls.customize_logging(
-            filepath=logging_config.get('path'),
-            level=logging_config.get('level'),
-            retention=logging_config.get('retention'),
-            rotation=logging_config.get('rotation'),
-            format=logging_config.get('format'))
+            filepath=logging_config.get("path"),
+            level=logging_config.get("level"),
+            retention=logging_config.get("retention"),
+            rotation=logging_config.get("rotation"),
+            format=logging_config.get("format"),
+        )
 
         return logger
 
     @classmethod
-    def customize_logging(cls,
-            filepath: Path,
-            level: str,
-            rotation: str,
-            retention: str,
-            format: str):
+    def customize_logging(cls, filepath: Path, level: str, rotation: str, retention: str, format: str):
 
         logger.remove()
 
-        logger.add(
-            sys.stdout,
-            enqueue=True,
-            backtrace=True,
-            level=level.upper(),
-            format=format)
+        logger.add(sys.stdout, enqueue=True, backtrace=True, level=level.upper(), format=format)
 
         logger.add(
             str(filepath),
@@ -97,12 +83,13 @@ def customize_logging(cls,
             enqueue=True,
             backtrace=True,
             level=level.upper(),
-            format=format)
+            format=format,
+        )
 
         basicConfig(handlers=[InterceptHandler()], level=0)
         getLogger("uvicorn.access").handlers = [InterceptHandler()]
 
-        for _log in ['uvicorn', 'uvicorn.error', 'uvicorn.access', 'fastapi']:
+        for _log in ["uvicorn", "uvicorn.error", "uvicorn.access", "fastapi"]:
             _logger = getLogger(_log)
             _logger.handlers = [InterceptHandler()]
 
@@ -113,4 +100,4 @@ def load_logging_config(cls, config_path):
         config = None
         with open(config_path) as config_file:
             config = load(config_file)
-        return config
+        return config