Function TestTasksTelemetry

coderd/telemetry/telemetry_test.go:756–1264

nolint: dupl // Test code is better WET than DRY.

(t *testing.T)

// nolint: dupl // Test code is better WET than DRY.
func TestTasksTelemetry(t *testing.T) {
	t.Parallel()

	// Define a fixed reference time for deterministic testing.
	now := time.Date(2025, 1, 15, 12, 0, 0, 0, time.UTC)

	createAppStatus := func(ctx context.Context, db database.Store, wsID uuid.UUID, agentID, appID uuid.UUID, state database.WorkspaceAppStatusState, message string, createdAt time.Time) {
		_, err := db.InsertWorkspaceAppStatus(ctx, database.InsertWorkspaceAppStatusParams{
			ID:          uuid.New(),
			CreatedAt:   createdAt,
			WorkspaceID: wsID,
			AgentID:     agentID,
			AppID:       appID,
			State:       state,
			Message:     message,
		})
		require.NoError(t, err)
	}

	getApp := func(ctx context.Context, db database.Store, agentID uuid.UUID) database.WorkspaceApp {
		apps, err := db.GetWorkspaceAppsByAgentID(ctx, agentID)
		require.NoError(t, err)
		require.NotEmpty(t, apps, "expected at least one app")
		return apps[0]
	}

	type statusSpec struct {
		state   database.WorkspaceAppStatusState
		message string
		offset  time.Duration
	}

	type buildSpec struct {
		buildNumber int32
		offset      time.Duration
		transition  database.WorkspaceTransition
		reason      database.BuildReason
		statuses    []statusSpec // created after this build, using this build's app
	}

	tests := []struct {
		name string

		// Input: DB setup.
		skipWorkspace bool
		createdOffset time.Duration
		buildOffset   *time.Duration
		extraBuilds   []buildSpec
		appStatuses   []statusSpec

		// Expected output.
		expectEvent       bool
		lastPausedOffset  *time.Duration
		lastResumedOffset *time.Duration
		pauseReason       *string
		resumeReason      *string
		idleDurationMS    *int64
		pausedDurationMS  *int64