feat(vikon): add PollPartStatusTask for part update polling

2026-07-05 02:41:23 +05:00
parent a624b83f18
commit 4764d4e2d9
2 changed files with 124 additions and 0 deletions
@@ -0,0 +1,50 @@
+<?php
+
+namespace App\Containers\VikonIntegration\Tasks;
+
+use Illuminate\Support\Facades\Log;
+
+class PollPartStatusTask
+{
+    public function __construct(
+        private readonly HttpTask $http,
+        private readonly int $interval,
+        private readonly int $maxAttempts,
+    ) {}
+
+    public function run(string $operationIdentity, string $accessToken): array
+    {
+        for ($attempt = 0; $attempt < $this->maxAttempts; $attempt++) {
+            $response = $this->http->getWithToken(
+                "pull_updates/getStatusPartGenerationByNewCoreJson?operation_identity={$operationIdentity}",
+                $accessToken
+            );
+
+            $body = $response->json();
+            $status = $body['status'] ?? 'unknown';
+
+            Log::info('Vikon poll part status', [
+                'operation' => $operationIdentity,
+                'status' => $status,
+                'attempt' => $attempt + 1,
+            ]);
+
+            if ($status === 'completed') {
+                return ['status' => 'completed'];
+            }
+
+            if ($status === 'failed') {
+                return [
+                    'status' => 'failed',
+                    'error' => $body['message'] ?? 'Unknown error',
+                ];
+            }
+
+            if ($attempt < $this->maxAttempts - 1) {
+                sleep($this->interval);
+            }
+        }
+
+        return ['status' => 'timeout'];
+    }
+}
@@ -0,0 +1,74 @@
+<?php
+
+namespace App\Containers\VikonIntegration\Tests\Unit;
+
+use App\Containers\VikonIntegration\Tasks\PollPartStatusTask;
+use App\Containers\VikonIntegration\Tasks\HttpTask;
+use App\Ship\Tests\TestCase;
+use Illuminate\Http\Client\Response;
+use Mockery;
+
+class PollPartStatusTaskTest extends TestCase
+{
+    protected function tearDown(): void
+    {
+        Mockery::close();
+        parent::tearDown();
+    }
+
+    public function test_returns_completed_when_status_is_completed(): void
+    {
+        $http = Mockery::mock(HttpTask::class);
+        $response = Mockery::mock(Response::class);
+        $response->shouldReceive('json')->once()->andReturn(['status' => 'completed']);
+
+        $http->shouldReceive('getWithToken')
+            ->once()
+            ->with(
+                Mockery::on(fn ($endpoint) => str_contains($endpoint, 'getStatusPartGeneration')),
+                'test-token'
+            )
+            ->andReturn($response);
+
+        $task = new PollPartStatusTask($http, 3, 50);
+        $result = $task->run('op-123', 'test-token');
+
+        $this->assertEquals('completed', $result['status']);
+    }
+
+    public function test_returns_failed_when_status_is_failed(): void
+    {
+        $http = Mockery::mock(HttpTask::class);
+        $response = Mockery::mock(Response::class);
+        $response->shouldReceive('json')->once()->andReturn([
+            'status' => 'failed',
+            'message' => 'Generation error',
+        ]);
+
+        $http->shouldReceive('getWithToken')
+            ->once()
+            ->andReturn($response);
+
+        $task = new PollPartStatusTask($http, 3, 50);
+        $result = $task->run('op-123', 'test-token');
+
+        $this->assertEquals('failed', $result['status']);
+        $this->assertEquals('Generation error', $result['error'] ?? null);
+    }
+
+    public function test_returns_timeout_after_max_attempts(): void
+    {
+        $http = Mockery::mock(HttpTask::class);
+        $response = Mockery::mock(Response::class);
+        $response->shouldReceive('json')->andReturn(['status' => 'pending']);
+
+        $http->shouldReceive('getWithToken')
+            ->times(3)
+            ->andReturn($response);
+
+        $task = new PollPartStatusTask($http, 0, 3); // interval=0, max=3
+        $result = $task->run('op-123', 'test-token');
+
+        $this->assertEquals('timeout', $result['status']);
+    }
+}