added nodemon

Author: modster

.gitignore

@@ -1,10 +1,8 @@
-# Options file with pub/priv keys
-# options.json
-
 # ngrok.exe
 ngrok.exe
 
-# Personal Modules
+# Binance Keys
+.env
 
 # Nodejs Modules
 node_modules

app.js

@@ -12,11 +12,22 @@
 const Binance = require( 'node-binance-api' );
 const http = require('http');
 const events = require('events');
-
+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: 1500, // 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 binance = new Binance().options('./options.json'); // <---- TODO: tweak recvWindo
 
-
 const symbol = 'BTCUSDT';
 const quantity = 0.015;
 const hostname = '127.0.0.1';
@@ -40,11 +51,11 @@ eventEmitter.on('buy', () => {
       return;
     }
 
-    if (balances.USDT.available > 200.00) {
+    if (balances.USDT.available > 20.00) {
 
-     /*
-      *                  M A R K E T  O R D E R   -   B U Y  
-      */
+    /*
+     *                  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);
@@ -56,7 +67,6 @@ eventEmitter.on('buy', () => {
   }) // binance.balance
 }) // eventemitter.on('buy')
 
-
 eventEmitter.on('sell', () => {
 
   binance.balance((error, balances) => {
@@ -81,7 +91,6 @@ eventEmitter.on('sell', () => {
   }) // binance.balance
 }) // end eventemitter.on('sell')
 
-
 const server = http.createServer((req, res) => {
   //const { headers, method, url } = req;
   let body = [];
@@ -107,7 +116,6 @@ const server = http.createServer((req, res) => {
   )}
 );
 
-
 server.listen(port, hostname, () => {
   console.log(`Server running at http://${hostname}:${port}/`);
 });

index.js

@@ -0,0 +1,99 @@
+var http = require('http');
+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: 1500, // 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 port = 80
+
+async function buy () {
+  try {
+    let usdtBal, qty, price;
+    let balances_data = await binance.futuresBalance(), assets = Object.keys( balances_data );
+    for ( let asset of assets ) {
+      let obj = balances_data[asset], bal = Number( obj.balance );
+      if ( obj.asset == 'USDT' ) {
+        console.log(`USDT balance: ${bal}`);
+        usdtBal = bal;
+        //const response = await binance.futuresMarketBuy( 'BTCUSDT', qty ) <-----------------------!
+        //console.log(response) <--------------------------------------------------------------------!
+      }
+    }
+  } catch (error) {
+    console.error(error)
+  }
+}
+
+async function sell () {
+  try {
+    let qty = 0.0016;
+    let balances_data = await binance.futuresBalance(), assets = Object.keys( balances_data );
+    for ( let asset of assets ) {
+      let obj = balances_data[asset], bal = Number( obj.balance );
+      if ( obj.asset == 'USDT' ) { // <-------------------------------------------------CHANGE TO BTC
+        console.log(`BTC balance ${bal}`);
+        qty = bal * 0.1;
+        console.log(`10% of BTC balance ${qty}`);
+        // response = await binance.futuresMarketSell( 'BTCUSDT', qty ) <-------------------------------UNCOMMENT
+        // console.log( response )
+      }
+    }
+  } catch (error) {
+    console.error(error)
+  }
+}
+
+async function stop () {
+  try {
+    let balances_data = await binance.futuresBalance(), assets = Object.keys( balances_data );
+    for ( let asset of assets ) {
+      let obj = balances_data[asset], bal = Number( obj.balance );
+      if ( obj.asset == 'BTC' ) {
+        console.log(bal);
+        //const response = await binance.futuresMarketSell( 'BTCUSDT', bal ) <-------------------------------!
+        //console.log(response) <----------------------------------------------------------------------------!
+      }
+    }
+  } catch (error) {
+    console.error(error)
+  }
+}
+
+//create a server object:
+http.createServer(function (req, res) {
+  if(req.url == '/balances') {
+    balances();
+    message = 'Balances Success';
+  }
+  else if(req.url == '/stop') {
+    stop();
+    message = 'Stop Success';
+  }
+  else if(req.url == '/buy') {
+    buy();
+    message = 'Buy Success';
+  }
+  else if(req.url == '/sell') {
+    sell();
+    message = 'Sell Success';
+  }
+  else {
+    message = '404';
+  }
+  
+  res.writeHead(200, {'Content-Type': 'text/html'});
+  res.write(message); //write a response to the client
+  res.end(); //end the response
+
+}).listen(port); //the server object listens on port 80
+console.log('Listening on ' + port)