Complete module API expansion: snapshot() on all remaining modules.

Adds snapshot(), clearAll aliases, and batch helpers across storage (hyperbee, hypercore, hyperdrive, autobase), indexes, pear-platform, trust, routing intent-router, and temporal-index.

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

indexes-search/hyper-p2p-semantic-vector-index/index.js

@@ -640,6 +640,10 @@ class HyperP2PSemanticVectorIndex extends EventEmitter {
     }
     return n
   }
+
+  async snapshot () {
+    return { ...this.getMetrics(), vectorIds: this.vectorIds().length }
+  }
 }
 
 module.exports = HyperP2PSemanticVectorIndex

indexes-search/hyper-p2p-similarity-lsh/index.js

@@ -166,6 +166,10 @@ class HyperP2PSimilarityLsh extends EventEmitter {
     return items.map((it) => this.embed(it.id, it.vector))
   }
 
+  snapshot () {
+    return { vectors: this._vectors.size, buckets: this._buckets.size }
+  }
+
   getStats () {
     return {
       ...this._stats,

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

@@ -271,6 +271,10 @@ class SpatialIndex extends EventEmitter {
     return [...this.localPoints.keys()]
   }
 
+  async snapshot () {
+    return { points: this.localPoints.size, ids: this.pointIds() }
+  }
+
   getStats () {
     return {
       ...this._stats,

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

@@ -109,6 +109,11 @@ class HyperP2PPercentileSketch extends EventEmitter {
     return this.reset()
   }
 
+  snapshot () {
+    const s = this.summarize()
+    return s || { samples: 0 }
+  }
+
   summarize () {
     this._sort()
     if (!this._sorted.length) return null

pear-platform/hyper-bare-addon-resolve/index.js

@@ -95,6 +95,10 @@ class HyperBareAddonResolve extends EventEmitter {
     return names.map((n) => this.resolve(n))
   }
 
+  snapshot () {
+    return { addons: this._addons.size, platform: this.platform }
+  }
+
   getStats () {
     return platformStats(this._stats, PROTOCOL, {
       addons: this._addons.size,

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

@@ -106,6 +106,10 @@ class HyperBareArgvBridge extends EventEmitter {
     return this.resetArgv([])
   }
 
+  snapshot () {
+    return { flags: this._flags.size, rest: this._rest.length, targets: this.launchTargets().length }
+  }
+
   getStats () {
     return platformStats(this._stats, PROTOCOL, {
       flags: this._flags.size,

pear-platform/hyper-bare-entry-runner/index.js

@@ -139,6 +139,10 @@ class HyperBareEntryRunner extends EventEmitter {
     return n
   }
 
+  snapshot () {
+    return { runs: this._runs.size, active: this.listRuns('running').length }
+  }
+
   getStats () {
     return platformStats(this._stats, PROTOCOL, {
       active: this.listRuns('running').length,

pear-platform/hyper-bare-import-map/index.js

@@ -102,6 +102,10 @@ class HyperBareImportMap extends EventEmitter {
     return n
   }
 
+  snapshot () {
+    return { entries: Object.keys(this._imports).length }
+  }
+
   getStats () {
     return platformStats(this._stats, PROTOCOL, { entries: Object.keys(this._imports).length })
   }

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

@@ -118,6 +118,10 @@ class HyperBareProcessSpawn extends EventEmitter {
     return plans.map((plan) => this.spawnPlan(plan))
   }
 
+  snapshot () {
+    return { children: this._children.size, active: this.activeCount() }
+  }
+
   waitFor (id, timeoutMs = 0) {
     const c = this.getChild(id)
     if (!c) return Promise.resolve(null)

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

@@ -102,6 +102,10 @@ class HyperBareTargetMatrix extends EventEmitter {
     return this.resetToDefaults()
   }
 
+  snapshot () {
+    return { host: this.host, targets: this.targetCount() }
+  }
+
   targetCount () {
     return this._targets.length
   }

pear-platform/hyper-pear-channel-registry/index.js

@@ -107,6 +107,10 @@ class HyperPearChannelRegistry extends EventEmitter {
     return this.unregisterAll()
   }
 
+  snapshot () {
+    return { channels: this._channels.size, aliases: this._aliases.size }
+  }
+
   getStats () {
     return platformStats(this._stats, PROTOCOL, {
       channels: this._channels.size,

pear-platform/hyper-pear-deep-link/index.js

@@ -71,6 +71,10 @@ class HyperPearDeepLink extends EventEmitter {
     return this.clearHistory()
   }
 
+  snapshot () {
+    return { history: this._history.length }
+  }
+
   peek (link) {
     const c = classifyTarget(link)
     let entrypoint = this.defaultEntry

pear-platform/hyper-pear-detached-registry/index.js

@@ -108,6 +108,10 @@ class HyperPearDetachedRegistry extends EventEmitter {
     return n
   }
 
+  snapshot () {
+    return { instances: this._instances.size, alive: this.listAlive().length }
+  }
+
   getStats () {
     return platformStats(this._stats, PROTOCOL, {
       instances: this._instances.size,

pear-platform/hyper-pear-electron-bridge/index.js

@@ -40,6 +40,10 @@ class HyperPearElectronBridge extends EventEmitter {
     return this.unregisterAll()
   }
 
+  snapshot () {
+    return { handlers: this.handlerCount(), renderer: this.renderer }
+  }
+
   handlerCount () {
     return this._channels.size
   }

pear-platform/hyper-pear-link-resolver/index.js

@@ -66,6 +66,10 @@ class HyperPearLinkResolver extends EventEmitter {
     return this.clearCache()
   }
 
+  snapshot () {
+    return { cached: this._cache.size }
+  }
+
   normalize (parts) {
     const href = this.serialize(parts)
     return this.parse(href)

pear-platform/hyper-pear-preflight-sync/index.js

@@ -143,6 +143,10 @@ class HyperPearPreflightSync extends EventEmitter {
     return n
   }
 
+  snapshot () {
+    return { jobs: this._jobs.size, pending: this.listPending().length }
+  }
+
   getStats () {
     return platformStats(this._stats, PROTOCOL, {
       jobs: this._jobs.size,

pear-platform/hyper-pear-runtime-session/index.js

@@ -94,6 +94,10 @@ class HyperPearRuntimeSession extends EventEmitter {
     return n
   }
 
+  snapshot () {
+    return { total: this._sessions.size, active: this.activeSessions().length }
+  }
+
   getStats () {
     return {
       ...this._stats,

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

@@ -74,6 +74,10 @@ class HyperPearTrustGate extends EventEmitter {
     return { trusted: this.listTrusted(), askByDefault: this.askByDefault, strict: this.strict }
   }
 
+  snapshot () {
+    return this.exportSnapshot()
+  }
+
   importSnapshot (snap) {
     if (!snap || !Array.isArray(snap.trusted)) throw new Error('invalid snapshot')
     this._trusted = new Set(snap.trusted.map(String))

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

@@ -95,6 +95,10 @@ class HyperPearUpdateGossip extends EventEmitter {
     return { subs, history }
   }
 
+  snapshot () {
+    return { subscribers: this._subs.size, hasLatest: !!this._latest }
+  }
+
   _notify (update) {
     for (const fn of this._subs) {
       try { fn(update) } catch (_) { /* ignore */ }

pear-platform/hyper-pear-worker-pipe/index.js

@@ -110,6 +110,10 @@ class HyperPearWorkerPipe extends EventEmitter {
     return this.closeAll()
   }
 
+  snapshot () {
+    return { pipes: this._pipes.size }
+  }
+
   getStats () {
     return platformStats(this._stats, PROTOCOL, { pipes: this._pipes.size })
   }

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

@@ -442,6 +442,14 @@ class HyperP2PIntentRouter extends EventEmitter {
     return ids.length
   }
 
+  async clearAll () {
+    return this.unregisterAll()
+  }
+
+  snapshot () {
+    return this.intentCounts()
+  }
+
   getPeerIntents (peerHex = null) {
     if (peerHex) {
       const p = this.peerIntents.get(peerHex)

storage-autobase/hyper-p2p-autobase-fork-choice/index.js

@@ -130,6 +130,10 @@ class HyperP2PAutobaseForkChoice extends EventEmitter {
     }
   }
 
+  snapshot () {
+    return { views: this._views.size, chosen: this._chosen }
+  }
+
   getStats () {
     return autobaseStats(this._stats, PROTOCOL, {
       views: this._views.size,

storage-autobase/hyper-p2p-autobase-indexer-bus/index.js

@@ -126,6 +126,10 @@ class HyperP2PAutobaseIndexerBus extends EventEmitter {
     this._deliver(d.evt)
   }
 
+  snapshot () {
+    return { pending: this._queue.length, subscribers: this._subs.size }
+  }
+
   getStats () {
     return autobaseStats(this._stats, PROTOCOL, {
       pending: this._queue.length,

storage-autobase/hyper-p2p-autobase-light-writer/index.js

@@ -103,6 +103,10 @@ class HyperP2PAutobaseLightWriter extends EventEmitter {
     return this.clearPending()
   }
 
+  snapshot () {
+    return { pending: this._ops.length, maxBatch: this.maxBatch }
+  }
+
   getStats () {
     return autobaseStats(this._stats, PROTOCOL, {
       pending: this._ops.length,

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

@@ -114,6 +114,10 @@ class HyperP2PBeeBatchWrite extends EventEmitter {
     return n
   }
 
+  snapshot () {
+    return { pending: this._ops.length }
+  }
+
   getStats () {
     return beeStats(this._stats, PROTOCOL, { pending: this._ops.length })
   }

storage-hyperbee/hyper-p2p-bee-diff-follow/index.js

@@ -111,6 +111,10 @@ class HyperP2PBeeDiffFollow extends EventEmitter {
     return this._cursor
   }
 
+  snapshot () {
+    return { cursor: this._cursor, buffered: this._buffer.length, behind: this.behindCount() }
+  }
+
   getStats () {
     return beeStats(this._stats, PROTOCOL, {
       cursor: this._cursor,

storage-hyperbee/hyper-p2p-bee-range-watch/index.js

@@ -103,6 +103,10 @@ class HyperP2PBeeRangeWatch extends EventEmitter {
     return this._watches.size
   }
 
+  snapshot () {
+    return { watches: this._watches.size }
+  }
+
   getStats () {
     return beeStats(this._stats, PROTOCOL, { active: this._watches.size })
   }

storage-hyperbee/hyper-p2p-bee-secondary-index/index.js

@@ -104,6 +104,10 @@ class HyperP2PBeeSecondaryIndex extends EventEmitter {
     return this.indexPutMany(pairs)
   }
 
+  snapshot () {
+    return { keys: this._index.size, primaries: this.totalPrimaries(), indexName: this.indexName }
+  }
+
   getStats () {
     return beeStats(this._stats, PROTOCOL, {
       secondaryKeys: this._index.size,

storage-hyperbee/hyper-p2p-bee-tombstone-gc/index.js

@@ -90,6 +90,10 @@ class HyperP2PBeeTombstoneGc extends EventEmitter {
     return oldest
   }
 
+  snapshot () {
+    return { tombstones: this._tombstones.size }
+  }
+
   getStats () {
     return beeStats(this._stats, PROTOCOL, { pending: this._tombstones.size })
   }

storage-hypercore/hyper-p2p-core-audit-chain/index.js

@@ -117,6 +117,10 @@ class HyperP2PCoreAuditChain extends EventEmitter {
     return this.verifyChain()
   }
 
+  snapshot () {
+    return { length: this._chain.length, head: this._headHash }
+  }
+
   getStats () {
     return coreStats(this._stats, PROTOCOL, {
       length: this._chain.length,

storage-hypercore/hyper-p2p-core-bitfield-scheduler/index.js

@@ -111,6 +111,10 @@ class HyperP2PCoreBitfieldScheduler extends EventEmitter {
     return { queue: q, served: s }
   }
 
+  snapshot () {
+    return { pending: this._queue.length, served: this._served.size }
+  }
+
   getStats () {
     return coreStats(this._stats, PROTOCOL, {
       pending: this._queue.length,

storage-hypercore/hyper-p2p-core-fork-picker/index.js

@@ -102,6 +102,10 @@ class HyperP2PCoreForkPicker extends EventEmitter {
     return n
   }
 
+  snapshot () {
+    return { forks: this._forks.size, chosen: this._chosen }
+  }
+
   getStats () {
     return coreStats(this._stats, PROTOCOL, {
       forkCount: this._forks.size,

storage-hypercore/hyper-p2p-core-priority-fetch/index.js

@@ -114,6 +114,10 @@ class HyperP2PCorePriorityFetch extends EventEmitter {
     return this._inflight.size
   }
 
+  snapshot () {
+    return { pending: this._heap.length, inflight: this._inflight.size }
+  }
+
   getStats () {
     return coreStats(this._stats, PROTOCOL, {
       pending: this._heap.length,

storage-hypercore/hyper-p2p-core-replicator/index.js

@@ -106,6 +106,10 @@ class HyperP2PCoreReplicator extends EventEmitter {
     this.emit('remote-policy', data)
   }
 
+  snapshot () {
+    return { policies: this.policyCount() }
+  }
+
   getStats () {
     return coreStats(this._stats, PROTOCOL, {
       policyCount: this._policies.size,

storage-hypercore/hyper-p2p-core-seed-policy/index.js

@@ -107,6 +107,10 @@ class HyperP2PCoreSeedPolicy extends EventEmitter {
     return n
   }
 
+  snapshot () {
+    return { policies: this._policies.size }
+  }
+
   getStats () {
     return coreStats(this._stats, PROTOCOL, {
       policyCount: this._policies.size,

storage-hyperdrive/hyper-p2p-drive-gc-sweep/index.js

@@ -97,6 +97,10 @@ class HyperP2PDriveGcSweep extends EventEmitter {
     }
   }
 
+  snapshot () {
+    return { stale: this._stale.size, swept: this._swept.length }
+  }
+
   getStats () {
     return driveStats(this._stats, PROTOCOL, {
       stale: this._stale.size,

storage-hyperdrive/hyper-p2p-drive-mirror-sync/index.js

@@ -100,6 +100,10 @@ class HyperP2PDriveMirrorSync extends EventEmitter {
     }
   }
 
+  snapshot () {
+    return { pending: this._queue.length, tracked: this._progress.size }
+  }
+
   getStats () {
     return driveStats(this._stats, PROTOCOL, {
       pending: this._queue.length,

storage-hyperdrive/hyper-p2p-drive-version-snapshot/index.js

@@ -103,6 +103,14 @@ class HyperP2PDriveVersionSnapshot extends EventEmitter {
     if (!prev || d.snap.at >= prev.at) this._snapshots.set(d.snap.id, d.snap)
   }
 
+  stateSnapshot () {
+    return { ids: this.snapshotIds(), count: this.snapshotCount() }
+  }
+
+  snapshot () {
+    return this.stateSnapshot()
+  }
+
   getStats () {
     return driveStats(this._stats, PROTOCOL, { snapshots: this._snapshots.size })
   }

storage-hyperdrive/hyper-p2p-drive-watch-notify/index.js

@@ -100,6 +100,10 @@ class HyperP2PDriveWatchNotify extends EventEmitter {
     }
   }
 
+  snapshot () {
+    return { watches: this._watches.size }
+  }
+
   getStats () {
     return driveStats(this._stats, PROTOCOL, { active: this._watches.size })
   }

time-ordering/hyper-p2p-temporal-index/index.js

@@ -405,6 +405,10 @@ class HyperP2PTemporalIndex extends EventEmitter {
     return n
   }
 
+  async snapshot () {
+    return { events: this.events.size, buckets: this.timeIndex.size }
+  }
+
   getStats () {
     return {
       events: this.events.size,

trust-security/hyper-p2p-encrypted-topic/index.js

@@ -82,6 +82,19 @@ class HyperP2PEncryptedTopic extends EventEmitter {
     return n
   }
 
+  clearAll () {
+    return this.unregisterAll()
+  }
+
+  snapshot () {
+    return { topics: this.listTopics(), count: this._topics.size }
+  }
+
+  registerTopicBatch (entries) {
+    if (!Array.isArray(entries)) throw new Error('entries array required')
+    return entries.map((e) => this.registerTopic(e.topicId, e.keyHint))
+  }
+
   rotateHint (topicId, newHint) {
     assertNonEmpty(topicId, 'topicId')
     assertNonEmpty(newHint, 'newHint')

trust-security/hyper-p2p-reputation-system/index.js

@@ -327,6 +327,10 @@ class HyperP2PReputationSystem extends EventEmitter {
     return peers.length
   }
 
+  snapshot () {
+    return { peers: this.scores.size }
+  }
+
   getHistory (peerId, limit = 50) {
     this.metrics.queries++
     const targetHex = typeof peerId === 'string' ? peerId : b4a.toString(peerId, 'hex')

trust-security/hyper-p2p-session-rotation/index.js

@@ -87,6 +87,10 @@ class HyperP2PSessionRotation extends EventEmitter {
     return this.revokeAll()
   }
 
+  snapshot () {
+    return { sessions: this._sessions.size }
+  }
+
   rotateSessionBatch (entries) {
     if (!Array.isArray(entries)) throw new Error('entries array required')
     return entries.map((e) => this.rotateSession(e.sessionId, e.newToken))