From cc6623404c2a4081af9f6ffc9a285d983e724901 Mon Sep 17 00:00:00 2001 From: Brendan Chen Date: Mon, 31 Mar 2025 19:37:19 -0700 Subject: [PATCH] add connect/disconnect methods --- src/repositories/RedisNotificationRepository.ts | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/src/repositories/RedisNotificationRepository.ts b/src/repositories/RedisNotificationRepository.ts index 8480877..6397140 100644 --- a/src/repositories/RedisNotificationRepository.ts +++ b/src/repositories/RedisNotificationRepository.ts @@ -21,6 +21,14 @@ class RedisNotificationRepository implements NotificationRepository { this.unsubscribeFromNotificationChanges = this.unsubscribeFromNotificationChanges.bind(this); } + public async connect() { + await this.redisClient.connect(); + } + + public async disconnect() { + await this.redisClient.disconnect(); + } + public async addOrUpdateNotification(notification: ScheduledNotification): Promise { }