Merge pull request #6 from keboola/odin-PS-2489

add long processing event

Author: odinuv

README.md

@@ -1,4 +1,4 @@
-# Notification API PHP Client [![Build Status]
+# Notification API PHP Client [![Build Status](https://dev.azure.com/keboola-dev/notification-api-php-client/_apis/build/status/keboola.notification-api-php-client?branchName=main)](https://dev.azure.com/keboola-dev/notification-api-php-client/_build/latest?definitionId=82&branchName=main)
 
 PHP client for the Notification API ([API docs](https://app.swaggerhub.com/apis/odinuv/notifications-service/1.0.0)).
 

src/Requests/PostEvent/JobProcessingLongEventData.php

@@ -0,0 +1,52 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Keboola\NotificationClient\Requests\PostEvent;
+
+use Keboola\NotificationClient\Requests\EventDataInterface;
+
+class JobProcessingLongEventData implements EventDataInterface
+{
+    private string $projectId;
+    private string $projectName;
+    private float $durationOvertimePercentage;
+    private float $averageDuration;
+    private float $currentDuration;
+    private JobData $jobData;
+
+    public function __construct(
+        string $projectId,
+        string $projectName,
+        float $durationOvertimePercentage,
+        float $averageDuration,
+        float $currentDuration,
+        JobData $jobData
+    ) {
+        $this->projectId = $projectId;
+        $this->projectName = $projectName;
+        $this->durationOvertimePercentage = $durationOvertimePercentage;
+        $this->jobData = $jobData;
+        $this->averageDuration = $averageDuration;
+        $this->currentDuration = $currentDuration;
+    }
+
+    public function jsonSerialize(): array
+    {
+        return [
+            'averageDuration' => $this->averageDuration,
+            'currentDuration' => $this->currentDuration,
+            'durationOvertimePercentage' => $this->durationOvertimePercentage,
+            'job' => $this->jobData->jsonSerialize(),
+            'project' => [
+                'id' => $this->projectId,
+                'name' => $this->projectName,
+            ],
+        ];
+    }
+
+    public static function getEventTypeName(): string
+    {
+        return 'job-processing-long';
+    }
+}

tests/Requests/PostEvent/JobProcessingLongEventDataTest.php

@@ -0,0 +1,57 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Keboola\NotificationClient\Tests\Requests\PostEvent;
+
+use DateTimeImmutable;
+use Keboola\NotificationClient\Requests\PostEvent\JobData;
+use Keboola\NotificationClient\Requests\PostEvent\JobFailedEventData;
+use Keboola\NotificationClient\Requests\PostEvent\JobProcessingLongEventData;
+use PHPUnit\Framework\TestCase;
+
+class JobProcessingLongEventDataTest extends TestCase
+{
+    public function testJsonSerialize(): void
+    {
+        $jobData = new JobData(
+            '23456',
+            'http://someUrl',
+            new DateTimeImmutable('2020-01-01T11:11:00+00:00'),
+            new DateTimeImmutable('2020-01-01T12:11:00+00:00'),
+            'keboola.orchestrator',
+            'Orchestrator',
+            'my-configuration',
+            'My configuration'
+        );
+        $failedEventData = new JobProcessingLongEventData('1234', 'My project', 12.534, 23.854, 12.0, $jobData);
+        self::assertSame(
+            [
+                'averageDuration' => 23.854,
+                'currentDuration' => 12.0,
+                'durationOvertimePercentage' => 12.534,
+                'job' => [
+                    'id' => '23456',
+                    'url' => 'http://someUrl',
+                    'component' => [
+                        'id' => 'keboola.orchestrator',
+                        'name' => 'Orchestrator',
+                    ],
+                    'tasks' => [],
+                    'startTime' => '2020-01-01T11:11:00+00:00',
+                    'endTime' => '2020-01-01T12:11:00+00:00',
+                    'configuration' => [
+                        'id' => 'my-configuration',
+                        'name' => 'My configuration',
+                    ],
+                ],
+                'project' => [
+                    'id' => '1234',
+                    'name' => 'My project',
+                ],
+            ],
+            $failedEventData->jsonSerialize()
+        );
+        self::assertEquals('job-processing-long', $failedEventData::getEventTypeName());
+    }
+}