feat: workflow example

.github/workflows/coding-standards.yml

@@ -95,7 +95,7 @@ jobs:
         uses: shivammathur/[email protected]
         with:
           php-version: ${{ matrix.php-version }}
-          extensions: none, ctype, dom, json, mbstring, simplexml, tokenizer, xml, xmlwriter, pdo, curl, fileinfo, pdo_mysql, sockets, decimal
+          extensions: none, ctype, dom, json, mbstring, simplexml, tokenizer, xml, xmlwriter, pdo, curl, fileinfo, pdo_mysql, sockets, decimal, grpc
           ini-values: error_reporting=E_ALL
           coverage: none
           tools: phive

.github/workflows/dependency-analysis.yml

@@ -46,7 +46,7 @@ jobs:
         uses: shivammathur/[email protected]
         with:
           php-version: ${{ matrix.php-version }}
-          extensions: none, ctype, dom, json, mbstring, simplexml, tokenizer, xml, xmlwriter, pdo, curl, fileinfo, pdo_mysql, sockets, decimal
+          extensions: none, ctype, dom, json, mbstring, simplexml, tokenizer, xml, xmlwriter, pdo, curl, fileinfo, pdo_mysql, sockets, decimal, grpc
           ini-values: error_reporting=E_ALL
           coverage: none
           tools: phive
@@ -109,7 +109,7 @@ jobs:
         uses: shivammathur/[email protected]
         with:
           php-version: ${{ matrix.php-version }}
-          extensions: none, ctype, dom, json, mbstring, simplexml, tokenizer, xml, xmlwriter, pdo, curl, fileinfo, pdo_mysql, sockets, decimal
+          extensions: none, ctype, dom, json, mbstring, simplexml, tokenizer, xml, xmlwriter, pdo, curl, fileinfo, pdo_mysql, sockets, decimal, grpc
           ini-values: error_reporting=E_ALL
           coverage: none
           tools: phive

.github/workflows/refactoring.yml

@@ -41,7 +41,7 @@ jobs:
         uses: shivammathur/[email protected]
         with:
           php-version: ${{ matrix.php-version }}
-          extensions: none, ctype, dom, json, mbstring, simplexml, tokenizer, xml, xmlwriter, pdo, curl, fileinfo, pdo_mysql, sockets, decimal
+          extensions: none, ctype, dom, json, mbstring, simplexml, tokenizer, xml, xmlwriter, pdo, curl, fileinfo, pdo_mysql, sockets, decimal, grpc
           ini-values: error_reporting=E_ALL
           coverage: none
 

.github/workflows/security-analysis.yml

@@ -36,7 +36,7 @@ jobs:
         uses: shivammathur/[email protected]
         with:
           php-version: ${{ matrix.php-version }}
-          extensions: none, ctype, dom, json, mbstring, simplexml, tokenizer, xml, xmlwriter, pdo, curl, fileinfo, sockets, decimal
+          extensions: none, ctype, dom, json, mbstring, simplexml, tokenizer, xml, xmlwriter, pdo, curl, fileinfo, sockets, decimal, grpc
           ini-values: error_reporting=E_ALL
           coverage: none
 

.github/workflows/static-analysis.yml

@@ -35,7 +35,7 @@ jobs:
         uses: shivammathur/[email protected]
         with:
           php-version: ${{ matrix.php-version }}
-          extensions: none, ctype, dom, json, mbstring, simplexml, tokenizer, xml, xmlwriter, pdo, curl, fileinfo, pdo_mysql, opcache, pcntl, posix, sockets, decimal
+          extensions: none, ctype, dom, json, mbstring, simplexml, tokenizer, xml, xmlwriter, pdo, curl, fileinfo, pdo_mysql, opcache, pcntl, posix, sockets, decimal, grpc
           ini-values: error_reporting=E_ALL
           coverage: none
 
@@ -89,7 +89,7 @@ jobs:
         uses: shivammathur/[email protected]
         with:
           php-version: ${{ matrix.php-version }}
-          extensions: none, ctype, dom, json, mbstring, simplexml, tokenizer, xml, xmlwriter, pdo, pdo_mysql, curl, fileinfo, opcache, pcntl, posix, sockets, decimal
+          extensions: none, ctype, dom, json, mbstring, simplexml, tokenizer, xml, xmlwriter, pdo, pdo_mysql, curl, fileinfo, opcache, pcntl, posix, sockets, decimal, grpc
           ini-values: error_reporting=E_ALL
           coverage: xdebug
 

.github/workflows/testing.yml

@@ -42,7 +42,7 @@ jobs:
         uses: shivammathur/[email protected]
         with:
           php-version: ${{ matrix.php-version }}
-          extensions: none, ctype, dom, json, mbstring, simplexml, tokenizer, xml, xmlwriter, pdo, pdo_mysql, pdo_sqlite, curl, fileinfo, opcache, pcntl, posix, sockets, decimal
+          extensions: none, ctype, dom, json, mbstring, simplexml, tokenizer, xml, xmlwriter, pdo, pdo_mysql, pdo_sqlite, curl, fileinfo, opcache, pcntl, posix, sockets, decimal, grpc
           ini-values: error_reporting=E_ALL
           coverage: xdebug
 

