/
external.js
97 lines (75 loc) · 2.1 KB
/
external.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
require('dotenv').config();
const kapi = require('kucoin-node-api');
const { Telegraf } = require('telegraf');
const config = {
apiKey: process.env.KC_API_KEY,
secretKey: process.env.KC_API_SECRET,
passphrase: process.env.KC_API_PASSPHRASE,
environment: 'live',
};
kapi.init(config);
async function getAssets() {
const { data } = await kapi.getAccounts();
return data;
}
async function getTickers(pretty= true) {
const { data } = await kapi.getAllTickers();
if (!pretty) return data.ticker;
const obj = {};
data.ticker.forEach((ticker) => {
const { symbol } = ticker;
obj[symbol] = ticker;
});
return obj;
}
async function getStatus() {
const assets = await getAssets();
const tickers = await getTickers();
const prices = {};
const data = {};
assets.forEach((asset) => {
const { type, currency } = asset;
if (type !== 'margin' || ['USDC', 'USDT', 'USD'].includes(currency)) return;
const symbol = `${currency}-USDT`;
const symbolTicker = tickers[symbol];
const { last } = symbolTicker;
const price = Number(last);
prices[currency] = price;
let { balance, available } = asset;
balance = Number(balance);
available = Number(available);
if (balance === 0) return;
data[currency] = {
symbol: currency,
price,
amount: {
base: available,
quote: Number((available*price).toFixed(2)),
}
};
});
return data;
}
async function showStatus(ctx, next) {
const data = await getStatus();
const msg = [];
Object.keys(data).forEach((symbol) => {
const { price, amount: { base: baseAmt, quote: quoteAmt } } = data[symbol];
msg.push(`${symbol}: ${baseAmt} @ ${price}, total ${quoteAmt}`);
});
await ctx.reply(msg.join('\n'));
return next();
}
const bot = new Telegraf(process.env.TELEGRAM_BOT_TOKEN);
bot.start((ctx) => ctx.reply('Welcome'));
bot.command('status', showStatus);
bot.launch();
process.once('SIGINT', () => bot.stop('SIGINT'));
process.once('SIGTERM', () => bot.stop('SIGTERM'));
(async () => {
try {
await getStatus();
} catch(err) {
console.log(err)
}
})();