feat(redis): introduce pub/sub (#2855)

jef · Dec 15, 2021 · d6d8ef2 · d6d8ef2
1 parent 72140be
commit d6d8ef2
Show file tree

Hide file tree

Showing 2 changed files with 17 additions and 7 deletions.
diff --git a/dotenv-example b/dotenv-example
@@ -112,6 +112,7 @@ PUSHOVER_RETRY=
 PUSHOVER_SOUND=
 PUSHOVER_TOKEN=
 PUSHOVER_USER=
+REDIS_URL=
 RESTART_TIME=
 SCREENSHOT=
 SCREENSHOT_DIR=

diff --git a/src/messaging/redis.ts b/src/messaging/redis.ts
@@ -29,13 +29,22 @@ export function updateRedis(link: Link, store: Store) {
         updatedAt: new Date().toUTCString(),
       };
 
-      const redisUpdated = client.set(key, JSON.stringify(value));
-
-      if (redisUpdated) {
-        logger.info('✔ redis updated');
-      } else {
-        logger.error(`✖ couldn't update redis for key (${key})`);
-      }
+      const message = JSON.stringify(value);
+      client.set(key, message, (error, success) => {
+        if (error) {
+          logger.error(`✖ couldn't update redis for key (${key})`);
+        } else {
+          logger.info('✔ redis updated');
+        }
+      });
+
+      client.publish('streetmerchant', message, (error, success) => {
+        if (error) {
+          logger.error(`✖ couldn't publish to redis`);
+        } else {
+          logger.info('✔ redis message published');
+        }
+      });
     }
   } catch (error: unknown) {
     logger.error("✖ couldn't update redis", error);