elasticsearch: skip error on mapping request

Author: rafael_chicoli

pkg/elasticsearch/v1/elasticsearch.go

@@ -169,7 +169,11 @@ func parseRequest(bulkableRequests []elastic.BulkableRequest) (*mapRequests, err
 		}
 		for _, v := range vv {
 			if header {
-				json.Unmarshal([]byte(v), payload)
+				err := json.Unmarshal([]byte(v), payload)
+				if err != nil {
+					// skip error and try to parse next line
+					continue
+				}
 				requests[payload.ID] = ""
 				header = false
 				continue

pkg/elasticsearch/v2/elasticsearch.go

@@ -169,7 +169,11 @@ func parseRequest(bulkableRequests []elastic.BulkableRequest) (*mapRequests, err
 		}
 		for _, v := range vv {
 			if header {
-				json.Unmarshal([]byte(v), payload)
+				err := json.Unmarshal([]byte(v), payload)
+				if err != nil {
+					// skip error and try to parse next line
+					continue
+				}
 				requests[payload.ID] = ""
 				header = false
 				continue

pkg/elasticsearch/v5/elasticsearch.go

@@ -172,7 +172,11 @@ func parseRequest(bulkableRequests []elastic.BulkableRequest) (*mapRequests, err
 		}
 		for _, v := range vv {
 			if header {
-				json.Unmarshal([]byte(v), payload)
+				err := json.Unmarshal([]byte(v), payload)
+				if err != nil {
+					// skip error and try to parse next line
+					continue
+				}
 				requests[payload.ID] = ""
 				header = false
 				continue

pkg/elasticsearch/v6/elasticsearch.go

@@ -171,7 +171,11 @@ func parseRequest(bulkableRequests []elastic.BulkableRequest) (*mapRequests, err
 		}
 		for _, v := range vv {
 			if header {
-				json.Unmarshal([]byte(v), payload)
+				err := json.Unmarshal([]byte(v), payload)
+				if err != nil {
+					// skip error and try to parse next line
+					continue
+				}
 				requests[payload.ID] = ""
 				header = false
 				continue