AmineTMIRI/frontend
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

ui fix

Browse Source
This commit is contained in:
MuslemRahimi 2025-03-18 16:16:06 +01:00
parent 29c708010c
commit 8c4b1f5dd8
4 changed files with 73 additions and 73 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
package-lock.json generated
View File

@ -34,7 +34,7 @@
"clsx": "^2.1.1",
"cmdk-sv": "^0.0.18",
"compression": "^1.7.4",
"daisyui": "^5.0.4",
"daisyui": "^5.0.6",
"date-fns": "^3.6.0",
"date-fns-tz": "^3.1.3",
"date-picker-svelte": "^2.12.0",
@ -4081,9 +4081,9 @@
"license": "BSD-3-Clause"
},
"node_modules/daisyui": {
"version": "5.0.4",
"resolved": "https://registry.npmjs.org/daisyui/-/daisyui-5.0.4.tgz",
"integrity": "sha512-9X3oX/k9hPBCslAECk8kYfvwgrz6Grs0lN7VI0/ZTM/hUfq1uFREHxCcBCCq0QROpN183N19B1hTNRWGipO2Eg==",
"version": "5.0.6",
"resolved": "https://registry.npmjs.org/daisyui/-/daisyui-5.0.6.tgz",
"integrity": "sha512-/e/9Gw/2y9oawBJlWkJMSEhRXdmfOLvcPl+6q/x2rPEdIVOtebs1t3ex2vwySl9vCRs1GGNBKCiL+P60Ps/wUw==",
"dev": true,
"license": "MIT",
"funding": {

2
package.json
View File

@ -34,7 +34,7 @@
"clsx": "^2.1.1",
"cmdk-sv": "^0.0.18",
"compression": "^1.7.4",
"daisyui": "^5.0.4",
"daisyui": "^5.0.6",
"date-fns": "^3.6.0",
"date-fns-tz": "^3.1.3",
"date-picker-svelte": "^2.12.0",

2
src/lib/components/Table/OptionsFlowTable.svelte
View File

@ -596,7 +596,7 @@
class:opacity-30={index + 1 === rawData?.length &&
data?.user?.tier !== "Pro"}
>
<div class="p-2 text-center text-sm sm:text-[1rem] whitespace-nowrap">
<div class="p-2 text-center text-sm whitespace-nowrap">
{formatTime(displayedData[index]?.time)}
</div>
<div

134
src/routes/options-flow/+page.svelte
View File

@ -500,6 +500,8 @@
let previousVolume = 0; //This is needed to play the sound only if it changes.
let notFound = false;
let isLoaded = false;
let reconnectAttempts = 0;
$: modeStatus = $isOpen === true ? true : false;
function toggleMode() {
@ -512,82 +514,80 @@
shouldLoadWorker.set(true);
}
} else {
toast.error(`Market is closed`, {
toast?.error(`Market is closed`, {
style: `border-radius: 5px; background: #fff; color: #000; border-color: ${$mode === "light" ? "#F9FAFB" : "#4B5563"}; font-size: 15px;`,
});
}
}
async function websocketRealtimeData() {
if (data?.user?.tier === "Pro") {
newData = [];
try {
socket = new WebSocket(data?.wsURL + "/options-flow-reader");
if (data?.user?.tier !== "Pro") return;
socket.addEventListener("message", (event) => {
const totalVolume = displayCallVolume + displayPutVolume;
if (modeStatus === true) {
try {
newData = JSON?.parse(event.data) ?? [];
if (newData?.length > 0) {
newData?.forEach((item) => {
item.dte = daysLeft(item?.date_expiration);
});
//calculateStats(newData);
//console.log(previousVolume);
if (
newData?.length > rawData?.length &&
previousVolume !== totalVolume
) {
//console.log(previousVolume,totalVolume,);
rawData = newData;
shouldLoadWorker.set(true);
//console.log('loading worker')
//displayedData = rawData;
if (!muted) {
audio?.play();
}
}
}
/*
if (previousCallVolume !== displayCallVolume && !muted && audio) {
audio?.play();
}
*/
} catch (e) {
console.error("Error processing WebSocket message:", e);
}
newData = [];
previousVolume = totalVolume;
}
});
socket.addEventListener("close", (event) => {
console.log("WebSocket connection closed:", event.reason);
// Explicitly nullify the socket and remove all event listeners
if (socket) {
socket.onmessage = null;
socket.onopen = null;
socket.onclose = null;
socket.onerror = null;
socket = null;
}
});
socket.addEventListener("error", (error) => {
console.error("WebSocket error:", error);
// Handle WebSocket errors here
});
} catch (error) {
console.error("WebSocket connection error:", error);
// Handle connection errors here
setTimeout(() => websocketRealtimeData(), 400);
// Cleanup previous connection
if (socket) {
socket.onmessage = null;
socket.onclose = null;
socket.onerror = null;
if (socket.readyState === WebSocket.OPEN) {
socket.close();
}
}
try {
socket = new WebSocket(`${data.wsURL}/options-flow-reader`);
socket.onopen = () => {
console.log("WebSocket connected");
reconnectAttempts = 0;
};
socket.onmessage = (event) => {
const totalVolume = displayCallVolume + displayPutVolume;
if (!modeStatus) return;
try {
const newData = JSON.parse(event.data) ?? [];
if (newData.length > 0) {
newData.forEach((item) => {
item.dte = daysLeft(item?.date_expiration);
});
if (
newData.length > rawData.length &&
previousVolume !== totalVolume
) {
rawData = newData;
shouldLoadWorker.set(true);
if (!muted && audio) {
audio.play().catch((error) => {
console.log("Audio play failed:", error);
});
}
}
}
previousVolume = totalVolume;
} catch (e) {
console.error("Message processing error:", e);
}
};
socket.onclose = (event) => {
console.log(`WebSocket closed (${event.code}), reconnecting...`);
const delay = Math.min(5000, reconnectAttempts ** 2 * 500);
setTimeout(websocketRealtimeData, delay);
reconnectAttempts++;
};
socket.onerror = (error) => {
console.error("WebSocket error:", error);
socket.close();
};
} catch (error) {
console.error("WebSocket connection error:", error);
setTimeout(websocketRealtimeData, 1000);
}
}
function daysLeft(targetDate) {