Remove duplicate upload logic

Author: simolus3

packages/common/src/client/ConnectionManager.ts

@@ -194,7 +194,6 @@ export class ConnectionManager extends BaseObserver<ConnectionManagerListener> {
 
     this.logger.debug('Attempting to connect to PowerSync instance');
     await this.syncStreamImplementation?.connect(appliedOptions!);
-    this.syncStreamImplementation?.triggerCrudUpload();
   }
 
   /**

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

@@ -885,12 +885,12 @@ The next upload iteration will be delayed.`);
             return;
           }
 
+          await control(line.command, line.payload);
+
           if (!hadSyncLine) {
             syncImplementation.triggerCrudUpload();
             hadSyncLine = true;
           }
-
-          await control(line.command, line.payload);
         }
       } finally {
         const activeInstructions = controlInvocations;
@@ -999,6 +999,7 @@ The next upload iteration will be delayed.`);
       );
 
       this.notifyCompletedUploads = () => {
+        console.log('notify completed');
         controlInvocations?.enqueueData({ command: PowerSyncControlCommand.NOTIFY_CRUD_UPLOAD_COMPLETED });
       };
       await receivingLines;