bugfixing websocket
This commit is contained in:
parent
80e83b9e14
commit
6162028a68
@ -335,7 +335,7 @@
|
|||||||
|
|
||||||
async function websocketRealtimeData() {
|
async function websocketRealtimeData() {
|
||||||
try {
|
try {
|
||||||
socket = new WebSocket(data?.wsURL + "/multiple-realtime-data");
|
socket = new WebSocket(data?.wsURL + "/price-data");
|
||||||
|
|
||||||
socket.addEventListener("open", () => {
|
socket.addEventListener("open", () => {
|
||||||
console.log("WebSocket connection opened");
|
console.log("WebSocket connection opened");
|
||||||
@ -349,7 +349,6 @@
|
|||||||
try {
|
try {
|
||||||
const newList = JSON?.parse(data);
|
const newList = JSON?.parse(data);
|
||||||
if (newList?.length > 0) {
|
if (newList?.length > 0) {
|
||||||
console.log("Received message:", newList);
|
|
||||||
if (originalData.some((item) => "changesPercentage" in item)) {
|
if (originalData.some((item) => "changesPercentage" in item)) {
|
||||||
originalData = calculateChange(originalData, newList);
|
originalData = calculateChange(originalData, newList);
|
||||||
stockList = updateStockList(stockList, originalData);
|
stockList = updateStockList(stockList, originalData);
|
||||||
|
|||||||
@ -154,7 +154,7 @@
|
|||||||
|
|
||||||
socket.addEventListener("message", (event) => {
|
socket.addEventListener("message", (event) => {
|
||||||
const data = event.data;
|
const data = event.data;
|
||||||
console.log("Received message:", data);
|
//console.log("Received message:", data);
|
||||||
try {
|
try {
|
||||||
const parsedData = JSON.parse(data);
|
const parsedData = JSON.parse(data);
|
||||||
const { type, lp, time, bp, ap, avgPrice } = parsedData?.at(0) || {};
|
const { type, lp, time, bp, ap, avgPrice } = parsedData?.at(0) || {};
|
||||||
|
|||||||
@ -163,7 +163,7 @@
|
|||||||
|
|
||||||
socket.addEventListener("message", (event) => {
|
socket.addEventListener("message", (event) => {
|
||||||
const data = event.data;
|
const data = event.data;
|
||||||
console.log("Received message:", data);
|
//console.log("Received message:", data);
|
||||||
try {
|
try {
|
||||||
const parsedData = JSON.parse(data);
|
const parsedData = JSON.parse(data);
|
||||||
const { type, lp, time, bp, ap, avgPrice } = parsedData?.at(0) || {};
|
const { type, lp, time, bp, ap, avgPrice } = parsedData?.at(0) || {};
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user