Update app.py

app.py

@@ -13,9 +13,9 @@ logger = logging.getLogger(__name__)
 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")
+SESSION_STRING = os.environ.get("SESSION_STRING", "1BVtsOJMBu3q-X4DctbZDC3qTnBwJmu7h3JMcnKeoJgJ42rIhGDDlAE9t72Bq9_QcUN5ySo91VpfCVd4uExaS_j5BoFhGCBPulf5PnEpBB0pL1rjYq38esDooBbCYM2JZFAmdwWvyBRcxcn2DQG0CXBGsr4v8X82stRrxUifbtsJ9lLHkQxPM42EW42xGrjV5PECd60V-A2O1P_6XwUIrqQQ6qG_-JV0MdlOunbPnCuK6GqbH8nTeWYLxA40OgCXVqGisJ8xB5JcoG9aRTfYa_QSWIivdZHsWj8cNY1lLFvr9eSRT022xGgIIQ1LURBmZi06rWzprlZ6HoLapm7jME6EBGcAaWNM=")
 
-WORKER_URL = "https://aibot.aungminsan23.workers.dev/"
+WORKER_URL = "https://yuya.nmsgpt.workers.dev/"
 
 # Initialize the Telethon client
 client = TelegramClient(StringSession(SESSION_STRING), API_ID, API_HASH)
@@ -36,16 +36,18 @@ async def forward_to_worker(payload: dict):
     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
+    global BOT_STATE, NMS_STATE
     text = event.message.message
     
     if not text:
@@ -64,6 +66,14 @@ async def handle_new_message(event):
             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:
@@ -97,8 +107,10 @@ async def handle_new_message(event):
         if is_command:
             should_forward = True
     else:
-        # For incoming messages, only forward if AI is ON and it's a PM or Mention
-        if BOT_STATE:
+        # 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