diff --git a/src/routes/etf/[tickerID]/+layout.svelte b/src/routes/etf/[tickerID]/+layout.svelte index e695ec20..a44f0c0a 100644 --- a/src/routes/etf/[tickerID]/+layout.svelte +++ b/src/routes/etf/[tickerID]/+layout.svelte @@ -197,14 +197,21 @@ let LoginPopup; + /* $: if ($isOpen) { websocketRealtimeData(); } + */ onMount(async () => { if (!data?.user) { LoginPopup = (await import("$lib/components/LoginPopup.svelte")).default; } + + if ($isOpen) { + await websocketRealtimeData(); + console.log("WebSocket restarted"); + } }); afterUpdate(async () => { diff --git a/src/routes/options-flow/+page.svelte b/src/routes/options-flow/+page.svelte index 7213b8f6..a6d03e57 100644 --- a/src/routes/options-flow/+page.svelte +++ b/src/routes/options-flow/+page.svelte @@ -591,10 +591,11 @@ function sendMessage(message) { body: JSON.stringify(postData), }); // make a POST request to the server with the FormData object } - + /* $: if ($isOpen) { websocketRealtimeData(); } + */ onMount(async () => { displayRules = allRows?.filter((row) => @@ -626,6 +627,11 @@ function sendMessage(message) { } isLoaded = true; + + if ($isOpen) { + await websocketRealtimeData(); + console.log("WebSocket restarted"); + } }); onDestroy(async () => { diff --git a/src/routes/stocks/[tickerID]/+layout.svelte b/src/routes/stocks/[tickerID]/+layout.svelte index 2ddd9d06..154d931c 100644 --- a/src/routes/stocks/[tickerID]/+layout.svelte +++ b/src/routes/stocks/[tickerID]/+layout.svelte @@ -204,15 +204,21 @@ } let LoginPopup; - + /* $: if ($isOpen) { websocketRealtimeData(); } + */ onMount(async () => { if (!data?.user) { LoginPopup = (await import("$lib/components/LoginPopup.svelte")).default; } + + if ($isOpen) { + await websocketRealtimeData(); + console.log("WebSocket restarted"); + } }); afterUpdate(async () => { diff --git a/src/routes/watchlist/stocks/+page.svelte b/src/routes/watchlist/stocks/+page.svelte index 4872f36e..8d15514d 100644 --- a/src/routes/watchlist/stocks/+page.svelte +++ b/src/routes/watchlist/stocks/+page.svelte @@ -579,12 +579,12 @@ displayList = [...displayList, ...filteredItem]; } } - + /* $: if ($isOpen) { websocketRealtimeData(); console.log("WebSocket restarted"); } - +*/ onMount(async () => { try { const savedRules = localStorage?.getItem("watchlist-ruleOfList"); @@ -655,6 +655,11 @@ console.log(e); } + if ($isOpen) { + await websocketRealtimeData(); + console.log("WebSocket restarted"); + } + window.addEventListener("scroll", handleScroll); return () => { window.removeEventListener("scroll", handleScroll);