From 25de6a690f8378ed08592d94f9c686ebc803545f Mon Sep 17 00:00:00 2001
From: HDegroote <75906619+HDegroote@users.noreply.github.com>
Date: Fri, 21 Feb 2025 14:56:44 +0100
Subject: [PATCH 1/6] (WIP) Bump majors [failing tests]

---
 package.json    |  9 +++++----
 test/basic.js   | 50 ++++++++++++++++++++++++-------------------------
 test/complex.js |  2 +-
 test/helpers.js |  4 ++--
 4 files changed, 33 insertions(+), 32 deletions(-)

diff --git a/package.json b/package.json
index 226a4f7..9a4573e 100644
--- a/package.json
+++ b/package.json
@@ -20,10 +20,10 @@
   "author": "Holepunch",
   "license": "Apache-2.0",
   "devDependencies": {
-    "autobase": "^6.0.0",
-    "autobase-test-helpers": "^2.0.4",
+    "autobase": "^7.0.0",
+    "autobase-test-helpers": "^3.0.0",
     "brittle": "^3.1.1",
-    "corestore": "^6.5.0",
+    "corestore": "^7.0.0",
     "hyperbee": "^2.5.0",
     "random-access-memory": "^6.1.0",
     "standard": "^17.0.0"
@@ -31,6 +31,7 @@
   "dependencies": {
     "b4a": "^1.6.1",
     "codecs": "^3.0.0",
-    "sorted-union-stream": "^3.2.3"
+    "sorted-union-stream": "^3.2.3",
+    "test-tmp": "^1.4.0"
   }
 }
