From 0a46caf44c0dc555e369cc0850a9c5597be11a13 Mon Sep 17 00:00:00 2001
From: Ty Book <ty@neynar.com>
Date: Fri, 25 Oct 2024 11:59:33 -0600
Subject: [PATCH] feat(shuttle): Pipe connectionTimeout arg through
 EventStreamHubSubscriber

    Follow-up to https://github.com/farcasterxyz/hub-monorepo/pull/2367. Missed piping through BaseHubSubscribers new `connectionTimeout` param through to EventStreamHubSubscriber.
---
 .changeset/itchy-feet-cough.md                | 5 +++++
 packages/shuttle/src/shuttle/hubSubscriber.ts | 3 ++-
 2 files changed, 7 insertions(+), 1 deletion(-)
 create mode 100644 .changeset/itchy-feet-cough.md

diff --git a/.changeset/itchy-feet-cough.md b/.changeset/itchy-feet-cough.md
new file mode 100644
index 0000000000..147d8ad127
--- /dev/null
+++ b/.changeset/itchy-feet-cough.md
@@ -0,0 +1,5 @@
+---
+"@farcaster/shuttle": patch
+---
+
+feat(shuttle): Pipe connectionTimeout arg through EventStreamHubSubscriber
diff --git a/packages/shuttle/src/shuttle/hubSubscriber.ts b/packages/shuttle/src/shuttle/hubSubscriber.ts
index a22804db57..188fb9082c 100644
--- a/packages/shuttle/src/shuttle/hubSubscriber.ts
+++ b/packages/shuttle/src/shuttle/hubSubscriber.ts
@@ -217,9 +217,10 @@ export class EventStreamHubSubscriber extends BaseHubSubscriber {
     eventTypes?: HubEventType[],
     totalShards?: number,
     shardIndex?: number,
+    connectionTimeout?: number,
     options?: EventStreamHubSubscriberOptions,
   ) {
-    super(label, hubClient.client, log, eventTypes, totalShards, shardIndex);
+    super(label, hubClient.client, log, eventTypes, totalShards, shardIndex, connectionTimeout);
     this.eventStream = eventStream;
     this.redis = redis;
     this.streamKey = `hub:${hubClient.host}:evt:msg:${shardKey}`;