Function TestServiceRecordingDoesNotWaitForDelivery

internal/telemetry/service_test.go:92–126

(t *testing.T)

}

func TestServiceRecordingDoesNotWaitForDelivery(t *testing.T) {
	t.Cleanup(stubDeviceID("test-device"))

	// Given an invocation whose delivery is blocked
	sendStarted := make(chan struct{})
	allowSend := make(chan struct{})
	service := NewService(func(SendTelemetryPayload) {
		close(sendStarted)
		<-allowSend
	})
	service.Record(ghtelemetry.Event{Type: "test"})
	deliveryDone := make(chan struct{})
	go func() {
		service.Finish()
		close(deliveryDone)
	}()
	<-sendStarted

	// When another recording is attempted
	recordingDone := make(chan struct{})
	go func() {
		service.Record(ghtelemetry.Event{Type: "too_late"})
		close(recordingDone)
	}()

	// Then recording returns without waiting for delivery
	select {
	case <-recordingDone:
	case <-time.After(5 * time.Second):
		t.Error("recording blocked while telemetry was being sent")
	}
	close(allowSend)
	<-deliveryDone
	<-recordingDone
}

func TestServiceCollectsConcurrentFacts(t *testing.T) {
	t.Cleanup(stubDeviceID("test-device"))