Add headers to SyncDriver (#1107)

src/Queue/src/Driver/SyncDriver.php

@@ -5,6 +5,7 @@
 namespace Spiral\Queue\Driver;
 
 use Ramsey\Uuid\Uuid;
+use Spiral\Queue\ExtendedOptionsInterface;
 use Spiral\Queue\Interceptor\Consume\Handler;
 use Spiral\Queue\OptionsInterface;
 use Spiral\Queue\QueueInterface;
@@ -36,7 +37,8 @@ public function push(string $name, mixed $payload = [], OptionsInterface $option
             driver: 'sync',
             queue: 'default',
             id: $id,
-            payload: $payload
+            payload: $payload,
+            headers: $options instanceof ExtendedOptionsInterface ? $options->getHeaders() : [],
         );
 
         return $id;

src/Queue/tests/Driver/SyncDriverTest.php

@@ -13,6 +13,7 @@
 use Spiral\Core\CoreInterface;
 use Spiral\Queue\Driver\SyncDriver;
 use Spiral\Queue\Interceptor\Consume\Handler;
+use Spiral\Queue\Options;
 use Spiral\Telemetry\NullTracer;
 use Spiral\Telemetry\NullTracerFactory;
 use Spiral\Telemetry\TracerInterface;
@@ -64,6 +65,28 @@ public function testJobShouldBePushed(mixed $payload): void
         $this->assertSame($uuid->toString(), $id);
     }
 
+    public function testJobWithHeadersShouldBePushed(): void
+    {
+        $this->factory->shouldReceive('uuid4')
+            ->andReturn($uuid = (new UuidFactory())->uuid4());
+
+        $options = (new Options())->withHeader('foo', 'bar');
+
+        $this->core->shouldReceive('callAction')
+            ->withSomeOfArgs('foo', [
+                'driver' => 'sync',
+                'queue' => 'default',
+                'id' => $uuid->toString(),
+                'payload' => ['baz' => 'baf'],
+                'headers' => ['foo' => ['bar']]
+            ])
+            ->once();
+
+        $id = $this->queue->push('foo', ['baz' => 'baf'], $options);
+
+        $this->assertSame($uuid->toString(), $id);
+    }
+
     public static function payloadDataProvider(): \Traversable
     {
         yield [['baz' => 'baf']];