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 code to update device ids object on successful delivery

Browse Source
This commit is contained in:
Brendan Chen
2025-02-03 21:50:59 -08:00
parent e96316aa1e
commit 8bc71d25fe
1 changed files with 11 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
src/services/NotificationService.ts
View File

@@ -19,7 +19,9 @@ export class NotificationService {
return this._lastRefreshedTimeMs; return this._lastRefreshedTimeMs;
} }
constructor(private repository: GetterRepository) {} constructor(private repository: GetterRepository) {
this.etaSubscriberCallback = this.etaSubscriberCallback.bind(this);
}
/** /**
* An object of device ID arrays to deliver notifications to. * An object of device ID arrays to deliver notifications to.
@@ -79,13 +81,19 @@ export class NotificationService {
return; return;
} }
await Promise.all(this.deviceIdsToDeliverTo[tuple.toString()].map(async (deviceId) => { const indicesToRemove = new Set();
await this.sendEtaNotificationImmediately({ await Promise.all(this.deviceIdsToDeliverTo[tuple.toString()].map(async (deviceId, index) => {
const deliveredSuccessfully = await this.sendEtaNotificationImmediately({
deviceId, deviceId,
shuttleId: eta.shuttleId, shuttleId: eta.shuttleId,
stopId: eta.stopId, stopId: eta.stopId,
}); });
if (deliveredSuccessfully) {
indicesToRemove.add(index);
}
})); }));
this.deviceIdsToDeliverTo[tuple.toString()] = this.deviceIdsToDeliverTo[tuple.toString()].filter((_, index) => !indicesToRemove.has(index));
} }
/** /**
@@ -102,7 +110,6 @@ export class NotificationService {
this.deviceIdsToDeliverTo[tuple.toString()].push(deviceId); this.deviceIdsToDeliverTo[tuple.toString()].push(deviceId);
} }
// Refresh the subscriber with the updated array if needed
this.repository.unsubscribeFromEtaUpdates(this.etaSubscriberCallback); this.repository.unsubscribeFromEtaUpdates(this.etaSubscriberCallback);
this.repository.subscribeToEtaUpdates(this.etaSubscriberCallback); this.repository.subscribeToEtaUpdates(this.etaSubscriberCallback);