Method ListFiles

storage/rclone/rclone.go:166–213

ListFiles implements storage.StorageListable

(ctx context.Context, dirPath string)

// ListFiles implements storage.StorageListable
func (r *Rclone) ListFiles(ctx context.Context, dirPath string) ([]storagetypes.FileInfo, error) {
	r.logger.Infof("Listing files in %s", dirPath)

	remotePath := r.getRemotePath(dirPath)

	args := r.buildBaseArgs()
	args = append(args, "lsjson", remotePath)

	cmd := exec.CommandContext(ctx, "rclone", args...)
	var stdout, stderr bytes.Buffer
	cmd.Stdout = &stdout
	cmd.Stderr = &stderr

	if err := cmd.Run(); err != nil {
		r.logger.Errorf("Failed to list files: %v, stderr: %s", err, stderr.String())
		return nil, fmt.Errorf("%w: %s", ErrFailedToListFiles, stderr.String())
	}

	var items []lsjsonItem
	if err := json.Unmarshal(stdout.Bytes(), &items); err != nil {
		r.logger.Errorf("Failed to parse lsjson output: %v", err)
		return nil, fmt.Errorf("failed to parse lsjson output: %w", err)
	}

	files := make([]storagetypes.FileInfo, 0, len(items))
	for _, item := range items {
		var modTime time.Time
		if item.ModTime != "" {
			parsedTime, err := time.Parse(time.RFC3339Nano, item.ModTime)
			if err != nil {
				r.logger.Warnf("Failed to parse mod time %q for %s: %v", item.ModTime, item.Name, err)
			} else {
				modTime = parsedTime
			}
		}

		files = append(files, storagetypes.FileInfo{
			Name:    item.Name,
			Path:    path.Join(dirPath, item.Name),
			Size:    item.Size,
			IsDir:   item.IsDir,
			ModTime: modTime,
		})
	}

	r.logger.Debugf("Found %d files/directories in %s", len(files), dirPath)
	return files, nil
}

// OpenFile implements storage.StorageReadable
func (r *Rclone) OpenFile(ctx context.Context, filePath string) (io.ReadCloser, int64, error) {