Recreate task ulid when redispatching

Author: apfelbox

CHANGELOG.md

@@ -1,3 +1,11 @@
+3.2.0
+=====
+
+* (feature) Add `TaskScheduler`.
+* (improvement) Update task ULID when redispatching in the scheduler.
+* (improvement) Require PHP 8.5+
+
+
 3.1.1
 =====
 

composer.json

@@ -11,7 +11,7 @@
 	],
 	"homepage": "https://github.com/21TORR/TaskManagerBundle",
 	"require": {
-		"php": ">= 8.4",
+		"php": ">= 8.5",
 		"21torr/bundle-helpers": "^2.3.1",
 		"21torr/cli": "^1.2.3",
 		"21torr/hosting": "^4.1.1",

src/Listener/MessengerEventListener.php

@@ -10,6 +10,7 @@
 use Torr\TaskManager\Entity\TaskLog;
 use Torr\TaskManager\Model\TaskLogModel;
 use Torr\TaskManager\Normalizer\TaskDetailsNormalizer;
+use Torr\TaskManager\Task\DispatchAfterRunTask\DispatchAfterRunTask;
 use Torr\TaskManager\Task\Task;
 
 /**
@@ -25,16 +26,17 @@ public function __construct (
 	/**
 	 *
 	 */
-	#[AsEventListener(SendMessageToTransportsEvent::class)]
+	#[AsEventListener]
 	public function onSendMessageToTransports (SendMessageToTransportsEvent $event) : void
 	{
-		$taskLog = $this->getLogForEvent($event->getEnvelope());
+		$envelope = $event->getEnvelope();
+		$taskLog = $this->getLogForEvent($envelope);
 
 		// make sure that the log entry is created and flushed
 		if (null !== $taskLog)
 		{
 			// update envelope with current version
-			$taskLog->setTaskDetails($this->detailsNormalizer->normalizeTaskDetails($event->getEnvelope()));
+			$taskLog->setTaskDetails($this->detailsNormalizer->normalizeTaskDetails($envelope));
 
 			$this->logModel->flush();
 		}
@@ -43,18 +45,19 @@ public function onSendMessageToTransports (SendMessageToTransportsEvent $event)
 	/**
 	 * Automatically integrate
 	 */
-	#[AsEventListener(WorkerMessageHandledEvent::class)]
+	#[AsEventListener]
 	public function onWorkerMessageHandled (WorkerMessageHandledEvent $event) : void
 	{
-		$taskLog = $this->getLogForEvent($event->getEnvelope());
+		$envelope = $event->getEnvelope();
+		$taskLog = $this->getLogForEvent($envelope);
 
 		if (null === $taskLog)
 		{
 			return;
 		}
 
 		// update envelope with current version
-		$taskLog->setTaskDetails($this->detailsNormalizer->normalizeTaskDetails($event->getEnvelope()));
+		$taskLog->setTaskDetails($this->detailsNormalizer->normalizeTaskDetails($envelope));
 
 		// abort run as success. It wasn't marked as finished manually, but it succeeded nonetheless.
 		$run = $taskLog->getLastUnfinishedRun();
@@ -63,18 +66,19 @@ public function onWorkerMessageHandled (WorkerMessageHandledEvent $event) : void
 		$this->logModel->flush();
 	}
 
-	#[AsEventListener(WorkerMessageFailedEvent::class)]
+	#[AsEventListener]
 	public function onWorkerMessageFailed (WorkerMessageFailedEvent $event) : void
 	{
-		$taskLog = $this->getLogForEvent($event->getEnvelope());
+		$envelope = $event->getEnvelope();
+		$taskLog = $this->getLogForEvent($envelope);
 
 		if (null === $taskLog)
 		{
 			return;
 		}
 
 		// update envelope with current version
-		$taskLog->setTaskDetails($this->detailsNormalizer->normalizeTaskDetails($event->getEnvelope()));
+		$taskLog->setTaskDetails($this->detailsNormalizer->normalizeTaskDetails($envelope));
 
 		// abort run as failure. It wasn't marked as finished manually and it failed.
 		$run = $taskLog->getLastUnfinishedRun();
@@ -90,7 +94,7 @@ private function getLogForEvent (Envelope $envelope) : ?TaskLog
 	{
 		$message = $envelope->getMessage();
 
-		return $message instanceof Task
+		return $message instanceof Task && !$message instanceof DispatchAfterRunTask
 			? $this->logModel->getLogForTask($message)
 			: null;
 	}

src/Schedule/WrappedSchedule.php

@@ -81,7 +81,6 @@ public function every (
 	#[\Override]
 	public function getSchedule () : Schedule
 	{
-		dump("get internal schedule");
 		return $this->schedule->getSchedule();
 	}
 }

src/Task/DispatchAfterRunTask/DispatchAfterRunTaskHandler.php

@@ -2,9 +2,12 @@
 
 namespace Torr\TaskManager\Task\DispatchAfterRunTask;
 
+use Symfony\Component\Console\Input\ArrayInput;
+use Symfony\Component\Console\Output\ConsoleOutput;
+use Symfony\Component\Console\Output\OutputInterface;
 use Symfony\Component\Messenger\Attribute\AsMessageHandler;
 use Symfony\Component\Messenger\Stamp\TransportNamesStamp;
-use Torr\TaskManager\Director\TaskDirector;
+use Torr\Cli\Console\Style\TorrStyle;
 use Torr\TaskManager\Manager\TaskManager;
 
 /**
@@ -16,7 +19,6 @@
 	 */
 	public function __construct (
 		private TaskManager $taskManager,
-		private TaskDirector $taskDirector,
 	) {}
 
 	/**
@@ -25,9 +27,13 @@ public function __construct (
 	#[AsMessageHandler]
 	public function onDispatchAfterRunTask (DispatchAfterRunTask $task) : void
 	{
-		$run = $this->taskDirector->startRun($task);
+		// DispatchAfterRun message should not use the task director, as we can't recreate the task ulid.
+		$io = new TorrStyle(
+			new ArrayInput([]),
+			new ConsoleOutput(OutputInterface::VERBOSITY_NORMAL, true),
+		);
 
-		$run->io->writeln(\sprintf(
+		$io->writeln(\sprintf(
 			"Redispatching task <fg=yellow>%s</>",
 			$task->task::class,
 		));
@@ -36,7 +42,7 @@ public function onDispatchAfterRunTask (DispatchAfterRunTask $task) : void
 			? [new TransportNamesStamp($task->transportNames)]
 			: [];
 
-		$this->taskManager->enqueue($task->task, $stamps);
-		$run->finish(success: true);
+		$wrappedTask = $task->task->withNewTaskUlid();
+		$this->taskManager->enqueue($wrappedTask, $stamps);
 	}
 }

src/Task/Task.php

@@ -15,7 +15,7 @@
 	 */
 	public function __construct ()
 	{
-		$this->ulid = (new Ulid())->toBase58();
+		$this->ulid = new Ulid()->toBase58();
 	}
 
 	/**
@@ -31,14 +31,8 @@ abstract public function getMetaData () : TaskMetaData;
 	 */
 	public function withNewTaskUlid () : static
 	{
-		if (\function_exists("clone") && \PHP_VERSION_ID >= 80500)
-		{
-			return clone($this, [
-				"ulid" => (new Ulid())->toBase58()
-			]);
-		}
-
-		// @todo remove fallback + if above, when PHP 8.5 is required
-		return $this;
+		return clone($this, [
+			"ulid" => new Ulid()->toBase58(),
+		]);
 	}
 }

tests/Task/TaskTest.php

@@ -0,0 +1,35 @@
+<?php declare(strict_types=1);
+
+namespace Tests\Torr\TaskManager\Task;
+
+use PHPUnit\Framework\TestCase;
+use Torr\TaskManager\Task\Task;
+use Torr\TaskManager\Task\TaskMetaData;
+
+/**
+ * @internal
+ */
+final class TaskTest extends TestCase
+{
+	/**
+	 *
+	 */
+	public function testNewTaskUlid () : void
+	{
+		// @phpstan-ignore-next-line 21torr.custom.task.suffix
+		$task = new readonly class() extends Task {
+			/**
+			 *
+			 */
+			#[\Override]
+			public function getMetaData () : TaskMetaData
+			{
+				return new TaskMetaData("Test");
+			}
+		};
+
+		$initialUlid = $task->ulid;
+		$newTask = $task->withNewTaskUlid();
+		self::assertNotSame($initialUlid, $newTask->ulid, "Task ULID should change on PHP 8.4");
+	}
+}