From cb2337972382e1bb12d0d7f4e5245a8eb3e84dc9 Mon Sep 17 00:00:00 2001
From: Brendan Chen <me@bchen.dev>
Date: Tue, 11 Nov 2025 11:41:39 -0800
Subject: [PATCH] Add shuttleRepository injection to the constructor of
 RedisSelfUpdatingETARepository

---
 .../eta/RedisSelfUpdatingETARepository.ts       | 17 +++++++++++++++++
 1 file changed, 17 insertions(+)

diff --git a/src/repositories/shuttle/eta/RedisSelfUpdatingETARepository.ts b/src/repositories/shuttle/eta/RedisSelfUpdatingETARepository.ts
index a636f57..8d26d60 100644
--- a/src/repositories/shuttle/eta/RedisSelfUpdatingETARepository.ts
+++ b/src/repositories/shuttle/eta/RedisSelfUpdatingETARepository.ts
@@ -2,8 +2,25 @@ import { IEta } from "../../../entities/ShuttleRepositoryEntities";
 import { ETARepositoryEventName, ETARepositoryEventListener } from "./ETAGetterRepository";
 import { SelfUpdatingETARepository } from "./SelfUpdatingETARepository";
 import { BaseRedisRepository } from "../../BaseRedisRepository";
+import { createClient, RedisClientType } from "redis";
+import { ShuttleGetterRepository } from "../ShuttleGetterRepository";
+import { REDIS_RECONNECT_INTERVAL } from "../../../environment";
 
 export class RedisSelfUpdatingETARepository extends BaseRedisRepository implements SelfUpdatingETARepository {
+  constructor(
+    readonly shuttleRepository: ShuttleGetterRepository,
+    redisClient: RedisClientType = createClient({
+      url: process.env.REDIS_URL,
+      socket: {
+        tls: process.env.NODE_ENV === 'production',
+        rejectUnauthorized: false,
+        reconnectStrategy: REDIS_RECONNECT_INTERVAL,
+      },
+    }),
+  ) {
+    super(redisClient);
+  }
+
   startListeningForUpdates(): void {
     throw new Error("Method not implemented.");
   }