keiths feedback

observIQ · Nov 8, 2023 · 5001091 · 5001091
1 parent 8bce2fe
commit 5001091
Showing 1 changed file with 10 additions and 9 deletions.
diff --git a/receiver/httpreceiver/logs.go b/receiver/httpreceiver/logs.go
@@ -217,18 +217,19 @@ func (r *httpLogsReceiver) processLogs(now pcommon.Timestamp, logs []map[string]
 
 // parsePayload transforms the payload into []map[string]interface structure
 func parsePayload(payload []byte) ([]map[string]interface{}, error) {
-	rawLogsArray := []json.RawMessage{}
-	rawLogObject := json.RawMessage{}
-	if err := json.Unmarshal(payload, &rawLogsArray); err != nil {
-		if err.Error() == "json: cannot unmarshal object into Go value of type []json.RawMessage" {
-			if err = json.Unmarshal(payload, &rawLogObject); err != nil {
-				return nil, err
-			}
-			return parseJSONObject(rawLogObject)
+	if string(payload[0]) == "[" {
+		rawLogsArray := []json.RawMessage{}
+		if err := json.Unmarshal(payload, &rawLogsArray); err != nil {
+			return nil, err
 		}
+		return parseJSONArray(rawLogsArray)
+	}
+
+	rawLogObject := json.RawMessage{}
+	if err := json.Unmarshal(payload, &rawLogObject); err != nil {
 		return nil, err
 	}
-	return parseJSONArray(rawLogsArray)
+	return parseJSONObject(rawLogObject)
 }
 
 func parseJSONObject(rawLog json.RawMessage) ([]map[string]interface{}, error) {