Added handling for last_update messages
This commit is contained in:
@@ -166,12 +166,17 @@ async function main() {
|
|||||||
|
|
||||||
// Fetch and send last message
|
// Fetch and send last message
|
||||||
if (redisChannel.includes('orderbook')) {
|
if (redisChannel.includes('orderbook')) {
|
||||||
|
const lastUpdateChannel = `last_update_${redisChannel}`;
|
||||||
const lastMessage = await lastMessageRetriever.client.get(
|
const lastMessage = await lastMessageRetriever.client.get(
|
||||||
`last_update_${redisChannel}`
|
lastUpdateChannel
|
||||||
);
|
);
|
||||||
|
|
||||||
if (lastMessage !== null) {
|
if (lastMessage !== null) {
|
||||||
ws.send(
|
ws.send(
|
||||||
JSON.stringify({ channel: redisChannel, data: lastMessage })
|
JSON.stringify({
|
||||||
|
channel: lastUpdateChannel,
|
||||||
|
data: lastMessage,
|
||||||
|
})
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user