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

unfinished commit

Browse Source
This commit is contained in:
Nour Alharithi
2023-12-26 10:52:16 -08:00
parent a67a6e80d6
commit b9192e543e
1 changed files with 27 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

32
src/index.ts
View File

@@ -56,9 +56,24 @@ import { RedisClient } from './utils/redisClient';
require('dotenv').config(); require('dotenv').config();
const REDIS_HOST = process.env.REDIS_HOST || 'localhost'; // Reading in Redis env vars
const REDIS_PORT = process.env.REDIS_PORT || '6379'; const REDIS_HOSTS_ENV = process.env.REDIS_HOSTS as string || 'localhost';
const REDIS_PASSWORD = process.env.REDIS_PASSWORD; const REDIS_HOSTS = REDIS_HOSTS_ENV.includes(',')
? REDIS_HOSTS_ENV.trim()
.replace(/^\[|\]$/g, '')
.split(/\s*,\s*/)
: [REDIS_HOSTS_ENV];
const REDIS_PASSWORDS_ENV = process.env.REDIS_HOSTS as string;
const REDIS_PASSWORDS = REDIS_PASSWORDS_ENV.includes(',')
? REDIS_PASSWORDS_ENV.trim()
.replace(/^\[|\]$/g, '')
.split(/\s*,\s*/)
: [REDIS_PASSWORDS_ENV];
if (REDIS_HOSTS.length !== REDIS_PASSWORDS.length) {
throw('REDIS_HOSTS and REDIS_PASSWORDS must be the same length');
}
const REDIS_PORT = '6379';
const driftEnv = (process.env.ENV || 'devnet') as DriftEnv; const driftEnv = (process.env.ENV || 'devnet') as DriftEnv;
const commitHash = process.env.COMMIT; const commitHash = process.env.COMMIT;
@@ -321,10 +336,17 @@ const main = async () => {
); );
let redisClient: RedisClient; let redisClient: RedisClient;
const redisClients: Array<RedisClient> = [];
let redisClientMap:
if (useRedis) { if (useRedis) {
logger.info('Connecting to redis'); logger.info('Connecting to redis');
redisClient = new RedisClient(REDIS_HOST, REDIS_PORT, REDIS_PASSWORD); for (let i = 0; i < REDIS_HOSTS.length; i++) {
await redisClient.connect(); redisClients.push(
new RedisClient(REDIS_HOSTS[i], REDIS_PORT, REDIS_PASSWORDS[i])
);
await redisClients[i].connect();
}
redisClient = redisClients[0];
} }
logger.info(`Initializing all market subscribers...`); logger.info(`Initializing all market subscribers...`);