Method Create

app/controlplane/pkg/data/casmapping.go:51–78

(ctx context.Context, digest string, casBackendID uuid.UUID, opts *biz.CASMappingCreateOpts)

}

func (r *CASMappingRepo) Create(ctx context.Context, digest string, casBackendID uuid.UUID, opts *biz.CASMappingCreateOpts) (*biz.CASMapping, error) {
	ctx, span := otelx.Start(ctx, casMappingRepoTracer, "CASMappingRepo.Create")
	defer span.End()

	casBackend, err := r.casBackendrepo.FindByID(ctx, casBackendID)
	if err != nil {
		return nil, fmt.Errorf("failed to find cas backend: %w", err)
	} else if casBackend == nil {
		return nil, fmt.Errorf("cas backend not found")
	}

	query := r.data.DB.CASMapping.Create().
		SetDigest(digest).
		SetCasBackendID(casBackendID).
		SetOrganizationID(casBackend.OrganizationID)

	if opts != nil {
		query.SetNillableProjectID(opts.ProjectID).SetNillableWorkflowRunID(opts.WorkflowRunID)
	}

	mapping, err := query.Save(ctx)
	if err != nil {
		return nil, fmt.Errorf("failed to create casMapping: %w", err)
	}

	// reload to get the edges
	return r.findByID(ctx, mapping.ID)
}

// FindByDigestInOrgs returns a single CAS mapping for the digest that is reachable through one of
// the given organizations, honouring project-level RBAC when projectIDs is provided for an org. The