@@ -42,7 +42,7 @@ |
||
| 42 | 42 | */ |
| 43 | 43 | protected function setErrorHandler(): self |
| 44 | 44 | { |
| 45 | - set_error_handler(function ($severity, $message, $file, $line) { |
|
| 45 | + set_error_handler(function($severity, $message, $file, $line) { |
|
| 46 | 46 | $log = $message.' in '.$file.':'.$line; |
| 47 | 47 | |
| 48 | 48 | switch ($severity) { |
@@ -184,7 +184,7 @@ |
||
| 184 | 184 | */ |
| 185 | 185 | protected function setExceptionHandler(): self |
| 186 | 186 | { |
| 187 | - set_exception_handler(function ($e) { |
|
| 187 | + set_exception_handler(function($e) { |
|
| 188 | 188 | $this->logger->emergency('uncaught exception: '.$e->getMessage(), [ |
| 189 | 189 | 'category' => get_class($this), |
| 190 | 190 | 'exception' => $e, |
@@ -50,9 +50,9 @@ discard block |
||
| 50 | 50 | */ |
| 51 | 51 | protected function utf16(): ExpressionFunction |
| 52 | 52 | { |
| 53 | - return new ExpressionFunction('utf16', function ($str) { |
|
| 53 | + return new ExpressionFunction('utf16', function($str) { |
|
| 54 | 54 | return sprintf('$len = strlen(%1$s); $new=""; for ($i = 0; $i < $len; ++$i) {$new .= "{$string[$i]}\000";}', $str); |
| 55 | - }, function ($arguments, $str) { |
|
| 55 | + }, function($arguments, $str) { |
|
| 56 | 56 | $len = strlen($str); |
| 57 | 57 | $new = ''; |
| 58 | 58 | |
@@ -71,9 +71,9 @@ discard block |
||
| 71 | 71 | */ |
| 72 | 72 | protected function uuidv4(): ExpressionFunction |
| 73 | 73 | { |
| 74 | - return new ExpressionFunction('uuidv4', function () { |
|
| 74 | + return new ExpressionFunction('uuidv4', function() { |
|
| 75 | 75 | return ''; |
| 76 | - }, function () { |
|
| 76 | + }, function() { |
|
| 77 | 77 | return sprintf( |
| 78 | 78 | '%04x%04x-%04x-%04x-%04x-%04x%04x%04x', |
| 79 | 79 | // 32 bits for "time_low" |
@@ -51,7 +51,7 @@ |
||
| 51 | 51 | */ |
| 52 | 52 | protected static function setErrorHandler(LoggerInterface $logger): void |
| 53 | 53 | { |
| 54 | - set_error_handler(function ($severity, $message, $file, $line) use ($logger) { |
|
| 54 | + set_error_handler(function($severity, $message, $file, $line) use ($logger) { |
|
| 55 | 55 | $log = $message.' in '.$file.':'.$line; |
| 56 | 56 | |
| 57 | 57 | switch ($severity) { |
@@ -54,7 +54,7 @@ |
||
| 54 | 54 | */ |
| 55 | 55 | protected function setErrorHandler(LoggerInterface $logger): self |
| 56 | 56 | { |
| 57 | - set_error_handler(function ($severity, $message, $file, $line) use ($logger) { |
|
| 57 | + set_error_handler(function($severity, $message, $file, $line) use ($logger) { |
|
| 58 | 58 | $log = $message.' in '.$file.':'.$line; |
| 59 | 59 | |
| 60 | 60 | switch ($severity) { |
@@ -100,7 +100,7 @@ |
||
| 100 | 100 | if ($handler instanceof MongoDBHandler) { |
| 101 | 101 | $handler->setLevel($level); |
| 102 | 102 | |
| 103 | - $this->logger->pushProcessor(function ($record) use ($context) { |
|
| 103 | + $this->logger->pushProcessor(function($record) use ($context) { |
|
| 104 | 104 | $record['context'] = array_merge($record['context'], $context); |
| 105 | 105 | |
| 106 | 106 | return $record; |
@@ -398,9 +398,9 @@ |
||
| 398 | 398 | } |
| 399 | 399 | |
| 400 | 400 | $mail = (new Message()) |
| 401 | - ->setSubject($subject) |
|
| 402 | - ->setBody($body) |
|
| 403 | - ->setEncoding('UTF-8'); |
|
| 401 | + ->setSubject($subject) |
|
| 402 | + ->setBody($body) |
|
| 403 | + ->setEncoding('UTF-8'); |
|
| 404 | 404 | |
| 405 | 405 | foreach ($this->data['notification']['receiver'] as $receiver) { |
| 406 | 406 | $mail->setTo($receiver); |
@@ -69,7 +69,7 @@ |
||
| 69 | 69 | /** |
| 70 | 70 | * Set options. |
| 71 | 71 | * |
| 72 | - * @param iterable $config |
|
| 72 | + * @param iterable|null $config |
|
| 73 | 73 | */ |
| 74 | 74 | public function setOptions(?Iterable $config): ApiClient |
| 75 | 75 | { |
@@ -60,6 +60,7 @@ |
||
| 60 | 60 | |
| 61 | 61 | /** |
| 62 | 62 | * Watch. |
| 63 | + * @param \Generator $cursor |
|
| 63 | 64 | */ |
| 64 | 65 | public static function watchAll(ServerRequestInterface $request, Identity $identity, Acl $acl, Iterable $cursor): ResponseInterface |
| 65 | 66 | { |
@@ -69,7 +69,7 @@ |
||
| 69 | 69 | $query = $request->getQueryParams(); |
| 70 | 70 | $options = isset($query['pretty']) ? JSON_PRETTY_PRINT : 0; |
| 71 | 71 | |
| 72 | - $stream = new StreamIterator($cursor, function ($event) use ($request, $options) { |
|
| 72 | + $stream = new StreamIterator($cursor, function($event) use ($request, $options) { |
|
| 73 | 73 | if ($this->tell() === 0) { |
| 74 | 74 | echo '['; |
| 75 | 75 | } else { |
@@ -139,6 +139,7 @@ |
||
| 139 | 139 | |
| 140 | 140 | /** |
| 141 | 141 | * Get all. |
| 142 | + * @param Closure $build |
|
| 142 | 143 | */ |
| 143 | 144 | public function getAllFrom(Collection $collection, ?array $query = null, ?int $offset = null, ?int $limit = null, ?array $sort = null, ?Closure $build = null): Generator |
| 144 | 145 | { |
@@ -143,7 +143,7 @@ discard block |
||
| 143 | 143 | public function getAllFrom(Collection $collection, ?array $query = null, ?int $offset = null, ?int $limit = null, ?array $sort = null, ?Closure $build = null): Generator |
| 144 | 144 | { |
| 145 | 145 | if ($build === null) { |
| 146 | - $build = function ($resource) { |
|
| 146 | + $build = function($resource) { |
|
| 147 | 147 | return $this->build($resource); |
| 148 | 148 | }; |
| 149 | 149 | } |
@@ -175,7 +175,7 @@ discard block |
||
| 175 | 175 | { |
| 176 | 176 | //$this->logger->debug("PIPE WATCH"); |
| 177 | 177 | if ($build === null) { |
| 178 | - $build = function ($resource) { |
|
| 178 | + $build = function($resource) { |
|
| 179 | 179 | return $this->build($resource); |
| 180 | 180 | }; |
| 181 | 181 | } |