brainexe / core

src/MessageQueue/Gateway.php

Doc Comments +1 added lines, -1 removed lines

@@ -105,7 +105,7 @@
     /**
      * @param string $eventType
      * @param int $since
-     * @return Generator|Job[]
+     * @return Generator
      */
     public function getEventsByTypeGenerator(string $eventType = null, int $since = 0) : Generator
     {

Spacing +4 added lines, -4 removed lines

@@ -59,7 +59,7 @@ 
      */
     public function addEvent(AbstractEvent $event, int $timestamp = 0) : Job
     {
-        $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);
@@ -80,7 +80,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);
@@ -120,7 +120,7 @@ 
 
         $keys = [];
         foreach ($resultRaw as $jobId => $timestamp) {
-            if (empty($eventType) || strpos($jobId, $eventType . ':') === 0) {
+            if (empty($eventType) || strpos($jobId, $eventType.':') === 0) {
                 $keys[$jobId] = $timestamp;
             }
         }
@@ -177,7 +177,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;

src/EventDispatcher/JobEvent.php

Spacing +1 added lines, -1 removed lines

@@ -27,7 +27,7 @@
     public function __construct(string $type, Job $job)
     {
         parent::__construct($type);
-        $this->job  = $job;
+        $this->job = $job;
     }
 
     /**

scripts/bootstrap.php

Spacing +2 added lines, -2 removed lines

@@ -2,8 +2,8 @@
 
 use BrainExe\Core\Core;
 
-require_once __DIR__ . '/../vendor/autoload.php';
+require_once __DIR__.'/../vendor/autoload.php';
 
-define('ROOT', realpath(__DIR__ . '/..') . '/');
+define('ROOT', realpath(__DIR__.'/..').'/');
 
 return (new Core())->boot();

src/Core.php

Spacing +1 added lines, -1 removed lines

@@ -16,7 +16,7 @@
      */
     public function boot() : Container
     {
-        $fileName = ROOT . 'cache/dic.php';
+        $fileName = ROOT.'cache/dic.php';
         /** @var Container $dic */
         if (!is_file($fileName)) {
             $rebuild = new Rebuild();

src/AnnotationLoader.php

Spacing +1 added lines, -1 removed lines

@@ -42,7 +42,7 @@
         $this->builders  = $builders;
         $this->reader    = new IndexedReader(new AnnotationReader());
 
-        AnnotationRegistry::registerLoader(function ($class) {
+        AnnotationRegistry::registerLoader(function($class) {
             return class_exists($class);
         });
     }

src/DependencyInjection/CompilerPass/ConfigCompilerPass.php

Spacing +1 added lines, -1 removed lines

@@ -23,7 +23,7 @@
     {
         $locator = new FileLocator([
             ROOT,
-            ROOT . 'app/',
+            ROOT.'app/',
         ]);
 
         $xmlLoader = new XmlFileLoader($container, $locator);

src/Console/ClearCacheCommand.php

Spacing +2 added lines, -2 removed lines

@@ -59,8 +59,8 @@
         $event = new ClearCacheEvent();
         $this->dispatcher->dispatchEvent($event);
 
-        @mkdir(ROOT . 'logs', 0744);
-        @mkdir(ROOT . 'cache', 0744);
+        @mkdir(ROOT.'logs', 0744);
+        @mkdir(ROOT.'cache', 0744);
 
         $output->writeln('<info>done</info>');
     }

src/Application/AppKernel.php

Spacing +1 added lines, -1 removed lines

@@ -143,7 +143,7 @@
      * @param Throwable $exception
      * @return Response|null
      */
-    protected function applyExceptionMiddleware(Request $request, Throwable $exception) : ?Response
+    protected function applyExceptionMiddleware(Request $request, Throwable $exception) : ? Response
     {
         foreach ($this->middlewares as $middleware) {
             $response = $middleware->processException($request, $exception);

src/Application/RedisLock.php

Spacing +2 added lines, -2 removed lines

@@ -24,7 +24,7 @@ 
     {
         $redis = $this->getRedis();
 
-        return (bool)$redis->set(self::PREFIX . $name, '1', 'EX', $lockTime, 'NX');
+        return (bool)$redis->set(self::PREFIX.$name, '1', 'EX', $lockTime, 'NX');
     }
 
     /**
@@ -32,6 +32,6 @@ 
      */
     public function unlock(string $name)
     {
-        $this->getRedis()->del(self::PREFIX . $name);
+        $this->getRedis()->del(self::PREFIX.$name);
     }
 }