Function getRecursiveInternal

cmd/get.go:247–342

(dbx filesClient, src, dst string, rootMeta files.IsMetadata, opts getOptions, collectResults bool)

}

func getRecursiveInternal(dbx filesClient, src, dst string, rootMeta files.IsMetadata, opts getOptions, collectResults bool) ([]getResult, error) {
	arg := files.NewListFolderArg(src)
	arg.Recursive = true

	res, err := dbx.ListFolderContext(currentContext(), arg)
	if err != nil {
		return nil, withJSONErrorDetails(fmt.Errorf("list folder %s: %v", src, err), operationErrorDetails("download"), pathErrorDetails(src))
	}

	var entries []files.IsMetadata
	entries = append(entries, res.Entries...)
	for res.HasMore {
		cont := files.NewListFolderContinueArg(res.Cursor)
		res, err = dbx.ListFolderContinueContext(currentContext(), cont)
		if err != nil {
			return nil, withJSONErrorDetails(fmt.Errorf("list folder continue: %v", err), operationErrorDetails("download"), pathErrorDetails(src))
		}
		entries = append(entries, res.Entries...)
	}

	var results []getResult

	if collectResults {
		result, err := ensureLocalDirectoryResult(src, dst, rootMeta)
		if err != nil {
			return nil, err
		}
		results = append(results, result)
	} else {
		if err := os.MkdirAll(dst, 0755); err != nil {
			return nil, err
		}
	}

	var downloadErrors []error

	for _, entry := range entries {
		switch f := entry.(type) {
		case *files.FolderMetadata:
			relPath, err := relativeTo(src, f.PathDisplay)
			if err != nil {
				downloadErrors = append(downloadErrors, err)
				continue
			}
			if relPath == "" {
				continue
			}
			localDir := filepath.Join(dst, filepath.FromSlash(relPath))
			if collectResults {
				result, err := ensureLocalDirectoryResult(f.PathDisplay, localDir, f)
				if err != nil {
					downloadErrors = append(downloadErrors, fmt.Errorf("mkdir %s: %w", localDir, err))
					continue
				}
				results = append(results, result)
			} else {
				if err := os.MkdirAll(localDir, 0755); err != nil {
					downloadErrors = append(downloadErrors, fmt.Errorf("mkdir %s: %w", localDir, err))