Update app.py

app.py

@@ -1,7 +1,6 @@
 import os
 import json
 import time
-import asyncio
 from flask import Flask, request, Response, jsonify, render_template, redirect
 from google import genai
 from google.genai import types
@@ -157,25 +156,25 @@ def set_item_availability(item_name: str, available: bool) -> str:
 # --- روت‌های مسیریابی آدرس‌ها (Domain URL Mapping) ---
 
 @app.route('/')
-async def home_redirect():
+def home_redirect():
     # ریدایرکت روت اصلی به میز ۱ به عنوان پیش‌فرض
     return redirect('/customer/1')
 
 @app.route('/customer/<table_number>')
-async def customer_chat_page(table_number):
+def customer_chat_page(table_number):
     # سرو کردن صفحه چت مشتری برای میز انتخابی
     return render_template("customer.html", table_number=table_number)
 
 @app.route('/dashboard')
-async def admin_dashboard_page():
+def admin_dashboard_page():
     # سرو کردن پنل مدیریت کافه
     return render_template("cafe.html")
 
 
-# --- مسیرهای ناهمگام سرویس‌های API مشتری ---
+# --- مسیرهای پایدار سرویس‌های API مشتری ---
 
 @app.route('/api/customer/chat_stream/<table_number>', methods=['POST'])
-async def api_customer_chat_stream(table_number):
+def api_customer_chat_stream(table_number):
     api_key = os.environ.get("NILLA_CUSTOMER")
     if not api_key:
         return jsonify({"error": "کلید NILLA_CUSTOMER در سرور یافت نشد."}), 500
@@ -185,20 +184,15 @@ async def api_customer_chat_stream(table_number):
     if not user_message:
         return jsonify({"error": "پیام خالی است."}), 400
 
-    # بررسی و تعریف آرایه سابقه چت برای میز جاری
     if table_number not in table_chat_histories:
         table_chat_histories[table_number] = []
 
-    # پاک کردن سفارش موقت قبلی جهت استخراج فاکتور جدید
     global_drafts.pop(table_number, None)
-
-    # افزودن پیام مشتری به آرشیو سوابق میز
     table_chat_histories[table_number].append({"role": "user", "content": user_message})
     active_tasks[table_number] = True
 
-    async def generate_chunks():
+    def generate_chunks():
         try:
-            # تبدیل ساختار آرشیو سوابق به انواع داده‌ای مورد پذیرش SDK جدید
             contents = []
             for msg in table_chat_histories[table_number]:
                 role = "user" if msg["role"] == "user" else "model"
@@ -209,7 +203,6 @@ async def api_customer_chat_stream(table_number):
                     )
                 )
 
-            # راه‌اندازی کلاینت ناهمگام گوگل با متد aio
             client = genai.Client(api_key=api_key)
             full_generated_text = ""
             
@@ -221,13 +214,12 @@ async def api_customer_chat_stream(table_number):
                 thinking_config=types.ThinkingConfig(thinking_level="MINIMAL")
             )
 
