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