Delete bot

bot/__init__.py

@@ -1,23 +0,0 @@
-from logging import getLogger
-from hydrogram import Client
-from .config import Telegram
-
-logger = getLogger("bot")
-
-_kwargs = dict(
-    name="bot",
-    api_id=Telegram.API_ID,
-    api_hash=Telegram.API_HASH,
-    plugins={"root": "bot/plugins"},
-    sleep_threshold=-1,
-    max_concurrent_transmissions=10,
-)
-
-if Telegram.SESSION_STRING:
-    _kwargs["session_string"] = Telegram.SESSION_STRING
-elif Telegram.BOT_TOKEN:
-    _kwargs["bot_token"] = Telegram.BOT_TOKEN
-else:
-    raise RuntimeError("Set SESSION_STRING or TELEGRAM_BOT_TOKEN in environment.")
-
-TelegramBot = Client(**_kwargs)

bot/__main__.py

@@ -1,8 +0,0 @@
-from bot import TelegramBot
-from bot.server import server
-from bot.startup_log import log_startup
-
-if __name__ == "__main__":
-    TelegramBot.loop.create_task(server.serve())
-    TelegramBot.loop.create_task(log_startup())
-    TelegramBot.run()

bot/config.py

@@ -1,29 +0,0 @@
-from os import environ as env
-
-def _to_int_list(s: str):
-    if not s:
-        return []
-    out = []
-    for part in s.replace(",", " ").split():
-        try:
-            out.append(int(part.strip()))
-        except:
-            pass
-    return out
-
-class Telegram:
-    API_ID = int(env.get("TELEGRAM_API_ID", "0") or "0")
-    API_HASH = env.get("TELEGRAM_API_HASH", "")
-    SESSION_STRING = env.get("SESSION_STRING", "")  # ✅ use this (generated by your gen.py)
-    OWNER_ID = int(env.get("OWNER_ID", "0") or "0")
-
-    # Optional: extra allowlist (space-separated ids)
-    ALLOWED_USER_IDS = set(_to_int_list(env.get("ALLOWED_USER_IDS", "")))
-
-    BOT_USERNAME = env.get("TELEGRAM_BOT_USERNAME", "")
-    CHANNEL_ID = int(env.get("TELEGRAM_CHANNEL_ID", "0") or "0")
-
-class Server:
-    BASE_URL = env.get("BASE_URL", "")
-    BIND_ADDRESS = env.get("BIND_ADDRESS", "0.0.0.0")
-    PORT = int(env.get("PORT", "7860") or "7860")

bot/init.py

@@ -1,39 +0,0 @@
-from hydrogram import Client
-from logging import getLogger
-from logging.config import dictConfig
-from .config import Telegram
-
-LOGGER_CONFIG_JSON = {
-    "version": 1,
-    "formatters": {
-        "default": {
-            "format": "[%(asctime)s][%(name)s][%(levelname)s] -> %(message)s",
-            "datefmt": "%d/%m/%Y %H:%M:%S",
-        },
-    },
-    "handlers": {
-        "stream_handler": {"class": "logging.StreamHandler", "formatter": "default"},
-    },
-    "loggers": {
-        "uvicorn": {"level": "INFO", "handlers": ["stream_handler"]},
-        "uvicorn.error": {"level": "WARNING", "handlers": ["stream_handler"]},
-        "bot": {"level": "INFO", "handlers": ["stream_handler"]},
-        "hydrogram": {"level": "INFO", "handlers": ["stream_handler"]},
-    },
-}
-
-dictConfig(LOGGER_CONFIG_JSON)
-logger = getLogger("bot")
-
-if not Telegram.SESSION_STRING:
-    raise RuntimeError("SESSION_STRING missing. Put it in HF Secrets/Variables.")
-
-TelegramBot = Client(
-    name="bot",
-    api_id=Telegram.API_ID,
-    api_hash=Telegram.API_HASH,
-    session_string=Telegram.SESSION_STRING,
-    plugins={"root": "bot/plugins"},
-    sleep_threshold=-1,
-    max_concurrent_transmissions=10,
-)

bot/main.py

@@ -1,8 +0,0 @@
-from bot import TelegramBot
-from bot.server import server
-from bot.startup_log import log_startup
-
-if __name__ == "__main__":
-    TelegramBot.loop.create_task(server.serve())
-    TelegramBot.loop.create_task(log_startup())
-    TelegramBot.run()

bot/plugins/init.py

@@ -1 +0,0 @@
-# plugin package

bot/plugins/talk.py