app/composer.json

@@ -39,6 +39,7 @@
         "ext-mbstring": "*",
         "ext-pdo": "*",
         "ext-sockets": "*",
+        "ext-grpc": "*",
         "beberlei/assert": "^3.3",
         "cycle/annotated": "^4.2",
         "cycle/database": "^2.11",
@@ -52,6 +53,7 @@
         "spiral-packages/laravel-validator": "^1.1",
         "spiral-packages/league-event": "^1.0",
         "spiral-packages/scheduler": "^2.3",
+        "spiral-packages/swagger-php": "^1.0",
         "spiral-packages/yii-error-handler-bridge": "^1.1",
         "spiral/cycle-bridge": "^2.10",
         "spiral/data-grid-bridge": "^3.0",

app/src/Application/Transfer/DTO/TransferDetails.php

@@ -0,0 +1,39 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Application\Transfer\DTO;
+
+use OpenApi\Attributes as OAT;
+
+class TransferDetails
+{
+    #[OAT\Property(format: 'string', example: '10ab5df0-693a-4cd8-8ed5-1e702947d4d0')]
+    public string $transferId;
+
+    #[OAT\Property(format: 'string', example: '10ab5df0-693a-4cd8-8ed5-1e702947d4d0')]
+    public string $fromUserId;
+
+    #[OAT\Property(format: 'string', example: '10ab5df0-693a-4cd8-8ed5-1e702947d4d0')]
+    public string $toUserId;
+
+    #[OAT\Property(format: 'string', example: 'https://wayof.dev')]
+    public string $fromDomain;
+
+    #[OAT\Property(format: 'string', example: 'https://your-dev.way')]
+    public string $toDomain;
+
+    public function __construct(
+        string $transferId,
+        string $fromUserId,
+        string $toUserId,
+        string $fromDomain,
+        string $toDomain,
+    ) {
+        $this->transferId = $transferId;
+        $this->fromUserId = $fromUserId;
+        $this->toUserId = $toUserId;
+        $this->fromDomain = $fromDomain;
+        $this->toDomain = $toDomain;
+    }
+}

app/src/Bridge/Spiral/Console/TransferCommand.php

@@ -0,0 +1,33 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Bridge\Spiral\Console;
+
+use Application\Transfer\DTO\TransferDetails;
+use Infrastructure\Temporal\Transfer\Workflows\TransferWebsiteWorkflowStub;
+use Spiral\Console\Attribute\AsCommand;
+use Spiral\Console\Command;
+use Temporal\Client\WorkflowClientInterface;
+
+/**
+ * @psalm-suppress PropertyNotSetInConstructor
+ */
+#[AsCommand(name: 'website:transfer', description: 'Transfer website from source to destination')]
+class TransferCommand extends Command
+{
+    public function __invoke(WorkflowClientInterface $workflow): int
+    {
+        $transferDetails = new TransferDetails(
+            transferId: '10ab5df0-693a-4cd8-8ed5-1e702947d4d0',
+            fromUserId: '10ab5df0-693a-4cd8-8ed5-1e702947d4d0',
+            toUserId: '10ab5df0-693a-4cd8-8ed5-1e702947d4d0',
+            fromDomain: 'https://wayof.dev',
+            toDomain: 'https://your-dev.way'
+        );
+
+        TransferWebsiteWorkflowStub::handle($workflow, $transferDetails);
+
+        return self::SUCCESS;
+    }
+}

app/src/Domain/Transfer/Contracts/TransferWebsiteWorkflowInterface.php

@@ -0,0 +1,16 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Domain\Transfer\Contracts;
+
+use Application\Transfer\DTO\TransferDetails;
+use Temporal\Workflow\WorkflowInterface;
+use Temporal\Workflow\WorkflowMethod;
+
+#[WorkflowInterface]
+interface TransferWebsiteWorkflowInterface
+{
+    #[WorkflowMethod(name: 'website.transfer')]
+    public function handle(TransferDetails $transferDetails);
+}

app/src/Infrastructure/Temporal/Transfer/Activities/Destination/AllocateSpaceActivity.php

@@ -0,0 +1,22 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Infrastructure\Temporal\Transfer\Activities\Destination;
+
+use Ramsey\Uuid\Uuid;
+use Temporal\Activity\ActivityInterface;
+
+use function sleep;
+
+#[ActivityInterface(prefix: 'website.transfer.destination.')]
+final readonly class AllocateSpaceActivity
+{
+    public function handle(): string
+    {
+        // Simulate long-running Amazon Block Storage allocation
+        sleep(5);
+
+        return Uuid::uuid7()->toString();
+    }
+}

app/src/Infrastructure/Temporal/Transfer/Activities/Destination/AttachDomainActivity.php

@@ -0,0 +1,22 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Infrastructure\Temporal\Transfer\Activities\Destination;
+
+use Ramsey\Uuid\Uuid;
+use Temporal\Activity\ActivityInterface;
+
+use function sleep;
+
+#[ActivityInterface(prefix: 'website.transfer.destination.')]
+final readonly class AttachDomainActivity
+{
+    public function handle(): string
+    {
+        // Attach domain in destination
+        sleep(5);
+
+        return Uuid::uuid7()->toString();
+    }
+}