Merge branch 'develop' into origin/product_updates

exchanges/binance.js

@@ -32,6 +32,10 @@ var Trader = function(config) {
     recvWindow: 60000, // suggested by binance
     disableBeautification: false
   });
+
+  // Binance has tight timing requirements, this will ask their server for the time and store
+  // a drift value so we can calculate the most accurate timestamp possible form our system time
+  this.binance.startTimeSync();
 };
 
 var retryCritical = {

package.json

@@ -17,7 +17,7 @@
   "dependencies": {
     "@slack/client": "^3.10.0",
     "async": "2.1.2",
-    "binance": "^1.1.0",
+    "binance": "^1.3.0",
     "bitcoin-co-id": "0.0.1",
     "bitexthai": "^0.1.0",
     "bitfinex-api-node": "^1.2.0",

plugins/postgresql/handle.js

@@ -48,7 +48,7 @@ checkClient.connect(function(err){
       if(err) {
         util.die(err);
       }
-      if(res.rowCount == 0){ //database does not exist
+      if(res.rows[0].count == 0){ //database does not exist
         log.debug("Database "+dbName+" does not exist");
         if(mode === 'realtime') { //create database if not found
           log.debug("Creating database "+dbName);

plugins/postgresql/util.js

@@ -38,14 +38,14 @@ module.exports = {
   database: function () {
     return useSingleDatabase() ?
       config.postgresql.database :
-      config.watch.exchange.toLowerCase();
+      config.watch.exchange.toLowerCase().replace(/\-/g,'');
   },
 
   // returns table name which can be different if we use
   // single or multiple db setup.
   table: function (name) {
     if (useSingleDatabase()) {
-      name = watch.exchange + '_' + name;
+      name = watch.exchange.replace(/\-/g,'') + '_' + name;
     }
     var fullName = [name, settings.pair.join('_')].join('_');
     return useLowerCaseTableNames() ? fullName.toLowerCase() : fullName;

plugins/postgresql/writer.js

@@ -45,7 +45,7 @@ Store.prototype.writeCandles = function() {
   var stmt = `
   INSERT INTO ${postgresUtil.table('candles')}
   (start, open, high,low, close, vwp, volume, trades)
-  select $1, $2, $3, $4, $5, $6, $7, $8
+  select $1, $2, $3, $4, $5, $6, $7, $8
   WHERE NOT EXISTS (select id from ${postgresUtil.table('candles')} where start=$1);
   `;
 
@@ -67,7 +67,7 @@ Store.prototype.writeCandles = function() {
 
 var processCandle = function(candle, done) {
   this.cache.push(candle);
-  if (this.cache.length > 100) 
+  if (this.cache.length > 1) 
     this.writeCandles();
 
   done();