add wss back

This commit is contained in:
MuslemRahimi 2024-09-17 14:08:19 +02:00
parent 13c86dbd77
commit fc93259f1e
4 changed files with 11 additions and 11 deletions

View File

@ -305,7 +305,7 @@ onMount(async () => {
//const endTime = currentDateTime.set({ hour: 22, minute: 0 });
// Check if it's not a weekend and the current time is within the specified range
//await websocketRealtimeData()
await websocketRealtimeData()
// Add a scroll event listener

View File

@ -314,12 +314,12 @@ async function fetchPortfolio()
//const endTime = currentDateTime.set({ hour: 22, minute: 0 });
// Check if it's not a weekend and the current time is within the specified range
/*
if ($isOpen) //&& currentDateTime > startTime && currentDateTime < endTime
{
await websocketRealtimeData()
}
*/
// Add a scroll event listener
window.addEventListener('scroll', handleScroll);

View File

@ -374,11 +374,12 @@ async function websocketRealtimeData() {
let newData = [];
try {
socket = new WebSocket(data?.wsURL + "/options-flow-reader");
/*
socket.addEventListener("open", () => {
const ids = rawData.map(item => item.id);
sendMessage(JSON.stringify({ ids }));
});
*/
socket.addEventListener('message', (event) => {
previousCallVolume = displayCallVolume ?? 0;
@ -389,14 +390,14 @@ async function websocketRealtimeData() {
newData.forEach((item) => {
item.dte = daysLeft(item?.date_expiration);
});
rawData = [...newData, ...rawData];
rawData = newData;
}
if (ruleOfList?.length !== 0 || filterQuery?.length !== 0) {
shouldLoadWorker.set(true);
}
if (previousCallVolume !== displayCallVolume && !muted && audio) {
audio.play();
audio?.play();
}
} catch (e) {
console.error('Error processing WebSocket message:', e);
@ -463,11 +464,10 @@ function daysLeft(targetDate) {
});
isLoaded = true;
/*
if ($isOpen) {
await websocketRealtimeData();
}
*/

View File

@ -226,12 +226,12 @@ async function fetchPortfolio()
//SellTrade = (await import('$lib/components/SellTrade.svelte')).default;
PriceAlert = (await import("$lib/components/PriceAlert.svelte")).default;
}
/*
if ($isOpen) {
//&& currentDateTime > startTime && currentDateTime < endTime
await websocketRealtimeData();
}*/
}
});
afterUpdate(async () => {