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

add realtime options flow back

Browse Source
This commit is contained in:
MuslemRahimi 2024-10-18 16:34:55 +02:00
parent 677359ad80
commit 7e8400564c
1 changed files with 14 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -344,6 +344,12 @@ let rawData = data?.getOptionsFlowFeed?.filter(item =>
{ {
if ($isOpen) { if ($isOpen) {
mode = !mode; mode = !mode;
if(mode === true && selectedDate !== undefined) {
selectedDate = undefined;
rawData = data?.getOptionsFlowFeed
displayedData = [...rawData];
shouldLoadWorker.set(true);
}
} }
else { else {
toast.error(`Market is closed`, { toast.error(`Market is closed`, {
@ -422,7 +428,10 @@ async function websocketRealtimeData() {
newData.forEach((item) => { newData.forEach((item) => {
item.dte = daysLeft(item?.date_expiration); item.dte = daysLeft(item?.date_expiration);
}); });
if(newData?.length > rawData?.length) {
rawData = newData; rawData = newData;
displayedData = rawData;
}
} }
if (ruleOfList?.length !== 0 || filterQuery?.length !== 0) { if (ruleOfList?.length !== 0 || filterQuery?.length !== 0) {
@ -510,11 +519,11 @@ async function saveCookieRuleOfList() {
} }
isLoaded = true; isLoaded = true;
/*
if ($isOpen) { if ($isOpen) {
await websocketRealtimeData(); await websocketRealtimeData();
} }
*/
@ -667,6 +676,8 @@ function calculateStats(data) {
const getHistoricalFlow = async () => { const getHistoricalFlow = async () => {
// Create a delay using setTimeout wrapped in a Promise // Create a delay using setTimeout wrapped in a Promise
if(data?.user?.tier === 'Pro') { if(data?.user?.tier === 'Pro') {
mode = false;
isLoaded = false; isLoaded = false;
displayRules = allRows?.filter(row => ruleOfList.some(rule => rule.name === row.rule)); displayRules = allRows?.filter(row => ruleOfList.some(rule => rule.name === row.rule));