From 53e120cd1e3dcec9fbbba75192aebd07103d8895 Mon Sep 17 00:00:00 2001
From: Brendan Chen <me@bchen.dev>
Date: Tue, 11 Nov 2025 10:54:46 -0800
Subject: [PATCH] Add stubs for Redis implementations of both ETA repository
 variants

---
 ...tory.ts => ExternalSourceETARepository.ts} |  0
 .../eta/RedisExternalSourceETARepository.ts   | 66 +++++++++++++++++++
 .../eta/RedisSelfUpdatingETARepository.ts     | 64 ++++++++++++++++++
 3 files changed, 130 insertions(+)
 rename src/repositories/shuttle/eta/{ETAGetterSetterRepository.ts => ExternalSourceETARepository.ts} (100%)
 create mode 100644 src/repositories/shuttle/eta/RedisExternalSourceETARepository.ts
 create mode 100644 src/repositories/shuttle/eta/RedisSelfUpdatingETARepository.ts

diff --git a/src/repositories/shuttle/eta/ETAGetterSetterRepository.ts b/src/repositories/shuttle/eta/ExternalSourceETARepository.ts
similarity index 100%
rename from src/repositories/shuttle/eta/ETAGetterSetterRepository.ts
rename to src/repositories/shuttle/eta/ExternalSourceETARepository.ts
diff --git a/src/repositories/shuttle/eta/RedisExternalSourceETARepository.ts b/src/repositories/shuttle/eta/RedisExternalSourceETARepository.ts
new file mode 100644
index 0000000..c4cff9b
--- /dev/null
+++ b/src/repositories/shuttle/eta/RedisExternalSourceETARepository.ts
@@ -0,0 +1,66 @@
+import { IEta } from "../../../entities/ShuttleRepositoryEntities";
+import { ETARepositoryEventName, ETARepositoryEventListener } from "./ETAGetterRepository";
+import { ExternalSourceETARepository } from "./ExternalSourceETARepository";
+
+export class RedisExternalSourceETARepository implements ExternalSourceETARepository {
+  addOrUpdateEtaFromExternalSource(eta: IEta): Promise<void> {
+    throw new Error("Method not implemented.");
+  }
+  removeEtaIfExists(shuttleId: string, stopId: string): Promise<IEta | null> {
+    throw new Error("Method not implemented.");
+  }
+  on<T extends ETARepositoryEventName>(event: T, listener: ETARepositoryEventListener<T>): this {
+    throw new Error("Method not implemented.");
+  }
+  once<T extends ETARepositoryEventName>(event: T, listener: ETARepositoryEventListener<T>): this {
+    throw new Error("Method not implemented.");
+  }
+  off<T extends ETARepositoryEventName>(event: T, listener: ETARepositoryEventListener<T>): this {
+    throw new Error("Method not implemented.");
+  }
+  addListener<T extends ETARepositoryEventName>(event: T, listener: ETARepositoryEventListener<T>): this {
+    throw new Error("Method not implemented.");
+  }
+  removeListener<T extends ETARepositoryEventName>(event: T, listener: ETARepositoryEventListener<T>): this {
+    throw new Error("Method not implemented.");
+  }
+  getEtasForShuttleId(shuttleId: string): Promise<IEta[]> {
+    throw new Error("Method not implemented.");
+  }
+  getEtasForStopId(stopId: string): Promise<IEta[]> {
+    throw new Error("Method not implemented.");
+  }
+  getEtaForShuttleAndStopId(shuttleId: string, stopId: string): Promise<IEta | null> {
+    throw new Error("Method not implemented.");
+  }
+  removeAllListeners(eventName?: string | symbol | undefined): this {
+    throw new Error("Method not implemented.");
+  }
+  setMaxListeners(n: number): this {
+    throw new Error("Method not implemented.");
+  }
+  getMaxListeners(): number {
+    throw new Error("Method not implemented.");
+  }
+  listeners<K>(eventName: string | symbol): Function[] {
+    throw new Error("Method not implemented.");
+  }
+  rawListeners<K>(eventName: string | symbol): Function[] {
+    throw new Error("Method not implemented.");
+  }
+  emit<K>(eventName: string | symbol, ...args: any[]): boolean {
+    throw new Error("Method not implemented.");
+  }
+  listenerCount<K>(eventName: string | symbol, listener?: Function | undefined): number {
+    throw new Error("Method not implemented.");
+  }
+  prependListener<K>(eventName: string | symbol, listener: (...args: any[]) => void): this {
+    throw new Error("Method not implemented.");
+  }
+  prependOnceListener<K>(eventName: string | symbol, listener: (...args: any[]) => void): this {
+    throw new Error("Method not implemented.");
+  }
+  eventNames(): (string | symbol)[] {
+    throw new Error("Method not implemented.");
+  }
+}
diff --git a/src/repositories/shuttle/eta/RedisSelfUpdatingETARepository.ts b/src/repositories/shuttle/eta/RedisSelfUpdatingETARepository.ts
new file mode 100644
index 0000000..797571f
--- /dev/null
+++ b/src/repositories/shuttle/eta/RedisSelfUpdatingETARepository.ts
@@ -0,0 +1,64 @@
+import { IEta } from "../../../entities/ShuttleRepositoryEntities";
+import { ETARepositoryEventName, ETARepositoryEventListener } from "./ETAGetterRepository";
+import { SelfUpdatingETARepository } from "./SelfUpdatingETARepository";
+
+export class RedisSelfUpdatingETARepository implements SelfUpdatingETARepository {
+  startListeningForUpdates(): void {
+    throw new Error("Method not implemented.");
+  }
+  on<T extends ETARepositoryEventName>(event: T, listener: ETARepositoryEventListener<T>): this {
+    throw new Error("Method not implemented.");
+  }
+  once<T extends ETARepositoryEventName>(event: T, listener: ETARepositoryEventListener<T>): this {
+    throw new Error("Method not implemented.");
+  }
+  off<T extends ETARepositoryEventName>(event: T, listener: ETARepositoryEventListener<T>): this {
+    throw new Error("Method not implemented.");
+  }
+  addListener<T extends ETARepositoryEventName>(event: T, listener: ETARepositoryEventListener<T>): this {
+    throw new Error("Method not implemented.");
+  }
+  removeListener<T extends ETARepositoryEventName>(event: T, listener: ETARepositoryEventListener<T>): this {
+    throw new Error("Method not implemented.");
+  }
+  getEtasForShuttleId(shuttleId: string): Promise<IEta[]> {
+    throw new Error("Method not implemented.");
+  }
+  getEtasForStopId(stopId: string): Promise<IEta[]> {
+    throw new Error("Method not implemented.");
+  }
+  getEtaForShuttleAndStopId(shuttleId: string, stopId: string): Promise<IEta | null> {
+    throw new Error("Method not implemented.");
+  }
+  removeAllListeners(eventName?: string | symbol | undefined): this {
+    throw new Error("Method not implemented.");
+  }
+  setMaxListeners(n: number): this {
+    throw new Error("Method not implemented.");
+  }
+  getMaxListeners(): number {
+    throw new Error("Method not implemented.");
+  }
+  listeners<K>(eventName: string | symbol): Function[] {
+    throw new Error("Method not implemented.");
+  }
+  rawListeners<K>(eventName: string | symbol): Function[] {
+    throw new Error("Method not implemented.");
+  }
+  emit<K>(eventName: string | symbol, ...args: any[]): boolean {
+    throw new Error("Method not implemented.");
+  }
+  listenerCount<K>(eventName: string | symbol, listener?: Function | undefined): number {
+    throw new Error("Method not implemented.");
+  }
+  prependListener<K>(eventName: string | symbol, listener: (...args: any[]) => void): this {
+    throw new Error("Method not implemented.");
+  }
+  prependOnceListener<K>(eventName: string | symbol, listener: (...args: any[]) => void): this {
+    throw new Error("Method not implemented.");
+  }
+  eventNames(): (string | symbol)[] {
+    throw new Error("Method not implemented.");
+  }
+
+}