From 0fb806bfda1ea9d3b5f791d3bde0ccedf2c7804c Mon Sep 17 00:00:00 2001
From: mountain <mountain@action2quare.com>
Date: Thu, 12 Oct 2023 12:03:11 +0900
Subject: [PATCH] =?UTF-8?q?JSONArrAppend=20=ED=98=B8=EC=B6=9C=20=EC=98=A4?=
 =?UTF-8?q?=EB=A5=98=20=EC=88=98=EC=A0=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 redis.go               | 6 ++++--
 wshandler/wshandler.go | 7 +++++++
 2 files changed, 11 insertions(+), 2 deletions(-)

diff --git a/redis.go b/redis.go
index add88f1..1d2e5b8 100644
--- a/redis.go
+++ b/redis.go
@@ -312,11 +312,13 @@ func (rh *RedisonHandler) JSONStrLen(key, path string) (res []int64, err error)
 }
 
 func (rh *RedisonHandler) JSONArrAppend(key, path string, values ...any) (int64, error) {
-	args := []any{
+	args := appendArgs[any]([]any{
 		"JSON.ARRAPPEND",
 		key,
 		path,
-	}
+	}, values...)
+
+	args = append(args, values...)
 	resp, err := rh.Do(rh.ctx, args...).Result()
 	if err != nil {
 		return 0, err
diff --git a/wshandler/wshandler.go b/wshandler/wshandler.go
index 4eeafce..18d1cf0 100644
--- a/wshandler/wshandler.go
+++ b/wshandler/wshandler.go
@@ -134,6 +134,13 @@ func NewWebsocketHandler(consumer session.Consumer, redisUrl string) (*Websocket
 					logger.Println("send_msg_queue_elem sender recover :", r, string(elem.msg))
 				}
 			}()
+			if elem == nil {
+				return
+			}
+			if elem.to == nil {
+				return
+			}
+
 			elem.to.WriteMessage(elem.mt, elem.msg)
 		}