brainexe / core

src/Middleware/Authentication.php

Spacing +1 added lines, -1 removed lines

@@ -33,7 +33,7 @@
      */
     public function __construct(LoadUser $loadUser)
     {
-        $this->loadUser      = $loadUser;
+        $this->loadUser = $loadUser;
     }
 
     /**

src/DependencyInjection/Rebuild.php

Spacing +5 added lines, -5 removed lines

@@ -52,11 +52,11 @@ 
 
         $appFinder = new Finder();
         $appFinder->directories()
-            ->in([ROOT . 'vendor/brainexe/'])
+            ->in([ROOT.'vendor/brainexe/'])
             ->depth("<=1")
             ->name('src');
 
-        $annotationLoader->load(ROOT . 'src');
+        $annotationLoader->load(ROOT.'src');
 
         foreach ($appFinder as $dir) {
             /** @var SplFileInfo $dir */
@@ -72,9 +72,9 @@ 
         $debug         = $container->getParameter('debug');
         $randomId      = mt_rand();
         $className     = sprintf('dic_%d', $randomId);
-        $containerFile = ROOT . 'cache/dic.php';
-        $versionFile   = ROOT . 'cache/dic.txt';
-        $configFile    = ROOT . 'cache/config.json';
+        $containerFile = ROOT.'cache/dic.php';
+        $versionFile   = ROOT.'cache/dic.txt';
+        $configFile    = ROOT.'cache/config.json';
 
         $dumper = new PhpDumper($container);
         $dumper->setProxyDumper(new ProxyDumper());

src/MessageQueue/Gateway.php

Spacing +4 added lines, -4 removed lines

@@ -61,7 +61,7 @@ 
      */
     public function addEvent(AbstractEvent $event, int $timestamp = 0)
     {
-        $jobId = $this->generateUniqueId('jobid:' . $event->getEventName());
+        $jobId = $this->generateUniqueId('jobid:'.$event->getEventName());
         $jobId = sprintf('%s:%s', $event->getEventName(), $jobId);
 
         $job = new Job($event, $jobId, $timestamp);
@@ -79,7 +79,7 @@ 
         $pipeline = $this->getRedis()->pipeline(['fire-and-forget' => true]);
         if (empty($job->timestamp)) {
             // immediate execution in background
-            $pipeline->lpush(self::QUEUE_IMMEDIATE, $job->jobId . '#' . $serialized);
+            $pipeline->lpush(self::QUEUE_IMMEDIATE, $job->jobId.'#'.$serialized);
         } else {
             // delayed execution
             $pipeline->hset(self::META_DATA, $job->jobId, $serialized);
@@ -119,7 +119,7 @@ 
 
         $keys = [];
         foreach ($resultRaw as $jobId => $timestamp) {
-            if (empty($eventType) || strpos($jobId, $eventType . ":") === 0) {
+            if (empty($eventType) || strpos($jobId, $eventType.":") === 0) {
                 $keys[$jobId] = $timestamp;
             }
         }
@@ -176,7 +176,7 @@ 
         $immediate = $this->getRedis()->lrange(self::QUEUE_IMMEDIATE, 0, 100);
         foreach ($immediate as $rawJob) {
             list($jobId, $rawJob) = explode('#', $rawJob, 2);
-            if (empty($eventType) || strpos($jobId, $eventType . ":") === 0) {
+            if (empty($eventType) || strpos($jobId, $eventType.":") === 0) {
                 /** @var Job $job */
                 $job = unserialize(base64_decode($rawJob));
                 yield $job->jobId => $job;