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

Add a base protected method for adding ETAs and emitting events

Browse Source
This commit is contained in:
Brendan Chen
2025-11-11 19:33:52 -08:00
parent 9af50ddfe9
commit e8f4e7b9ee
1 changed files with 9 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/repositories/shuttle/eta/BaseRedisETARepository.ts
View File

@@ -1,6 +1,6 @@
import { IEta } from "../../../entities/ShuttleRepositoryEntities"; import { IEta } from "../../../entities/ShuttleRepositoryEntities";
import { BaseRedisRepository } from "../../BaseRedisRepository"; import { BaseRedisRepository } from "../../BaseRedisRepository";
import { ETAGetterRepository, ETARepositoryEventListener, ETARepositoryEventName } from "./ETAGetterRepository"; import { ETAGetterRepository, ETARepositoryEvent, ETARepositoryEventListener, ETARepositoryEventName } from "./ETAGetterRepository";
export abstract class BaseRedisETARepository extends BaseRedisRepository implements ETAGetterRepository { export abstract class BaseRedisETARepository extends BaseRedisRepository implements ETAGetterRepository {
private static readonly ETA_KEY_PREFIX = 'shuttle:eta:'; private static readonly ETA_KEY_PREFIX = 'shuttle:eta:';
@@ -65,6 +65,14 @@ export abstract class BaseRedisETARepository extends BaseRedisRepository impleme
return this.createEtaFromRedisData(data); return this.createEtaFromRedisData(data);
} }
// Protected setter for internal use
protected async addOrUpdateEta(eta: IEta): Promise<void> {
const key = this.createEtaKey(eta.shuttleId, eta.stopId);
const hash = this.createRedisHashFromEta(eta);
await this.redisClient.hSet(key, hash);
this.emit(ETARepositoryEvent.ETA_UPDATED, eta);
}
// EventEmitter override methods for type safety // EventEmitter override methods for type safety
override on<T extends ETARepositoryEventName>( override on<T extends ETARepositoryEventName>(
event: T, event: T,