sync start simplification

decentralized-identity · Sep 4, 2024 · b5a9a2b · b5a9a2b
1 parent 4d95c0c
commit b5a9a2b
Showing 1 changed file with 9 additions and 5 deletions.
diff --git a/packages/agent/src/sync-engine-level.ts b/packages/agent/src/sync-engine-level.ts
@@ -289,12 +289,20 @@ export class SyncEngineLevel implements SyncEngine {
     }
   }
 
-  public startSync({ interval }: {
+  public async startSync({ interval }: {
     interval: string
   }): Promise<void> {
     // Convert the interval string to milliseconds.
     const intervalMilliseconds = ms(interval);
 
+    if (this._syncIntervalId) {
+      this.stopSync();
+    }
+
+    if (!this._syncLock) {
+      await this.sync();
+    }
+
     return new Promise((resolve, reject) => {
       const intervalSync = async () => {
         if (this._syncLock) {
@@ -317,10 +325,6 @@ export class SyncEngineLevel implements SyncEngine {
         }
       };
 
-      if (this._syncIntervalId) {
-        clearInterval(this._syncIntervalId);
-      }
-
       this._syncIntervalId = setInterval(intervalSync, intervalMilliseconds);
     });
   }