From 860ae5cedfda6aa67511555d06362b0f502e2afb Mon Sep 17 00:00:00 2001
From: Julie Lenaerts <julielenaerts@gmail.com>
Date: Thu, 8 Aug 2024 17:00:27 +0200
Subject: [PATCH] Create CancelStaleWorkflow message and handler

---
 .../Service/Workflow/CancelStaleWorkflow.php  | 15 ++++++++++
 .../Workflow/CancelStaleWorkflowHandler.php   | 30 +++++++++++++++++++
 2 files changed, 45 insertions(+)
 create mode 100644 src/Bundle/ChillMainBundle/Service/Workflow/CancelStaleWorkflow.php
 create mode 100644 src/Bundle/ChillMainBundle/Service/Workflow/CancelStaleWorkflowHandler.php

diff --git a/src/Bundle/ChillMainBundle/Service/Workflow/CancelStaleWorkflow.php b/src/Bundle/ChillMainBundle/Service/Workflow/CancelStaleWorkflow.php
new file mode 100644
index 000000000..d13ca039e
--- /dev/null
+++ b/src/Bundle/ChillMainBundle/Service/Workflow/CancelStaleWorkflow.php
@@ -0,0 +1,15 @@
+<?php
+
+namespace Chill\MainBundle\Service\Workflow;
+
+class CancelStaleWorkflow
+{
+    public function __construct(public array $workflowIds)
+    {
+    }
+
+    public function getWorkflowIds(): array
+    {
+        return $this->workflowIds;
+    }
+}
diff --git a/src/Bundle/ChillMainBundle/Service/Workflow/CancelStaleWorkflowHandler.php b/src/Bundle/ChillMainBundle/Service/Workflow/CancelStaleWorkflowHandler.php
new file mode 100644
index 000000000..aff22d1e3
--- /dev/null
+++ b/src/Bundle/ChillMainBundle/Service/Workflow/CancelStaleWorkflowHandler.php
@@ -0,0 +1,30 @@
+<?php
+
+namespace Chill\MainBundle\Service\Workflow;
+
+use Chill\MainBundle\Repository\Workflow\EntityWorkflowRepository;
+use Doctrine\ORM\EntityManagerInterface;
+use Psr\Log\LoggerInterface;
+use Symfony\Component\Messenger\Handler\MessageHandlerInterface;
+
+class CancelStaleWorkflowHandler implements MessageHandlerInterface
+{
+    public function __construct(private readonly EntityWorkflowRepository $workflowRepository, private EntityManagerInterface $em, private LoggerInterface $logger)
+    {
+
+    }
+
+    public function __invoke(CancelStaleWorkflow $message): void
+    {
+        $workflowIds = $message->getWorkflowIds();
+
+        foreach ($workflowIds as $workflowId) {
+            $workflow = $this->workflowRepository->find($workflowId);
+
+            $steps = $workflow->getSteps();
+
+
+        }
+    }
+
+}