@@ -1,69 +0,0 @@
-from hydrogram import filters
-from hydrogram.types import Message
-from bot import TelegramBot
-from bot.config import Telegram
-
-def is_allowed(uid: int) -> bool:
-    if Telegram.OWNER_ID and uid == Telegram.OWNER_ID:
-        return True
-    return uid in Telegram.ALLOWED_USER_IDS
-
-@TelegramBot.on_message(filters.command("start"))
-async def start_handler(_, m: Message):
-    uid = m.from_user.id if m.from_user else 0
-    if not is_allowed(uid):
-        return await m.reply_text("❌ Not allowed. Contact owner.")
-    await m.reply_text(
-        "✅ Bot live.\n"
-        "Commands:\n"
-        "/ping\n"
-        "/id\n"
-        "/help\n\n"
-        "Ab normal msg bhejo, main reply dunga."
-    )
-
-@TelegramBot.on_message(filters.command("help"))
-async def help_handler(_, m: Message):
-    uid = m.from_user.id if m.from_user else 0
-    if not is_allowed(uid):
-        return await m.reply_text("❌ Not allowed.")
-    await m.reply_text(
-        "✅ Help\n"
-        "/ping  -> pong\n"
-        "/id    -> your telegram id\n"
-        "Send any text -> echo + small talk reply"
-    )
-
-@TelegramBot.on_message(filters.command("ping"))
-async def ping_handler(_, m: Message):
-    uid = m.from_user.id if m.from_user else 0
-    if not is_allowed(uid):
-        return await m.reply_text("❌ Not allowed.")
-    await m.reply_text("pong ✅")
-
-@TelegramBot.on_message(filters.command("id"))
-async def id_handler(_, m: Message):
-    uid = m.from_user.id if m.from_user else 0
-    await m.reply_text(f"Your ID: `{uid}`")
-
-@TelegramBot.on_message(filters.text & ~filters.command(["start","help","ping","id"]))
-async def talk_handler(_, m: Message):
-    uid = m.from_user.id if m.from_user else 0
-    if not is_allowed(uid):
-        return await m.reply_text("❌ Not allowed.")
-
-    text = (m.text or "").strip()
-    if not text:
-        return
-
-    # ultra-simple “talking” logic (safe, fast)
-    low = text.lower()
-    if any(x in low for x in ["hi", "hello", "hey"]):
-        return await m.reply_text("Haan bol 😄")
-    if "kaisa" in low or "kaisi" in low:
-        return await m.reply_text("Mast. Tu bata 😄")
-    if "bye" in low:
-        return await m.reply_text("Bye 👋")
-
-    # default echo-style reply
-    await m.reply_text(f"🗣️ You said: {text}")

bot/server/__init__.py

@@ -1,36 +0,0 @@
-from quart import Quart
-from uvicorn import Server as UvicornServer, Config
-from logging import getLogger
-
-from bot.config import Server as ServerCfg
-from . import main, error
-
-logger = getLogger("uvicorn")
-
-instance = Quart(__name__)
-instance.config["RESPONSE_TIMEOUT"] = None
-instance.config["MAX_CONTENT_LENGTH"] = 999999999999999
-
-@instance.before_serving
-async def before_serve():
-    logger.info("Web server is started!")
-    logger.info(f"Server running on {ServerCfg.BIND_ADDRESS}:{ServerCfg.PORT}")
-
-# routes
-instance.register_blueprint(main.bp)
-
-# errors
-instance.register_error_handler(400, error.invalid_request)
-instance.register_error_handler(404, error.not_found)
-instance.register_error_handler(405, error.invalid_method)
-instance.register_error_handler(error.HTTPError, error.http_error)
-
-# uvicorn server (no custom log_config)
-server = UvicornServer(
-    Config(
-        app=instance,
-        host=ServerCfg.BIND_ADDRESS,
-        port=ServerCfg.PORT,
-        log_level="info",
-    )
-)

bot/server/main.py

@@ -1,18 +0,0 @@
-from quart import Blueprint, jsonify
-from bot.startup_log import uptime_s
-from bot import TelegramBot
-
-bp = Blueprint("main", __name__)
-
-@bp.route("/")
-async def home():
-    return "OK: talking bot + web server", 200
-
-@bp.route("/health")
-async def health():
-    # simple health + uptime + connected state
-    return jsonify({
-        "ok": True,
-        "uptime_s": uptime_s(),
-        "connected": bool(getattr(TelegramBot, "is_connected", False))
-    }), 200

bot/startup_log.py

@@ -1,35 +0,0 @@
-import platform
-import time
-from datetime import datetime
-from hydrogram import __version__ as hydrogram_version
-from bot import TelegramBot
-from bot.config import Telegram, Server
-
-START_TS = time.time()
-
-def uptime_s() -> int:
-    return int(time.time() - START_TS)
-
-async def log_startup():
-    now = datetime.now().strftime("%Y-%m-%d %H:%M:%S")
-    print(f"\n===== STARTUP SNAPSHOT @ {now} =====", flush=True)
-    print(f"Python: {platform.python_version()} | System: {platform.platform()}", flush=True)
-    print(f"Hydrogram: {hydrogram_version}", flush=True)
-
-    print(f"API_ID: {Telegram.API_ID}", flush=True)
-    print(f"BOT_USERNAME env: {Telegram.BOT_USERNAME}", flush=True)
-    print(f"OWNER_ID: {Telegram.OWNER_ID}", flush=True)
-    print(f"ALLOWED_USER_IDS count: {len(Telegram.ALLOWED_USER_IDS)}", flush=True)
-    print(f"BASE_URL: {Server.BASE_URL} | BIND: {Server.BIND_ADDRESS}:{Server.PORT}", flush=True)
-
-    # Bot identity test
-    try:
-        me = await TelegramBot.get_me()
-        print("\n--- BOT IDENTITY ---", flush=True)
-        print(f"id={me.id}", flush=True)
-        print(f"username=@{me.username}", flush=True)
-        print(f"name={me.first_name}", flush=True)
-    except Exception as e:
-        print(f"get_me_failed: {type(e).__name__}: {e}", flush=True)
-
-    print("===== END SNAPSHOT =====\n", flush=True)