`ea43f03`

actions/sqlc: expose run detail selectors (S41f)

Authored by mfwolffe <wolffemf@dukes.jmu.edu> 2 days ago

SHA: ea43f03d4f5a3f8cfb007122e52d7c878d194c3e
Parents: cabd341
Tree: 26b59f4

9 changed files

Status	File	+	-
M	`internal/actions/queries/workflow_jobs.sql`	1	1
M	`internal/actions/queries/workflow_runs.sql`	11	0
M	`internal/actions/queries/workflow_step_log_chunks.sql`	6	0
M	`internal/actions/queries/workflow_steps.sql`	2	2
M	`internal/actions/sqlc/querier.go`	2	0
M	`internal/actions/sqlc/workflow_jobs.sql.go`	5	1
M	`internal/actions/sqlc/workflow_runs.sql.go`	76	0
M	`internal/actions/sqlc/workflow_step_log_chunks.sql.go`	33	0
M	`internal/actions/sqlc/workflow_steps.sql.go`	6	2

internal/actions/queries/workflow_jobs.sqlmodified


 
 -- name: ListJobsForRun :many
 SELECT id, run_id, job_index, job_key, job_name, runs_on, status,
+       conclusion, needs_jobs, started_at, completed_at, created_at, updated_at
 FROM workflow_jobs
 WHERE run_id = $1
 ORDER BY job_index ASC;

internal/actions/queries/workflow_runs.sqlmodified

  FROM workflow_runs
  WHERE id = $1;
++-- name: GetWorkflowRunForRepoByIndex :one
++SELECT r.id, r.repo_id, r.run_index, r.workflow_file, r.workflow_name,
++       r.head_sha, r.head_ref, r.event, r.event_payload,
++       r.actor_user_id, COALESCE(u.username::text, '')::text AS actor_username,
++       r.parent_run_id, r.concurrency_group,
++       r.status, r.conclusion, r.pinned, r.need_approval, r.approved_by_user_id,
++       r.started_at, r.completed_at, r.version, r.created_at, r.updated_at, r.trigger_event_id
++FROM workflow_runs r
++LEFT JOIN users u ON u.id = r.actor_user_id
++WHERE r.repo_id = $1 AND r.run_index = $2;
++
  -- name: MarkWorkflowRunRunning :exec
  UPDATE workflow_runs
  SET status = 'running',

internal/actions/queries/workflow_step_log_chunks.sqlmodified

  ORDER BY seq ASC
  LIMIT $3;
++-- name: ListAllStepLogChunksForStep :many
++SELECT id, step_id, seq, chunk, created_at
++FROM workflow_step_log_chunks
++WHERE step_id = $1
++ORDER BY seq ASC;
++
  -- name: GetStepLogChunkBefore :one
  SELECT id, step_id, seq, chunk, created_at
  FROM workflow_step_log_chunks

internal/actions/queries/workflow_steps.sqlmodified

  -- name: ListStepsForJob :many
  SELECT id, job_id, step_index, step_id, step_name, run_command,
--       uses_alias, status, conclusion, log_byte_count,
++       uses_alias, status, conclusion, log_object_key, log_byte_count,
--       started_at, completed_at, created_at
++       started_at, completed_at, created_at, updated_at
  FROM workflow_steps
  WHERE job_id = $1
  ORDER BY step_index ASC;

internal/actions/sqlc/querier.gomodified

  	GetWorkflowJobByID(ctx context.Context, db DBTX, id int64) (WorkflowJob, error)
  	GetWorkflowJobSecretMask(ctx context.Context, db DBTX, jobID int64) (WorkflowJobSecretMask, error)
  	GetWorkflowRunByID(ctx context.Context, db DBTX, id int64) (WorkflowRun, error)
++	GetWorkflowRunForRepoByIndex(ctx context.Context, db DBTX, arg GetWorkflowRunForRepoByIndexParams) (GetWorkflowRunForRepoByIndexRow, error)
  	GetWorkflowStepByID(ctx context.Context, db DBTX, id int64) (WorkflowStep, error)
  	HeartbeatRunner(ctx context.Context, db DBTX, arg HeartbeatRunnerParams) (WorkflowRunner, error)
  	// SPDX-License-Identifier: AGPL-3.0-or-later
  	InsertWorkflowRun(ctx context.Context, db DBTX, arg InsertWorkflowRunParams) (WorkflowRun, error)
  	// SPDX-License-Identifier: AGPL-3.0-or-later
  	InsertWorkflowStep(ctx context.Context, db DBTX, arg InsertWorkflowStepParams) (WorkflowStep, error)
