load before append

orbitdb-archive · Jul 8, 2019 · 752e4bf · 752e4bf
1 parent 85cc685
commit 752e4bf
Show file tree

Hide file tree

Showing 2 changed files with 91 additions and 58 deletions.
diff --git a/package-lock.json b/package-lock.json
diff --git a/src/Store.js b/src/Store.js
@@ -19,7 +19,8 @@ const DefaultOptions = {
   directory: './orbitdb',
   replicate: true,
   referenceCount: 64,
-  replicationConcurrency: 128
+  replicationConcurrency: 128,
+  syncLocal: false
 }
 
 class Store {
@@ -200,7 +201,6 @@ class Store {
   async load (amount) {
     amount = amount || this.options.maxHistory
 
-
     const localHeads = await this._cache.get('_localHeads') || []
     const remoteHeads = await this._cache.get('_remoteHeads') || []
     const heads = localHeads.concat(remoteHeads)
@@ -419,6 +419,12 @@ class Store {
 
   async _addOperation (data, batchOperation, lastOperation, onProgressCallback) {
     if (this._oplog) {
+      if (this.options.syncLocal) {
+        const localHeads = await this._cache.get('_localHeads') || []
+        if (localHeads[0] && localHeads[0].hash != this._oplog.heads[0]) {
+          await this.load()
+        }
+      }
       const entry = await this._oplog.append(data, this.options.referenceCount)
       this._recalculateReplicationStatus(this.replicationStatus.progress + 1, entry.clock.time)
       await this._cache.set('_localHeads', [entry])