diff --git a/package.json b/package.json index 7d308f3..bc4794b 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.52.0-beta.0", + "@drift-labs/sdk": "2.52.0-beta.1", "@opentelemetry/api": "^1.1.0", "@opentelemetry/auto-instrumentations-node": "^0.31.1", "@opentelemetry/exporter-prometheus": "^0.31.0", diff --git a/src/wsConnectionManager.ts b/src/wsConnectionManager.ts index bb37b5c..a4e74fe 100644 --- a/src/wsConnectionManager.ts +++ b/src/wsConnectionManager.ts @@ -110,6 +110,7 @@ async function main() { wss.on('connection', (ws: WebSocket) => { console.log('Client connected'); + console.log('Number of active connections:', wss.clients.size); wsConnectionsGauge.inc(); ws.on('message', async (msg) => { @@ -235,6 +236,7 @@ async function main() { // Handle disconnection ws.on('close', () => { + console.log('Client disconnected'); // Clear any existing intervals and timeouts channelSubscribers.forEach((subscribers, channel) => { if (subscribers.delete(ws) && subscribers.size === 0) { @@ -243,6 +245,7 @@ async function main() { subscribedChannels.delete(channel); } }); + console.log('Number of active connections:', wss.clients.size); wsConnectionsGauge.dec(); }); diff --git a/yarn.lock b/yarn.lock index cc463b0..a64b3b4 100644 --- a/yarn.lock +++ b/yarn.lock @@ -115,10 +115,10 @@ enabled "2.0.x" kuler "^2.0.0" -"@drift-labs/sdk@2.52.0-beta.0": - version "2.52.0-beta.0" - resolved "https://registry.yarnpkg.com/@drift-labs/sdk/-/sdk-2.52.0-beta.0.tgz#03da2e192e3f2180238e5e464336e0fc1697c0e0" - integrity sha512-SnuXh06oJFzAvTQZ/dOjcWduhKC8rRMlyTE5Xqb3LfCcEkQ/B+XvxTItCSzAPh33qq0MMhZKjxGdqKezUxnV1w== +"@drift-labs/sdk@2.52.0-beta.1": + version "2.52.0-beta.1" + resolved "https://registry.yarnpkg.com/@drift-labs/sdk/-/sdk-2.52.0-beta.1.tgz#6b26c434edf9e796010b0be358c732cacc251a24" + integrity sha512-qlfMvN9Fc7TOtRXtkQbTgok7nN0pObosfL1oh7uiEvgQrMeQY2lJoUzSHi4U8djxR68MkVnLnwVGABEgKEBdRQ== dependencies: "@coral-xyz/anchor" "0.28.1-beta.2" "@ellipsis-labs/phoenix-sdk" "^1.4.2"