@@ -123,6 +123,9 @@ discard block |
||
| 123 | 123 | return $readable ? $readable : $entity; |
| 124 | 124 | } |
| 125 | 125 | |
| 126 | + /** |
|
| 127 | + * @param string $readable |
|
| 128 | + */ |
|
| 126 | 129 | public function formatUser(string $entity, $readable = null) : string |
| 127 | 130 | { |
| 128 | 131 | if ($readable) { |
@@ -137,6 +140,9 @@ discard block |
||
| 137 | 140 | return $entity; |
| 138 | 141 | } |
| 139 | 142 | |
| 143 | + /** |
|
| 144 | + * @param string $readable |
|
| 145 | + */ |
|
| 140 | 146 | public function formatChannel(string $entity, $readable = null) : string |
| 141 | 147 | { |
| 142 | 148 | if ($readable) { |
@@ -26,7 +26,7 @@ |
||
| 26 | 26 | $clientFactory = new ReactAwareGuzzleClientFactory(); |
| 27 | 27 | $reactAwareCurlFactory = $clientFactory->createReactAwareCurlFactory($this->eventLoop, null, $this->logger); |
| 28 | 28 | $handler = $reactAwareCurlFactory->getHandler(); |
| 29 | - $handlerStack = $this->createHandlerStack($handler); |
|
| 29 | + $handlerStack = $this->createHandlerStack($handler); |
|
| 30 | 30 | $config['handler'] = $handlerStack; |
| 31 | 31 | |
| 32 | 32 | return new Client($config); |
@@ -175,7 +175,7 @@ discard block |
||
| 175 | 175 | protected function logMessage($data) |
| 176 | 176 | { |
| 177 | 177 | if ($this->messageLog !== null) { |
| 178 | - file_put_contents($this->messageLog, json_encode($data) . "\n", FILE_APPEND); |
|
| 178 | + file_put_contents($this->messageLog, json_encode($data)."\n", FILE_APPEND); |
|
| 179 | 179 | } |
| 180 | 180 | } |
| 181 | 181 | |
@@ -186,11 +186,11 @@ discard block |
||
| 186 | 186 | } |
| 187 | 187 | |
| 188 | 188 | $this->getSlack()->reconnect()->then( |
| 189 | - function () { |
|
| 189 | + function() { |
|
| 190 | 190 | $this->getLog()->info('Reconnected'); |
| 191 | 191 | $this->monitor = $this->startConnectionMonitor(); |
| 192 | 192 | }, |
| 193 | - function () { |
|
| 193 | + function() { |
|
| 194 | 194 | $this->getLog()->error('Reconnect failed, shutting down.'); |
| 195 | 195 | $this->shutDown(); |
| 196 | 196 | } |
@@ -206,7 +206,7 @@ discard block |
||
| 206 | 206 | |
| 207 | 207 | $this->getLog()->info("Monitoring websocket connection every $interval seconds."); |
| 208 | 208 | |
| 209 | - return $this->loop->addPeriodicTimer($interval, function () use (&$timer) { |
|
| 209 | + return $this->loop->addPeriodicTimer($interval, function() use (&$timer) { |
|
| 210 | 210 | |
| 211 | 211 | static $pong = true; |
| 212 | 212 | |
@@ -217,7 +217,7 @@ discard block |
||
| 217 | 217 | |
| 218 | 218 | $this->getSlack()->ping() |
| 219 | 219 | ->then( |
| 220 | - function (Payload $payload) use (&$pong) { |
|
| 220 | + function(Payload $payload) use (&$pong) { |
|
| 221 | 221 | $this->getLog()->info($payload->toJson()); |
| 222 | 222 | $pong = true; |
| 223 | 223 | } |