animethemes-server/app/Repositories/Storage/StorageRepository.php

<?php

declare(strict_types=1);

namespace App\Repositories\Storage;

use App\Contracts\Repositories\RepositoryInterface;
use App\Contracts\Storage\InteractsWithDisk;
use Closure;
use Illuminate\Database\Eloquent\Model;
use Illuminate\Filesystem\FilesystemAdapter;
use Illuminate\Support\Collection;
use Illuminate\Support\Facades\Storage;
use League\Flysystem\FilesystemException;
use League\Flysystem\FilesystemReader;
use League\Flysystem\StorageAttributes;

/**
 * @template TModel of \App\Models\BaseModel
 *
 * @implements RepositoryInterface<TModel>
 */
abstract class StorageRepository implements InteractsWithDisk, RepositoryInterface
{
    /**
     * The base path of the filesystem to retrieve files from.
     */
    protected string $location = '';

    /**
     * Get models from the repository.
     *
     *
     * @throws FilesystemException
     */
    public function get(array $columns = ['*']): Collection
    {
        /** @var FilesystemAdapter $fs */
        $fs = Storage::disk($this->disk());

        $files = collect($fs->listContents($this->location, FilesystemReader::LIST_DEEP));

        return $files->filter($this->filterCallback())
            ->map($this->mapCallback());
    }

    /**
     * Save model to the repository.
     */
    public function save(Model $model): bool
    {
        // Do not write serialized models to filesystem
        return false;
    }

    /**
     * Delete model from the repository.
     */
    public function delete(Model $model): bool
    {
        // Do not write serialized models to filesystem
        return false;
    }

    /**
     * Update model in the repository.
     */
    public function update(Model $model, array $attributes): bool
    {
        // Do not write serialized models to filesystem
        return false;
    }

    /**
     * Return the callback to filter filesystem contents.
     *
     * @return Closure(StorageAttributes): bool
     */
    abstract protected function filterCallback(): Closure;

    /**
     * Map filesystem files to model.
     *
     * @return Closure(StorageAttributes): TModel
     */
    abstract protected function mapCallback(): Closure;

    /**
     * Filter repository models.
     */
    public function handleFilter(string $filter, mixed $value = null): void
    {
        if ($filter === 'path') {
            $this->location = $value;
        }
    }
}