Update app.py

app.py

@@ -1,43 +1,63 @@
 import gradio as gr
 from telethon.sync import TelegramClient, events
-import asyncio
 import datetime
+import socks
+import time
 
-api_id = '10086982'
-api_hash = '3ed461889a88b31fcbc323d13e43cf7e'
+proxy_server = '142.93.68.63'
+proxy_port = 2434
+proxy_secret = 'ee32b920dffb51643028e2f6b878d4eac1666172616b61762e636f6d'
+proxy_dc_id = 2  # This is usually 2 for MTProto proxies
 
+#('hostname', port, 'secret')
+proxy = (
+    socks.SOCKS5,
+    proxy_server,
+    proxy_port,
+    True,
+    'vpn',
+    'unlimited'
+)
 
-def handle_messages():
-    async def process_messages():
-        async with TelegramClient('anon', api_id, api_hash) as client:
-            @client.on(events.NewMessage())
-            async def my_event_handler(event):
-                sender = await event.get_sender()
-                sender_id = sender.id
-                sender_name = sender.first_name
-                chat = await event.get_chat()
-                chat_id = chat.id
-                text = event.raw_text
+api_id = '10086982'
+api_hash = '3ed461889a88b31fcbc323d13e43cf7e'
+phone = '+963994935356'
 
-        # مقياس الزمن
-                checkpoint = datetime.datetime.now()
-                print(f'Checkpoint: {checkpoint}')
+# Dictionary to track the times when senders were last replied to
+reply_times = {}
 
-        # رسالة شخصية
-                if chat_id == sender_id:
-                    response = f'اهلا {sender_name} , لقد تلقيت رسالتك سأقوم بالرد عليك بأقرب وقت ممكن وشكراً لتفهمك.'
-                    await client.send_message(chat_id, response)
-        
-        # رسالة مجموعة
-                elif '@Mohammed_Alakhras' in text:
-                    response = f'اهلا {sender_name} , لقد تلقيت رسالتك سأقوم بالرد عليك بأقرب وقت ممكن وشكراً لتفهمك.'
-                    await client.send_message(chat_id, response)
+async with TelegramClient('anon', api_id, api_hash, proxy=proxy) as client:
+    @client.on(events.NewMessage())
+    async def my_event_handler(event):
+        sender = await event.get_sender()
+        sender_id = sender.id
+        sender_name = sender.first_name
+        chat = await event.get_chat()
+        chat_id = chat.id
+        text = event.raw_text
 
+        # Timekeeping
+        checkpoint = datetime.datetime.now()
+        print(f'Checkpoint: {checkpoint}')
 
-            await client.run_until_disconnected()
+        # Personal message
+        if chat_id == sender_id:
+            # Check the last reply to this sender
+            last_reply_time = reply_times.get(sender_id, None)
+            if last_reply_time is None or time.time() - last_reply_time > 60*15:  # reply only if not replied in the last minute
+                response = f'Hello {sender_name}, I received your message and will reply as soon as possible. Thank you for your understanding.'
+                await client.send_message(chat_id, response)
+                reply_times[sender_id] = time.time()  # update the last reply time
 
-    asyncio.run(process_messages())
+        # Group message
+        elif '@Mohammed_Alakhras' in text:
+            last_reply_time = reply_times.get(sender_id, None)
+            if last_reply_time is None or time.time() - last_reply_time > 60:
+                response = f'Hello {sender_name}, I received your message and will reply as soon as possible. Thank you for your understanding.'
+                await client.send_message(chat_id, response)
+                reply_times[sender_id] = time.time()
 
+    await client.run_until_disconnected()
 # تعريف حقول النص في Gradio
 
 # تعريف الواجهة