chore: return promise from cleanupWal

We want to return a promise so callers can await on it if desired.
ar-io · Sep 24, 2024 · edf56d7 · edf56d7
1 parent 51e3744
commit edf56d7
Showing 1 changed file with 20 additions and 18 deletions.
diff --git a/src/database/standalone-sqlite.ts b/src/database/standalone-sqlite.ts
@@ -2973,25 +2973,27 @@ export class StandaloneSqliteDatabase
   }
 
   async cleanupWal(dbName: WorkerPoolName): Promise<void> {
-    this.queueWrite(dbName, 'cleanupWal', [dbName]).then((walCheckpoint) => {
-      this.log.info('WAL checkpoint', {
-        dbName,
-        walCheckpoint,
-      });
+    return this.queueWrite(dbName, 'cleanupWal', [dbName]).then(
+      (walCheckpoint) => {
+        this.log.info('WAL checkpoint', {
+          dbName,
+          walCheckpoint,
+        });
 
-      metrics.sqliteWalCheckpointPages.set(
-        { db: dbName, type: 'busy' },
-        walCheckpoint.busy,
-      );
-      metrics.sqliteWalCheckpointPages.set(
-        { db: dbName, type: 'log' },
-        walCheckpoint.log,
-      );
-      metrics.sqliteWalCheckpointPages.set(
-        { db: dbName, type: 'checkpointed' },
-        walCheckpoint.checkpointed,
-      );
-    });
+        metrics.sqliteWalCheckpointPages.set(
+          { db: dbName, type: 'busy' },
+          walCheckpoint.busy,
+        );
+        metrics.sqliteWalCheckpointPages.set(
+          { db: dbName, type: 'log' },
+          walCheckpoint.log,
+        );
+        metrics.sqliteWalCheckpointPages.set(
+          { db: dbName, type: 'checkpointed' },
+          walCheckpoint.checkpointed,
+        );
+      },
+    );
   }
 }