hyperbee - npm Package Compare versions

Comparing version 1.6.0 to 1.6.1

index.js

		@@ -307,3 +307,3 @@ const codecs = require('codecs')

		if (this.prefix) this.keyEncoding = prefixEncoding(this.prefix, this.keyEncoding)
		if (this.prefix && !this._checkout) this.keyEncoding = prefixEncoding(this.prefix, this.keyEncoding)
		}
		@@ -446,2 +446,3 @@
		sep: this.sep,
		prefix: this.prefix,
		checkout: version,
		@@ -448,0 +449,0 @@ extension: this.extension,

package.json

		{
		"name": "hyperbee",
		"version": "1.6.0",
		"version": "1.6.1",
		"description": "An append-only Btree running on a Hypercore.",
		@@ -5,0 +5,0 @@ "main": "index.js",

test/all.js

		@@ -331,2 +331,54 @@ const tape = require('tape')

		tape('read stream on sub checkout returns only sub keys', async t => {
		t.plan(3)

		const db = create({ sep: '!', keyEncoding: 'utf-8' })
		const sub = db.sub('sub')

		await db.put('a', 'a')
		await sub.put('sa', 'sa')
		await sub.put('sb', 'sb')

		const checkout = sub.snapshot()

		await db.put('b', 'b')

		const keys = []
		for await (const { key } of checkout.createReadStream()) {
		keys.push(key)
		}

		t.same(keys.length, 2)
		t.same(keys[0], 'sa')
		t.same(keys[1], 'sb')

		t.end()
		})

		tape('read stream on double sub checkout', async t => {
		t.plan(3)

		const db = create({ sep: '!', keyEncoding: 'utf-8' })
		const sub = db.sub('sub')

		await db.put('a', 'a')
		await sub.put('sa', 'sa')
		await sub.put('sb', 'sb')

		const checkout = sub.snapshot().snapshot()

		await db.put('b', 'b')

		const keys = []
		for await (const { key } of checkout.createReadStream()) {
		keys.push(key)
		}

		t.same(keys.length, 2)
		t.same(keys[0], 'sa')
		t.same(keys[1], 'sb')

		t.end()
		})

		tape('setting read-only flag to false disables header write', async t => {
		@@ -333,0 +385,0 @@ const db = create({ readonly: true })

test/diff.js

		const test = require('tape')
		const { createRange, collect, insertRange } = require('./helpers')
		const { create, createRange, collect, insertRange } = require('./helpers')

		@@ -38,1 +38,25 @@ test('basic diff', async function (t) {
		})

		test('diff stream on sub + checkout', async function (t) {
		const db = create({ sep: '!', keyEncoding: 'utf-8' })
		const sub = db.sub('sub')

		await db.put('a', 'a')
		await sub.put('sa', 'sa')
		const v1 = sub.version
		await sub.put('sb', 'sb')
		const v2 = sub.version
		await db.put('b', 'b')
		await sub.put('sc', 'sc')

		const entries1 = await collect(sub.checkout(v2).createDiffStream(v1))
		const entries2 = await collect(sub.createDiffStream(v1))

		t.same(entries1.length, 1)
		t.same(entries2.length, 2)
		t.same(entries1[0].left.key, 'sb')
		t.same(entries2[0].left.key, 'sb')
		t.same(entries2[1].left.key, 'sc')

		t.end()
		})

New alerts