async command controle with telegram

Author: ibrahimbidi

lib/telegram.js

@@ -1,30 +1,62 @@
 
 import { TelegramBot, ENV } from "../deps.js";
 const { TOKEN_TELEGRAM } = ENV;
+export default (hooks) => {
+    const bot = new TelegramBot(TOKEN_TELEGRAM);
+    // Error handler
+    bot.use(async (ctx, next) => {
+        try {
+            await next(ctx);
+        } catch (err) {
+            console.error(err.message);
+        }
+    });
 
-export const bot = new TelegramBot(TOKEN_TELEGRAM);
-// Error handler
-bot.use(async (ctx, next) => {
-    try {
-        await next(ctx);
-    } catch (err) {
-        console.error(err.message);
-    }
-});
-/*
-bot.on("text", async (ctx) => {
-    const text = ctx.message?.text;
+    bot.on("text", async (ctx) => {
+        const text = ctx.message?.text;
 
-    if (text === "/start") {
-        await ctx.reply("HI, Im Deno Trad Bot");
-    }
+        //console.info(ctx.message)
+        /*
+        {
+          message_id: 64,
+          from: {
+            id: 1664500170,
+            is_bot: false,
+            first_name: "Bot",
+            last_name: "Js",
+            username: "bot_js",
+            language_code: "fr"
+          },
+          chat: {
+            id: 1664500170,
+            first_name: "Bot",
+            last_name: "Js",
+            username: "bot_js",
+            type: "private"
+          },
+          date: 1622945574,
+          text: "hfhghh"
+        }
+        */
+        if (text === "/connect") {
+            hooks.dataConnect = text;
+            await ctx.reply("HI, Im Deno Trading Bot \n https://github.com/Zizwar/deno-trading-bot");
+        }
 
-    if (text === "/stars" || text === "/stars@DenoBot") {
+        if (text === "/stars" || text === "/stars@DenoBot")
+            await ctx.reply(`Stars: :star:`);
 
-        await ctx.reply(`Stars: :star:`);
-    }
+        const has = (val) => text.includes(val)
+        if (has('$:')) {
 
-});
+            if (has("buy:"))
+                hooks.dataConnect = 'buy'
+            if (has("stop:"))
+                hooks.dataConnect = "stop"
+        }
 
-bot.launch();
-*/
+    });
+
+    bot.launch();
+    return bot;
+}

main.js

@@ -4,7 +4,7 @@ const { INTERVAL_TIME = 1 } = ENV;
 
 const denoBot = new DenoBot();
 const ping = await denoBot.ping;
-console.log("isDenoBotConectToFutures="+ping ? "yes :)":"no :(")
+console.log("isDenoBotConectToFutures=" + ping ? "conect denoBot :)" : "no conect denoBot :(")
 denoBot.stratigy = "onlyRsis";
 //const balanceUSDT = await denoBot.getBalance("USDT");
 //const balanceBUSD = await denoBot.getBalance("BUSD");
@@ -46,10 +46,10 @@ console.info(
 )
 */
 //console.log(await denoBot.binance.withdrawHistory())
-/*
-setInterval(async _ => {
+///*
+const  _thisInterval = setInterval(async _ => {
     const options = {
-        candeles: { symbol: "DOGEUSDT",interval:"3m" }
+        candeles: { symbol: "DOGEUSDT", interval: "5m" }
     }
     const listenMyCoins = await denoBot.listenCoins(options);
     const action = denoBot.action(listenMyCoins);
@@ -82,8 +82,14 @@ stratigy=${stratigy}
             console.error(error)
         }
     }
+    const dataConnect = denoBot.dataConnect
+    console.log({ action, dataConnect})
+if(dataConnect==="stop"){
+clearInterval(_thisInterval)
+console.warn('Stop  Deno Bot')
+}
     // denoBot.postMessageSlacK(action)
-    console.log({ action, ...listenMyCoins })
+    //console.log({ action, ...listenMyCoins })
 }, INTERVAL_TIME * 1000)
 
 //*/

wino/denoBot.js

@@ -1,6 +1,6 @@
 import { BinanceApi, Technicalindicators, SlackApi, ENV } from '../deps.js';
 import { OnlyRsis } from './stratigy/index.js'
-import { bot as TelegramBot } from "../lib/telegram.js";
+import TelegramBot from "../lib/telegram.js";
 const { API_KEY_BINANCE, API_SECRET_BINANCE, TOKEN_SLACK, CHANEL_SLACK, ID_CHAT_TELEGRAM } = ENV;
 //console.info(await Binance.futuresCandles({ symbol: 'BTCUSDT' }));
 const { SMA, EMA, BollingerBands, RSI, StochasticRSI } = Technicalindicators;
@@ -16,8 +16,10 @@ export default class DenoBot {
             test: true
         });
         //
-        this.slack = new SlackApi(TOKEN_SLACK)
-        this.telegramBot = TelegramBot
+        this.slack = new SlackApi(TOKEN_SLACK);
+        this._dataConnect = [];
+        this._telegramBot = TelegramBot(this);
+        
     }
     async getBalance(symbol = "USDT") {
         const balancFutures = await this._binance.futuresAccountBalance();
@@ -30,7 +32,7 @@ export default class DenoBot {
         })
     }
     postMessageTelegram(text) {
-        return this.telegramBot.telegram.sendMessage({
+        return this._telegramBot.telegram.sendMessage({
             chat_id: ID_CHAT_TELEGRAM,
             text,
         })
@@ -44,7 +46,7 @@ export default class DenoBot {
     }
 
     futuresCandles(args = []) {
-        const { symbol = "BTCUSDT", interval = '1m', limit = 30 } = args
+        const { symbol = "BTCUSDT", interval = '5m', limit = 30 } = args
         return this._binance.futuresCandles({ symbol, interval, limit })
     }
 
@@ -116,6 +118,12 @@ export default class DenoBot {
     get stratigy() {
         return this._stratigy
     }
+    set dataConnect(_dataConnect) {
+        this.__dataConnect = _dataConnect
+    }
+    get dataConnect() {
+        return this.__dataConnect
+    }
     action(properties) {
         switch (this._stratigy) {
             case "onlyRsis": return OnlyRsis(properties);