How to build your Telegram Buy Bot

pip install websocket-client
pip install python-telegram-bot

import websocket
import json
import threading
from telegram import Bot

# Initialize your Telegram Bot
TOKEN = 'YOUR_TELEGRAM_BOT_TOKEN'
CHAT_ID = 'YOUR_CHAT_ID'
bot = Bot(TOKEN)

def send_telegram_message(message):
    bot.send_message(chat_id=CHAT_ID, text=message)

def on_message(ws, message):
    data = json.loads(message)
    if data.get("type") == "trade_update":
        trades = data.get("data", [])
        for trade in trades:
            if trade['token_amount_usd'] >= 1 and trade.get('contract_address') == 'THE-TOKEN_CONTRACT_ADDRESS':
                alert_message = f"Trade Alert - Blockchain: {trade['blockchain']}, Hash: {trade['hash']}, " \
                                f"Token: {trade.get('token_name', 'Unknown Token')}, " \
                                f"Amount: {trade['token_amount']}, Value in USD: {trade['token_amount_usd']}"
                send_telegram_message(alert_message)

def on_error(ws, error):
    print("Error:", error)

def on_close(ws, close_status_code, close_msg):
    print("### closed ###")

def on_open(ws):
    def run(*args):
        message = {
            "type": "pair",
            "authorization": "YOUR-API-KEY",
            "payload": {
                "blockchain": "1",
                "filters": {
                    "amount_usd": {
                        "operator": ">=",
                        "value": 1
                    },
                    "contract_address": "THE-TOKEN_CONTRACT_ADDRESS"  # Ensure this key is supported by your API
                }
            }
        }
        ws.send(json.dumps(message))
        print("Message sent, listening for The-Token trades...")
    thread = threading.Thread(target=run)
    thread.start()

if __name__ == "__main__":
    websocket.enableTrace(True)
    ws = websocket.WebSocketApp("wss://api.mobula.io",
                                on_open=on_open,
                                on_message=on_message,
                                on_error=on_error,
                                on_close=on_close)

    ws.run_forever()