Add access to JobExecution in callback processor (#170)

Co-authored-by: sardin <[email protected]>

Author: yann-eugone

src/batch/src/Job/Item/Processor/CallbackProcessor.php

@@ -6,20 +6,24 @@
 
 use Closure;
 use Yokai\Batch\Job\Item\ItemProcessorInterface;
+use Yokai\Batch\Job\JobExecutionAwareInterface;
+use Yokai\Batch\Job\JobExecutionAwareTrait;
 
 /**
  * This {@see ItemProcessorInterface} will transform every item
  * with a closure provided at object's construction.
  */
-final class CallbackProcessor implements ItemProcessorInterface
+final class CallbackProcessor implements ItemProcessorInterface, JobExecutionAwareInterface
 {
+    use JobExecutionAwareTrait;
+
     public function __construct(
         private Closure $callback,
     ) {
     }
 
     public function process(mixed $item): mixed
     {
-        return ($this->callback)($item);
+        return ($this->callback)($item, $this->jobExecution);
     }
 }

src/batch/tests/Job/Item/Processor/CallbackProcessorTest.php

@@ -6,14 +6,16 @@
 
 use PHPUnit\Framework\TestCase;
 use Yokai\Batch\Job\Item\Processor\CallbackProcessor;
+use Yokai\Batch\JobExecution;
 
 class CallbackProcessorTest extends TestCase
 {
     public function testProcess(): void
     {
-        $processor = new CallbackProcessor(fn($item) => \mb_strtolower($item));
-
-        self::assertSame('john', $processor->process('John'));
-        self::assertSame('doe', $processor->process('DOE'));
+        $processor = new CallbackProcessor(fn($item, JobExecution $jobExecution)
+            => \mb_strtolower($item . '-' . $jobExecution->getJobName()));
+        $processor->setJobExecution(JobExecution::createRoot(id: '123', jobName: 'test'));
+        self::assertSame('john-test', $processor->process('John'));
+        self::assertSame('doe-test', $processor->process('DOE'));
     }
 }