@@ -2,7 +2,6 @@ |
||
2 | 2 | namespace App\Gitter\Middlewares; |
3 | 3 | |
4 | 4 | use App\Gitter\Response; |
5 | -use App\Room; |
|
6 | 5 | use App\Message; |
7 | 6 | use App\Gitter\MiddlewareInterface; |
8 | 7 | use BigShark\SQLToBuilder\BuilderClass; |
@@ -96,7 +96,7 @@ |
||
96 | 96 | |
97 | 97 | return $this->container->call([$middleware, 'handle'], [ |
98 | 98 | 'message' => $message, |
99 | - 'next' => function (Message $message) use ($number) { |
|
99 | + 'next' => function(Message $message) use ($number) { |
|
100 | 100 | $result = $this->fireMiddleware(++$number, $message); |
101 | 101 | |
102 | 102 | if (!($result instanceof Response)) { |
@@ -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) { |
|
61 | + $this->findRoom($client, $this->argument('room'), function(GitterRoom $room) { |
|
62 | 62 | try { |
63 | 63 | $this->listen($room, true); |
64 | 64 | |
@@ -82,7 +82,7 @@ discard block |
||
82 | 82 | protected function auth(Client $client, \Closure $callback) |
83 | 83 | { |
84 | 84 | GitterUser::current($client) |
85 | - ->then(function (GitterUser $gitterUser) use ($callback) { |
|
85 | + ->then(function(GitterUser $gitterUser) use ($callback) { |
|
86 | 86 | $user = User::make($gitterUser); |
87 | 87 | \Auth::setUser($user); |
88 | 88 | |
@@ -121,7 +121,7 @@ discard block |
||
121 | 121 | protected function listen(GitterRoom $gitter, $startup = false) |
122 | 122 | { |
123 | 123 | /** @var Room $room */ |
124 | - $room = Room::make($gitter, function (Room $room) { |
|
124 | + $room = Room::make($gitter, function(Room $room) { |
|
125 | 125 | $this->call('gitter:sync', [ |
126 | 126 | 'room' => $room->gitter_id, |
127 | 127 | '--users' => true, |
@@ -147,11 +147,11 @@ discard block |
||
147 | 147 | Carbon::now()->toDateTimeString() |
148 | 148 | )); |
149 | 149 | |
150 | - $gitter->onMessage(function (GitterMessage $msg) { |
|
150 | + $gitter->onMessage(function(GitterMessage $msg) { |
|
151 | 151 | app(Client::class)->setFallbackMode(false); |
152 | 152 | $this->onMessage($msg); |
153 | 153 | |
154 | - }, function (\Throwable $e) use ($loop, $gitter) { |
|
154 | + }, function(\Throwable $e) use ($loop, $gitter) { |
|
155 | 155 | $this->error($e->getMessage()); |
156 | 156 | $this->error($e->getFile() . ':' . $e->getLine()); |
157 | 157 | $this->warn('Stream not available. Use message fallback fetch mode.'); |
@@ -176,13 +176,13 @@ discard block |
||
176 | 176 | ->first(); |
177 | 177 | |
178 | 178 | if ($lastMessage) { |
179 | - $loop->addTimer($timeout, function () use ($gitter, $lastMessage) { |
|
179 | + $loop->addTimer($timeout, function() use ($gitter, $lastMessage) { |
|
180 | 180 | $gitter->getMessages($lastMessage->gitter_id, GitterRoom::MESSAGE_FETCH_ASC) |
181 | - ->fetch(function (GitterMessage $message, Controls $controls) { |
|
181 | + ->fetch(function(GitterMessage $message, Controls $controls) { |
|
182 | 182 | $this->onMessage($message); |
183 | 183 | $controls->next(); |
184 | 184 | }) |
185 | - ->then(function () use ($gitter) { |
|
185 | + ->then(function() use ($gitter) { |
|
186 | 186 | $this->warn('Connection...'); |
187 | 187 | $this->listen($gitter); |
188 | 188 | }); |