Spaces:

Opera8
/

Tsj

Sleeping

App Files Files Community

Opera8 commited on Jun 14

Commit

8bd13e5

verified ·

1 Parent(s): 632f40e

Update app.py

Browse files

Files changed (1) hide show

app.py +378 -47

app.py CHANGED Viewed

@@ -1,54 +1,385 @@
-# یک پروکسی لینک مستقیم برای استفاده در برنامه‌ها و ربات‌های دیگر
-@app.get("/proxy")
-async def proxy_endpoint(q: str):
-    if not q.strip():
-        return {"error": "عبارت جستجو نمی‌تواند خالی باشد"}
-    global global_browser
-    url = f"https://www.google.com/search?q={q}&udm=50"
-    context = await global_browser.new_context(
-        user_agent="Mozilla/5.0 (Linux; Android 10; K) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/122.0.0.0 Mobile Safari/537.36",
-        viewport={"width": 412, "height": 915},
-        locale="fa-IR", timezone_id="Asia/Tehran"
-    )
-    page = await context.new_page()
-    try:
-        await page.goto(url, wait_until="commit", timeout=20000)
-        await page.wait_for_timeout(500)
-        # شبیه‌سازی زدن اینتر
-        input_box = await page.query_selector("textarea") or await page.query_selector("input[type='text']")
-        if input_box:
-            await input_box.focus()
-            await input_box.press("Enter")
-        # چک کردن داینامیک پایان تایپ گوگل
-        full_text = ""
-        for _ in range(25):
-            await page.wait_for_timeout(400)
-            full_text = await page.evaluate("() => document.body.innerText")
-            if "هوشواره ممکن است اشتباه" in full_text or "بیشتر بدانید" in full_text:
-                break
-        # تصفیه و استخراج متن خالص
-        lines = full_text.split('\n')
-        cleaned_lines = []
-        for line in lines:
-            line_str = line.strip()
-            if not line_str or any(j == line_str for j in ["تصاویر", "ویدیوها", "اخبار", "نقشه‌ها", "خرید کردن", "کتاب‌ها", "مالی", "حالت موضوع‌محور", "ورود", "همه", "ارسال"]):
-                continue
-            if "هوشواره ممکن است اشتباه" in line_str or "بیشتر بدانید" in line_str:
-                break
-            if line_str == q:
-                cleaned_lines = []
-                continue
-            cleaned_lines.append(line_str)
-        await context.close()
-        return HTMLResponse(content="\n".join(cleaned_lines).strip(), status_code=200)
-    except Exception as e:
-        await context.close()
-        return HTMLResponse(content=f"Error: {str(e)}", status_code=500)

