trade/trade-drift-dlob
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge pull request #292 from drift-labs/master

Browse Source 
master -> staging
This commit is contained in:
moosecat
2024-12-03 14:25:45 -08:00
committed by GitHub
parent 5888585977 cb8dcc7ec2
commit 6b17117c02
1 changed files with 7 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/wsConnectionManager.ts
View File

@@ -107,8 +107,14 @@ async function main() {
const subscribedChannelToSlot: Map<string, number> = new Map(); const subscribedChannelToSlot: Map<string, number> = new Map();
const redisClients: Array<RedisClient> = []; const redisClients: Array<RedisClient> = [];
const lastMessageClients: Array<RedisClient> = [];
for (let i = 0; i < REDIS_CLIENTS.length; i++) { for (let i = 0; i < REDIS_CLIENTS.length; i++) {
const redisClient = new RedisClient({ prefix: REDIS_CLIENTS[i] }); const redisClient = new RedisClient({ prefix: REDIS_CLIENTS[i] });
const lastMessageClient = new RedisClient({ prefix: REDIS_CLIENTS[i] });
await redisClient.connect();
await lastMessageClient.connect();
lastMessageClients.push(lastMessageClient);
redisClients.push(redisClient); redisClients.push(redisClient);
redisClient.forceGetClient().on('connect', () => { redisClient.forceGetClient().on('connect', () => {
@@ -260,7 +266,7 @@ async function main() {
// Fetch and send last message // Fetch and send last message
if (redisChannel.includes('orderbook')) { if (redisChannel.includes('orderbook')) {
const lastMessages = await Promise.all( const lastMessages = await Promise.all(
redisClients.map((redisClient) => lastMessageClients.map((redisClient) =>
redisClient.getRaw( redisClient.getRaw(
`last_update_${redisChannel}`.replace( `last_update_${redisChannel}`.replace(
redisClient.getPrefix(), redisClient.getPrefix(),