refactor subscription engine

Author: DavidBadura

docker-compose.yaml

@@ -1,4 +1,15 @@
+# docker run --rm -it --volume $PWD:/app --net="host" -w /app ghcr.io/patchlevel/php:8.5
 services:
+  php:
+    image: ghcr.io/patchlevel/php:8.5
+    volumes:
+      - .:/app
+    working_dir: /app
+    network_mode: host
+    tty: true
+    stdin_open: true
+    command: sleep infinity
+
   postgres:
     image: postgres:alpine
     environment:
@@ -13,4 +24,4 @@ services:
       - MYSQL_ALLOW_EMPTY_PASSWORD="yes"
       - MYSQL_DATABASE=eventstore
     ports:
-      - 3306:3306
+      - 3306:3306

src/Subscription/Engine/Command/Boot.php

@@ -0,0 +1,21 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Patchlevel\EventSourcing\Subscription\Engine\Command;
+
+final class Boot extends Command
+{
+    /**
+     * @param list<string>|null $ids
+     * @param list<string>|null $groups
+     * @param positive-int|null $limit
+     */
+    public function __construct(
+        array|null $ids = null,
+        array|null $groups = null,
+        public readonly int|null $limit = null,
+    ) {
+        parent::__construct($ids, $groups);
+    }
+}

src/Subscription/Engine/Command/Command.php

@@ -0,0 +1,18 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Patchlevel\EventSourcing\Subscription\Engine\Command;
+
+abstract class Command
+{
+    /**
+     * @param list<string>|null $ids
+     * @param list<string>|null $groups
+     */
+    public function __construct(
+        public readonly array|null $ids = null,
+        public readonly array|null $groups = null,
+    ) {
+    }
+}

src/Subscription/Engine/Command/Pause.php

@@ -0,0 +1,9 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Patchlevel\EventSourcing\Subscription\Engine\Command;
+
+final class Pause extends Command
+{
+}

src/Subscription/Engine/Command/Reactivate.php

@@ -0,0 +1,9 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Patchlevel\EventSourcing\Subscription\Engine\Command;
+
+final class Reactivate extends Command
+{
+}

src/Subscription/Engine/Command/Refresh.php

@@ -0,0 +1,9 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Patchlevel\EventSourcing\Subscription\Engine\Command;
+
+final class Refresh extends Command
+{
+}

src/Subscription/Engine/Command/Remove.php

@@ -0,0 +1,9 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Patchlevel\EventSourcing\Subscription\Engine\Command;
+
+final class Remove extends Command
+{
+}

src/Subscription/Engine/Command/Run.php

@@ -0,0 +1,21 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Patchlevel\EventSourcing\Subscription\Engine\Command;
+
+final class Run extends Command
+{
+    /**
+     * @param list<string>|null $ids
+     * @param list<string>|null $groups
+     * @param positive-int|null $limit
+     */
+    public function __construct(
+        array|null $ids = null,
+        array|null $groups = null,
+        public readonly int|null $limit = null,
+    ) {
+        parent::__construct($ids, $groups);
+    }
+}

src/Subscription/Engine/Command/Setup.php

@@ -0,0 +1,20 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Patchlevel\EventSourcing\Subscription\Engine\Command;
+
+final class Setup extends Command
+{
+    /**
+     * @param list<string>|null $ids
+     * @param list<string>|null $groups
+     */
+    public function __construct(
+        array|null $ids = null,
+        array|null $groups = null,
+        public readonly bool $skipBooting = false,
+    ) {
+        parent::__construct($ids, $groups);
+    }
+}

src/Subscription/Engine/Command/Teardown.php

@@ -0,0 +1,9 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Patchlevel\EventSourcing\Subscription\Engine\Command;
+
+final class Teardown extends Command
+{
+}