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

switch over more redis clients to drift common clients

Browse Source
This commit is contained in:
Nour Alharithi
2024-10-24 13:46:47 -07:00
parent 2aaa6a50c6
commit 61e6854f30
6 changed files with 9 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/dlob-subscriber/DLOBSubscriberIO.ts
View File

@@ -9,7 +9,7 @@ import {
isOperationPaused, isOperationPaused,
isVariant, isVariant,
} from '@drift-labs/sdk'; } from '@drift-labs/sdk';
import { RedisClient } from '@drift/common'; import { RedisClient } from '@drift/common/clients';
import { logger } from '../utils/logger'; import { logger } from '../utils/logger';
import { import {
SubscriberLookup, SubscriberLookup,

2
src/publishers/dlobPublisher.ts
View File

@@ -19,7 +19,7 @@ import {
SpotMarketConfig, SpotMarketConfig,
PhoenixSubscriber, PhoenixSubscriber,
} from '@drift-labs/sdk'; } from '@drift-labs/sdk';
import { RedisClient, RedisClientPrefix } from '@drift/common'; import { RedisClient, RedisClientPrefix } from '@drift/common/clients';
import { logger, setLogLevel } from '../utils/logger'; import { logger, setLogLevel } from '../utils/logger';
import { import {

2
src/publishers/priorityFeesPublisher.ts
View File

@@ -10,7 +10,7 @@ import {
BulkAccountLoader, BulkAccountLoader,
getMarketsAndOraclesForSubscription, getMarketsAndOraclesForSubscription,
} from '@drift-labs/sdk'; } from '@drift-labs/sdk';
import { RedisClient, RedisClientPrefix } from '@drift/common'; import { RedisClient, RedisClientPrefix } from '@drift/common/clients';
import { logger, setLogLevel } from '../utils/logger'; import { logger, setLogLevel } from '../utils/logger';
import { sleep } from '../utils/utils'; import { sleep } from '../utils/utils';

2
src/publishers/tradesPublisher.ts
View File

@@ -20,7 +20,7 @@ import {
OrderActionRecord, OrderActionRecord,
Event, Event,
} from '@drift-labs/sdk'; } from '@drift-labs/sdk';
import { RedisClient, RedisClientPrefix } from '@drift/common'; import { RedisClient, RedisClientPrefix } from '@drift/common/clients';
import { logger, setLogLevel } from '../utils/logger'; import { logger, setLogLevel } from '../utils/logger';
import { sleep } from '../utils/utils'; import { sleep } from '../utils/utils';

7
src/scripts/publishUnsettledPnlUsers.ts
View File

@@ -1,4 +1,5 @@
import { RedisClient, RedisClientPrefix, sleep } from '@drift/common'; import { RedisClient, RedisClientPrefix } from '@drift/common/clients';
import { sleep } from '@drift/common';
import { import {
BigNum, BigNum,
DriftClient, DriftClient,
@@ -156,7 +157,7 @@ const writeToDlobRedis = async (userPnlMap: UserPnlMap): Promise<boolean> => {
}; };
const createMarketPnlLeaderboards = (allPnlUsers: AllPnlUsers): UserPnlMap => { const createMarketPnlLeaderboards = (allPnlUsers: AllPnlUsers): UserPnlMap => {
let pnlMap = {}; const pnlMap = {};
Object.keys(allPnlUsers).forEach((perpMarketIndex) => { Object.keys(allPnlUsers).forEach((perpMarketIndex) => {
try { try {
@@ -187,7 +188,7 @@ const buildUserMarketLists = (
redisUsers: { user: User; bufferString: string }[], redisUsers: { user: User; bufferString: string }[],
allPnlUsers: AllPnlUsers allPnlUsers: AllPnlUsers
): AllPnlUsers => { ): AllPnlUsers => {
let newPnlUsers = allPnlUsers; const newPnlUsers = allPnlUsers;
const usdcSpotMarket = driftClient.getSpotMarketAccount( const usdcSpotMarket = driftClient.getSpotMarketAccount(
QUOTE_SPOT_MARKET_INDEX QUOTE_SPOT_MARKET_INDEX

2
src/serverLite.ts
View File

@@ -14,7 +14,7 @@ import {
MarketType, MarketType,
getVariant, getVariant,
} from '@drift-labs/sdk'; } from '@drift-labs/sdk';
import { RedisClient, RedisClientPrefix } from '@drift/common'; import { RedisClient, RedisClientPrefix } from '@drift/common/clients';
import { logger, setLogLevel } from './utils/logger'; import { logger, setLogLevel } from './utils/logger';