-            # فراخوانی استریم ناهمگام گوگل
-            async for chunk in await client.aio.models.generate_content_stream(
+            # فراخوانی جریان استریم همگام و پایدار
+            for chunk in client.models.generate_content_stream(
                 model="gemini-3.1-flash-lite",
                 contents=contents,
                 config=config
             ):
-                # اگر کلاینت دکمه توقف را زده باشد، استریم بلافاصله خاتمه یابد
                 if not active_tasks.get(table_number, True):
                     break
 
@@ -235,14 +227,11 @@ async def api_customer_chat_stream(table_number):
                     full_generated_text += chunk.text
                     yield f"data: {json.dumps({'type': 'text', 'content': chunk.text}, ensure_ascii=False)}\n\n"
 
-            # ذخیره پاسخ مدل در پایان جریان چت برای پیوستگی گفتگوهای بعد
             if full_generated_text:
                 table_chat_histories[table_number].append({"role": "model", "content": full_generated_text})
 
-            # بررسی اینکه آیا ابزار ثبت سفارش (prepare_order_draft) صدا زده شده بود
             draft = global_drafts.get(table_number)
             if draft:
-                # ارسال فاکتور استخراج شده به سمت فرانت‌اند جهت نمایش دکمه تایید نهایی دو مرحله‌ای
                 yield f"data: {json.dumps({'type': 'draft', 'items': draft['items']}, ensure_ascii=False)}\n\n"
 
         except Exception as e:
@@ -253,13 +242,12 @@ async def api_customer_chat_stream(table_number):
     return Response(generate_chunks(), mimetype='text/event-stream')
 
 @app.route('/api/customer/stop/<table_number>', methods=['POST'])
-async def api_customer_stop(table_number):
-    # متوقف کردن زنده فرآیند استریمینگ در سمت بک‌اند
+def api_customer_stop(table_number):
     active_tasks[table_number] = False
     return jsonify({"success": True, "message": "فرآیند تولید متوقف شد."})
 
 @app.route('/api/confirm_order', methods=['POST'])
-async def api_confirm_order():
+def api_confirm_order():
     data = request.json or {}
     table_number = data.get("table_number")
     items = data.get("items")
@@ -268,7 +256,6 @@ async def api_confirm_order():
         return jsonify({"error": "شماره میز مشخص نیست."}), 400
         
     if not items:
-        # در صورت نبود آیتم‌ها تلاش مجدد برای خواندن از درفت سرور انجام می‌شود
         draft = global_drafts.get(table_number)
         if not draft:
             return jsonify({"error": "اطلاعات پیش‌نویس یافت نشد."}), 404
@@ -285,7 +272,6 @@ async def api_confirm_order():
     orders.append(new_order)
     save_orders(orders)
     
-    # --- پاکسازی نهایی جهت آزادسازی منابع سیستم (نیاز ادمین) ---
     table_chat_histories.pop(table_number, None)
     global_drafts.pop(table_number, None)
     active_tasks.pop(table_number, None)
@@ -293,16 +279,16 @@ async def api_confirm_order():
     return jsonify({"success": True, "message": "سفارش ثبت شد و سشن میز کاملاً آزاد گردید."})
 
 
-# --- مسیرهای ناهمگام سرویس‌های API مدیریت کافه ---
+# --- سرویس‌های API مدیریت کافه ---
 
 @app.route('/api/admin/orders', methods=['GET'])
-async def api_admin_orders():
+def api_admin_orders():
     orders = load_orders()
     active_orders = [o for o in orders if o.get("status", "pending") == "pending"]
     return jsonify(active_orders)
 
 @app.route('/api/admin/complete_order', methods=['POST'])
-async def api_admin_complete_order():
+def api_admin_complete_order():
     data = request.json or {}
     order_id = data.get("order_id")
     
@@ -323,7 +309,7 @@ async def api_admin_complete_order():
     return jsonify({"error": "سفارش پیدا نشد."}), 404
 
 @app.route('/api/admin/chat', methods=['POST'])
-async def api_admin_chat():
+def api_admin_chat():
     api_key = os.environ.get("NILLA_CAFE")
     if not api_key:
         return jsonify({"error": "کلید NILLA_CAFE یافت نشد."}), 500
@@ -349,8 +335,7 @@ async def api_admin_chat():
             thinking_config=types.ThinkingConfig(thinking_level="MINIMAL")
         )
         
-        # استفاده از متد فراخوانی ناهمگام aio برای جلوگیری از بلاک شدن سایر کاربران
-        response = await client.aio.models.generate_content(
+        response = client.models.generate_content(
             model="gemini-3.1-flash-lite",
             contents=contents,
             config=config
@@ -365,7 +350,7 @@ async def api_admin_chat():
         return jsonify({"error": f"خطا در بخش سرور: {str(e)}"}), 500
 
 @app.route('/api/admin/extract_menu', methods=['POST'])
-async def api_extract_menu():
+def api_extract_menu():
     api_key = os.environ.get("NILLA_CAFE")
     if not api_key:
         return jsonify({"error": "کلید NILLA_CAFE یافت نشد."}), 500
@@ -394,8 +379,7 @@ async def api_extract_menu():
         client = genai.Client(api_key=api_key)
         file_part = types.Part.from_bytes(data=file_bytes, mime_type=mime_type)
         
-        # استخراج منوی آپلود شده به صورت ناهمگام
-        response = await client.aio.models.generate_content(
+        response = client.models.generate_content(
             model="gemini-3.1-flash-lite",
             contents=[file_part, prompt],
             config=types.GenerateContentConfig(
@@ -413,18 +397,16 @@ async def api_extract_menu():
         return jsonify({"error": f"خطا در استخراج ساختار: {str(e)}"}), 500
 
 @app.route('/api/admin/save_menu', methods=['POST'])
-async def api_admin_save_menu():
+def api_admin_save_menu():
     data = request.json or {}
     menu_list = data.get("menu")
     
     if not isinstance(menu_list, list):
         return jsonify({"error": "فرمت داده ارسال شده نادرست است."}), 400
         
-    # ثبت نهایی منو در قالب فایل دیتابیس ثابت menu.json
     save_menu(menu_list)
     return jsonify({"success": True, "message": "منوی فعال با موفقیت ثبت شد."})
 
 
 if __name__ == "__main__":
-    # راه‌اندازی سرور
     app.run(host="0.0.0.0", port=7860, debug=True)