fix: initializing db if db was closed

silkroadnomad · Jan 22, 2025 · ae73214 · ae73214
1 parent 046fbdf
commit ae73214
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 12 deletions.
diff --git a/relay/package.json b/relay/package.json
@@ -1,6 +1,6 @@
 {
   "name": "libp2p-relay",
-  "version": "0.12.54",
+  "version": "0.12.55",
   "private": true,
   "scripts": {
     "start:no-restart": "node src/relay.js",

diff --git a/relay/src/pinner/pinningService.js b/relay/src/pinner/pinningService.js
@@ -229,8 +229,8 @@ export class PinningService {
    * @returns {Promise<boolean>} - Should remain pinned
    */
   async shouldRemainPinned(cid) {
+    if(!this.db) await this.initializeDatabase()
     return this.queue.add(async () => {
-      const dbPath = './orbitdb/pinning-metadata';
 
       // Clean up any stale lock files before opening
       const MAX_RETRIES = 3;
@@ -283,16 +283,7 @@ export class PinningService {
           }
 
           await new Promise(resolve => setTimeout(resolve, RETRY_DELAY));
-        } finally {
-          if (this.db) {
-            try {
-              await this.db.close();
-              logger.info(`Database closed successfully after attempt ${attempt}`);
-            } catch (closeError) {
-              logger.error(`Error closing database on attempt ${attempt}:`, closeError);
-            }
-          }
-        }
+        } 
       }
     });
   }