saga

Makefile

@@ -70,7 +70,7 @@ db_schema_validate:
 	${DOCKER_COMPOSE} exec -u www-data php-fpm bin/console doctrine:schema:validate
 
 db_migration_down:
-	${DOCKER_COMPOSE} exec -u www-data php-fpm bin/console doctrine:migrations:execute "App\Shared\Infrastructure\Database\Migrations\Version********" --down --dry-run
+	${DOCKER_COMPOSE} exec -u www-data php-fpm bin/console doctrine:migrations:execute "App\Shared\Infrastructure\Database\Migrations\Version20240201164919" --down --dry-run
 
 db_drop:
 	docker-compose -f ./docker/docker-compose.yml exec -u www-data php-fpm bin/console doctrine:schema:drop --force

README.md

@@ -53,4 +53,7 @@
 - [X] [Gitlab CI/CD](https://docs.gitlab.com/ee/ci/yaml/)
 - [X] [GitHub Actions](https://docs.github.com/en/actions/quickstart)
 
-Документация [в разработке](docs/index.md).
+Документация [в разработке](docs/index.md).
+
+
+// Добавить слушатели REJECTED и CONFIRMED методов в orders контексте.

composer.json

@@ -32,6 +32,7 @@
         "symfony/twig-bundle": "^6.4",
         "symfony/uid": "^6.4",
         "symfony/validator": "^6.4",
+        "symfony/workflow": "6.*",
         "symfony/yaml": "^6.4",
         "webmozart/assert": "^1.11"
     },

config/packages/doctrine.yaml

@@ -55,6 +55,18 @@ doctrine:
                 dir: '%kernel.project_dir%/src/Payments/Infrastructure/ORM/Aggregate'
                 prefix: 'App\Payments\Domain\Aggregate'
                 alias: Payment
+            Inventory:
+                is_bundle: false
+                type: xml
+                dir: '%kernel.project_dir%/src/Inventory/Infrastructure/ORM/Aggregate'
+                prefix: 'App\Inventory\Domain\Aggregate'
+                alias: Inventory
+            Saga:
+                is_bundle: false
+                type: attribute
+                dir: '%kernel.project_dir%/src/Saga'
+                prefix: 'App\Saga'
+                alias: Saga
 
 #when@test:
 #    doctrine:

config/packages/messenger.yaml

@@ -22,8 +22,34 @@ framework:
                     table_name: 'orders_outbox_message'
                     use_notify: true
                     auto_setup: true
-            # failed: 'doctrine://default?queue_name=failed'
-            # sync: 'sync://'
+                    check_delayed_interval: 1000
+            inventory_outbox:
+                dsn: '%env(DOCTRINE_MESSENGER_TRANSPORT_DSN)%'
+                options:
+                    table_name: 'inventory_outbox_message'
+                    use_notify: true
+                    auto_setup: true
+                    check_delayed_interval: 1000
+            payments_outbox:
+                dsn: '%env(DOCTRINE_MESSENGER_TRANSPORT_DSN)%'
+                options:
+                    table_name: 'payments_outbox_message'
+                    use_notify: true
+                    auto_setup: true
+                    check_delayed_interval: 1000
+            saga:
+                dsn: '%env(MESSENGER_TRANSPORT_DSN)%'
+                serializer: 'App\Saga\Event\EventEnvelopeSerializer'
+                options:
+                    exchange:
+                        name: 'saga'
+                        type: 'topic'
+                    queues:
+                        saga:
+                            binding_keys:
+                                - 'payments.#'
+                                - 'inventory.#'
+                                - 'orders.#'
             orders:
                 dsn: '%env(MESSENGER_TRANSPORT_DSN)%'
                 serializer: 'App\Orders\Infrastructure\Event\EventEnvelopeSerializer'
@@ -34,11 +60,26 @@ framework:
                     queues:
                         orders:
                             binding_keys:
+                                - 'payments.#'
+                                - 'inventory.#'
                                 - 'orders.#'
+            inventory:
+                dsn: '%env(MESSENGER_TRANSPORT_DSN)%'
+                serializer: 'App\Inventory\Infrastructure\Event\EventEnvelopeSerializer'
+#                retry_strategy:
+#                    max_retries: 3
+#                    delay: 1000
+#                    multiplier: 2
+                options:
+                    exchange:
+                        name: 'inventory'
+                        type: 'topic'
+                    queues:
+                        inventory:
+                            binding_keys:
                                 - 'payments.#'
-#                            arguments:
-#                                x-max-length: 10000
-#                                x-overflow: reject-publish
+                                - 'inventory.#'
+                                - 'orders.#'
             payments:
                 dsn: '%env(MESSENGER_TRANSPORT_DSN)%'
                 serializer: 'App\Payments\Infrastructure\Event\EventEnvelopeSerializer'
@@ -50,9 +91,13 @@ framework:
                         payments:
                             binding_keys:
                                 - 'payments.#'
+                                - 'inventory.#'
                                 - 'orders.#'
 
         routing:
+            'App\Orders\Infrastructure\Event\EventEnvelope': [orders, payments, inventory, saga]
             'App\Orders\Infrastructure\Event\Outbox\OutboxMessage': orders_outbox
-            'App\Orders\Infrastructure\Event\EventEnvelope': [orders, payments]
-            'App\Payments\Infrastructure\Event\EventEnvelope': [orders, payments]
+            'App\Payments\Infrastructure\Event\EventEnvelope': [orders, payments, inventory, saga]
+            'App\Payments\Infrastructure\Event\Outbox\OutboxMessage': payments_outbox
+            'App\Inventory\Infrastructure\Event\EventEnvelope': [orders, payments, inventory, saga]
+            'App\Inventory\Infrastructure\Event\Outbox\OutboxMessage': inventory_outbox

config/packages/workflow.yaml

@@ -0,0 +1,48 @@
+framework:
+    workflows:
+        create_order:
+            type: 'state_machine'
+#            marking_store:
+#                type: 'method'
+#                property: 'state'
+            marking_store:
+                service: App\Saga\CreateOrder\SagaMarkingStore
+            supports:
+                - App\Saga\CreateOrder\Entity\CreateOrderSagaEntity
+            initial_marking: reservation_pending
+            places:
+                reservation_pending: ~
+                reservation_rejected: ~
+                reservation_confirmed: ~
+
+                payment_pending: ~
+                payment_rejected: ~
+                payment_confirmed: ~
+
+                order_completed:  ~
+                order_cancelled:  ~
+            transitions:
+                confirm_reservation:
+                    from: reservation_pending
+                    to: reservation_confirmed
+                reject_reservation:
+                    from: reservation_pending
+                    to: reservation_rejected
+
+                pay_order:
+                    from: reservation_confirmed
+                    to: payment_pending
+                confirm_payment:
+                    from: payment_pending
+                    to: payment_confirmed
+                reject_payment:
+                    from: payment_pending
+                    to: payment_rejected
+
+                complete:
+                    from: payment_confirmed
+                    to: order_completed
+
+                cancel:
+                    from: [reservation_rejected, payment_rejected]
+                    to: order_cancelled

deptrac-modules.yaml

@@ -33,6 +33,14 @@ parameters:
       collectors:
         - type: directory
           regex: /src/Payments/.*
+    - name: Inventory
+      collectors:
+        - type: directory
+          regex: /src/Inventory/.*
+    - name: Saga
+      collectors:
+        - type: directory
+          regex: /src/Saga/.*
   ruleset:
     Skills:
       - Shared
@@ -46,3 +54,7 @@ parameters:
       - Shared
     Payments:
       - Shared
+    Inventory:
+      - Shared
+    Saga:
+      - Shared

docker/php-fpm/Dockerfile

@@ -37,6 +37,9 @@ RUN apk add --no-cache rabbitmq-c-dev \
 RUN apk add --no-cache supervisor
 COPY ./docker/php-fpm/supervisord.conf /etc/supervisord.conf
 
+# Graphviz, provides the dot command (Symfony Workflow component)
+RUN apk add --no-cache graphviz ttf-freefont
+
 # Source code
 RUN chown www-data:www-data /var/www
 COPY --chown=www-data:www-data ./ /var/www

docker/php-fpm/supervisord.conf

@@ -44,4 +44,16 @@ user=www-data
 stdout_logfile=/dev/stdout
 stdout_logfile_maxbytes=0
 stderr_logfile=/dev/stderr
-stderr_logfile_maxbytes=0
+stderr_logfile_maxbytes=0
+
+;[program:messenger-consume]
+;command=php bin/console messenger:consume orders_outbox inventory_outbox payments_outbox saga orders inventory payments
+;autostart=true
+;autorestart=true
+;priority=20
+;startretries=1
+;user=www-data
+;stdout_logfile=/dev/stdout
+;stdout_logfile_maxbytes=0
+;stderr_logfile=/dev/stderr
+;stderr_logfile_maxbytes=0

src/Console/TestCompletePaymentConsoleCommand.php

@@ -0,0 +1,30 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Console;
+
+use App\Payments\Application\UseCase\PaymentsUseCaseInteractor;
+use Symfony\Component\Console\Attribute\AsCommand;
+use Symfony\Component\Console\Command\Command;
+use Symfony\Component\Console\Input\InputInterface;
+use Symfony\Component\Console\Output\OutputInterface;
+
+#[AsCommand(
+    name: 'payments:test',
+)]
+final class TestCompletePaymentConsoleCommand extends Command
+{
+    public function __construct(
+        private PaymentsUseCaseInteractor $paymentsUseCaseInteractor,
+    ) {
+        parent::__construct();
+    }
+
+    protected function execute(InputInterface $input, OutputInterface $output): int
+    {
+        $this->paymentsUseCaseInteractor->completePayment('ff1605cadc83ee2595f4f27bd70a3609');
+
+        return Command::SUCCESS;
+    }
+}