++	ListAllStepLogChunksForStep(ctx context.Context, db DBTX, stepID int64) ([]WorkflowStepLogChunk, error)
  	ListArtifactsForRun(ctx context.Context, db DBTX, runID int64) ([]ListArtifactsForRunRow, error)
  	ListJobsForRun(ctx context.Context, db DBTX, runID int64) ([]ListJobsForRunRow, error)
  	ListOrgSecrets(ctx context.Context, db DBTX, orgID pgtype.Int8) ([]ListOrgSecretsRow, error)

internal/actions/sqlc/workflow_jobs.sql.gomodified

  const listJobsForRun = `-- name: ListJobsForRun :many
  SELECT id, run_id, job_index, job_key, job_name, runs_on, status,
--       conclusion, started_at, completed_at, created_at
++       conclusion, needs_jobs, started_at, completed_at, created_at, updated_at
  FROM workflow_jobs
  WHERE run_id = $1
  ORDER BY job_index ASC
  	RunsOn      string
  	Status      WorkflowJobStatus
  	Conclusion  NullCheckConclusion
++	NeedsJobs   []string
  	StartedAt   pgtype.Timestamptz
  	CompletedAt pgtype.Timestamptz
  	CreatedAt   pgtype.Timestamptz
++	UpdatedAt   pgtype.Timestamptz
  }
  func (q *Queries) ListJobsForRun(ctx context.Context, db DBTX, runID int64) ([]ListJobsForRunRow, error) {
  			&i.RunsOn,
  			&i.Status,
  			&i.Conclusion,
++			&i.NeedsJobs,
  			&i.StartedAt,
  			&i.CompletedAt,
  			&i.CreatedAt,
++			&i.UpdatedAt,
  		); err != nil {
  			return nil, err
  		}

internal/actions/sqlc/workflow_runs.sql.gomodified

  	return i, err
+ }
++const getWorkflowRunForRepoByIndex = `-- name: GetWorkflowRunForRepoByIndex :one
++SELECT r.id, r.repo_id, r.run_index, r.workflow_file, r.workflow_name,
++       r.head_sha, r.head_ref, r.event, r.event_payload,
++       r.actor_user_id, COALESCE(u.username::text, '')::text AS actor_username,
++       r.parent_run_id, r.concurrency_group,
++       r.status, r.conclusion, r.pinned, r.need_approval, r.approved_by_user_id,
++       r.started_at, r.completed_at, r.version, r.created_at, r.updated_at, r.trigger_event_id
++FROM workflow_runs r
++LEFT JOIN users u ON u.id = r.actor_user_id
++WHERE r.repo_id = $1 AND r.run_index = $2
++`
++
++type GetWorkflowRunForRepoByIndexParams struct {
++	RepoID   int64
++	RunIndex int64
++}
++
++type GetWorkflowRunForRepoByIndexRow struct {
++	ID               int64
++	RepoID           int64
++	RunIndex         int64
++	WorkflowFile     string
++	WorkflowName     string
++	HeadSha          string
++	HeadRef          string
++	Event            WorkflowRunEvent
++	EventPayload     []byte
++	ActorUserID      pgtype.Int8
++	ActorUsername    string
++	ParentRunID      pgtype.Int8
++	ConcurrencyGroup string
++	Status           WorkflowRunStatus
++	Conclusion       NullCheckConclusion
++	Pinned           bool
++	NeedApproval     bool
++	ApprovedByUserID pgtype.Int8
++	StartedAt        pgtype.Timestamptz
++	CompletedAt      pgtype.Timestamptz
++	Version          int32
++	CreatedAt        pgtype.Timestamptz
++	UpdatedAt        pgtype.Timestamptz
++	TriggerEventID   string
++}
++
++func (q *Queries) GetWorkflowRunForRepoByIndex(ctx context.Context, db DBTX, arg GetWorkflowRunForRepoByIndexParams) (GetWorkflowRunForRepoByIndexRow, error) {
++	row := db.QueryRow(ctx, getWorkflowRunForRepoByIndex, arg.RepoID, arg.RunIndex)
++	var i GetWorkflowRunForRepoByIndexRow
++	err := row.Scan(
++		&i.ID,
++		&i.RepoID,
++		&i.RunIndex,
++		&i.WorkflowFile,
++		&i.WorkflowName,
++		&i.HeadSha,
++		&i.HeadRef,
++		&i.Event,
++		&i.EventPayload,
++		&i.ActorUserID,
++		&i.ActorUsername,
++		&i.ParentRunID,
++		&i.ConcurrencyGroup,
++		&i.Status,
++		&i.Conclusion,
++		&i.Pinned,
++		&i.NeedApproval,
++		&i.ApprovedByUserID,
++		&i.StartedAt,
++		&i.CompletedAt,
++		&i.Version,
++		&i.CreatedAt,
++		&i.UpdatedAt,
++		&i.TriggerEventID,
++	)
++	return i, err
++}
++
  const insertWorkflowRun = `-- name: InsertWorkflowRun :one
  INSERT INTO workflow_runs (

internal/actions/sqlc/workflow_step_log_chunks.sql.gomodified

  	return i, err
+ }
++const listAllStepLogChunksForStep = `-- name: ListAllStepLogChunksForStep :many
++SELECT id, step_id, seq, chunk, created_at
++FROM workflow_step_log_chunks
++WHERE step_id = $1
++ORDER BY seq ASC
++`
++
++func (q *Queries) ListAllStepLogChunksForStep(ctx context.Context, db DBTX, stepID int64) ([]WorkflowStepLogChunk, error) {
++	rows, err := db.Query(ctx, listAllStepLogChunksForStep, stepID)
++	if err != nil {
++		return nil, err
++	}
++	defer rows.Close()
++	items := []WorkflowStepLogChunk{}
++	for rows.Next() {
++		var i WorkflowStepLogChunk
++		if err := rows.Scan(
++			&i.ID,
++			&i.StepID,
++			&i.Seq,
++			&i.Chunk,
++			&i.CreatedAt,
++		); err != nil {
++			return nil, err
++		}
++		items = append(items, i)
++	}
++	if err := rows.Err(); err != nil {
++		return nil, err
++	}
++	return items, nil
++}
++
  const listStepLogChunks = `-- name: ListStepLogChunks :many
  SELECT id, step_id, seq, chunk, created_at
  FROM workflow_step_log_chunks

internal/actions/sqlc/workflow_steps.sql.gomodified

  const listStepsForJob = `-- name: ListStepsForJob :many
  SELECT id, job_id, step_index, step_id, step_name, run_command,
