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

fix for flosight changes

Browse Source
This commit is contained in:
sairajzero 2023-05-12 01:44:04 +05:30
parent 5387f818fd
commit d1c80ff958
1 changed files with 9 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
scripts/bobs-fund.js
View File

@ -193,15 +193,16 @@ const bobsFund = (function () {
function refreshBlockchainData(newOnly = false) { function refreshBlockchainData(newOnly = false) {
return new Promise((resolve, reject) => { return new Promise((resolve, reject) => {
compactIDB.readData("appendix", "lastTx").then(lastTx => { compactIDB.readData("appendix", "lastTx").then(lastTx => {
floBlockchainAPI.readData(floGlobals.adminID, { var query_options = { tx: true, filter: d => d.startsWith(bobsFund.productStr) };
ignoreOld: lastTx, query_options.senders = floExchangeAPI.nodeList.concat(floGlobals.adminID); //sentOnly: true,
senders: floExchangeAPI.nodeList.concat(floGlobals.adminID), //sentOnly: true, if (typeof lastTx == 'number') //lastTx is tx count (*backward support)
tx: true, query_options.ignoreOld = lastTx;
filter: d => d.startsWith(bobsFund.productStr) else if (typeof lastTx == 'string') //lastTx is txid of last tx
}).then(result => { query_options.after = lastTx;
floBlockchainAPI.readData(floGlobals.adminID, query_options).then(result => {
compactIDB.readAllData("funds").then(funds => { compactIDB.readAllData("funds").then(funds => {
let writeKeys = new Set(); let writeKeys = new Set();
result.data.reverse().forEach(d => { result.items.reverse().forEach(d => {
if (/close: /i.test(d.data)) { if (/close: /i.test(d.data)) {
let ctx = d.data.match(/close: [0-9a-z]{64}/i).toString().split(": ")[1]; let ctx = d.data.match(/close: [0-9a-z]{64}/i).toString().split(": ")[1];
funds[ctx].push({ funds[ctx].push({
@ -228,7 +229,7 @@ function refreshBlockchainData(newOnly = false) {
}) })
writeKeys = Array.from(writeKeys); writeKeys = Array.from(writeKeys);
Promise.all(writeKeys.map(k => compactIDB.writeData("funds", funds[k], k))).then(results => { Promise.all(writeKeys.map(k => compactIDB.writeData("funds", funds[k], k))).then(results => {
compactIDB.writeData('appendix', result.totalTxs, "lastTx"); compactIDB.writeData('appendix', result.lastItem, "lastTx");
resolve(newOnly ? writeKeys.map(k => funds[k]) : funds) resolve(newOnly ? writeKeys.map(k => funds[k]) : funds)
}).catch(error => reject(error)) }).catch(error => reject(error))
}).catch(error => reject(error)) }).catch(error => reject(error))