repos.go

package runtime

import (
	"context"
	"io"
	"time"
)

func (r *Runtime) ListFiles(ctx context.Context, instanceID, glob string) ([]string, error) {
	repo, release, err := r.Repo(ctx, instanceID)
	if err != nil {
		return nil, err
	}
	defer release()

	return repo.ListRecursive(ctx, glob)
}

func (r *Runtime) GetFile(ctx context.Context, instanceID, path string) (string, time.Time, error) {
	repo, release, err := r.Repo(ctx, instanceID)
	if err != nil {
		return "", time.Time{}, err
	}
	defer release()

	blob, err := repo.Get(ctx, path)
	if err != nil {
		return "", time.Time{}, err
	}

	// TODO: Could we return Stat as part of Get?
	stat, err := repo.Stat(ctx, path)
	if err != nil {
		return "", time.Time{}, err
	}

	return blob, stat.LastUpdated, nil
}

func (r *Runtime) PutFile(ctx context.Context, instanceID, path string, blob io.Reader, create, createOnly bool) error {
	repo, release, err := r.Repo(ctx, instanceID)
	if err != nil {
		return err
	}
	defer release()

	// TODO: Handle create, createOnly

	err = repo.Put(ctx, path, blob)
	if err != nil {
		return err
	}

	return nil
}

func (r *Runtime) DeleteFile(ctx context.Context, instanceID, path string) error {
	repo, release, err := r.Repo(ctx, instanceID)
	if err != nil {
		return err
	}
	defer release()

	err = repo.Delete(ctx, path)
	if err != nil {
		return err
	}

	return nil
}

func (r *Runtime) RenameFile(ctx context.Context, instanceID, fromPath, toPath string) error {
	repo, release, err := r.Repo(ctx, instanceID)
	if err != nil {
		return err
	}
	defer release()

	err = repo.Rename(ctx, fromPath, toPath)
	if err != nil {
		return err
	}

	return nil
}