Method SendData

pkg/telemetry/exporter/cli/task.go:75–130

SendData a small task that sends telemetry data.

(ctx context.Context)

// SendData a small task that sends telemetry data.
func (ct *cliTask) SendData(ctx context.Context) {
	logger := log.FromContext(ctx)

	st, err := store.New()
	if err != nil {
		logger.WithError(err).Debug("Failed to open telemetry database")
		return
	}

	state, err := st.GetState()
	if err != nil {
		logger.WithError(err).Debug("Failed to retrieve telemetry state")
		return // Skip the telemetry procedure if an error is found creating or fetching the previous state.
	}

	if !shouldSendTelemetry(state) {
		return
	}

	cmdData, err := st.GetCmdData()
	if err != nil {
		logger.WithError(err).Debug("Failed to fetch commands usage data")
		return
	}

	data := &models.TelemetryMessage{
		UID: state.UID,
		CLI: &models.CLITelemetry{CmdData: *cmdData},
		OS:  telemetry.OSTelemetryData(),
	}

	b, err := json.Marshal(data)
	if err != nil {
		logger.WithError(err).Debug("Failed to marshal telemetry information")
		return
	}

	resp, err := http.DefaultClient.Post(ct.target, "application/json", bytes.NewReader(b))
	if err != nil {
		logger.WithError(err).Debug("Failed to send telemetry information")
		return
	}
	defer resp.Body.Close()
	io.Copy(io.Discard, resp.Body) // nolint:errcheck,gosec

	// Operations after sending the telemetry data
	if err := st.UpdateLastSent(); err != nil {
		logger.WithError(err).Debug("Failed to update last_sent field in telemetry state")
		return
	}

	if err := st.ResetCmdData(); err != nil {
		logger.WithError(err).Debug("Failed to reset command usage data")
		return
	}
}

// SaveData process and stores data related to the CLI usage.