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

Merge branch 'master' into staging

Browse Source
This commit is contained in:
wphan
2023-12-26 20:01:09 -08:00
parent dac60ff967 f67c0a6603
commit e189dfbdeb
3 changed files with 5 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
package.json
View File

@@ -6,7 +6,7 @@
"license": "Apache-2.0", "license": "Apache-2.0",
"dependencies": { "dependencies": {
"@coral-xyz/anchor": "^0.29.0", "@coral-xyz/anchor": "^0.29.0",
"@drift-labs/sdk": "2.53.0-beta.1", "@drift-labs/sdk": "2.53.0-beta.3",
"@opentelemetry/api": "^1.1.0", "@opentelemetry/api": "^1.1.0",
"@opentelemetry/auto-instrumentations-node": "^0.31.1", "@opentelemetry/auto-instrumentations-node": "^0.31.1",
"@opentelemetry/exporter-prometheus": "^0.31.0", "@opentelemetry/exporter-prometheus": "^0.31.0",

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

@@ -13,8 +13,6 @@ import {
addOracletoResponse, addOracletoResponse,
l2WithBNToStrings, l2WithBNToStrings,
} from '../utils/utils'; } from '../utils/utils';
import { logger } from '../utils/logger';
import { webhookMessage } from '../utils/webhook';
type wsMarketL2Args = { type wsMarketL2Args = {
marketIndex: number; marketIndex: number;
@@ -141,19 +139,6 @@ export class DLOBSubscriberIO extends DLOBSubscriber {
asks: l2Formatted.asks.slice(0, 5), asks: l2Formatted.asks.slice(0, 5),
}); });
// START HACK FOR DEBUGGING FAILURE WEBSOCKET CONNECTIONS
const orderSubscriberSlot = this.slotSource.getSlot();
const dlobOracleSlot = parseInt(l2Formatted['oracleData']['slot']);
const slotDiff = Math.abs(orderSubscriberSlot - dlobOracleSlot);
if (slotDiff > 50) {
const msg = `DlobPublisher bad slot in ${l2Formatted['marketType']} market ${l2Formatted['marketName']}! abs(oracleSlot (${dlobOracleSlot}) - orderSubscriberSlot (${orderSubscriberSlot})) = ${slotDiff} > 50`;
logger.error(msg);
webhookMessage(msg).then(() => {
process.exit(1);
});
}
// END HACK FOR DEBUGGING FAILURE WEBSOCKET CONNECTIONS
this.redisClient.client.publish( this.redisClient.client.publish(
`orderbook_${marketType}_${l2Args.marketIndex}`, `orderbook_${marketType}_${l2Args.marketIndex}`,
JSON.stringify(l2Formatted) JSON.stringify(l2Formatted)

8
yarn.lock
View File

@@ -115,10 +115,10 @@
enabled "2.0.x" enabled "2.0.x"
kuler "^2.0.0" kuler "^2.0.0"
"@drift-labs/sdk@2.53.0-beta.1": "@drift-labs/sdk@2.53.0-beta.3":
version "2.53.0-beta.1" version "2.53.0-beta.3"
resolved "https://registry.yarnpkg.com/@drift-labs/sdk/-/sdk-2.53.0-beta.1.tgz#91671fc7d6550ecdd2f3b9a5cc82ec358e033fd6" resolved "https://registry.yarnpkg.com/@drift-labs/sdk/-/sdk-2.53.0-beta.3.tgz#4ce6aeec21959df24341fc3f7eca5fff6ce8c6d6"
integrity sha512-pzqnFykg0hDwViP5N+i7mKvqHDEwLbfRPRTLzV/gvE8rfcuDQLQm3Ce33UwO1I3ufkvQ97PGgGUJ9l2SrqcB5A== integrity sha512-ZG/urHFdTZ1ikc3F9tdRGSvsylCb2woV3eCVsRfxZCgmpDaK09pfCLDGtzkiROlZ0VVe5ECPJinbi0NyK2nNnQ==
dependencies: dependencies:
"@coral-xyz/anchor" "0.28.1-beta.2" "@coral-xyz/anchor" "0.28.1-beta.2"
"@ellipsis-labs/phoenix-sdk" "^1.4.2" "@ellipsis-labs/phoenix-sdk" "^1.4.2"