cross-solution / YAWIK

module/Jobs/src/Queue/FindJobsWithExternalImageJob.php

Spacing +3 added lines, -3 removed lines

@@ -75,8 +75,8 @@ 
         foreach ($cursor->toArray() as $job) {
             if (0 === strpos($job->getLogoRef(), 'http')) {
                 $queue->push(FetchExternalImageJob::create($job));
-                $logger->debug('Found external image uri: ' . $job->getLogoRef());
-                $logger->info('Pushed fetch image job for Job: '  . $job->getId());
+                $logger->debug('Found external image uri: '.$job->getLogoRef());
+                $logger->info('Pushed fetch image job for Job: '.$job->getId());
             } else {
                 $invalidJobs += 1;
             }
@@ -84,7 +84,7 @@ 
 
         $delay = 0 >= ($cursor->count() - $invalidJobs) ? '+2 hours' : '+5 minutes';
         $queue->push(self::create(), ['delay' => $delay]);
-        $logger->info('Reinserted to fetch more jobs with delay: ' . $delay);
+        $logger->info('Reinserted to fetch more jobs with delay: '.$delay);
     }
 
 }

module/Jobs/src/Queue/FetchExternalImageJob.php

Spacing +9 added lines, -9 removed lines

@@ -63,34 +63,34 @@ 
         $jobEntity = $this->repository->find($payload['jobId']);
 
         if (!$jobEntity) {
-            $logger->err('No job entity with the id ' . $payload['jobId'] . ' was found.');
+            $logger->err('No job entity with the id '.$payload['jobId'].' was found.');
 
-            throw new FatalJobException('No job entity with the id ' . $payload['jobId'] . ' was found.');
+            throw new FatalJobException('No job entity with the id '.$payload['jobId'].' was found.');
         }
 
         $uri = $jobEntity->getLogoRef();
 
         if (0 !== strpos($uri, 'http')) {
-            $logger->notice('logoRef seems not to be external: ' . $uri);
+            $logger->notice('logoRef seems not to be external: '.$uri);
             $logger->info('Skip fetching for this job.');
             return;
         }
 
-        $logger->debug('Trying to fetch image from ' . $uri);
+        $logger->debug('Trying to fetch image from '.$uri);
 
         $client = new Client($uri);
         $response = $client->send();
 
         if (200 != $response->getStatusCode()) {
-            $logger->err('Received status code ' . $response->getStatusCode() . ' when trying to fetch ' . $uri);
+            $logger->err('Received status code '.$response->getStatusCode().' when trying to fetch '.$uri);
 
-            throw new RecoverableJobException('Status code ' . $response->getStatusCode() . ' received.', ['delay' => '+5 minutes']);
+            throw new RecoverableJobException('Status code '.$response->getStatusCode().' received.', ['delay' => '+5 minutes']);
         }
 
         $content = $response->getBody();
         $type = $response->getHeaders()->get('Content-Type')->getFieldValue();
         list(,$ext) = explode('/', $type, 2);
-        $imageName = '/static/Jobs/logos/' . $jobEntity->getId() . '.' . $ext;
+        $imageName = '/static/Jobs/logos/'.$jobEntity->getId().'.'.$ext;
 
         if (false === file_put_contents("public$imageName", $content, FILE_BINARY)) {
             $logger->err('Writing image failed.');
@@ -98,10 +98,10 @@ 
             throw new FatalJobException('Writing image failed.');
         }
 
-        $logger->info('Saved job logo as ' . basename($imageName));
+        $logger->info('Saved job logo as '.basename($imageName));
         $jobEntity->setLogoRef($imageName);
         $this->repository->store($jobEntity);
-        $logger->info('Saved job logo as ' . basename($imageName));
+        $logger->info('Saved job logo as '.basename($imageName));
 
     }
 }