From 1e5281de2987d270edcf3db2eff89c410c1e5ceb Mon Sep 17 00:00:00 2001
From: Deon George <deon@leenooks.net>
Date: Wed, 22 Jun 2022 10:39:45 +1000
Subject: [PATCH] More debugging trying to catch websocket connect errors

---
 src/Client/SocketMode.php | 10 +++++++---
 1 file changed, 7 insertions(+), 3 deletions(-)

diff --git a/src/Client/SocketMode.php b/src/Client/SocketMode.php
index 432d5fe..7233dac 100644
--- a/src/Client/SocketMode.php
+++ b/src/Client/SocketMode.php
@@ -89,8 +89,8 @@ class SocketMode extends API
 				// initiate the websocket connection
 				// write PHPWS things to the existing logger
 				$this->websocket = new WebSocket($response['url'].($this->debug_reconnect ? '&debug_reconnects=true' : ''),$this->loop,$this->logger);
-				$this->websocket->on('message', function ($message) {
-					Log::debug(sprintf('%s:- Calling onMessage ...',self::LOGKEY),['m'=>__METHOD__]);
+				$this->websocket->on('message', function ($message) use ($response) {
+					Log::debug(sprintf('%s:- Calling onMessage ...',self::LOGKEY),['m'=>__METHOD__,'payload'=>serialize($response),'message'=>serialize($message)]);
 					$this->onMessage($message);
 				});
 
@@ -169,7 +169,11 @@ class SocketMode extends API
 		Log::debug(sprintf('%s:+ Start',self::LOGKEY),['m'=>__METHOD__]);
 
 		// parse the message and get the event name
-		$payload = Payload::fromJson($message->getData());
+		try {
+			$payload = Payload::fromJson($message->getData());
+		} catch (\UnexpectedValueException $e) {
+			Log::error(sprintf('%s:! ERROR in json payload in onMessage',self::LOGKEY),['message'=>serialize($message)]);
+		}
 		$emitted = FALSE;
 
 		if (isset($payload['type'])) {