Init logic for mapping

pyproject.toml

@@ -26,6 +26,7 @@ requires-python = '>=3.10, <4'
 dependencies = [
     'fastapi',
     'Jinja2',
+    'rdflib',
 ]
 
 [project.urls]

requirements.dev.txt

@@ -0,0 +1 @@
+uvicorn

requirements.txt

@@ -2,10 +2,14 @@ annotated-types==0.6.0
 anyio==3.7.1
 fastapi==0.104.1
 idna==3.4
+isodate==0.6.1
 Jinja2==3.1.2
 MarkupSafe==2.1.3
 pydantic==2.4.2
 pydantic_core==2.10.1
+pyparsing==3.1.1
+rdflib==7.0.0
+six==1.16.0
 sniffio==1.3.0
 starlette==0.27.0
 typing_extensions==4.8.0

run.sh

@@ -0,0 +1,5 @@
+#!/usr/bin/env bash
+
+export $(grep -v '^#' .env | xargs)
+
+uvicorn fip2dmp_importer:app --reload

src/smp_importer/logic.py

@@ -0,0 +1,40 @@
+class _MappingExecutor:
+
+    def __init__(self):
+        self.result = []
+        self.variables = {}
+
+    def reset(self):
+        self.result = []
+        self.variables = {}
+
+    def result_add(self, action: str, **kwargs):
+        self.result.append({
+            'type': action,
+            **kwargs,
+        })
+
+    def result_debug(self, message: str):
+        self.result_add(action='debug', message=message)
+
+    def result_add_item(self, path: str, var_name: str):
+        self.result_add(action='addItem', path=path.split('.'), var=var_name)
+
+    def result_set_reply(self, path: str, value: str):
+        self.result_add(action='setReply', path=path.split('.'), value=value)
+
+    def result_set_integration_reply(self, path: str, value: str, item_id):
+        self.result_add(action='setIntegrationReply', path=path.split('.'), value=value, itemId=item_id)
+
+    def get_result_dict(self):
+        return {
+            'actions': self.result,
+        }
+
+
+def prepare_import_mapping(contents: str, content_type: str) -> dict:
+        executor = _MappingExecutor()
+
+        # TODO: process contents in custom functions, etc.
+
+        return executor.get_result_dict()