decagraphicsdecagraphics/scriptUpdateNode2.js

107 lines
3.5 KiB
JavaScript

//Load Environment Variables
require('dotenv').config()
//IPFS
const IpfsClient = require('ipfs-http-client');
const OrbitDB = require('orbit-db');
//Instance of IPFS locally in IPFS daemon
const node = IpfsClient('http://localhost:5001');
//Module for get prices
var getEth = require('./getEth');
//ABI from contract DECA ERC20
const abi = require("./ABI.js");
//Web3 and IPC Provider
const Web3 = require('web3');
const web3 = new Web3(new Web3.providers.WebsocketProvider(process.env.INFURAKEY));
//DECA Contract instance
const decaContract = new web3.eth.Contract(abi, '0xD60DC0805f44d10cAc6594f1a501c67929448957');
async function index() {
//Open and load orbitdb databases
const orbitdb = await OrbitDB.createInstance(node)
const db = await orbitdb.docs('/orbitdb/zdpuAykPJ4qtBg2toS2vxr5eaPfGEBJmvGerM7V7x8qn5c8hW/decaCCDB', {
indexBy: 'CCID'
});
await db.load();
const db2 = await orbitdb.docs('decaPrices', {
indexBy: 'dates'
});
await db2.load();
const db3 = await orbitdb.docs('decaGeth', {
indexBy: 'dates'
});
await db3.load();
const db4 = await orbitdb.docs('decaCCT', {
indexBy: 'dates'
});
await db4.load();
//Flag to save the following data
let dates = 1591980300;
while (true) {
//Get Carbon Credits Data
const data = db.get('');
//Compare flag and unixtime to add data
if (Math.round(new Date().getTime() / 1000) == dates) {
dates += 300;
//Get data from functions
let elemsGeth = await getGethElems(dates);
let elemsDECAPrice = await getEth(dates);
let ccTotalEth = await getEthSum(data, dates);
//checks every 2 minutes to see if the data has already been inserted into the DBs if not
setTimeout(function () {
const query1 = db2.query((doc) => doc.dates == dates);
const query2 = db3.query((doc) => doc.dates == dates);
const query3 = db4.query((doc) => doc.dates == dates);
if(query1.length > 0){
const hash1 = await db2.put(elemsDECAPrice);
console.log(hash1);
}
if(query2.length > 0){
const hash2 = await db3.put(elemsGeth);
console.log(hash2);
}
if(query3.length > 0){
const hash3 = await db4.put(ccTotalEth);
console.log(hash3);
}
}, 20000);
}
}
}
index();
//Function to save data from web3 and contract (ret TotalSupply, Ethereum, Date)
const getGethElems = async (dates) => {
let ret = {};
var balanceEthereum = await web3.eth.getBalance('0xD60DC0805f44d10cAc6594f1a501c67929448957');
var totalSupply = await decaContract.methods.totalSupply().call();
totalSupply = web3.utils.fromWei(totalSupply, 'ether');
balanceEthereum = web3.utils.fromWei(balanceEthereum, 'ether');
ret.DTS = totalSupply;
ret.ETS = balanceEthereum;
ret.dates = dates;
return ret;
}
//Function to save data from orbitDB CC (ret ccTotal, ccTS, dates)
const getEthSum = async (elemsCC, dates) => {
const ret = {};
let sum = 0;
let sumCC = 0;
for (let key in elemsCC) {
sum += elemsCC[key]['conversionPrice']['ETH'];
}
for (let key in elemsCC) {
sumCC += 1;
}
ret.ccTotal = sumCC;
ret.ccTS = sum;
ret.dates = dates;
return ret;
}