Function TestTelemetryHandlers

server/handlers_test.go:176–227

TestTelemetryHandlers 测试 Telemetry 相关的处理器

(t *testing.T)

// TestTelemetryHandlers 测试 Telemetry 相关的处理器
func TestTelemetryHandlers(t *testing.T) {
	srv, cleanup := setupTestServer(t)
	defer cleanup()

	t.Run("RecordMetric", func(t *testing.T) {
		body := `{
			"name": "test_metric",
			"type": "counter",
			"value": 42.0,
			"tags": {
				"env": "test"
			}
		}`

		req := httptest.NewRequest(http.MethodPost, "/v1/telemetry/metrics", strings.NewReader(body))
		req.Header.Set("Content-Type", "application/json")
		w := httptest.NewRecorder()

		srv.Router().ServeHTTP(w, req)

		assert.Equal(t, http.StatusCreated, w.Code)
	})

	t.Run("ListMetrics", func(t *testing.T) {
		req := httptest.NewRequest(http.MethodGet, "/v1/telemetry/metrics", nil)
		w := httptest.NewRecorder()

		srv.Router().ServeHTTP(w, req)

		assert.Equal(t, http.StatusOK, w.Code)
	})

	t.Run("RecordTrace", func(t *testing.T) {
		t.Skip("Trace recording needs proper implementation")
	})

	t.Run("RecordLog", func(t *testing.T) {
		body := `{
			"level": "info",
			"message": "Test log message",
			"timestamp": "2024-01-01T00:00:00Z"
		}`

		req := httptest.NewRequest(http.MethodPost, "/v1/telemetry/logs", strings.NewReader(body))
		req.Header.Set("Content-Type", "application/json")
		w := httptest.NewRecorder()

		srv.Router().ServeHTTP(w, req)

		assert.Equal(t, http.StatusCreated, w.Code)
	})
}

// TestSystemHandlers 测试 System 相关的处理器
func TestSystemHandlers(t *testing.T) {