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

optimize websocket

Browse Source
This commit is contained in:
MuslemRahimi 2024-11-26 18:38:56 +01:00
parent 5fc6d84fad
commit 5479976653
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
fastify/app.js
View File

@ -373,20 +373,20 @@ fastify.register(async function (fastify) {
// Only send data if conditions are met and data has changed // Only send data if conditions are met and data has changed
if ( if (
jsonData?.ap != null && jsonData?.lp != null &&
jsonData?.t != null && jsonData?.t != null &&
["Q", "T"].includes(jsonData?.type) && ["Q", "T"].includes(jsonData?.type) &&
connection.socket.readyState === WebSocket.OPEN connection.socket.readyState === WebSocket.OPEN
) { ) {
// Check if the current data is different from the last sent data // Check if the current data is different from the last sent data
const currentDataSignature = `${jsonData.ap}`; const currentDataSignature = `${jsonData.lp}`;
const lastSentSignature = lastSentData[symbol]; const lastSentSignature = lastSentData[symbol];
if (currentDataSignature !== lastSentSignature) { if (currentDataSignature !== lastSentSignature) {
// Collect data to send // Collect data to send
dataToSend.push({ dataToSend.push({
symbol, // Include the ticker symbol in the sent data symbol, // Include the ticker symbol in the sent data
ap: jsonData.ap, lp: jsonData.lp,
}); });
// Update the last sent data for this ticker // Update the last sent data for this ticker
@ -404,6 +404,7 @@ fastify.register(async function (fastify) {
// Send all collected data as a single message // Send all collected data as a single message
if (dataToSend.length > 0 && connection.socket.readyState === WebSocket.OPEN) { if (dataToSend.length > 0 && connection.socket.readyState === WebSocket.OPEN) {
connection.socket.send(JSON.stringify(dataToSend)); connection.socket.send(JSON.stringify(dataToSend));
//console.log(dataToSend)
} }
}; };