Fix: Rust Client Disconnect Race (#700)

Author: stevensJourney

.changeset/honest-penguins-worry.md

@@ -0,0 +1,5 @@
+---
+'@powersync/common': patch
+---
+
+Fix issue where Rust sync implementation might not disconnect in some circumstances.

packages/common/src/client/sync/stream/AbstractRemote.ts

@@ -502,6 +502,10 @@ export abstract class AbstractRemote {
      *  Aborting the active fetch request while it is being consumed seems to throw
      *  an unhandled exception on the window level.
      */
+    if (abortSignal?.aborted) {
+      throw new AbortOperation('Abort request received before making postStreamRaw request');
+    }
+
     const controller = new AbortController();
     let requestResolved = false;
     abortSignal?.addEventListener('abort', () => {

packages/common/src/client/sync/stream/AbstractStreamingSyncImplementation.ts

@@ -899,6 +899,9 @@ The next upload iteration will be delayed.`);
     let receivingLines: Promise<void> | null = null;
     let hadSyncLine = false;
 
+    if (signal.aborted) {
+      throw new AbortOperation('Connection request has been aborted');
+    }
     const abortController = new AbortController();
     signal.addEventListener('abort', () => abortController.abort());