php-service-bus / module-event-sourcing

src/SqlSchemaCreator.php

<?php

/**
 * Event Sourcing implementation module.
 *
 * @author  Maksim Masiukevich <dev@async-php.com>
 * @license MIT
 * @license https://opensource.org/licenses/MIT
 */

declare(strict_types = 1);

namespace ServiceBus\EventSourcingModule;

use function Amp\call;
use Amp\Promise;
use ServiceBus\Storage\Common\DatabaseAdapter;

/**
 * @codeCoverageIgnore
 */
final class SqlSchemaCreator
{
    private const FIXTURES = [
        /** common fixtures */
        '/src/EventStream/Store/schema/extensions.sql'                => false,
        /** event streams */
        '/src/EventStream/Store/schema/event_store_stream.sql'        => false,
        '/src/EventStream/Store/schema/event_store_stream_events.sql' => false,
        '/src/EventStream/Store/schema/indexes.sql'                   => true,
        /** snapshots */
        '/src/Snapshots/Store/schema/event_store_snapshots.sql'       => false,
        '/src/Snapshots/Store/schema/indexes.sql'                     => true,
        /** indexer */
        '/src/Indexes/Store/schema/event_sourcing_indexes.sql'        => false,
    ];

    /**
     * @var DatabaseAdapter
     */
    private $adapter;

    /**
     * @var string
     */
    private $rootDirectoryPath;

    /**
     * @param DatabaseAdapter $adapter
     * @param string          $rootDirectoryPath
     */
    public function __construct(DatabaseAdapter $adapter, string $rootDirectoryPath)
    {
        $this->adapter           = $adapter;
        $this->rootDirectoryPath = \rtrim($rootDirectoryPath, '/');
    }

    /**
     * Import fixtures.
     *
     * @return Promise
     */
    public function import(): Promise
    {
        /** @psalm-suppress InvalidArgument Incorrect psalm unpack parameters (...$args) */
        return call(
            function(array $fixtures): \Generator
            {
                /**
                 * @var string $filePath
                 * @var bool   $multipleQueries
                 */
                foreach ($fixtures as $filePath => $multipleQueries)
                {
                    $filePath = $this->rootDirectoryPath . $filePath;

                    $queries = true === $multipleQueries
                        ? \array_map('trim', \file($filePath))

It seems like file($filePath) can also be of type false; however, parameter $arr1 of array_map() does only seem to accept array, maybe add an additional type check?

                        : [(string) \file_get_contents($filePath)];

                    foreach ($queries as $query)
                    {
                        if ('' !== $query)
                        {
                            /** @psalm-suppress TooManyTemplateParams Wrong Promise template */
                            yield $this->adapter->execute($query);
                        }
                    }
                }
            },
            self::FIXTURES
        );
    }
}