Function putRecursiveInternal

cmd/put.go:734–848

(src, dst string, opts putOptions, collectResults bool)

}

func putRecursiveInternal(src, dst string, opts putOptions, collectResults bool) ([]putResult, []jsonWarning, error) {
	src = filepath.Clean(src)
	var results []putResult
	var warnings []jsonWarning
	var uploadErrors []error
	dirsWithFiles := make(map[string]bool)

	err := filepath.WalkDir(src, func(filePath string, d os.DirEntry, err error) error {
		if err != nil {
			return err
		}
		if d.IsDir() {
			return nil
		}
		if !d.Type().IsRegular() {
			if collectResults && d.Type()&os.ModeSymlink != 0 {
				warnings = append(warnings, jsonWarning{
					Code:    jsonWarningCodeSkippedSymlink,
					Message: "skipped symlink during recursive upload",
					Path:    filePath,
				})
			}
			return nil
		}

		relPath, err := filepath.Rel(src, filePath)
		if err != nil {
			return err
		}

		dirsWithFiles[filepath.Dir(filePath)] = true

		remotePath := path.Join(dst, filepath.ToSlash(relPath))
		putOutput(opts).Status("Processing %s -> %s", filePath, remotePath)

		if collectResults {
			result, err := putFileWithResult(filePath, remotePath, opts)
			if err != nil {
				uploadErrors = append(uploadErrors, fmt.Errorf("%s: %w", filePath, err))
				return nil
			}
			results = append(results, result)
			return nil
		}
		if err := putFile(filePath, remotePath, opts); err != nil {
			uploadErrors = append(uploadErrors, fmt.Errorf("%s: %w", filePath, err))
			return nil
		}
		return nil
	})
	if err != nil {
		return nil, nil, withJSONErrorDetails(err, operationErrorDetails("upload"), pathErrorDetails(src))
	}

	dbx := filesNewFunc(config)

	putOutput(opts).Status("Creating directory %s", dst)
	if collectResults {