add databox_id and record_id in workerRunningJob

alchemy-fr · Apr 29, 2024 · bac310d · bac310d
1 parent 2c412ec
commit bac310d
Showing 1 changed file with 15 additions and 5 deletions.
diff --git a/lib/Alchemy/Phrasea/WorkerManager/Worker/WebhookWorker.php b/lib/Alchemy/Phrasea/WorkerManager/Worker/WebhookWorker.php
@@ -56,6 +56,12 @@ public function __construct(Application $app)
     public function process(array $payload)
     {
         if (isset($payload['id'])) {
+            $webhookEventId = $payload['id'];
+
+            /** @var WebhookEvent|null $webhookevent */
+            $webhookevent = $this->app['repo.webhook-event']->find($webhookEventId);
+            $wData = $webhookevent->getData();
+
             $this->repoWorkerJob = $this->getWorkerRunningJobRepository();
             $em = $this->repoWorkerJob->getEntityManager();
             $em->beginTransaction();
@@ -70,12 +76,20 @@ public function process(array $payload)
                 $workerRunningJob = new WorkerRunningJob();
                 $workerRunningJob
                     ->setWork(MessagePublisher::WEBHOOK_TYPE)
-                    ->setWorkOn('WebhookEventId: '. $payload['id'])
+                    ->setWorkOn($webhookevent->getName() . ' , WebhookEventId: '. $payload['id'])
                     ->setPayload($message)
                     ->setPublished($date->setTimestamp($payload['published']))
                     ->setStatus(WorkerRunningJob::RUNNING)
                 ;
 
+                if (isset($wData['databox_id'])) {
+                    $workerRunningJob->setDataboxId($wData['databox_id']);
+                }
+
+                if (isset($wData['record_id'])) {
+                    $workerRunningJob->setRecordId($wData['record_id']);
+                }
+
                 $em->persist($workerRunningJob);
 
                 $em->flush();
@@ -85,7 +99,6 @@ public function process(array $payload)
                 $em->rollback();
             }
 
-            $webhookEventId = $payload['id'];
             $app = $this->app;
 
             $version = new Version();
@@ -107,9 +120,6 @@ public function process(array $payload)
 
             $thirdPartyApplications = $this->app['repo.api-applications']->findWithDefinedWebhookCallback();
 
-            /** @var WebhookEvent|null $webhookevent */
-            $webhookevent = $this->app['repo.webhook-event']->find($webhookEventId);
-
             if ($webhookevent !== null) {
                 $app['manipulator.webhook-event']->processed($webhookevent);