Pint

Author: marickvantuil

src/CloudTasksQueue.php

@@ -24,13 +24,14 @@
 class CloudTasksQueue extends LaravelQueue implements QueueContract
 {
     private static ?Closure $handlerUrlCallback = null;
+
     private static ?Closure $taskHeadersCallback = null;
 
     public function __construct(public array $config, public CloudTasksClient $client, public $dispatchAfterCommit = false)
     {
         //
     }
-    
+
     public static function configureHandlerUrlUsing(Closure $callback): void
     {
         static::$handlerUrlCallback = $callback;
@@ -126,7 +127,7 @@ function ($payload, $queue, $delay) use ($job) {
      * @param  string|null  $queue
      * @param  string  $payload
      * @param  \DateTimeInterface|\DateInterval|int  $delay
-     * @param  string|object $job
+     * @param  string|object  $job
      * @return string
      */
     protected function pushToCloudTasks($queue, $payload, $delay, mixed $job)
@@ -257,12 +258,12 @@ public function getHandler(mixed $job): string
     }
 
     /**
-     * @param array<string, mixed> $payload 
-     * @return array<string, mixed> 
+     * @param  array<string, mixed>  $payload
+     * @return array<string, mixed>
      */
     private function headers(mixed $payload): array
     {
-        if (!static::$taskHeadersCallback) {
+        if (! static::$taskHeadersCallback) {
             return [];
         }
 

src/CloudTasksServiceProvider.php

@@ -9,8 +9,6 @@
 use Illuminate\Foundation\Application;
 use Illuminate\Queue\Events\JobExceptionOccurred;
 use Illuminate\Queue\Events\JobFailed;
-use Illuminate\Queue\Events\JobProcessed;
-use Illuminate\Queue\Events\JobProcessing;
 use Illuminate\Support\ServiceProvider as LaravelServiceProvider;
 use Stackkit\LaravelGoogleCloudTasksQueue\Events\JobReleased;
 

tests/QueueTest.php

@@ -92,7 +92,7 @@ public function it_posts_to_the_callback_handler_url()
         // Arrange
         $this->setConfigValue('handler', 'https://docker.for.mac.localhost:8081');
         CloudTasksApi::fake();
-        CloudTasksQueue::configureHandlerUrlUsing(static fn(SimpleJob $job) => 'https://example.com/api/my-custom-route?job=' . $job->id);
+        CloudTasksQueue::configureHandlerUrlUsing(static fn (SimpleJob $job) => 'https://example.com/api/my-custom-route?job='.$job->id);
 
         // Act
         $job = new SimpleJob();
@@ -226,7 +226,6 @@ public function jobs_can_be_released()
             ->runAndGetReleasedJob()
             ->run();
 
-
         // Assert
         CloudTasksApi::assertTaskCreated(function (Task $task) {
             $body = $task->getHttpRequest()->getBody();
@@ -465,7 +464,7 @@ public function headers_can_be_added_to_the_task()
         CloudTasksApi::fake();
 
         // Act
-        CloudTasksQueue::setTaskHeadersUsing(static fn() => [
+        CloudTasksQueue::setTaskHeadersUsing(static fn () => [
             'X-MyHeader' => 'MyValue',
         ]);
 
@@ -484,7 +483,7 @@ public function headers_can_be_added_to_the_task_with_job_context()
         CloudTasksApi::fake();
 
         // Act
-        CloudTasksQueue::setTaskHeadersUsing(static fn(array $payload) => [
+        CloudTasksQueue::setTaskHeadersUsing(static fn (array $payload) => [
             'X-MyHeader' => $payload['displayName'],
         ]);
 

tests/Support/SimpleJob.php

@@ -15,6 +15,7 @@ class SimpleJob implements ShouldQueue
     use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
 
     public $tries = 3;
+
     public $id = 0;
 
     /**