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 the code to associate tuple key with array of device ids

Browse Source
This commit is contained in:
Brendan Chen
2025-02-03 21:31:18 -08:00
parent 69525a643d
commit 3bdc730c95
1 changed files with 13 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/services/NotificationService.ts
View File

@@ -2,6 +2,7 @@ import { GetterRepository } from "../repositories/GetterRepository";
import * as crypto from "node:crypto";
import jwt from "jsonwebtoken";
import fs from "fs";
import { TupleKey } from "../types/TupleKey";
interface ScheduledNotificationData {
deviceId: string;
@@ -78,6 +79,13 @@ export class NotificationService {
*/
public async scheduleNotification({ deviceId, shuttleId, stopId }: ScheduledNotificationData) {
// Associate TupleKey(shuttleId, stopId) with array of device IDs
const tuple = new TupleKey(shuttleId, stopId);
if (this.deviceIdsToDeliverTo[tuple.toString()] === undefined) {
this.deviceIdsToDeliverTo[tuple.toString()] = [deviceId];
} else {
this.deviceIdsToDeliverTo[tuple.toString()].push(deviceId);
}
// Refresh the subscriber with the updated array if needed
// In the subscriber callback:
@@ -103,8 +111,12 @@ export class NotificationService {
* @param stopId
*/
public isNotificationScheduled({ deviceId, shuttleId, stopId }: ScheduledNotificationData): boolean {
const tuple = new TupleKey(shuttleId, stopId);
if (this.deviceIdsToDeliverTo[tuple.toString()] === undefined) {
return false;
}
return this.deviceIdsToDeliverTo[tuple.toString()].includes(deviceId);
}
public cancelAllNotifications(deviceId: string) {