feat: add SyncEntitiesSubscriber to sync entities with migrations

Author: calebdw

src/Listeners/SyncEntities.php

@@ -0,0 +1,55 @@
+<?php
+
+declare(strict_types=1);
+
+namespace CalebDW\SqlEntities\Listeners;
+
+use CalebDW\SqlEntities\EntityManager;
+use Illuminate\Database\Events\MigrationsEnded;
+use Illuminate\Database\Events\MigrationsStarted;
+
+class SyncEntities
+{
+    public function __construct(
+        protected EntityManager $manager,
+    ) {
+    }
+
+    public function handleStarted(MigrationsStarted $event): void
+    {
+        if ($event->method !== 'up') {
+            return;
+        }
+
+        if ($event->options['pretend'] ?? false) {
+            return;
+        }
+
+        $this->manager->dropAll();
+    }
+
+    public function handleEnded(MigrationsEnded $event): void
+    {
+        if ($event->method !== 'up') {
+            return;
+        }
+
+        if ($event->options['pretend'] ?? false) {
+            return;
+        }
+
+        $this->manager->createAll();
+    }
+
+    /**
+     * @codeCoverageIgnore
+     * @return array<string, string>
+     */
+    public function subscribe(): array
+    {
+        return [
+            MigrationsStarted::class => 'handleStarted',
+            MigrationsEnded::class   => 'handleEnded',
+        ];
+    }
+}

tests/Unit/Listeners/SyncEntitiesSubscriberTest.php

@@ -0,0 +1,66 @@
+<?php
+
+declare(strict_types=1);
+
+use CalebDW\SqlEntities\EntityManager;
+use CalebDW\SqlEntities\Listeners\SyncEntities;
+use Illuminate\Database\Events\MigrationsEnded;
+use Illuminate\Database\Events\MigrationsStarted;
+use Mockery;
+
+beforeEach(function () {
+    test()->manager = Mockery::mock(EntityManager::class);
+    test()->listener = new SyncEntities(test()->manager);
+});
+
+afterEach(function () {
+    Mockery::close();
+});
+
+describe('started', function () {
+    it('does nothing if the method is not "up"', function () {
+        test()->manager->shouldNotReceive('dropAll');
+        test()->listener->handleStarted(
+            new MigrationsStarted(method: 'down'),
+        );
+    });
+    it('does nothing if the pretend option is true', function () {
+        test()->manager->shouldNotReceive('dropAll');
+        test()->listener->handleStarted(
+            new MigrationsStarted(method: 'up', options: ['pretend' => true]),
+        );
+    });
+    it('drops all entities', function () {
+        test()->manager
+            ->shouldReceive('dropAll')
+            ->once();
+
+        test()->listener->handleStarted(
+            new MigrationsStarted(method: 'up'),
+        );
+    });
+});
+
+describe('ended', function () {
+    it('does nothing if the method is not "up"', function () {
+        test()->manager->shouldNotReceive('createAll');
+        test()->listener->handleEnded(
+            new MigrationsEnded(method: 'down'),
+        );
+    });
+    it('does nothing if the pretend option is true', function () {
+        test()->manager->shouldNotReceive('createAll');
+        test()->listener->handleEnded(
+            new MigrationsEnded(method: 'up', options: ['pretend' => true]),
+        );
+    });
+    it('creates all entities', function () {
+        test()->manager
+            ->shouldReceive('createAll')
+            ->once();
+
+        test()->listener->handleEnded(
+            new MigrationsEnded(method: 'up'),
+        );
+    });
+});