add parsing tests

Author: ndakkoune

aws/logs_monitoring_go/internal/parsing/parsing_test.go

@@ -0,0 +1,48 @@
+// Unless explicitly stated otherwise all files in this repository are licensed
+// under the Apache License Version 2.0.
+// This product includes software developed at Datadog (https://www.datadoghq.com/).
+// Copyright 2026-Present Datadog, Inc.
+
+package parsing
+
+import (
+	"encoding/json"
+	"testing"
+)
+
+func TestDetectInvocationSource(t *testing.T) {
+	tests := map[string]struct {
+		event   json.RawMessage
+		wantKey invocationSource
+	}{
+		"cloudwatch logs": {
+			event:   json.RawMessage(`{"awslogs":{"data":"dGVzdA=="}}`),
+			wantKey: invocationSourceCloudwatchLogs,
+		},
+		"empty object": {
+			event:   json.RawMessage(`{}`),
+			wantKey: invocationSourceUnknown,
+		},
+		"s3 not yet implemented": {
+			event:   json.RawMessage(`{"Records":[{"s3":{"bucket":{"name":"my-bucket"},"object":{"key":"my-key"}}}]}`),
+			wantKey: invocationSourceUnknown,
+		},
+		"not JSON": {
+			event:   json.RawMessage(`not a json`),
+			wantKey: invocationSourceUnknown,
+		},
+		"empty input": {
+			event:   json.RawMessage(``),
+			wantKey: invocationSourceUnknown,
+		},
+	}
+
+	for name, tc := range tests {
+		t.Run(name, func(t *testing.T) {
+			got := detectInvocationSource(tc.event)
+			if got != tc.wantKey {
+				t.Errorf("got %d, want %d", got, tc.wantKey)
+			}
+		})
+	}
+}