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

Merge pull request #51 from drift-labs/phoenix-fix

Browse Source 
phoenix fix
This commit is contained in:
Nour Alharithi
2023-12-12 14:53:46 -08:00
committed by GitHub
parent 6ee967933f aa7df63625
commit 27db8815af
2 changed files with 38 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
src/index.ts
View File

@@ -168,7 +168,16 @@ const initializeAllMarketSubscribers = async (driftClient: DriftClient) => {
sdkConfig
);
await phoenixSubscriber.subscribe();
markets[market.marketIndex].phoenix = phoenixSubscriber;
// Test get L2 to know if we should add
try {
phoenixSubscriber.getL2Asks();
phoenixSubscriber.getL2Bids();
markets[market.marketIndex].phoenix = phoenixSubscriber;
} catch (e) {
logger.info(
`Excluding phoenix for ${market.marketIndex}, error: ${e}`
);
}
}
}
@@ -183,7 +192,15 @@ const initializeAllMarketSubscribers = async (driftClient: DriftClient) => {
sdkConfig
);
await serumSubscriber.subscribe();
markets[market.marketIndex].serum = serumSubscriber;
try {
serumSubscriber.getL2Asks();
serumSubscriber.getL2Bids();
markets[market.marketIndex].serum = serumSubscriber;
} catch (e) {
logger.info(
`Excluding phoenix for ${market.marketIndex}, error: ${e}`
);
}
}
}
}

21
src/publishers/dlobPublisher.ts
View File

@@ -89,7 +89,16 @@ const initializeAllMarketSubscribers = async (driftClient: DriftClient) => {
sdkConfig
);
await phoenixSubscriber.subscribe();
markets[market.marketIndex].phoenix = phoenixSubscriber;
// Test get L2 to know if we should add
try {
phoenixSubscriber.getL2Asks();
phoenixSubscriber.getL2Bids();
markets[market.marketIndex].phoenix = phoenixSubscriber;
} catch (e) {
logger.info(
`Excluding phoenix for ${market.marketIndex}, error: ${e}`
);
}
}
}
@@ -104,7 +113,15 @@ const initializeAllMarketSubscribers = async (driftClient: DriftClient) => {
sdkConfig
);
await serumSubscriber.subscribe();
markets[market.marketIndex].serum = serumSubscriber;
try {
serumSubscriber.getL2Asks();
serumSubscriber.getL2Bids();
markets[market.marketIndex].serum = serumSubscriber;
} catch (e) {
logger.info(
`Excluding phoenix for ${market.marketIndex}, error: ${e}`
);
}
}
}
}