[node] Upgrade undici and remove ErrorRecordingDispatcher for websockets (#652)

Author: rkistner

.changeset/lazy-onions-dance.md

@@ -0,0 +1,5 @@
+---
+'@powersync/node': minor
+---
+
+Upgrade undici and use the default undici errors for WebSockets.

demos/example-node/package.json

@@ -12,7 +12,7 @@
   "dependencies": {
     "@powersync/node": "workspace:*",
     "dotenv": "^16.4.7",
-    "undici": "^7.10.0"
+    "undici": "^7.11.0"
   },
   "devDependencies": {
     "ts-node": "^10.9.2",

packages/node/package.json

@@ -53,7 +53,7 @@
     "async-lock": "^1.4.0",
     "bson": "^6.6.0",
     "comlink": "^4.4.2",
-    "undici": "^7.10.0"
+    "undici": "^7.11.0"
   },
   "devDependencies": {
     "@powersync/drizzle-driver": "workspace:*",

packages/node/src/sync/stream/ErrorRecordingDispatcher.ts

@@ -19,7 +19,6 @@ import {
   ProxyAgent,
   WebSocket as UndiciWebSocket
 } from 'undici';
-import { ErrorRecordingDispatcher } from './ErrorRecordingDispatcher.js';
 
 export const STREAMING_POST_TIMEOUT_MS = 30_000;
 
@@ -65,26 +64,15 @@ export class NodeRemote extends AbstractRemote {
   protected createSocket(url: string): globalThis.WebSocket {
     // Create dedicated dispatcher for this WebSocket
     const baseDispatcher = this.getWebsocketDispatcher(url);
-    const errorRecordingDispatcher = new ErrorRecordingDispatcher(baseDispatcher);
 
     // Create WebSocket with dedicated dispatcher
     const ws = new UndiciWebSocket(url, {
-      dispatcher: errorRecordingDispatcher,
+      dispatcher: baseDispatcher,
       headers: {
         'User-Agent': this.getUserAgent()
       }
     });
 
-    errorRecordingDispatcher.onError = (error: Error) => {
-      // When we receive an error from the Dispatcher, emit the event on the websocket.
-      // This will take precedence over the WebSocket's own error event, giving more details on what went wrong.
-      const event = new ErrorEvent('error', {
-        error,
-        message: error.message
-      });
-      ws.dispatchEvent(event);
-    };
-
     return ws as globalThis.WebSocket;
   }