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

add bindings and redis client arg for constructor

Browse Source
This commit is contained in:
Brendan Chen
2025-03-31 19:35:38 -07:00
parent bef2ce18fb
commit c98367f12e
1 changed files with 16 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
src/repositories/RedisNotificationRepository.ts
View File

@@ -4,10 +4,24 @@ import {
NotificationRepository, NotificationRepository,
ScheduledNotification ScheduledNotification
} from "./NotificationRepository"; } from "./NotificationRepository";
import { createClient, RedisClientType } from "redis";
class RedisNotificationRepository implements NotificationRepository { class RedisNotificationRepository implements NotificationRepository {
addOrUpdateNotification(notification: ScheduledNotification): Promise<void> { constructor(
return Promise.resolve(undefined); private redisClient = createClient({
url: process.env.REDIS_URL,
}),
) {
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);
}
public async addOrUpdateNotification(notification: ScheduledNotification): Promise<void> {
} }
public async deleteNotificationIfExists(lookupArguments: NotificationLookupArguments): Promise<void> { public async deleteNotificationIfExists(lookupArguments: NotificationLookupArguments): Promise<void> {