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

ignore markets for slot diff restart

Browse Source
This commit is contained in:
Nour Alharithi
2024-03-13 12:59:06 -04:00
parent 66834fca13
commit a21da890e5
4 changed files with 28 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -31,6 +31,16 @@ type wsMarketArgs = {
const PERP_MAKRET_STALENESS_THRESHOLD = 10 * 60 * 1000;
const SPOT_MAKRET_STALENESS_THRESHOLD = 20 * 60 * 1000;
const PERP_MARKETS_TO_SKIP_SLOT_CHECK = {
'mainnet-beta': [17, 21, 23, 25, 26],
devnet: [17, 21],
};
const SPOT_MARKETS_TO_SKIP_SLOT_CHECK = {
'mainnet-beta': [6, 8, 10],
devnet: [],
};
export type wsMarketInfo = {
marketIndex: number;
marketName: string;
@@ -46,7 +56,8 @@ export class DLOBSubscriberIO extends DLOBSubscriber {
Map<number, { slot: number; ts: number }>
>;
public skipSlotStalenessCheckMarkets = new Set<number>();
public skipSlotStalenessCheckMarketsPerp: number[];
public skipSlotStalenessCheckMarketsSpot: number[];
constructor(
config: DLOBSubscriptionConfig & {
@@ -70,6 +81,11 @@ export class DLOBSubscriberIO extends DLOBSubscriber {
this.lastMarketSlotMap.set(MarketType.SPOT, new Map());
this.lastMarketSlotMap.set(MarketType.PERP, new Map());
this.skipSlotStalenessCheckMarketsPerp =
PERP_MARKETS_TO_SKIP_SLOT_CHECK[config.env];
this.skipSlotStalenessCheckMarketsSpot =
SPOT_MARKETS_TO_SKIP_SLOT_CHECK[config.env];
for (const market of config.perpMarketInfos) {
const perpMarket = this.driftClient.getPerpMarketAccount(
market.marketIndex
@@ -77,7 +93,7 @@ export class DLOBSubscriberIO extends DLOBSubscriber {
const includeVamm = !isVariant(perpMarket.status, 'ammPaused');
const oracleSource = perpMarket.amm.oracleSource;
if (isVariant(oracleSource, 'prelaunch')) {
this.skipSlotStalenessCheckMarkets.add(market.marketIndex);
this.skipSlotStalenessCheckMarketsPerp.push(market.marketIndex);
}
this.marketArgs.push({
@@ -182,8 +198,14 @@ export class DLOBSubscriberIO extends DLOBSubscriber {
// Check if slot diffs are too large for oracle
const skipSlotCheck =
marketType === 'perp' &&
this.skipSlotStalenessCheckMarkets.has(marketArgs.marketIndex);
(marketType === 'perp' &&
this.skipSlotStalenessCheckMarketsPerp.includes(
marketArgs.marketIndex
)) ||
(marketType === 'spot' &&
this.skipSlotStalenessCheckMarketsSpot.includes(
marketArgs.marketIndex
));
if (
Math.abs(slot - parseInt(l2Formatted['oracleData']['slot'])) >
this.killSwitchSlotDiffThreshold &&