Function buildTaskEvent

coderd/telemetry/telemetry.go:1031–1109

buildTaskEvent constructs a TaskEvent from the combined query row.

(
	row database.GetTelemetryTaskEventsRow,
	createdAfter time.Time,
	now time.Time,
)

// buildTaskEvent constructs a TaskEvent from the combined query row.
func buildTaskEvent(
	row database.GetTelemetryTaskEventsRow,
	createdAfter time.Time,
	now time.Time,
) TaskEvent {
	event := TaskEvent{
		TaskID: row.TaskID.String(),
	}

	var (
		hasStartBuild    = row.StartBuildCreatedAt.Valid
		isResumed        = hasStartBuild && row.StartBuildNumber.Valid && row.StartBuildNumber.Int32 > 1
		hasStopBuild     = row.StopBuildCreatedAt.Valid
		startedAfterStop = hasStartBuild && hasStopBuild && row.StartBuildCreatedAt.Time.After(row.StopBuildCreatedAt.Time)
		currentlyPaused  = hasStopBuild && !startedAfterStop
	)

	// Pause-related fields (requires a stop build).
	if hasStopBuild {
		event.LastPausedAt = &row.StopBuildCreatedAt.Time
		switch {
		case row.StopBuildReason.Valid && row.StopBuildReason.BuildReason == database.BuildReasonTaskAutoPause:
			event.PauseReason = ptr.Ref("auto")
		case row.StopBuildReason.Valid && row.StopBuildReason.BuildReason == database.BuildReasonTaskManualPause:
			event.PauseReason = ptr.Ref("manual")
		default:
			event.PauseReason = ptr.Ref("other")
		}

		// Idle duration: time between last working status and the pause.
		if row.LastWorkingStatusAt.Valid &&
			row.StopBuildCreatedAt.Time.After(row.LastWorkingStatusAt.Time) {
			idle := row.StopBuildCreatedAt.Time.Sub(row.LastWorkingStatusAt.Time)
			event.IdleDurationMS = ptr.Ref(idle.Milliseconds())
		}
	}

	// Resume-related fields (requires task_resume start after stop).
	if startedAfterStop {
		// Paused duration: time between pause and resume.
		if row.StartBuildCreatedAt.Time.After(createdAfter) {
			paused := row.StartBuildCreatedAt.Time.Sub(row.StopBuildCreatedAt.Time)
			event.PausedDurationMS = ptr.Ref(paused.Milliseconds())
		}

		// Below only relevant for "resumed" tasks, not when initially created.
		if isResumed {
			event.LastResumedAt = &row.StartBuildCreatedAt.Time
			switch {
			// TODO(Cian): will this exist? Future readers may know better than I.
			// case row.StartBuildReason == database.BuildReasonTaskAutoResume:
			//	event.ResumeReason = ptr.Ref("auto")
			case row.StartBuildReason.BuildReason == database.BuildReasonTaskResume:
				event.ResumeReason = ptr.Ref("manual")
			default: // Task resumed by starting workspace?
				event.ResumeReason = ptr.Ref("other")
			}
		}