(ctx context.Context, orgID, workflowID string)
| 426 | } |
| 427 | |
| 428 | func (uc *WorkflowUseCase) FindByIDInOrg(ctx context.Context, orgID, workflowID string) (*Workflow, error) { |
| 429 | ctx, span := otelx.Start(ctx, workflowTracer, "WorkflowUseCase.FindByIDInOrg") |
| 430 | defer span.End() |
| 431 | |
| 432 | orgUUID, err := uuid.Parse(orgID) |
| 433 | if err != nil { |
| 434 | return nil, NewErrInvalidUUID(err) |
| 435 | } |
| 436 | |
| 437 | workflowUUID, err := uuid.Parse(workflowID) |
| 438 | if err != nil { |
| 439 | return nil, NewErrInvalidUUID(err) |
| 440 | } |
| 441 | |
| 442 | wf, err := uc.wfRepo.GetOrgScoped(ctx, orgUUID, workflowUUID) |
| 443 | if err != nil { |
| 444 | return nil, fmt.Errorf("failed to get workflow: %w", err) |
| 445 | } else if wf == nil { |
| 446 | return nil, NewErrNotFound("workflow in organization") |
| 447 | } |
| 448 | |
| 449 | return wf, nil |
| 450 | } |
| 451 | |
| 452 | func (uc *WorkflowUseCase) FindByNameInOrg(ctx context.Context, orgID, projectName, workflowName string) (*Workflow, error) { |
| 453 | ctx, span := otelx.Start(ctx, workflowTracer, "WorkflowUseCase.FindByNameInOrg") |
nothing calls this directly
no test coverage detected