From b09fb590a065236223fce7c34be1d899962d2969 Mon Sep 17 00:00:00 2001
From: Mathias Buus <mathiasbuus@gmail.com>
Date: Fri, 5 Jul 2024 10:56:45 +0200
Subject: [PATCH] interrupt takes a reason

---
 index.js | 14 +++++++-------
 1 file changed, 7 insertions(+), 7 deletions(-)

diff --git a/index.js b/index.js
index 39dff8eb..f630d21e 100644
--- a/index.js
+++ b/index.js
@@ -20,6 +20,7 @@ const CorePool = require('./lib/core-pool')
 const AutoWakeup = require('./lib/wakeup')
 
 const inspect = Symbol.for('nodejs.util.inspect.custom')
+const INTERRUPT = new Error('Apply interrupted')
 
 const AUTOBASE_VERSION = 1
 
@@ -130,7 +131,7 @@ module.exports = class Autobase extends ReadyResource {
     this.view = null
     this.system = null
     this.version = -1
-    this.interrupted = false
+    this.interrupted = null
 
     this.maxCacheSize = handlers.maxCacheSize || 0 // 0 means the hyperbee default cache size will be used
 
@@ -349,10 +350,10 @@ module.exports = class Autobase extends ReadyResource {
     }
   }
 
-  interrupt (err = new Error('Apply interrupted')) {
+  interrupt (reason) {
     assert(this._applying !== null, 'Interrupt is only allowed in apply')
-    this.interrupted = true
-    throw err // throw to interrupt apply
+    if (reason) this.interrupted = reason
+    throw INTERRUPT
   }
 
   async flush () {
@@ -621,9 +622,8 @@ module.exports = class Autobase extends ReadyResource {
     if (this.closing) return
     this.close().catch(safetyCatch)
 
-    if (this.interrupted) {
-      this.interrupted = false
-      this.emit('interrupt', err)
+    if (err === INTERRUPT) {
+      this.emit('interrupt', this.interrupted)
       return
     }