Function runSendTelemetry

pkg/cmd/send-telemetry/send_telemetry.go:76–110

(ctx context.Context, opts *SendTelemetryOptions)

}

func runSendTelemetry(ctx context.Context, opts *SendTelemetryOptions) error {
	httpClient := &http.Client{
		Timeout: 2 * time.Second,
		Transport: &userAgentTransport{
			base:      handleUnixDomainSocket(opts.HTTPUnixSocket),
			userAgent: fmt.Sprintf("GitHub CLI %s", build.Version),
		},
	}

	client := observability.NewTelemetryAPIProtobufClient(opts.TelemetryEndpointURL, httpClient)

	var payload telemetry.SendTelemetryPayload
	if err := json.Unmarshal([]byte(opts.PayloadJSON), &payload); err != nil {
		return fmt.Errorf("parsing payload JSON: %w", err)
	}

	if len(payload.Events) == 0 {
		return nil
	}

	events := make([]*observability.TelemetryEvent, len(payload.Events))
	for i, event := range payload.Events {
		events[i] = &observability.TelemetryEvent{
			App:        "github-cli",
			EventType:  event.Type,
			Dimensions: event.Dimensions,
			Measures:   event.Measures,
		}
	}

	_, err := client.RecordEvents(ctx, &observability.RecordEventsRequest{
		Events: events,
	})
	return err
}

type userAgentTransport struct {
	base      http.RoundTripper