From 9239cadd8b3e539a7d5da0eb22b2b047417fb426 Mon Sep 17 00:00:00 2001
From: Heiner Lohaus <hlohaus@users.noreply.github.com>
Date: Sun, 19 Nov 2023 05:36:04 +0100
Subject: Add Response Handler to OpenaiChat Update Providers with WebDriver
 Add WebDriverSession helper Use native streaming in curl_cffi

---
 g4f/Provider/PerplexityAi.py | 62 ++++++++++++++++++++------------------------
 1 file changed, 28 insertions(+), 34 deletions(-)

(limited to 'g4f/Provider/PerplexityAi.py')

diff --git a/g4f/Provider/PerplexityAi.py b/g4f/Provider/PerplexityAi.py
index bce77715..c0b2412e 100644
--- a/g4f/Provider/PerplexityAi.py
+++ b/g4f/Provider/PerplexityAi.py
@@ -4,7 +4,7 @@ import time
 
 from ..typing import CreateResult, Messages
 from .base_provider import BaseProvider
-from .helper import WebDriver, format_prompt, get_browser
+from .helper import WebDriver, WebDriverSession, format_prompt
 
 class PerplexityAi(BaseProvider):
     url = "https://www.perplexity.ai"
@@ -20,27 +20,27 @@ class PerplexityAi(BaseProvider):
         stream: bool,
         proxy: str = None,
         timeout: int = 120,
-        browser: WebDriver = None,
+        web_driver: WebDriver = None,
+        virtual_display: bool = True,
         copilot: bool = False,
         **kwargs
     ) -> CreateResult:
-        driver = browser if browser else get_browser("", False, proxy)
+        with WebDriverSession(web_driver, "", virtual_display=virtual_display, proxy=proxy) as driver:
+            from selenium.webdriver.common.by import By
+            from selenium.webdriver.support.ui import WebDriverWait
+            from selenium.webdriver.support import expected_conditions as EC
+            from selenium.webdriver.common.keys import Keys
 
-        from selenium.webdriver.common.by import By
-        from selenium.webdriver.support.ui import WebDriverWait
-        from selenium.webdriver.support import expected_conditions as EC
-        from selenium.webdriver.common.keys import Keys
+            prompt = format_prompt(messages)
 
-        prompt = format_prompt(messages)
+            driver.get(f"{cls.url}/")
+            wait = WebDriverWait(driver, timeout)
 
-        driver.get(f"{cls.url}/")
-        wait = WebDriverWait(driver, timeout)
+            # Is page loaded?
+            wait.until(EC.visibility_of_element_located((By.CSS_SELECTOR, "textarea[placeholder='Ask anything...']")))
 
-        # Is page loaded?
-        wait.until(EC.visibility_of_element_located((By.CSS_SELECTOR, "textarea[placeholder='Ask anything...']")))
-
-        # Register WebSocket hook
-        script = """
+            # Register WebSocket hook
+            script = """
 window._message = window._last_message = "";
 window._message_finished = false;
 const _socket_send = WebSocket.prototype.send;
@@ -67,22 +67,21 @@ WebSocket.prototype.send = function(...args) {
     return _socket_send.call(this, ...args);
 };
 """
-        driver.execute_script(script)
+            driver.execute_script(script)
 
-        if copilot:
-            try:
-               # Check for account
-                driver.find_element(By.CSS_SELECTOR, "img[alt='User avatar']")
-               # Enable copilot
-                driver.find_element(By.CSS_SELECTOR, "button[data-testid='copilot-toggle']").click()
-            except:
-                raise RuntimeError("You need a account for copilot")
+            if copilot:
+                try:
+                # Check for account
+                    driver.find_element(By.CSS_SELECTOR, "img[alt='User avatar']")
+                # Enable copilot
+                    driver.find_element(By.CSS_SELECTOR, "button[data-testid='copilot-toggle']").click()
+                except:
+                    raise RuntimeError("You need a account for copilot")
 
-        # Submit prompt
-        driver.find_element(By.CSS_SELECTOR, "textarea[placeholder='Ask anything...']").send_keys(prompt)
-        driver.find_element(By.CSS_SELECTOR, "textarea[placeholder='Ask anything...']").send_keys(Keys.ENTER)
+            # Submit prompt
+            driver.find_element(By.CSS_SELECTOR, "textarea[placeholder='Ask anything...']").send_keys(prompt)
+            driver.find_element(By.CSS_SELECTOR, "textarea[placeholder='Ask anything...']").send_keys(Keys.ENTER)
 
-        try:
             # Stream response
             script = """
 if(window._message && window._message != window._last_message) {
@@ -104,9 +103,4 @@ if(window._message && window._message != window._last_message) {
                 elif chunk != "":
                     break
                 else:
-                    time.sleep(0.1)
-        finally:
-            if not browser:
-                driver.close()
-                time.sleep(0.1)
-                driver.quit()
\ No newline at end of file
+                    time.sleep(0.1)
\ No newline at end of file
-- 
cgit v1.2.3