Nb ev loop fixes

.github/workflows/build.yml

@@ -57,7 +57,7 @@ jobs:
     strategy:
       matrix:
         os: [ubuntu-latest]
-        node: [14.x, 16.x, 18.x, 20.x, 22.x, 24.x]
+        node: [16.x, 18.x, 20.x, 22.x, 24.x]
 
     steps:
     - uses: actions/checkout@v4
@@ -71,12 +71,6 @@ jobs:
       if: contains(matrix.os, 'ubuntu')
       run: sudo apt-get update && sudo apt-get install -y libunbound-dev
 
-    # Pythong 3.10->3.11 broke node-gyp. This upgrades node-gyp for older nodejs.
-    # https://github.com/nodejs/node-gyp/issues/2219
-    - name: Update npm.
-      if: contains(matrix.node, '14.x')
-      run: npm i -g npm@9
-
     - name: Install dependencies
       run: npm install
 

lib/client/wallet.js

@@ -685,6 +685,32 @@ class WalletClient extends bcurl.Client {
     return this.patch(`/wallet/${id}/account/${name}`, options);
   }
 
+  /**
+   * Get receive address. (UNSAFE)
+   * @param {String} id
+   * @param {String} account
+   * @param {Number} index
+   * @param {Boolean} safe
+   * @returns {Promise}
+   */
+
+  getAddress(id, account, index, safe) {
+    return this.get(`/wallet/${id}/address`, { account, index, safe });
+  }
+
+  /**
+   * Get change address. (UNSAFE)
+   * @param {String} id
+   * @param {String} account
+   * @param {Number} index
+   * @param {Boolean} safe
+   * @returns {Promise}
+   */
+
+  getChange(id, account, index, safe) {
+    return this.get(`/wallet/${id}/change`, { account, index, safe });
+  }
+
   /**
    * Create address.
    * @param {Object} options
@@ -1374,6 +1400,30 @@ class Wallet extends EventEmitter {
     return this.client.modifyAccount(this.id, name, options);
   }
 
+  /**
+   * Get receive address. (UNSAFE)
+   * @param {String} account
+   * @param {Number} index
+   * @param {Boolean} safe
+   * @returns {Promise}
+   */
+
+  getAddress(account, index, safe) {
+    return this.client.getAddress(this.id, account, index, safe);
+  }
+
+  /**
+   * Get change address. (UNSAFE)
+   * @param {String} account
+   * @param {Number} index
+   * @param {Boolean} safe
+   * @returns {Promise}
+   */
+
+  getChange(account, index, safe) {
+    return this.client.getChange(this.id, account, index, safe);
+  }
+
   /**
    * Create address.
    * @param {Object} options

lib/node/rpc.js

@@ -255,6 +255,9 @@ class RPC extends RPCBase {
     // this.add('getnameinfo', this.getNameInfo);
     // this.add('getnameresource', this.getNameResource);
     // this.add('getnameproof', this.getNameProof);
+
+    // Namebase specific events.
+    this.add('emitnamebaseevent', this.emitNamebaseEvent);
   }
 
   /*
@@ -2634,6 +2637,18 @@ class RPC extends RPCBase {
     return null;
   }
 
+  async emitNamebaseEvent(args) {
+    if (args.length < 1)
+      throw new RPCError(errs.MISC_ERROR, 'emitnamebaseevent ( ...args )');
+
+    const valid = new Validator(args);
+    const eventName = valid.str(0);
+
+    this.emit(`namebase-${eventName}`, args.slice(1));
+
+    return null;
+  }
+
   /*
    * Helpers
    */

lib/primitives/mtx.js

@@ -870,11 +870,14 @@ class MTX extends TX {
    * @returns {Number} Number of inputs templated.
    */
 
-  template(ring) {
+  async template(ring) {
     if (Array.isArray(ring)) {
       let total = 0;
-      for (const key of ring)
+      for (const key of ring) {
         total += this.template(key);
+        await yieldToRuntime();
+      }
+
       return total;
     }
 
@@ -895,6 +898,9 @@ class MTX extends TX {
         continue;
 
       total += 1;
+
+      if (total % 100 === 0)
+        await yieldToRuntime();
     }
 
     return total;
@@ -1484,6 +1490,10 @@ function sortLinked(a, b) {
   return a[0].compare(b[0]);
 }
 
+function yieldToRuntime() {
+  return new Promise(res => setImmediate(res));
+}
+
 /*
  * Expose
  */

lib/wallet/account.js

@@ -435,6 +435,39 @@ class Account extends bio.Struct {
     }
   }
 
+  /**
+   * Derive an address at `index`. Do not increment depth.
+   * Optionally check safety.
+   * @param {Number} branch
+   * @param {Number} index
+   * @param {Boolean} [safe]
+   * @param {MasterKey} [master]
+   * @returns {WalletKey}
+   */
+
+  deriveCheckedKey(branch, index, safe, master) {
+    assert(typeof branch === 'number');
+
+    if (safe) {
+      switch (branch) {
+        case 0: {
+          if (index > this.receiveDepth + this.lookahead)
+            throw new Error('Receive index out of bounds.');
+
+          break;
+        }
+        case 1: {
+          if (index > this.changeDepth + this.lookahead)
+            throw new Error('Change index out of bounds.');
+
+          break;
+        }
+      }
+    }
+
+    return this.deriveKey(branch, index, master);
+  }
+
   /**
    * Derive an address at `index`. Do not increment depth.
    * @param {Number} branch

lib/wallet/common.js

@@ -162,3 +162,21 @@ common.coinSelectionTypes = {
   DB_SWEEPDUST: 'db-sweepdust',
   DB_AGE: 'db-age'
 };
+
+common.AbortError = class AbortError extends Error {
+  constructor(message, options) {
+    super(message, options);
+    this.name = 'AbortError';
+    this.message = 'Operation aborted.';
+
+    if (message)
+      this.message = message;
+
+    if (options.cause)
+      this.message += ` (${options.cause})`;
+
+    if (Error.captureStackTrace) {
+      Error.captureStackTrace(this, common.AbortError);
+    }
+  }
+};