@@ -65,7 +65,7 @@ |
||
65 | 65 | $host = parse_url($url, PHP_URL_HOST) ?: $request->getHost(); |
66 | 66 | |
67 | 67 | if ($port) { |
68 | - $host .= ':' . $port; |
|
68 | + $host .= ':'.$port; |
|
69 | 69 | } |
70 | 70 | $allowed[] = $host; |
71 | 71 | } |
@@ -35,7 +35,7 @@ |
||
35 | 35 | foreach ($logLevels as $file => $level) { |
36 | 36 | $definition->addMethodCall('pushHandler', [ |
37 | 37 | new Definition(StreamHandler::class, [ |
38 | - $baseDir . $file, |
|
38 | + $baseDir.$file, |
|
39 | 39 | $level |
40 | 40 | ]) |
41 | 41 | ]); |
@@ -54,7 +54,7 @@ |
||
54 | 54 | |
55 | 55 | /** |
56 | 56 | * @param int $userId |
57 | - * @return array[]|Generator |
|
57 | + * @return Generator |
|
58 | 58 | */ |
59 | 59 | public function getTokensForUser(int $userId) |
60 | 60 | { |
@@ -105,7 +105,7 @@ |
||
105 | 105 | /** |
106 | 106 | * @param string $eventType |
107 | 107 | * @param int $since |
108 | - * @return Generator|Job[] |
|
108 | + * @return Generator |
|
109 | 109 | */ |
110 | 110 | public function getEventsByTypeGenerator(string $eventType = null, int $since = 0) : Generator |
111 | 111 | { |
@@ -59,7 +59,7 @@ discard block |
||
59 | 59 | */ |
60 | 60 | public function addEvent(AbstractEvent $event, int $timestamp = 0) : Job |
61 | 61 | { |
62 | - $jobId = $this->generateUniqueId('jobid:' . $event->getEventName()); |
|
62 | + $jobId = $this->generateUniqueId('jobid:'.$event->getEventName()); |
|
63 | 63 | $jobId = sprintf('%s:%s', $event->getEventName(), $jobId); |
64 | 64 | |
65 | 65 | $job = new Job($event, $jobId, $timestamp); |
@@ -80,7 +80,7 @@ discard block |
||
80 | 80 | $pipeline = $this->getRedis()->pipeline(['fire-and-forget' => true]); |
81 | 81 | if (empty($job->timestamp)) { |
82 | 82 | // immediate execution in background |
83 | - $pipeline->lpush(self::QUEUE_IMMEDIATE, $job->jobId . '#' . $serialized); |
|
83 | + $pipeline->lpush(self::QUEUE_IMMEDIATE, $job->jobId.'#'.$serialized); |
|
84 | 84 | } else { |
85 | 85 | // delayed execution |
86 | 86 | $pipeline->hset(self::META_DATA, $job->jobId, $serialized); |
@@ -120,7 +120,7 @@ discard block |
||
120 | 120 | |
121 | 121 | $keys = []; |
122 | 122 | foreach ($resultRaw as $jobId => $timestamp) { |
123 | - if (empty($eventType) || strpos($jobId, $eventType . ":") === 0) { |
|
123 | + if (empty($eventType) || strpos($jobId, $eventType.":") === 0) { |
|
124 | 124 | $keys[$jobId] = $timestamp; |
125 | 125 | } |
126 | 126 | } |
@@ -177,7 +177,7 @@ discard block |
||
177 | 177 | $immediate = $this->getRedis()->lrange(self::QUEUE_IMMEDIATE, 0, 100); |
178 | 178 | foreach ($immediate as $rawJob) { |
179 | 179 | list($jobId, $rawJob) = explode('#', $rawJob, 2); |
180 | - if (empty($eventType) || strpos($jobId, $eventType . ":") === 0) { |
|
180 | + if (empty($eventType) || strpos($jobId, $eventType.":") === 0) { |
|
181 | 181 | /** @var Job $job */ |
182 | 182 | $job = unserialize(base64_decode($rawJob)); |
183 | 183 | yield $job->jobId => $job; |
@@ -27,7 +27,7 @@ |
||
27 | 27 | public function __construct(string $type, Job $job) |
28 | 28 | { |
29 | 29 | parent::__construct($type); |
30 | - $this->job = $job; |
|
30 | + $this->job = $job; |
|
31 | 31 | } |
32 | 32 | |
33 | 33 | /** |
@@ -33,7 +33,7 @@ |
||
33 | 33 | */ |
34 | 34 | public function generateRandomId(int$length = self::ID_LENGTH) : string |
35 | 35 | { |
36 | - $randomId = md5(microtime() . mt_rand()) . mt_rand(); |
|
36 | + $randomId = md5(microtime().mt_rand()).mt_rand(); |
|
37 | 37 | |
38 | 38 | return substr(base_convert($randomId, 10, 36), 0, $length); |
39 | 39 | } |
@@ -127,6 +127,6 @@ |
||
127 | 127 | */ |
128 | 128 | private function generateCacheKey(Request $request) : string |
129 | 129 | { |
130 | - return self::PREFIX . $request->getRequestUri(); |
|
130 | + return self::PREFIX.$request->getRequestUri(); |
|
131 | 131 | } |
132 | 132 | } |
@@ -2,8 +2,8 @@ |
||
2 | 2 | |
3 | 3 | use BrainExe\Core\Core; |
4 | 4 | |
5 | -require_once __DIR__ . '/../vendor/autoload.php'; |
|
5 | +require_once __DIR__.'/../vendor/autoload.php'; |
|
6 | 6 | |
7 | -define('ROOT', realpath(__DIR__ . '/..') . '/'); |
|
7 | +define('ROOT', realpath(__DIR__.'/..').'/'); |
|
8 | 8 | |
9 | 9 | return (new Core())->boot(); |
@@ -5,7 +5,7 @@ |
||
5 | 5 | use Symfony\Component\HttpFoundation\Request; |
6 | 6 | |
7 | 7 | /** @var Container $dic */ |
8 | -$dic = include __DIR__ . '/../src/bootstrap.php'; |
|
8 | +$dic = include __DIR__.'/../src/bootstrap.php'; |
|
9 | 9 | |
10 | 10 | $request = Request::createFromGlobals(); |
11 | 11 |