Complete module API expansion: clearAll and batch helpers on every remaining module.

Co-authored-by: Cursor <[email protected]>

consensus-coordination/hyper-p2p-causal-consensus/index.js

@@ -413,6 +413,17 @@ class HyperP2PCausalConsensus extends EventEmitter {
     return n
   }
 
+  clearAll () {
+    const decided = this.clearDecided()
+    const proposals = this.proposals.size
+    this.proposals.clear()
+    this.forksDetected.clear()
+    this.vectorClock.clear()
+    for (const timer of this._proposalTimers.values()) clearTimeout(timer)
+    this._proposalTimers.clear()
+    return { proposals, decided }
+  }
+
   getMetrics () {
     return { ...this._metrics, peers: this.peers.size, pendingProposals: this.proposals.size - this.decidedOrders.size }
   }

consensus-coordination/hyper-p2p-distributed-lock/index.js

@@ -358,6 +358,14 @@ class HyperP2PDistributedLock extends EventEmitter {
     return ids.length
   }
 
+  async clearAll () {
+    const released = await this.releaseAllOwned()
+    const locks = this.locks.size
+    this.locks.clear()
+    this.myLocks.clear()
+    return { released, locks }
+  }
+
   /**
    * List all currently active locks (local + remote).
    * Supports optional filter by owner or resource prefix.

indexes-search/hyper-spatial-index/index.js

@@ -249,6 +249,20 @@ class SpatialIndex extends EventEmitter {
     return n
   }
 
+  async clearAll () {
+    const local = this.clearLocal()
+    return { local }
+  }
+
+  async insertBatch (entries) {
+    if (!Array.isArray(entries)) throw new Error('entries array required')
+    const out = []
+    for (const e of entries) {
+      out.push(await this.insert(e.id, e.x, e.y, e.data || {}))
+    }
+    return out
+  }
+
   hasPoint (id) {
     return this.localPoints.has(String(id))
   }

measurement-rate-control/hyper-p2p-percentile-sketch/index.js

@@ -105,6 +105,10 @@ class HyperP2PPercentileSketch extends EventEmitter {
     return true
   }
 
+  clearAll () {
+    return this.reset()
+  }
+
   summarize () {
     this._sort()
     if (!this._sorted.length) return null

measurement-rate-control/hyper-p2p-sla-budget/index.js

@@ -124,6 +124,15 @@ class HyperP2PSlaBudget extends EventEmitter {
     return true
   }
 
+  clearAll () {
+    return this.reset()
+  }
+
+  consumeBatch (entries) {
+    if (!Array.isArray(entries)) throw new Error('entries array required')
+    return entries.map((e) => this.consume(e.service, e.n ?? 1))
+  }
+
   serviceCount () {
     return this._services.size
   }

messaging-streams/hyper-p2p-stream-chunker/index.js

@@ -47,6 +47,10 @@ class HyperP2PStreamChunker extends EventEmitter {
     return this
   }
 
+  clearAll () {
+    return this.reset()
+  }
+
   flush () {
     if (!this._pending.length) return null
     const tail = this._pending

messaging-streams/hyper-p2p-stream-resume-token/index.js

@@ -112,6 +112,15 @@ class HyperP2PStreamResumeToken extends EventEmitter {
     return this
   }
 
+  clearAll () {
+    return this.reset()
+  }
+
+  writeBatch (chunks) {
+    if (!Array.isArray(chunks)) throw new Error('chunks array required')
+    return chunks.map((c) => this.write(c))
+  }
+
   getStats () {
     return {
       ...this._stats,

messaging-streams/hyper-p2p-stream-transform/index.js

@@ -82,6 +82,10 @@ class HyperP2PStreamTransform extends EventEmitter {
     return n
   }
 
+  clearAll () {
+    return this.clearPending()
+  }
+
   writeBatch (chunks) {
     if (!Array.isArray(chunks)) throw new Error('chunks must be an array')
     let ok = 0

network-stack/hyper-p2p-circuit-loom/index.js

@@ -98,6 +98,15 @@ class HyperP2PCircuitLoom extends EventEmitter {
     return n
   }
 
+  clearAll () {
+    return this.teardownAll()
+  }
+
+  buildCircuitBatch (specs) {
+    if (!Array.isArray(specs)) throw new Error('specs array required')
+    return specs.map((s) => this.buildCircuit(s.hopPeers))
+  }
+
   circuitCount () {
     return this._circuits.size
   }

network-transport/hyper-p2p-udx-metrics/index.js

@@ -64,6 +64,11 @@ class HyperP2PUdxMetrics extends EventEmitter {
     this._recvWindow = []
   }
 
+  clearAll () {
+    this.resetTotals()
+    return true
+  }
+
   setWindowMs (ms) {
     if (ms < 100) throw new Error('windowMs must be >= 100')
     this.windowMs = ms | 0

pear-platform/hyper-bare-argv-bridge/index.js

@@ -101,6 +101,11 @@ class HyperBareArgvBridge extends EventEmitter {
     return this.setArgv(argv)
   }
 
+  clearAll () {
+    this.clearFlags()
+    return this.resetArgv([])
+  }
+
   getStats () {
     return platformStats(this._stats, PROTOCOL, {
       flags: this._flags.size,

pear-platform/hyper-bare-headless-ui/index.js

@@ -87,6 +87,11 @@ class HyperBareHeadlessUi extends EventEmitter {
     this.emit('teardown')
   }
 
+  clearAll () {
+    this.teardown()
+    return true
+  }
+
   pipeChannels () {
     return this._pipe ? [...this._pipe.channels] : []
   }

pear-platform/hyper-bare-process-spawn/index.js

@@ -106,6 +106,18 @@ class HyperBareProcessSpawn extends EventEmitter {
     return n
   }
 
+  clearAll () {
+    this.killAll()
+    const n = this._children.size
+    this._children.clear()
+    return n
+  }
+
+  spawnPlanBatch (plans) {
+    if (!Array.isArray(plans)) throw new Error('plans array required')
+    return plans.map((plan) => this.spawnPlan(plan))
+  }
+
   waitFor (id, timeoutMs = 0) {
     const c = this.getChild(id)
     if (!c) return Promise.resolve(null)

pear-platform/hyper-bare-target-matrix/index.js

@@ -98,6 +98,10 @@ class HyperBareTargetMatrix extends EventEmitter {
     return this.list()
   }
 
+  clearAll () {
+    return this.resetToDefaults()
+  }
+
   targetCount () {
     return this._targets.length
   }

pear-platform/hyper-pear-applink-config/index.js

@@ -83,6 +83,12 @@ class HyperPearApplinkConfig extends EventEmitter {
     return this.load(pkg)
   }
 
+  clearAll () {
+    const had = this._config != null
+    this._config = null
+    return had
+  }
+
   isLoaded () {
     return this._config != null
   }

pear-platform/hyper-pear-trust-gate/index.js

@@ -36,6 +36,10 @@ class HyperPearTrustGate extends EventEmitter {
     return n
   }
 
+  clearAll () {
+    return this.untrustAll()
+  }
+
   check (key, autoTrust = false) {
     const k = String(key)
     this._stats.checks++
@@ -88,12 +92,6 @@ class HyperPearTrustGate extends EventEmitter {
     return this._trusted.size
   }
 
-  untrustAll () {
-    const n = this._trusted.size
-    this._trusted.clear()
-    return n
-  }
-
   checkBatch (keys, autoTrust = false) {
     if (!Array.isArray(keys)) throw new Error('keys must be an array')
     return keys.map((k) => this.check(k, autoTrust))

pear-platform/hyper-pear-update-gossip/index.js

@@ -88,6 +88,13 @@ class HyperPearUpdateGossip extends EventEmitter {
     return n
   }
 
+  clearAll () {
+    const subs = this.unsubscribeAll()
+    const history = this.clearHistory()
+    this._latest = null
+    return { subs, history }
+  }
+
   _notify (update) {
     for (const fn of this._subs) {
       try { fn(update) } catch (_) { /* ignore */ }

