From 1af24ec844f5ef87c814bf578af8398353fe0070 Mon Sep 17 00:00:00 2001
From: MuslemRahimi <moslem_rahimi@hotmail.de>
Date: Tue, 10 Dec 2024 16:39:56 +0100
Subject: [PATCH] bugfixing websocket

---
 src/lib/components/Table/Table.svelte    | 10 +++++-----
 src/routes/watchlist/stocks/+page.svelte |  9 +++++----
 2 files changed, 10 insertions(+), 9 deletions(-)

diff --git a/src/lib/components/Table/Table.svelte b/src/lib/components/Table/Table.svelte
index 4b2d1288..b3bb1a31 100644
--- a/src/lib/components/Table/Table.svelte
+++ b/src/lib/components/Table/Table.svelte
@@ -409,12 +409,12 @@
 
   $: stockList = [...stockList];
 
+  $: if ($isOpen) {
+    websocketRealtimeData();
+    console.log("WebSocket restarted");
+  }
+
   onMount(async () => {
-    // Initialize the download worker if not already done
-    if ($isOpen) {
-      await websocketRealtimeData();
-      console.log("WebSocket restarted due to watchlist changes");
-    }
     try {
       const savedRules = localStorage?.getItem(pagePathName);
 
diff --git a/src/routes/watchlist/stocks/+page.svelte b/src/routes/watchlist/stocks/+page.svelte
index 5b86d6e2..2d9a8c29 100644
--- a/src/routes/watchlist/stocks/+page.svelte
+++ b/src/routes/watchlist/stocks/+page.svelte
@@ -580,6 +580,11 @@
     }
   }
 
+  $: if ($isOpen) {
+    websocketRealtimeData();
+    console.log("WebSocket restarted");
+  }
+
   onMount(async () => {
     try {
       const savedRules = localStorage?.getItem("watchlist-ruleOfList");
@@ -648,10 +653,6 @@
       console.log(e);
     }
 
-    if ($isOpen) {
-      await websocketRealtimeData();
-    }
-
     window.addEventListener("scroll", handleScroll);
     return () => {
       window.removeEventListener("scroll", handleScroll);