Fix for prompt totally blocking the event loop

CHANGELOG.md

@@ -1,3 +1,9 @@
+## 0.15.4
+
+- Fix for `prompt` totally blocking the event loop in the cli tool, preventing
+  synchronization.
+- Make the watchdog slightly more invincible.
+
 ## 0.15.3
 
 - Internal fix; Always unblock sync even if a vacuum fails

deno.json

@@ -1,6 +1,6 @@
 {
   "name": "@cross/kv",
-  "version": "0.15.3",
+  "version": "0.15.4",
   "exports": {
     ".": "./mod.ts",
     "./cli": "./src/cli/mod.ts"

src/cli/loop.ts

@@ -14,12 +14,17 @@ export function registerCommand(command: string, handler: KVCliHandler) {
 export async function main() {
   const container: KVDBContainer = {};
   let exit = false;
-
   while (!exit) {
+    // Collect user input
     const command = await prompt(Colors.blue(">"));
     if (command === null) {
       continue;
     }
+
+    // Yield to event loop, allowing any scheduled tasks to be executed
+    await new Promise((resolve) => setTimeout(resolve, 0));
+
+    // Handle the user input
     const commandSplit = command.split(" ");
     const cmd = commandSplit[0].toLowerCase();
     const startTime = performance.now(); // Start measuring time
@@ -42,5 +47,8 @@ export async function main() {
     } else {
       console.error(Colors.red("Invalid command.\n"));
     }
+
+    // Yield to event loop, allowing any scheduled tasks to be executed
+    await new Promise((resolve) => setTimeout(resolve, 0));
   }
 }

src/lib/kv.ts

@@ -276,7 +276,9 @@ export class KV extends EventEmitter {
     this.watchdogTimer = setTimeout(
       async () => {
         // Make sure current run is done
-        await this.watchdogPromise;
+        try {
+          await this.watchdogPromise;
+        } catch (_e) { /* Ignore */ }
 
         // Initiate a new run
         this.watchdogPromise = this.watchdog();