UNPKG

9.54 kBJavaScriptView Raw
1"use strict";
2var __extends = (this && this.__extends) || (function () {
3 var extendStatics = function (d, b) {
4 extendStatics = Object.setPrototypeOf ||
5 ({ __proto__: [] } instanceof Array && function (d, b) { d.__proto__ = b; }) ||
6 function (d, b) { for (var p in b) if (Object.prototype.hasOwnProperty.call(b, p)) d[p] = b[p]; };
7 return extendStatics(d, b);
8 };
9 return function (d, b) {
10 if (typeof b !== "function" && b !== null)
11 throw new TypeError("Class extends value " + String(b) + " is not a constructor or null");
12 extendStatics(d, b);
13 function __() { this.constructor = d; }
14 d.prototype = b === null ? Object.create(b) : (__.prototype = b.prototype, new __());
15 };
16})();
17var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
18 function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
19 return new (P || (P = Promise))(function (resolve, reject) {
20 function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
21 function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
22 function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
23 step((generator = generator.apply(thisArg, _arguments || [])).next());
24 });
25};
26var __generator = (this && this.__generator) || function (thisArg, body) {
27 var _ = { label: 0, sent: function() { if (t[0] & 1) throw t[1]; return t[1]; }, trys: [], ops: [] }, f, y, t, g;
28 return g = { next: verb(0), "throw": verb(1), "return": verb(2) }, typeof Symbol === "function" && (g[Symbol.iterator] = function() { return this; }), g;
29 function verb(n) { return function (v) { return step([n, v]); }; }
30 function step(op) {
31 if (f) throw new TypeError("Generator is already executing.");
32 while (_) try {
33 if (f = 1, y && (t = op[0] & 2 ? y["return"] : op[0] ? y["throw"] || ((t = y["return"]) && t.call(y), 0) : y.next) && !(t = t.call(y, op[1])).done) return t;
34 if (y = 0, t) op = [op[0] & 2, t.value];
35 switch (op[0]) {
36 case 0: case 1: t = op; break;
37 case 4: _.label++; return { value: op[1], done: false };
38 case 5: _.label++; y = op[1]; op = [0]; continue;
39 case 7: op = _.ops.pop(); _.trys.pop(); continue;
40 default:
41 if (!(t = _.trys, t = t.length > 0 && t[t.length - 1]) && (op[0] === 6 || op[0] === 2)) { _ = 0; continue; }
42 if (op[0] === 3 && (!t || (op[1] > t[0] && op[1] < t[3]))) { _.label = op[1]; break; }
43 if (op[0] === 6 && _.label < t[1]) { _.label = t[1]; t = op; break; }
44 if (t && _.label < t[2]) { _.label = t[2]; _.ops.push(op); break; }
45 if (t[2]) _.ops.pop();
46 _.trys.pop(); continue;
47 }
48 op = body.call(thisArg, _);
49 } catch (e) { op = [6, e]; y = 0; } finally { f = t = 0; }
50 if (op[0] & 5) throw op[1]; return { value: op[0] ? op[1] : void 0, done: true };
51 }
52};
53var __read = (this && this.__read) || function (o, n) {
54 var m = typeof Symbol === "function" && o[Symbol.iterator];
55 if (!m) return o;
56 var i = m.call(o), r, ar = [], e;
57 try {
58 while ((n === void 0 || n-- > 0) && !(r = i.next()).done) ar.push(r.value);
59 }
60 catch (error) { e = { error: error }; }
61 finally {
62 try {
63 if (r && !r.done && (m = i["return"])) m.call(i);
64 }
65 finally { if (e) throw e.error; }
66 }
67 return ar;
68};
69var __spreadArray = (this && this.__spreadArray) || function (to, from, pack) {
70 if (pack || arguments.length === 2) for (var i = 0, l = from.length, ar; i < l; i++) {
71 if (ar || !(i in from)) {
72 if (!ar) ar = Array.prototype.slice.call(from, 0, i);
73 ar[i] = from[i];
74 }
75 }
76 return to.concat(ar || Array.prototype.slice.call(from));
77};
78Object.defineProperty(exports, "__esModule", { value: true });
79exports.SecureTrie = void 0;
80var ethereumjs_util_1 = require("ethereumjs-util");
81var checkpointTrie_1 = require("./checkpointTrie");
82/**
83 * You can create a secure Trie where the keys are automatically hashed
84 * using **keccak256** by using `import { SecureTrie as Trie } from 'merkle-patricia-tree'`.
85 * It has the same methods and constructor as `Trie`.
86 * @class SecureTrie
87 * @extends Trie
88 * @public
89 */
90var SecureTrie = /** @class */ (function (_super) {
91 __extends(SecureTrie, _super);
92 function SecureTrie() {
93 var args = [];
94 for (var _i = 0; _i < arguments.length; _i++) {
95 args[_i] = arguments[_i];
96 }
97 return _super.apply(this, __spreadArray([], __read(args), false)) || this;
98 }
99 /**
100 * Gets a value given a `key`
101 * @param key - the key to search for
102 * @returns A Promise that resolves to `Buffer` if a value was found or `null` if no value was found.
103 */
104 SecureTrie.prototype.get = function (key) {
105 return __awaiter(this, void 0, void 0, function () {
106 var hash, value;
107 return __generator(this, function (_a) {
108 switch (_a.label) {
109 case 0:
110 hash = (0, ethereumjs_util_1.keccak256)(key);
111 return [4 /*yield*/, _super.prototype.get.call(this, hash)];
112 case 1:
113 value = _a.sent();
114 return [2 /*return*/, value];
115 }
116 });
117 });
118 };
119 /**
120 * Stores a given `value` at the given `key`.
121 * For a falsey value, use the original key to avoid double hashing the key.
122 * @param key
123 * @param value
124 */
125 SecureTrie.prototype.put = function (key, val) {
126 return __awaiter(this, void 0, void 0, function () {
127 var hash;
128 return __generator(this, function (_a) {
129 switch (_a.label) {
130 case 0:
131 if (!(!val || val.toString() === '')) return [3 /*break*/, 2];
132 return [4 /*yield*/, this.del(key)];
133 case 1:
134 _a.sent();
135 return [3 /*break*/, 4];
136 case 2:
137 hash = (0, ethereumjs_util_1.keccak256)(key);
138 return [4 /*yield*/, _super.prototype.put.call(this, hash, val)];
139 case 3:
140 _a.sent();
141 _a.label = 4;
142 case 4: return [2 /*return*/];
143 }
144 });
145 });
146 };
147 /**
148 * Deletes a value given a `key`.
149 * @param key
150 */
151 SecureTrie.prototype.del = function (key) {
152 return __awaiter(this, void 0, void 0, function () {
153 var hash;
154 return __generator(this, function (_a) {
155 switch (_a.label) {
156 case 0:
157 hash = (0, ethereumjs_util_1.keccak256)(key);
158 return [4 /*yield*/, _super.prototype.del.call(this, hash)];
159 case 1:
160 _a.sent();
161 return [2 /*return*/];
162 }
163 });
164 });
165 };
166 /**
167 * prove has been renamed to {@link SecureTrie.createProof}.
168 * @deprecated
169 * @param trie
170 * @param key
171 */
172 SecureTrie.prove = function (trie, key) {
173 return __awaiter(this, void 0, void 0, function () {
174 return __generator(this, function (_a) {
175 return [2 /*return*/, this.createProof(trie, key)];
176 });
177 });
178 };
179 /**
180 * Creates a proof that can be verified using {@link SecureTrie.verifyProof}.
181 * @param trie
182 * @param key
183 */
184 SecureTrie.createProof = function (trie, key) {
185 var hash = (0, ethereumjs_util_1.keccak256)(key);
186 return _super.createProof.call(this, trie, hash);
187 };
188 /**
189 * Verifies a proof.
190 * @param rootHash
191 * @param key
192 * @param proof
193 * @throws If proof is found to be invalid.
194 * @returns The value from the key.
195 */
196 SecureTrie.verifyProof = function (rootHash, key, proof) {
197 return __awaiter(this, void 0, void 0, function () {
198 var hash;
199 return __generator(this, function (_a) {
200 hash = (0, ethereumjs_util_1.keccak256)(key);
201 return [2 /*return*/, _super.verifyProof.call(this, rootHash, hash, proof)];
202 });
203 });
204 };
205 /**
206 * Returns a copy of the underlying trie with the interface of SecureTrie.
207 * @param includeCheckpoints - If true and during a checkpoint, the copy will contain the checkpointing metadata and will use the same scratch as underlying db.
208 */
209 SecureTrie.prototype.copy = function (includeCheckpoints) {
210 if (includeCheckpoints === void 0) { includeCheckpoints = true; }
211 var db = this.db.copy();
212 var secureTrie = new SecureTrie(db._leveldb, this.root);
213 if (includeCheckpoints && this.isCheckpoint) {
214 secureTrie.db.checkpoints = __spreadArray([], __read(this.db.checkpoints), false);
215 }
216 return secureTrie;
217 };
218 return SecureTrie;
219}(checkpointTrie_1.CheckpointTrie));
220exports.SecureTrie = SecureTrie;
221//# sourceMappingURL=secure.js.map
\No newline at end of file