@@ -16,9 +16,9 @@ discard block |
||
| 16 | 16 | public function __construct(string $replyDirectory = null) |
| 17 | 17 | { |
| 18 | 18 | if ($replyDirectory === null) { |
| 19 | - $replyDirectory = \sys_get_temp_dir().'/replies'; |
|
| 19 | + $replyDirectory = \sys_get_temp_dir() . '/replies'; |
|
| 20 | 20 | } |
| 21 | - $this->replyDirectory = rtrim($replyDirectory, '/').'/'; |
|
| 21 | + $this->replyDirectory = rtrim($replyDirectory, '/') . '/'; |
|
| 22 | 22 | if (!\file_exists($replyDirectory)) { |
| 23 | 23 | \mkdir($replyDirectory, 0777, true); |
| 24 | 24 | } |
@@ -29,7 +29,7 @@ discard block |
||
| 29 | 29 | */ |
| 30 | 30 | public function clear(): void |
| 31 | 31 | { |
| 32 | - $files = glob($this->replyDirectory.'*'); // get all file names |
|
| 32 | + $files = glob($this->replyDirectory . '*'); // get all file names |
|
| 33 | 33 | foreach ($files as $file) { // iterate files |
| 34 | 34 | if (is_file($file)) { |
| 35 | 35 | unlink($file); // delete file |
@@ -40,15 +40,15 @@ discard block |
||
| 40 | 40 | private function getNextFileName(): string |
| 41 | 41 | { |
| 42 | 42 | $i = 0; |
| 43 | - while (\file_exists($this->replyDirectory.'tmp'.$i)) { |
|
| 43 | + while (\file_exists($this->replyDirectory . 'tmp' . $i)) { |
|
| 44 | 44 | $i++; |
| 45 | 45 | } |
| 46 | - return 'tmp'.$i; |
|
| 46 | + return 'tmp' . $i; |
|
| 47 | 47 | } |
| 48 | 48 | |
| 49 | 49 | public function storeReply(string $payload): void |
| 50 | 50 | { |
| 51 | - $path = $this->replyDirectory.$this->getNextFileName(); |
|
| 51 | + $path = $this->replyDirectory . $this->getNextFileName(); |
|
| 52 | 52 | \file_put_contents($path, $payload); |
| 53 | 53 | } |
| 54 | 54 | |
@@ -59,8 +59,8 @@ discard block |
||
| 59 | 59 | { |
| 60 | 60 | $i = 0; |
| 61 | 61 | $replies = []; |
| 62 | - while (\file_exists($this->replyDirectory.'tmp'.$i)) { |
|
| 63 | - $replies[] = \file_get_contents($this->replyDirectory.'tmp'.$i); |
|
| 62 | + while (\file_exists($this->replyDirectory . 'tmp' . $i)) { |
|
| 63 | + $replies[] = \file_get_contents($this->replyDirectory . 'tmp' . $i); |
|
| 64 | 64 | $i++; |
| 65 | 65 | } |
| 66 | 66 | return $replies; |
@@ -37,11 +37,11 @@ |
||
| 37 | 37 | public static function dispatchJson(string $event, $payload): array |
| 38 | 38 | { |
| 39 | 39 | if (\is_object($payload) && !$payload instanceof \JsonSerializable) { |
| 40 | - throw new \RuntimeException('Payload object should implement JsonSerializable. Got an instance of '.\get_class($payload)); |
|
| 40 | + throw new \RuntimeException('Payload object should implement JsonSerializable. Got an instance of ' . \get_class($payload)); |
|
| 41 | 41 | } |
| 42 | 42 | $replies = self::dispatch($event, \json_encode($payload)); |
| 43 | 43 | |
| 44 | - return \array_map(function (string $reply) { |
|
| 44 | + return \array_map(function(string $reply) { |
|
| 45 | 45 | return \GuzzleHttp\json_decode($reply, true); |
| 46 | 46 | }, $replies); |
| 47 | 47 | } |