only pull if server revision is not expected

sevenbitbyte · sevenbitbyte · commit 43917d625b91 · 2022-09-17T22:01:32.000-07:00
diff --git a/src/party/idocument.js b/src/party/idocument.js
@@ -140,10 +140,13 @@ class IDocument extends EventEmitter {
     debug('asign data')
     await this.setData(value)
     debug('data set')
-    await this.party.update(value)
+    const expectedRevision = reach(this.data, '$meta.revision', -1) + 1
+    const rawDocument = (await this.party.update(value))[0]
     debug('doc updated')
-    await this.pull()
-    debug('doc pulled')
+    if(expectedRevision != reach(rawDocument, '$meta.revision')){
+      console.log('pull')
+      await this.pull()
+    }
   }
 
 
@@ -385,4 +388,4 @@ class IDocument extends EventEmitter {
   }
 }
 
-module.exports = IDocument
+module.exports = IDocument

Original file line number	Diff line number	Diff line change
`@@ -140,10 +140,13 @@ class IDocument extends EventEmitter {`
`140`	`140`	`debug('asign data')`
`141`	`141`	`await this.setData(value)`
`142`	`142`	`debug('data set')`
`143`		`- await this.party.update(value)`
	`143`	`+ const expectedRevision = reach(this.data, '$meta.revision', -1) + 1`
	`144`	`+ const rawDocument = (await this.party.update(value))[0]`
`144`	`145`	`debug('doc updated')`
`145`		`- await this.pull()`
`146`		`- debug('doc pulled')`
	`146`	`+ if(expectedRevision != reach(rawDocument, '$meta.revision')){`
	`147`	`+ console.log('pull')`
	`148`	`+ await this.pull()`
	`149`	`+ }`
`147`	`150`	`}`
`148`	`151`
`149`	`152`
`@@ -385,4 +388,4 @@ class IDocument extends EventEmitter {`
`385`	`388`	`}`
`386`	`389`	`}`
`387`	`390`
`388`		`-module.exports = IDocument`
	`391`	`+module.exports = IDocument`