Submodule drift-common updated: 761577b59b...ea47fb97e1
@@ -26,7 +26,7 @@
|
|||||||
"cors": "^2.8.5",
|
"cors": "^2.8.5",
|
||||||
"dotenv": "^10.0.0",
|
"dotenv": "^10.0.0",
|
||||||
"express": "^4.18.2",
|
"express": "^4.18.2",
|
||||||
"ioredis": "^5.3.2",
|
"ioredis": "^5.4.1",
|
||||||
"morgan": "^1.10.0",
|
"morgan": "^1.10.0",
|
||||||
"prom-client": "^15.0.0",
|
"prom-client": "^15.0.0",
|
||||||
"redis": "^4.6.10",
|
"redis": "^4.6.10",
|
||||||
|
|||||||
@@ -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,
|
||||||
|
|||||||
@@ -24,7 +24,7 @@ import {
|
|||||||
PerpOperation,
|
PerpOperation,
|
||||||
DelistedMarketSetting,
|
DelistedMarketSetting,
|
||||||
} 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';
|
||||||
|
|
||||||
|
|||||||
@@ -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 {
|
||||||
|
|||||||
@@ -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';
|
||||||
|
|||||||
@@ -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';
|
||||||
|
|||||||
@@ -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
|
||||||
|
|||||||
@@ -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';
|
||||||
|
|
||||||
|
|||||||
@@ -13,7 +13,7 @@ import {
|
|||||||
decodeUser,
|
decodeUser,
|
||||||
isVariant,
|
isVariant,
|
||||||
} from '@drift-labs/sdk';
|
} from '@drift-labs/sdk';
|
||||||
import { RedisClient } from '@drift/common';
|
import { RedisClient } from '@drift/common/clients';
|
||||||
|
|
||||||
import { logger } from './logger';
|
import { logger } from './logger';
|
||||||
import { NextFunction, Request, Response } from 'express';
|
import { NextFunction, Request, Response } from 'express';
|
||||||
|
|||||||
@@ -6,7 +6,7 @@ import { WebSocket, WebSocketServer } from 'ws';
|
|||||||
import { sleep } from './utils/utils';
|
import { sleep } from './utils/utils';
|
||||||
import { register, Gauge } from 'prom-client';
|
import { register, Gauge } from 'prom-client';
|
||||||
import { DriftEnv, PerpMarkets, SpotMarkets } from '@drift-labs/sdk';
|
import { DriftEnv, PerpMarkets, SpotMarkets } from '@drift-labs/sdk';
|
||||||
import { RedisClient, RedisClientPrefix } from '@drift/common';
|
import { RedisClient, RedisClientPrefix } from '@drift/common/clients';
|
||||||
|
|
||||||
// Set up env constants
|
// Set up env constants
|
||||||
require('dotenv').config();
|
require('dotenv').config();
|
||||||
|
|||||||
@@ -12,7 +12,10 @@
|
|||||||
"emitDecoratorMetadata": true,
|
"emitDecoratorMetadata": true,
|
||||||
"baseUrl": ".",
|
"baseUrl": ".",
|
||||||
"rootDir": "src",
|
"rootDir": "src",
|
||||||
"outDir": "./lib"
|
"outDir": "./lib",
|
||||||
|
"paths": {
|
||||||
|
"@drift/common/clients": ["./drift-common/common-ts/lib/clients"],
|
||||||
|
}
|
||||||
},
|
},
|
||||||
"include": ["src/**/*"],
|
"include": ["src/**/*"],
|
||||||
"exclude": ["node_modules"]
|
"exclude": ["node_modules"]
|
||||||
|
|||||||
17
yarn.lock
17
yarn.lock
@@ -484,7 +484,7 @@
|
|||||||
"@drift/common@file:./drift-common/common-ts":
|
"@drift/common@file:./drift-common/common-ts":
|
||||||
version "1.0.0"
|
version "1.0.0"
|
||||||
dependencies:
|
dependencies:
|
||||||
"@drift-labs/sdk" "file:../../Library/Caches/Yarn/v6/npm-@drift-common-1.0.0-66ae29fc-f764-4f8c-951d-c0993d2ea55f-1728326228912/node_modules/@drift/protocol/sdk"
|
"@drift-labs/sdk" "file:../../Library/Caches/Yarn/v6/npm-@drift-common-1.0.0-79940387-1595-4bdc-b73c-2bd48440a03a-1729802406625/node_modules/@drift/protocol/sdk"
|
||||||
"@jest/globals" "^29.3.1"
|
"@jest/globals" "^29.3.1"
|
||||||
"@slack/web-api" "^6.4.0"
|
"@slack/web-api" "^6.4.0"
|
||||||
"@solana/spl-token" "^0.3.8"
|
"@solana/spl-token" "^0.3.8"
|
||||||
@@ -4373,21 +4373,6 @@ inherits@2, inherits@2.0.4, inherits@^2.0.3:
|
|||||||
resolved "https://registry.yarnpkg.com/inherits/-/inherits-2.0.4.tgz#0fa2c64f932917c3433a0ded55363aae37416b7c"
|
resolved "https://registry.yarnpkg.com/inherits/-/inherits-2.0.4.tgz#0fa2c64f932917c3433a0ded55363aae37416b7c"
|
||||||
integrity sha512-k/vGaX4/Yla3WzyMCvTQOXYeIHvqOKtnqBduzTHpzpQZzAskKMhZ2K+EnBiSM9zGSoIFeMpXKxa4dYeZIQqewQ==
|
integrity sha512-k/vGaX4/Yla3WzyMCvTQOXYeIHvqOKtnqBduzTHpzpQZzAskKMhZ2K+EnBiSM9zGSoIFeMpXKxa4dYeZIQqewQ==
|
||||||
|
|
||||||
ioredis@^5.3.2:
|
|
||||||
version "5.3.2"
|
|
||||||
resolved "https://registry.yarnpkg.com/ioredis/-/ioredis-5.3.2.tgz#9139f596f62fc9c72d873353ac5395bcf05709f7"
|
|
||||||
integrity sha512-1DKMMzlIHM02eBBVOFQ1+AolGjs6+xEcM4PDL7NqOS6szq7H9jSaEkIUH6/a5Hl241LzW6JLSiAbNvTQjUupUA==
|
|
||||||
dependencies:
|
|
||||||
"@ioredis/commands" "^1.1.1"
|
|
||||||
cluster-key-slot "^1.1.0"
|
|
||||||
debug "^4.3.4"
|
|
||||||
denque "^2.1.0"
|
|
||||||
lodash.defaults "^4.2.0"
|
|
||||||
lodash.isarguments "^3.1.0"
|
|
||||||
redis-errors "^1.2.0"
|
|
||||||
redis-parser "^3.0.0"
|
|
||||||
standard-as-callback "^2.1.0"
|
|
||||||
|
|
||||||
ioredis@^5.4.1:
|
ioredis@^5.4.1:
|
||||||
version "5.4.1"
|
version "5.4.1"
|
||||||
resolved "https://registry.yarnpkg.com/ioredis/-/ioredis-5.4.1.tgz#1c56b70b759f01465913887375ed809134296f40"
|
resolved "https://registry.yarnpkg.com/ioredis/-/ioredis-5.4.1.tgz#1c56b70b759f01465913887375ed809134296f40"
|
||||||
|
|||||||
Reference in New Issue
Block a user