From 542ea2fdf166284816ef3a3bc9c8ec31106438aa Mon Sep 17 00:00:00 2001
From: Makussu <maximilian@ruhm.info>
Date: Sun, 2 Jun 2024 17:22:54 +0200
Subject: [PATCH] correct sessionid

---
 routes/reset.js        | 15 +++++----------
 routes/transactions.js |  4 ----
 2 files changed, 5 insertions(+), 14 deletions(-)

diff --git a/routes/reset.js b/routes/reset.js
index fbe27d7..bbe5c7a 100644
--- a/routes/reset.js
+++ b/routes/reset.js
@@ -33,18 +33,13 @@ async function mysse(req, res) {
 
     // Tell the client to retry every 10 seconds if connectivity is lost
     res.write('retry: 10000\n\n');
-    update.set(Math.random(), res)
+    update.set(req.sessionId, res)
     console.log("connected")
-    res.write("data: update\n\n")
-    // while (true ) {
-    //     await new Promise(resolve => setTimeout(resolve, 1000));
 
-    //     // console.log('Emit', ++count);
-    //     // Emit an SSE that contains the current 'count' as a string
-    //     res.write(`data: ${update}\n\n`);
-    //     // update = false;
-        
-    // }
+    res.on("close", () => {
+        update.delete(req.sessionId)
+        res.end()
+    })
 };
 
 function set_update() {
diff --git a/routes/transactions.js b/routes/transactions.js
index 36cb706..df2b054 100644
--- a/routes/transactions.js
+++ b/routes/transactions.js
@@ -34,7 +34,6 @@ router.post("/", (req, res) => {
         // res.write("data: update\n\n")
         res.write('event: update\n');
         res.write('data: {}\n\n');
-
     }
 
 })
@@ -61,10 +60,8 @@ router.put("/:id", (req, res) => {
 
     res.status(204).send()
     for (res of update.values()) {
-        // res.write("data: update\n\n")
         res.write('event: update\n');
         res.write('data: {}\n\n');
-
     }
 
 })
@@ -79,7 +76,6 @@ router.delete("/:id", (req, res) => {
         // res.write("data: update\n\n")
         res.write('event: update\n');
         res.write('data: {}\n\n');
-
     }
 
 })