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;
     }
 
     /**

src/Middleware/Cache.php

Spacing +1 added lines, -1 removed lines

@@ -127,6 +127,6 @@
      */
     private function generateCacheKey(Request $request) : string
     {
-        return self::PREFIX . $request->getRequestUri();
+        return self::PREFIX.$request->getRequestUri();
     }
 }

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();

scripts/index.php

Spacing +1 added lines, -1 removed lines

@@ -5,7 +5,7 @@
 use Symfony\Component\HttpFoundation\Request;
 
 /** @var Container $dic */
-$dic = include __DIR__ . '/../src/bootstrap.php';
+$dic = include __DIR__.'/../src/bootstrap.php';
 
 $request = Request::createFromGlobals();
 

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/Middleware/CatchUserException.php

Doc Comments +1 added lines, -1 removed lines

@@ -80,7 +80,7 @@
     }
 
     /**
-     * @param Throwable $exception
+     * @param UserException $exception
      * @param Request $request
      * @param Response $response
      */