added stop, and now buys 100% of avail. balance

Author: modster

app.js

@@ -21,15 +21,13 @@ const binance = new Binance().options({
   useServerTime: true,
   recvWindow: 1500, // Set a higher recvWindow to increase response timeout
   verbose: false, // Add extra output when subscribing to WebSockets, etc
-  test: true,
+  test: false,
   reconnect: true
   // to do: enable Logging
 });
 
-const binance = new Binance().options('./options.json'); // <---- TODO: tweak recvWindo
-
 const symbol = 'BTCUSDT';
-const quantity = 0.015;
+const quantity = 0.0016;
 const hostname = '127.0.0.1';
 const port = 80;
 
@@ -45,52 +43,51 @@ eventEmitter.on('error', (err) => {
 eventEmitter.on('buy', () => {
 
   binance.balance((error, balances) => {
-
-    if (error) {
-      console.error(error);
-      return;
-    }
-    
+    if ( error ) return console.error(error);
+    const usdtBal = balances.USDT.available;
     if (balances.USDT.available > 20.00) {
-    
-    /*
-     *                  M A R K E T  O R D E R   -   B U Y  
-     */
-      binance.marketBuy(symbol, quantity, (error, response) => {
-        if (error) {
-        console.error(error);
-        }
-        console.log(response)
-        console.log("Bought " + quantity + " Order Id: " + response.orderId);
-      }); // marketBuy 
-    } // if
+      binance.bookTickers('BTCUSDT', (error, ticker) => {
+        tickAsk = ticker.askPrice;
+        let qty = usdtBal/tickAsk;
+        qty = qty.toFixed(5);
+        console.log(tickAsk, usdtBal, qty);
+        binance.marketBuy(symbol, qty);
+      });
+    }
+    else {
+      console.log('Balance < 20.00')
+    }
   }) // binance.balance
 }) // eventemitter.on('buy')
 
 eventEmitter.on('sell', () => {
 
   binance.balance((error, balances) => {
-
-    if (error) {
-      console.error(error);
-      return false;
-    }
+    if ( error ) return console.error(error);
 
-    if ( balances.BTC.available > quantity ) {   
-      /*
-      *                  M A R K E T   O R D E R  -  S E L L
-      */
-      binance.marketSell(symbol, quantity, (error, response) => {
-        if (error) {
-          console.error(error); 
-        }
-        console.log(response)
-        console.log('Sold ' + quantity + ' Order Id: ', + response.orderId);
-      }); // marketSell 
-    } // if
+    if ( balances.BTC.available > quantity ) {
+      binance.marketSell(symbol, quantity);
+    }
+  
+    else {
+      let btcBalance = balances.BTC.available;
+      binance.marketSell(symbol, btcBalance);
+    }
   }) // binance.balance
 }) // end eventemitter.on('sell')
 
+//  S T O P
+eventEmitter.on('stop', () => {
+
+  binance.balance((error, balances) => {
+
+    if ( error ) return console.error(error);
+
+    let btcBalance = balances.BTC.available;
+    binance.marketSell(symbol, btcBalance);
+  }) // binance.balance
+}) // end eventemitter.on('stop')
+
 const server = http.createServer((req, res) => {
   //const { headers, method, url } = req;
   let body = [];
@@ -108,7 +105,10 @@ const server = http.createServer((req, res) => {
     if(body === 'sell') {
       eventEmitter.emit('sell'); // <---------------------- SELL
     }
-
+    
+    if(body === 'stop') {
+      eventEmitter.emit('stop'); // <---------------------- SELL
+    }
     console.log(body);
     res.statusCode = 200;
     res.end();

index.js

@@ -20,6 +20,7 @@
   "author": "EM Greeff",
   "license": "MIT",
   "dependencies": {
+    "dotenv": "^8.2.0",
     "node-binance-api": "^0.9.8",
     "nodemon": "^2.0.4"
   }

package-lock.json

@@ -0,0 +1,9 @@
+
+eventEmitter.on('stop', () => {
+  binance.balance((error, balances) => {
+    if ( error ) return console.error(error);
+    let btcBalance = balances.BTC.available;
+    binance.marketSell(symbol, btcBalance);
+  }) // binance.balance
+}) // end eventemitter.on('stop')
+

package.json

@@ -0,0 +1,35 @@
+const http = require('http');
+const events = require('events');
+const Binance = require( 'node-binance-api' );
+require('dotenv').config();
+
+// B i n a n c e - N o d e - A P I   O p t i o n s
+const binance = new Binance().options({
+  APIKEY: process.env.BINANCE_APIKEY,
+  APISECRET: process.env.BINANCE_SECRET,
+  useServerTime: true,
+  recvWindow: 2500, // Set a higher recvWindow to increase response timeout
+  verbose: false, // Add extra output when subscribing to WebSockets, etc
+  test: true,
+  reconnect: true
+  // to do: enable Logging
+});
+
+const symbol = 'BTCUSDT';
+const quantity = 0.0016;
+
+binance.balance((error, balances) => {
+  if ( error ) return console.error(error);
+  const usdtBal = balances.USDT.available;
+  if (balances.USDT.available > 20.00) {
+    binance.bookTickers('BTCUSDT', (error, ticker) => {
+      tickAsk = ticker.askPrice;
+      let qty = usdtBal/tickAsk;
+      console.log(tickAsk, usdtBal, qty);
+      binance.marketBuy(symbol, qty);
+    });
+  }
+  else {
+    console.log('Balance < 20.00')
+  }
+}) // binance.balance