Update main.py

main.py

@@ -15,7 +15,7 @@ all_processes = {}
 #
 # @bot.message_handler(commands=['showid'])
 # def start_message(message):
-# 	bot.send_message(message.chat.id, message.chat.id)
+# 	bot.send_message(message.chat.id, message.chat.id, timeout=20)
 # bot.infinity_polling()
 
 def get_data(symbol, exchange, interval):
@@ -107,13 +107,13 @@ def push_notification(symbol, exchange, interval):
         long_risk = check_risk(symbol, exchange, 'long')
 
         if table[-1, 1]:
-            bot.send_message(os.getenv('TELEGRAM_CHAT_ID'), f'LONG now ({long_risk}): {symbol} {exchange} {interval}')
+            bot.send_message(os.getenv('TELEGRAM_CHAT_ID'), f'LONG now ({long_risk}): {symbol} {exchange} {interval}', timeout=20)
 
         # send short buy message
         table = get_buy_short_indicator(data)
         short_risk = check_risk(symbol, exchange, 'short')
         if table[-1, 1]:
-            bot.send_message(os.getenv('TELEGRAM_CHAT_ID'), f'SHORT now ({short_risk}): {symbol} {exchange} {interval}')
+            bot.send_message(os.getenv('TELEGRAM_CHAT_ID'), f'SHORT now ({short_risk}): {symbol} {exchange} {interval}', timeout=20)
 
         if 'H' in interval:
             time.sleep(3600)
@@ -196,14 +196,12 @@ def startpolling(exchange, symbol, interval):
     if all_processes.get(f'{symbol}_{exchange}_{interval}', None) is not None:
         return False
 
-    all_processes[f'{symbol}_{exchange}_{interval}'] = {'process_stop': False, 'process': None}
-    selected_process = all_processes[f'{symbol}_{exchange}_{interval}']
 
-    bot.send_message(os.getenv('TELEGRAM_CHAT_ID'), f'STARTING BOT FOR: {symbol} {exchange} {interval}')
+    bot.send_message(os.getenv('TELEGRAM_CHAT_ID'), f'STARTING BOT FOR: {symbol} {exchange} {interval}', timeout=20)
 
     process = multiprocessing.Process(target=push_notification, args=(symbol, exchange, interval))
     process.start()
-    selected_process['process'] = process
+    all_processes[f'{symbol}_{exchange}_{interval}'] = {'process_stop': False, 'process': process}
     return True
 
 
@@ -216,10 +214,10 @@ def endpolling(exchange, symbol, interval):
     selected_process = all_processes[f'{symbol}_{exchange}_{interval}']
     selected_process['process_stop'] = True
 
-    bot.send_message(os.getenv('TELEGRAM_CHAT_ID'), f'STOPPING BOT FOR: {symbol} {exchange} {interval}')
+    bot.send_message(os.getenv('TELEGRAM_CHAT_ID'), f'STOPPING BOT FOR: {symbol} {exchange} {interval}', timeout=20)
     selected_process['process'].terminate()
     all_processes.pop(f'{symbol}_{exchange}_{interval}')
-    bot.send_message(os.getenv('TELEGRAM_CHAT_ID'), f'BOT STOPPED FOR: {symbol} {exchange} {interval}')
+    bot.send_message(os.getenv('TELEGRAM_CHAT_ID'), f'BOT STOPPED FOR: {symbol} {exchange} {interval}', timeout=20)
 
     return True
 
@@ -234,7 +232,7 @@ def end_all_processes():
 
     all_processes = {}
 
-    bot.send_message(os.getenv('TELEGRAM_CHAT_ID'), f'ALL NOTIFICATIONS ENDED')
+    bot.send_message(os.getenv('TELEGRAM_CHAT_ID'), f'ALL NOTIFICATIONS ENDED', timeout=20)
 
     return True