Function TestHandler

packaging/tools/agent-events/server_test.go:101–658

(t *testing.T)

}

func TestHandler(t *testing.T) {
	setupTest(t) // Setup once for all sub-tests

	// --- Test Cases ---

	t.Run("FirstValidRequest", func(t *testing.T) {
		t.Cleanup(resetDedupState) // Reset map for isolation
		jsonBody := `{"id": "uuid-1", "data": "value1"}`
		req := httptest.NewRequest(http.MethodPost, "/", strings.NewReader(jsonBody))
		rr := httptest.NewRecorder()
		stdout, _ := captureOutput(t, func() { handler(rr, req) })
		if status := rr.Code; status != http.StatusOK {
			t.Errorf("status: got %v want %v", status, http.StatusOK)
		}
		if rr.Body.String() != "OK" {
			t.Errorf("body: got %v want %v", rr.Body.String(), "OK")
		}
		if !strings.Contains(stdout, `"id":"uuid-1"`) {
			t.Errorf("stdout missing id: %q", stdout)
		}
		mapMutex.Lock()
		mapLen := len(seenIDs)
		mapMutex.Unlock()
		if mapLen != 1 {
			t.Errorf("map size: got %d want 1", mapLen)
		}
	})

	t.Run("DuplicateRequestWithinWindow", func(t *testing.T) {
		t.Cleanup(resetDedupState)
		firstJsonBody := `{"id": "uuid-2", "data": "value2"}`
		firstReq := httptest.NewRequest(http.MethodPost, "/", strings.NewReader(firstJsonBody))
		firstRr := httptest.NewRecorder()
		captureOutput(t, func() { handler(firstRr, firstReq) })
		if firstRr.Code != http.StatusOK {
			t.Fatalf("Setup failed")
		}
		req := httptest.NewRequest(http.MethodPost, "/", strings.NewReader(firstJsonBody))
		rr := httptest.NewRecorder()
		stdout, _ := captureOutput(t, func() { handler(rr, req) })
		if status := rr.Code; status != http.StatusOK {
			t.Errorf("status: got %v want %v", status, http.StatusOK)
		}
		if rr.Body.String() != "OK" {
			t.Errorf("body: got %v want %v", rr.Body.String(), "OK")
		}
		if stdout != "" {
			t.Errorf("stdout not empty: %q", stdout)
		}
		mapMutex.Lock()
		mapLen := len(seenIDs)
		mapMutex.Unlock()
		if mapLen != 1 {
			t.Errorf("map size: got %d want 1", mapLen)
		}
	})

	t.Run("InvalidJSON", func(t *testing.T) {