timeout selection on database sync

Author: PradaJoaquin

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@bitxenia/astradb",
-  "version": "0.1.0",
+  "version": "0.1.1",
   "description": "Database for astrawiki & astrachat ipfs using orbitdb & libp2p",
   "author": "Bitxenia",
   "license": "MIT",

src/database.ts

@@ -41,9 +41,9 @@ export class Database {
     await this.updateDatabase();
   }
 
-  public async initExisting(): Promise<boolean> {
+  public async initExisting(msTimeout: number): Promise<boolean> {
     await this.createDatabase();
-    const synced = await this.syncDb();
+    const synced = await this.syncDb(msTimeout);
     await this.setupDbEvents();
     await this.updateDatabase();
     return synced;
@@ -79,7 +79,7 @@ export class Database {
     this.openDb = db;
   }
 
-  private async syncDb(): Promise<boolean> {
+  private async syncDb(msTimeout: number): Promise<boolean> {
     // We wait for the database to be synced with at least one provider.
     // This is because the database is empty until it is synced.
     let synced = false;
@@ -98,7 +98,9 @@ export class Database {
     try {
       await this.waitFor(
         async () => synced,
-        async () => true
+        async () => true,
+        100,
+        msTimeout
       );
     } catch (error) {
       if (error instanceof SyncTimeoutError) {
@@ -116,8 +118,8 @@ export class Database {
   private async waitFor(
     valueA: any,
     toBeValueB: any,
-    pollInterval = 100,
-    timeout = 20000 // 20 seconds | TODO: see if this is enough
+    pollInterval: number,
+    timeout: number
   ): Promise<void> {
     // TODO: We use this slight modifided busy wait found in the OrbitDB codebase:
     // https://github.com/orbitdb/orbitdb/blob/main/test/utils/wait-for.js

src/keyRepository.ts

@@ -38,7 +38,7 @@ export class KeyRepository {
 
     if (!this.isCollaborator && !offlineMode) {
       // If we are not a collaborator and we are not in offline mode, we open an existing database which sincronizes with the providers.
-      const synced = await this.keyDb.initExisting();
+      const synced = await this.keyDb.initExisting(60000);
       if (!synced) {
         // If we are not a collaborator and the db did not sync with the providers,
         // We throw an error because a non collaborator node cannot create a new astradb.
@@ -135,7 +135,7 @@ export class KeyRepository {
     valueDb = new Database(valueDbName, this.orbitdb, this.events);
     if (existing) {
       // If the database already exists, we open it and sync it.
-      await valueDb.initExisting();
+      await valueDb.initExisting(20000);
     } else {
       await valueDb.initNew();
     }