@@ -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) { |