Add isEmpty() helpers across all modules with clearable state.

Seventh expansion pass: domain-specific isEmpty() after moduleSnapshot on every module that has clearAll(), using existing count/snapshot helpers (async variants for temporal, spatial, semantic-vector, and reactive-state indexes).

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

agents-workflows/hyper-p2p-agent-memory/index.js

@@ -462,6 +462,10 @@ class HyperP2PAgentMemory extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.memoryCount() === 0
+  }
+
   async storeMemoryBatch (entries) {
     if (!Array.isArray(entries)) throw new Error('entries array required')
     const out = []

agents-workflows/hyper-p2p-task-orchestrator/index.js

@@ -467,6 +467,10 @@ class HyperP2PTaskOrchestrator extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.tasks.size === 0
+  }
+
   getStats () {
     const counts = this.taskCounts()
     return {

agents-workflows/hyper-p2p-workflow-graph/index.js

@@ -197,6 +197,10 @@ class HyperP2PWorkflowGraph extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.nodeCount() === 0
+  }
+
   nodeIds () {
     return [...this._nodes.keys()]
   }

applications-collab/hyper-p2p-collab-room/index.js

@@ -176,6 +176,10 @@ class HyperP2PCollabRoom extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.roomCount() === 0
+  }
+
   _onGossip (data) {
     if (!data || !data.type) return
     this._stats.gossipIn++

applications-collab/hyper-p2p-cursor-presence/index.js

@@ -122,6 +122,10 @@ class HyperP2PCursorPresence extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.cursorCount() === 0
+  }
+
   _onGossip (data) {
     if (!data) return
     this._stats.gossipIn++

applications-collab/hyper-p2p-document-line-lock/index.js

@@ -116,6 +116,10 @@ class HyperP2PDocumentLineLock extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.lockCount() === 0
+  }
+
   acquireBatch (entries) {
     if (!Array.isArray(entries)) throw new Error('entries array required')
     return entries.map((e) => this.acquire(e.docId, e.line))

applications-collab/hyper-p2p-whiteboard-op/index.js

@@ -114,6 +114,10 @@ class HyperP2PWhiteboardOp extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.opCount() === 0
+  }
+
   applyBatch (entries) {
     if (!Array.isArray(entries)) throw new Error('entries array required')
     return entries.map((e) => this.apply(e.roomId, e.op))

applications-economy/hyper-p2p-auction-gossip/index.js

@@ -149,6 +149,10 @@ class HyperP2PAuctionGossip extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.snapshot().auctions === 0
+  }
+
   openAuctionBatch (entries) {
     if (!Array.isArray(entries)) throw new Error('entries array required')
     return entries.map((e) => this.openAuction(e.auctionId, e.meta || {}))

applications-economy/hyper-p2p-credit-ledger/index.js

@@ -118,6 +118,10 @@ class HyperP2PCreditLedger extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.accountCount() === 0
+  }
+
   _apply (accountId, delta, kind, reason) {
     assertNonEmpty(accountId, 'accountId')
     const acct = this._accounts.get(accountId)

applications-economy/hyper-p2p-marketplace-listing/index.js

@@ -129,6 +129,10 @@ class HyperP2PMarketplaceListing extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.snapshot().listings === 0
+  }
+
   createListingBatch (entries) {
     if (!Array.isArray(entries)) throw new Error('entries array required')
     return entries.map((e) => this.createListing(e.listingId, e.listing))

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

@@ -445,6 +445,10 @@ class HyperP2PCausalConsensus extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.proposals.size === 0 && this.decidedOrders.size === 0
+  }
+
   async proposeBatch (entries) {
     if (!Array.isArray(entries)) throw new Error('entries array required')
     const out = []

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

@@ -386,6 +386,10 @@ class HyperP2PDistributedLock extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.lockCount() === 0
+  }
+
   async acquireBatch (entries) {
     if (!Array.isArray(entries)) throw new Error('entries array required')
     const out = []

consensus-coordination/hyper-p2p-leader-lease/index.js

@@ -160,6 +160,10 @@ class HyperP2PLeaderLease extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return !this._leader && this.followerCount() === 0
+  }
+
   _gossipSync () {
     gossipSend(this, {
       type: 'leader-lease-sync',

consensus-coordination/hyper-p2p-quorum-pool/index.js

@@ -210,6 +210,10 @@ class HyperP2PQuorumPool extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.proposalCount() === 0
+  }
+
   proposeBatch (payloads, opts = {}) {
     if (!Array.isArray(payloads)) throw new Error('payloads array required')
     return payloads.map((payload) => this.propose(payload, opts))

consensus-coordination/hyper-p2p-raft-lite/index.js

@@ -99,6 +99,10 @@ class HyperP2PRaftLite extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.snapshot().logLength === 0
+  }
+
   logEntryAt (index) {
     return this._log[index] || null
   }

core-infrastructure/hyper-p2p-capabilities/index.js

@@ -279,6 +279,11 @@ class CapabilityManager extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    const s = this.snapshot()
+    return s.issued === 0 && s.received === 0 && s.revoked === 0
+  }
+
   issueBatch (entries) {
     if (!Array.isArray(entries)) throw new Error('entries array required')
     return entries.map((e) => this.issue(e.subjectPubKey, e.resource, e.actions, e.ttlMs))

core-infrastructure/hyper-p2p-presence/index.js

@@ -364,6 +364,10 @@ class HyperP2PPresence extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.peers.size <= 1
+  }
+
   announceNow () {
     this._broadcastPresence()
     return this.getSelf()

core-infrastructure/hyper-p2p-rpc/index.js

@@ -160,6 +160,10 @@ class RPCServer extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.connectionCount() === 0 && this.pendingCount() === 0
+  }
+
   connectionCount () { return this.connections.size }
 
   getStats () {

core-infrastructure/hyper-p2p-session-bridge/index.js

@@ -97,6 +97,10 @@ class HyperP2PSessionBridge extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.pairCount() === 0
+  }
+
   async createPairBatch (count = 1) {
     const n = Math.max(1, count | 0)
     const out = []

core-infrastructure/hyper-p2p-vector-clock/index.js

@@ -357,6 +357,10 @@ class HyperP2PVectorClock extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.peerCount() === 0
+  }
+
   clearAll () {
     const n = this.clock.size
     this.clock.clear()

encoding-wire/hyper-p2p-compact-codec-bridge/index.js

@@ -97,6 +97,11 @@ class HyperP2PCompactCodecBridge extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    const s = this._stats
+    return s.encode === 0 && s.decode === 0 && s.frames === 0
+  }
+
   getStats () {
     return {
       ...this._stats,

encoding-wire/hyper-p2p-message-envelope/index.js

@@ -129,6 +129,11 @@ class HyperP2PMessageEnvelope extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    const s = this._stats
+    return s.wrapped === 0 && s.unwrapped === 0 && s.encoded === 0 && s.decoded === 0 && s.failed === 0
+  }
+
   getStats () {
     return { ...this._stats, protocol: PROTOCOL }
   }

encoding-wire/hyper-p2p-schema-validator/index.js

@@ -122,6 +122,10 @@ class HyperP2PSchemaValidator extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.listSchemas().length === 0
+  }
+
   registerSchemaBatch (entries) {
     if (!Array.isArray(entries)) throw new Error('entries array required')
     return entries.map((e) => this.register(e.name, e.schema))

encoding-wire/hyper-p2p-wire-registry/index.js

@@ -158,6 +158,10 @@ class HyperP2PWireRegistry extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this._codecs.size === 0 && this._protocols.size === 0
+  }
+
   clearAll () {
     const codecs = this.clearAllCodecs()
     const protocols = this.unregisterAllProtocols()

experimental/hyper-p2p-contradiction-graph/index.js

@@ -149,6 +149,10 @@ class HyperP2PContradictionGraph extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this._claims.length === 0
+  }
+
   async ready () {
     if (this.swarm || !this.topic) return this
     await initModuleSwarm(this, {

experimental/hyper-p2p-entropy-beacon/index.js

@@ -93,6 +93,10 @@ class HyperP2PEntropyBeacon extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.snapshot().contributions === 0
+  }
+
   contributionCount () {
     return this._contributions
   }

experimental/hyper-p2p-entropy-spiral/index.js

@@ -71,6 +71,10 @@ class HyperP2PEntropySpiral extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.snapshot().samples.length === 0
+  }
+
   sampleBatch (seeds) {
     if (!Array.isArray(seeds)) throw new Error('seeds array required')
     return seeds.map((seed) => this.sampleEntropy(seed))

experimental/hyper-p2p-gravity-well/index.js

@@ -128,6 +128,10 @@ class HyperP2PGravityWell extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.snapshot().wells.length === 0
+  }
+
   async ready () {
     if (this.swarm || !this.topic) return this
     await initModuleSwarm(this, {

experimental/hyper-p2p-memetic-spread/index.js

@@ -112,6 +112,10 @@ class HyperP2PMemeticSpread extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.snapshot().totalMemes === 0
+  }
+
   _gossip (data) {
     if (!this._peerMsgs) return
     gossipSend(this, data)

experimental/hyper-p2p-mirror-realm/index.js

@@ -151,6 +151,11 @@ class HyperP2PMirrorRealm extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    const s = this.snapshot()
+    return s.realmA.length === 0 && s.realmB.length === 0
+  }
+
   async ready () {
     if (this.swarm || !this.topic) return this
     await initModuleSwarm(this, {

experimental/hyper-p2p-mycelium-pool/index.js

@@ -130,6 +130,10 @@ class HyperP2PMyceliumPool extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.snapshot().balances.length === 0
+  }
+
   donateBatch (entries) {
     if (!Array.isArray(entries)) throw new Error('entries array required')
     return entries.map((e) => this.donate(e.peerId, e.credits))

experimental/hyper-p2p-paradox-clock/index.js

@@ -129,6 +129,10 @@ class HyperP2PParadoxClock extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.snapshot().stamps.length === 0
+  }
+
   stampBatch (eventIds, opts = {}) {
     if (!Array.isArray(eventIds)) throw new Error('eventIds array required')
     return eventIds.map((id) => this.stamp(id, opts))

experimental/hyper-p2p-paradox-merge/index.js

@@ -105,6 +105,11 @@ class HyperP2PParadoxMerge extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    const s = this.snapshot()
+    return s.open === 0 && s.resolved === 0
+  }
+
   branchBatch (entries) {
     if (!Array.isArray(entries)) throw new Error('entries array required')
     return entries.map((e) => this.branch(e.id, e.value))

experimental/hyper-p2p-phase-shift-clock/index.js

@@ -116,6 +116,10 @@ class HyperP2PPhaseShiftClock extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return Object.keys(this.snapshot().peers).length === 0
+  }
+
   shiftBatch (entries) {
     if (!Array.isArray(entries)) throw new Error('entries array required')
     return entries.map((e) => this.shift(e.phaseMs))

experimental/hyper-p2p-pheromone-trail/index.js

@@ -126,6 +126,10 @@ class HyperP2PPheromoneTrail extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.trailCount() === 0
+  }
+
   depositBatch (entries) {
     if (!Array.isArray(entries)) throw new Error('entries array required')
     return entries.map((e) => this.deposit(e.pathId, e.strength, e.dest))

experimental/hyper-p2p-silence-protocol/index.js

@@ -120,6 +120,10 @@ class HyperP2PSilenceProtocol extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.listAbsent().length === 0
+  }
+
   async ready () {
     if (this.swarm || !this.topic) return this
     await initModuleSwarm(this, {

experimental/hyper-p2p-tension-field/index.js

@@ -165,6 +165,10 @@ class HyperP2PTensionField extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.snapshot().cells === 0
+  }
+
   getStats () {
     return experimentalStats(this._stats, PROTOCOL, {
       cells: this._field.size,

experimental/hyper-p2p-time-capsule/index.js

@@ -164,6 +164,10 @@ class HyperP2PTimeCapsule extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.snapshot().total === 0
+  }
+
   sealBatch (entries) {
     if (!Array.isArray(entries)) throw new Error('entries array required')
     return entries.map((e) => this.seal(e.payload, e.opts || {}))

experimental/hyper-p2p-void-channel/index.js

@@ -92,6 +92,10 @@ class HyperP2PVoidChannel extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.snapshot().voids.length === 0
+  }
+
   unsubscribeAll () {
     const n = this._subs.size
     this._subs.clear()

experimental/hyper-p2p-whisper-mesh/index.js

@@ -111,6 +111,10 @@ class HyperP2PWhisperMesh extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.snapshot().seen === 0
+  }
+
   async ready () {
     if (this.swarm || !this.topic) return this
     await initModuleSwarm(this, {

indexes-search/hyper-p2p-bloom-gossip/index.js

@@ -118,6 +118,10 @@ class HyperP2PBloomGossip extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.snapshot().size === 0
+  }
+
   addBatch (keys) {
     if (!Array.isArray(keys)) throw new Error('keys array required')
     return keys.map((k) => this.add(k))

indexes-search/hyper-p2p-fulltext-lite/index.js

@@ -165,6 +165,10 @@ class HyperP2PFulltextLite extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.snapshot().documents === 0
+  }
+
   searchBatch (queries, mode = 'and') {
     if (!Array.isArray(queries)) throw new Error('queries array required')
     return queries.map((q) => this.search(q, mode))

indexes-search/hyper-p2p-graph-index/index.js

@@ -163,6 +163,10 @@ class HyperP2PGraphIndex extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.snapshot().edges.length === 0
+  }
+
   addEdgeBatch (edges) {
     if (!Array.isArray(edges)) throw new Error('edges array required')
     return edges.map((e) => this.addEdge(e.from, e.to))

indexes-search/hyper-p2p-inverted-index/index.js

@@ -142,6 +142,10 @@ class HyperP2PInvertedIndex extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.snapshot().documents === 0
+  }
+
   indexBatch (entries) {
     if (!Array.isArray(entries)) throw new Error('entries array required')
     return entries.map((e) => this.index(e.docId, e.terms))

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

@@ -656,6 +656,11 @@ class HyperP2PSemanticVectorIndex extends EventEmitter {
   async moduleSnapshot () {
     return this.snapshot()
   }
+
+  async isEmpty () {
+    const s = await this.snapshot()
+    return s.vectorIds === 0
+  }
 }
 
 module.exports = HyperP2PSemanticVectorIndex

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

@@ -182,6 +182,11 @@ class HyperP2PSimilarityLsh extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    const s = this.snapshot()
+    return s.vectors === 0 && s.buckets === 0
+  }
+
   getStats () {
     return {
       ...this._stats,

indexes-search/hyper-p2p-trie-prefix/index.js

@@ -141,6 +141,10 @@ class HyperP2PTriePrefix extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.snapshot().words === 0
+  }
+
   getStats () {
     return {
       ...this._stats,

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

@@ -287,6 +287,11 @@ class SpatialIndex extends EventEmitter {
     return this.snapshot()
   }
 
+  async isEmpty () {
+    const s = await this.snapshot()
+    return s.points === 0
+  }
+
   getStats () {
     return {
       ...this._stats,

measurement-rate-control/hyper-p2p-bucket-rate-limit/index.js

@@ -48,6 +48,10 @@ class HyperP2PBucketRateLimit extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return Object.keys(this.snapshot().buckets).length === 0
+  }
+
   _bucketSnapshot () {
     const out = {}
     for (const [peerId, b] of this._buckets) {

measurement-rate-control/hyper-p2p-histogram-gossip/index.js

@@ -100,6 +100,10 @@ class HyperP2PHistogramGossip extends EventEmitter {
     }
   }
 
+  isEmpty () {
+    return this._metrics.size === 0
+  }
+
   toJSON () {
     return this.moduleSnapshot()
   }

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

@@ -126,6 +126,10 @@ class HyperP2PPercentileSketch extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.snapshot().samples === 0
+  }
+
   summarize () {
     this._sort()
     if (!this._sorted.length) return null

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

@@ -119,6 +119,10 @@ class HyperP2PSlaBudget extends EventEmitter {
     }
   }
 
+  isEmpty () {
+    return this.serviceCount() === 0
+  }
+
   toJSON () {
     return this.moduleSnapshot()
   }

media-streaming/hyper-p2p-adaptive-streaming-engine/index.js

@@ -137,6 +137,10 @@ class HyperP2PAdaptiveStreamingEngine extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.snapshot().bufferMs === 0
+  }
+
   getStats () {
     return mediaStats(this._stats, PROTOCOL, { recommendation: this._recommendation })
   }

media-streaming/hyper-p2p-bandwidth-aggregator/index.js

@@ -143,6 +143,10 @@ class HyperP2PBandwidthAggregator extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.sourceCount() === 0
+  }
+
   sourceCount () {
     return this._sources.size
   }

media-streaming/hyper-p2p-buffer-health-predictor/index.js

@@ -102,6 +102,10 @@ class HyperP2PBufferHealthPredictor extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.snapshot().samples === 0
+  }
+
   sampleCount () {
     return this._samples.length
   }

media-streaming/hyper-p2p-chunk-scheduler-media/index.js

@@ -121,6 +121,10 @@ class HyperP2PChunkSchedulerMedia extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.snapshot().pending === 0
+  }
+
   enqueueBatch (chunks) {
     if (!Array.isArray(chunks)) throw new Error('chunks array required')
     return chunks.map((chunk) => this.enqueue(chunk))

media-streaming/hyper-p2p-content-protection/index.js

@@ -121,6 +121,10 @@ class HyperP2PContentProtection extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.snapshot().keys === 0
+  }
+
   getStats () {
     return mediaStats(this._stats, PROTOCOL, { activeKeyId: this._activeKeyId, keys: this._keys.size })
   }

media-streaming/hyper-p2p-contribution-ledger/index.js

@@ -110,6 +110,10 @@ class HyperP2PContributionLedger extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.snapshot().contributors === 0
+  }
+
   _gossip (payload) {
     if (this._peerMsgs) {
       gossipSend(this, payload)

media-streaming/hyper-p2p-enterprise-orchestrator/index.js

@@ -130,6 +130,10 @@ class HyperP2PEnterpriseOrchestrator extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.snapshot().count === 0
+  }
+
   getStats () {
     return mediaStats(this._stats, PROTOCOL, { regions: this._regions.size })
   }

media-streaming/hyper-p2p-fec-video/index.js

@@ -119,6 +119,10 @@ class HyperP2PFecVideo extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.snapshot().groups === 0
+  }
+
   getStats () {
     return mediaStats(this._stats, PROTOCOL, { groups: this._groups.size })
   }

media-streaming/hyper-p2p-helper-swarm-coordinator/index.js

@@ -129,6 +129,10 @@ class HyperP2PHelperSwarmCoordinator extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.snapshot().helpers === 0
+  }
+
   registerHelperBatch (entries) {
     if (!Array.isArray(entries)) throw new Error('entries array required')
     return entries.map((e) => this.registerHelper(e.peerId, e.capacityBps))

media-streaming/hyper-p2p-latency-optimizer/index.js

@@ -107,6 +107,10 @@ class HyperP2PLatencyOptimizer extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.snapshot().paths === 0
+  }
+
   measureBatch (entries) {
     if (!Array.isArray(entries)) throw new Error('entries must be an array')
     return entries.map((e) => this.measurePath(e.pathId, e.hops || []))

media-streaming/hyper-p2p-live-edge-manager/index.js

@@ -108,6 +108,10 @@ class HyperP2PLiveEdgeManager extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.snapshot().count === 0
+  }
+
   setLiveEdgeBatch (entries) {
     if (!Array.isArray(entries)) throw new Error('entries array required')
     return entries.map((e) => this.setLiveEdge(e.streamId, e.seq, e.wallAt))

media-streaming/hyper-p2p-media-chunker/index.js

@@ -145,6 +145,10 @@ class HyperP2PMediaChunker extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.snapshot().stored === 0
+  }
+
   getStats () {
     return mediaStats(this._stats, PROTOCOL, { stored: this._chunks.size })
   }

media-streaming/hyper-p2p-media-tree-orchestrator/index.js

@@ -180,6 +180,10 @@ class HyperP2PMediaTreeOrchestrator extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.snapshot().nodes === 0
+  }
+
   _gossip (payload) {
     if (!this._peerMsgs) return
     gossipSend(this, payload)

media-streaming/hyper-p2p-origin-hybrid-bridge/index.js

@@ -116,6 +116,10 @@ class HyperP2POriginHybridBridge extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.snapshot().streams === 0
+  }
+
   registerOriginBatch (entries) {
     if (!Array.isArray(entries)) throw new Error('entries array required')
     return entries.map((e) => this.registerOrigin(e.streamId, e.url, e.weight))

media-streaming/hyper-p2p-peer-selector-streaming/index.js

@@ -138,6 +138,10 @@ class HyperP2PPeerSelectorStreaming extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.snapshot().peers === 0
+  }
+
   registerPeerBatch (entries) {
     if (!Array.isArray(entries)) throw new Error('entries array required')
     return entries.map((e) => this.registerPeer(e.peerId, e.stats || {}))

media-streaming/hyper-p2p-quality-ladder/index.js

@@ -118,6 +118,10 @@ class HyperP2PQualityLadder extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.snapshot().ladders === 0
+  }
+
   getStats () {
     return mediaStats(this._stats, PROTOCOL, { ladders: this._ladders.size })
   }

media-streaming/hyper-p2p-retransmission-media/index.js

@@ -103,6 +103,10 @@ class HyperP2PRetransmissionMedia extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.snapshot().pending === 0
+  }
+
   nackBatch (entries) {
     if (!Array.isArray(entries)) throw new Error('entries array required')
     return entries.map((e) => this.nack(e.streamId, e.seq, e.reason))

media-streaming/hyper-p2p-stream-access-control/index.js

@@ -124,6 +124,10 @@ class HyperP2PStreamAccessControl extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.snapshot().total === 0
+  }
+
   grantCapabilityBatch (entries) {
     if (!Array.isArray(entries)) throw new Error('entries array required')
     return entries.map((e) => this.grantCapability(e.streamId, e.subject, e.ttlMs))

media-streaming/hyper-p2p-stream-manifest/index.js

@@ -121,6 +121,10 @@ class HyperP2PStreamManifest extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.snapshot().count === 0
+  }
+
   buildManifestBatch (entries) {
     if (!Array.isArray(entries)) throw new Error('entries array required')
     return entries.map((e) => this.buildManifest(e.streamId, e.meta || {}))

media-streaming/hyper-p2p-stream-telemetry/index.js

@@ -140,6 +140,10 @@ class HyperP2PStreamTelemetry extends EventEmitter {
     return this.clusterSnapshot()
   }
 
+  isEmpty () {
+    return this.sessionCount() === 0
+  }
+
   getStats () {
     return mediaStats(this._stats, PROTOCOL, { sessions: this._sessions.size })
   }

messaging-gossip/hyper-p2p-dedup-filter/index.js

@@ -167,6 +167,10 @@ class HyperP2PDedupFilter extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.snapshot().size === 0
+  }
+
   restoreSnapshot (snap) {
     if (!snap || !Array.isArray(snap.ids)) throw new Error('invalid snapshot')
     this._seen = new Set(snap.ids)

messaging-gossip/hyper-p2p-distributed-event-bus/index.js

@@ -394,6 +394,11 @@ class HyperP2PDistributedEventBus extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    const s = this.snapshot()
+    return s.topics === 0 && s.subscribers === 0 && this.seenEvents.size === 0
+  }
+
   hasSeen (eventId) {
     return this.seenEvents.has(String(eventId))
   }

messaging-gossip/hyper-p2p-gossip-mesh/index.js

@@ -162,6 +162,10 @@ class HyperP2PGossipMesh extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.seenCount() === 0
+  }
+
   hasSeen (id) {
     return this._seen.has(String(id))
   }

messaging-pubsub/hyper-p2p-qos-topic/index.js

@@ -137,6 +137,12 @@ class HyperP2PQosTopic extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    const s = this.snapshot()
+    return s.channels.length === 0 && s.handlers === 0 &&
+      Object.values(s.queueDepths).every((n) => n === 0)
+  }
+
   _onGossip (data) {
     if (!data || data.type !== 'qos-publish') return
     this._stats.gossipIn++

messaging-pubsub/hyper-p2p-retained-messages/index.js

@@ -109,6 +109,10 @@ class HyperP2PRetainedMessages extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.snapshot().total === 0
+  }
+
   retainBatch (entries) {
     if (!Array.isArray(entries)) throw new Error('entries array required')
     return entries.map((e) => this.retain(e.channel, e.payload, e.opts || {}))

messaging-pubsub/hyper-p2p-subscription-lease/index.js

@@ -157,6 +157,10 @@ class HyperP2PSubscriptionLease extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.snapshot().leases === 0
+  }
+
   acquireBatch (channels) {
     if (!Array.isArray(channels)) throw new Error('channels array required')
     return channels.map((ch) => this.acquire(ch))

messaging-pubsub/hyper-p2p-topic-channel/index.js

@@ -128,6 +128,11 @@ class HyperP2PTopicChannel extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    const s = this.snapshot()
+    return s.channels === 0 && s.retained === 0
+  }
+
   _deliverLocal (channel, payload, meta) {
     const handler = this._subs.get(channel)
     if (handler) {

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

@@ -108,6 +108,11 @@ class HyperP2PStreamBackpressure extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    const s = this.snapshot()
+    return s.bytes === 0 && !s.paused
+  }
+
   writeBatch (chunks) {
     if (!Array.isArray(chunks)) throw new Error('chunks array required')
     return chunks.map((chunk) => this.write(chunk))

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

@@ -67,6 +67,10 @@ class HyperP2PStreamChunker extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.snapshot().pending === 0
+  }
+
   flush () {
     if (!this._pending.length) return null
     const tail = this._pending

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

@@ -139,6 +139,10 @@ class HyperP2PStreamMultiplex extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.snapshot().open === 0
+  }
+
   openStreamBatch (ids) {
     if (!Array.isArray(ids)) throw new Error('ids array required')
     return ids.map((id) => this.openStream(id))

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

@@ -132,6 +132,10 @@ class HyperP2PStreamResumeToken extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.snapshot().tokens === 0
+  }
+
   writeBatch (chunks) {
     if (!Array.isArray(chunks)) throw new Error('chunks array required')
     return chunks.map((c) => this.write(c))

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

@@ -107,6 +107,10 @@ class HyperP2PStreamTee extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.snapshot().branches === 0
+  }
+
   addBranchBatch (names) {
     if (!Array.isArray(names)) throw new Error('names array required')
     return names.map((name) => this.addBranch(name))

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

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

network-discovery/hyper-p2p-capability-discovery/index.js

@@ -83,6 +83,10 @@ class HyperP2PCapabilityDiscovery extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.snapshot().capabilities === 0
+  }
+
   registerCapabilityBatch (entries) {
     if (!Array.isArray(entries)) throw new Error('entries array required')
     return entries.map((e) => this.registerCapability(e.name, e.meta || {}))

network-discovery/hyper-p2p-discovery-health/index.js

@@ -99,6 +99,10 @@ class HyperP2PDiscoveryHealth extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.snapshot().peers === 0
+  }
+
   reportPeerBatch (entries) {
     if (!Array.isArray(entries)) throw new Error('entries array required')
     return entries.map((e) => this.reportPeer(e.peerId, e.status || {}))

network-discovery/hyper-p2p-peer-bootstrap-store/index.js

@@ -89,6 +89,10 @@ class HyperP2PPeerBootstrapStore extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.snapshot().bootstraps === 0
+  }
+
   _gossip (data) {
     if (!this._peerMsgs) return
     gossipSend(this, data)

network-discovery/hyper-p2p-seeder-registry/index.js

@@ -102,6 +102,10 @@ class HyperP2PSeederRegistry extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.snapshot().topics === 0
+  }
+
   _gossip (data) {
     if (!this._peerMsgs) return
     gossipSend(this, data)

network-discovery/hyper-p2p-topic-announcer/index.js

@@ -91,6 +91,10 @@ class HyperP2PTopicAnnouncer extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.snapshot().count === 0
+  }
+
   _gossip (data) {
     if (!this._peerMsgs) return
     gossipSend(this, data)

network-stack/hyper-p2p-anycast-selector/index.js

@@ -110,6 +110,11 @@ class HyperP2PAnycastSelector extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    const s = this.snapshot()
+    return s.tags === 0 && s.latencyPeers === 0
+  }
+
   getStats () {
     return { ...this._stats, tags: this._tags.size, latencyPeers: this._latency.size, protocol: PROTOCOL }
   }

network-stack/hyper-p2p-bandwidth-broker/index.js

@@ -100,6 +100,10 @@ class HyperP2PBandwidthBroker extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.snapshot().peers === 0
+  }
+
   grantBatch (entries) {
     if (!Array.isArray(entries)) throw new Error('entries array required')
     return entries.map((e) => this.grant(e.peerId, e.bytes))

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

@@ -127,6 +127,10 @@ class HyperP2PCircuitLoom extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.snapshot().total === 0
+  }
+
   hopCount (circuitId) {
     const c = this._circuits.get(circuitId)
     return c ? c.hops.length : 0

network-stack/hyper-p2p-congestion-signal/index.js

@@ -96,6 +96,10 @@ class HyperP2PCongestionSignal extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.snapshot().peers === 0
+  }
+
   reportSampleBatch (entries) {
     if (!Array.isArray(entries)) throw new Error('entries array required')
     return entries.map((e) => this.reportSample(e.peerId, e.rttMs, e.loss))

network-stack/hyper-p2p-connection-pool/index.js

@@ -101,6 +101,10 @@ class HyperP2PConnectionPool extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.snapshot().total === 0
+  }
+
   acquireBatch (peerIds) {
     if (!Array.isArray(peerIds)) throw new Error('peerIds array required')
     return peerIds.map((peerId) => this.acquire(peerId))

network-stack/hyper-p2p-flow-shaper/index.js

@@ -121,6 +121,10 @@ class HyperP2PFlowShaper extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.snapshot().queued === 0
+  }
+
   getStats () {
     return {
       ...this._stats,

network-stack/hyper-p2p-link-probe/index.js

@@ -104,6 +104,10 @@ class HyperP2PLinkProbe extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.snapshot().entries === 0
+  }
+
   probeBatch (peerIds) {
     if (!Array.isArray(peerIds)) throw new Error('peerIds array required')
     return peerIds.map((id) => this.probe(id))

network-stack/hyper-p2p-multipath-fanout/index.js

@@ -113,6 +113,10 @@ class HyperP2PMultipathFanout extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.pendingCount() === 0
+  }
+
   fanoutBatch (entries) {
     if (!Array.isArray(entries)) throw new Error('entries array required')
     return entries.map((e) => this.fanout(e.payload, e.pathCount))

network-stack/hyper-p2p-overlay-topology/index.js

@@ -100,6 +100,10 @@ class HyperP2POverlayTopology extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    return this.snapshot().degree === 0
+  }
+
   getStats () {
     return { ...this._stats, degree: this._neighbors.size, protocol: PROTOCOL }
   }

network-stack/hyper-p2p-protocol-handshake/index.js

@@ -103,6 +103,11 @@ class HyperP2PProtocolHandshake extends EventEmitter {
     return this.snapshot()
   }
 
+  isEmpty () {
+    const s = this.snapshot()
+    return s.pending === 0 && s.agreed === 0
+  }
+
   offerBatch (entries) {
     if (!Array.isArray(entries)) throw new Error('entries array required')
     return entries.map((e) => this.offer(e.features || {}))