Method moduleSourceRemoveItems

core/schema/modulesource.go:1783–1882

moduleSourceRemoveItems processes removal requests for items (dependencies or toolchains).

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

// moduleSourceRemoveItems processes removal requests for items (dependencies or
// toolchains).
func (s *moduleSourceSchema) moduleSourceRemoveItems(
	ctx context.Context,
	parentSrc *core.ModuleSource,
	removeArgs []string,
	accessor moduleRelationTypeAccessor,
) (*core.ModuleSource, error) {
	parentSrc = parentSrc.Clone()

	var filteredItems []dagql.ObjectResult[*core.ModuleSource]
	var filteredConfigItems []*modules.ModuleConfigDependency

	for i, existingItem := range accessor.getItems(parentSrc) {
		existingName := existingItem.Self().ModuleName
		var existingSymbolic, existingVersion string

		switch existingItem.Self().Kind {
		case core.ModuleSourceKindLocal:
			if parentSrc.Kind != core.ModuleSourceKindLocal {
				return nil, fmt.Errorf("cannot remove local %s from non-local module source kind %s", accessor.typ, parentSrc.Kind)
			}
			parentSrcRoot := filepath.Join(parentSrc.Local.ContextDirectoryPath, parentSrc.SourceRootSubpath)
			itemSrcRoot := filepath.Join(parentSrc.Local.ContextDirectoryPath, existingItem.Self().SourceRootSubpath)
			var err error
			existingSymbolic, err = pathutil.LexicalRelativePath(parentSrcRoot, itemSrcRoot)
			if err != nil {
				return nil, fmt.Errorf("failed to get relative path: %w", err)
			}

		case core.ModuleSourceKindGit:
			existingSymbolic = existingItem.Self().Git.CloneRef
			if existingItem.Self().SourceRootSubpath != "" {
				existingSymbolic += "/" + strings.TrimPrefix(existingItem.Self().SourceRootSubpath, "/")
			}
			existingVersion = existingItem.Self().Git.Version

		default:
			return nil, fmt.Errorf("unhandled %s kind: %s", accessor.typ, existingItem.Self().Kind)
		}

		keep := true
		for _, removeArg := range removeArgs {
			argSymbolic, argVersion, _ := strings.Cut(removeArg, "@")
			argSymbolic = filepath.Clean(argSymbolic)

			if argSymbolic != existingName && argSymbolic != existingSymbolic {
				continue
			}
			keep = false

			if argVersion == "" {
				break
			}

			if existingVersion == "" {
				return nil, fmt.Errorf(
					"version %q was requested to be uninstalled but the %s %q was installed without a specific version. Try re-running without specifying the version number",
					argVersion,
					accessor.typ,