f88985149c/lib/channel/generic.js (L59)

2019-08-11 19:11:33 -04:00 · 2019-08-11 19:11:33 -04:00 · 083e2b588e
commit 083e2b588e
parent ccf2b7b321
1 changed files with 10 additions and 0 deletions
--- a/sonic/ingester.go
+++ b/sonic/ingester.go
@ -98,6 +98,16 @@ func NewIngester(host string, port int, password string) (Ingestable, error) {
 }

 func (i ingesterChannel) Push(collection, bucket, object, text string) (err error) {
+	//
+	patterns := []struct {
+		Pattern string
+		Replacement     string
+	}{{"\\", "\\\\"},
+		{"\n", "\\n"},
+		{"\"",  "\\\""}}
+	for _, v := range patterns {
+		text = strings.Replace(text, v.Pattern, v.Replacement, -1)
+	}

 	chunks := splitText(text, i.cmdMaxBytes/2)
 	// split chunks with partial success will yield single error