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 seconds threshold for notification

Browse Source
This commit is contained in:
Brendan Chen
2025-02-03 22:47:17 -08:00
parent d357af7509
commit 16d2d4b4ef
1 changed files with 14 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
src/services/NotificationService.ts
View File

@@ -1,5 +1,4 @@
import { GetterRepository } from "../repositories/GetterRepository"; import { GetterRepository } from "../repositories/GetterRepository";
import * as crypto from "node:crypto";
import jwt from "jsonwebtoken"; import jwt from "jsonwebtoken";
import fs from "fs"; import fs from "fs";
import { TupleKey } from "../types/TupleKey"; import { TupleKey } from "../types/TupleKey";
@@ -140,11 +139,7 @@ export class NotificationService {
const indicesToRemove = new Set(); const indicesToRemove = new Set();
await Promise.all(this.deviceIdsToDeliverTo[tuple.toString()].map(async (deviceId, index) => { await Promise.all(this.deviceIdsToDeliverTo[tuple.toString()].map(async (deviceId, index) => {
const deliveredSuccessfully = await this.sendEtaNotificationImmediately({ const deliveredSuccessfully = await this.sendEtaNotificationImmediatelyIfSecondsRemainingBelowThreshold(deviceId, eta);
deviceId,
shuttleId: eta.shuttleId,
stopId: eta.stopId,
});
if (deliveredSuccessfully) { if (deliveredSuccessfully) {
indicesToRemove.add(index); indicesToRemove.add(index);
} }
@@ -153,6 +148,19 @@ export class NotificationService {
this.deviceIdsToDeliverTo[tuple.toString()] = this.deviceIdsToDeliverTo[tuple.toString()].filter((_, index) => !indicesToRemove.has(index)); this.deviceIdsToDeliverTo[tuple.toString()] = this.deviceIdsToDeliverTo[tuple.toString()].filter((_, index) => !indicesToRemove.has(index));
} }
private async sendEtaNotificationImmediatelyIfSecondsRemainingBelowThreshold(deviceId: string, eta: IEta) {
const secondsThresholdForNotificationToFire = 300;
if (eta.secondsRemaining > secondsThresholdForNotificationToFire) {
return false;
}
return await this.sendEtaNotificationImmediately({
deviceId,
shuttleId: eta.shuttleId,
stopId: eta.stopId,
});
}
/** /**
* Queue a notification to be sent. * Queue a notification to be sent.
* @param deviceId The device ID to send the notification to. * @param deviceId The device ID to send the notification to.