umbrellio / laravel-heavy-jobs

src/HeavyJobsServiceProvider.php

Spacing +5 added lines, -5 removed lines

@@ -34,15 +34,15 @@ 
 
         $this->app->singleton(StoreResolver::class);
 
-        $this->app->singleton('heavy-jobs-store', function (Application $app) {
+        $this->app->singleton('heavy-jobs-store', function(Application $app) {
             return $app->make(PayloadStoreManager::class);
         });
 
-        $this->app->extend(QueueFactory::class, function (QueueManager $manager, Application $app) {
+        $this->app->extend(QueueFactory::class, function(QueueManager $manager, Application $app) {
             return new QueueManagerDecorator($manager, $app);
         });
 
-        $this->app->extend(FailedJobProviderInterface::class, function (FailedJobProviderInterface $provider) {
+        $this->app->extend(FailedJobProviderInterface::class, function(FailedJobProviderInterface $provider) {
             return new FailedJobProviderDecorator($provider);
         });
 
@@ -51,7 +51,7 @@ 
 
     private function registerPayloadCleaner(): void
     {
-        Queue::createPayloadUsing(function ($connection, $queue, $payload) {
+        Queue::createPayloadUsing(function($connection, $queue, $payload) {
             $job = Arr::get($payload, 'data.command');
             if ($job instanceof HeavyJob) {
                 return ['heavy-payload-id' => $job->getHeavyPayloadId()];
@@ -60,7 +60,7 @@ 
             return [];
         });
 
-        $this->app['events']->listen(JobProcessed::class, function (JobProcessed $event): void {
+        $this->app['events']->listen(JobProcessed::class, function(JobProcessed $event): void {
             if ($heavyPayloadId = Arr::get($event->job->payload(), 'heavy-payload-id')) {
                 HeavyJobsStore::remove($heavyPayloadId);
             }

src/Stores/RedisStore.php

Spacing +6 added lines, -6 removed lines

@@ -28,13 +28,13 @@ 
     {
         $score = $this->lifetime !== -1 ? Carbon::now()->getTimestamp() : 0;
 
-        [$payload, $ids] = $this->connection->pipeline(function ($pipe) use ($id, $score): void {
+        [$payload, $ids] = $this->connection->pipeline(function($pipe) use ($id, $score): void {
             $pipe->eval(LuaScripts::get(), [self::JOB_PAYLOADS_KEY, self::FAILED_JOB_PAYLOADS_KEY, $id], 2);
             $pipe->zrangebyscore(self::LIFETIME_FAILED_JOB_PAYLOADS_KEY, '-inf', (string) $score);
         });
 
         if (count($ids)) {
-            $this->connection->pipeline(function ($pipe) use ($ids, $score): void {
+            $this->connection->pipeline(function($pipe) use ($ids, $score): void {
                 $pipe->hdel(self::FAILED_JOB_PAYLOADS_KEY, ...$ids);
                 $pipe->zremrangebyscore(self::LIFETIME_FAILED_JOB_PAYLOADS_KEY, '-inf', (string) $score);
             });
@@ -50,7 +50,7 @@ 
 
     public function set(string $id, string $serializedData): bool
     {
-        [$set] = $this->connection->pipeline(function ($pipe) use ($id, $serializedData): void {
+        [$set] = $this->connection->pipeline(function($pipe) use ($id, $serializedData): void {
             $pipe->hset(self::JOB_PAYLOADS_KEY, $id, $serializedData);
             $pipe->zrem(self::LIFETIME_FAILED_JOB_PAYLOADS_KEY, $id);
         });
@@ -70,7 +70,7 @@ 
 
     public function removeFailed(string $id): bool
     {
-        [$deleted] = $this->connection->pipeline(function ($pipe) use ($id): void {
+        [$deleted] = $this->connection->pipeline(function($pipe) use ($id): void {
             $pipe->hdel(self::FAILED_JOB_PAYLOADS_KEY, $id);
             $pipe->zrem(self::LIFETIME_FAILED_JOB_PAYLOADS_KEY, $id);
         });
@@ -80,7 +80,7 @@ 
 
     public function markAsFailed(string $id): bool
     {
-        [$marked] = $this->connection->pipeline(function ($pipe) use ($id): void {
+        [$marked] = $this->connection->pipeline(function($pipe) use ($id): void {
             $pipe->eval(LuaScripts::markAsFailed(), [self::JOB_PAYLOADS_KEY, self::FAILED_JOB_PAYLOADS_KEY, $id], 2);
             $pipe->zadd(self::LIFETIME_FAILED_JOB_PAYLOADS_KEY, Carbon::now()->getTimestamp() + $this->lifetime, $id);
         });
@@ -90,7 +90,7 @@ 
 
     public function flushFailed(): bool
     {
-        $result = $this->connection->pipeline(function ($pipe): void {
+        $result = $this->connection->pipeline(function($pipe): void {
             $pipe->del(self::FAILED_JOB_PAYLOADS_KEY);
             $pipe->del(self::LIFETIME_FAILED_JOB_PAYLOADS_KEY);
         });

src/Decorators/QueueDecorator.php

Spacing +1 added lines, -1 removed lines

@@ -138,7 +138,7 @@
 
     private function prepareJobs($jobs): array
     {
-        return array_map(function ($job) {
+        return array_map(function($job) {
             return $this->prepareJob($job);
         }, $jobs);
     }