RanchiMall/exchangemarket
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Improved floCloudAPI

Browse Source 
floCloudAPI now stores the lastCommit value of the objects via requestObjectData, resetObjectData, updateObjectData

resetObjectData and updateObjectData now takes the new and old value from floGlobals.appObjects and lastCommit respectively

Parameter changes:
resetObjectData: function(objectName, options = {})
updateObjectData: function(objectName, options = {})
This commit is contained in:
sairajzero 2020-03-10 22:00:56 +05:30
parent 8652959e54
commit 3d0c8883b7
1 changed files with 16 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
standard_Operations.html
View File

@ -8286,6 +8286,9 @@ Bitcoin.Util = {
const floCloudAPI = { const floCloudAPI = {
util:{ util:{
lastCommit: {},
resetData: function(dataSet){ resetData: function(dataSet){
try{ try{
dataSet = JSON.parse(dataSet); dataSet = JSON.parse(dataSet);
@ -8420,6 +8423,7 @@ Bitcoin.Util = {
request.mostRecent = false request.mostRecent = false
floSupernode.requestData(JSON.stringify(request), request.receiverID).then(dataSet => { floSupernode.requestData(JSON.stringify(request), request.receiverID).then(dataSet => {
this.util.updateData(dataSet) this.util.updateData(dataSet)
this.util.lastCommit[objectName] = JSON.stringify(floGlobals.appObjects[objectName])
resolve('Object Data Updated') resolve('Object Data Updated')
}).catch(error => reject(error)) }).catch(error => reject(error))
}).catch(error => reject(error)) }).catch(error => reject(error))
@ -8427,32 +8431,34 @@ Bitcoin.Util = {
}, },
//reset or initialize an object and send it to cloud //reset or initialize an object and send it to cloud
resetObjectData: function(newObject, objectName, options = {}){ resetObjectData: function(objectName, options = {}){
return new Promise((resolve,reject) => { return new Promise((resolve,reject) => {
var message = { var message = {
division: options.division || floGlobals.division, division: options.division || floGlobals.division,
object: objectName, object: objectName,
vectorClock: floGlobals.vectorClock[objectName], vectorClock: floGlobals.vectorClock[objectName],
reset: newObject reset: floGlobals.appObjects[objectName]
} }
this.sendApplicationData(message, `${objectName}@Reset`, options) this.sendApplicationData(message, `${objectName}@Reset`, options).then(result => {
.then(result => resolve(result)) this.util.lastCommit[objectName] = JSON.stringify(floGlobals.appObjects[objectName])
.catch(error => reject(error)) resolve(result)
}).catch(error => reject(error))
}) })
}, },
//update the diff and send it to cloud //update the diff and send it to cloud
updateObjectData: function(oldObject, newObject, objectName, options = {}){ updateObjectData: function(objectName, options = {}){
return new Promise((resolve,reject) => { return new Promise((resolve,reject) => {
var message = { var message = {
division: options.division || floGlobals.division, division: options.division || floGlobals.division,
object: objectName, object: objectName,
vectorClock: floGlobals.vectorClock[objectName], vectorClock: floGlobals.vectorClock[objectName],
diff: findDifference(oldObject, newObject) diff: findDifference(JSON.parse(this.util.lastCommit[objectName]), floGlobals.appObjects[objectName])
} }
this.sendApplicationData(message, `${objectName}@Update`, options) this.sendApplicationData(message, `${objectName}@Update`, options).then(result => {
.then(result => resolve(result)) this.util.lastCommit[objectName] = JSON.stringify(floGlobals.appObjects[objectName])
.catch(error => reject(error)) resolve(result)
}).catch(error => reject(error))
}) })
} }
} }