attendantelectro commited on
Commit
12956c2
·
verified ·
1 Parent(s): 5629318

Update app.py

Browse files
Files changed (1) hide show
  1. app.py +10 -9
app.py CHANGED
@@ -1,28 +1,29 @@
1
  from fastapi import FastAPI, Request
2
- from telegram import Update, Bot
3
  from telegram.ext import Dispatcher, MessageHandler, Filters
4
  import os
5
 
6
  TOKEN = os.getenv("TELEGRAM_TOKEN")
7
- bot = Bot(token=TOKEN)
 
 
 
 
 
8
  dispatcher = Dispatcher(bot, None, use_context=True)
9
 
10
  def handle_message(update: Update, context):
 
 
11
  update.message.reply_text(f"سلام! تو گفتی: {update.message.text}")
12
 
13
  dispatcher.add_handler(MessageHandler(Filters.text & ~Filters.command, handle_message))
14
 
15
  app = FastAPI()
16
 
17
- # --- این بخش جدید اضافه شده است ---
18
  @app.get("/")
19
  async def root():
20
- """
21
- این مسیر برای پاسخ به درخواست‌های Health Check است
22
- تا خطای 404 در لاگ‌ها ایجاد نشود.
23
- """
24
- return {"status": "running", "message": "Bot is active!"}
25
- # ---------------------------------
26
 
27
  @app.post("/webhook")
28
  async def webhook(request: Request):
 
1
  from fastapi import FastAPI, Request
2
+ from telegram import Update, Bot, Request # 1. Request را ایمپورت کنید
3
  from telegram.ext import Dispatcher, MessageHandler, Filters
4
  import os
5
 
6
  TOKEN = os.getenv("TELEGRAM_TOKEN")
7
+
8
+ # 2. یک آبجکت Request با زمان انتظار بیشتر بسازید (مثلا 20 ثانیه)
9
+ request = Request(connect_timeout=20.0, read_timeout=20.0)
10
+
11
+ # 3. از این request در ساختن Bot استفاده کنید
12
+ bot = Bot(token=TOKEN, request=request)
13
  dispatcher = Dispatcher(bot, None, use_context=True)
14
 
15
  def handle_message(update: Update, context):
16
+ # برای اطمینان از اینکه تابع اجرا می‌شود، می‌توانید لاگ بگیرید
17
+ print(f"Received message: {update.message.text}")
18
  update.message.reply_text(f"سلام! تو گفتی: {update.message.text}")
19
 
20
  dispatcher.add_handler(MessageHandler(Filters.text & ~Filters.command, handle_message))
21
 
22
  app = FastAPI()
23
 
 
24
  @app.get("/")
25
  async def root():
26
+ return {"status": "running"}
 
 
 
 
 
27
 
28
  @app.post("/webhook")
29
  async def webhook(request: Request):