Improve Message Output

Cajs · Cajs · commit f8213018702f · 2025-07-04T09:10:12.000Z
diff --git a/main.go b/main.go
@@ -99,10 +99,15 @@ func clearCache(cachePath string) {
 
 func logJSON(msg string, fields map[string]string) {
 	entry := map[string]string{
-		"msg": "[nginx-cache-sync] " + msg,
+		"msg": msg,
 	}
 	for k, v := range fields {
 		entry[k] = v
 	}
-	_ = json.NewEncoder(os.Stdout).Encode(entry)
+	jsonBytes, err := json.Marshal(entry)
+	if err != nil {
+		fmt.Fprintf(os.Stdout, "[nginx-cache-sync] {\"msg\":\"failed to encode log: %s\"}\n", err.Error())
+		return
+	}
+	fmt.Fprintf(os.Stdout, "[nginx-cache-sync] %s\n", string(jsonBytes))
 }

Original file line number	Diff line number	Diff line change
`@@ -99,10 +99,15 @@ func clearCache(cachePath string) {`
`99`	`99`
`100`	`100`	`func logJSON(msg string, fields map[string]string) {`
`101`	`101`	`entry := map[string]string{`
`102`		`- "msg": "[nginx-cache-sync] " + msg,`
	`102`	`+ "msg": msg,`
`103`	`103`	`}`
`104`	`104`	`for k, v := range fields {`
`105`	`105`	`entry[k] = v`
`106`	`106`	`}`
`107`		`- _ = json.NewEncoder(os.Stdout).Encode(entry)`
	`107`	`+ jsonBytes, err := json.Marshal(entry)`
	`108`	`+ if err != nil {`
	`109`	`+ fmt.Fprintf(os.Stdout, "[nginx-cache-sync] {\"msg\":\"failed to encode log: %s\"}\n", err.Error())`
	`110`	`+ return`
	`111`	`+ }`
	`112`	`+ fmt.Fprintf(os.Stdout, "[nginx-cache-sync] %s\n", string(jsonBytes))`
`108`	`113`	`}`