Function TestServiceDisable

internal/telemetry/telemetry_test.go:641–697

(t *testing.T)

}

func TestServiceDisable(t *testing.T) {
	t.Run("drops recorded events from flushed payload", 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.Record(ghtelemetry.Event{Type: "test"})
		svc.Disable()
		svc.Flush()

		assert.True(t, called, "flusher should still be called so log mode can surface the absence of events")
		assert.Empty(t, captured.Events, "recorded events should be dropped after Disable()")
	})

	t.Run("drops events even with multiple recorded events", 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.Record(ghtelemetry.Event{Type: "event1"})
		svc.Record(ghtelemetry.Event{Type: "event2"})
		svc.Record(ghtelemetry.Event{Type: "event3"})
		svc.Disable()
		svc.Flush()

		assert.True(t, called, "flusher should still be called")
		assert.Empty(t, captured.Events, "recorded events should be dropped after Disable()")
	})

	t.Run("can be called before any events are 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.Disable()
		svc.Record(ghtelemetry.Event{Type: "test"})
		svc.Flush()

		assert.True(t, called, "flusher should still be called")
		assert.Empty(t, captured.Events, "events recorded after Disable() should be dropped")
	})
}