From a95704db3f895bafe9474e40cb25ec89eb414191 Mon Sep 17 00:00:00 2001
From: DoobleD <pierre.alletru@gmail.com>
Date: Fri, 8 Nov 2024 11:43:33 +0100
Subject: [PATCH] fix missing error handlers on pi-watch and pi-karma redis
 clients

---
 CHANGELOG.md | 4 ++++
 index.js     | 6 ++++++
 package.json | 2 +-
 3 files changed, 11 insertions(+), 1 deletion(-)

diff --git a/CHANGELOG.md b/CHANGELOG.md
index 4ed4ab6..452d930 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -4,6 +4,10 @@ The format is based on [Keep a Changelog](https://keepachangelog.com/).
 
 ### Unreleased
 
+### [2.0.8] - 2024-11-08
+
+- fix missing error handlers on pi-watch and pi-karma redis clients [#45](https://github.com/haraka/haraka-plugin-redis/issues/45)
+
 ### [2.0.7] - 2024-04-21
 
 - populate [files] in package.json. Delete .npmignore.
diff --git a/index.js b/index.js
index 8021aa8..a481aa4 100644
--- a/index.js
+++ b/index.js
@@ -216,6 +216,9 @@ exports.redis_subscribe_pattern = async function (pattern, onMessage) {
   if (this.redis) return // already subscribed?
 
   this.redis = redis.createClient(this.redisCfg.pubsub)
+  this.redis.on('error', (err) => {
+    this.logerror(err.message)
+  })
   await this.redis.connect()
 
   await this.redis.pSubscribe(pattern, onMessage)
@@ -234,6 +237,9 @@ exports.redis_subscribe = async function (connection, onMessage) {
   }, 3 * 1000)
 
   connection.notes.redis = redis.createClient(this.redisCfg.pubsub)
+  connection.notes.redis.on('error', (err) => {
+    this.logerror(err.message)
+  })
   await connection.notes.redis.connect()
 
   clearTimeout(timer)
diff --git a/package.json b/package.json
index 4eaa9dc..d999062 100644
--- a/package.json
+++ b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "haraka-plugin-redis",
-  "version": "2.0.7",
+  "version": "2.0.8",
   "description": "Redis plugin for Haraka & other plugins to inherit from",
   "main": "index.js",
   "files": [