ts-sdk: filter out erroneous logs in EventSubscriber (#815)

drift-labs · Jan 11, 2024 · dffa9c5 · dffa9c5
1 parent da1fc8d
commit dffa9c5
Showing 1 changed file with 11 additions and 2 deletions.
diff --git a/sdk/src/events/webSocketLogProvider.ts b/sdk/src/events/webSocketLogProvider.ts
@@ -1,5 +1,11 @@
 import { LogProvider, logProviderCallback } from './types';
-import { Commitment, Connection, PublicKey } from '@solana/web3.js';
+import {
+	Commitment,
+	Connection,
+	Context,
+	Logs,
+	PublicKey,
+} from '@solana/web3.js';
 import { EventEmitter } from 'events';
 
 export class WebSocketLogProvider implements LogProvider {
@@ -45,7 +51,7 @@ export class WebSocketLogProvider implements LogProvider {
 	public setSubscription(callback: logProviderCallback): void {
 		this.subscriptionId = this.connection.onLogs(
 			this.address,
-			(logs, ctx) => {
+			(logs: Logs, ctx: Context) => {
 				if (this.resubTimeoutMs && !this.isUnsubscribing) {
 					this.receivingData = true;
 					clearTimeout(this.timeoutId);
@@ -55,6 +61,9 @@ export class WebSocketLogProvider implements LogProvider {
 					}
 					this.reconnectAttempts = 0;
 				}
+				if (logs.err !== null) {
+					return;
+				}
 				callback(logs.signature, ctx.slot, logs.logs, undefined);
 			},
 			this.commitment