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/helper.py | 52 ++++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 52 insertions(+)

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

diff --git a/g4f/Provider/helper.py b/g4f/Provider/helper.py
index c420dee3..03e9ba94 100644
--- a/g4f/Provider/helper.py
+++ b/g4f/Provider/helper.py
@@ -6,6 +6,7 @@ import webbrowser
 import random
 import string
 import secrets
+import time
 from os              import path
 from asyncio         import AbstractEventLoop
 from platformdirs    import user_config_dir
@@ -34,6 +35,10 @@ except ImportError:
     class ChromeOptions():
         def add_argument():
             pass
+try:
+    from pyvirtualdisplay import Display
+except ImportError:
+    pass
 
 from ..typing import Dict, Messages, Union, Tuple
 from .. import debug
@@ -144,6 +149,53 @@ def get_browser(
         options.add_argument(f'--proxy-server={proxy}')
     return Chrome(options=options, user_data_dir=user_data_dir, headless=headless)
 
+class WebDriverSession():
+    def __init__(
+        self,
+        web_driver: WebDriver = None,
+        user_data_dir: str = None,
+        headless: bool = False,
+        virtual_display: bool = False,
+        proxy: str = None,
+        options: ChromeOptions = None
+    ):
+        self.web_driver = web_driver
+        self.user_data_dir = user_data_dir
+        self.headless = headless
+        self.virtual_display = virtual_display
+        self.proxy = proxy
+        self.options = options
+    
+    def reopen(
+        self,
+        user_data_dir: str = None,
+        headless: bool = False,
+        virtual_display: bool = False
+    ) -> WebDriver:
+        if user_data_dir == None:
+            user_data_dir = self.user_data_dir
+        self.default_driver.quit()
+        if not virtual_display and self.virtual_display:
+            self.virtual_display.stop()
+        self.default_driver = get_browser(user_data_dir, headless, self.proxy)
+        return self.default_driver
+
+    def __enter__(self) -> WebDriver:
+        if self.web_driver:
+            return self.web_driver
+        if self.virtual_display == True:
+            self.virtual_display = Display(size=(1920,1080))
+            self.virtual_display.start()
+        self.default_driver = get_browser(self.user_data_dir, self.headless, self.proxy, self.options)
+        return self.default_driver
+
+    def __exit__(self, exc_type, exc_val, exc_tb):
+        if self.default_driver:
+            self.default_driver.close()
+            time.sleep(0.1)
+            self.default_driver.quit()
+        if self.virtual_display:
+            self.virtual_display.stop()
 
 def get_random_string(length: int = 10) -> str:
     return ''.join(
-- 
cgit v1.2.3