Method deleteSafeRecursive

pkg/devspace/sync/downstream.go:432–493

(relativePath string, deleteChanges []*remote.Change, force bool)

}

func (d *downstream) deleteSafeRecursive(relativePath string, deleteChanges []*remote.Change, force bool) {
	absolutePath := filepath.Join(d.sync.LocalPath, relativePath)
	relativePath = getRelativeFromFullPath(absolutePath, d.sync.LocalPath)

	// Check if path is in delete changes
	found := false
	for _, remove := range deleteChanges {
		if remove.Path == relativePath {
			found = true
		}
	}

	// We don't delete the folder or the contents if we haven't tracked it
	if !force {
		if d.sync.fileIndex.fileMap[relativePath] == nil || !found {
			d.sync.log.Infof("Downstream - Skip delete directory '.%s'", relativePath)
			return
		}
	}

	// Delete directory from fileMap
	defer delete(d.sync.fileIndex.fileMap, relativePath)
	files, err := os.ReadDir(absolutePath)
	if err != nil {
		return
	}

	// Loop over directory contents and check if we should delete the contents
	for _, dirEntry := range files {
		f, err := dirEntry.Info()
		if err != nil {
			continue
		}

		if fsutil.IsRecursiveSymlink(f, path.Join(relativePath, f.Name())) {
			continue
		}

		childRelativePath := filepath.ToSlash(filepath.Join(relativePath, f.Name()))
		childAbsFilepath := filepath.Join(d.sync.LocalPath, childRelativePath)
		if shouldRemoveLocal(childAbsFilepath, d.sync.fileIndex.fileMap[childRelativePath], d.sync, force) {
			if f.IsDir() {
				d.deleteSafeRecursive(childRelativePath, deleteChanges, force)
			} else {
				err = os.Remove(childAbsFilepath)
				if err != nil {
					d.sync.log.Infof("Downstream - Skip file delete '.%s': %v", relativePath, err)
				}
			}
		} else {
			d.sync.log.Infof("Downstream - Skip delete '.%s'", relativePath)
		}

		delete(d.sync.fileIndex.fileMap, childRelativePath)
	}

	// This will not remove the directory if there is still a file or directory in it
	err = os.Remove(absolutePath)