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

Merge pull request #4 from sairajzero/main

Browse Source 
Update floBlockchainAPI.js
This commit is contained in:
Sai Raj 2022-03-09 20:45:42 +05:30 committed by GitHub
commit 9ae1ea2602
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 75 additions and 69 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

144
src/floBlockchainAPI.js
View File

@ -1,5 +1,6 @@
'use strict'; 'use strict';
/* FLO Blockchain Operator to send/receive data from blockchain using API calls*/ /* FLO Blockchain Operator to send/receive data from blockchain using API calls*/
//version 2.2.1
(function(GLOBAL) { (function(GLOBAL) {
const floBlockchainAPI = GLOBAL.floBlockchainAPI = { const floBlockchainAPI = GLOBAL.floBlockchainAPI = {
@ -426,76 +427,81 @@
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 => {
var newItems = response.totalItems - options.ignoreOld; var newItems = response.totalItems - options.ignoreOld;
this.promisedAPI(`api/addrs/${addr}/txs?from=0&to=${newItems*2}`).then( this.promisedAPI(`api/addrs/${addr}/txs?from=0&to=${newItems*2}`).then(response => {
response => { if (options.limit <= 0)
if (options.limit <= 0) options.limit = response.items.length;
options.limit = response.items.length; var filteredData = [];
var filteredData = []; let numToRead = response.totalItems - options.ignoreOld,
for (let i = 0; i < (response.totalItems - options.ignoreOld) && unconfirmedCount = 0;
filteredData.length < options.limit; i++) { for (let i = 0; i < numToRead && filteredData.length < options.limit; i++) {
if (options.pattern) { if (!response.items[i].confirmations) { //unconfirmed transactions
try { unconfirmedCount++;
let jsonContent = JSON.parse(response.items[i].floData); numToRead++;
if (!Object.keys(jsonContent).includes(options.pattern)) continue;
continue;
} catch (error) {
continue;
}
}
if (options.sentOnly) {
let flag = false;
for (let vin of response.items[i].vin)
if (vin.addr === addr) {
flag = true;
break;
}
if (!flag) continue;
}
if (Array.isArray(options.sender)) {
let flag = false;
for (let vin of response.items[i].vin)
if (options.sender.includes(vin.addr)) {
flag = true;
break;
}
if (!flag) continue;
}
if (options.receivedOnly) {
let flag = false;
for (let vout of response.items[i].vout)
if (vout.scriptPubKey.addresses[0] === addr) {
flag = true;
break;
}
if (!flag) continue;
}
if (Array.isArray(options.receiver)) {
let flag = false;
for (let vout of response.items[i].vout)
if (options.receiver.includes(vout.scriptPubKey.addresses[0])) {
flag = true;
break;
}
if (!flag) continue;
}
if (options.filter && !options.filter(response.items[i].floData))
continue;
if (options.tx) {
let d = {}
d.txid = response.items[i].txid;
d.time = response.items[i].time;
d.blockheight = response.items[i].blockheight;
d.data = response.items[i].floData;
filteredData.push(d);
} else
filteredData.push(response.items[i].floData);
} }
resolve({ if (options.pattern) {
totalTxs: response.totalItems, try {
data: filteredData let jsonContent = JSON.parse(response.items[i].floData);
}); if (!Object.keys(jsonContent).includes(options.pattern))
}).catch(error => { continue;
} catch (error) {
continue;
}
}
if (options.sentOnly) {
let flag = false;
for (let vin of response.items[i].vin)
if (vin.addr === addr) {
flag = true;
break;
}
if (!flag) continue;
}
if (Array.isArray(options.sender)) {
let flag = false;
for (let vin of response.items[i].vin)
if (options.sender.includes(vin.addr)) {
flag = true;
break;
}
if (!flag) continue;
}
if (options.receivedOnly) {
let flag = false;
for (let vout of response.items[i].vout)
if (vout.scriptPubKey.addresses[0] === addr) {
flag = true;
break;
}
if (!flag) continue;
}
if (Array.isArray(options.receiver)) {
let flag = false;
for (let vout of response.items[i].vout)
if (options.receiver.includes(vout.scriptPubKey.addresses[0])) {
flag = true;
break;
}
if (!flag) continue;
}
if (options.filter && !options.filter(response.items[i].floData))
continue;
if (options.tx) {
let d = {}
d.txid = response.items[i].txid;
d.time = response.items[i].time;
d.blockheight = response.items[i].blockheight;
d.data = response.items[i].floData;
filteredData.push(d);
} else
filteredData.push(response.items[i].floData);
}
resolve({
totalTxs: response.totalItems - unconfirmedCount,
data: filteredData
});
}).catch(error => {
reject(error); reject(error);
}); });
}).catch(error => { }).catch(error => {