LaravelFreelancerNL / laravel-arangodb

src/Migrations/DatabaseMigrationRepository.php

<?php

declare(strict_types=1);

namespace LaravelFreelancerNL\Aranguent\Migrations;

use ArangoClient\Exceptions\ArangoException;
use ArangoClient\Schema\SchemaManager;
use Illuminate\Database\ConnectionResolverInterface as IlluminateResolver;
use Illuminate\Database\Migrations\DatabaseMigrationRepository as IlluminateDatabaseMigrationRepository;
use Illuminate\Database\Query\Builder as IlluminateQueryBuilder;
use LaravelFreelancerNL\Aranguent\Connection;
use LaravelFreelancerNL\Aranguent\Console\Concerns\ArangoCommands;
use LaravelFreelancerNL\Aranguent\Exceptions\AranguentException;
use LaravelFreelancerNL\Aranguent\Query\Builder;

class DatabaseMigrationRepository extends IlluminateDatabaseMigrationRepository
{
    use ArangoCommands;

    /**
     * The name of the migration collection.
     *
     * @var string
     */
    protected $table;

    /**
     * Create a new database migration repository instance.
     */
    public function __construct(IlluminateResolver $resolver, string $table)
    {
        parent::__construct($resolver, $table);
    }

    protected function getSchemaManager(): SchemaManager
    {
        $connection = $this->getConnection();
        assert($connection instanceof Connection);

        $arangoClient = $connection->getArangoClient();

        if ($arangoClient === null) {
            throw new AranguentException('No arangodb client set.');
        }

        return $arangoClient->schema();
    }

    /**
     * Create the migration repository data store.
     *
     * @return void
     */
    public function createRepository()
    {
        if ($this->useFallback()) {
            parent::createRepository();
            return;
        }

        $schemaManager = $this->getSchemaManager();

        $schemaManager->createCollection($this->table);
    }

    /**
     * Get the list of migrations.
     *
     * @param  int  $steps
     * @return array<mixed>
     */
    public function getMigrations($steps)
    {
        if ($this->useFallback()) {
            return parent::getMigrations($steps);
        }

        //TODO: the only difference with the parent function is that type of the batch value:
        // 1 instead of '1'. This should probably be changed in the Laravel framework as it
        // seems unnecessary to use a numeric string here.

        $query = $this->table()
            ->where('batch', '>=', 1)
            ->orderBy('batch', 'desc')

'batch' of type string is incompatible with the type Closure|Illuminate\Database\Eloquent\Builder|Illuminate\Database\Query\Builder expected by parameter $column of Illuminate\Database\Query\Builder::orderBy().

            ->orderBy('migration', 'desc')
            ->take($steps);

        return $query->get()->all();
    }


    /**
     * Determine if the migration repository exists.
     *
     * @return bool
     * @throws ArangoException
     * @throws AranguentException
     */
    public function repositoryExists()
    {
        if ($this->useFallback()) {
            return parent::repositoryExists();
        }

        $schemaManager = $this->getSchemaManager();

        return $schemaManager->hasCollection($this->table);
    }

    /**
     * Get a query builder for the migration collection.
     *
     * @return IlluminateQueryBuilder
     */
    protected function collection()
    {
        return $this->table();
    }
}