--       uses_alias, status, conclusion, log_byte_count,
++       uses_alias, status, conclusion, log_object_key, log_byte_count,
--       started_at, completed_at, created_at
++       started_at, completed_at, created_at, updated_at
  FROM workflow_steps
  WHERE job_id = $1
  ORDER BY step_index ASC
  	UsesAlias    string
  	Status       WorkflowStepStatus
  	Conclusion   NullCheckConclusion
++	LogObjectKey pgtype.Text
  	LogByteCount int64
  	StartedAt    pgtype.Timestamptz
  	CompletedAt  pgtype.Timestamptz
  	CreatedAt    pgtype.Timestamptz
++	UpdatedAt    pgtype.Timestamptz
  }
  func (q *Queries) ListStepsForJob(ctx context.Context, db DBTX, jobID int64) ([]ListStepsForJobRow, error) {
  			&i.UsesAlias,
  			&i.Status,
  			&i.Conclusion,
++			&i.LogObjectKey,
  			&i.LogByteCount,
  			&i.StartedAt,
  			&i.CompletedAt,
  			&i.CreatedAt,
++			&i.UpdatedAt,
  		); err != nil {
  			return nil, err
  		}

`@@ -85,7 +85,7 @@` JOIN workflow_runs r ON r.id = c.run_id;
85		85
86	-- name: ListJobsForRun :many	86	-- name: ListJobsForRun :many
87	SELECT id, run_id, job_index, job_key, job_name, runs_on, status,	87	SELECT id, run_id, job_index, job_key, job_name, runs_on, status,
88	- conclusion, started_at, completed_at, created_at	88	+ conclusion, needs_jobs, started_at, completed_at, created_at, updated_at
89	FROM workflow_jobs	89	FROM workflow_jobs
90	WHERE run_id = $1	90	WHERE run_id = $1
91	ORDER BY job_index ASC;	91	ORDER BY job_index ASC;