codeninja · May 23, 2023 05:57 · linglung · Mar 27, 2018 · Gustraa · Jun 9, 2022
diff --git a/openOrderMonitor.js b/openOrderMonitor.js
 //this script will monitor for all pairs and find any open orders for that pair.
 // I've done my best to account for throttling and make the script robust.
 // save locally, add your api key, and run with "node <script name>" in console.
 // You'll get alerted (in console) when an order fills.
 // if you'd like to send a donation my way:
 // BTC: 1JD595vphvXmWEwpjiUmfw3QzsBtE9jUP7
 // LTC: LcaHE2dqrH73xLtoKXwDZEUtDiY42iAvk4
 // ETH: 0x110191093ffab1f0d3d6012cc0de15f42257b7f6
 // BNB: 0x110191093ffab1f0d3d6012cc0de15f42257b7f6
 // [email protected] for questions... I'll do my best to support the script if you find any bugs.

 binanceNode  = require('binance-api-node')["default"];

 const api = binanceNode({apiKey: '*****', apiSecret: '****'});

 var orders = {}

 var openOrders = async function(pair){
  var res = await api.openOrders({symbol: pair})
  for( i in res){
    // save the open order that we know about
    orders[res[i]['orderId']] = res[i]
    // check back in 10 seconds, modify this to check more frequently, 
    // but note that there's a limit of 10 requests per second to the API
    setTimeout(checkOrderStatus, 10*1000, res[i]['orderId'])
  }

  // recheck our open orders every 1 seconds
  setTimeout(openOrders, 10*1000, pair);
 }

 // updates an order and notifies when it's status changes.
 var checkOrderStatus = async function(orderId){
  o = orders[orderId];

  var res = await api.getOrder({symbol:o['symbol'], orderId: orderId})

  // alert if our status has changed.
  if(res['status'] != o['status']){
    // this could play a sound, send a text, or rickroll 
    console.log('ALERT! Status for', o['orderId'], o['symbol'], o['price'], 'has changed to', res['status`'])
  }

  o[orderId] = res;
  // call ourselves in 10 more seconds if the status isn't filled
  if(res['status'].includes('NEW', "PARTIALLY_FILLED")){
    setTimeout(checkOrderStatus, 10*1000, orderId)  
  }
 }

 var delay = 0;

 // if you don't want to check all pairs, then use this instead
 // pairs= ['ETHBTC', 'LTCBTC']
 // for(i in pairs){
 //     // start a query, on a delay, for each pair.
 //     const pair = res['symbols'][i]['symbol']
 //     // openOrders(pair)
 //     var new_check = setTimeout(openOrders, 1000+delay, res['symbols'][i]['symbol'])
 //     delay += 1000 //100 ms added to delay for each symbol to avoid spamming the API and being banned.
 // }

 // checks all pairs on a delay
 api.exchangeInfo().then((res)=>{
  for(i in res['symbols']){
    // start a query, on a delay, for each pair.
    const pair = res['symbols'][i]['symbol']
    // openOrders(pair)
    var new_check = setTimeout(openOrders, 1000+delay, res['symbols'][i]['symbol'])
    delay += 1000 //1s added to delay for each symbol to avoid spamming the API and being banned.
  }
 })
	//this script will monitor for all pairs and find any open orders for that pair.
	// I've done my best to account for throttling and make the script robust.
	// save locally, add your api key, and run with "node <script name>" in console.
	// You'll get alerted (in console) when an order fills.
	// if you'd like to send a donation my way:
	// BTC: 1JD595vphvXmWEwpjiUmfw3QzsBtE9jUP7
	// LTC: LcaHE2dqrH73xLtoKXwDZEUtDiY42iAvk4
	// ETH: 0x110191093ffab1f0d3d6012cc0de15f42257b7f6
	// BNB: 0x110191093ffab1f0d3d6012cc0de15f42257b7f6
	// [email protected] for questions... I'll do my best to support the script if you find any bugs.

	binanceNode = require('binance-api-node')["default"];

	const api = binanceNode({apiKey: '***', apiSecret: '**'});

	var orders = {}

	var openOrders = async function(pair){
	var res = await api.openOrders({symbol: pair})
	for( i in res){
	// save the open order that we know about
	orders[res[i]['orderId']] = res[i]
	// check back in 10 seconds, modify this to check more frequently,
	// but note that there's a limit of 10 requests per second to the API
	setTimeout(checkOrderStatus, 10*1000, res[i]['orderId'])
	}

	// recheck our open orders every 1 seconds
	setTimeout(openOrders, 10*1000, pair);
	}

	// updates an order and notifies when it's status changes.
	var checkOrderStatus = async function(orderId){
	o = orders[orderId];

	var res = await api.getOrder({symbol:o['symbol'], orderId: orderId})

	// alert if our status has changed.
	if(res['status'] != o['status']){
	// this could play a sound, send a text, or rickroll
	console.log('ALERT! Status for', o['orderId'], o['symbol'], o['price'], 'has changed to', res['status`'])
	}

	o[orderId] = res;
	// call ourselves in 10 more seconds if the status isn't filled
	if(res['status'].includes('NEW', "PARTIALLY_FILLED")){
	setTimeout(checkOrderStatus, 10*1000, orderId)
	}
	}

	var delay = 0;

	// if you don't want to check all pairs, then use this instead
	// pairs= ['ETHBTC', 'LTCBTC']
	// for(i in pairs){
	// // start a query, on a delay, for each pair.
	// const pair = res['symbols'][i]['symbol']
	// // openOrders(pair)
	// var new_check = setTimeout(openOrders, 1000+delay, res['symbols'][i]['symbol'])
	// delay += 1000 //100 ms added to delay for each symbol to avoid spamming the API and being banned.
	// }

	// checks all pairs on a delay
	api.exchangeInfo().then((res)=>{
	for(i in res['symbols']){
	// start a query, on a delay, for each pair.
	const pair = res['symbols'][i]['symbol']
	// openOrders(pair)
	var new_check = setTimeout(openOrders, 1000+delay, res['symbols'][i]['symbol'])
	delay += 1000 //1s added to delay for each symbol to avoid spamming the API and being banned.
	}
	})