Delete app.py

app.py

@@ -1,182 +0,0 @@
-import os
-import asyncio
-import logging
-from telethon import TelegramClient, events
-from telethon.sessions import StringSession
-import aiohttp
-from aiohttp import web
-
-logging.basicConfig(level=logging.INFO)
-logger = logging.getLogger(__name__)
-
-# --- Configuration ---
-API_ID = 29988110
-API_HASH = "a524f28572523984696d1d3a95d0d6ae"
-# Use environment variable for session string if available, otherwise fallback to the hardcoded one
-SESSION_STRING = os.environ.get("SESSION_STRING")
-
-WORKER_URL = "https://aibot.aungminsan23.workers.dev/"
-
-# Initialize the Telethon client
-client = TelegramClient(StringSession(SESSION_STRING), API_ID, API_HASH)
-
-async def forward_to_worker(payload: dict):
-    """Forwards the payload to the Cloudflare Worker and returns the full JSON response."""
-    try:
-        async with aiohttp.ClientSession() as session:
-            async with session.post(WORKER_URL, json=payload, timeout=60) as response:
-                if response.status == 200:
-                    data = await response.json()
-                    return data
-                else:
-                    text = await response.text()
-                    logger.error(f"Worker returned status {response.status}: {text}")
-    except Exception as e:
-        logger.error(f"Error forwarding to worker: {e}")
-    return None
-
-BOT_STATE = True  # Default is ON
-NMS_STATE = False # Default is OFF
-
-@client.on(events.NewMessage)
-async def handle_new_message(event):
-    """
-    Handles routing of messages:
-    - /bot on and /bot off commands to control AI state.
-    - /nms on and /nms off to reply to every message.
-    - Forwards outgoing commands to worker.
-    - Forwards incoming PMs/mentions to worker if AI is ON.
-    """
-    global BOT_STATE, NMS_STATE
-    text = event.message.message
-    
-    if not text:
-        return
-
-    is_outgoing = event.out
-    
-    # 1. Handle owner commands directly in app.py
-    if is_outgoing:
-        lower_text = text.strip().lower()
-        if lower_text == '/bot on':
-            BOT_STATE = True
-            await event.reply("✅ **Userbot AI Mode: ON**\nAI will automatically reply to PMs and mentions.")
-            return
-        elif lower_text == '/bot off':
-            BOT_STATE = False
-            await event.reply("🛑 **Userbot AI Mode: OFF**\nAI is paused. You can reply manually. (Commands still work)")
-            return
-        elif lower_text == '/nms on':
-            NMS_STATE = True
-            await event.reply("✅ **NMS Auto-Reply Mode: ON**\nAI will now reply to EVERY incoming message.")
-            return
-        elif lower_text == '/nms off':
-            NMS_STATE = False
-            await event.reply("🛑 **NMS Auto-Reply Mode: OFF**\nAI stopped replying to every message.")
-            return
-        elif lower_text.startswith('/broadcast'):
-            broadcast_msg = text[10:].strip()
-            if not broadcast_msg:
-                await event.reply("❌ စာသားထည့်ပေးပါ။ (ဥပမာ- `/broadcast မင်္ဂလာပါ`)")
-                return
-
-            await event.reply("🚀 သင်ရောက်ရှိနေသော Group အားလုံးဆီသို့ Broadcast စတင်ပို့ဆောင်နေပါပြီ...")
-            success_count = 0
-            fail_count = 0
-            
-            async for dialog in client.iter_dialogs():
-                if dialog.is_group:
-                    try:
-                        await client.send_message(dialog.id, broadcast_msg, parse_mode='html')
-                        success_count += 1
-                        await asyncio.sleep(0.5)
-                    except Exception as e:
-                        logger.error(f"Failed to broadcast to {dialog.name} ({dialog.id}): {e}")
-                        fail_count += 1
-            
-            await event.reply(f"✅ **Broadcast ပြီးဆုံးပါပြီ။**\n- အောင်မြင်: {success_count} Groups\n- ကျရှုံး: {fail_count} Groups")
-            return
-
-    # 2. Determine if we should forward the message to the Worker
-    should_forward = False
-    is_command = text.startswith(('/', '.', '!'))
-
-    if is_outgoing:
-        # Always forward owner's commands (except the ones handled above) to worker
-
-        if is_command:
-            should_forward = True
-    else:
-        # For incoming messages, check NMS_STATE first, then BOT_STATE
-        if NMS_STATE:
-            should_forward = True
-        elif BOT_STATE:
-            if event.is_private or event.mentioned:
-                should_forward = True
-
-    if not should_forward:
-        return
-
-    sender = await event.get_sender()
-    
-    # Prepare payload exactly as the Cloudflare Worker expects it for userbot_request
-    payload = {
-        "userbot_request": True,
-        "text": text,
-        "chat_id": event.chat_id,
-        "user_id": event.sender_id,
-        "user_name": getattr(sender, 'first_name', 'User') if sender else 'User',
-        "is_group": event.is_group
-    }
-
-    # Handle replies
-    if event.is_reply:
-        reply_msg = await event.get_reply_message()
-        if reply_msg:
-            payload["reply_to_message_id"] = reply_msg.id
-            if reply_msg.sender_id:
-                payload["reply_user_id"] = reply_msg.sender_id
-
-    # Add command compatibility: if owner uses a dot prefix, treat it as slash for the worker
-    if is_outgoing and text.startswith('.'):
-        payload["text"] = '/' + text[1:]
-
-    logger.info(f"Forwarding payload to worker: {payload}")
-    worker_data = await forward_to_worker(payload)
-
-    if worker_data and worker_data.get("ok"):
-        # Handle Standard Text Response
-        response_text = worker_data.get("response")
-        if response_text:
-            try:
-                await event.reply(response_text, parse_mode='html')
-            except Exception as e:
-                logger.error(f"Error sending response to Telegram: {e}")
-
-# --- Dummy Web Server (Keep-Alive for Hugging Face Spaces) ---
-async def handle_ping(request):
-    return web.Response(text="Userbot is running!")
-
-async def start_web_server():
-    app = web.Application()
-    app.router.add_get('/', handle_ping)
-    runner = web.AppRunner(app)
-    await runner.setup()
-    port = int(os.environ.get('PORT', 7860))
-    site = web.TCPSite(runner, '0.0.0.0', port)
-    await site.start()
-    logger.info(f"Web server started on port {port}")
-
-async def main():
-    await client.start()
-    logger.info("Userbot started successfully!")
-    
-    # Start the dummy web server
-    await start_web_server()
-    
-    # Run the bot until disconnected
-    await client.run_until_disconnected()
-
-if __name__ == '__main__':
-    # Run the asyncio event loop
-    asyncio.run(main())