brendan/project-inter-server
1
0
Fork 0
mirror of https://github.com/brendan-ch/project-inter-server.git synced 2026-04-19 08:50:29 +00:00
Code Issues Packages Projects Releases Wiki Activity

Connect etaRepository to Redis in the builder

Browse Source
This commit is contained in:
Brendan Chen
2025-11-11 20:47:20 -08:00
parent e03e962ab9
commit 97feec6d3f
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/entities/InterchangeSystem.ts
View File

@@ -21,6 +21,7 @@ import { ETAGetterRepository } from "../repositories/shuttle/eta/ETAGetterReposi
import { RedisSelfUpdatingETARepository } from "../repositories/shuttle/eta/RedisSelfUpdatingETARepository"; import { RedisSelfUpdatingETARepository } from "../repositories/shuttle/eta/RedisSelfUpdatingETARepository";
import { RedisExternalSourceETARepository } from "../repositories/shuttle/eta/RedisExternalSourceETARepository"; import { RedisExternalSourceETARepository } from "../repositories/shuttle/eta/RedisExternalSourceETARepository";
import { InMemorySelfUpdatingETARepository } from "../repositories/shuttle/eta/InMemorySelfUpdatingETARepository"; import { InMemorySelfUpdatingETARepository } from "../repositories/shuttle/eta/InMemorySelfUpdatingETARepository";
import { BaseRedisETARepository } from "../repositories/shuttle/eta/BaseRedisETARepository";
export interface InterchangeSystemBuilderArguments { export interface InterchangeSystemBuilderArguments {
name: string; name: string;
@@ -107,12 +108,13 @@ export class InterchangeSystem {
shuttleDataLoader shuttleDataLoader
); );
let etaRepository: ETAGetterRepository; let etaRepository: BaseRedisETARepository;
if (args.useSelfUpdatingEtas) { if (args.useSelfUpdatingEtas) {
etaRepository = new RedisSelfUpdatingETARepository(shuttleRepository); etaRepository = new RedisSelfUpdatingETARepository(shuttleRepository);
} else { } else {
etaRepository = new RedisExternalSourceETARepository(); etaRepository = new RedisExternalSourceETARepository();
} }
await etaRepository.connect();
return { shuttleRepository, etaRepository, timedShuttleDataLoader }; return { shuttleRepository, etaRepository, timedShuttleDataLoader };
} }