laravel/slack
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

More debugging for connects and disconnects

Browse Source
This commit is contained in:
Deon George 2021-08-24 16:32:19 +10:00
parent 03c6a5c426
commit edfb802805
No known key found for this signature in database
GPG Key ID: 7670E8DC27415254
1 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/Client/SocketMode.php
View File

@ -7,6 +7,7 @@ use Devristo\Phpws\Messaging\WebSocketMessageInterface;
use Evenement\EventEmitterTrait; use Evenement\EventEmitterTrait;
use GuzzleHttp\ClientInterface; use GuzzleHttp\ClientInterface;
use Illuminate\Http\Client\ConnectionException; use Illuminate\Http\Client\ConnectionException;
use Illuminate\Support\Arr;
use Illuminate\Support\Facades\Log; use Illuminate\Support\Facades\Log;
use React\EventLoop\LoopInterface; use React\EventLoop\LoopInterface;
use React\Promise\Deferred; use React\Promise\Deferred;
@ -103,10 +104,15 @@ class SocketMode extends API
// then wait for the connection to be ready. // then wait for the connection to be ready.
->then(function () use ($deferred) { ->then(function () use ($deferred) {
$this->once('hello', function () use ($deferred) { $this->once('hello', function ($data) use ($deferred) {
Log::debug(sprintf('%s:- hello [#%d]...',self::LOGKEY,Arr::get($data->getData(),'num_connections')),['m'=>__METHOD__,'d'=>$data]);
$deferred->resolve(); $deferred->resolve();
}); });
$this->once('disconnect', function ($data) use ($deferred) {
Log::debug(sprintf('%s:- disconnect ...',self::LOGKEY),['m'=>__METHOD__,'d'=>$data]);
});
$this->once('error', function ($data) use ($deferred) { $this->once('error', function ($data) use ($deferred) {
$deferred->reject(new ConnectionException( $deferred->reject(new ConnectionException(
'Could not connect to WebSocket: '.$data['error']['msg'], 'Could not connect to WebSocket: '.$data['error']['msg'],