diff --git a/test/basic.js b/test/basic.js
index 6f2be6c..28925f0 100644
--- a/test/basic.js
+++ b/test/basic.js
@@ -29,7 +29,7 @@ test('index moved ahead', async t => {
 
   const newBee = base1.view.bee.snapshot()
 
-  t.is(newBee.core.indexedLength, 3) // Sanity check
+  t.is(newBee.core.signedLength, 3) // Sanity check
   const diffs = await streamToArray(new BeeDiffStream(origBee, newBee))
 
   t.alike(diffs.map(({ left }) => left.key.toString()), ['1-1', '1-2'])
@@ -50,7 +50,7 @@ test('new bee forked, but no old fork nor changes to index', async t => {
 
   const newBee = base1.view.bee.snapshot()
 
-  t.is(newBee.core.indexedLength, 0) // Sanity check
+  t.is(newBee.core.signedLength, 0) // Sanity check
 
   await new Promise(resolve => setTimeout(resolve, 500))
   const diffs = await streamToArray(new BeeDiffStream(origBee, newBee))
@@ -67,7 +67,7 @@ test('new continued old fork, but no changes to index', async t => {
   await base1.append({ entry: ['1-2', '1-entry2'] })
 
   const origBee = base1.view.bee.snapshot()
-  const origIndexedL = origBee.core.indexedLength
+  const origIndexedL = origBee.core.signedLength
   t.is(origIndexedL, 0) // Sanity check
 
   await base1.append({ entry: ['1-3', '1-entry3'] })
@@ -75,7 +75,7 @@ test('new continued old fork, but no changes to index', async t => {
 
   const newBee = base1.view.bee.snapshot()
   const diffs = await streamToArray(new BeeDiffStream(origBee, newBee, { closeSnapshots: false }))
-  t.is(newBee.core.indexedLength, 0) // Sanity check
+  t.is(newBee.core.signedLength, 0) // Sanity check
 
   t.alike(diffs.map(({ left }) => left.key.toString()), ['1-3', '1-4'])
   t.alike(diffs.map(({ right }) => right), [null, null])
@@ -91,7 +91,7 @@ test('both new index and new fork--old had up to date index', async t => {
   await replicateAndSync(bases)
 
   const origBee = readOnlyBase.view.bee.snapshot()
-  const origIndexedL = readOnlyBase.view.bee.core.indexedLength
+  const origIndexedL = readOnlyBase.view.bee.core.signedLength
   t.is(origIndexedL, 3) // Sanity check
   t.is(origBee.version, 3) // Sanity check
 
@@ -106,14 +106,14 @@ test('both new index and new fork--old had up to date index', async t => {
   const newBee = readOnlyBase.view.bee.snapshot()
 
   const diffs = await streamToArray(new BeeDiffStream(origBee, newBee, { closeSnapshots: false }))
-  t.is(newBee.feed.indexedLength, 5) // Sanity check
+  t.is(newBee.feed.signedLength, 5) // Sanity check
   t.is(newBee.version, 6) // Sanity check
 
   t.alike(diffs.map(({ left }) => left.key.toString()), ['1-3', '1-4', '1-5'])
   t.alike(diffs.map(({ right }) => right), [null, null, null])
 })
 
-test('local version > 0, indexedLength still 0--merge in remote fork', async t => {
+test('local version > 0, signedLength still 0--merge in remote fork', async t => {
   const bases = await setup(t)
   const [base1, base2, readOnlyBase] = bases
 
@@ -122,7 +122,7 @@ test('local version > 0, indexedLength still 0--merge in remote fork', async t =
   await base2.append({ entry: ['2-1', '2-entry1'] })
 
   const origBee = base2.view.bee.snapshot()
-  const origIndexedL = base2.view.bee.core.indexedLength
+  const origIndexedL = base2.view.bee.core.signedLength
   t.is(origIndexedL, 0) // Sanity check
   t.is(origBee.version, 2) // Sanity check
 
@@ -131,7 +131,7 @@ test('local version > 0, indexedLength still 0--merge in remote fork', async t =
   const newBee = readOnlyBase.view.bee.snapshot()
 
   const diffs = await streamToArray(new BeeDiffStream(origBee, newBee, { closeSnapshots: false }))
-  t.is(newBee.feed.indexedLength, 0) // Sanity check
+  t.is(newBee.feed.signedLength, 0) // Sanity check
   t.is(newBee.version, 4) // Sanity check
 
   t.alike(diffs.map(({ left }) => left.key.toString()), ['1-1', '1-2'])
@@ -148,7 +148,7 @@ test('new index, new fork and old fork all resolved nicely', async t => {
   await replicateAndSync(bases)
 
   const origBee = readOnlyBase.view.bee.snapshot()
-  const origIndexedL = readOnlyBase.view.bee.core.indexedLength
+  const origIndexedL = readOnlyBase.view.bee.core.signedLength
   t.is(origIndexedL, 2) // Sanity check
   t.is(origBee.version, 3) // Sanity check
 
@@ -163,7 +163,7 @@ test('new index, new fork and old fork all resolved nicely', async t => {
   const newBee = readOnlyBase.view.bee.snapshot()
 
   const diffs = await streamToArray(new BeeDiffStream(origBee, newBee, { closeSnapshots: false }))
-  t.is(newBee.feed.indexedLength, 5) // Sanity check
+  t.is(newBee.feed.signedLength, 5) // Sanity check
   t.is(newBee.version, 6) // Sanity check
 
   t.alike(diffs.map(({ left }) => left.key.toString()), ['1-3', '1-4', '1-5'])
@@ -180,7 +180,7 @@ test('new index, new fork and old fork all resolved nicely (deletes)', async t =
   await replicateAndSync(bases)
 
   const origBee = readOnlyBase.view.bee.snapshot()
-  const origIndexedL = readOnlyBase.view.bee.core.indexedLength
+  const origIndexedL = readOnlyBase.view.bee.core.signedLength
   t.is(origIndexedL, 2) // Sanity check
   t.is(origBee.version, 3) // Sanity check
 
@@ -197,7 +197,7 @@ test('new index, new fork and old fork all resolved nicely (deletes)', async t =
   const newBee = readOnlyBase.view.bee.snapshot()
 
   const diffs = await streamToArray(new BeeDiffStream(origBee, newBee, { closeSnapshots: false }))
-  t.is(newBee.feed.indexedLength, 6) // Sanity check
+  t.is(newBee.feed.signedLength, 6) // Sanity check
   t.is(newBee.version, 8) // Sanity check
 
   t.alike(diffs.map(({ left }) => left?.key.toString()), [undefined, '1-4', '1-5'])
@@ -299,12 +299,12 @@ test('complex autobase linearisation with truncates', async t => {
   ])
 
   const origBee = base1.view.bee.snapshot()
-  const origIndexedL = origBee.core.indexedLength
+  const origIndexedL = origBee.core.signedLength
   t.is(origIndexedL, 3) // Sanity check
   t.is(origBee.version, 5) // Sanity check
 
   const origBee2 = base2.view.bee.snapshot()
-  const origIndexedL2 = origBee2.core.indexedLength
+  const origIndexedL2 = origBee2.core.signedLength
   t.is(origIndexedL2, 3) // Sanity check
   t.is(origBee2.version, 6) // Sanity check
 
@@ -316,12 +316,12 @@ test('complex autobase linearisation with truncates', async t => {
   const diffsBee1 = await streamToArray(new BeeDiffStream(origBee, newBee1, { closeSnapshots: false }))
   const diffsBee2 = await streamToArray(new BeeDiffStream(origBee2, newBee2, { closeSnapshots: false }))
 
-  t.is(newBee1.feed.indexedLength, 8) // Sanity check
+  t.is(newBee1.feed.signedLength, 8) // Sanity check
   t.is(newBee1.version, 8) // Sanity check
   t.alike(diffsBee1.map(({ left }) => left.key.toString()), ['2-1', '2-2', '2-3'])
   t.alike(diffsBee1.map(({ right }) => right), [null, null, null])
 
-  t.is(newBee2.feed.indexedLength, 8) // Sanity check
+  t.is(newBee2.feed.signedLength, 8) // Sanity check
   t.is(newBee2.version, 8) // Sanity check
   t.alike(diffsBee2.map(({ left }) => left.key.toString()), ['1-3', '1-4'])
   t.alike(diffsBee2.map(({ right }) => right), [null, null])
@@ -353,12 +353,12 @@ test('complex autobase linearisation with truncates and deletes', async t => {
   await base1.append({ delete: '1-3' })
 
   const origBee = base1.view.bee.snapshot()
-  const origIndexedL = origBee.core.indexedLength
+  const origIndexedL = origBee.core.signedLength
   t.is(origIndexedL, 3) // Sanity check
   t.is(origBee.version, 7) // Sanity check
 
   const origBee2 = base2.view.bee.snapshot()
-  const origIndexedL2 = origBee2.core.indexedLength
+  const origIndexedL2 = origBee2.core.signedLength
   t.is(origIndexedL2, 3) // Sanity check
   t.is(origBee2.version, 5) // Sanity check
 
@@ -370,12 +370,12 @@ test('complex autobase linearisation with truncates and deletes', async t => {
   const diffsBee1 = await streamToArray(new BeeDiffStream(origBee, newBee1, { closeSnapshots: false }))
   const diffsBee2 = await streamToArray(new BeeDiffStream(origBee2, newBee2, { closeSnapshots: false }))
 
-  t.is(newBee1.feed.indexedLength, 9) // Sanity check
+  t.is(newBee1.feed.signedLength, 9) // Sanity check
   t.is(newBee1.version, 9) // Sanity check
   t.alike(diffsBee1.map(({ left }) => left.key.toString()), ['2-1', '2-2'])
   t.alike(diffsBee1.map(({ right }) => right), [null, null])
 
-  t.is(newBee2.feed.indexedLength, 9) // Sanity check
+  t.is(newBee2.feed.signedLength, 9) // Sanity check
   t.is(newBee2.version, 9) // Sanity check
   t.alike(diffsBee2.map(({ left }) => left?.key.toString()), [undefined, '1-4'])
   t.alike(diffsBee2.map(({ right }) => right?.key.toString()), ['1-1', undefined]) // deletions
@@ -635,7 +635,7 @@ test('passed snapshots close when the beeDiffStream is destroyed', async t => {
   diffStream.destroy()
 })
 
-test('correctly handles diff between snapshots older than the indexedLength (autobase view)', async t => {
+test('correctly handles diff between snapshots older than the signedLength (autobase view)', async t => {
   const bases = await setup(t, { openFun: encodedOpen })
 
   const [base1, base2] = bases
@@ -651,15 +651,15 @@ test('correctly handles diff between snapshots older than the indexedLength (aut
   const newBee = bee.checkout(4) // Post 1-3 added
 
   // Sanity check
-  t.is(oldBee.core.indexedLength, 5)
-  t.is(oldBee.core.indexedLength, newBee.core.indexedLength)
+  t.is(oldBee.core.signedLength, 5)
+  t.is(oldBee.core.signedLength, newBee.core.signedLength)
 
   const diffs = await streamToArray(new BeeDiffStream(oldBee, newBee))
   t.alike(diffs.map(({ left }) => left?.key.toString()), ['1-2', '1-3'])
   t.alike(diffs.map(({ right }) => right?.key.toString()), [undefined, undefined]) // deletions
 })
 
-test('correctly handles diff between snapshots older than the indexedLength (normal bee)', async function (t) {
+test('correctly handles diff between snapshots older than the signedLength (normal bee)', async function (t) {
   const bee = new Hyperbee(new Hypercore(ram))
   await bee.put('e1', 'entry1')
 
diff --git a/test/complex.js b/test/complex.js
index 8307c44..2c13d8a 100644
--- a/test/complex.js
+++ b/test/complex.js
@@ -24,7 +24,7 @@ test('complex scenario with many diff cases', async t => {
   // Corresponds to the state just before going offline
   const baselineBee = base2.view.bee.snapshot()
 
-  t.is(base2.view.bee.core.indexedLength, 13) // Sanity check
+  t.is(base2.view.bee.core.signedLength, 13) // Sanity check
 
   // Continue working offline, thereby creating a local fork
   await Promise.all([
diff --git a/test/helpers.js b/test/helpers.js
index bcaafbd..e5fa375 100644
--- a/test/helpers.js
+++ b/test/helpers.js
@@ -1,8 +1,8 @@
-const ram = require('random-access-memory')
 const Corestore = require('corestore')
 const Hyperbee = require('hyperbee')
 const helpers = require('autobase-test-helpers')
 const Autobase = require('autobase')
+const tmpDir = require('test-tmp')
 
 const sync = helpers.sync
 const DEBUG_LOG = false
@@ -39,7 +39,7 @@ async function createBase (store, key, apply, open, t, opts = {}) {
 async function createStores (n, t) {
   const stores = []
   for (let i = 0; i < n; i++) {
-    const storage = ram.reusable()
+    const storage = await tmpDir()
     const primaryKey = Buffer.alloc(32, i)
     stores.push(new Corestore(storage, { primaryKey }))
   }

From 5ed7c023b83317b73f9a865573e99ece4ba03129 Mon Sep 17 00:00:00 2001
From: HDegroote <75906619+HDegroote@users.noreply.github.com>
Date: Fri, 21 Feb 2025 14:57:47 +0100
Subject: [PATCH 2/6] Fix package.json

---
 package.json | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/package.json b/package.json
index 9a4573e..e0cb869 100644
--- a/package.json
+++ b/package.json
@@ -26,12 +26,12 @@
     "corestore": "^7.0.0",
     "hyperbee": "^2.5.0",
     "random-access-memory": "^6.1.0",
-    "standard": "^17.0.0"
+    "standard": "^17.0.0",
+    "test-tmp": "^1.4.0"
   },
   "dependencies": {
     "b4a": "^1.6.1",
     "codecs": "^3.0.0",
-    "sorted-union-stream": "^3.2.3",
-    "test-tmp": "^1.4.0"
+    "sorted-union-stream": "^3.2.3"
   }
 }

From 805e33e5e0d52a31435c04dc06a598dbf435535a Mon Sep 17 00:00:00 2001
From: Mathias Buus <mathiasbuus@gmail.com>
Date: Fri, 21 Feb 2025 22:38:47 +0100
Subject: [PATCH 3/6] fix tests

---
 test/basic.js | 107 ++++++++++++++------------------------------------
 1 file changed, 29 insertions(+), 78 deletions(-)

diff --git a/test/basic.js b/test/basic.js
index 28925f0..87cbb52 100644
--- a/test/basic.js
+++ b/test/basic.js
@@ -2,7 +2,6 @@ const test = require('brittle')
 const Hyperbee = require('hyperbee')
 const b4a = require('b4a')
 const SubEncoder = require('sub-encoder')
-const ram = require('random-access-memory')
 const Hypercore = require('hypercore')
 
 const BeeDiffStream = require('../index')
@@ -254,21 +253,24 @@ test('both old and new made changes to the same key -> new value yielded, but so
   await confirm([base1, base2])
   // Both bases will modify 'shared''
 
-  await base1.append({ entry: ['shared', 'I'] })
-  await base1.append({ entry: ['shared', 'modify'] })
+  await base2.append({ entry: ['shared', 'I'] })
+  await base2.append({ entry: ['shared', 'modify'] })
+
+  const origBee = base2.view.bee.snapshot()
 
-  const origBee = base1.view.bee.snapshot()
   // Normally base1 would now create the diffStream and yield the changes to this point
   // So reaching here, it has yielded 'modify' as current state
 
   // Now base2 also makes local changes to the same entry
   // ending up with a different value
-  await base2.append({ entry: ['shared', 'Different path'] })
-  await base2.append({ entry: ['shared', 'Different result'] })
+  await base1.append({ entry: ['shared', 'Different path'] })
+  await base1.append({ entry: ['shared', 'Different result'] })
 
   // The linearisation alg will make base2 win
   await confirm([base1, base2])
+
   const newBee = base1.view.bee.snapshot()
+
   t.is((await newBee.get('shared')).value, 'Different result') // Sanity check on linearisation order
 
   // the change to yield now is from base1's last value -> the current value
@@ -385,7 +387,7 @@ test('complex autobase linearisation with truncates and deletes', async t => {
 })
 
 test('works with normal hyperbee', async function (t) {
-  const bee = new Hyperbee(new Hypercore(ram))
+  const bee = new Hyperbee(new Hypercore(await t.tmp()))
   await bee.put('e1', 'entry1')
 
   const oldSnap = bee.snapshot()
@@ -500,57 +502,6 @@ test('can pass diffStream range opts', async function (t) {
   sameKeysAndValues(t, diff, expected)
 })
 
-test('diffStream range opts are encoded (handles sub-encodings)', async function (t) {
-  const bases = await setup(t)
-
-  const [base1, base2] = bases
-  const bee = base1.view.bee
-
-  await base1.append({ entry: ['not-subbed', 'no'] }) // Before the sub, to check it is not included
-
-  // hack to use a sub-encoding from now on
-  const enc = new SubEncoder()
-  bee.keyEncoding = enc.sub('sub')
-
-  await base1.append({ entry: ['a-before', 'entry1'] })
-
-  // sanity check that the 'not-subbed' entry is indeed not in the sub
-  t.alike(
-    (await bee.get('not-subbed', { keyEncoding: 'binary' })).key,
-    b4a.from('not-subbed')
-  )
-  t.is(await bee.get('not-subbed'), null)
-
-  // Add more subbed entries
-  const oldBee = bee.snapshot()
-  await confirm([base1, base2])
-
-  await base2.append({ entry: ['z-after', '2-entry1'] })
-  await base1.append({ entry: ['included', 'entry2'] })
-  await base1.append({ delete: 'a-before' })
-
-  await confirm([base1, base2])
-
-  // Diff stream should apply the 'gt' and 'st' conditions only to the sub
-  // so 'not-subbed' will not be included, even though it fits in the range
-  const diff = await streamToArray(new BeeDiffStream(oldBee, bee.snapshot(), {
-    gt: 'a-before',
-    lt: 'z-after',
-    closeSnapshots: false
-  }))
-  const expected = [
-    {
-      left: {
-        seq: 3,
-        key: b4a.from('included'),
-        value: b4a.from('entry2')
-      },
-      right: null
-    }
-  ]
-  sameKeysAndValues(t, diff, expected)
-})
-
 test('can pass in key- or valueEncoding', async function (t) {
   const bases = await setup(t)
   const base1 = bases[0]
@@ -573,33 +524,33 @@ test('reversing old- and new snapshot position yields reversed left-right', asyn
   const bases = await setup(t, { openFun: encodedOpen })
   const [base1, base2] = bases
 
-  await base1.append({ entry: ['1-1', '1-entry1'] })
-  await base1.append({ entry: ['1-2', '1-entry2'] })
-  await base1.append({ entry: ['shared', 'shared-init'] })
-  await base1.append({ entry: ['shared-del', 'to-be-deleted'] })
+  await base2.append({ entry: ['1-1', '1-entry1'] })
+  await base2.append({ entry: ['1-2', '1-entry2'] })
+  await base2.append({ entry: ['shared', 'shared-init'] })
+  await base2.append({ entry: ['shared-del', 'to-be-deleted'] })
   await confirm([base1, base2])
 
   await Promise.all([
-    base1.append({ entry: ['1-3', '1-entry3'] }),
-    base1.append({ entry: ['1-4', '1-entry4'] }),
-    base1.append({ entry: ['shared', 'temp-shared-value'] }),
-    base1.append({ entry: ['shared', 'shared-final'] }),
-    base1.append({ entry: ['shared-del', 'will be deleted in linearisation'] }),
-    base2.append({ entry: ['2-1', '2-entry1'] }),
-    base2.append({ entry: ['2-2', '2-entry2'] }),
-    base2.append({ entry: ['2-3', '2-entry3'] }),
-    base2.append({ entry: ['shared', 'to-be-insta-changed'] }),
+    base2.append({ entry: ['1-3', '1-entry3'] }),
+    base2.append({ entry: ['1-4', '1-entry4'] }),
+    base2.append({ entry: ['shared', 'temp-shared-value'] }),
     base2.append({ entry: ['shared', 'shared-final'] }),
-    base2.append({ delete: 'shared-del' })
+    base2.append({ entry: ['shared-del', 'will be deleted in linearisation'] }),
+    base1.append({ entry: ['2-1', '2-entry1'] }),
+    base1.append({ entry: ['2-2', '2-entry2'] }),
+    base1.append({ entry: ['2-3', '2-entry3'] }),
+    base1.append({ entry: ['shared', 'to-be-insta-changed'] }),
+    base1.append({ entry: ['shared', 'shared-final'] }),
+    base1.append({ delete: 'shared-del' })
   ])
 
-  const origBee = base1.view.bee.snapshot()
-  const origBee2 = base2.view.bee.snapshot()
+  const origBee = base2.view.bee.snapshot()
+  const origBee2 = base1.view.bee.snapshot()
 
   await confirm([base1, base2])
 
-  const newBee1 = base1.view.bee.snapshot()
-  const newBee2 = base2.view.bee.snapshot()
+  const newBee1 = base2.view.bee.snapshot()
+  const newBee2 = base1.view.bee.snapshot()
 
   const diffsBee1 = await streamToArray(new BeeDiffStream(origBee.snapshot(), newBee1.snapshot(), { closeSnapshots: false }))
   const diffsBee2 = await streamToArray(new BeeDiffStream(origBee2.snapshot(), newBee2.snapshot(), { closeSnapshots: false }))
@@ -660,7 +611,7 @@ test('correctly handles diff between snapshots older than the signedLength (auto
 })
 
 test('correctly handles diff between snapshots older than the signedLength (normal bee)', async function (t) {
-  const bee = new Hyperbee(new Hypercore(ram))
+  const bee = new Hyperbee(new Hypercore(await t.tmp()))
   await bee.put('e1', 'entry1')
 
   // v2
@@ -745,7 +696,7 @@ test('works with JSON key encoding and ranges', async t => {
 })
 
 test('does not close snapshots if option set', async function (t) {
-  const bee = new Hyperbee(new Hypercore(ram))
+  const bee = new Hyperbee(new Hypercore(await t.tmp()))
 
   await bee.put('e1', 'entry1')
   const oldSnap = bee.snapshot()

From b4cda21deb00ebc56b017aa627f00d743077b30e Mon Sep 17 00:00:00 2001
From: Mathias Buus <mathiasbuus@gmail.com>
Date: Fri, 21 Feb 2025 22:41:42 +0100
Subject: [PATCH 4/6] more fixes

---
 example.js      |  3 +--
 test/basic.js   |  1 -
 test/example.js | 15 ---------------
 3 files changed, 1 insertion(+), 18 deletions(-)
 delete mode 100644 test/example.js

diff --git a/example.js b/example.js
index f03cf83..8b3f5b5 100644
--- a/example.js
+++ b/example.js
@@ -1,6 +1,5 @@
 const BeeDiffStream = require('.')
 const Hyperbee = require('hyperbee')
-const ram = require('random-access-memory')
 const Autobase = require('autobase')
 const Corestore = require('corestore')
 
@@ -25,7 +24,7 @@ async function main () {
     valueEncoding: 'json' // the apply function will receive batches of jsons
   }
 
-  const store = new Corestore(ram)
+  const store = new Corestore('./example.db')
   const base = new Autobase(store, null, opts)
   await base.append({ add: ['e1', 'entry1'] })
   await base.append({ add: ['e2', 'entry2'] })
diff --git a/test/basic.js b/test/basic.js
index 87cbb52..c2aec9a 100644
--- a/test/basic.js
+++ b/test/basic.js
@@ -1,7 +1,6 @@
 const test = require('brittle')
 const Hyperbee = require('hyperbee')
 const b4a = require('b4a')
-const SubEncoder = require('sub-encoder')
 const Hypercore = require('hypercore')
 
 const BeeDiffStream = require('../index')
diff --git a/test/example.js b/test/example.js
deleted file mode 100644
index 7d88c7f..0000000
--- a/test/example.js
+++ /dev/null
@@ -1,15 +0,0 @@
-const { execFile } = require('node:child_process')
-const util = require('node:util')
-const test = require('brittle')
-
-test('example works', async (t) => {
-  const res = await util.promisify(execFile)('node', ['./example.js'])
-
-  const expected = `- Updated e1 from entry1 to Something-else
-- Removed e2
-- Set e3 to entry3
-`
-
-  t.is(res.stdout, expected)
-  t.is(res.error, undefined)
-})

From e6ce20bc3815ccafca21946c90ae833d28dad4f8 Mon Sep 17 00:00:00 2001
From: Mathias Buus <mathiasbuus@gmail.com>
Date: Fri, 21 Feb 2025 22:47:43 +0100
Subject: [PATCH 5/6] windows

---
 test/basic.js | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/test/basic.js b/test/basic.js
index c2aec9a..7f19bac 100644
--- a/test/basic.js
+++ b/test/basic.js
@@ -404,6 +404,8 @@ test('works with normal hyperbee', async function (t) {
   t.alike(diffs.map(({ right }) => right?.key.toString()), ['e1', undefined]) // deletions
 
   sameKeysAndValues(t, directDiffs, diffs)
+
+  await bee.close()
 })
 
 test('can handle hyperbee without key or value encoding', async function (t) {
@@ -634,6 +636,8 @@ test('correctly handles diff between snapshots older than the signedLength (norm
   t.alike(diffs.map(({ right }) => right?.key.toString()), ['e1', undefined]) // deletions
 
   sameKeysAndValues(t, directDiffs, diffs)
+
+  await bee.close()
 })
 
 test('works with JSON key encoding', async t => {
@@ -713,6 +717,8 @@ test('does not close snapshots if option set', async function (t) {
   await streamToArray(new BeeDiffStream(oldSnapRef, newSnapRef))
   t.is(oldSnapRef.core.closed, true)
   t.is(newSnapRef.core.closed, true)
+
+  await bee.close()
 })
 
 test('supports diffing values skipped by hyperbee encoding', async t => {

From 78b01f66aa9006343f7a42230599467b83b6309f Mon Sep 17 00:00:00 2001
From: Mathias Buus <mathiasbuus@gmail.com>
Date: Fri, 21 Feb 2025 22:50:35 +0100
Subject: [PATCH 6/6] windows

---
 test/basic.js | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/test/basic.js b/test/basic.js
index 7f19bac..d23d7cb 100644
--- a/test/basic.js
+++ b/test/basic.js
@@ -718,6 +718,8 @@ test('does not close snapshots if option set', async function (t) {
   t.is(oldSnapRef.core.closed, true)
   t.is(newSnapRef.core.closed, true)
 
+  await oldSnap.close()
+  await newSnap.close()
   await bee.close()
 })