+import os
+import time
+import asyncio
+import uvicorn
+from fastapi import FastAPI, Form, File, UploadFile
+from fastapi.responses import HTMLResponse, StreamingResponse
+from playwright.async_api import async_playwright
+from contextlib import asynccontextmanager
+UPLOAD_DIR = "temp_uploads"
+os.makedirs(UPLOAD_DIR, exist_ok=True)
+global_browser = None
+pw_instance = None
+@asynccontextmanager
+async def lifespan(app: FastAPI):
+    global global_browser, pw_instance
+    print("⚡ در حال راه‌اندازی مرورگر سراسری کروم...")
+    pw_instance = await async_playwright().start()
+    global_browser = await pw_instance.chromium.launch(
+        headless=True,
+        args=[
+            "--no-sandbox",
+            "--disable-setuid-sandbox",
+            "--disable-dev-shm-usage",
+            "--disable-blink-features=AutomationControlled"
+        ]
+    )
+    print("🚀 مرورگر سراسری با موفقیت لود شد.")
+    yield
+    print("🛑 در حال بستن مرورگر سراسری...")
+    if global_browser:
+        await global_browser.close()
+    if pw_instance:
+        await pw_instance.stop()
+app = FastAPI(lifespan=lifespan)
+# رابط کاربری با قابلیت خواندن استریم باینری پاسخ‌ها با استفاده از ReadableStream فرچ
+HTML_CHAT_INTERFACE = """
+<!DOCTYPE html>
+<html lang="fa" dir="rtl">
+<head>
+    <meta charset="UTF-8">
+    <meta name="viewport" content="width=device-width, initial-scale=1.0">
+    <title>Google AI Free Chatbot + Streaming</title>
+    <style>
+        :root {
+            --bg-gradient: linear-gradient(135deg, #0f172a 0%, #1e293b 100%);
+            --glass-bg: rgba(30, 41, 59, 0.7);
+            --glass-border: rgba(255, 255, 255, 0.08);
+            --text-main: #f8fafc;
+            --accent-color: #38bdf8;
+            --user-bubble: linear-gradient(135deg, #0284c7 0%, #0369a1 100%);
+            --ai-bubble: rgba(255, 255, 255, 0.06);
+        }
+        body {
+            font-family: -apple-system, BlinkMacSystemFont, "Segoe UI", Roboto, Tahoma, sans-serif;
+            margin: 0; padding: 0; background: var(--bg-gradient); color: var(--text-main);
+            height: 100vh; display: flex; align-items: center; justify-content: center; overflow: hidden;
+        }
+        .chat-container {
+            width: 100%; max-width: 850px; height: 85vh; background: var(--glass-bg);
+            backdrop-filter: blur(16px); -webkit-backdrop-filter: blur(16px);
+            border: 1px solid var(--glass-border); border-radius: 24px;
+            display: flex; flex-direction: column; box-shadow: 0 20px 40px rgba(0, 0, 0, 0.3); margin: 20px;
+        }
+        .chat-header { padding: 20px 24px; border-bottom: 1px solid var(--glass-border); display: flex; align-items: center; gap: 12px; }
+        .chat-header .status-dot { width: 10px; height: 10px; background: #4ade80; border-radius: 50%; box-shadow: 0 0 10px #4ade80; }
+        .chat-header h2 { margin: 0; font-size: 18px; font-weight: 600; color: var(--accent-color); }
+        .messages-box { flex: 1; padding: 24px; overflow-y: auto; display: flex; flex-direction: column; gap: 16px; }
+        .messages-box::-webkit-scrollbar { width: 6px; }
+        .messages-box::-webkit-scrollbar-track { background: transparent; }
+        .messages-box::-webkit-scrollbar-thumb { background: rgba(255, 255, 255, 0.1); border-radius: 10px; }
+        .message { max-width: 75%; padding: 14px 18px; border-radius: 18px; font-size: 15px; line-height: 1.6; word-wrap: break-word; animation: fadeIn 0.3s ease forwards; }
+        .message.user { background: var(--user-bubble); align-self: flex-start; border-bottom-right-radius: 4px; box-shadow: 0 4px 12px rgba(2, 132, 199, 0.2); }
+        .message.ai { background: var(--ai-bubble); border: 1px solid var(--glass-border); align-self: flex-end; border-bottom-left-radius: 4px; white-space: pre-wrap; }
+        .input-wrapper { border-top: 1px solid var(--glass-border); background: rgba(15, 23, 42, 0.4); border-bottom-left-radius: 24px; border-bottom-right-radius: 24px; padding: 15px 24px; display: flex; flex-direction: column; gap: 10px; }
+        .preview-container { display: none; align-items: center; gap: 10px; background: rgba(255, 255, 255, 0.05); padding: 8px 12px; border-radius: 10px; width: fit-content; border: 1px solid var(--glass-border); }
+        .preview-container img { width: 40px; height: 40px; object-fit: cover; border-radius: 6px; }
+        .preview-container .remove-btn { color: #ef4444; cursor: pointer; font-weight: bold; font-size: 14px; }
+        .input-area { display: flex; gap: 12px; align-items: center; }
+        .input-area input[type="text"] { flex: 1; background: rgba(255, 255, 255, 0.05); border: 1px solid var(--glass-border); padding: 14px 20px; border-radius: 14px; color: white; font-size: 15px; outline: none; transition: all 0.2s; }
+        .input-area input[type="text"]:focus { border-color: var(--accent-color); background: rgba(255, 255, 255, 0.08); box-shadow: 0 0 12px rgba(56, 189, 248, 0.15); }
+        .upload-label { background: rgba(255, 255, 255, 0.05); border: 1px solid var(--glass-border); padding: 12px; border-radius: 14px; cursor: pointer; display: flex; align-items: center; justify-content: center; transition: all 0.2s; }
+        .upload-label:hover { background: rgba(255, 255, 255, 0.1); border-color: var(--accent-color); }
+        .upload-label svg { width: 22px; height: 22px; fill: var(--text-main); }
+        .input-area button { background: var(--accent-color); color: #0f172a; border: none; padding: 14px 24px; border-radius: 14px; font-size: 15px; font-weight: bold; cursor: pointer; transition: all 0.2s; }
+        .input-area button:hover { background: #7dd3fc; transform: translateY(-1px); }
+        .input-area button:disabled { background: #64748b; color: #1e293b; cursor: not-allowed; transform: none; }
+        .typing-indicator { display: flex; gap: 5px; padding: 12px 18px; background: var(--ai-bubble); border-radius: 12px; align-self: flex-end; border: 1px solid var(--glass-border); }
+        .typing-indicator span { width: 8px; height: 8px; background: var(--accent-color); border-radius: 50%; animation: bounce 1.4s infinite ease-in-out both; }
+        .typing-indicator span:nth-child(1) { animation-delay: -0.32s; }
+        .typing-indicator span:nth-child(2) { animation-delay: -0.16s; }
+        @keyframes fadeIn { from { opacity: 0; transform: translateY(10px); } to { opacity: 1; transform: translateY(0); } }
+        @keyframes bounce { 0%, 80%, 100% { transform: scale(0); } 40% { transform: scale(1.0); } }
+    </style>
+</head>
+<body>
+    <div class="chat-container">
+        <div class="chat-header">
+            <div class="status-dot"></div>
+            <h2>دستیار مالتی‌مدال گوگل (متن + تصویر زنده و سریع)</h2>
+        </div>
+        <div class="messages-box" id="messagesBox">
+            <div class="message ai">سلام! من متصل به هوشواره گوگل هستم. کلمات را به صورت کلمه به کلمه و زنده تایپ می‌کنم. چطور می‌توانم کمکتان کنم؟</div>
+        </div>
+        <div class="input-wrapper">
+            <div class="preview-container" id="previewContainer">
+                <img src="" id="imagePreview">
+                <span class="remove-btn" onclick="removeSelectedImage()">✕ حذف</span>
+            </div>
+            <div class="input-area">
+                <input type="file" id="fileInput" accept="image/*" style="display: none;" onchange="previewImage(event)">
+                <label for="fileInput" class="upload-label" title="آپلود تصویر">
+                    <svg viewBox="0 0 24 24"><path d="M16.5 6v11.5c0 2.21-1.79 4-4 4s-4-1.79-4-4V5c0-1.38 1.12-2.5 2.5-2.5s2.5 1.12 2.5 2.5v10.5c0 .55-.45 1-1 1s-1-.45-1-1V6H10v9.5c0 1.66 1.34 3 3 3s3-1.34 3-3V5c0-2.48-2.02-4.5-4.5-4.5S7 2.52 7 5v12.5c0 3.59 2.91 6.5 6.5 6.5s6.5-2.91 6.5-6V6h-1.5z"/></svg>
+                </label>
+                <input type="text" id="userInput" placeholder="پیام یا توضیح مربوط به تصویر را بنویسید..." onkeypress="handleKeyPress(event)">
+                <button id="sendBtn" onclick="sendMessage()">ارسال</button>
+            </div>
+        </div>
+    </div>
+    <script>
+        const messagesBox = document.getElementById('messagesBox');
+        const userInput = document.getElementById('userInput');
+        const fileInput = document.getElementById('fileInput');
+        const sendBtn = document.getElementById('sendBtn');
+        const previewContainer = document.getElementById('previewContainer');
+        const imagePreview = document.getElementById('imagePreview');
+        function handleKeyPress(e) { if (e.key === 'Enter') sendMessage(); }
+        function previewImage(event) {
+            const file = event.target.files[0];
+            if (file) {
+                const reader = new FileReader();
+                reader.onload = function(e) { imagePreview.src = e.target.result; previewContainer.style.display = 'flex'; }
+                reader.readAsDataURL(file);
+            }
+        }
+        function removeSelectedImage() { fileInput.value = ''; previewContainer.style.display = 'none'; imagePreview.src = ''; }
+        async function sendMessage() {
+            const text = userInput.value.trim();
+            const file = fileInput.files[0];
+            if (!text && !file) return;
+            if (file) appendImageMessage(imagePreview.src, 'user');
+            if (text) appendMessage(text, 'user');
+            userInput.value = '';
+            removeSelectedImage();
+            setLoading(true);
+            const formData = new FormData();
+            formData.append('message', text || "این تصویر را تحلیل کن");
+            if (file) formData.append('image', file);
+            // ایجاد حباب خالی هوش مصنوعی برای آماده‌سازی فرآیند تایپ زنده
+            const aiMessageDiv = document.createElement('div');
+            aiMessageDiv.classList.add('message', 'ai');
+            messagesBox.appendChild(aiMessageDiv);
+            try {
+                const response = await fetch('/api/chat', { method: 'POST', body: formData });
+                if (!response.ok) {
+                    aiMessageDiv.innerText = "خطا در برقراری ارتباط با سرور گوگل.";
+                    setLoading(false);
+                    return;
+                }
+                // خواندن باینری استریم کلمه به کلمه خروجی پایتون
+                const reader = response.body.getReader();
+                const decoder = new TextDecoder("utf-8");
+                // پنهان کردن انیمیشن لودینگ به محض شروع اولین کلمه دریافتی
+                let firstChunk = true;
+                while (true) {
+                    const { value, done } = await reader.read();
+                    if (done) break;
+                    const chunk = decoder.decode(value, { stream: true });
+                    if (chunk) {
+                        if (firstChunk) {
+                            // حذف لودینگ سه نقطه‌ای
+                            const indicator = document.getElementById('typingIndicator');
+                            if (indicator) indicator.remove();
+                            firstChunk = false;
+                        }
+                        aiMessageDiv.innerText += chunk;
+                        messagesBox.scrollTop = messagesBox.scrollHeight;
+                    }
+                }
+            } catch (error) {
+                aiMessageDiv.innerText = "خطای شبکه: دریافت استریم با شکست مواجه شد.";
+            } finally {
+                setLoading(false);
+            }
+        }
+        function appendMessage(text, sender) {
+            const msgDiv = document.createElement('div'); msgDiv.classList.add('message', sender);
+            msgDiv.innerText = text; messagesBox.appendChild(msgDiv); messagesBox.scrollTop = messagesBox.scrollHeight;
+        }
+        function appendImageMessage(src, sender) {
+            const msgDiv = document.createElement('div'); msgDiv.classList.add('message', sender); msgDiv.style.padding = '8px';
+            const img = document.createElement('img'); img.src = src; img.style.maxWidth = '200px'; img.style.maxHeight = '200px'; img.style.borderRadius = '12px'; img.style.display = 'block';
+            msgDiv.appendChild(img); messagesBox.appendChild(msgDiv); messagesBox.scrollTop = messagesBox.scrollHeight;
+        }
+        function setLoading(isLoading) {
+            if (isLoading) {
+                userInput.disabled = true; sendBtn.disabled = true;
+                const indicator = document.createElement('div'); indicator.classList.add('typing-indicator'); indicator.id = 'typingIndicator';
+                indicator.innerHTML = '<span></span><span></span><span></span>'; messagesBox.appendChild(indicator); messagesBox.scrollTop = messagesBox.scrollHeight;
+            } else {
+                userInput.disabled = false; sendBtn.disabled = false;
+                const indicator = document.getElementById('typingIndicator'); if (indicator) indicator.remove(); userInput.focus();
+            }
+        }
+    </script>
+</body>
+</html>
+"""
+# الگوریتم مهندسی معکوس برای استخراج و تصفیه متن خالص پاسخ هوش مصنوعی
+def clean_text(full_text: str, message: str) -> str:
+    lines = full_text.split('\n')
+    cleaned_lines = []
+    # واژه‌های کاربری منوهای ناوبری که نباید به هیچ وجه نشت پیدا کنند
+    global_junk = ["تصاویر", "ویدیوها", "اخبار", "نقشه‌ها", "خرید کردن", "کتاب‌ها", "مالی", "حالت موضوع‌محور", "ورود", "همه", "ویدئوها", "ارسال", "پاسخ «حالت هوشواره‌ای» آماده است", "All items removed", message]
+    for line in lines:
+        line_str = line.strip()
+        if not line_str or line_str in global_junk:
+            continue
+        # به محض رسیدن به لایه فوتر سلب مسئولیت، کلاً خواندن را قطع کن
+        if "هوشواره ممکن است اشتباه" in line_str or "در پاسخ‌های" in line_str or "بیشتر بدانید" in line_str:
+            break
+        cleaned_lines.append(line_str)
+    return "\n".join(cleaned_lines).strip()
+@app.get("/", response_class=HTMLResponse)
+async def chat_interface():
+    return HTML_CHAT_INTERFACE
+@app.post("/api/chat")
+async def chat_endpoint(message: str = Form(...), image: UploadFile = File(None)):
+    global global_browser
+    if not global_browser:
+        return StreamingResponse(iter(["خطا: وب سرور کروم فعال نیست."]), media_type="text/plain")
+    saved_image_path = None
+    if image:
+        try:
+            saved_image_path = os.path.join(UPLOAD_DIR, f"{int(time.time())}_{image.filename}")
+            with open(saved_image_path, "wb") as buffer:
+                buffer.write(await image.read())
+        except Exception as e:
+            return StreamingResponse(iter([f"خطا در ذخیره تصویر روی داکر: {str(e)}"]), media_type="text/plain")
+    # ساخت سشن ژنراتور استریمینگ زنده کلمات برای پاسخ در لحظه
+    async def response_generator():
+        # استفاده از domcontentloaded برای بالا بردن سرعت اولیه رندر فرم‌ها بدون معطلی تصاویر حجیم
+        context = await global_browser.new_context(
+            user_agent="Mozilla/5.0 (Linux; Android 10; K) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/122.0.0.0 Mobile Safari/537.36",
+            viewport={"width": 412, "height": 915},
+            locale="fa-IR", timezone_id="Asia/Tehran"
+        )
+        page = await context.new_page()
+        try:
+            url = "https://www.google.com/search?q=سلام&udm=50"
+            await page.goto(url, wait_until="domcontentloaded", timeout=30000)
+            # تزریق ۱۰۰٪ پناهنده فایل به اینپوت‌های مخفی لایه وب گوگل
+            if saved_image_path and os.path.exists(saved_image_path):
+                try:
+                    file_input = await page.query_selector("input[type='file']")
+                    if file_input:
+                        await file_input.set_input_files(saved_image_path)
+                        await page.wait_for_timeout(1500)
+                except Exception as e:
+                    print(f"Bypassed image setup: {e}")
+            # درج کوئری متنی کاربر درون کادر چت
+            input_box = None
+            candidates = await page.query_selector_all("textarea, input, [contenteditable='true']")
+            for el in candidates:
+                try:
+                    if await el.is_visible():
+                        placeholder = await el.get_attribute("placeholder") or ""
+                        if any(w in placeholder for w in ["بپرسید", "ask", "پیام", "چطور", "هرچه"]):
+                            input_box = el
+                            break
+                except:
+                    continue
+            if not input_box:
+                input_box = await page.query_selector("textarea") or await page.query_selector("input[type='text']")
+            if input_box:
+                await input_box.focus()
+                await input_box.fill(message)
+                await page.wait_for_timeout(300)
+                await input_box.press("Enter")
+                # فایر کردن دکمه فیزیکی ارسال جهت اطمینان فرم در کلاینت‌های کند
+                try:
+                    send_buttons = await page.query_selector_all("button, [role='button']")
+                    for btn in send_buttons:
+                        if await btn.is_visible():
+                            aria = (await btn.get_attribute("aria-label") or "").lower()
+                            if any(w in aria for w in ["send", "ارسال", "arrow", "up"]):
+                                await btn.click(timeout=1000)
+                                break
+                except:
+                    pass
+            # 🚀 حلقه مانیتورینگ استریمینگ: واکشی کلمات در زمان واقعی بدون ثانیه‌ای معطلی ثمر بخش
+            last_sent_text = ""
+            no_change_count = 0
+            for _ in range(40): # حداکثر ۱۶ ثانیه پایش زنده صفحه
+                await page.wait_for_timeout(400) # بررسی صفحه هر ۴۰۰ میلی‌ثانیه برای استریم فوق سریع
+                full_text = await page.evaluate("() => document.body.innerText")
+                current_clean_text = clean_text(full_text, message)
+                # اگر متن جدیدی تایپ شده بود، تفاوت آن را فوراً روانه کلاینت کن
+                if len(current_clean_text) > len(last_sent_text):
+                    new_chunk = current_clean_text[len(last_sent_text):]
+                    yield new_chunk
+                    last_sent_text = current_clean_text
+                    no_change_count = 0
+                else:
+                    if len(current_clean_text) > 0:
+                        no_change_count += 1
+                # اگر کادر هشدار گوگل لود شده بود یا تایپ متن به پایان رسیده بود، استریم را ببند
+                if "هوشواره ممکن است اشتباه" in full_text or "بیشتر بدانید" in full_text or "پاسخ‌های مربوط به افراد" in full_text:
+                    # ارسال نهایی باقیمانده کاراکترها برای احتیاط
+                    full_text = await page.evaluate("() => document.body.innerText")
+                    current_clean_text = clean_text(full_text, message)
+                    if len(current_clean_text) > len(last_sent_text):
+                        yield current_clean_text[len(last_sent_text):]
+                    break
+                # اگر برای ۳ ثانیه هیچ متنی اضافه نشد یعنی پاسخ متوقف شده است
+                if no_change_count > 7 and len(last_sent_text) > 0:
+                    break
+        except Exception as e:
+            yield f"خطای پردازش هوش مصنوعی: {str(e)}"
+        finally:
+            await context.close()
+            if saved_image_path and os.path.exists(saved_image_path):
+                try: os.remove(saved_image_path)
+                except: pass
+    return StreamingResponse(response_generator(), media_type="text/event-stream")
+if __name__ == "__main__":
+    uvicorn.run(app, host="0.0.0.0", port=7860)