From 97feec6d3fa43df6ef192ebf41d186c04138a5bb Mon Sep 17 00:00:00 2001 From: Brendan Chen Date: Tue, 11 Nov 2025 20:47:20 -0800 Subject: [PATCH] Connect etaRepository to Redis in the builder --- src/entities/InterchangeSystem.ts | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/entities/InterchangeSystem.ts b/src/entities/InterchangeSystem.ts index 49ec992..f9877b9 100644 --- a/src/entities/InterchangeSystem.ts +++ b/src/entities/InterchangeSystem.ts @@ -21,6 +21,7 @@ import { ETAGetterRepository } from "../repositories/shuttle/eta/ETAGetterReposi import { RedisSelfUpdatingETARepository } from "../repositories/shuttle/eta/RedisSelfUpdatingETARepository"; import { RedisExternalSourceETARepository } from "../repositories/shuttle/eta/RedisExternalSourceETARepository"; import { InMemorySelfUpdatingETARepository } from "../repositories/shuttle/eta/InMemorySelfUpdatingETARepository"; +import { BaseRedisETARepository } from "../repositories/shuttle/eta/BaseRedisETARepository"; export interface InterchangeSystemBuilderArguments { name: string; @@ -107,12 +108,13 @@ export class InterchangeSystem { shuttleDataLoader ); - let etaRepository: ETAGetterRepository; + let etaRepository: BaseRedisETARepository; if (args.useSelfUpdatingEtas) { etaRepository = new RedisSelfUpdatingETARepository(shuttleRepository); } else { etaRepository = new RedisExternalSourceETARepository(); } + await etaRepository.connect(); return { shuttleRepository, etaRepository, timedShuttleDataLoader }; }