routing-paths/hyper-p2p-pattern-router/index.js

@@ -105,6 +105,10 @@ class HyperP2PPatternRouter extends EventEmitter {
     return n
   }
 
+  clearAll () {
+    return this.clearRoutes()
+  }
+
   async ready () {
     if (this.swarm || !this.topic) return this
     await initModuleSwarm(this, {

scheduling-queues/hyper-p2p-peer-scheduler/index.js

@@ -70,6 +70,10 @@ class HyperP2PPeerScheduler extends EventEmitter {
     return ids.length
   }
 
+  clearAll () {
+    return this.cancelAll()
+  }
+
   jobIds () {
     return [...this._jobs.keys()]
   }

storage-hyperbee/hyper-p2p-bee-batch-write/index.js

@@ -101,6 +101,10 @@ class HyperP2PBeeBatchWrite extends EventEmitter {
     return this.rollbackBatch()
   }
 
+  clearAll () {
+    return this.clearPending()
+  }
+
   bufferPutMany (entries) {
     if (!Array.isArray(entries)) throw new Error('entries must be an array')
     let n = 0

storage-hypercore/hyper-p2p-core-merkle-sync/index.js

@@ -133,6 +133,15 @@ class HyperP2PCoreMerkleSync extends EventEmitter {
     return n
   }
 
+  clearAll () {
+    return this.clearRanges()
+  }
+
+  applyRangeBatch (ranges) {
+    if (!Array.isArray(ranges)) throw new Error('ranges array required')
+    return ranges.map((range) => this.applyRange(range))
+  }
+
   _onGossip (d) {
     if (!d) return
     if (d.type === 'merkle-ranges' && Array.isArray(d.ranges)) {

trust-security/hyper-p2p-blind-pair-handoff/index.js

@@ -95,6 +95,17 @@ class HyperP2PBlindPairHandoff extends EventEmitter {
     return n
   }
 
+  clearAll () {
+    const n = this._handoffs.size
+    this._handoffs.clear()
+    return n
+  }
+
+  offerHandoffBatch (entries) {
+    if (!Array.isArray(entries)) throw new Error('entries array required')
+    return entries.map((e) => this.offerHandoff(e.sessionId, e.targetPeer))
+  }
+
   sessionIds () {
     return [...this._handoffs.keys()]
   }