Method List

app/controlplane/pkg/data/workflow.go:266–319

(ctx context.Context, orgID uuid.UUID, filter *biz.WorkflowListOpts, pagination *pagination.OffsetPaginationOpts)

}

func (r *WorkflowRepo) List(ctx context.Context, orgID uuid.UUID, filter *biz.WorkflowListOpts, pagination *pagination.OffsetPaginationOpts) ([]*biz.Workflow, int, error) {
	ctx, span := otelx.Start(ctx, workflowRepoTracer, "WorkflowRepo.List")
	defer span.End()

	if pagination == nil {
		return nil, 0, fmt.Errorf("pagination options is required")
	}

	// Initialize the base query for WorkflowRun
	baseQuery := orgScopedQuery(r.data.DB, orgID).QueryWorkflows()

	// Apply filters to the WorkflowRun query based on the provided options
	baseQuery = applyWorkflowRunFilters(baseQuery, filter)

	// Initialize the Workflow query and apply organization and deletion filters
	wfQuery := baseQuery.Where(workflow.DeletedAtIsNil())

	// Apply additional filters to the Workflow query based on the provided options
	wfQuery, err := applyWorkflowFilters(wfQuery, filter)
	if err != nil {
		return nil, 0, err
	}

	// Get the count of all filtered rows without the limit and offset
	count, err := wfQuery.Count(ctx)
	if err != nil {
		return nil, 0, err
	}

	// Apply pagination options and execute the query
	workflows, err := wfQuery.
		WithLatestWorkflowRun().
		WithContract().
		WithProject().
		Order(ent.Desc(workflow.FieldCreatedAt)).
		Limit(pagination.Limit()).
		Offset(pagination.Offset()).
		All(ctx)
	if err != nil {
		return nil, 0, err
	}

	result := make([]*biz.Workflow, 0, len(workflows))
	for _, wf := range workflows {
		r, err := entWFToBizWF(ctx, wf)
		if err != nil {
			return nil, 0, fmt.Errorf("converting entity: %w", err)
		}

		result = append(result, r)
	}

	return result, count, nil
}

// applyWorkflowRunFilters applies filters to the WorkflowRun query based on the provided options
func applyWorkflowRunFilters(baseQuery *ent.WorkflowQuery, opts *biz.WorkflowListOpts) *ent.WorkflowQuery {