display warning when socket.io fails

Author: jochen-testingbot

src/providers/espresso.ts

@@ -52,6 +52,7 @@ export default class Espresso extends BaseProvider<EspressoOptions> {
   private socket: Socket | null = null;
   private updateServer: string | null = null;
   private updateKey: string | null = null;
+  private socketFallbackWarned = false;
 
   public constructor(credentials: Credentials, options: EspressoOptions) {
     super(credentials, options);
@@ -539,8 +540,16 @@ export default class Espresso extends BaseProvider<EspressoOptions> {
         this.handleEspressoError(data);
       });
 
-      this.socket.on('connect_error', () => {
-        // Silently fail - real-time updates are optional
+      this.socket.on('connect_error', (err: Error) => {
+        if (!this.socketFallbackWarned) {
+          this.socketFallbackWarned = true;
+          logger.warn(
+            'Real-time log stream unavailable, falling back to polling.',
+          );
+          logger.debug(
+            `Socket connect_error: ${err?.message ?? 'unknown error'}`,
+          );
+        }
         this.disconnectFromUpdateServer();
       });
     } catch {

src/providers/maestro.ts

@@ -93,6 +93,7 @@ export default class Maestro extends BaseProvider<MaestroOptions> {
   private socket: Socket | null = null;
   private updateServer: string | null = null;
   private updateKey: string | null = null;
+  private socketFallbackWarned = false;
 
   public constructor(credentials: Credentials, options: MaestroOptions) {
     super(credentials, options);
@@ -2580,8 +2581,16 @@ export default class Maestro extends BaseProvider<MaestroOptions> {
         this.handleMaestroError(data);
       });
 
-      this.socket.on('connect_error', () => {
-        // Silently fail - real-time updates are optional
+      this.socket.on('connect_error', (err: Error) => {
+        if (!this.socketFallbackWarned) {
+          this.socketFallbackWarned = true;
+          logger.warn(
+            'Real-time log stream unavailable, falling back to polling.',
+          );
+          logger.debug(
+            `Socket connect_error: ${err?.message ?? 'unknown error'}`,
+          );
+        }
         this.disconnectFromUpdateServer();
       });
     } catch {

src/providers/xcuitest.ts

@@ -52,6 +52,7 @@ export default class XCUITest extends BaseProvider<XCUITestOptions> {
   private socket: Socket | null = null;
   private updateServer: string | null = null;
   private updateKey: string | null = null;
+  private socketFallbackWarned = false;
 
   public constructor(credentials: Credentials, options: XCUITestOptions) {
     super(credentials, options);
@@ -542,8 +543,16 @@ export default class XCUITest extends BaseProvider<XCUITestOptions> {
         this.handleXCUITestError(data);
       });
 
-      this.socket.on('connect_error', () => {
-        // Silently fail - real-time updates are optional
+      this.socket.on('connect_error', (err: Error) => {
+        if (!this.socketFallbackWarned) {
+          this.socketFallbackWarned = true;
+          logger.warn(
+            'Real-time log stream unavailable, falling back to polling.',
+          );
+          logger.debug(
+            `Socket connect_error: ${err?.message ?? 'unknown error'}`,
+          );
+        }
         this.disconnectFromUpdateServer();
       });
     } catch {