exchange rate logging to influxdb

6 years ago · 9651a4c157
1 changed files with 10 additions and 0 deletions
--- a/app/utils.js
+++ b/app/utils.js
@ -278,6 +278,16 @@ function refreshExchangeRate() {
 					global.exchangeRate = exchangeRate;
 					global.exchangeRateUpdateTime = new Date();

+					if (global.influxdb) {
+						global.influxdb.writePoints([{
+							measurement: "exchange_rates.btc_usd",
+							fields:{value:parseFloat(exchangeRate)}
+
+						}]).catch(err => {
+							console.error(`Error saving data to InfluxDB: ${err.stack}`)
+						});
+					}
+
 					console.log("Using exchange rate: " + global.exchangeRate + " USD/" + coins[config.coin].name + " starting at " + global.exchangeRateUpdateTime);

 				} else {