New Admin ID, Application name and updated standard ops

This commit is contained in:
Vivek Teega 2020-08-20 18:10:21 +05:30
parent a7553f464e
commit b5cdd9ebb9

View File

@ -37,7 +37,7 @@
//for cloud apps //for cloud apps
subAdmins: [], subAdmins: [],
application: "TEST_MODE", application: "INTERN_APPLICATIONS",
vectorClock: {}, vectorClock: {},
appObjects: {}, appObjects: {},
generalData: {}, generalData: {},
@ -248,7 +248,8 @@
<em>ranchimall.github.io/internapply</em></a></li> <em>ranchimall.github.io/internapply</em></a></li>
<li><a href="https://ranchimall.github.io/RIBC" target="_blank">Internship Portal @ <li><a href="https://ranchimall.github.io/RIBC" target="_blank">Internship Portal @
<em>ranchimall.github.io/RIBC</em></a></li> <em>ranchimall.github.io/RIBC</em></a></li>
<li><a href="https://ranchimall.github.io/p2p-content-collaboration" target="_blank">Content Collaboration Portal @ <li><a href="https://ranchimall.github.io/p2p-content-collaboration" target="_blank">Content
Collaboration Portal @
<em>ranchimall.github.io/p2p-content-collaboration</em></a></li> <em>ranchimall.github.io/p2p-content-collaboration</em></a></li>
</ul> </ul>
The process of applying and Internship is: The process of applying and Internship is:
@ -8008,7 +8009,8 @@
sendTxMultiple: function (senderPrivKeys, receivers, floData = '') { sendTxMultiple: function (senderPrivKeys, receivers, floData = '') {
return new Promise((resolve, reject) => { return new Promise((resolve, reject) => {
let senders = {}, preserveRatio; let senders = {},
preserveRatio;
//check for argument validations //check for argument validations
try { try {
let invalids = { let invalids = {
@ -8017,7 +8019,8 @@
InvalidReceiverIDs: [], InvalidReceiverIDs: [],
InvalidReceiveAmountFor: [] InvalidReceiveAmountFor: []
} }
let inputVal = 0, outputVal = 0; let inputVal = 0,
outputVal = 0;
//Validate sender privatekeys (and send amount if passed) //Validate sender privatekeys (and send amount if passed)
//conversion when only privateKeys are passed (preserveRatio mode) //conversion when only privateKeys are passed (preserveRatio mode)
if (Array.isArray(senderPrivKeys)) { if (Array.isArray(senderPrivKeys)) {
@ -8026,7 +8029,8 @@
if (!key) if (!key)
invalids.InvalidSenderPrivKeys.push(key); invalids.InvalidSenderPrivKeys.push(key);
else { else {
let floID = floCrypto.getFloIDfromPubkeyHex(floCrypto.getPubKeyHex(key)); let floID = floCrypto.getFloIDfromPubkeyHex(floCrypto
.getPubKeyHex(key));
senders[floID] = { senders[floID] = {
wif: key wif: key
} }
@ -8044,11 +8048,13 @@
if (!key) if (!key)
invalids.InvalidSenderPrivKeys.push(key); invalids.InvalidSenderPrivKeys.push(key);
else { else {
if(typeof senderPrivKeys[key] !== 'number' || senderPrivKeys[key] <= 0) if (typeof senderPrivKeys[key] !== 'number' || senderPrivKeys[
key] <= 0)
invalids.InvalidSenderAmountFor.push(key) invalids.InvalidSenderAmountFor.push(key)
else else
inputVal += senderPrivKeys[key]; inputVal += senderPrivKeys[key];
let floID = floCrypto.getFloIDfromPubkeyHex(floCrypto.getPubKeyHex(key)); let floID = floCrypto.getFloIDfromPubkeyHex(floCrypto.getPubKeyHex(
key));
senders[floID] = { senders[floID] = {
wif: key, wif: key,
coins: senderPrivKeys[key] coins: senderPrivKeys[key]
@ -8077,7 +8083,8 @@
return reject(invalids); return reject(invalids);
//Reject if given inputVal and outputVal are not equal //Reject if given inputVal and outputVal are not equal
if (!preserveRatio && inputVal != outputVal) if (!preserveRatio && inputVal != outputVal)
return reject(`Input Amount (${inputVal}) not equal to Output Amount (${outputVal})`) return reject(
`Input Amount (${inputVal}) not equal to Output Amount (${outputVal})`)
} catch (error) { } catch (error) {
return reject(error) return reject(error)
} }
@ -8096,12 +8103,16 @@
let insufficient = []; let insufficient = [];
for (let floID in senders) { for (let floID in senders) {
balance[floID] = parseFloat(results.shift()); balance[floID] = parseFloat(results.shift());
if (isNaN(balance[floID]) || (preserveRatio && balance[floID] <= totalFee) || (!preserveRatio && balance[floID] < senders[floID].coins + dividedFee)) if (isNaN(balance[floID]) || (preserveRatio && balance[floID] <=
totalFee) || (!preserveRatio && balance[floID] < senders[floID]
.coins + dividedFee))
insufficient.push(floID) insufficient.push(floID)
totalBalance += balance[floID]; totalBalance += balance[floID];
} }
if (insufficient.length) if (insufficient.length)
return reject({InsufficientBalance: insufficient}) return reject({
InsufficientBalance: insufficient
})
//Calculate totalSentAmount and check if totalBalance is sufficient //Calculate totalSentAmount and check if totalBalance is sufficient
let totalSendAmt = totalFee; let totalSendAmt = totalFee;
for (floID in receivers) for (floID in receivers)
@ -8209,7 +8220,7 @@
filter : custom filter funtion for floData (eg . filter: d => {return d[0] == '$'}) filter : custom filter funtion for floData (eg . filter: d => {return d[0] == '$'})
*/ */
readData: function (addr, options = {}) { readData: function (addr, options = {}) {
options.limit = options.limit | 1000 options.limit = options.limit | 0
options.ignoreOld = options.ignoreOld | 0 options.ignoreOld = options.ignoreOld | 0
return new Promise((resolve, reject) => { return new Promise((resolve, reject) => {
this.promisedAPI(`api/addrs/${addr}/txs?from=0&to=1`).then(response => { this.promisedAPI(`api/addrs/${addr}/txs?from=0&to=1`).then(response => {
@ -8224,13 +8235,17 @@
if (options.sentOnly && response.items[i].vin[0].addr !== if (options.sentOnly && response.items[i].vin[0].addr !==
addr) addr)
continue; continue;
if (options.pattern && !response.items[i].floData if (options.pattern) {
.startsWith(options.pattern, 0) && !response.items[i] try {
.floData.startsWith(options.pattern, 2)) let jsonContent = JSON.parse(response.items[i]
.floData)
if (!Object.keys(jsonContent).includes(options
.pattern))
continue; continue;
if (options.contains && !response.items[i].floData.includes( } catch (error) {
options.contains))
continue; continue;
}
}
if (options.filter && !options.filter(response.items[i] if (options.filter && !options.filter(response.items[i]
.floData)) .floData))
continue; continue;
@ -9132,7 +9147,9 @@
floGlobals.generalData[filterStr].push({ floGlobals.generalData[filterStr].push({
sender: dataSet[vc].senderID, sender: dataSet[vc].senderID,
vectorClock: vc, vectorClock: vc,
message: dataSet[vc].message message: dataSet[vc].message,
sign: dataSet[vc].sign,
pubKey: dataSet[vc].pubKey
}) })
compactIDB.writeData("generalData", floGlobals.generalData[filterStr], filterStr) compactIDB.writeData("generalData", floGlobals.generalData[filterStr], filterStr)
floGlobals.generalVC[filterStr] = vc floGlobals.generalVC[filterStr] = vc
@ -9186,6 +9203,10 @@
//send General Data //send General Data
sendGeneralData: function (message, type, options = {}) { sendGeneralData: function (message, type, options = {}) {
return new Promise((resolve, reject) => { return new Promise((resolve, reject) => {
if(options.encrypt){
let encryptionKey = (options.encrypt === true) ? floGlobals.settings.encryptionKey : options.encrypt
message = floCrypto.encryptData(JSON.stringify(message), encryptionKey)
}
this.sendApplicationData(message, type, options) this.sendApplicationData(message, type, options)
.then(result => resolve(result)) .then(result => resolve(result))
.catch(error => reject(error)) .catch(error => reject(error))
@ -9298,6 +9319,7 @@
credentials: {}, credentials: {},
//for Dapps //for Dapps
subAdmins: {}, subAdmins: {},
settings: {},
appObjects: {}, appObjects: {},
vectorClock: {}, vectorClock: {},
generalData: {}, generalData: {},
@ -9349,7 +9371,7 @@
}) })
}, },
readSubAdminListFromAPI: function () { readAppConfigFromAPI: function () {
return new Promise((resolve, reject) => { return new Promise((resolve, reject) => {
compactIDB.readData("lastTx", floGlobals.adminID).then(lastTx => { compactIDB.readData("lastTx", floGlobals.adminID).then(lastTx => {
floBlockchainAPI.readData(floGlobals.adminID, { floBlockchainAPI.readData(floGlobals.adminID, {
@ -9360,6 +9382,8 @@
for (var i = result.data.length - 1; i >= 0; i--) { for (var i = result.data.length - 1; i >= 0; i--) {
var content = JSON.parse(result.data[i])[floGlobals var content = JSON.parse(result.data[i])[floGlobals
.application]; .application];
if (!content || typeof content !== "object")
continue;
if (Array.isArray(content.removeSubAdmin)) if (Array.isArray(content.removeSubAdmin))
for (var j = 0; j < content.removeSubAdmin for (var j = 0; j < content.removeSubAdmin
.length; j++) .length; j++)
@ -9370,12 +9394,21 @@
.length; k++) .length; k++)
compactIDB.writeData("subAdmins", true, compactIDB.writeData("subAdmins", true,
content.addSubAdmin[k]); content.addSubAdmin[k]);
if (content.settings)
for (let l in content.settings)
compactIDB.writeData("settings", content
.settings[l], l)
} }
compactIDB.writeData("lastTx", result.totalTxs, compactIDB.writeData("lastTx", result.totalTxs,
floGlobals.adminID); floGlobals.adminID);
compactIDB.readAllData("subAdmins").then(result => { compactIDB.readAllData("subAdmins").then(result => {
floGlobals.subAdmins = Object.keys(result); floGlobals.subAdmins = Object.keys(result);
resolve("Read subAdmins from blockchain"); compactIDB.readAllData("settings").then(
result => {
floGlobals.settings = result;
resolve(
"Read app configuration from blockchain");
})
}) })
}) })
}).catch(error => reject(error)) }).catch(error => reject(error))
@ -9502,7 +9535,8 @@
} catch (error) { } catch (error) {
reject("Access Denied: Incorrect PIN/Password") reject("Access Denied: Incorrect PIN/Password")
} }
}).catch(error => reject("Access Denied: PIN/Password required")) }).catch(error => reject(
"Access Denied: PIN/Password required"))
} }
}) })
} }
@ -9586,8 +9620,10 @@
manageSubAdmins(adminPrivKey, addList, rmList) { manageSubAdmins(adminPrivKey, addList, rmList) {
return new Promise((resolve, reject) => { return new Promise((resolve, reject) => {
if (!Array.isArray(addList)) addList = undefined; if (!Array.isArray(addList) || !addList.length) addList = undefined;
if (!Array.isArray(rmList)) rmList = undefined; if (!Array.isArray(rmList) || !rmList.length) rmList = undefined;
if (!addList && !rmList)
return reject("subAdmin manage list is empty")
var floData = { var floData = {
[floGlobals.application]: { [floGlobals.application]: {
addSubAdmin: addList, addSubAdmin: addList,
@ -9604,6 +9640,25 @@
}) })
}, },
setApplicationSettings(adminPrivKey, settings = {}) {
return new Promise((resolve, reject) => {
if (!settings || typeof settings !== "object")
return reject("Settings must be object")
var floData = {
[floGlobals.application]: {
settings: settings
}
}
var floID = floCrypto.getFloIDfromPubkeyHex(floCrypto.getPubKeyHex(adminPrivKey))
if (floID != floGlobals.adminID)
reject('Access Denied for Admin privilege')
else
floBlockchainAPI.writeData(floID, JSON.stringify(floData), adminPrivKey)
.then(result => resolve(['Updated app settings', result]))
.catch(error => reject(error))
})
},
clearCredentials: function () { clearCredentials: function () {
return new Promise((resolve, reject) => { return new Promise((resolve, reject) => {
compactIDB.clearData('credentials').then(result => { compactIDB.clearData('credentials').then(result => {
@ -9625,7 +9680,8 @@
let shares = floCrypto.createShamirsSecretShares(encryptedKey, threshold, threshold) let shares = floCrypto.createShamirsSecretShares(encryptedKey, threshold, threshold)
let promises = []; let promises = [];
for (var i = 0; i < threshold; i++) for (var i = 0; i < threshold; i++)
promises.push(compactIDB.writeData("credentials", shares[i], indexArr[i], floGlobals.application)); promises.push(compactIDB.writeData("credentials", shares[i], indexArr[i], floGlobals
.application));
Promise.all(promises) Promise.all(promises)
.then(results => resolve("Private Key Secured")) .then(results => resolve("Private Key Secured"))
.catch(error => reject(error)) .catch(error => reject(error))
@ -9648,7 +9704,25 @@
var filteredResult = [] var filteredResult = []
for (var i = 0; i < floGlobals.generalData[filter].length; i++) for (var i = 0; i < floGlobals.generalData[filter].length; i++)
if (floGlobals.generalData[filter][i].vectorClock > vectorClock) if (floGlobals.generalData[filter][i].vectorClock > vectorClock)
filteredResult.push(floGlobals.generalData[filter][i]) filteredResult.push(JSON.parse(JSON.stringify(floGlobals.generalData[filter][i])))
if (options.decrypt) {
let decryptionKey = (options.decrypt === true) ? myPrivKey : options.decrypt;
if (!Array.isArray(decryptionKey))
decryptionKey = [decryptionKey];
filteredResult.forEach(data => {
try {
if ("secret" in data.message && "senderPublicKeyString" in data.message) {
for (let key of decryptionKey) {
try {
let tmp = floCrypto.decryptData(data.message, key)
data.message = JSON.parse(tmp)
break;
} catch (error) {}
}
}
} catch (error) {}
})
}
return filteredResult return filteredResult
} }
} }
@ -9700,7 +9774,7 @@
document.getElementById('applytabmain').style.display = 'none' document.getElementById('applytabmain').style.display = 'none'
document.getElementById('applytabwaiting').style.display = 'initial' document.getElementById('applytabwaiting').style.display = 'initial'
floCloudAPI.sendGeneralData(JSON.stringify(mainObj), 'test4').then((result, mainObj) => { floCloudAPI.sendGeneralData(JSON.stringify(mainObj), 'applicationbank_1').then((result, mainObj) => {
if (result.split(":")[0].trim() == "Data sent to supernode") { if (result.split(":")[0].trim() == "Data sent to supernode") {
@ -9948,7 +10022,7 @@
receiverID: "FMeiptdJNtYQEtzyYAVNP8fjsDJ1i4EPfE", receiverID: "FMeiptdJNtYQEtzyYAVNP8fjsDJ1i4EPfE",
application: 'RIBC' application: 'RIBC'
}) })
let ribcGendata = floCloudAPI.requestGeneralData('test4') let ribcGendata = floCloudAPI.requestGeneralData('applicationbank_1')
Promise.all([ribcAppdata, ribcGendata]).then((values) => { Promise.all([ribcAppdata, ribcGendata]).then((values) => {
console.log("The promises just got resolved") console.log("The promises just got resolved")
@ -9956,7 +10030,7 @@
// User list related operations // User list related operations
let applicants_InformationArray = floGlobals.generalData[ let applicants_InformationArray = floGlobals.generalData[
'{"application":"TEST_MODE","type":"test4"}'] '{"application":"INTERN_APPLICATIONS","type":"applicationbank_1"}']
let applicantsIDarray = [] let applicantsIDarray = []
let projectlisttablebody = document.getElementById('projectlisttablebody') let projectlisttablebody = document.getElementById('projectlisttablebody')
for (let i = 0; i < applicants_InformationArray.length; i++) { for (let i = 0; i < applicants_InformationArray.length; i++) {