diff options
| -rw-r--r-- | index.js | 130 |
1 files changed, 76 insertions, 54 deletions
@@ -1,8 +1,8 @@ #!/usr/bin/env node
+
const Request = require('request-promise');
const dotenv = require('dotenv');
dotenv.config();
-
const token = process.env['TELEGRAM_TOKEN'];
const chat_id = process.env['TELEGRAM_CHAT_ID'];
const api_key = process.env['BINANCE_API_KEY'];
@@ -10,28 +10,24 @@ const secret_key = process.env['BINANCE_SECRET_KEY']; const NODE_ENV = process.env.NODE_ENV || "development";
const port = process.env.PORT || 3000;
const timeZone = process.env.TIME_ZONE_STRING || 'Asia/Kolkata';
-
-if (process.env.NODE_ENV === "development") {
+if(NODE_ENV === "development") {
console.log("NODE_ENV development")
-} else {
+} else {
console.log("NODE_ENV production")
}
//Indian time string
-const event = new Date().toLocaleString('en-IN', { timeZone: timeZone, timeZoneName: 'short' });
-
-//sending telegram message
-const Slim_bot = require('slimbot');
-const bot = new Slim_bot(token);
-
+const event = new Date().toLocaleString('en-IN', {
+ timeZone: timeZone,
+ timeZoneName: 'short'
+});
//only for heroku port error
const express = require('express');
const app = express();
app.all('/', (req, res) => res.send('Bot is Running'));
app.listen(port, () => console.log(`${event} - Server started on ${port} port`));
-
//BinanceWS
const binanceApi = require('binance');
-const binanceWS = new binanceApi.BinanceWS(true);
+const binanceWS = new binanceApi.BinanceWS(false);
try {
binanceRest = new binanceApi.BinanceRest({
key: api_key,
@@ -41,12 +37,11 @@ try { binanceWS.onUserData(binanceRest, data => {
console.log(`${event} - Session Message: `, data);
process_data(data);
-
- }, 60000).then(ws => {
+ }, 60000).then(() => {
console.log(`${event} - Monitoring Spot User Order Data for binance.com`);
sendMessage(`<b>Binance Spot Order Monitor Started</b>\nthis message shows that you or heroku(if your are using) restart the bot.`)
})
-} catch (err) {
+} catch(err) {
console.error(`${event} - ${err}`)
sendMessage(err.toString())
}
@@ -54,39 +49,68 @@ try { function fixFloat(floatNum, Precision = 8) {
const num = Number.parseFloat(floatNum).toFixed(Precision);
const str = num.toString();
- return str.replace(/(\.\d+?)0+\b/g, "$1") //fix 20.000 to 20.0 or 0.0000000120 to 0.000000012
+ return str.replace(/(\.\d+?)0+\b/g, "$1") //fix 20.000 to 20.0 or 0.0000000120 to 0.000000012
}
-
function process_data(data) {
+ let {
+ e: eventType,
+ x: executionType,
+ s: symbol,
+ p: price,
+ q: quantity,
+ S: side,
+ o: orderType,
+ i: orderId,
+ X: orderStatus,
+ l: lastTradeQuantity,
+ z: Cumulative_filled_quantity
+ } = data;
+ let str4 = symbol.slice(symbol.length - 4);
+ let str3 = symbol.slice(symbol.length - 3);
+ let sy;
+ if(["USDT", "BUSD", "TUSD", "USDC", "BIDR", "IDRT", "BVND"].includes(str4)) {
+ sy = str4
+ } else if(["BNB", "BTC", "XRP", "TRX", "ETH", "AUD", "BRL", "EUR", "GBP", "RUB", "TRY", "PAX", "DAI", "UAH", "NGN", "VAI"].includes(str3)) {
+ sy = str3
+ }
+ let total = `${fixFloat(Number(price) * Number(quantity))} ${sy}`
+ if(orderType !== "LIMIT") {
+ let {
+ L: Lprice
+ } = data;
+ price = Lprice
+ }
let txt;
- if (data.eventType === 'executionReport') {
- if (data.executionType === 'NEW') {
- if (data.orderStatus === 'NEW') {
- txt = `💸 💸 💸\n<b>Spot Order CREATED\nSide:</b> ${data.side}\n<b>Symbol:</b> #${data.symbol}\n<b>Price:</b> ${data.price}\n<b>Quantity:</b> ${fixFloat(data.quantity)}\n<b>Order ID:</b> #ID${data.orderId}`
- }
- else if (data.orderStatus === 'REJECTED') {
- txt = `🚫 🚫 🚫\n<b>Spot Order REJECTED\nSide:</b> ${data.side}\n<b>Symbol:</b> #${data.symbol}\n<b>Price:</b> ${data.price}\n<b>Quantity:</b> ${fixFloat(data.quantity)}\n<b>Order ID:</b> #ID${data.orderId}`
+ if(eventType === 'executionReport') {
+ if(executionType === 'NEW') {
+ if(orderStatus === 'NEW') {
+ txt = `💸 💸 💸\n<b>Spot Order CREATED\nSide:</b> ${side}\n<b>Symbol:</b> #${symbol}\n<b>Price:</b> ${price}\n<b>Quantity:</b> ${fixFloat(quantity)}\n<b>Total:</b> ${total}\n<b>Order ID:</b> #ID${orderId}`
+ } else if(orderStatus === 'REJECTED') {
+ txt = `🚫 🚫 🚫\n<b>Spot Order REJECTED\nSide:</b> ${side}\n<b>Symbol:</b> #${symbol}\n<b>Price:</b> ${price}\n<b>Quantity:</b> ${fixFloat(quantity)}\n<b>Total:</b> ${total}\n<b>Order ID:</b> #ID${orderId}`
}
- } else if (data.executionType === 'CANCELED') {
- if (data.orderStatus === 'CANCELED') {
- txt = `🛑 🛑 🛑\n<b>Spot Order CANCELED\nSide:</b> ${data.side}\n<b>Symbol:</b> #${data.symbol}\n<b>Price:</b> ${data.price}\n<b>Quantity:</b> ${fixFloat(data.quantity)}\n<b>Order ID:</b> #ID${data.orderId}`
+ } else if(executionType === 'CANCELED') {
+ if(orderStatus === 'CANCELED') {
+ txt = `🛑 🛑 🛑\n<b>Spot Order CANCELED\nSide:</b> ${side}\n<b>Symbol:</b> #${symbol}\n<b>Price:</b> ${price}\n<b>Quantity:</b> ${fixFloat(quantity)}\n<b>Total:</b> ${total}\n<b>Order ID:</b> #ID${orderId}`
}
- } else if (data.executionType === 'TRADE') {
- if (data.orderStatus === 'PARTIALLY_FILLED') {
- txt = `💰 💰 💰\n<b>Spot Order PARTIALLY FILLED\nSide:</b> ${data.side}\n<b>Symbol:</b> #${data.symbol}\n<b>Price:</b> ${data.price}\n<b>Last Filled:</b> ${fixFloat(data.lastTradeQuantity)}\n<b>Remaining:</b> ${fixFloat(Number(data.quantity) - Number(data.accumulatedQuantity))}\n<b>Order ID:</b> #ID${data.orderId}`
- } else if (data.orderStatus === 'FILLED') {
- txt = `✅ ✅ ✅\n<b>Spot Order FULLY FILLED\nSide:</b> ${data.side}\n<b>Symbol:</b> #${data.symbol}\n<b>Price:</b> ${data.price}\n<b>Filled:</b> ${fixFloat(data.accumulatedQuantity)}\n<b>Order ID:</b> #ID${data.orderId}`
+ } else if(executionType === 'TRADE') {
+ if(orderStatus === 'PARTIALLY_FILLED') {
+ txt = `💰 💰 💰 <b>Spot Order PARTIALLY FILLED Side:</b> ${side} <b>Symbol:</b> #${symbol} <b>Price:</b> ${price}
+ <b>Last Filled:</b> ${fixFloat(lastTradeQuantity)}
+ <b>Remaining:</b> ${fixFloat(Number(quantity) - Number(Cumulative_filled_quantity))}
+ <b>Total:</b> ${total} <b>Order ID:</b> #ID${orderId}`
+ } else if(orderStatus === 'FILLED') {
+ txt = `✅ ✅ ✅\n<b>Spot Order FULLY FILLED\nSide:</b> ${side}\n<b>Symbol:</b> #${symbol}\n<b>Price:</b> ${price}\n<b>Filled:</b> ${fixFloat(Cumulative_filled_quantity)}\n<b>Total:</b> ${total}\n<b>Order ID:</b> #ID${orderId}`
}
- } else if (['REPLACED', 'EXPIRED', 'PENDING_CANCEL'].includes(data.orderStatus)) {
- txt = `🔴 🟡 🔵\n<b>Spot Order ${data.orderStatus}\nSide:</b> ${data.side}\n<b>Symbol:</b> #${data.symbol}\n<b>Price:</b> ${data.price}\n<b>Quantity:</b> ${fixFloat(data.quantity)}\n<b>Order ID:</b> #ID${data.orderId}`
+ } else if(['REPLACED', 'EXPIRED', 'PENDING_CANCEL'].includes(orderStatus)) {
+ txt = `🔴 🟡 🔵\n<b>Spot Order ${orderStatus}\nSide:</b> ${side}\n<b>Symbol:</b> #${symbol}\n<b>Price:</b> ${price}\n<b>Quantity:</b> ${fixFloat(quantity)}\n<b>Total:</b> ${total}\n<b>Order ID:</b> #ID${orderId}`
} else {
- txt = `⚠️ ⚠️ ⚠️\n<b>Undefined</b>\nExecution Type: ${data.executionType}\nOrder Status ${data.orderStatus}\nFull Details:\n${msg}`
+ txt = `⚠️ ⚠️ ⚠️\n<b>Undefined</b>\nExecution Type: ${executionType}\nOrder Status ${orderStatus}\nFull Details:\n${data}`
}
sendMessage(txt)
}
}
-
+//sending telegram message
function sendMessage(text) {
let params = {
chat_id: chat_id,
@@ -100,22 +124,20 @@ function sendMessage(text) { resolveWithFullResponse: true,
forever: true
};
- return Request(options)
- .then(resp => {
- if (resp.statusCode !== 200) {
- throw new Error(resp.statusCode + ':\n' + resp.body);
- }
- let updates = JSON.parse(resp.body);
- if (updates.ok) {
- console.log("Message send via Telegram")
- return updates;
- } else {
- console.log(`something went wrong while sending message to telegram see detailed error below.`)
- console.error(updates)
- return null;
- }
- })
- .catch(error => {
- throw error;
- });
+ return Request(options).then(resp => {
+ if(resp.statusCode !== 200) {
+ throw new Error(resp.statusCode + ':\n' + resp.body);
+ }
+ let updates = JSON.parse(resp.body);
+ if(updates.ok) {
+ console.log("Message send via Telegram")
+ return updates;
+ } else {
+ console.log(`something went wrong while sending message to telegram see detailed error below.`)
+ console.error(updates)
+ return null;
+ }
+ }).catch(error => {
+ throw error;
+ });
}
|