From ffbda52c36d22c467f373499d7e28652985e3291 Mon Sep 17 00:00:00 2001
From: Wolfgang Hottgenroth <wolfgang.hottgenroth@icloud.com>
Date: Sat, 23 Dec 2023 22:57:27 +0100
Subject: [PATCH] migration stuff

---
 migration/.gitignore       |  1 +
 migration/migrate-level.py | 29 +++++++++++++++++++++++++++++
 migration/requirements.txt |  2 ++
 3 files changed, 32 insertions(+)
 create mode 100644 migration/.gitignore
 create mode 100644 migration/migrate-level.py
 create mode 100644 migration/requirements.txt

diff --git a/migration/.gitignore b/migration/.gitignore
new file mode 100644
index 0000000..1d17dae
--- /dev/null
+++ b/migration/.gitignore
@@ -0,0 +1 @@
+.venv
diff --git a/migration/migrate-level.py b/migration/migrate-level.py
new file mode 100644
index 0000000..10113bb
--- /dev/null
+++ b/migration/migrate-level.py
@@ -0,0 +1,29 @@
+import psycopg2
+from loguru import logger
+
+try:
+    srcConn = psycopg2.connect(database="level_monitoring_berresheim")
+    srcConn.autocommit = False
+
+    with srcConn.cursor() as srcCur:
+        srcCur.execute("select time, application_name, raw_level, level, status, battery from measurement_t")
+        for srcObj in srcCur:
+            timestamp = srcObj[0]
+            deviceName = srcObj[1]
+            rawLevel = srcObj[2]
+            level = srcObj[3]
+            status = srcObj[4]
+            battery = srcObj[5]
+
+            logger.info(f"{timestamp=}, {deviceName=}, {rawLevel=}, {level=}, {status=}, {battery=}")
+
+            destTime = timestamp
+            destApplication = "de-hottis-level-monitoring"
+            destDevice = "eui-a84041a2c18341d6"
+            destAttributes = '{"ApplicationId":"de-hottis-level-monitoring", "DeviceType":"dragino-ldds75", "Hint": "Migrated"}'
+            destValues = '{"Battery":{"unit":"V","label":"Battery","value":' + str(battery) + ',"variable":"Voltage"}, "Distance":{"unit":mm","label":"Distance","variable":"Level","value":' + str(rawLevel) + '}, "CorrectedDistance":{"unit":"mm", "label":"CorrectedDistance", "variable":"Level","value":' + str(level) + '}}'
+            logger.info(f"{destTime=}, {destApplication=}, {destDevice=}, {destAttributes=}, {destValues=}")
+finally:
+    if srcConn:
+        srcConn.close()
+
diff --git a/migration/requirements.txt b/migration/requirements.txt
new file mode 100644
index 0000000..fe61e7b
--- /dev/null
+++ b/migration/requirements.txt
@@ -0,0 +1,2 @@
+loguru==0.7.2
+psycopg2==2.9.9