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

Unify eventual getter implementations in a BaseRedisETARepository class

Browse Source
This commit is contained in:
Brendan Chen
2025-11-11 18:47:13 -08:00
parent 7497c1d004
commit 6cf61d1cdb
3 changed files with 69 additions and 61 deletions
Download Patch File Download Diff File Expand all files Collapse all files

62
src/repositories/shuttle/eta/BaseRedisETARepository.ts Normal file
View File

@@ -0,0 +1,62 @@
import { IEta } from "../../../entities/ShuttleRepositoryEntities";
import { BaseRedisRepository } from "../../BaseRedisRepository";
import { ETAGetterRepository, ETARepositoryEventListener, ETARepositoryEventName } from "./ETAGetterRepository";
export abstract class BaseRedisETARepository extends BaseRedisRepository implements ETAGetterRepository {
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.");
}
// EventEmitter override methods for type safety
override on<T extends ETARepositoryEventName>(
event: T,
listener: ETARepositoryEventListener<T>,
): this;
override on(event: string | symbol, listener: (...args: any[]) => void): this {
return super.on(event, listener);
}
override once<T extends ETARepositoryEventName>(
event: T,
listener: ETARepositoryEventListener<T>,
): this;
override once(event: string | symbol, listener: (...args: any[]) => void): this {
return super.once(event, listener);
}
override off<T extends ETARepositoryEventName>(
event: T,
listener: ETARepositoryEventListener<T>,
): this;
override off(event: string | symbol, listener: (...args: any[]) => void): this {
return super.off(event, listener);
}
override addListener<T extends ETARepositoryEventName>(
event: T,
listener: ETARepositoryEventListener<T>,
): this;
override addListener(event: string | symbol, listener: (...args: any[]) => void): this {
return super.addListener(event, listener);
}
override removeListener<T extends ETARepositoryEventName>(
event: T,
listener: ETARepositoryEventListener<T>,
): this;
override removeListener(event: string | symbol, listener: (...args: any[]) => void): this {
return super.removeListener(event, listener);
}
override removeAllListeners(eventName?: string | symbol): this {
return super.removeAllListeners(eventName);
}
}

33
src/repositories/shuttle/eta/RedisExternalSourceETARepository.ts
View File

@@ -1,40 +1,13 @@
import { IEta } from "../../../entities/ShuttleRepositoryEntities";
import { BaseRedisRepository } from "../../BaseRedisRepository";
import { ETARepositoryEventName, ETARepositoryEventListener } from "./ETAGetterRepository";
import { BaseRedisETARepository } from "./BaseRedisETARepository";
import { ExternalSourceETARepository } from "./ExternalSourceETARepository";
export class RedisExternalSourceETARepository extends BaseRedisRepository implements ExternalSourceETARepository {
export class RedisExternalSourceETARepository extends BaseRedisETARepository 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.");
}
}

35
src/repositories/shuttle/eta/RedisSelfUpdatingETARepository.ts
View File

@@ -1,12 +1,10 @@
import { IEta } from "../../../entities/ShuttleRepositoryEntities";
import { ETARepositoryEventName, ETARepositoryEventListener } from "./ETAGetterRepository";
import { SelfUpdatingETARepository } from "./SelfUpdatingETARepository";
import { BaseRedisRepository } from "../../BaseRedisRepository";
import { BaseRedisETARepository } from "./BaseRedisETARepository";
import { createClient, RedisClientType } from "redis";
import { ShuttleGetterRepository, ShuttleTravelTimeDataIdentifier, ShuttleTravelTimeDateFilterArguments } from "../ShuttleGetterRepository";
import { REDIS_RECONNECT_INTERVAL } from "../../../environment";
export class RedisSelfUpdatingETARepository extends BaseRedisRepository implements SelfUpdatingETARepository {
export class RedisSelfUpdatingETARepository extends BaseRedisETARepository implements SelfUpdatingETARepository {
constructor(
readonly shuttleRepository: ShuttleGetterRepository,
redisClient: RedisClientType = createClient({
@@ -20,37 +18,12 @@ export class RedisSelfUpdatingETARepository extends BaseRedisRepository implemen
) {
super(redisClient);
}
getAverageTravelTimeSeconds(identifier: ShuttleTravelTimeDataIdentifier, dateFilter: ShuttleTravelTimeDateFilterArguments): Promise<number | undefined> {
throw new Error("Method not implemented.");
}
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.");
}
}