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

Adding requestApplicationData

Browse Source 
requestApplicationData : request any message from the supernode cloud
Fixed minor bugs
This commit is contained in:
sairajzero 2019-11-20 20:20:39 +05:30
parent 62ac2a9371
commit 577bee4d37
1 changed files with 39 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

51
standard_Operations.html
View File

@ -22,7 +22,14 @@
fee: 0.0005, fee: 0.0005,
//Required for Supernode operations //Required for Supernode operations
supernodes: {} //each supnernode must be stored as floID : {uri:<uri>,pubKey:<publicKey>} SNStorageID: "FEzk75EGMPEQMrCuPosGiwuK162hcEu49E",
supernodes: {}, //each supnernode must be stored as floID : {uri:<uri>,pubKey:<publicKey>}
//for cloud apps
subAdmins: [],
application: "Test_RIBC",
vectorClock: {},
appObjects: {}
} }
</script> </script>
@ -6240,6 +6247,26 @@
}) })
}, },
//request any data from supernode cloud
requestApplicationData: function(options = {}){
return new Promise((resolve,reject) => {
var request = {
receiverID: options.receiverID || floGlobals.adminID,
senderIDs: options.senderIDs || undefined,
application: options.application || floGlobals.application,
type: options.type || undefined,
comment: options.comment || undefined,
lowerVectorClock: options.lowerVectorClock || undefined,
upperVectorClock: options.upperVectorClock || undefined,
atVectorClock: options.atVectorClock || undefined,
mostRecent: options.mostRecent || undefined,
}
floSupernode.requestData(JSON.stringify(request), request.receiverID)
.then(response => resolve(response))
.catch(error => reject(error))
})
},
//request an object data from supernode cloud //request an object data from supernode cloud
requestObjectData: function(objectName, options = {}){ requestObjectData: function(objectName, options = {}){
var request = { var request = {
@ -6265,10 +6292,10 @@
var message = { var message = {
division: options.division || floGlobals.division, division: options.division || floGlobals.division,
object: objectName, object: objectName,
vectorClock: floGlobals.vectorClock[object], vectorClock: floGlobals.vectorClock[objectName],
reset: newObject reset: newObject
} }
this.sendApplicationData(message, `${object}@Reset`, options) this.sendApplicationData(message, `${objectName}@Reset`, options)
.then(result => reactor.dispatchEvent('logHandle',result)) .then(result => reactor.dispatchEvent('logHandle',result))
.catch(error => reactor.dispatchEvent('errorHandle',error)) .catch(error => reactor.dispatchEvent('errorHandle',error))
}, },
@ -6278,10 +6305,10 @@
var message = { var message = {
division: options.division || floGlobals.division, division: options.division || floGlobals.division,
object: objectName, object: objectName,
vectorClock: floGlobals.vectorClock[object], vectorClock: floGlobals.vectorClock[objectName],
diff: detailedDiff(oldObject, newObject) diff: detailedDiff(oldObject, newObject)
} }
this.sendApplicationData(message, `${object}@Update`, options) this.sendApplicationData(message, `${objectName}@Update`, options)
.then(result => reactor.dispatchEvent('logHandle',result)) .then(result => reactor.dispatchEvent('logHandle',result))
.catch(error => reactor.dispatchEvent('errorHandle',error)) .catch(error => reactor.dispatchEvent('errorHandle',error))
} }
@ -6293,15 +6320,15 @@
dataSet = JSON.parse(dataSet); dataSet = JSON.parse(dataSet);
console.log(dataSet) console.log(dataSet)
for(vc in dataSet){ for(vc in dataSet){
if(floGlobals.subAdmins.includes(dataSet[v].senderID)){ //if(floGlobals.subAdmins.includes(dataSet[vc].senderID)){
var message = dataSet[v].message; var message = dataSet[vc].message;
if(message.reset){ if(message.reset){
floGlobals.appObjects[message.object] = message.reset floGlobals.appObjects[message.object] = message.reset
floGlobals.vectorClock[message.object] = vc floGlobals.vectorClock[message.object] = vc
//compactIDB.writeData("appObjects", floGlobals.appObjects[message.object], message.object) //compactIDB.writeData("appObjects", floGlobals.appObjects[message.object], message.object)
//compactIDB.writeData("vectorClocks", vc, message.object) //compactIDB.writeData("vectorClocks", vc, message.object)
} }
} //}
} }
}catch(error){ }catch(error){
console.log(error) console.log(error)
@ -6314,13 +6341,13 @@
dataSet = JSON.parse(dataSet); dataSet = JSON.parse(dataSet);
console.log(dataSet) console.log(dataSet)
for(vc in dataSet){ for(vc in dataSet){
if(floGlobals.subAdmins.includes(dataSet[v].senderID)){ //if(floGlobals.subAdmins.includes(dataSet[vc].senderID)){
var message = dataSet[v].message; var message = dataSet[vc].message;
if(message.diff){ if(message.diff){
floGlobals.appObjects[message.object] = mergeAllDiff(floGlobals.appObjects[message.object], message.diff) floGlobals.appObjects[message.object] = mergeAllDiff(floGlobals.appObjects[message.object], message.diff)
//compactIDB.writeData("objects",floGlobals.appObjects[message.object], message.object) //compactIDB.writeData("appObjects",floGlobals.appObjects[message.object], message.object)
} }
} //}
floGlobals.vectorClock[message.object] = vc floGlobals.vectorClock[message.object] = vc
//compactIDB.writeData("vectorClocks", vc, message.object) //compactIDB.writeData("vectorClocks", vc, message.object)
} }