From 6808e9119a585600d3ad3ed5c3d4a836ebf6f2fa Mon Sep 17 00:00:00 2001 From: Jack Waller Date: Wed, 4 Feb 2026 11:50:55 +1100 Subject: [PATCH 1/3] fix: error with filters --- sdk/src/accounts/grpcProgramAccountSubscriber.ts | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/sdk/src/accounts/grpcProgramAccountSubscriber.ts b/sdk/src/accounts/grpcProgramAccountSubscriber.ts index b5cf64b84..ba1abca61 100644 --- a/sdk/src/accounts/grpcProgramAccountSubscriber.ts +++ b/sdk/src/accounts/grpcProgramAccountSubscriber.ts @@ -16,7 +16,7 @@ export class grpcProgramAccountSubscriber< T, > extends WebSocketProgramAccountSubscriber { private client: Client; - private stream: ClientDuplexStream; + private stream: Awaited>;; private commitmentLevel: CommitmentLevel; public listenerId?: number; @@ -91,19 +91,18 @@ export class grpcProgramAccountSubscriber< this.onChange = onChange; // Subscribe with grpc - this.stream = - (await this.client.subscribe()) as unknown as typeof this.stream; + this.stream = await this.client.subscribe() const filters = this.options.filters.map((filter) => { return { memcmp: { - offset: filter.memcmp.offset.toString(), + offset: filter.memcmp.offset, base58: filter.memcmp.bytes, }, }; }); - const request: SubscribeRequest = { + const request = { slots: {}, accounts: { drift: { @@ -120,6 +119,7 @@ export class grpcProgramAccountSubscriber< entry: {}, transactionsStatus: {}, }; + this.stream.on('data', (chunk: SubscribeUpdate) => { if (!chunk.account) { return; From 7c5b93a28eeed865a5dc7ea201922e07437d32b0 Mon Sep 17 00:00:00 2001 From: Jack Waller Date: Wed, 4 Feb 2026 11:53:43 +1100 Subject: [PATCH 2/3] fix: lint/format --- sdk/src/accounts/grpcProgramAccountSubscriber.ts | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/sdk/src/accounts/grpcProgramAccountSubscriber.ts b/sdk/src/accounts/grpcProgramAccountSubscriber.ts index ba1abca61..c34115718 100644 --- a/sdk/src/accounts/grpcProgramAccountSubscriber.ts +++ b/sdk/src/accounts/grpcProgramAccountSubscriber.ts @@ -5,7 +5,6 @@ import * as Buffer from 'buffer'; import { WebSocketProgramAccountSubscriber } from './webSocketProgramAccountSubscriber'; import { Client, - ClientDuplexStream, CommitmentLevel, createClient, SubscribeRequest, @@ -16,7 +15,7 @@ export class grpcProgramAccountSubscriber< T, > extends WebSocketProgramAccountSubscriber { private client: Client; - private stream: Awaited>;; + private stream: Awaited>; private commitmentLevel: CommitmentLevel; public listenerId?: number; @@ -91,7 +90,7 @@ export class grpcProgramAccountSubscriber< this.onChange = onChange; // Subscribe with grpc - this.stream = await this.client.subscribe() + this.stream = await this.client.subscribe(); const filters = this.options.filters.map((filter) => { return { From 758075cb24e6a825f5388680c75a648d88f97218 Mon Sep 17 00:00:00 2001 From: Jack Waller Date: Wed, 4 Feb 2026 11:58:00 +1100 Subject: [PATCH 3/3] fix: prettify --- sdk/src/accounts/grpcProgramAccountSubscriber.ts | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sdk/src/accounts/grpcProgramAccountSubscriber.ts b/sdk/src/accounts/grpcProgramAccountSubscriber.ts index c34115718..f69b0ac62 100644 --- a/sdk/src/accounts/grpcProgramAccountSubscriber.ts +++ b/sdk/src/accounts/grpcProgramAccountSubscriber.ts @@ -15,7 +15,7 @@ export class grpcProgramAccountSubscriber< T, > extends WebSocketProgramAccountSubscriber { private client: Client; - private stream: Awaited>; + private stream: Awaited>; private commitmentLevel: CommitmentLevel; public listenerId?: number;