client: Fix connection status not working with web worker

aspen-cloud · Jun 15, 2024 · fef88d1 · fef88d1
1 parent 09fbb43
commit fef88d1
Show file tree

Hide file tree

Showing 4 changed files with 7 additions and 5 deletions.
diff --git a/.changeset/loud-mayflies-approve.md b/.changeset/loud-mayflies-approve.md
@@ -0,0 +1,5 @@
+---
+'@triplit/client': patch
+---
+
+Fix connection status listening when using web worker client
diff --git a/packages/client/package.json b/packages/client/package.json
@@ -47,7 +47,7 @@
  "test:unit": "vitest run",
  "typecheck": "vitest --typecheck.only --no-watch",
  "publish-pkg": "node ../../scripts/npm-check-version-and-publish.js",
- "build-worker": "esbuild ./src/worker-client/worker-client-operator.ts --bundle --minify --platform=browser --outfile=./dist/worker-client/worker-client-operator.js --format=esm --sourcemap",
+ "build-worker": "esbuild ./src/worker-client/worker-client-operator.ts --bundle --minify --platform=browser --outfile=./dist/worker-client/worker-client-operator.js --format=esm",
  "validate:types": "node ../../scripts/check-for-local-references-in-declarations.js dist"
  },
  "files": [

diff --git a/packages/client/src/transport/websocket-transport.ts b/packages/client/src/transport/websocket-transport.ts
@@ -158,9 +158,7 @@ function friendlyReadyState(conn: WebSocket): ConnectionStatus {
  }
 }
 
-// temporary defensive check for node env
-// only run in browser for now
-if (typeof document !== 'undefined') {
+if (typeof WebSocket !== 'undefined') {
  // Add any changes to the WebSocket type here (ex more event handlers)
  var WebSocketProxy = new Proxy(WebSocket, {
  construct: function (target, args) {

diff --git a/packages/client/src/worker-client/worker-client.ts b/packages/client/src/worker-client/worker-client.ts
@@ -51,7 +51,6 @@ export class WorkerClient<M extends ClientSchema | undefined = undefined> {
  });
  this._connectionStatus = 'CLOSED';
  this.onConnectionStatusChange((status) => {
- console.log('connection status:', status);
  this._connectionStatus = status;
  }, true);
  this.db.updateGlobalVariables = (variables) => {