Files: e9a615abb11b8b5aeaa5cf7b1503bab5c33b64eb / datastore.js
1071 bytesRaw
1 | const Buffer = require('safe-buffer').Buffer |
2 | const crypto = require('node-webcrypto-shim') |
3 | const DAG = require('ipld-graph-builder/datastore.js') |
4 | const treeNode = require('./treeNode.js') |
5 | const HASH_LEN = 20 |
6 | |
7 | module.exports = class TreeDAG extends DAG { |
8 | async put (val) { |
9 | const encoded = treeNode.encode(val) |
10 | let key = await TreeDAG.getMerkleLink(encoded) |
11 | |
12 | return new Promise((resolve, reject) => { |
13 | this._dag.put(key, encoded.toString('hex'), () => { |
14 | resolve(key) |
15 | }) |
16 | }) |
17 | } |
18 | |
19 | get (link) { |
20 | return new Promise((resolve, reject) => { |
21 | this._dag.get(link, (err, val) => { |
22 | if (err) { |
23 | reject(err) |
24 | } else { |
25 | val = Buffer.from(val, 'hex') |
26 | const decoded = treeNode.decode(val) |
27 | resolve(decoded) |
28 | } |
29 | }) |
30 | }) |
31 | } |
32 | |
33 | static isValidLink (link) { |
34 | return Buffer.isBuffer(link) && link.length === HASH_LEN |
35 | } |
36 | |
37 | static getMerkleLink (buf) { |
38 | return crypto.subtle.digest({ |
39 | name: 'SHA-256' |
40 | }, buf).then(link => Buffer.from(link.slice(0, HASH_LEN))) |
41 | } |
42 | } |
43 |
Built with git-ssb-web