@@ -12,7 +12,6 @@ |
||
| 12 | 12 | |
| 13 | 13 | use App\Message; |
| 14 | 14 | use App\Gitter\Response; |
| 15 | -use App\Text; |
|
| 16 | 15 | use BigShark\SQLToBuilder\BuilderClass; |
| 17 | 16 | use App\Gitter\Extensions\Middlewares\MiddlewareInterface; |
| 18 | 17 | |
@@ -117,7 +117,7 @@ |
||
| 117 | 117 | return $this->room->sendMessage($text); |
| 118 | 118 | } |
| 119 | 119 | |
| 120 | - return new Promise(function($resolve, $reject){ |
|
| 120 | + return new Promise(function($resolve, $reject) { |
|
| 121 | 121 | $reject(new \RuntimeException('Message bus is disabled')); |
| 122 | 122 | }); |
| 123 | 123 | } |
@@ -56,9 +56,9 @@ discard block |
||
| 56 | 56 | /** @var Client $client */ |
| 57 | 57 | $client = $this->createClient($container, $config->get('gitter.token')); |
| 58 | 58 | |
| 59 | - $this->auth($client, function (User $user) use ($client) { |
|
| 59 | + $this->auth($client, function(User $user) use ($client) { |
|
| 60 | 60 | |
| 61 | - $this->findRoom($client, $this->argument('room'), function (GitterRoom $room) use ($client) { |
|
| 61 | + $this->findRoom($client, $this->argument('room'), function(GitterRoom $room) use ($client) { |
|
| 62 | 62 | try { |
| 63 | 63 | $this->listen($room, true); |
| 64 | 64 | |
@@ -90,7 +90,7 @@ discard block |
||
| 90 | 90 | protected function auth(Client $client, \Closure $callback) |
| 91 | 91 | { |
| 92 | 92 | GitterUser::current($client) |
| 93 | - ->then(function (GitterUser $gitterUser) use ($callback) { |
|
| 93 | + ->then(function(GitterUser $gitterUser) use ($callback) { |
|
| 94 | 94 | $user = User::make($gitterUser); |
| 95 | 95 | \Auth::setUser($user); |
| 96 | 96 | |
@@ -108,7 +108,7 @@ discard block |
||
| 108 | 108 | protected function listen(GitterRoom $gitter, $startup = false) |
| 109 | 109 | { |
| 110 | 110 | /** @var Room $room */ |
| 111 | - $room = Room::make($gitter, function (Room $room) { |
|
| 111 | + $room = Room::make($gitter, function(Room $room) { |
|
| 112 | 112 | $this->call('gitter:sync', [ |
| 113 | 113 | 'room' => $room->gitter_id, |
| 114 | 114 | '--users' => true, |
@@ -132,11 +132,11 @@ discard block |
||
| 132 | 132 | Carbon::now()->toDateTimeString() |
| 133 | 133 | )); |
| 134 | 134 | |
| 135 | - $gitter->onMessage(function (GitterMessage $msg) { |
|
| 135 | + $gitter->onMessage(function(GitterMessage $msg) { |
|
| 136 | 136 | app(Client::class)->setFallbackMode(false); |
| 137 | 137 | $this->onMessage($msg); |
| 138 | 138 | |
| 139 | - }, function (\Throwable $e) use ($loop, $gitter) { |
|
| 139 | + }, function(\Throwable $e) use ($loop, $gitter) { |
|
| 140 | 140 | $this->warn('Stream not available. Use message fallback fetch mode.'); |
| 141 | 141 | |
| 142 | 142 | app(Client::class)->setFallbackMode(true); |
@@ -159,14 +159,14 @@ discard block |
||
| 159 | 159 | ->first(); |
| 160 | 160 | |
| 161 | 161 | if ($lastMessage) { |
| 162 | - $loop->addTimer($timeout, function () use ($gitter, $lastMessage) { |
|
| 162 | + $loop->addTimer($timeout, function() use ($gitter, $lastMessage) { |
|
| 163 | 163 | $gitter |
| 164 | 164 | ->getMessages($lastMessage->gitter_id, GitterRoom::MESSAGE_FETCH_ASC) |
| 165 | - ->fetch(function (GitterMessage $message, Controls $controls) { |
|
| 165 | + ->fetch(function(GitterMessage $message, Controls $controls) { |
|
| 166 | 166 | $this->onMessage($message); |
| 167 | 167 | $controls->next(); |
| 168 | 168 | }) |
| 169 | - ->then(function () use ($gitter) { |
|
| 169 | + ->then(function() use ($gitter) { |
|
| 170 | 170 | $this->warn('Connection...'); |
| 171 | 171 | $this->listen($gitter); |
| 172 | 172 | }, function(\Throwable $e) { |