From 497798b45522bcc33b1ed176b150e021b9430202 Mon Sep 17 00:00:00 2001
From: Michael <heluecht@pirati.ca>
Date: Sun, 1 Jun 2025 04:27:52 +0000
Subject: [PATCH] Warning handler removed

---
 src/Protocol/ATProtocol/Jetstream.php | 31 ---------------------------
 1 file changed, 31 deletions(-)

diff --git a/src/Protocol/ATProtocol/Jetstream.php b/src/Protocol/ATProtocol/Jetstream.php
index 86e28c0124a..a4771cae441 100755
--- a/src/Protocol/ATProtocol/Jetstream.php
+++ b/src/Protocol/ATProtocol/Jetstream.php
@@ -94,34 +94,20 @@ class Jetstream
 
 			$this->syncContacts();
 			try {
-				set_error_handler(function ($errno, $errstr, $errfile, $errline) {
-					restore_error_handler();
-					throw new \ErrorException($errstr, 0, $errno, $errfile, $errline);
-				}, E_WARNING);
 				// @todo make the path configurable
 				$this->client = new \WebSocket\Client('wss://jetstream1.us-west.bsky.network/subscribe?requireHello=true' . $cursor);
 				$this->client->setTimeout($timeout);
 				$this->client->setLogger($this->logger);
-				restore_error_handler();
 			} catch (\WebSocket\ConnectionException $e) {
 				$this->logger->error('Error while trying to establish the connection', ['code' => $e->getCode(), 'message' => $e->getMessage(), 'file' => $e->getFile(), 'line' => $e->getLine()]);
 				echo "Connection wasn't established.\n";
 				exit(1);
-			} catch (\ErrorException $e) {
-				$this->logger->notice('Warning while trying to establish the connection', ['code' => $e->getCode(), 'severity' => $e->getSeverity(), 'message' => $e->getMessage(), 'file' => $e->getFile(), 'line' => $e->getLine()]);
-				echo "Connection wasn't established.\n";
-				exit(1);
 			}
 			$this->setOptions();
 			$last_timeout = time();
 			while (true) {
 				try {
-					set_error_handler(function ($errno, $errstr, $errfile, $errline) {
-						restore_error_handler();
-						throw new \ErrorException($errstr, 0, $errno, $errfile, $errline);
-					}, E_WARNING);
 					$message = $this->client->receive();
-					restore_error_handler();
 
 					if (empty($message)) {
 						$this->logger->notice('Empty message received');
@@ -150,23 +136,13 @@ class Jetstream
 						$this->logger->error('Error while trying to receive a message', ['code' => $e->getCode(), 'message' => $e->getMessage(), 'file' => $e->getFile(), 'line' => $e->getLine()]);
 						break;
 					}
-				} catch (\ErrorException $e) {
-					$this->logger->notice('Warning while trying to receive a message', ['code' => $e->getCode(), 'severity' => $e->getSeverity(), 'message' => $e->getMessage(), 'file' => $e->getFile(), 'line' => $e->getLine()]);
-					break;
 				}
 				$last_timeout = time();
 			}
 			try {
-				set_error_handler(function ($errno, $errstr, $errfile, $errline) {
-					restore_error_handler();
-					throw new \ErrorException($errstr, 0, $errno, $errfile, $errline);
-				}, E_WARNING);
 				$this->client->close();
-				restore_error_handler();
 			} catch (\WebSocket\ConnectionException $e) {
 				$this->logger->error('Error while trying to close the connection', ['code' => $e->getCode(), 'message' => $e->getMessage(), 'file' => $e->getFile(), 'line' => $e->getLine()]);
-			} catch (\ErrorException $e) {
-				$this->logger->notice('Warning while trying to close the connection', ['code' => $e->getCode(), 'severity' => $e->getSeverity(), 'message' => $e->getMessage(), 'file' => $e->getFile(), 'line' => $e->getLine()]);
 			}
 		}
 		$this->logger->notice('Stop listening');
@@ -263,16 +239,9 @@ class Jetstream
 			]
 		];
 		try {
-			set_error_handler(function ($errno, $errstr, $errfile, $errline) {
-				restore_error_handler();
-				throw new \ErrorException($errstr, 0, $errno, $errfile, $errline);
-			}, E_WARNING);
 			$this->client->send(json_encode($update));
-			restore_error_handler();
 		} catch (\WebSocket\ConnectionException $e) {
 			$this->logger->error('Error while trying to send options.', ['code' => $e->getCode(), 'message' => $e->getMessage(), 'file' => $e->getFile(), 'line' => $e->getLine()]);
-		} catch (\ErrorException $e) {
-			$this->logger->notice('Warning while trying to send options.', ['code' => $e->getCode(), 'severity' => $e->getSeverity(), 'message' => $e->getMessage(), 'file' => $e->getFile(), 'line' => $e->getLine()]);
 		}
 	}