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

Add getAverageTravelTimeSeconds in SelfUpdatingETARepository definition

Browse Source
This commit is contained in:
Brendan Chen
2025-11-11 12:26:22 -08:00
parent e0b00d1887
commit 13bfc853e3
2 changed files with 16 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -3,7 +3,7 @@ import { ETARepositoryEventName, ETARepositoryEventListener } from "./ETAGetterR
import { SelfUpdatingETARepository } from "./SelfUpdatingETARepository"; import { SelfUpdatingETARepository } from "./SelfUpdatingETARepository";
import { BaseRedisRepository } from "../../BaseRedisRepository"; import { BaseRedisRepository } from "../../BaseRedisRepository";
import { createClient, RedisClientType } from "redis"; import { createClient, RedisClientType } from "redis";
import { ShuttleGetterRepository } from "../ShuttleGetterRepository"; import { ShuttleGetterRepository, ShuttleTravelTimeDataIdentifier, ShuttleTravelTimeDateFilterArguments } from "../ShuttleGetterRepository";
import { REDIS_RECONNECT_INTERVAL } from "../../../environment"; import { REDIS_RECONNECT_INTERVAL } from "../../../environment";
export class RedisSelfUpdatingETARepository extends BaseRedisRepository implements SelfUpdatingETARepository { export class RedisSelfUpdatingETARepository extends BaseRedisRepository implements SelfUpdatingETARepository {
@@ -20,7 +20,9 @@ export class RedisSelfUpdatingETARepository extends BaseRedisRepository implemen
) { ) {
super(redisClient); super(redisClient);
} }
getAverageTravelTimeSeconds(identifier: ShuttleTravelTimeDataIdentifier, dateFilter: ShuttleTravelTimeDateFilterArguments): Promise<number | undefined> {
throw new Error("Method not implemented.");
}
startListeningForUpdates(): void { startListeningForUpdates(): void {
throw new Error("Method not implemented."); throw new Error("Method not implemented.");
} }

12
src/repositories/shuttle/eta/SelfUpdatingETARepository.ts
View File

@@ -1,3 +1,4 @@
import { ShuttleTravelTimeDataIdentifier, ShuttleTravelTimeDateFilterArguments } from "../ShuttleGetterRepository";
import { ETAGetterRepository } from "./ETAGetterRepository"; import { ETAGetterRepository } from "./ETAGetterRepository";
export interface SelfUpdatingETARepository extends ETAGetterRepository { export interface SelfUpdatingETARepository extends ETAGetterRepository {
@@ -6,4 +7,15 @@ export interface SelfUpdatingETARepository extends ETAGetterRepository {
* shuttle updates * shuttle updates
*/ */
startListeningForUpdates(): void; startListeningForUpdates(): void;
/**
* Get average travel time between two stops based on historical data.
* Returns undefined if no data exists for the specified time range.
* @param identifier - The route and stop IDs to query
* @param dateFilter - The date range to filter data
*/
getAverageTravelTimeSeconds(
identifier: ShuttleTravelTimeDataIdentifier,
dateFilter: ShuttleTravelTimeDateFilterArguments
): Promise<number | undefined>;
} }