Add shuttleRepository injection to the constructor of RedisSelfUpdatingETARepository

This commit is contained in:
2025-11-11 11:41:39 -08:00
parent 7ac8232878
commit cb23379723

View File

@@ -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.");
}