Function TestServiceCollectsConcurrentFacts

internal/telemetry/service_test.go:128–157

(t *testing.T)

}

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

	// Given two command activities contributing to the same pending event
	var payload SendTelemetryPayload
	service := NewService(func(p SendTelemetryPayload) { payload = p })
	pending := service.Begin(ghtelemetry.Event{Type: "attachment_invocation"})

	// When both activities finish before command completion
	var workers sync.WaitGroup
	workers.Go(func() {
		pending.UpsertDimensions(ghtelemetry.Dimensions{"command": "gh issue create"})
		pending.UpsertMeasures(ghtelemetry.Measures{"append_ops_count": 1})
	})
	workers.Go(func() {
		pending.UpsertDimensions(ghtelemetry.Dimensions{"flags": "attach"})
		pending.UpsertMeasures(ghtelemetry.Measures{"replace_ops_count": 2})
	})
	workers.Wait()
	service.Finish()

	// Then the completed event contains both activities' facts
	require.Len(t, payload.Events, 1)
	assert.Equal(t, "gh issue create", payload.Events[0].Dimensions["command"])
	assert.Equal(t, "attach", payload.Events[0].Dimensions["flags"])
	assert.Equal(t, map[string]int64{
		"append_ops_count":  1,
		"replace_ops_count": 2,
	}, payload.Events[0].Measures)
}