MCPcopy Index your code
hub / github.com/chainloop-dev/chainloop / contractInOrgQuery

Function contractInOrgQuery

app/controlplane/pkg/data/workflowcontract.go:430–460  ·  view source on GitHub ↗

It can be loaded via by ID or name

(ctx context.Context, q *ent.OrganizationQuery, orgID uuid.UUID, contractID *uuid.UUID, name *string, opts ...biz.ContractQueryOpt)

Source from the content-addressed store, hash-verified

428
429// It can be loaded via by ID or name
430func contractInOrgQuery(ctx context.Context, q *ent.OrganizationQuery, orgID uuid.UUID, contractID *uuid.UUID, name *string, opts ...biz.ContractQueryOpt) (*ent.WorkflowContract, error) {
431 c := &biz.ContractQueryOpts{}
432 for _, opt := range opts {
433 opt(c)
434 }
435
436 if contractID == nil && name == nil {
437 return nil, fmt.Errorf("either contractID or name must be provided")
438 }
439
440 query := q.
441 Where(organization.ID(orgID)).
442 QueryWorkflowContracts().
443 Where(workflowcontract.DeletedAtIsNil())
444
445 if !c.SkipGetReferences {
446 query = query.WithWorkflows(func(q *ent.WorkflowQuery) {
447 q.Where(workflow.DeletedAtIsNil()).WithProject().Select(project.FieldID, project.FieldName)
448 })
449 }
450
451 if contractID != nil {
452 query = query.Where(workflowcontract.ID(*contractID))
453 }
454
455 if name != nil {
456 query = query.Where(workflowcontract.NameEQ(*name))
457 }
458
459 return query.Only(ctx)
460}
461
462func (r *WorkflowContractRepo) entContractToBizContract(ctx context.Context, w *ent.WorkflowContract, version *ent.WorkflowContractVersion, workflowReferences []*biz.WorkflowRef) *biz.WorkflowContract {
463 c := &biz.WorkflowContract{

Callers 1

contractInOrgFunction · 0.85

Calls 11

IDFunction · 0.92
DeletedAtIsNilFunction · 0.92
DeletedAtIsNilFunction · 0.92
IDFunction · 0.92
NameEQFunction · 0.92
WhereMethod · 0.45
WithWorkflowsMethod · 0.45
SelectMethod · 0.45
WithProjectMethod · 0.45
OnlyMethod · 0.45

Tested by

no test coverage detected