reverting back

This commit is contained in:
MuslemRahimi 2024-09-16 22:35:32 +02:00
parent 051849eaab
commit ab5b5720af
6 changed files with 65 additions and 98 deletions

View File

@ -24,7 +24,6 @@ const fetchData = async (apiURL, apiKey, endpoint, ticker) => {
}; };
const fetchWatchlist = async (fastifyURL, userId) => { const fetchWatchlist = async (fastifyURL, userId) => {
try {
const postData = { userId: userId }; const postData = { userId: userId };
const response = await fetch(fastifyURL + "/all-watchlists", { const response = await fetch(fastifyURL + "/all-watchlists", {
method: "POST", method: "POST",
@ -36,10 +35,6 @@ const fetchWatchlist = async (fastifyURL, userId) => {
const output = (await response.json())?.items; const output = (await response.json())?.items;
return output; return output;
} catch (e) {
console.log(e);
return [];
}
}; };
/* /*

View File

@ -318,36 +318,32 @@ onMount(async () => {
}); });
afterUpdate( async () => { afterUpdate( async () => {
if (previousTicker !== $cryptoTicker && typeof socket !== "undefined") {
if(previousTicker !== $cryptoTicker && typeof socket !== 'undefined')
{
previousTicker = $cryptoTicker; previousTicker = $cryptoTicker;
//socket.send('close') //socket.send('close')
if (socket?.readyState === WebSocket?.OPEN) {
socket?.close(); socket?.close();
}
await new Promise((resolve, reject) => { await new Promise((resolve, reject) => {
socket?.addEventListener("close", resolve); socket?.addEventListener('close', resolve);
}); });
if (socket?.readyState === WebSocket?.CLOSED) { if(socket?.readyState === WebSocket?.CLOSED)
await websocketRealtimeData(); {
console.log("connecting again"); await websocketRealtimeData()
console.log('connecting again')
} }
} }
}); });
onDestroy(() => { onDestroy(() => {
try { try {
//socket?.send('close') //socket?.send('close')
if (socket && typeof socket !== "undefined") { socket?.close()
if (socket.readyState === WebSocket.OPEN) {
socket?.close(); // Close the WebSocket connection
}
socket = null; // Ensure socket is set to null
}
} }
catch(e) { catch(e) {
console.log(e) console.log(e)
@ -357,11 +353,13 @@ onMount(async () => {
$currentPortfolioPrice = null; $currentPortfolioPrice = null;
$currentPrice = null; $currentPrice = null;
$priceIncrease = null; $priceIncrease = null;
//$traded = false $traded = false
}); });
$: { $: {
if ($cryptoTicker && $cryptoTicker?.length !== 0 && typeof window !== 'undefined') // add a check to see if running on client-side if ($cryptoTicker && $cryptoTicker?.length !== 0 && typeof window !== 'undefined') // add a check to see if running on client-side
{ {

View File

@ -31,7 +31,6 @@ const fetchData = async (apiURL, apiKey, endpoint, ticker) => {
}; };
const fetchFromFastify = async (fastifyURL, endpoint, userId) => { const fetchFromFastify = async (fastifyURL, endpoint, userId) => {
try {
const response = await fetch(`${fastifyURL}${endpoint}`, { const response = await fetch(`${fastifyURL}${endpoint}`, {
method: "POST", method: "POST",
headers: { "Content-Type": "application/json" }, headers: { "Content-Type": "application/json" },
@ -39,10 +38,6 @@ const fetchFromFastify = async (fastifyURL, endpoint, userId) => {
}); });
const { items } = await response.json(); const { items } = await response.json();
return items; return items;
} catch (e) {
console.log(e);
return [];
}
}; };
export const load = async ({ params, locals, setHeaders }) => { export const load = async ({ params, locals, setHeaders }) => {

View File

@ -336,9 +336,7 @@ async function fetchPortfolio()
{ {
previousTicker = $etfTicker; previousTicker = $etfTicker;
//socket.send('close') //socket.send('close')
if (socket.readyState === WebSocket.OPEN) { socket?.close();
socket?.close(); // Close the WebSocket connection
}
await new Promise((resolve, reject) => { await new Promise((resolve, reject) => {
socket.addEventListener('close', resolve); socket.addEventListener('close', resolve);
}); });
@ -357,12 +355,7 @@ async function fetchPortfolio()
onDestroy(() => { onDestroy(() => {
try { try {
//socket?.send('close') //socket?.send('close')
if (socket && typeof socket !== "undefined") { socket?.close()
if (socket.readyState === WebSocket.OPEN) {
socket?.close(); // Close the WebSocket connection
}
socket = null; // Ensure socket is set to null
}
} }
catch(e) { catch(e) {
console.log(e) console.log(e)

View File

@ -31,7 +31,6 @@ const fetchData = async (apiURL, apiKey, endpoint, ticker) => {
}; };
const fetchFromFastify = async (fastifyURL, endpoint, userId) => { const fetchFromFastify = async (fastifyURL, endpoint, userId) => {
try {
const response = await fetch(`${fastifyURL}${endpoint}`, { const response = await fetch(`${fastifyURL}${endpoint}`, {
method: "POST", method: "POST",
headers: { "Content-Type": "application/json" }, headers: { "Content-Type": "application/json" },
@ -39,10 +38,6 @@ const fetchFromFastify = async (fastifyURL, endpoint, userId) => {
}); });
const { items } = await response.json(); const { items } = await response.json();
return items; return items;
} catch (e) {
console.log(e);
return [];
}
}; };
const fetchCommunitySentiment = async (pb, ticker, cookies) => { const fetchCommunitySentiment = async (pb, ticker, cookies) => {

View File

@ -237,10 +237,7 @@ async function fetchPortfolio()
if (previousTicker !== $stockTicker && typeof socket !== "undefined") { if (previousTicker !== $stockTicker && typeof socket !== "undefined") {
previousTicker = $stockTicker; previousTicker = $stockTicker;
//socket.send('close') //socket.send('close')
if (socket?.readyState === WebSocket?.OPEN) {
socket?.close(); socket?.close();
}
await new Promise((resolve, reject) => { await new Promise((resolve, reject) => {
socket?.addEventListener("close", resolve); socket?.addEventListener("close", resolve);
}); });
@ -255,15 +252,9 @@ async function fetchPortfolio()
onDestroy(() => { onDestroy(() => {
try { try {
//socket?.send('close') //socket?.send('close')
if (socket && typeof socket !== "undefined") { socket?.close();
if (socket.readyState === WebSocket.OPEN) { } catch (e) {
socket?.close(); // Close the WebSocket connection console.log(e);
}
socket = null; // Ensure socket is set to null
}
}
catch(e) {
console.log(e)
} }
//$displayCompanyName = ''; //$displayCompanyName = '';