From 036384d9cacb56d8c3bde93c1479777503b09d24 Mon Sep 17 00:00:00 2001
From: Daniel <daniel94nagel@gmail.com>
Date: Sat, 6 Sep 2025 09:45:17 +0000
Subject: [PATCH] data_worker

---
 data_worker.js | 29 +++++++++++++++++++++++++++++
 1 file changed, 29 insertions(+)
 create mode 100644 data_worker.js

diff --git a/data_worker.js b/data_worker.js
new file mode 100644
index 0000000..18ad5ec
--- /dev/null
+++ b/data_worker.js
@@ -0,0 +1,29 @@
+import Redis from "ioredis";
+
+// Verbindung zu Redis herstellen
+const redis = new Redis({
+  host: "data_jobs",   // Dein Redis-Containername
+  port: 6379
+});
+
+// Endlosschleife: Immer auf neue Jobs warten
+async function startWorker() {
+  console.log("Worker gestartet – warte auf Jobs...");
+
+  while (true) {
+    // BLPOP = Warte auf Job in der Queue "grist:jobs"
+    const job = await redis.blpop("grist:jobs", 0);
+    const payload = job[1]; // [0] = Queue-Name, [1] = Daten
+
+    console.log("Job empfangen:", payload);
+
+    // Ergebnis vorbereiten
+    const result = `Bearbeitet: ${payload}`;
+
+    // Ergebnis in andere Queue schreiben
+    await redis.rpush("grist:results", result);
+    console.log("Ergebnis gespeichert:", result);
+  }
+}
+
+startWorker();