Function TestServiceFlush

internal/telemetry/telemetry_test.go:384–494

(t *testing.T)

}

func TestServiceFlush(t *testing.T) {
	t.Run("calls flusher with empty payload when no events recorded", func(t *testing.T) {
		t.Cleanup(stubDeviceID("test-device"))

		var captured SendTelemetryPayload
		called := false
		svc := newService(func(p SendTelemetryPayload) {
			called = true
			captured = p
		}, nil)
		svc.Flush()

		assert.True(t, called, "flusher should be called even with no events so log mode can surface the absence")
		assert.Empty(t, captured.Events, "payload should have no events")
	})

	t.Run("flushes events with merged dimensions", func(t *testing.T) {
		t.Cleanup(stubDeviceID("test-device"))

		var captured SendTelemetryPayload
		svc := newService(func(p SendTelemetryPayload) { captured = p }, ghtelemetry.Dimensions{"version": "2.45.0"})

		svc.Record(ghtelemetry.Event{
			Type:       "command_invocation",
			Dimensions: map[string]string{"command": "gh pr list"},
			Measures:   map[string]int64{"duration_ms": 150},
		})
		svc.Flush()

		require.Len(t, captured.Events, 1)
		event := captured.Events[0]
		assert.Equal(t, "command_invocation", event.Type)
		assert.Equal(t, "gh pr list", event.Dimensions["command"])
		assert.Equal(t, "2.45.0", event.Dimensions["version"])
		assert.Equal(t, "test-device", event.Dimensions["device_id"])
		assert.NotEmpty(t, event.Dimensions["timestamp"])
		assert.NotEmpty(t, event.Dimensions["invocation_id"])
		assert.Equal(t, int64(150), event.Measures["duration_ms"])
	})

	t.Run("flushes multiple events", func(t *testing.T) {
		t.Cleanup(stubDeviceID("test-device"))

		var captured SendTelemetryPayload
		svc := newService(func(p SendTelemetryPayload) { captured = p }, nil)

		svc.Record(ghtelemetry.Event{Type: "event1"})
		svc.Record(ghtelemetry.Event{Type: "event2"})
		svc.Flush()

		require.Len(t, captured.Events, 2)
		assert.Equal(t, "event1", captured.Events[0].Type)
		assert.Equal(t, "event2", captured.Events[1].Type)
	})

	t.Run("is idempotent", func(t *testing.T) {
		t.Cleanup(stubDeviceID("test-device"))