Method moduleSourceUpdateItems

core/schema/modulesource.go:1630–1779

moduleSourceUpdateItems processes update requests for items (dependencies or toolchains).

(
	ctx context.Context,
	parentSrc dagql.ObjectResult[*core.ModuleSource],
	updateArgs []string,
	accessor moduleRelationTypeAccessor,
)

// moduleSourceUpdateItems processes update requests for items (dependencies or
// toolchains).
func (s *moduleSourceSchema) moduleSourceUpdateItems(
	ctx context.Context,
	parentSrc dagql.ObjectResult[*core.ModuleSource],
	updateArgs []string,
	accessor moduleRelationTypeAccessor,
) ([]core.ModuleSourceID, error) {
	dag, err := core.CurrentDagqlServer(ctx)
	if err != nil {
		return nil, fmt.Errorf("failed to get dag server: %w", err)
	}

	type updateReq struct {
		symbolic string
		version  string
	}
	updateReqs := make(map[updateReq]struct{}, len(updateArgs))
	for _, updateArg := range updateArgs {
		req := updateReq{}
		req.symbolic, req.version, _ = strings.Cut(updateArg, "@")
		updateReqs[req] = struct{}{}
	}

	var newUpdatedArgs []core.ModuleSourceID
	for _, existingItem := range accessor.getItems(parentSrc.Self()) {
		if len(updateReqs) == 0 {
			if existingItem.Self().Kind == core.ModuleSourceKindLocal {
				continue
			}

			var updatedItem dagql.ObjectResult[*core.ModuleSource]
			err := dag.Select(ctx, dag.Root(), &updatedItem,
				dagql.Selector{
					Field: "moduleSource",
					Args: []dagql.NamedInput{
						{Name: "refString", Value: dagql.String(existingItem.Self().AsString())},
					},
				},
			)
			if err != nil {
				return nil, fmt.Errorf("failed to load existing %s: %w", accessor.typ, err)
			}

			updatedItemID, err := updatedItem.ID()
			if err != nil {
				return nil, fmt.Errorf("failed to get updated %s ID: %w", accessor.typ, err)
			}
			newUpdatedArgs = append(newUpdatedArgs, dagql.NewID[*core.ModuleSource](updatedItemID))
			continue
		}

		if existingItem.Self().Kind == core.ModuleSourceKindLocal {
			for updateReq := range updateReqs {
				if updateReq.symbolic == existingItem.Self().ModuleName {
					return nil, fmt.Errorf("updating local %s is not supported", accessor.typ.Plural())
				}

				var contextRoot string
				switch parentSrc.Self().Kind {