Mirroristas/orbitdb
2
0
Fork 0
mirror of https://github.com/orbitdb/orbitdb.git synced 2025-03-30 15:08:28 +00:00
Code Issues Packages Projects Releases Wiki Activity

Cleanup

Browse Source
This commit is contained in:
haad 2016-03-04 23:36:49 +01:00
parent 59c5291248
commit 9c1e811dfe
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/list/OrbitList.js
View File

@ -79,14 +79,14 @@ class OrbitList extends List {
.reverse() // Start from the latest item .reverse() // Start from the latest item
.map((f) => f.heads).flatten() // Go through all heads .map((f) => f.heads).flatten() // Go through all heads
.filter((f) => !(f instanceof Node === true)) // OrbitNode vs. {}, filter out instances (we already have them in mem) .filter((f) => !(f instanceof Node === true)) // OrbitNode vs. {}, filter out instances (we already have them in mem)
.map((f) => this._fetchRecursive(f, MaxHistory, allHashes)).flatten() // IO - get the data from IPFS .map((f) => this._fetchRecursive(f, allHashes)).flatten() // IO - get the data from IPFS
.map((f) => this._insert(f)) // Insert to the list .map((f) => this._insert(f)) // Insert to the list
.take(MaxHistory) // How many items from the history we should fetch .take(MaxHistory) // How many items from the history we should fetch
.toArray(); .toArray();
// console.log("--> Fetched", res.length, "items from the history\n"); // console.log("--> Fetched", res.length, "items from the history\n");
} }
_fetchRecursive(hash, amount, all) { _fetchRecursive(hash, all) {
const isReferenced = (list, item) => Lazy(list).find((f) => f === item) !== undefined; const isReferenced = (list, item) => Lazy(list).find((f) => f === item) !== undefined;
let result = []; let result = [];
if(!isReferenced(all, hash)) { if(!isReferenced(all, hash)) {
@ -94,7 +94,7 @@ class OrbitList extends List {
const item = await(Node.fromIpfsHash(this._ipfs, hash)); // IO - get from IPFS const item = await(Node.fromIpfsHash(this._ipfs, hash)); // IO - get from IPFS
result.push(item); result.push(item);
result = result.concat(Lazy(item.heads) result = result.concat(Lazy(item.heads)
.map((f) => this._fetchRecursive(f, amount, all)) .map((f) => this._fetchRecursive(f, all))
.flatten() .flatten()
.toArray()); .toArray());
} }