diff options
Diffstat (limited to '')
| -rw-r--r-- | g4f/Provider/You.py | 155 |
1 files changed, 105 insertions, 50 deletions
diff --git a/g4f/Provider/You.py b/g4f/Provider/You.py index 17e6269a..e1ae7f9e 100644 --- a/g4f/Provider/You.py +++ b/g4f/Provider/You.py @@ -3,67 +3,114 @@ from __future__ import annotations import json import base64 import uuid +from aiohttp import ClientSession, FormData -from ..requests import StreamSession -from ..typing import AsyncGenerator, Messages -from .base_provider import AsyncGeneratorProvider, format_prompt - +from ..typing import AsyncGenerator, Messages, ImageType, Cookies +from .base_provider import AsyncGeneratorProvider +from .helper import get_connector, format_prompt +from ..image import to_bytes +from ..defaults import DEFAULT_HEADERS class You(AsyncGeneratorProvider): url = "https://you.com" working = True supports_gpt_35_turbo = True supports_gpt_4 = True - _session_used = 0 - _session_token = None + _cookies = None + _cookies_used = 0 @classmethod async def create_async_generator( cls, model: str, messages: Messages, + image: ImageType = None, + image_name: str = None, proxy: str = None, - timeout: int = 120, + chat_mode: str = "default", **kwargs, ) -> AsyncGenerator: - async with StreamSession(proxies={"https": proxy}, impersonate="chrome107", timeout=timeout) as session: + async with ClientSession( + connector=get_connector(kwargs.get("connector"), proxy), + headers=DEFAULT_HEADERS + ) as client: + if image: + chat_mode = "agent" + elif model == "gpt-4": + chat_mode = model + cookies = await cls.get_cookies(client) if chat_mode != "default" else None + upload = json.dumps([await cls.upload_file(client, cookies, to_bytes(image), image_name)]) if image else "" + #questions = [message["content"] for message in messages if message["role"] == "user"] + # chat = [ + # {"question": questions[idx-1], "answer": message["content"]} + # for idx, message in enumerate(messages) + # if message["role"] == "assistant" + # and idx < len(questions) + # ] headers = { "Accept": "text/event-stream", "Referer": f"{cls.url}/search?fromSearchBar=true&tbm=youchat", } data = { + "userFiles": upload, + "selectedChatMode": chat_mode, "q": format_prompt(messages), "domain": "youchat", - "chat": "", "selectedChatMode": "gpt-4" if model == "gpt-4" else "default" + #"chat": json.dumps(chat), } - async with session.get( + async with client.post( f"{cls.url}/api/streamingSearch", - params=data, + data=data, headers=headers, - cookies=cls.get_cookies(await cls.get_session_token(proxy, timeout)) if model == "gpt-4" else None + cookies=cookies ) as response: response.raise_for_status() - start = b'data: {"youChatToken": ' - async for line in response.iter_lines(): - if line.startswith(start): - yield json.loads(line[len(start):-1]) + async for line in response.content: + if line.startswith(b'event: '): + event = line[7:-1] + elif line.startswith(b'data: '): + if event == b"youChatUpdate" or event == b"youChatToken": + data = json.loads(line[6:-1]) + if event == b"youChatToken" and "youChatToken" in data: + yield data["youChatToken"] + elif event == b"youChatUpdate" and "t" in data: + yield data["t"] @classmethod - async def get_session_token(cls, proxy: str, timeout: int): - if not cls._session_token or cls._session_used >= 5: - cls._session_token = await cls.create_session_token(proxy, timeout) - cls._session_used += 1 - return cls._session_token + async def upload_file(cls, client: ClientSession, cookies: Cookies, file: bytes, filename: str = None) -> dict: + async with client.get( + f"{cls.url}/api/get_nonce", + cookies=cookies, + ) as response: + response.raise_for_status() + upload_nonce = await response.text() + data = FormData() + data.add_field('file', file, filename=filename) + async with client.post( + f"{cls.url}/api/upload", + data=data, + headers={ + "X-Upload-Nonce": upload_nonce, + }, + cookies=cookies + ) as response: + if not response.ok: + raise RuntimeError(f"Response: {await response.text()}") + result = await response.json() + result["user_filename"] = filename + result["size"] = len(file) + return result - def get_cookies(access_token: str, session_jwt: str = "0"): - return { - 'stytch_session_jwt': session_jwt, - 'ydc_stytch_session': access_token, - 'ydc_stytch_session_jwt': session_jwt - } + @classmethod + async def get_cookies(cls, client: ClientSession) -> Cookies: + if not cls._cookies or cls._cookies_used >= 5: + cls._cookies = await cls.create_cookies(client) + cls._cookies_used = 0 + cls._cookies_used += 1 + return cls._cookies @classmethod - def get_jwt(cls): + def get_sdk(cls) -> str: return base64.standard_b64encode(json.dumps({ "event_id":f"event-id-{str(uuid.uuid4())}", "app_session_id":f"app-session-id-{str(uuid.uuid4())}", @@ -75,26 +122,34 @@ class You(AsyncGeneratorProvider): "sdk":{"identifier":"Stytch.js Javascript SDK","version":"3.3.0" }}).encode()).decode() + def get_auth() -> str: + auth_uuid = "507a52ad-7e69-496b-aee0-1c9863c7c8" + auth_token = f"public-token-live-{auth_uuid}bb:public-token-live-{auth_uuid}19" + auth = base64.standard_b64encode(auth_token.encode()).decode() + return f"Basic {auth}", + @classmethod - async def create_session_token(cls, proxy: str, timeout: int): - async with StreamSession(proxies={"https": proxy}, impersonate="chrome110", timeout=timeout) as session: - user_uuid = str(uuid.uuid4()) - auth_uuid = "507a52ad-7e69-496b-aee0-1c9863c7c8" - auth_token = f"public-token-live-{auth_uuid}bb:public-token-live-{auth_uuid}19" - auth = base64.standard_b64encode(auth_token.encode()).decode() - async with session.post( - "https://web.stytch.com/sdk/v1/passwords", - headers={ - "Authorization": f"Basic {auth}", - "X-SDK-Client": cls.get_jwt(), - "X-SDK-Parent-Host": "https://you.com" - }, - json={ - "email": f"{user_uuid}@gmail.com", - "password": f"{user_uuid}#{user_uuid}", - "session_duration_minutes": 129600 - } - ) as response: - if not response.ok: - raise RuntimeError(f"Response: {await response.text()}") - return (await response.json())["data"]["session_token"]
\ No newline at end of file + async def create_cookies(cls, client: ClientSession) -> Cookies: + user_uuid = str(uuid.uuid4()) + async with client.post( + "https://web.stytch.com/sdk/v1/passwords", + headers={ + "Authorization": cls.get_auth(), + "X-SDK-Client": cls.get_sdk(), + "X-SDK-Parent-Host": cls.url + }, + json={ + "email": f"{user_uuid}@gmail.com", + "password": f"{user_uuid}#{user_uuid}", + "session_duration_minutes": 129600 + } + ) as response: + if not response.ok: + raise RuntimeError(f"Response: {await response.text()}") + session = (await response.json())["data"] + return { + "stytch_session": session["session_token"], + 'stytch_session_jwt': session["session_jwt"], + 'ydc_stytch_session': session["session_token"], + 'ydc_stytch_session_jwt': session["session_jwt"], + }
\ No newline at end of file |