From d432e704df1b9de4192ad509cb40e8ec8d8d7f4d Mon Sep 17 00:00:00 2001
From: Diego Pino Navarro <DiegoPino@users.noreply.github.com>
Date: Thu, 8 Aug 2024 16:24:11 -0400
Subject: [PATCH] First pass on the Action ADO queworker & and CSV to action

So far only acts on delete. But will do magic. I promise @alliomeria
---
 src/Plugin/QueueWorker/ActionADOQueueWorker.php | 12 +++++++-----
 1 file changed, 7 insertions(+), 5 deletions(-)

diff --git a/src/Plugin/QueueWorker/ActionADOQueueWorker.php b/src/Plugin/QueueWorker/ActionADOQueueWorker.php
index 3aa73fa..d11cfbd 100644
--- a/src/Plugin/QueueWorker/ActionADOQueueWorker.php
+++ b/src/Plugin/QueueWorker/ActionADOQueueWorker.php
@@ -188,10 +188,11 @@ public static function create(
   /**
    * {@inheritdoc}
    */
-  public function processItem($data)
-  {
+  public function processItem($data) {
     $log = new Logger('ami_file');
-    $private_path = \Drupal::service('stream_wrapper_manager')->getViaUri('private://')->getDirectoryPath();
+    $private_path = \Drupal::service('stream_wrapper_manager')
+      ->getViaUri('private://')
+      ->getDirectoryPath();
     $handler = new StreamHandler($private_path . '/ami/logs/set' . $data->info['set_id'] . '.log', Logger::DEBUG);
     $handler->setFormatter(new JsonFormatter());
     $log->pushHandler($handler);
@@ -219,7 +220,7 @@ public function processItem($data)
               'batch_size' => max Number of UUIDs/ADOS to process per Queue entry, defaults to 50,
             ];
     */
-    if  ($data->pluginconfig->op !== "action") {
+    if ($data->pluginconfig->op !== "action") {
       return;
     }
 
@@ -245,8 +246,8 @@ public function processItem($data)
         'setid' => $data->info['set_id'] ?? NULL,
         'time_submitted' => $data->info['time_submitted'] ?? '',
       ]);
+      return;
     }
-    return;
   }
 
   private function processAction($data): bool|null {
@@ -319,6 +320,7 @@ private function processAction($data): bool|null {
               'time_submitted' => $data->info['time_submitted'] ?? '',
             ]);
             $success = TRUE;
+
           }
           catch (EntityStorageException $e) {
             $message = $this->t('Error executing @action on ADOs via Set @setid.', [