From b4acbad16c2a3b583ac14c02d729c273808e471f Mon Sep 17 00:00:00 2001
From: Martijn Remmen <martijn@pop-os.localdomain>
Date: Fri, 18 Jun 2021 18:40:21 +0200
Subject: [PATCH] AiKompasMessage type toegevoegd en logberichten

---
 functions/Analyzer/__init__.py | 29 +++++++++++++++++++++++++++--
 1 file changed, 27 insertions(+), 2 deletions(-)

diff --git a/functions/Analyzer/__init__.py b/functions/Analyzer/__init__.py
index 3a1ad19..ee49b77 100644
--- a/functions/Analyzer/__init__.py
+++ b/functions/Analyzer/__init__.py
@@ -2,7 +2,32 @@ import logging
 
 import azure.functions as func
 
+from json import dump as jsondump, loads as jsonload
+from dataclasses import dataclass, asdict
+from typing import Optional
+
+
+
+@dataclass(frozen=True)
+class AiKompasMessage:
+    msg_type: int
+    obj_id: Optional[str]
+
+
+    @classmethod
+    def fromServiceBusMessage(cls, msg: func.ServiceBusMessage) -> 'AiKompasMessage':
+        s = msg.get_body().decode('utf-8')
+
+        return AiKompasMessage(**jsonload(s))
+
+
+    def toJson(self) -> str:
+        return jsondump(asdict(self))
+
+
 
 def main(msg: func.ServiceBusMessage):
-    logging.info('Python ServiceBus queue trigger processed message: %s',
-                 msg.get_body().decode('utf-8'))
+    logging.info('[Analyzer] Starting')
+    msg = AiKompasMessage.fromServiceBusMessage(msg)
+
+    logging.info(f'[Analyzer] Received Message with obj_id: {msg.obj_id}')