diff options
Diffstat (limited to '')
-rw-r--r-- | g4f/Provider/needs_auth/Bard.py (renamed from g4f/Provider/Bard.py) | 2 | ||||
-rw-r--r-- | g4f/Provider/needs_auth/HuggingChat.py (renamed from g4f/Provider/HuggingChat.py) | 4 | ||||
-rw-r--r-- | g4f/Provider/needs_auth/OpenAssistant.py (renamed from g4f/Provider/OpenAssistant.py) | 6 | ||||
-rw-r--r-- | g4f/Provider/needs_auth/OpenaiChat.py (renamed from g4f/Provider/OpenaiChat.py) | 53 | ||||
-rw-r--r-- | g4f/Provider/needs_auth/Raycast.py (renamed from g4f/Provider/Raycast.py) | 4 | ||||
-rw-r--r-- | g4f/Provider/needs_auth/Theb.py (renamed from g4f/Provider/Theb.py) | 4 | ||||
-rw-r--r-- | g4f/Provider/needs_auth/__init__.py | 6 |
7 files changed, 47 insertions, 32 deletions
diff --git a/g4f/Provider/Bard.py b/g4f/Provider/needs_auth/Bard.py index 4e076378..7c42b680 100644 --- a/g4f/Provider/Bard.py +++ b/g4f/Provider/needs_auth/Bard.py @@ -6,7 +6,7 @@ import re from aiohttp import ClientSession -from .base_provider import AsyncProvider, format_prompt, get_cookies +from ..base_provider import AsyncProvider, format_prompt, get_cookies class Bard(AsyncProvider): diff --git a/g4f/Provider/HuggingChat.py b/g4f/Provider/needs_auth/HuggingChat.py index f1cec775..1d500338 100644 --- a/g4f/Provider/HuggingChat.py +++ b/g4f/Provider/needs_auth/HuggingChat.py @@ -4,8 +4,8 @@ import json, uuid from aiohttp import ClientSession -from ..typing import AsyncGenerator -from .base_provider import AsyncGeneratorProvider, format_prompt, get_cookies +from ...typing import AsyncGenerator +from ..base_provider import AsyncGeneratorProvider, format_prompt, get_cookies class HuggingChat(AsyncGeneratorProvider): diff --git a/g4f/Provider/OpenAssistant.py b/g4f/Provider/needs_auth/OpenAssistant.py index 1e9a0661..3b0e0424 100644 --- a/g4f/Provider/OpenAssistant.py +++ b/g4f/Provider/needs_auth/OpenAssistant.py @@ -4,14 +4,14 @@ import json from aiohttp import ClientSession -from ..typing import Any, AsyncGenerator -from .base_provider import AsyncGeneratorProvider, format_prompt, get_cookies +from ...typing import Any, AsyncGenerator +from ..base_provider import AsyncGeneratorProvider, format_prompt, get_cookies class OpenAssistant(AsyncGeneratorProvider): url = "https://open-assistant.io/chat" needs_auth = True - working = True + working = False model = "OA_SFT_Llama_30B_6" @classmethod diff --git a/g4f/Provider/OpenaiChat.py b/g4f/Provider/needs_auth/OpenaiChat.py index fbd26d7c..c57692d3 100644 --- a/g4f/Provider/OpenaiChat.py +++ b/g4f/Provider/needs_auth/OpenaiChat.py @@ -1,12 +1,11 @@ from __future__ import annotations -import uuid -import json +import uuid, json, time -from .base_provider import AsyncGeneratorProvider -from .helper import get_browser, get_cookies, format_prompt -from ..typing import AsyncGenerator -from ..requests import StreamSession +from ..base_provider import AsyncGeneratorProvider +from ..helper import get_browser, get_cookies, format_prompt +from ...typing import AsyncGenerator +from ...requests import StreamSession class OpenaiChat(AsyncGeneratorProvider): url = "https://chat.openai.com" @@ -56,23 +55,26 @@ class OpenaiChat(AsyncGeneratorProvider): line = line[6:] if line == b"[DONE]": break - line = json.loads(line) - if "message" in line and not line["message"]["end_turn"]: + try: + line = json.loads(line) + except: + continue + if "message" not in line or "message_type" not in line["message"]["metadata"]: + continue + if line["message"]["metadata"]["message_type"] == "next": new_message = line["message"]["content"]["parts"][0] yield new_message[len(last_message):] last_message = new_message @classmethod - def fetch_access_token(cls) -> str: + def browse_access_token(cls) -> str: try: from selenium.webdriver.common.by import By from selenium.webdriver.support.ui import WebDriverWait from selenium.webdriver.support import expected_conditions as EC - except ImportError: - return - driver = get_browser() - if not driver: + driver = get_browser() + except ImportError: return driver.get(f"{cls.url}/") @@ -83,21 +85,28 @@ class OpenaiChat(AsyncGeneratorProvider): javascript = "return (await (await fetch('/api/auth/session')).json())['accessToken']" return driver.execute_script(javascript) finally: + time.sleep(1) driver.quit() @classmethod + async def fetch_access_token(cls, cookies: dict, proxies: dict = None) -> str: + async with StreamSession(proxies=proxies, cookies=cookies, impersonate="chrome107") as session: + async with session.get(f"{cls.url}/api/auth/session") as response: + response.raise_for_status() + auth = await response.json() + if "accessToken" in auth: + return auth["accessToken"] + + @classmethod async def get_access_token(cls, cookies: dict = None, proxies: dict = None) -> str: if not cls._access_token: cookies = cookies if cookies else get_cookies("chat.openai.com") - async with StreamSession(proxies=proxies, cookies=cookies, impersonate="chrome107") as session: - async with session.get(f"{cls.url}/api/auth/session") as response: - response.raise_for_status() - auth = await response.json() - if "accessToken" in auth: - cls._access_token = auth["accessToken"] - cls._access_token = cls.fetch_access_token() - if not cls._access_token: - raise RuntimeError("Missing access token") + if cookies: + cls._access_token = await cls.fetch_access_token(cookies, proxies) + if not cls._access_token: + cls._access_token = cls.browse_access_token() + if not cls._access_token: + raise RuntimeError("Read access token failed") return cls._access_token @classmethod diff --git a/g4f/Provider/Raycast.py b/g4f/Provider/needs_auth/Raycast.py index 7ddc8acd..619b217b 100644 --- a/g4f/Provider/Raycast.py +++ b/g4f/Provider/needs_auth/Raycast.py @@ -4,8 +4,8 @@ import json import requests -from ..typing import Any, CreateResult -from .base_provider import BaseProvider +from ...typing import Any, CreateResult +from ..base_provider import BaseProvider class Raycast(BaseProvider): diff --git a/g4f/Provider/Theb.py b/g4f/Provider/needs_auth/Theb.py index 72fce3ac..c35ea592 100644 --- a/g4f/Provider/Theb.py +++ b/g4f/Provider/needs_auth/Theb.py @@ -5,8 +5,8 @@ import random import requests -from ..typing import Any, CreateResult -from .base_provider import BaseProvider +from ...typing import Any, CreateResult +from ..base_provider import BaseProvider class Theb(BaseProvider): diff --git a/g4f/Provider/needs_auth/__init__.py b/g4f/Provider/needs_auth/__init__.py new file mode 100644 index 00000000..815194c4 --- /dev/null +++ b/g4f/Provider/needs_auth/__init__.py @@ -0,0 +1,6 @@ +from .Bard import Bard +from .Raycast import Raycast +from .Theb import Theb +from .HuggingChat import HuggingChat +from .OpenaiChat import OpenaiChat +from .OpenAssistant import OpenAssistant
\ No newline at end of file |