diff --git a/package.json b/package.json index cc0480a..21a1f53 100644 --- a/package.json +++ b/package.json @@ -6,7 +6,7 @@ "license": "Apache-2.0", "dependencies": { "@coral-xyz/anchor": "^0.29.0", - "@drift-labs/sdk": "2.70.0-beta.0", + "@drift-labs/sdk": "2.71.0-beta.3", "@opentelemetry/api": "^1.1.0", "@opentelemetry/auto-instrumentations-node": "^0.31.1", "@opentelemetry/exporter-prometheus": "^0.31.0", diff --git a/src/index.ts b/src/index.ts index 3fa4e52..8e3768e 100644 --- a/src/index.ts +++ b/src/index.ts @@ -275,7 +275,9 @@ const main = async (): Promise => { type: 'websocket', commitment: stateCommitment, }; - slotSubscriber = new SlotSubscriber(connection); + slotSubscriber = new SlotSubscriber(connection, { + resubTimeoutMs: 5000 + }); await slotSubscriber.subscribe(); } @@ -768,7 +770,7 @@ const main = async (): Promise => { const parsedResponse = JSON.parse(redisResponse); if ( parsedResponse && - Math.abs(dlobProvider.getSlot() - parsedResponse.slot) < + dlobProvider.getSlot() - parsedResponse.slot < SLOT_STALENESS_TOLERANCE ) { if (side === 'bid') { diff --git a/yarn.lock b/yarn.lock index 19c4daf..909b69a 100644 --- a/yarn.lock +++ b/yarn.lock @@ -115,10 +115,10 @@ enabled "2.0.x" kuler "^2.0.0" -"@drift-labs/sdk@2.70.0-beta.0": - version "2.70.0-beta.0" - resolved "https://registry.yarnpkg.com/@drift-labs/sdk/-/sdk-2.70.0-beta.0.tgz#fe142f269995572b6abddf5c559717a97ba3264c" - integrity sha512-OhAPdW66RokHH8VsMUMUFPS1BYqU98uCoNi3eBRX76h4vb4u/4luispAn+ln+8MSncAK4QuloBJYYGy/YIGT9Q== +"@drift-labs/sdk@2.71.0-beta.3": + version "2.71.0-beta.3" + resolved "https://registry.yarnpkg.com/@drift-labs/sdk/-/sdk-2.71.0-beta.3.tgz#bddb4c5a2c3661dd12e533b4450f97d03d698a9a" + integrity sha512-/MDv4678WGrgTKOMZlemvmCnT9Xs7gbQmY2wGQQN2umzXIa/ifCovD5kSNZcARlQuZltnLv8b8Hr98euzMt5aA== dependencies: "@coral-xyz/anchor" "0.28.1-beta.2" "@ellipsis-labs/phoenix-sdk" "^1.4.2"