update options page
This commit is contained in:
parent
b1e039c883
commit
f6929ec641
@ -388,6 +388,8 @@ function sendMessage(message) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
async function websocketRealtimeData() {
|
async function websocketRealtimeData() {
|
||||||
|
|
||||||
|
let newData = [];
|
||||||
try {
|
try {
|
||||||
socket = new WebSocket(data?.wsURL + "/options-flow-reader");
|
socket = new WebSocket(data?.wsURL + "/options-flow-reader");
|
||||||
|
|
||||||
@ -401,16 +403,14 @@ async function websocketRealtimeData() {
|
|||||||
previousCallVolume = displayCallVolume ?? 0;
|
previousCallVolume = displayCallVolume ?? 0;
|
||||||
if (mode === true) {
|
if (mode === true) {
|
||||||
try {
|
try {
|
||||||
const newData = JSON.parse(event.data);
|
newData = JSON.parse(event.data) ?? [];
|
||||||
if (rawData?.length !== newData?.length) {
|
if(newData?.length !== 0) {
|
||||||
newIncomingData = true;
|
newData.forEach((item) => {
|
||||||
}
|
|
||||||
|
|
||||||
rawData = [...newData, ...rawData];
|
|
||||||
// Update dte for each item
|
|
||||||
rawData.forEach((item) => {
|
|
||||||
item.dte = daysLeft(item?.date_expiration);
|
item.dte = daysLeft(item?.date_expiration);
|
||||||
});
|
});
|
||||||
|
rawData = [...newData, ...rawData];
|
||||||
|
}
|
||||||
|
|
||||||
if (ruleOfList?.length !== 0 || filterQuery?.length !== 0) {
|
if (ruleOfList?.length !== 0 || filterQuery?.length !== 0) {
|
||||||
shouldLoadWorker.set(true);
|
shouldLoadWorker.set(true);
|
||||||
}
|
}
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user