From 95a6aa96e9d228883ef9e912e696ef0edb1dbbe3 Mon Sep 17 00:00:00 2001
From: Juan Pablo Vial <jpvialb@incoviba.cl>
Date: Mon, 12 May 2025 19:46:31 -0400
Subject: [PATCH] Queue

---
 app/resources/routes/api/queue.php |  6 ++++++
 app/src/Controller/API/Queues.php  | 23 +++++++++++++++++++++++
 app/src/Service/Worker/Dummy.php   | 17 +++++++++++++++++
 3 files changed, 46 insertions(+)
 create mode 100644 app/resources/routes/api/queue.php
 create mode 100644 app/src/Controller/API/Queues.php
 create mode 100644 app/src/Service/Worker/Dummy.php

diff --git a/app/resources/routes/api/queue.php b/app/resources/routes/api/queue.php
new file mode 100644
index 0000000..000c6e3
--- /dev/null
+++ b/app/resources/routes/api/queue.php
@@ -0,0 +1,6 @@
+<?php
+use Incoviba\Controller\API\Queues;
+
+$app->group('/queue', function($app) {
+    $app->get('/run[/]', Queues::class);
+});
diff --git a/app/src/Controller/API/Queues.php b/app/src/Controller/API/Queues.php
new file mode 100644
index 0000000..02183e1
--- /dev/null
+++ b/app/src/Controller/API/Queues.php
@@ -0,0 +1,23 @@
+<?php
+namespace Incoviba\Controller\API;
+
+use Psr\Http\Message\ServerRequestInterface;
+use Psr\Http\Message\ResponseInterface;
+use Incoviba\Common\Ideal;
+use Incoviba\Service;
+
+class Queues extends Ideal\Controller
+{
+    use withJson;
+
+    public function __invoke(ServerRequestInterface $request, ResponseInterface $response, Service\Queue $queueService): ResponseInterface
+    {
+        $output = [
+            'success' => false
+        ];
+        if ($queueService->run()) {
+            $output['success'] = true;
+        }
+        return $this->withJson($response, $output);
+    }
+}
diff --git a/app/src/Service/Worker/Dummy.php b/app/src/Service/Worker/Dummy.php
new file mode 100644
index 0000000..e5d82e7
--- /dev/null
+++ b/app/src/Service/Worker/Dummy.php
@@ -0,0 +1,17 @@
+<?php
+namespace Incoviba\Service\Worker;
+
+use Incoviba\Common\Ideal;
+use Incoviba\Model;
+use Incoviba\Service;
+
+class Dummy extends Ideal\Service implements Service\Worker
+{
+
+    public function execute(Model\Job $job): bool
+    {
+        $configuration = $job->configuration;
+        $this->logger->info('Dummy worker executed', ['configuration' => $configuration]);
+        return true;
+    }
+}