disable grpc for general driftclient

drift-labs · Dec 5, 2024 · e8feb96 · e8feb96
1 parent 4ae9d9b
commit e8feb96
Showing 1 changed file with 27 additions and 22 deletions.
diff --git a/src/publishers/dlobPublisher.ts b/src/publishers/dlobPublisher.ts
@@ -324,29 +324,34 @@ const main = async () => {
 	let accountSubscription: DriftClientSubscriptionConfig;
 	let slotSource: SlotSource;
 
+	// NOTE: disable GRPC for general driftClient subscriptions until we can reliably subscribe
+	// to multiple streams. Currently this causes the nodes to start killing connections.
+	//
 	// USE_GRPC=true will override websocket
-	if (useGrpc) {
-		accountSubscription = {
-			type: 'grpc',
-			resubTimeoutMs: 30_000,
-			grpcConfigs: {
-				endpoint,
-				token,
-				channelOptions: {
-					'grpc.keepalive_time_ms': 10_000,
-					'grpc.keepalive_timeout_ms': 1_000,
-					'grpc.keepalive_permit_without_calls': 1,
-				},
-			},
-		};
-
-		slotSubscriber = new SlotSubscriber(connection);
-		await slotSubscriber.subscribe();
-
-		slotSource = {
-			getSlot: () => slotSubscriber!.getSlot(),
-		};
-	} else if (!useWebsocket) {
+	// if (useGrpc) {
+	// 	accountSubscription = {
+	// 		type: 'grpc',
+	// 		resubTimeoutMs: 30_000,
+	// 		grpcConfigs: {
+	// 			endpoint,
+	// 			token,
+	// 			channelOptions: {
+	// 				'grpc.keepalive_time_ms': 10_000,
+	// 				'grpc.keepalive_timeout_ms': 1_000,
+	// 				'grpc.keepalive_permit_without_calls': 1,
+	// 			},
+	// 		},
+	// 	};
+
+	// 	slotSubscriber = new SlotSubscriber(connection);
+	// 	await slotSubscriber.subscribe();
+
+	// 	slotSource = {
+	// 		getSlot: () => slotSubscriber!.getSlot(),
+	// 	};
+	// }
+
+	if (!useWebsocket) {
 		bulkAccountLoader = new BulkAccountLoader(
 			connection,
 			stateCommitment,