From 2103b6ae23f4d3ef8ee8c8329fe51ba5555f3813 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E6=9D=8E=E4=BC=9F=E4=B9=90?= <mogfee@163.com>
Date: Fri, 3 Mar 2023 15:23:00 +0800
Subject: [PATCH] x

---
 log/mq/nsq.go      | 10 ++++++----
 log/mq/nsq_test.go | 14 ++++++++++++++
 2 files changed, 20 insertions(+), 4 deletions(-)
 create mode 100644 log/mq/nsq_test.go

diff --git a/log/mq/nsq.go b/log/mq/nsq.go
index 6e9be64..39339f0 100644
--- a/log/mq/nsq.go
+++ b/log/mq/nsq.go
@@ -79,13 +79,15 @@ func (l *nsqLogger) Log(level log.Level, keyvals ...any) error {
 	if len(keyvals)&1 == 1 {
 		keyvals = append(keyvals, "KEYVALS UNPAIRED")
 	}
-	buf := make(map[any]any)
+	buf := make(map[string]any)
 	buf["status"] = level.String()
 	for i := 0; i < len(keyvals); i += 2 {
-		buf[keyvals[i]] = keyvals[i+1]
+		buf[fmt.Sprintf("%v", keyvals[i])] = keyvals[i+1]
+	}
+	body, err := json.Marshal(buf)
+	if err != nil {
+		return err
 	}
-	body, _ := json.Marshal(buf)
-	fmt.Println("ww", string(body))
 	l.list <- body
 	return nil
 }
diff --git a/log/mq/nsq_test.go b/log/mq/nsq_test.go
new file mode 100644
index 0000000..78a795b
--- /dev/null
+++ b/log/mq/nsq_test.go
@@ -0,0 +1,14 @@
+package mq
+
+import (
+	"git.diulo.com/mogfee/protoc-gen-kit/log"
+	"testing"
+)
+
+func Test_nsqLogger_Log(t *testing.T) {
+	logger := log.With(NewNsqLogger("localhost:4150", "app_log"),
+		"ts", log.DefaultTimestamp,
+		"caller", log.DefaultCaller,
+	)
+	logger.Log(log.LevelInfo, "user name ttt")
+}