Skip to content
This repository was archived by the owner on Dec 2, 2024. It is now read-only.

Commit c9bb2af

Browse files
committed
Add subleveldown test
1 parent 5e0e7f5 commit c9bb2af

File tree

2 files changed

+43
-0
lines changed

2 files changed

+43
-0
lines changed

package.json

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -13,6 +13,7 @@
1313
"bytewise": "^1.1.0",
1414
"level-sublevel": "^6.3.11",
1515
"osenv": "~0.1.0",
16+
"subleveldown": "^4.1.4",
1617
"tape": "^4.11.0"
1718
},
1819
"scripts": {

test/subleveldown.js

Lines changed: 42 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,42 @@
1+
var test = require('tape');
2+
var level = require('../');
3+
var path = require('path');
4+
var sub = require('subleveldown');
5+
var tmpdir = require('osenv').tmpdir();
6+
var datadir = path.join(tmpdir, 'level-party-' + Math.random());
7+
8+
test('subleveldown on level-party', function (t) {
9+
t.plan(9);
10+
11+
var a = level(datadir);
12+
var b = level(datadir);
13+
var asub = sub(a, 'test', { valueEncoding: 'json' });
14+
var bsub = sub(b, 'test');
15+
var obj = { test: Math.floor(Math.random() * 100000) };
16+
17+
asub.put('a', obj, function (err) {
18+
t.ifError(err);
19+
20+
asub.get('a', function (err, value) {
21+
t.ifError(err);
22+
t.deepEqual(value, obj);
23+
});
24+
bsub.get('a', function (err, value) {
25+
t.ifError(err);
26+
t.deepEqual(value, JSON.stringify(obj));
27+
});
28+
asub.createReadStream().on('data', function (row) {
29+
t.deepEqual(row.key, 'a');
30+
t.deepEqual(row.value, obj);
31+
});
32+
bsub.createReadStream().on('data', function (row) {
33+
t.deepEqual(row.key, 'a');
34+
t.deepEqual(row.value, JSON.stringify(obj));
35+
});
36+
});
37+
38+
t.on('end', function () {
39+
a.close();
40+
b.close();
41+
});
42+
});

0 commit comments

Comments
 (0)