Morph MORPH
SIGN IN SIGN UP
askmike / gekko UNCLAIMED

A bitcoin trading bot written in node - https://gekko.wizb.it/

0 0 26 JavaScript
Normal View History Raw
Adds scanner that looks for databases with exchange tables in them. Returns array of all dxchanges with their curreency and asset pairs. Use as: scan((err, markets) => { console.log('markets', markets); }); This would write: [ { exchange: 'poloniex', currency: 'usdt', asset: 'btc' } ] Similar to what sqlite scanner is doing.
2017-03-28 22:17:57 +02:00
const _ = require('lodash');
const async = require('async');
var pg = require('pg');
const util = require('../../core/util.js');
const config = util.getConfig();
const dirs = util.dirs();
var postgresUtil = require('./util');
var connectionString = config.postgresql.connectionString;
module.exports = done => {
var scanClient = new pg.Client(connectionString+"/postgres");
let markets = [];
scanClient.connect(function (err) {
if(err){
util.die(err);
}
Single DB setup.
2017-04-04 22:37:26 +02:00
var sql = "select datname from pg_database";
// In single DB setup we don't need to go look into other DBs
if (postgresUtil.useSingleDatabase()) {
sql = "select datname from pg_database where datname='" + postgresUtil.database() + "'";
}
var query = scanClient.query(sql, function (err, result) {
Adds scanner that looks for databases with exchange tables in them. Returns array of all dxchanges with their curreency and asset pairs. Use as: scan((err, markets) => { console.log('markets', markets); }); This would write: [ { exchange: 'poloniex', currency: 'usdt', asset: 'btc' } ] Similar to what sqlite scanner is doing.
2017-03-28 22:17:57 +02:00
async.each(result.rows, (dbRow, next) => {
var scanTablesClient = new pg.Client(connectionString + "/" + dbRow.datname);
var dbName = dbRow.datname;
scanTablesClient.connect(function (err) {
if (err) {
return next();
}
var query = scanTablesClient.query(`
SELECT table_name
FROM information_schema.tables
WHERE table_schema='${postgresUtil.schema()}';
`, function(err, result) {
if (err) {
return util.die('DB error at `scanning tables`');
}
_.each(result.rows, table => {
let parts = table.table_name.split('_');
let first = parts.shift();
Single DB setup.
2017-04-04 22:37:26 +02:00
let exchangeName = dbName;
/**
* If using single database, we need to strip
* exchange from table name. See here how tables
* are named:
*
* - in single database setup: poloniex_candles_usdt_btc
* - in multi db setup: db = poloniex, table = candles_usdt_btc
*/
if (postgresUtil.useSingleDatabase()) {
exchangeName = first;
first = parts.shift();
}
Adds scanner that looks for databases with exchange tables in them. Returns array of all dxchanges with their curreency and asset pairs. Use as: scan((err, markets) => { console.log('markets', markets); }); This would write: [ { exchange: 'poloniex', currency: 'usdt', asset: 'btc' } ] Similar to what sqlite scanner is doing.
2017-03-28 22:17:57 +02:00
if(first === 'candles')
markets.push({
Single DB setup.
2017-04-04 22:37:26 +02:00
exchange: exchangeName,
Adds scanner that looks for databases with exchange tables in them. Returns array of all dxchanges with their curreency and asset pairs. Use as: scan((err, markets) => { console.log('markets', markets); }); This would write: [ { exchange: 'poloniex', currency: 'usdt', asset: 'btc' } ] Similar to what sqlite scanner is doing.
2017-03-28 22:17:57 +02:00
currency: _.first(parts),
asset: _.last(parts)
});
});
scanTablesClient.end();
next();
});
});
},
// got all tables!
err => {
scanClient.end();
done(err, markets);
});
});
});
}
Reference in New Issue Copy Permalink