diff --git a/package.json b/package.json index ca74e54..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.69.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 3d519e4..909b69a 100644 --- a/yarn.lock +++ b/yarn.lock @@ -115,10 +115,10 @@ enabled "2.0.x" kuler "^2.0.0" -"@drift-labs/sdk@2.69.0-beta.0": - version "2.69.0-beta.0" - resolved "https://registry.yarnpkg.com/@drift-labs/sdk/-/sdk-2.69.0-beta.0.tgz#3e540e594a43f77120e6451749159ac3f0faa72b" - integrity sha512-9JQcw/BxHEh9TpCKg/ahyj3cb7k4ecudtJ6McGuzR2OQE8Nfvtp3wIA/Q1cl604V76FJTLsGVB+4nGcW7KVnsQ== +"@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"