Method removeRecursive

helper/server/upstream.go:196–237

(absolutePath string)

}

func (u *Upstream) removeRecursive(absolutePath string) error {
	files, err := os.ReadDir(absolutePath)
	if err != nil {
		return err
	}

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

		absoluteChildPath := filepath.Join(absolutePath, f.Name())
		if fsutil.IsRecursiveSymlink(f, absoluteChildPath) {
			continue
		}

		// Check if ignored
		if u.ignoreMatcher != nil && !u.ignoreMatcher.RequireFullScan() && u.ignoreMatcher.Matches(absolutePath[len(u.options.UploadPath):], f.IsDir()) {
			continue
		}

		// Remove recursive
		if f.IsDir() {
			// Ignore the errors here
			_ = u.removeRecursive(absoluteChildPath)
		} else {
			// Check if not ignored
			if u.ignoreMatcher == nil || !u.ignoreMatcher.RequireFullScan() || !u.ignoreMatcher.Matches(absolutePath[len(u.options.UploadPath):], false) {
				_ = os.Remove(absoluteChildPath)
			}
		}
	}

	// Check if not ignored
	if u.ignoreMatcher == nil || !u.ignoreMatcher.RequireFullScan() || !u.ignoreMatcher.Matches(absolutePath[len(u.options.UploadPath):], true) {
		// This will not remove the directory if there is still a file or directory in it
		return os.Remove(absolutePath)
	}
	return nil
}

// Upload implements the server upload interface and writes all the data received to a
// temporary file