chore: add grpc client to order subscriber

Author: jackwaller

sdk/src/accounts/types.ts

@@ -234,6 +234,7 @@ export type GrpcConfigs = {
 	 * Defaults to false, will throw on connection loss.
 	 */
 	enableReconnect?: boolean;
+	client?: 'yellowstone' | 'laser';
 };
 
 export interface HighLeverageModeConfigAccountSubscriber {

sdk/src/orderSubscriber/grpcSubscription.ts

@@ -5,14 +5,17 @@ import { OrderSubscriber } from './OrderSubscriber';
 import { GrpcConfigs, ResubOpts } from '../accounts/types';
 import { UserAccount } from '../types';
 import { getUserFilter, getNonIdleUserFilter } from '../memcmp';
+import { LaserstreamProgramAccountSubscriber } from '../accounts/laserProgramAccountSubscriber';
 
 export class grpcSubscription {
 	private orderSubscriber: OrderSubscriber;
 	private skipInitialLoad: boolean;
 	private resubOpts?: ResubOpts;
 	private resyncIntervalMs?: number;
 
-	private subscriber?: grpcProgramAccountSubscriber<UserAccount>;
+	private subscriber?:
+		| grpcProgramAccountSubscriber<UserAccount>
+		| LaserstreamProgramAccountSubscriber<UserAccount>;
 	private resyncTimeoutId?: ReturnType<typeof setTimeout>;
 
 	private decoded?: boolean;
@@ -47,17 +50,32 @@ export class grpcSubscription {
 			return;
 		}
 
-		this.subscriber = await grpcProgramAccountSubscriber.create<UserAccount>(
-			this.grpcConfigs,
-			'OrderSubscriber',
-			'User',
-			this.orderSubscriber.driftClient.program,
-			this.orderSubscriber.decodeFn,
-			{
-				filters: [getUserFilter(), getNonIdleUserFilter()],
-			},
-			this.resubOpts
-		);
+		if (this.grpcConfigs.client === 'laser') {
+			this.subscriber =
+				await LaserstreamProgramAccountSubscriber.create<UserAccount>(
+					this.grpcConfigs,
+					'OrderSubscriber',
+					'User',
+					this.orderSubscriber.driftClient.program,
+					this.orderSubscriber.decodeFn,
+					{
+						filters: [getUserFilter(), getNonIdleUserFilter()],
+					},
+					this.resubOpts
+				);
+		} else {
+			this.subscriber = await grpcProgramAccountSubscriber.create<UserAccount>(
+				this.grpcConfigs,
+				'OrderSubscriber',
+				'User',
+				this.orderSubscriber.driftClient.program,
+				this.orderSubscriber.decodeFn,
+				{
+					filters: [getUserFilter(), getNonIdleUserFilter()],
+				},
+				this.resubOpts
+			);
+		}
 
 		await this.subscriber.subscribe(
 			(