somehow working tests - not yet fully

Author: skurfuerst

composer.json

@@ -15,7 +15,8 @@
         "phpstan/phpstan": "^1.10",
         "squizlabs/php_codesniffer": "^4.0.x-dev",
         "phpunit/phpunit": "^10",
-        "brianium/paratest": "^7.2"
+        "brianium/paratest": "^7.2",
+        "illuminate/support": "^11"
     },
     "autoload": {
         "psr-4": {
@@ -34,9 +35,9 @@
         "test:cs:fix": "phpcbf --colors src",
         "test:integration": "phpunit tests/Integration --exclude-group=parallel",
         "test:consistency": [
-            "Sandstorm\\EventStore\\LaravelAdapter\\Tests\\Integration\\DoctrineEventStoreTest::consistency_prepare",
+            "Sandstorm\\EventStore\\LaravelAdapter\\Tests\\Integration\\LaravelEventStoreTest::consistency_prepare",
             "paratest tests/Integration --group=parallel --functional --processes 10",
-            "Sandstorm\\EventStore\\LaravelAdapter\\Tests\\Integration\\DoctrineEventStoreTest::consistency_validateEvents"
+            "Sandstorm\\EventStore\\LaravelAdapter\\Tests\\Integration\\LaravelEventStoreTest::consistency_validateEvents"
         ],
         "test": [
             "@test:phpstan",

src/LaravelEventStore.php

@@ -179,40 +179,77 @@ public function status(): Status
 
         /** @var SchemaBuilder $schema */
         $schema = $this->connection->getSchemaBuilder();
-        if (!$schema->hasTable($this->eventTableName)) {
+        if (! $schema->hasTable($this->eventTableName)) {
             return Status::setupRequired(
                 sprintf('Table `%s` does not exist.', $this->eventTableName)
             );
         }
 
+        // detect schema drift: make sure all the columns we created in setup() are still here
+        $actual = $schema->getColumnListing($this->eventTableName);
+        $expected = [
+            'sequencenumber',
+            'stream',
+            'version',
+            'type',
+            'payload',
+            'metadata',
+            'id',
+            'causationid',
+            'correlationid',
+            'recordedat',
+        ];
+
+        if (count(array_diff($expected, $actual)) > 0) {
+            return Status::setupRequired(
+                sprintf('Table `%s` requires schema update.', $this->eventTableName)
+            );
+        }
+
         return Status::ok();
     }
 
+
     public function setup(): void
     {
         /** @var SchemaBuilder $schema */
         $schema = $this->connection->getSchemaBuilder();
-        if (!$schema->hasTable($this->eventTableName)) {
+
+        if (! $schema->hasTable($this->eventTableName)) {
             $schema->create($this->eventTableName, function (Blueprint $table) {
-                $table->unsignedBigInteger('sequencenumber', true);
-                $table->string('stream', StreamName::MAX_LENGTH)->charset('ascii');
+                // == PRIMARY KEY ==
+                // bigIncrements on MySQL => BIGINT UNSIGNED AUTO_INCREMENT PRIMARY KEY
+                // on SQLite Laravel will collapse it to INTEGER PRIMARY KEY AUTOINCREMENT
+                $table->bigIncrements('sequencenumber');
+
+                // == COLUMNS ==
+                $table->string('stream', StreamName::MAX_LENGTH)
+                    ->charset('ascii');
                 $table->unsignedBigInteger('version');
-                $table->string('type', Event\EventType::MAX_LENGTH)->charset('ascii');
+                $table->string('type', Event\EventType::MAX_LENGTH)
+                    ->charset('ascii');
                 $table->text('payload');
                 $table->json('metadata')->nullable();
-                $table->char('id', Event\EventId::MAX_LENGTH);
-                $table->char('causationid', Event\CausationId::MAX_LENGTH)->nullable();
-                $table->char('correlationid', Event\CorrelationId::MAX_LENGTH)->nullable();
-                $table->timestamp('recordedat');
+                $table->char('id', Event\EventId::MAX_LENGTH)
+                    ->charset('ascii')
+                    ->unique();
+                $table->char('causationid', Event\CausationId::MAX_LENGTH)
+                    ->charset('ascii')
+                    ->nullable();
+                $table->char('correlationid', Event\CorrelationId::MAX_LENGTH)
+                    ->charset('ascii')
+                    ->nullable();
+                // Doctrine used DATETIME, so use dateTime() here (not timestamp)
+                $table->dateTime('recordedat');
 
-                $table->primary('sequencenumber');
-                $table->unique('id');
+                // == INDEXES ==
                 $table->unique(['stream', 'version']);
                 $table->index('correlationid');
             });
         }
     }
 
+
     private function getStreamVersion(StreamName $streamName): MaybeVersion
     {
         $version = $this->connection

tests/Integration/LaravelEventStoreTest.php

@@ -3,6 +3,8 @@
 
 namespace Sandstorm\EventStore\LaravelAdapter\Tests\Integration;
 
+use Illuminate\Config\Repository;
+use Illuminate\Container\Container;
 use Illuminate\Database\Capsule\Manager as Capsule;
 use Illuminate\Database\Connection;
 use Illuminate\Database\Schema\Blueprint;
@@ -13,6 +15,26 @@
 use PHPUnit\Framework\Attributes\CoversClass;
 use Sandstorm\EventStore\LaravelAdapter\LaravelEventStore;
 
+require_once __DIR__ . '/../../vendor/autoload.php';
+
+class TestApplication extends Container
+{
+    public function basePath(string $path = ''): string
+    {
+        // point this at your package root (or test root) so that SQLite can write its files
+        $root = __DIR__ . '/..';
+        return $path ? $root . DIRECTORY_SEPARATOR . $path : $root;
+    }
+
+    public function databasePath(string $path = ''): string
+    {
+        // if you want SQLite files under "database/"
+        $db = $this->basePath('database');
+        return $path ? $db . DIRECTORY_SEPARATOR . $path : $db;
+    }
+}
+
+
 #[CoversClass(LaravelEventStore::class)]
 final class LaravelEventStoreTest extends AbstractEventStoreTestBase
 {
@@ -25,19 +47,25 @@ protected static function createEventStore(): EventStoreInterface
 
     protected static function resetEventStore(): void
     {
-        $schema = self::connection()->getSchemaBuilder();
-        if ($schema->hasTable(self::eventTableName())) {
-            $schema->drop(self::eventTableName());
-        }
+        unlink(__DIR__ . '/../events_test.sqlite');
     }
 
     public static function connection(): Connection
     {
         if (self::$capsule === null) {
+
+            // 1) replace the global container
+            Container::setInstance(new TestApplication());
+
+            $path = __DIR__ . '/../events_test.sqlite';
+            if (!file_exists($path)) {
+                touch($path);
+            }
+
             $capsule = new Capsule();
             $capsule->addConnection([
                 'driver'   => 'sqlite',
-                'database' => __DIR__ . '/../events_test.sqlite',
+                'database' => $path,
                 'prefix'   => '',
             ], 'default');
             $capsule->setAsGlobal();