Method List

app/controlplane/internal/service/workflow.go:160–257

List returns a list of workflows.

(ctx context.Context, req *pb.WorkflowServiceListRequest)

// List returns a list of workflows.
func (s *WorkflowService) List(ctx context.Context, req *pb.WorkflowServiceListRequest) (*pb.WorkflowServiceListResponse, error) {
	currentOrg, err := requireCurrentOrg(ctx)
	if err != nil {
		return nil, err
	}

	// Initialize the pagination options, with default values
	paginationOpts := pagination.NewDefaultOffsetPaginationOpts()

	// Override the pagination options if they are provided
	if req.GetPagination() != nil {
		paginationOpts, err = pagination.NewOffsetPaginationOpts(
			int(req.GetPagination().GetPage()),
			int(req.GetPagination().GetPageSize()),
		)
		if err != nil {
			return nil, handleUseCaseErr(err, s.log)
		}
	}

	// Initialize the filters
	filters := &biz.WorkflowListOpts{}

	// Check the workflow name
	if req.GetWorkflowName() != "" {
		filters.WorkflowName = req.GetWorkflowName()
	}

	// Check the Team
	if req.GetWorkflowTeam() != "" {
		filters.WorkflowTeam = req.GetWorkflowTeam()
	}

	// Check the Workflow Description
	if req.GetWorkflowDescription() != "" {
		filters.WorkflowDescription = req.GetWorkflowDescription()
	}

	// Check the Project Name
	if len(req.GetProjectNames()) != 0 {
		filters.WorkflowProjectNames = req.GetProjectNames()
	}

	// Workflow visibility
	if req.WorkflowPublic != nil {
		val := req.GetWorkflowPublic()
		filters.WorkflowPublic = &val
	}

	// Workflow Run Runner Type
	if req.GetWorkflowRunRunnerType() != schema.CraftingSchema_Runner_RUNNER_TYPE_UNSPECIFIED {
		filters.WorkflowRunRunnerType = req.GetWorkflowRunRunnerType().String()
	}

	// Workflow Last Known Status
	if req.GetWorkflowRunLastStatus() != pb.RunStatus_RUN_STATUS_UNSPECIFIED {
		status, err := pbWorkflowRunStatusToBiz(req.GetWorkflowRunLastStatus())
		if err != nil {