Fix keyvalue example

Refactor List

examples/keyvalue.js

@@ -40,7 +40,6 @@ let run = (async(() => {
     }
 
   } catch(e) {
-    console.error("error:", e);
     console.error(e.stack);
     process.exit(1);
   }

src/list/List.js

@@ -12,8 +12,9 @@ class List {
     this._currentBatch = [];
   }
 
+  /* Methods */
   add(data) {
-    const heads = this._findHeads(this.items);
+    const heads = List.findHeads(this.items);
     const node  = new Node(this.id, this.seq, this.ver, data, heads);
     this._currentBatch.push(node);
     this.ver ++;
@@ -36,20 +37,16 @@ class List {
     this.ver = 0;
   }
 
-  _findHeads(list) {
+  /* Private methods */
-    return Lazy(list)
+  _commit() {
-      .reverse()
+    const current = Lazy(this._currentBatch).difference(this._items).toArray();
-      .indexBy((f) => f.id)
+    this._items   = this._items.concat(current);
-      .pairs()
+    this._currentBatch = [];
-      .map((f) => f[1])
+    this.ver = 0;
-      .filter((f) => !this._isReferencedInChain(list, f))
+    this.seq ++;
-      .toArray();
-  }
-
-  _isReferencedInChain(all, item) {
-    return Lazy(all).find((e) => e.hasChild(item)) !== undefined;
   }
 
+  /* Properties */
   get items() {
     return this._items.concat(this._currentBatch);
   }
@@ -67,6 +64,7 @@ class List {
     }
   }
 
+  /* Static methods */
   static fromJson(json) {
     let list = new List(json.id);
     list.seq = json.seq;
@@ -77,6 +75,20 @@ class List {
       .toArray();
     return list;
   }
+
+  static findHeads(list) {
+    return Lazy(list)
+      .reverse()
+      .indexBy((f) => f.id)
+      .pairs()
+      .map((f) => f[1])
+      .filter((f) => !List.isReferencedInChain(list, f))
+      .toArray();
+  }
+
+  static isReferencedInChain(all, item) {
+    return Lazy(all).find((e) => e.hasChild(item)) !== undefined;
+  }
 }
 
 module.exports = List;

src/list/OrbitList.js

@@ -23,7 +23,7 @@ class OrbitList extends List {
     if(this.ver >= MaxBatchSize)
       this._commit();
 
-    const heads = super._findHeads(this.items);
+    const heads = List.findHeads(this.items);
     const node  = new Node(this._ipfs, this.id, this.seq, this.ver, data, heads);
     node._commit(); // TODO: obsolete?
     this._currentBatch.push(node);