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 bindings for the notifications repository

Browse Source
This commit is contained in:
Brendan Chen
2025-03-27 11:34:01 -07:00
parent a84cedd05a
commit 9c22e154be
1 changed files with 12 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
src/repositories/InMemoryNotificationRepository.ts
View File

@@ -21,6 +21,16 @@ export class InMemoryNotificationRepository implements NotificationRepository {
private listeners: Listener[] = [];
constructor() {
this.getAllNotificationsForShuttleAndStopId = this.getAllNotificationsForShuttleAndStopId.bind(this);
this.getSecondsThresholdForNotificationIfExists = this.getSecondsThresholdForNotificationIfExists.bind(this);
this.deleteNotificationIfExists = this.deleteNotificationIfExists.bind(this);
this.addOrUpdateNotification = this.addOrUpdateNotification.bind(this);
this.isNotificationScheduled = this.isNotificationScheduled.bind(this);
this.subscribeToNotificationChanges = this.subscribeToNotificationChanges.bind(this);
this.unsubscribeFromNotificationChanges = this.unsubscribeFromNotificationChanges.bind(this);
}
async getAllNotificationsForShuttleAndStopId(shuttleId: string, stopId: string) {
const tuple = new TupleKey(shuttleId, stopId);
if (this.deviceIdsToDeliverTo[tuple.toString()] === undefined) {
@@ -51,7 +61,8 @@ export class InMemoryNotificationRepository implements NotificationRepository {
}
async isNotificationScheduled(lookupArguments: NotificationLookupArguments): Promise<boolean> {
return await this.getSecondsThresholdForNotificationIfExists(lookupArguments) !== null;
const threshold = await this.getSecondsThresholdForNotificationIfExists(lookupArguments);
return threshold !== null;
}
async addOrUpdateNotification({