From 0b52fa578488e4e90bc03a26691d210edb3b5f1e Mon Sep 17 00:00:00 2001
From: Vadim Boev <33985574+VadimBoev@users.noreply.github.com>
Date: Thu, 5 Oct 2023 00:30:46 +0300
Subject: [PATCH] upd 0.1.1

---
 g4f/Provider/AItianhu.py       |  66 ++++++
 g4f/Provider/AItianhuSpace.py  |  81 +++++++
 g4f/Provider/Acytoo.py         |  51 +++++
 g4f/Provider/Aibn.py           |  51 +++++
 g4f/Provider/Aichat.py         |  54 +++++
 g4f/Provider/Ails.py           | 106 +++++++++
 g4f/Provider/Aivvm.py          |  62 ++++++
 g4f/Provider/Bing.py           | 299 ++++++++++++++++++++++++++
 g4f/Provider/ChatBase.py       |  62 ++++++
 g4f/Provider/ChatForAi.py      |  62 ++++++
 g4f/Provider/ChatgptAi.py      |  75 +++++++
 g4f/Provider/ChatgptDuo.py     |  51 +++++
 g4f/Provider/ChatgptLogin.py   |  74 +++++++
 g4f/Provider/DeepAi.py         |  66 ++++++
 g4f/Provider/FreeGpt.py        |  54 +++++
 g4f/Provider/GptGo.py          |  78 +++++++
 g4f/Provider/H2o.py            | 109 ++++++++++
 g4f/Provider/Liaobots.py       |  89 ++++++++
 g4f/Provider/Myshell.py        | 172 +++++++++++++++
 g4f/Provider/Phind.py          |  76 +++++++
 g4f/Provider/Vercel.py         | 377 +++++++++++++++++++++++++++++++++
 g4f/Provider/Vitalentum.py     |  68 ++++++
 g4f/Provider/Ylokh.py          |  74 +++++++
 g4f/Provider/You.py            |  40 ++++
 g4f/Provider/Yqcloud.py        |  48 +++++
 g4f/Provider/base_provider.py  | 136 ++++++++++++
 g4f/Provider/helper.py         |  70 ++++++
 g4f/Provider/retry_provider.py |  81 +++++++
 28 files changed, 2632 insertions(+)
 create mode 100644 g4f/Provider/AItianhu.py
 create mode 100644 g4f/Provider/AItianhuSpace.py
 create mode 100644 g4f/Provider/Acytoo.py
 create mode 100644 g4f/Provider/Aibn.py
 create mode 100644 g4f/Provider/Aichat.py
 create mode 100644 g4f/Provider/Ails.py
 create mode 100644 g4f/Provider/Aivvm.py
 create mode 100644 g4f/Provider/Bing.py
 create mode 100644 g4f/Provider/ChatBase.py
 create mode 100644 g4f/Provider/ChatForAi.py
 create mode 100644 g4f/Provider/ChatgptAi.py
 create mode 100644 g4f/Provider/ChatgptDuo.py
 create mode 100644 g4f/Provider/ChatgptLogin.py
 create mode 100644 g4f/Provider/DeepAi.py
 create mode 100644 g4f/Provider/FreeGpt.py
 create mode 100644 g4f/Provider/GptGo.py
 create mode 100644 g4f/Provider/H2o.py
 create mode 100644 g4f/Provider/Liaobots.py
 create mode 100644 g4f/Provider/Myshell.py
 create mode 100644 g4f/Provider/Phind.py
 create mode 100644 g4f/Provider/Vercel.py
 create mode 100644 g4f/Provider/Vitalentum.py
 create mode 100644 g4f/Provider/Ylokh.py
 create mode 100644 g4f/Provider/You.py
 create mode 100644 g4f/Provider/Yqcloud.py
 create mode 100644 g4f/Provider/base_provider.py
 create mode 100644 g4f/Provider/helper.py
 create mode 100644 g4f/Provider/retry_provider.py

diff --git a/g4f/Provider/AItianhu.py b/g4f/Provider/AItianhu.py
new file mode 100644
index 00000000..1d8653b7
--- /dev/null
+++ b/g4f/Provider/AItianhu.py
@@ -0,0 +1,66 @@
+from __future__ import annotations
+
+import json
+
+from ..typing import AsyncGenerator
+from ..requests import StreamSession
+from .base_provider import AsyncGeneratorProvider, format_prompt
+
+
+class AItianhu(AsyncGeneratorProvider):
+    url = "https://www.aitianhu.com"
+    working = True
+    supports_gpt_35_turbo = True
+
+    @classmethod
+    async def create_async_generator(
+        cls,
+        model: str,
+        messages: list[dict[str, str]],
+        proxy: str = None,
+        **kwargs
+    ) -> AsyncGenerator:
+        data = {
+            "prompt": format_prompt(messages),
+            "options": {},
+            "systemMessage": "You are ChatGPT, a large language model trained by OpenAI. Follow the user's instructions carefully.",
+            "temperature": 0.8,
+            "top_p": 1,
+            **kwargs
+        }
+        headers = {
+            "Authority": cls.url,
+            "Accept": "application/json, text/plain, */*",
+            "Origin": cls.url,
+            "Referer": f"{cls.url}/"
+        }
+        async with StreamSession(headers=headers, proxies={"https": proxy}, impersonate="chrome107", verify=False) as session:
+            async with session.post(f"{cls.url}/api/chat-process", json=data) as response:
+                response.raise_for_status()
+                async for line in response.iter_lines():
+                    if line == b"<script>":
+                        raise RuntimeError("Solve Challenge")
+                    if b"platform's risk control" in line:
+                        raise RuntimeError("Platform's Risk Control")
+                    line = json.loads(line)
+                    if "detail" in line:
+                        content = line["detail"]["choices"][0]["delta"].get("content")
+                        if content:
+                            yield content
+                    else:
+                        raise RuntimeError(f"Response: {line}")
+
+
+    @classmethod
+    @property
+    def params(cls):
+        params = [
+            ("model", "str"),
+            ("messages", "list[dict[str, str]]"),
+            ("stream", "bool"),
+            ("proxy", "str"),
+            ("temperature", "float"),
+            ("top_p", "int"),
+        ]
+        param = ", ".join([": ".join(p) for p in params])
+        return f"g4f.provider.{cls.__name__} supports: ({param})"
diff --git a/g4f/Provider/AItianhuSpace.py b/g4f/Provider/AItianhuSpace.py
new file mode 100644
index 00000000..27f2b1fa
--- /dev/null
+++ b/g4f/Provider/AItianhuSpace.py
@@ -0,0 +1,81 @@
+from __future__ import annotations
+
+import random, json
+
+from ..typing import AsyncGenerator
+from ..requests import StreamSession
+from .base_provider import AsyncGeneratorProvider, format_prompt
+
+domains = {
+    "gpt-3.5-turbo": ".aitianhu.space",
+    "gpt-4": ".aitianhu.website",
+}
+
+class AItianhuSpace(AsyncGeneratorProvider):
+    url = "https://chat3.aiyunos.top/"
+    working = True
+    supports_gpt_35_turbo = True
+
+    @classmethod
+    async def create_async_generator(
+        cls,
+        model: str,
+        messages: list[dict[str, str]],
+        stream: bool = True,
+        **kwargs
+    ) -> AsyncGenerator:
+        if not model:
+            model = "gpt-3.5-turbo"
+        elif not model in domains:
+            raise ValueError(f"Model are not supported: {model}")
+        
+        chars = 'abcdefghijklmnopqrstuvwxyz0123456789'
+        rand = ''.join(random.choice(chars) for _ in range(6))
+        domain = domains[model]
+        url = f'https://{rand}{domain}'
+
+        async with StreamSession(impersonate="chrome110", verify=False) as session:
+            data = {
+                "prompt": format_prompt(messages),
+                "options": {},
+                "systemMessage": "You are ChatGPT, a large language model trained by OpenAI. Follow the user's instructions carefully.",
+                "temperature": 0.8,
+                "top_p": 1,
+                **kwargs
+            }
+            headers = {
+                "Authority": url,
+                "Accept": "application/json, text/plain, */*",
+                "Origin": url,
+                "Referer": f"{url}/"
+            }
+            async with session.post(f"{url}/api/chat-process", json=data, headers=headers) as response:
+                response.raise_for_status()
+                async for line in response.iter_lines():
+                    if line == b"<script>":
+                        raise RuntimeError("Solve Challenge")
+                    if b"platform's risk control" in line:
+                        raise RuntimeError("Platform's Risk Control")
+                    line = json.loads(line)
+                    if "detail" in line:
+                        content = line["detail"]["choices"][0]["delta"].get("content")
+                        if content:
+                            yield content
+                    elif "message" in line and "AI-4接口非常昂贵" in line["message"]:
+                        raise RuntimeError("Rate limit for GPT 4 reached")
+                    else:
+                        raise RuntimeError(f"Response: {line}")
+        
+
+    @classmethod
+    @property
+    def params(cls):
+        params = [
+            ("model", "str"),
+            ("messages", "list[dict[str, str]]"),
+            ("stream", "bool"),
+            ("temperature", "float"),
+            ("top_p", "int"),
+        ]
+        param = ", ".join([": ".join(p) for p in params])
+        return f"g4f.provider.{cls.__name__} supports: ({param})"
diff --git a/g4f/Provider/Acytoo.py b/g4f/Provider/Acytoo.py
new file mode 100644
index 00000000..d36ca6da
--- /dev/null
+++ b/g4f/Provider/Acytoo.py
@@ -0,0 +1,51 @@
+from __future__ import annotations
+
+from aiohttp import ClientSession
+
+from ..typing import AsyncGenerator
+from .base_provider import AsyncGeneratorProvider
+
+
+class Acytoo(AsyncGeneratorProvider):
+    url                   = 'https://chat.acytoo.com'
+    working               = True
+    supports_gpt_35_turbo = True
+
+    @classmethod
+    async def create_async_generator(
+        cls,
+        model: str,
+        messages: list[dict[str, str]],
+        proxy: str = None,
+        **kwargs
+    ) -> AsyncGenerator:
+
+        async with ClientSession(
+            headers=_create_header()
+        ) as session:
+            async with session.post(
+                cls.url + '/api/completions',
+                proxy=proxy,
+                json=_create_payload(messages, **kwargs)
+            ) as response:
+                response.raise_for_status()
+                async for stream in response.content.iter_any():
+                    if stream:
+                        yield stream.decode()
+
+
+def _create_header():
+    return {
+        'accept': '*/*',
+        'content-type': 'application/json',
+    }
+
+
+def _create_payload(messages: list[dict[str, str]], temperature: float = 0.5, **kwargs):
+    return {
+        'key'         : '',
+        'model'       : 'gpt-3.5-turbo',
+        'messages'    : messages,
+        'temperature' : temperature,
+        'password'    : ''
+    }
\ No newline at end of file
diff --git a/g4f/Provider/Aibn.py b/g4f/Provider/Aibn.py
new file mode 100644
index 00000000..df56189b
--- /dev/null
+++ b/g4f/Provider/Aibn.py
@@ -0,0 +1,51 @@
+from __future__ import annotations
+
+import time
+import hashlib
+
+from ..typing import AsyncGenerator
+from ..requests import StreamSession
+from .base_provider import AsyncGeneratorProvider
+
+
+class Aibn(AsyncGeneratorProvider):
+    url                   = "https://aibn.cc"
+    supports_gpt_35_turbo = True
+    working               = True
+
+    @classmethod
+    async def create_async_generator(
+        cls,
+        model: str,
+        messages: list[dict[str, str]],
+        **kwargs
+    ) -> AsyncGenerator:
+        async with StreamSession(impersonate="chrome107") as session:
+            timestamp = int(time.time())
+            data = {
+                "messages": messages,
+                "pass": None,
+                "sign": generate_signature(timestamp, messages[-1]["content"]),
+                "time": timestamp
+            }
+            async with session.post(f"{cls.url}/api/generate", json=data) as response:
+                response.raise_for_status()
+                async for chunk in response.iter_content():
+                    yield chunk.decode()
+
+    @classmethod
+    @property
+    def params(cls):
+        params = [
+            ("model", "str"),
+            ("messages", "list[dict[str, str]]"),
+            ("stream", "bool"),
+            ("temperature", "float"),
+        ]
+        param = ", ".join([": ".join(p) for p in params])
+        return f"g4f.provider.{cls.__name__} supports: ({param})"
+    
+
+def generate_signature(timestamp: int, message: str, secret: str = "undefined"):
+    data = f"{timestamp}:{message}:{secret}"
+    return hashlib.sha256(data.encode()).hexdigest()
\ No newline at end of file
diff --git a/g4f/Provider/Aichat.py b/g4f/Provider/Aichat.py
new file mode 100644
index 00000000..8edd17e2
--- /dev/null
+++ b/g4f/Provider/Aichat.py
@@ -0,0 +1,54 @@
+from __future__ import annotations
+
+from aiohttp import ClientSession
+
+from .base_provider import AsyncProvider, format_prompt
+
+
+class Aichat(AsyncProvider):
+    url                   = "https://chat-gpt.org/chat"
+    working               = True
+    supports_gpt_35_turbo = True
+
+    @staticmethod
+    async def create_async(
+        model: str,
+        messages: list[dict[str, str]],
+        proxy: str = None,
+        **kwargs
+    ) -> str:
+        headers = {
+            "authority": "chat-gpt.org",
+            "accept": "*/*",
+            "cache-control": "no-cache",
+            "content-type": "application/json",
+            "origin": "https://chat-gpt.org",
+            "pragma": "no-cache",
+            "referer": "https://chat-gpt.org/chat",
+            "sec-ch-ua-mobile": "?0",
+            "sec-ch-ua-platform": '"macOS"',
+            "sec-fetch-dest": "empty",
+            "sec-fetch-mode": "cors",
+            "sec-fetch-site": "same-origin",
+            "user-agent": "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/113.0.0.0 Safari/537.36",
+        }
+        async with ClientSession(
+            headers=headers
+        ) as session:
+            json_data = {
+                "message": format_prompt(messages),
+                "temperature": kwargs.get('temperature', 0.5),
+                "presence_penalty": 0,
+                "top_p": kwargs.get('top_p', 1),
+                "frequency_penalty": 0,
+            }
+            async with session.post(
+                "https://chat-gpt.org/api/text",
+                proxy=proxy,
+                json=json_data
+            ) as response:
+                response.raise_for_status()
+                result = await response.json()
+                if not result['response']:
+                    raise Exception(f"Error Response: {result}")
+                return result["message"]
diff --git a/g4f/Provider/Ails.py b/g4f/Provider/Ails.py
new file mode 100644
index 00000000..d533ae24
--- /dev/null
+++ b/g4f/Provider/Ails.py
@@ -0,0 +1,106 @@
+from __future__ import annotations
+
+import hashlib
+import time
+import uuid
+import json
+from datetime import datetime
+from aiohttp import ClientSession
+
+from ..typing import SHA256, AsyncGenerator
+from .base_provider import AsyncGeneratorProvider
+
+
+class Ails(AsyncGeneratorProvider):
+    url: str              = "https://ai.ls"
+    working               = True
+    supports_gpt_35_turbo = True
+
+    @staticmethod
+    async def create_async_generator(
+        model: str,
+        messages: list[dict[str, str]],
+        stream: bool,
+        proxy: str = None,
+        **kwargs
+    ) -> AsyncGenerator:
+        headers = {
+            "authority": "api.caipacity.com",
+            "accept": "*/*",
+            "accept-language": "en,fr-FR;q=0.9,fr;q=0.8,es-ES;q=0.7,es;q=0.6,en-US;q=0.5,am;q=0.4,de;q=0.3",
+            "authorization": "Bearer free",
+            "client-id": str(uuid.uuid4()),
+            "client-v": "0.1.278",
+            "content-type": "application/json",
+            "origin": "https://ai.ls",
+            "referer": "https://ai.ls/",
+            "sec-ch-ua": '"Not.A/Brand";v="8", "Chromium";v="114", "Google Chrome";v="114"',
+            "sec-ch-ua-mobile": "?0",
+            "sec-ch-ua-platform": '"Windows"',
+            "sec-fetch-dest": "empty",
+            "sec-fetch-mode": "cors",
+            "sec-fetch-site": "cross-site",
+            "user-agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/114.0.0.0 Safari/537.36",
+            "from-url": "https://ai.ls/?chat=1"
+        }
+        async with ClientSession(
+            headers=headers
+        ) as session:
+            timestamp = _format_timestamp(int(time.time() * 1000))
+            json_data = {
+                "model": "gpt-3.5-turbo",
+                "temperature": kwargs.get("temperature", 0.6),
+                "stream": True,
+                "messages": messages,
+                "d": datetime.now().strftime("%Y-%m-%d"),
+                "t": timestamp,
+                "s": _hash({"t": timestamp, "m": messages[-1]["content"]}),
+            }
+            async with session.post(
+                "https://api.caipacity.com/v1/chat/completions",
+                proxy=proxy,
+                json=json_data
+            ) as response:
+                response.raise_for_status()
+                start = "data: "
+                async for line in response.content:
+                    line = line.decode('utf-8')
+                    if line.startswith(start) and line != "data: [DONE]":
+                        line = line[len(start):-1]
+                        line = json.loads(line)
+                        token = line["choices"][0]["delta"].get("content")
+                        if token:
+                            if "ai.ls" in token or "ai.ci" in token:
+                                raise Exception("Response Error: " + token)
+                            yield token
+
+
+    @classmethod
+    @property
+    def params(cls):
+        params = [
+            ("model", "str"),
+            ("messages", "list[dict[str, str]]"),
+            ("stream", "bool"),
+            ("temperature", "float"),
+        ]
+        param = ", ".join([": ".join(p) for p in params])
+        return f"g4f.provider.{cls.__name__} supports: ({param})"
+
+
+def _hash(json_data: dict[str, str]) -> SHA256:
+    base_string: str = "%s:%s:%s:%s" % (
+        json_data["t"],
+        json_data["m"],
+        "WI,2rU#_r:r~aF4aJ36[.Z(/8Rv93Rf",
+        len(json_data["m"]),
+    )
+
+    return SHA256(hashlib.sha256(base_string.encode()).hexdigest())
+
+
+def _format_timestamp(timestamp: int) -> str:
+    e = timestamp
+    n = e % 10
+    r = n + 1 if n % 2 == 0 else n
+    return str(e - n + r)
\ No newline at end of file
diff --git a/g4f/Provider/Aivvm.py b/g4f/Provider/Aivvm.py
new file mode 100644
index 00000000..c4ec677c
--- /dev/null
+++ b/g4f/Provider/Aivvm.py
@@ -0,0 +1,62 @@
+from __future__ import annotations
+
+from ..requests import StreamSession
+from .base_provider import AsyncGeneratorProvider
+from ..typing import AsyncGenerator
+
+# to recreate this easily, send a post request to https://chat.aivvm.com/api/models
+models = {
+    'gpt-3.5-turbo': {'id': 'gpt-3.5-turbo', 'name': 'GPT-3.5'},
+    'gpt-3.5-turbo-0613': {'id': 'gpt-3.5-turbo-0613', 'name': 'GPT-3.5-0613'},
+    'gpt-3.5-turbo-16k': {'id': 'gpt-3.5-turbo-16k', 'name': 'GPT-3.5-16K'},
+    'gpt-3.5-turbo-16k-0613': {'id': 'gpt-3.5-turbo-16k-0613', 'name': 'GPT-3.5-16K-0613'},
+    'gpt-4': {'id': 'gpt-4', 'name': 'GPT-4'},
+    'gpt-4-0613': {'id': 'gpt-4-0613', 'name': 'GPT-4-0613'},
+    'gpt-4-32k': {'id': 'gpt-4-32k', 'name': 'GPT-4-32K'},
+    'gpt-4-32k-0613': {'id': 'gpt-4-32k-0613', 'name': 'GPT-4-32K-0613'},
+}
+
+class Aivvm(AsyncGeneratorProvider):
+    url                   = 'https://chat.aivvm.com'
+    supports_stream       = True
+    working               = True
+    supports_gpt_35_turbo = True
+    supports_gpt_4        = True
+
+    @classmethod
+    async def create_async_generator(
+        cls,
+        model: str,
+        messages: list[dict[str, str]],
+        stream: bool,
+        **kwargs
+    ) -> AsyncGenerator:
+        if not model:
+            model = "gpt-3.5-turbo"
+        elif model not in models:
+            raise ValueError(f"Model is not supported: {model}")
+
+        json_data = {
+            "model"       : models[model],
+            "messages"    : messages,
+            "key"         : "",
+            "prompt"      : kwargs.get("system_message", "You are ChatGPT, a large language model trained by OpenAI. Follow the user's instructions carefully. Respond using markdown."),
+            "temperature" : kwargs.get("temperature", 0.7)
+        }
+        async with StreamSession(impersonate="chrome107") as session:
+            async with session.post(f"{cls.url}/api/chat", json=json_data) as response:
+                response.raise_for_status()
+                async for chunk in response.iter_content():
+                    yield chunk.decode()
+
+    @classmethod
+    @property
+    def params(cls):
+        params = [
+            ('model', 'str'),
+            ('messages', 'list[dict[str, str]]'),
+            ('stream', 'bool'),
+            ('temperature', 'float'),
+        ]
+        param = ', '.join([': '.join(p) for p in params])
+        return f'g4f.provider.{cls.__name__} supports: ({param})'
\ No newline at end of file
diff --git a/g4f/Provider/Bing.py b/g4f/Provider/Bing.py
new file mode 100644
index 00000000..940b3a0b
--- /dev/null
+++ b/g4f/Provider/Bing.py
@@ -0,0 +1,299 @@
+from __future__ import annotations
+
+import random
+import json
+import os
+import urllib.parse
+from aiohttp        import ClientSession, ClientTimeout
+from ..typing       import AsyncGenerator
+from .base_provider import AsyncGeneratorProvider
+
+class Tones():
+    creative = "Creative"
+    balanced = "Balanced"
+    precise = "Precise"
+
+class Bing(AsyncGeneratorProvider):
+    url             = "https://bing.com/chat"
+    working         = True
+    supports_gpt_4  = True
+        
+    @staticmethod
+    def create_async_generator(
+        model: str,
+        messages: list[dict[str, str]],
+        cookies: dict = None,
+        tone: str = Tones.creative,
+        **kwargs
+    ) -> AsyncGenerator:
+        
+        if len(messages) < 2:
+            prompt = messages[0]["content"]
+            context = None
+        else:
+            prompt = messages[-1]["content"]
+            context = create_context(messages[:-1])
+        
+        if not cookies or "SRCHD" not in cookies:
+            cookies = {
+                'SRCHD'         : 'AF=NOFORM',
+                'PPLState'      : '1',
+                'KievRPSSecAuth': '',
+                'SUID'          : '',
+                'SRCHUSR'       : '',
+                'SRCHHPGUSR'    : '',
+            }
+        return stream_generate(prompt, tone, context, cookies)
+
+def create_context(messages: list[dict[str, str]]):
+    context = "".join(f"[{message['role']}](#message)\n{message['content']}\n\n" for message in messages)
+
+    return context
+
+class Conversation():
+    def __init__(self, conversationId: str, clientId: str, conversationSignature: str) -> None:
+        self.conversationId = conversationId
+        self.clientId = clientId
+        self.conversationSignature = conversationSignature
+
+async def create_conversation(session: ClientSession) -> Conversation:
+    url = 'https://www.bing.com/turing/conversation/create'
+    async with await session.get(url) as response:
+        response = await response.json()
+        conversationId = response.get('conversationId')
+        clientId = response.get('clientId')
+        conversationSignature = response.get('conversationSignature')
+
+        if not conversationId or not clientId or not conversationSignature:
+            raise Exception('Failed to create conversation.')
+        
+        return Conversation(conversationId, clientId, conversationSignature)
+
+async def retry_conversation(session: ClientSession) -> Conversation:
+    for _ in range(5):
+        try:
+            return await create_conversation(session)
+        except:
+            session.cookie_jar.clear()
+    return await create_conversation(session)
+
+async def list_conversations(session: ClientSession) -> list:
+    url = "https://www.bing.com/turing/conversation/chats"
+    async with session.get(url) as response:
+        response = await response.json()
+        return response["chats"]
+        
+async def delete_conversation(session: ClientSession, conversation: Conversation) -> list:
+    url = "https://sydney.bing.com/sydney/DeleteSingleConversation"
+    json = {
+        "conversationId": conversation.conversationId,
+        "conversationSignature": conversation.conversationSignature,
+        "participant": {"id": conversation.clientId},
+        "source": "cib",
+        "optionsSets": ["autosave"]
+    }
+    async with session.post(url, json=json) as response:
+        response = await response.json()
+        return response["result"]["value"] == "Success"
+
+class Defaults:
+    delimiter = "\x1e"
+    ip_address = f"13.{random.randint(104, 107)}.{random.randint(0, 255)}.{random.randint(0, 255)}"
+
+    allowedMessageTypes = [
+        "Chat",
+        "Disengaged",
+        "AdsQuery",
+        "SemanticSerp",
+        "GenerateContentQuery",
+        "SearchQuery",
+        "ActionRequest",
+        "Context",
+        "Progress",
+        "AdsQuery",
+        "SemanticSerp",
+    ]
+
+    sliceIds = [
+        "winmuid3tf",
+        "osbsdusgreccf",
+        "ttstmout",
+        "crchatrev",
+        "winlongmsgtf",
+        "ctrlworkpay",
+        "norespwtf",
+        "tempcacheread",
+        "temptacache",
+        "505scss0",
+        "508jbcars0",
+        "515enbotdets0",
+        "5082tsports",
+        "515vaoprvs",
+        "424dagslnv1s0",
+        "kcimgattcf",
+        "427startpms0",
+    ]
+
+    location = {
+        "locale": "en-US",
+        "market": "en-US",
+        "region": "US",
+        "locationHints": [
+            {
+                "country": "United States",
+                "state": "California",
+                "city": "Los Angeles",
+                "timezoneoffset": 8,
+                "countryConfidence": 8,
+                "Center": {"Latitude": 34.0536909, "Longitude": -118.242766},
+                "RegionType": 2,
+                "SourceType": 1,
+            }
+        ],
+    }
+
+    headers = {
+        'accept': '*/*',
+        'accept-language': 'en-US,en;q=0.9',
+        'cache-control': 'max-age=0',
+        'sec-ch-ua': '"Chromium";v="110", "Not A(Brand";v="24", "Microsoft Edge";v="110"',
+        'sec-ch-ua-arch': '"x86"',
+        'sec-ch-ua-bitness': '"64"',
+        'sec-ch-ua-full-version': '"110.0.1587.69"',
+        'sec-ch-ua-full-version-list': '"Chromium";v="110.0.5481.192", "Not A(Brand";v="24.0.0.0", "Microsoft Edge";v="110.0.1587.69"',
+        'sec-ch-ua-mobile': '?0',
+        'sec-ch-ua-model': '""',
+        'sec-ch-ua-platform': '"Windows"',
+        'sec-ch-ua-platform-version': '"15.0.0"',
+        'sec-fetch-dest': 'document',
+        'sec-fetch-mode': 'navigate',
+        'sec-fetch-site': 'none',
+        'sec-fetch-user': '?1',
+        'upgrade-insecure-requests': '1',
+        'user-agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/110.0.0.0 Safari/537.36 Edg/110.0.1587.69',
+        'x-edge-shopping-flag': '1',
+        'x-forwarded-for': ip_address,
+    }
+
+    optionsSets = [
+        'saharasugg',
+        'enablenewsfc',
+        'clgalileo',
+        'gencontentv3',
+        "nlu_direct_response_filter",
+        "deepleo",
+        "disable_emoji_spoken_text",
+        "responsible_ai_policy_235",
+        "enablemm",
+        "h3precise"
+        "dtappid",
+        "cricinfo",
+        "cricinfov2",
+        "dv3sugg",
+        "nojbfedge"
+    ]
+
+def format_message(msg: dict) -> str:
+    return json.dumps(msg, ensure_ascii=False) + Defaults.delimiter
+
+def create_message(conversation: Conversation, prompt: str, tone: str, context: str=None) -> str:
+    struct = {
+        'arguments': [
+            {
+                'optionsSets': Defaults.optionsSets,
+                'source': 'cib',
+                'allowedMessageTypes': Defaults.allowedMessageTypes,
+                'sliceIds': Defaults.sliceIds,
+                'traceId': os.urandom(16).hex(),
+                'isStartOfSession': True,
+                'message': Defaults.location | {
+                    'author': 'user',
+                    'inputMethod': 'Keyboard',
+                    'text': prompt,
+                    'messageType': 'Chat'
+                },
+                'tone': tone,
+                'conversationSignature': conversation.conversationSignature,
+                'participant': {
+                    'id': conversation.clientId
+                },
+                'conversationId': conversation.conversationId
+            }
+        ],
+        'invocationId': '0',
+        'target': 'chat',
+        'type': 4
+    }
+
+    if context:
+        struct['arguments'][0]['previousMessages'] = [{
+            "author": "user",
+            "description": context,
+            "contextType": "WebPage",
+            "messageType": "Context",
+            "messageId": "discover-web--page-ping-mriduna-----"
+        }]
+    return format_message(struct)
+
+async def stream_generate(
+        prompt: str,
+        tone: str,
+        context: str=None,
+        cookies: dict=None,
+    ):
+    async with ClientSession(
+        timeout=ClientTimeout(total=900),
+        cookies=cookies,
+        headers=Defaults.headers,
+    ) as session:
+        conversation = await retry_conversation(session)
+        try:
+            async with session.ws_connect(
+                'wss://sydney.bing.com/sydney/ChatHub',
+                autoping=False,
+            ) as wss:
+                
+                await wss.send_str(format_message({'protocol': 'json', 'version': 1}))
+                msg = await wss.receive(timeout=900)
+
+                await wss.send_str(create_message(conversation, prompt, tone, context))
+
+                response_txt = ''
+                returned_text = ''
+                final = False
+
+                while not final:
+                    msg = await wss.receive(timeout=900)
+                    objects = msg.data.split(Defaults.delimiter)
+                    for obj in objects:
+                        if obj is None or not obj:
+                            continue
+
+                        response = json.loads(obj)
+                        if response.get('type') == 1 and response['arguments'][0].get('messages'):
+                            message = response['arguments'][0]['messages'][0]
+                            if (message['contentOrigin'] != 'Apology'):
+                                if 'adaptiveCards' in message:
+                                    card = message['adaptiveCards'][0]['body'][0]
+                                    if "text" in card:
+                                        response_txt = card.get('text')
+                                    if message.get('messageType'):
+                                        inline_txt = card['inlines'][0].get('text')
+                                        response_txt += inline_txt + '\n'
+                                elif message.get('contentType') == "IMAGE":
+                                    query = urllib.parse.quote(message.get('text'))
+                                    url = f"\nhttps://www.bing.com/images/create?q={query}"
+                                    response_txt += url
+                                    final = True
+                            if response_txt.startswith(returned_text):
+                                new = response_txt[len(returned_text):]
+                                if new != "\n":
+                                    yield new
+                                    returned_text = response_txt
+                        elif response.get('type') == 2:
+                            result = response['item']['result']
+                            if result.get('error'):
+                                raise Exception(f"{result['value']}: {result['message']}")
+                            return
+        finally:
+            await delete_conversation(session, conversation)
\ No newline at end of file
diff --git a/g4f/Provider/ChatBase.py b/g4f/Provider/ChatBase.py
new file mode 100644
index 00000000..b98fe565
--- /dev/null
+++ b/g4f/Provider/ChatBase.py
@@ -0,0 +1,62 @@
+from __future__ import annotations
+
+from aiohttp import ClientSession
+
+from ..typing       import AsyncGenerator
+from .base_provider import AsyncGeneratorProvider
+
+
+class ChatBase(AsyncGeneratorProvider):
+    url                   = "https://www.chatbase.co"
+    supports_gpt_35_turbo = True
+    supports_gpt_4        = True
+    working               = True
+
+    @classmethod
+    async def create_async_generator(
+        cls,
+        model: str,
+        messages: list[dict[str, str]],
+        **kwargs
+    ) -> AsyncGenerator:
+        if model == "gpt-4":
+            chat_id = "quran---tafseer-saadi-pdf-wbgknt7zn"
+        elif model == "gpt-3.5-turbo" or not model:
+            chat_id = "chatbase--1--pdf-p680fxvnm"
+        else:
+            raise ValueError(f"Model are not supported: {model}")
+        headers = {
+            "User-Agent"         : "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/116.0.0.0 Safari/537.36",
+            "Accept"             : "*/*",
+            "Accept-language"    : "en,fr-FR;q=0.9,fr;q=0.8,es-ES;q=0.7,es;q=0.6,en-US;q=0.5,am;q=0.4,de;q=0.3",
+            "Origin"             : cls.url,
+            "Referer"            : cls.url + "/",
+            "Sec-Fetch-Dest"     : "empty",
+            "Sec-Fetch-Mode"     : "cors",
+            "Sec-Fetch-Site"     : "same-origin",
+        }
+        async with ClientSession(
+            headers=headers
+        ) as session:
+            data = {
+                "messages": messages,
+                "captchaCode": "hadsa",
+                "chatId": chat_id,
+                "conversationId": f"kcXpqEnqUie3dnJlsRi_O-{chat_id}"
+            }
+            async with session.post("https://www.chatbase.co/api/fe/chat", json=data) as response:
+                response.raise_for_status()
+                async for stream in response.content.iter_any():
+                    yield stream.decode()
+
+
+    @classmethod
+    @property
+    def params(cls):
+        params = [
+            ("model", "str"),
+            ("messages", "list[dict[str, str]]"),
+            ("stream", "bool"),
+        ]
+        param = ", ".join([": ".join(p) for p in params])
+        return f"g4f.provider.{cls.__name__} supports: ({param})"
\ No newline at end of file
diff --git a/g4f/Provider/ChatForAi.py b/g4f/Provider/ChatForAi.py
new file mode 100644
index 00000000..779799cf
--- /dev/null
+++ b/g4f/Provider/ChatForAi.py
@@ -0,0 +1,62 @@
+from __future__ import annotations
+
+import time, hashlib
+
+from ..typing import AsyncGenerator
+from ..requests import StreamSession
+from .base_provider import AsyncGeneratorProvider
+
+
+class ChatForAi(AsyncGeneratorProvider):
+    url                   = "https://chatforai.com"
+    supports_gpt_35_turbo = True
+    working               = True
+
+    @classmethod
+    async def create_async_generator(
+        cls,
+        model: str,
+        messages: list[dict[str, str]],
+        **kwargs
+    ) -> AsyncGenerator:
+        async with StreamSession(impersonate="chrome107") as session:
+            conversation_id = f"id_{int(time.time())}"
+            prompt = messages[-1]["content"]
+            timestamp = int(time.time())
+            data = {
+                "conversationId": conversation_id,
+                "conversationType": "chat_continuous",
+                "botId": "chat_continuous",
+                "globalSettings":{
+                    "baseUrl": "https://api.openai.com",
+                    "model": model if model else "gpt-3.5-turbo",
+                    "messageHistorySize": 5,
+                    "temperature": 0.7,
+                    "top_p": 1,
+                    **kwargs
+                },
+                "botSettings": {},
+                "prompt": prompt,
+                "messages": messages,
+                "sign": generate_signature(timestamp, conversation_id, prompt),
+                "timestamp": timestamp
+            }
+            async with session.post(f"{cls.url}/api/handle/provider-openai", json=data) as response:
+                response.raise_for_status()
+                async for chunk in response.iter_content():
+                    yield chunk.decode()
+
+    @classmethod
+    @property
+    def params(cls):
+        params = [
+            ("model", "str"),
+            ("messages", "list[dict[str, str]]"),
+            ("stream", "bool"),
+        ]
+        param = ", ".join([": ".join(p) for p in params])
+        return f"g4f.provider.{cls.__name__} supports: ({param})"
+    
+def generate_signature(timestamp, id, prompt):
+    data = f"{timestamp}:{id}:{prompt}:6B46K4pt"
+    return hashlib.sha256(data.encode()).hexdigest()
diff --git a/g4f/Provider/ChatgptAi.py b/g4f/Provider/ChatgptAi.py
new file mode 100644
index 00000000..e6416cc3
--- /dev/null
+++ b/g4f/Provider/ChatgptAi.py
@@ -0,0 +1,75 @@
+from __future__ import annotations
+
+import re
+import html
+import json
+from aiohttp import ClientSession
+
+from ..typing       import AsyncGenerator
+from .base_provider import AsyncGeneratorProvider
+
+
+class ChatgptAi(AsyncGeneratorProvider):
+    url: str = "https://chatgpt.ai/"
+    working = True
+    supports_gpt_35_turbo  = True
+    _system_data = None
+
+    @classmethod
+    async def create_async_generator(
+        cls,
+        model: str,
+        messages: list[dict[str, str]],
+        proxy: str = None,
+        **kwargs
+    ) -> AsyncGenerator:
+        headers = {
+            "authority"          : "chatgpt.ai",
+            "accept"             : "*/*",
+            "accept-language"    : "en,fr-FR;q=0.9,fr;q=0.8,es-ES;q=0.7,es;q=0.6,en-US;q=0.5,am;q=0.4,de;q=0.3",
+            "cache-control"      : "no-cache",
+            "origin"             : "https://chatgpt.ai",
+            "pragma"             : "no-cache",
+            "referer"            : cls.url,
+            "sec-ch-ua"          : '"Not.A/Brand";v="8", "Chromium";v="114", "Google Chrome";v="114"',
+            "sec-ch-ua-mobile"   : "?0",
+            "sec-ch-ua-platform" : '"Windows"',
+            "sec-fetch-dest"     : "empty",
+            "sec-fetch-mode"     : "cors",
+            "sec-fetch-site"     : "same-origin",
+            "user-agent"         : "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/114.0.0.0 Safari/537.36",
+        }
+        async with ClientSession(
+            headers=headers
+        ) as session:
+            if not cls._system_data:
+                async with session.get(cls.url, proxy=proxy) as response:
+                    response.raise_for_status()
+                    match = re.findall(r"data-system='([^']+)'", await response.text())
+                    if not match:
+                        raise RuntimeError("No system data")
+                    cls._system_data = json.loads(html.unescape(match[0]))
+
+            data = {
+                "botId":      cls._system_data["botId"],
+                "clientId":   "",
+                "contextId":  cls._system_data["contextId"],
+                "id":         cls._system_data["id"],
+                "messages":   messages[:-1],
+                "newMessage": messages[-1]["content"],
+                "session":    cls._system_data["sessionId"],
+                "stream":     True
+            }
+            async with session.post(
+                "https://chatgpt.ai/wp-json/mwai-ui/v1/chats/submit",
+                proxy=proxy,
+                json=data
+            ) as response:
+                response.raise_for_status()
+                start = "data: "
+                async for line in response.content:
+                    line = line.decode('utf-8')
+                    if line.startswith(start):
+                        line = json.loads(line[len(start):-1])
+                        if line["type"] == "live":
+                            yield line["data"]
\ No newline at end of file
diff --git a/g4f/Provider/ChatgptDuo.py b/g4f/Provider/ChatgptDuo.py
new file mode 100644
index 00000000..abed8a3c
--- /dev/null
+++ b/g4f/Provider/ChatgptDuo.py
@@ -0,0 +1,51 @@
+from __future__ import annotations
+
+from curl_cffi.requests import AsyncSession
+from .base_provider import AsyncProvider, format_prompt
+
+
+class ChatgptDuo(AsyncProvider):
+    url                   = "https://chatgptduo.com"
+    supports_gpt_35_turbo = True
+    working               = True
+
+    @classmethod
+    async def create_async(
+        cls,
+        model: str,
+        messages: list[dict[str, str]],
+        **kwargs
+    ) -> str:
+        async with AsyncSession(impersonate="chrome107") as session:
+            prompt = format_prompt(messages),
+            data = {
+                "prompt": prompt,
+                "search": prompt,
+                "purpose": "ask",
+            }
+            response = await session.post(f"{cls.url}/", data=data)
+            response.raise_for_status()
+            data = response.json()
+
+            cls._sources = [{
+                "title": source["title"],
+                "url": source["link"],
+                "snippet": source["snippet"]
+            } for source in data["results"]]
+
+            return data["answer"]
+
+    @classmethod
+    def get_sources(cls):
+        return cls._sources
+
+    @classmethod
+    @property
+    def params(cls):
+        params = [
+            ("model", "str"),
+            ("messages", "list[dict[str, str]]"),
+            ("stream", "bool"),
+        ]
+        param = ", ".join([": ".join(p) for p in params])
+        return f"g4f.provider.{cls.__name__} supports: ({param})"
\ No newline at end of file
diff --git a/g4f/Provider/ChatgptLogin.py b/g4f/Provider/ChatgptLogin.py
new file mode 100644
index 00000000..3eb55a64
--- /dev/null
+++ b/g4f/Provider/ChatgptLogin.py
@@ -0,0 +1,74 @@
+from __future__ import annotations
+
+import os, re
+from aiohttp import ClientSession
+
+from .base_provider import AsyncProvider, format_prompt
+
+
+class ChatgptLogin(AsyncProvider):
+    url                   = "https://opchatgpts.net"
+    supports_gpt_35_turbo = True
+    working               = True
+    _nonce                = None
+
+    @classmethod
+    async def create_async(
+        cls,
+        model: str,
+        messages: list[dict[str, str]],
+        **kwargs
+    ) -> str:
+        headers = {
+            "User-Agent"         : "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/116.0.0.0 Safari/537.36",
+            "Accept"             : "*/*",
+            "Accept-language"    : "en,fr-FR;q=0.9,fr;q=0.8,es-ES;q=0.7,es;q=0.6,en-US;q=0.5,am;q=0.4,de;q=0.3",
+            "Origin"             : "https://opchatgpts.net",
+            "Alt-Used"           : "opchatgpts.net",
+            "Referer"            : "https://opchatgpts.net/chatgpt-free-use/",
+            "Sec-Fetch-Dest"     : "empty",
+            "Sec-Fetch-Mode"     : "cors",
+            "Sec-Fetch-Site"     : "same-origin",
+        }
+        async with ClientSession(
+            headers=headers
+        ) as session:
+            if not cls._nonce:
+                async with session.get(
+                    "https://opchatgpts.net/chatgpt-free-use/",
+                    params={"id": os.urandom(6).hex()},
+                ) as response:
+                    result = re.search(r'data-nonce="(.*?)"', await response.text())
+                if not result:
+                    raise RuntimeError("No nonce value")
+                cls._nonce = result.group(1)
+            data = {
+                "_wpnonce": cls._nonce,
+                "post_id": 28,
+                "url": "https://opchatgpts.net/chatgpt-free-use",
+                "action": "wpaicg_chat_shortcode_message",
+                "message": format_prompt(messages),
+                "bot_id": 0
+            }
+            async with session.post("https://opchatgpts.net/wp-admin/admin-ajax.php", data=data) as response:
+                response.raise_for_status()
+                data = await response.json()
+                if "data" in data:
+                    return data["data"]
+                elif "msg" in data:
+                    raise RuntimeError(data["msg"])
+                else:
+                    raise RuntimeError(f"Response: {data}")
+
+
+    @classmethod
+    @property
+    def params(cls):
+        params = [
+            ("model", "str"),
+            ("messages", "list[dict[str, str]]"),
+            ("stream", "bool"),
+            ("temperature", "float"),
+        ]
+        param = ", ".join([": ".join(p) for p in params])
+        return f"g4f.provider.{cls.__name__} supports: ({param})"
\ No newline at end of file
diff --git a/g4f/Provider/DeepAi.py b/g4f/Provider/DeepAi.py
new file mode 100644
index 00000000..7239f6ac
--- /dev/null
+++ b/g4f/Provider/DeepAi.py
@@ -0,0 +1,66 @@
+from __future__ import annotations
+
+import json
+import js2py
+from aiohttp import ClientSession
+
+from ..typing       import AsyncGenerator
+from .base_provider import AsyncGeneratorProvider
+
+
+class DeepAi(AsyncGeneratorProvider):
+    url: str              = "https://deepai.org"
+    working               = True
+    supports_gpt_35_turbo = True
+
+    @staticmethod
+    async def create_async_generator(
+        model: str,
+        messages: list[dict[str, str]],
+        proxy: str = None,
+        **kwargs
+    ) -> AsyncGenerator:
+        
+        token_js = """
+var agent = 'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/115.0.0.0 Safari/537.36'
+var a, b, c, d, e, h, f, l, g, k, m, n, r, x, C, E, N, F, T, O, P, w, D, G, Q, R, W, I, aa, fa, na, oa, ha, ba, X, ia, ja, ka, J, la, K, L, ca, S, U, M, ma, B, da, V, Y;
+h = Math.round(1E11 * Math.random()) + "";
+f = function () {
+    for (var p = [], q = 0; 64 > q;) p[q] = 0 | 4294967296 * Math.sin(++q % Math.PI);
+    
+    return function (t) {
+        var v, y, H, ea = [v = 1732584193, y = 4023233417, ~v, ~y],
+            Z = [],
+            A = unescape(encodeURI(t)) + "\u0080",
+            z = A.length;
+        t = --z / 4 + 2 | 15;
+        for (Z[--t] = 8 * z; ~z;) Z[z >> 2] |= A.charCodeAt(z) << 8 * z--;
+        for (q = A = 0; q < t; q += 16) {
+            for (z = ea; 64 > A; z = [H = z[3], v + ((H = z[0] + [v & y | ~v & H, H & v | ~H & y, v ^ y ^ H, y ^ (v | ~H)][z = A >> 4] + p[A] + ~~Z[q | [A, 5 * A + 1, 3 * A + 5, 7 * A][z] & 15]) << (z = [7, 12, 17, 22, 5, 9, 14, 20, 4, 11, 16, 23, 6, 10, 15, 21][4 * z + A++ % 4]) | H >>> -z), v, y]) v = z[1] | 0, y = z[2];
+            for (A = 4; A;) ea[--A] += z[A]
+        }
+        for (t = ""; 32 > A;) t += (ea[A >> 3] >> 4 * (1 ^ A++) & 15).toString(16);
+        return t.split("").reverse().join("")
+    }
+}();
+
+"tryit-" + h + "-" + f(agent + f(agent + f(agent + h + "x")));
+"""
+
+        payload = {"chat_style": "chat", "chatHistory": json.dumps(messages)}
+        api_key = js2py.eval_js(token_js)
+        headers = {
+            "api-key": api_key,
+            "User-Agent": "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/115.0.0.0 Safari/537.36",
+            **kwargs.get("headers", {})
+        }
+        async with ClientSession(
+            headers=headers
+        ) as session:
+            fill = "ing_is"
+            fill = f"ack{fill}_a_crim"
+            async with session.post(f"https://api.deepai.org/h{fill}e", proxy=proxy, data=payload) as response:
+                response.raise_for_status()
+                async for stream in response.content.iter_any():
+                    if stream:
+                        yield stream.decode()
diff --git a/g4f/Provider/FreeGpt.py b/g4f/Provider/FreeGpt.py
new file mode 100644
index 00000000..092e1bb6
--- /dev/null
+++ b/g4f/Provider/FreeGpt.py
@@ -0,0 +1,54 @@
+from __future__ import annotations
+
+import time, hashlib, random
+
+from ..typing import AsyncGenerator
+from ..requests import StreamSession
+from .base_provider import AsyncGeneratorProvider
+
+domains = [
+    'https://k.aifree.site',
+    'https://p.aifree.site'
+]
+
+class FreeGpt(AsyncGeneratorProvider):
+    url                   = "https://freegpts1.aifree.site/"
+    supports_gpt_35_turbo = True
+    working               = True
+
+    @classmethod
+    async def create_async_generator(
+        cls,
+        model: str,
+        messages: list[dict[str, str]],
+        **kwargs
+    ) -> AsyncGenerator:
+        async with StreamSession(impersonate="chrome107") as session:
+            prompt = messages[-1]["content"]
+            timestamp = int(time.time())
+            data = {
+                "messages": messages,
+                "time": timestamp,
+                "pass": None,
+                "sign": generate_signature(timestamp, prompt)
+            }
+            url = random.choice(domains)
+            async with session.post(f"{url}/api/generate", json=data) as response:
+                response.raise_for_status()
+                async for chunk in response.iter_content():
+                    yield chunk.decode()
+
+    @classmethod
+    @property
+    def params(cls):
+        params = [
+            ("model", "str"),
+            ("messages", "list[dict[str, str]]"),
+            ("stream", "bool"),
+        ]
+        param = ", ".join([": ".join(p) for p in params])
+        return f"g4f.provider.{cls.__name__} supports: ({param})"
+    
+def generate_signature(timestamp: int, message: str, secret: str = ""):
+    data = f"{timestamp}:{message}:{secret}"
+    return hashlib.sha256(data.encode()).hexdigest()
\ No newline at end of file
diff --git a/g4f/Provider/GptGo.py b/g4f/Provider/GptGo.py
new file mode 100644
index 00000000..7db8fb0d
--- /dev/null
+++ b/g4f/Provider/GptGo.py
@@ -0,0 +1,78 @@
+from __future__ import annotations
+
+from aiohttp import ClientSession
+import json
+
+from ..typing       import AsyncGenerator
+from .base_provider import AsyncGeneratorProvider, format_prompt
+
+
+class GptGo(AsyncGeneratorProvider):
+    url                   = "https://gptgo.ai"
+    supports_gpt_35_turbo = True
+    working               = True
+
+    @classmethod
+    async def create_async_generator(
+        cls,
+        model: str,
+        messages: list[dict[str, str]],
+        proxy: str = None,
+        **kwargs
+    ) -> AsyncGenerator:
+        headers = {
+            "User-Agent"         : "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/116.0.0.0 Safari/537.36",
+            "Accept"             : "*/*",
+            "Accept-language"    : "en,fr-FR;q=0.9,fr;q=0.8,es-ES;q=0.7,es;q=0.6,en-US;q=0.5,am;q=0.4,de;q=0.3",
+            "Origin"             : cls.url,
+            "Referer"            : cls.url + "/",
+            "Sec-Fetch-Dest"     : "empty",
+            "Sec-Fetch-Mode"     : "cors",
+            "Sec-Fetch-Site"     : "same-origin",
+        }
+        async with ClientSession(
+            headers=headers
+        ) as session:
+            async with session.get(
+                "https://gptgo.ai/action_get_token.php",
+                params={
+                    "q": format_prompt(messages),
+                    "hlgpt": "default",
+                    "hl": "en"
+                },
+                proxy=proxy
+            ) as response:
+                response.raise_for_status()
+                token = (await response.json(content_type=None))["token"]
+
+            async with session.get(
+                "https://gptgo.ai/action_ai_gpt.php",
+                params={
+                    "token": token,
+                },
+                proxy=proxy
+            ) as response:
+                response.raise_for_status()
+                start = "data: "
+                async for line in response.content:
+                    line = line.decode()
+                    if line.startswith("data: "):
+                        if line.startswith("data: [DONE]"):
+                            break
+                        line = json.loads(line[len(start):-1])
+                        content = line["choices"][0]["delta"].get("content")
+                        if content:
+                            yield content
+
+
+    @classmethod
+    @property
+    def params(cls):
+        params = [
+            ("model", "str"),
+            ("messages", "list[dict[str, str]]"),
+            ("stream", "bool"),
+            ("temperature", "float"),
+        ]
+        param = ", ".join([": ".join(p) for p in params])
+        return f"g4f.provider.{cls.__name__} supports: ({param})"
\ No newline at end of file
diff --git a/g4f/Provider/H2o.py b/g4f/Provider/H2o.py
new file mode 100644
index 00000000..d92bd6d1
--- /dev/null
+++ b/g4f/Provider/H2o.py
@@ -0,0 +1,109 @@
+from __future__ import annotations
+
+import json
+import uuid
+
+from aiohttp import ClientSession
+
+from ..typing import AsyncGenerator
+from .base_provider import AsyncGeneratorProvider, format_prompt
+
+
+class H2o(AsyncGeneratorProvider):
+    url = "https://gpt-gm.h2o.ai"
+    working = True
+    model = "h2oai/h2ogpt-gm-oasst1-en-2048-falcon-40b-v1"
+
+    @classmethod
+    async def create_async_generator(
+        cls,
+        model: str,
+        messages: list[dict[str, str]],
+        proxy: str = None,
+        **kwargs
+    ) -> AsyncGenerator:
+        model = model if model else cls.model
+        headers = {"Referer": cls.url + "/"}
+
+        async with ClientSession(
+            headers=headers
+        ) as session:
+            data = {
+                "ethicsModalAccepted": "true",
+                "shareConversationsWithModelAuthors": "true",
+                "ethicsModalAcceptedAt": "",
+                "activeModel": model,
+                "searchEnabled": "true",
+            }
+            async with session.post(
+                f"{cls.url}/settings",
+                proxy=proxy,
+                data=data
+            ) as response:
+                response.raise_for_status()
+
+            async with session.post(
+                f"{cls.url}/conversation",
+                proxy=proxy,
+                json={"model": model},
+            ) as response:
+                response.raise_for_status()
+                conversationId = (await response.json())["conversationId"]
+
+            data = {
+                "inputs": format_prompt(messages),
+                "parameters": {
+                    "temperature": 0.4,
+                    "truncate": 2048,
+                    "max_new_tokens": 1024,
+                    "do_sample":  True,
+                    "repetition_penalty": 1.2,
+                    "return_full_text": False,
+                    **kwargs
+                },
+                "stream": True,
+                "options": {
+                    "id": str(uuid.uuid4()),
+                    "response_id": str(uuid.uuid4()),
+                    "is_retry": False,
+                    "use_cache": False,
+                    "web_search_id": "",
+                },
+            }
+            async with session.post(
+                f"{cls.url}/conversation/{conversationId}",
+                proxy=proxy,
+                json=data
+             ) as response:
+                start = "data:"
+                async for line in response.content:
+                    line = line.decode("utf-8")
+                    if line and line.startswith(start):
+                        line = json.loads(line[len(start):-1])
+                        if not line["token"]["special"]:
+                            yield line["token"]["text"]
+
+            async with session.delete(
+                f"{cls.url}/conversation/{conversationId}",
+                proxy=proxy,
+                json=data
+            ) as response:
+                response.raise_for_status()
+
+
+    @classmethod
+    @property
+    def params(cls):
+        params = [
+            ("model", "str"),
+            ("messages", "list[dict[str, str]]"),
+            ("stream", "bool"),
+            ("temperature", "float"),
+            ("truncate", "int"),
+            ("max_new_tokens", "int"),
+            ("do_sample", "bool"),
+            ("repetition_penalty", "float"),
+            ("return_full_text", "bool"),
+        ]
+        param = ", ".join([": ".join(p) for p in params])
+        return f"g4f.provider.{cls.__name__} supports: ({param})"
diff --git a/g4f/Provider/Liaobots.py b/g4f/Provider/Liaobots.py
new file mode 100644
index 00000000..ea3e0d45
--- /dev/null
+++ b/g4f/Provider/Liaobots.py
@@ -0,0 +1,89 @@
+from __future__ import annotations
+
+import json
+import uuid
+
+from aiohttp import ClientSession
+
+from ..typing import AsyncGenerator
+from .base_provider import AsyncGeneratorProvider
+
+models = {
+    "gpt-4": {
+        "id": "gpt-4",
+        "name": "GPT-4",
+        "maxLength": 24000,
+        "tokenLimit": 8000,
+    },
+    "gpt-3.5-turbo": {
+        "id": "gpt-3.5-turbo",
+        "name": "GPT-3.5",
+        "maxLength": 12000,
+        "tokenLimit": 4000,
+    },
+    "gpt-3.5-turbo-16k": {
+        "id": "gpt-3.5-turbo-16k",
+        "name": "GPT-3.5-16k",
+        "maxLength": 48000,
+        "tokenLimit": 16000,
+    },
+}
+
+class Liaobots(AsyncGeneratorProvider):
+    url = "https://liaobots.com"
+    working = False
+    supports_gpt_35_turbo = True
+    supports_gpt_4 = True
+    _auth_code = None
+
+    @classmethod
+    async def create_async_generator(
+        cls,
+        model: str,
+        messages: list[dict[str, str]],
+        auth: str = None,
+        proxy: str = None,
+        **kwargs
+    ) -> AsyncGenerator:
+        model = model if model in models else "gpt-3.5-turbo"
+        headers = {
+            "authority": "liaobots.com",
+            "content-type": "application/json",
+            "origin": cls.url,
+            "referer": cls.url + "/",
+            "user-agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/112.0.0.0 Safari/537.36",
+        }
+        async with ClientSession(
+            headers=headers
+        ) as session:
+            auth_code = auth if isinstance(auth, str) else cls._auth_code
+            if not auth_code:
+                async with session.post(cls.url + "/api/user", proxy=proxy, json={"authcode": ""}) as response:
+                    response.raise_for_status()
+                    auth_code = cls._auth_code = json.loads(await response.text())["authCode"]
+            data = {
+                "conversationId": str(uuid.uuid4()),
+                "model": models[model],
+                "messages": messages,
+                "key": "",
+                "prompt": "You are ChatGPT, a large language model trained by OpenAI. Follow the user's instructions carefully.",
+            }
+            async with session.post(cls.url + "/api/chat", proxy=proxy, json=data, headers={"x-auth-code": auth_code}) as response:
+                response.raise_for_status()
+                async for stream in response.content.iter_any():
+                    if stream:
+                        yield stream.decode()
+
+
+    @classmethod
+    @property
+    def params(cls):
+        params = [
+            ("model", "str"),
+            ("messages", "list[dict[str, str]]"),
+            ("stream", "bool"),
+            ("proxy", "str"),
+            ("auth", "str"),
+        ]
+        param = ", ".join([": ".join(p) for p in params])
+        return f"g4f.provider.{cls.__name__} supports: ({param})"
diff --git a/g4f/Provider/Myshell.py b/g4f/Provider/Myshell.py
new file mode 100644
index 00000000..0ddd3029
--- /dev/null
+++ b/g4f/Provider/Myshell.py
@@ -0,0 +1,172 @@
+from __future__ import annotations
+
+import json, uuid, hashlib, time, random
+
+from aiohttp import ClientSession
+from aiohttp.http import WSMsgType
+import asyncio
+
+from ..typing import AsyncGenerator
+from .base_provider import AsyncGeneratorProvider, format_prompt
+
+
+models = {
+    "samantha": "1e3be7fe89e94a809408b1154a2ee3e1",
+    "gpt-3.5-turbo": "8077335db7cd47e29f7de486612cc7fd",
+    "gpt-4": "01c8de4fbfc548df903712b0922a4e01",
+}
+
+
+class Myshell(AsyncGeneratorProvider):
+    url = "https://app.myshell.ai/chat"
+    working               = True
+    supports_gpt_35_turbo = True
+    supports_gpt_4        = True
+
+    @classmethod
+    async def create_async_generator(
+        cls,
+        model: str,
+        messages: list[dict[str, str]],
+        **kwargs
+    ) -> AsyncGenerator:
+        if not model:
+            bot_id = models["samantha"]
+        elif model in models:
+            bot_id = models[model]
+        else:
+            raise ValueError(f"Model are not supported: {model}")
+        
+        user_agent = 'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/111.0.0.0 Safari/537.36'
+        visitor_id = generate_visitor_id(user_agent)
+
+        async with ClientSession(
+            headers={'User-Agent': user_agent}
+        ) as session:
+            async with session.ws_connect(
+                "wss://api.myshell.ai/ws/?EIO=4&transport=websocket",
+                autoping=False,
+                timeout=90
+            ) as wss:
+                # Send and receive hello message
+                await wss.receive_str()
+                message = json.dumps({"token": None, "visitorId": visitor_id})
+                await wss.send_str(f"40/chat,{message}")
+                await wss.receive_str()
+
+                # Fix "need_verify_captcha" issue
+                await asyncio.sleep(5)
+
+                # Create chat message
+                text = format_prompt(messages)
+                chat_data = json.dumps(["text_chat",{
+                    "reqId": str(uuid.uuid4()),
+                    "botUid": bot_id,
+                    "sourceFrom": "myshellWebsite",
+                    "text": text,
+                    **generate_signature(text)
+                }])
+
+                # Send chat message
+                chat_start = "42/chat,"
+                chat_message = f"{chat_start}{chat_data}"
+                await wss.send_str(chat_message)
+
+                # Receive messages
+                async for message in wss:
+                    if message.type != WSMsgType.TEXT:
+                        continue
+                    # Ping back
+                    if message.data == "2":
+                        await wss.send_str("3")
+                        continue
+                    # Is not chat message
+                    if not message.data.startswith(chat_start):
+                        continue
+                    data_type, data = json.loads(message.data[len(chat_start):])
+                    if data_type == "text_stream":
+                        if data["data"]["text"]:
+                            yield data["data"]["text"]
+                        elif data["data"]["isFinal"]:
+                            break
+                    elif data_type in ("message_replied", "need_verify_captcha"):
+                        raise RuntimeError(f"Received unexpected message: {data_type}")
+
+
+    @classmethod
+    @property
+    def params(cls):
+        params = [
+            ("model", "str"),
+            ("messages", "list[dict[str, str]]"),
+            ("stream", "bool"),
+        ]
+        param = ", ".join([": ".join(p) for p in params])
+        return f"g4f.provider.{cls.__name__} supports: ({param})"
+
+
+def generate_timestamp() -> str:
+    return str(
+        int(
+            str(int(time.time() * 1000))[:-1]
+            + str(
+                sum(
+                    2 * int(digit)
+                    if idx % 2 == 0
+                    else 3 * int(digit)
+                    for idx, digit in enumerate(str(int(time.time() * 1000))[:-1])
+                )
+                % 10
+            )
+        )
+    )
+
+def generate_signature(text: str):
+    timestamp = generate_timestamp()
+    version = 'v1.0.0'
+    secret = '8@VXGK3kKHr!u2gA' 
+    data = f"{version}#{text}#{timestamp}#{secret}"
+    signature = hashlib.md5(data.encode()).hexdigest()
+    signature = signature[::-1]
+    return {
+        "signature": signature,
+        "timestamp": timestamp,
+        "version": version
+    }
+
+def xor_hash(B: str):
+    r = []
+    i = 0
+    
+    def o(e, t):
+        o_val = 0
+        for i in range(len(t)):
+            o_val |= r[i] << (8 * i)
+        return e ^ o_val
+    
+    for e in range(len(B)):
+        t = ord(B[e])
+        r.insert(0, 255 & t)
+        
+        if len(r) >= 4:
+            i = o(i, r)
+            r = []
+    
+    if len(r) > 0:
+        i = o(i, r)
+    
+    return hex(i)[2:]
+
+def performance() -> str:
+    t = int(time.time() * 1000)
+    e = 0
+    while t == int(time.time() * 1000):
+        e += 1
+    return hex(t)[2:] + hex(e)[2:]
+
+def generate_visitor_id(user_agent: str) -> str:
+    f = performance()
+    r = hex(int(random.random() * (16**16)))[2:-2]
+    d = xor_hash(user_agent)
+    e = hex(1080 * 1920)[2:]
+    return f"{f}-{r}-{d}-{e}-{f}"
\ No newline at end of file
diff --git a/g4f/Provider/Phind.py b/g4f/Provider/Phind.py
new file mode 100644
index 00000000..0db4e3c2
--- /dev/null
+++ b/g4f/Provider/Phind.py
@@ -0,0 +1,76 @@
+from __future__ import annotations
+
+import random
+from datetime import datetime
+
+from ..typing import AsyncGenerator
+from ..requests import StreamSession
+from .base_provider import AsyncGeneratorProvider, format_prompt
+
+
+class Phind(AsyncGeneratorProvider):
+    url = "https://www.phind.com"
+    working = True
+    supports_gpt_4 = True
+
+    @classmethod
+    async def create_async_generator(
+        cls,
+        model: str,
+        messages: list[dict[str, str]],
+        proxy: str = None,
+        **kwargs
+    ) -> AsyncGenerator:
+        chars = 'abcdefghijklmnopqrstuvwxyz0123456789'
+        user_id = ''.join(random.choice(chars) for _ in range(24))
+        data = {
+            "question": format_prompt(messages),
+            "webResults": [],
+            "options": {
+                "date": datetime.now().strftime("%d.%m.%Y"),
+                "language": "en",
+                "detailed": True,
+                "anonUserId": user_id,
+                "answerModel": "GPT-4",
+                "creativeMode": False,
+                "customLinks": []
+            },
+            "context":""
+        }
+        headers = {
+            "Authority": cls.url,
+            "Accept": "application/json, text/plain, */*",
+            "Origin": cls.url,
+            "Referer": f"{cls.url}/"
+        }
+        async with StreamSession(headers=headers, timeout=(5, 180), proxies={"https": proxy}, impersonate="chrome107") as session:
+            async with session.post(f"{cls.url}/api/infer/answer", json=data) as response:
+                response.raise_for_status()
+                new_lines = 0
+                async for line in response.iter_lines():
+                    if not line:
+                        continue
+                    if line.startswith(b"data: "):
+                        line = line[6:]
+                    if line.startswith(b"<PHIND_METADATA>"):
+                        continue
+                    if line:
+                        if new_lines:
+                            yield "".join(["\n" for _ in range(int(new_lines / 2))])
+                            new_lines = 0
+                        yield line.decode()
+                    else:
+                        new_lines += 1
+
+
+    @classmethod
+    @property
+    def params(cls):
+        params = [
+            ("model", "str"),
+            ("messages", "list[dict[str, str]]"),
+            ("stream", "bool"),
+            ("proxy", "str"),
+        ]
+        param = ", ".join([": ".join(p) for p in params])
+        return f"g4f.provider.{cls.__name__} supports: ({param})"
diff --git a/g4f/Provider/Vercel.py b/g4f/Provider/Vercel.py
new file mode 100644
index 00000000..2d20ca6a
--- /dev/null
+++ b/g4f/Provider/Vercel.py
@@ -0,0 +1,377 @@
+from __future__ import annotations
+
+import json, base64, requests, execjs, random, uuid
+
+from ..typing       import Any, TypedDict, CreateResult
+from .base_provider import BaseProvider
+from abc            import abstractmethod
+
+
+class Vercel(BaseProvider):
+    url = 'https://sdk.vercel.ai'
+    working               = True
+    supports_gpt_35_turbo = True
+    supports_stream       = True
+
+    @staticmethod
+    @abstractmethod
+    def create_completion(
+        model: str,
+        messages: list[dict[str, str]],
+        stream: bool,
+        **kwargs
+    ) -> CreateResult:
+        if not model:
+            model = "gpt-3.5-turbo"
+        elif model not in model_info:
+            raise ValueError(f"Model are not supported: {model}")
+
+        headers = {
+            'authority'         : 'sdk.vercel.ai',
+            'accept'            : '*/*',
+            'accept-language'   : 'en,fr-FR;q=0.9,fr;q=0.8,es-ES;q=0.7,es;q=0.6,en-US;q=0.5,am;q=0.4,de;q=0.3',
+            'cache-control'     : 'no-cache',
+            'content-type'      : 'application/json',
+            'custom-encoding'   : get_anti_bot_token(),
+            'origin'            : 'https://sdk.vercel.ai',
+            'pragma'            : 'no-cache',
+            'referer'           : 'https://sdk.vercel.ai/',
+            'sec-ch-ua'         : '"Google Chrome";v="117", "Not;A=Brand";v="8", "Chromium";v="117"',
+            'sec-ch-ua-mobile'  : '?0',
+            'sec-ch-ua-platform': '"macOS"',
+            'sec-fetch-dest'    : 'empty',
+            'sec-fetch-mode'    : 'cors',
+            'sec-fetch-site'    : 'same-origin',
+            'user-agent'        :  'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/117.0.%s.%s Safari/537.36' % (
+                random.randint(99, 999),
+                random.randint(99, 999)
+            )
+        }
+
+        json_data = {
+            'model'       : model_info[model]['id'],
+            'messages'    : messages,
+            'playgroundId': str(uuid.uuid4()),
+            'chatIndex'   : 0} | model_info[model]['default_params']
+
+        max_retries  = kwargs.get('max_retries', 20)
+        for i in range(max_retries):
+            response = requests.post('https://sdk.vercel.ai/api/generate', 
+                                    headers=headers, json=json_data, stream=True)
+            try:
+                response.raise_for_status()
+            except:
+                continue
+            for token in response.iter_content(chunk_size=None):
+                yield token.decode()
+            break
+
+
+def get_anti_bot_token() -> str:
+    headers = {
+        'authority'         : 'sdk.vercel.ai',
+        'accept'            : '*/*',
+        'accept-language'   : 'en,fr-FR;q=0.9,fr;q=0.8,es-ES;q=0.7,es;q=0.6,en-US;q=0.5,am;q=0.4,de;q=0.3',
+        'cache-control'     : 'no-cache',
+        'pragma'            : 'no-cache',
+        'referer'           : 'https://sdk.vercel.ai/',
+        'sec-ch-ua'         : '"Google Chrome";v="117", "Not;A=Brand";v="8", "Chromium";v="117"',
+        'sec-ch-ua-mobile'  : '?0',
+        'sec-ch-ua-platform': '"macOS"',
+        'sec-fetch-dest'    : 'empty',
+        'sec-fetch-mode'    : 'cors',
+        'sec-fetch-site'    : 'same-origin',
+        'user-agent'        : 'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/117.0.%s.%s Safari/537.36' % (
+            random.randint(99, 999), 
+            random.randint(99, 999)
+        )
+    }
+
+    response = requests.get('https://sdk.vercel.ai/openai.jpeg', 
+                            headers=headers).text
+
+    raw_data = json.loads(base64.b64decode(response, 
+                                    validate=True))
+
+    js_script = '''const globalThis={marker:"mark"};String.prototype.fontcolor=function(){return `<font>${this}</font>`};
+        return (%s)(%s)''' % (raw_data['c'], raw_data['a'])
+
+    raw_token = json.dumps({'r': execjs.compile(js_script).call(''), 't': raw_data['t']}, 
+                        separators = (",", ":"))
+
+    return base64.b64encode(raw_token.encode('utf-16le')).decode()
+
+class ModelInfo(TypedDict):
+    id: str
+    default_params: dict[str, Any]
+
+model_info: dict[str, ModelInfo] = {
+    'claude-instant-v1': {
+        'id': 'anthropic:claude-instant-v1',
+        'default_params': {
+            'temperature': 1,
+            'maximumLength': 1024,
+            'topP': 1,
+            'topK': 1,
+            'presencePenalty': 1,
+            'frequencyPenalty': 1,
+            'stopSequences': ['\n\nHuman:'],
+        },
+    },
+    'claude-v1': {
+        'id': 'anthropic:claude-v1',
+        'default_params': {
+            'temperature': 1,
+            'maximumLength': 1024,
+            'topP': 1,
+            'topK': 1,
+            'presencePenalty': 1,
+            'frequencyPenalty': 1,
+            'stopSequences': ['\n\nHuman:'],
+        },
+    },
+    'claude-v2': {
+        'id': 'anthropic:claude-v2',
+        'default_params': {
+            'temperature': 1,
+            'maximumLength': 1024,
+            'topP': 1,
+            'topK': 1,
+            'presencePenalty': 1,
+            'frequencyPenalty': 1,
+            'stopSequences': ['\n\nHuman:'],
+        },
+    },
+    'a16z-infra/llama7b-v2-chat': {
+        'id': 'replicate:a16z-infra/llama7b-v2-chat',
+        'default_params': {
+            'temperature': 0.75,
+            'maximumLength': 3000,
+            'topP': 1,
+            'repetitionPenalty': 1,
+        },
+    },
+    'a16z-infra/llama13b-v2-chat': {
+        'id': 'replicate:a16z-infra/llama13b-v2-chat',
+        'default_params': {
+            'temperature': 0.75,
+            'maximumLength': 3000,
+            'topP': 1,
+            'repetitionPenalty': 1,
+        },
+    },
+    'replicate/llama-2-70b-chat': {
+        'id': 'replicate:replicate/llama-2-70b-chat',
+        'default_params': {
+            'temperature': 0.75,
+            'maximumLength': 3000,
+            'topP': 1,
+            'repetitionPenalty': 1,
+        },
+    },
+    'bigscience/bloom': {
+        'id': 'huggingface:bigscience/bloom',
+        'default_params': {
+            'temperature': 0.5,
+            'maximumLength': 1024,
+            'topP': 0.95,
+            'topK': 4,
+            'repetitionPenalty': 1.03,
+        },
+    },
+    'google/flan-t5-xxl': {
+        'id': 'huggingface:google/flan-t5-xxl',
+        'default_params': {
+            'temperature': 0.5,
+            'maximumLength': 1024,
+            'topP': 0.95,
+            'topK': 4,
+            'repetitionPenalty': 1.03,
+        },
+    },
+    'EleutherAI/gpt-neox-20b': {
+        'id': 'huggingface:EleutherAI/gpt-neox-20b',
+        'default_params': {
+            'temperature': 0.5,
+            'maximumLength': 1024,
+            'topP': 0.95,
+            'topK': 4,
+            'repetitionPenalty': 1.03,
+            'stopSequences': [],
+        },
+    },
+    'OpenAssistant/oasst-sft-4-pythia-12b-epoch-3.5': {
+        'id': 'huggingface:OpenAssistant/oasst-sft-4-pythia-12b-epoch-3.5',
+        'default_params': {
+            'maximumLength': 1024,
+            'typicalP': 0.2,
+            'repetitionPenalty': 1,
+        },
+    },
+    'OpenAssistant/oasst-sft-1-pythia-12b': {
+        'id': 'huggingface:OpenAssistant/oasst-sft-1-pythia-12b',
+        'default_params': {
+            'maximumLength': 1024,
+            'typicalP': 0.2,
+            'repetitionPenalty': 1,
+        },
+    },
+    'bigcode/santacoder': {
+        'id': 'huggingface:bigcode/santacoder',
+        'default_params': {
+            'temperature': 0.5,
+            'maximumLength': 1024,
+            'topP': 0.95,
+            'topK': 4,
+            'repetitionPenalty': 1.03,
+        },
+    },
+    'command-light-nightly': {
+        'id': 'cohere:command-light-nightly',
+        'default_params': {
+            'temperature': 0.9,
+            'maximumLength': 1024,
+            'topP': 1,
+            'topK': 0,
+            'presencePenalty': 0,
+            'frequencyPenalty': 0,
+            'stopSequences': [],
+        },
+    },
+    'command-nightly': {
+        'id': 'cohere:command-nightly',
+        'default_params': {
+            'temperature': 0.9,
+            'maximumLength': 1024,
+            'topP': 1,
+            'topK': 0,
+            'presencePenalty': 0,
+            'frequencyPenalty': 0,
+            'stopSequences': [],
+        },
+    },
+    'gpt-4': {
+        'id': 'openai:gpt-4',
+        'default_params': {
+            'temperature': 0.7,
+            'maximumLength': 8192,
+            'topP': 1,
+            'presencePenalty': 0,
+            'frequencyPenalty': 0,
+            'stopSequences': [],
+        },
+    },
+    'gpt-4-0613': {
+        'id': 'openai:gpt-4-0613',
+        'default_params': {
+            'temperature': 0.7,
+            'maximumLength': 8192,
+            'topP': 1,
+            'presencePenalty': 0,
+            'frequencyPenalty': 0,
+            'stopSequences': [],
+        },
+    },
+    'code-davinci-002': {
+        'id': 'openai:code-davinci-002',
+        'default_params': {
+            'temperature': 0.5,
+            'maximumLength': 1024,
+            'topP': 1,
+            'presencePenalty': 0,
+            'frequencyPenalty': 0,
+            'stopSequences': [],
+        },
+    },
+    'gpt-3.5-turbo': {
+        'id': 'openai:gpt-3.5-turbo',
+        'default_params': {
+            'temperature': 0.7,
+            'maximumLength': 4096,
+            'topP': 1,
+            'topK': 1,
+            'presencePenalty': 1,
+            'frequencyPenalty': 1,
+            'stopSequences': [],
+        },
+    },
+    'gpt-3.5-turbo-16k': {
+        'id': 'openai:gpt-3.5-turbo-16k',
+        'default_params': {
+            'temperature': 0.7,
+            'maximumLength': 16280,
+            'topP': 1,
+            'topK': 1,
+            'presencePenalty': 1,
+            'frequencyPenalty': 1,
+            'stopSequences': [],
+        },
+    },
+    'gpt-3.5-turbo-16k-0613': {
+        'id': 'openai:gpt-3.5-turbo-16k-0613',
+        'default_params': {
+            'temperature': 0.7,
+            'maximumLength': 16280,
+            'topP': 1,
+            'topK': 1,
+            'presencePenalty': 1,
+            'frequencyPenalty': 1,
+            'stopSequences': [],
+        },
+    },
+    'text-ada-001': {
+        'id': 'openai:text-ada-001',
+        'default_params': {
+            'temperature': 0.5,
+            'maximumLength': 1024,
+            'topP': 1,
+            'presencePenalty': 0,
+            'frequencyPenalty': 0,
+            'stopSequences': [],
+        },
+    },
+    'text-babbage-001': {
+        'id': 'openai:text-babbage-001',
+        'default_params': {
+            'temperature': 0.5,
+            'maximumLength': 1024,
+            'topP': 1,
+            'presencePenalty': 0,
+            'frequencyPenalty': 0,
+            'stopSequences': [],
+        },
+    },
+    'text-curie-001': {
+        'id': 'openai:text-curie-001',
+        'default_params': {
+            'temperature': 0.5,
+            'maximumLength': 1024,
+            'topP': 1,
+            'presencePenalty': 0,
+            'frequencyPenalty': 0,
+            'stopSequences': [],
+        },
+    },
+    'text-davinci-002': {
+        'id': 'openai:text-davinci-002',
+        'default_params': {
+            'temperature': 0.5,
+            'maximumLength': 1024,
+            'topP': 1,
+            'presencePenalty': 0,
+            'frequencyPenalty': 0,
+            'stopSequences': [],
+        },
+    },
+    'text-davinci-003': {
+        'id': 'openai:text-davinci-003',
+        'default_params': {
+            'temperature': 0.5,
+            'maximumLength': 4097,
+            'topP': 1,
+            'presencePenalty': 0,
+            'frequencyPenalty': 0,
+            'stopSequences': [],
+        },
+    },
+}
\ No newline at end of file
diff --git a/g4f/Provider/Vitalentum.py b/g4f/Provider/Vitalentum.py
new file mode 100644
index 00000000..d5265428
--- /dev/null
+++ b/g4f/Provider/Vitalentum.py
@@ -0,0 +1,68 @@
+from __future__ import annotations
+
+import json
+from aiohttp import ClientSession
+
+from .base_provider import AsyncGeneratorProvider
+from ..typing import AsyncGenerator
+
+class Vitalentum(AsyncGeneratorProvider):
+    url                   = "https://app.vitalentum.io"
+    working               = True
+    supports_gpt_35_turbo = True
+
+
+    @classmethod
+    async def create_async_generator(
+        cls,
+        model: str,
+        messages: list[dict[str, str]],
+        proxy: str = None,
+        **kwargs
+    ) -> AsyncGenerator:
+        headers = {
+            "User-Agent"         : "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/116.0.0.0 Safari/537.36",
+            "Accept"             : "text/event-stream",
+            "Accept-language"    : "de,en-US;q=0.7,en;q=0.3",
+            "Origin"             : cls.url,
+            "Referer"            : cls.url + "/",
+            "Sec-Fetch-Dest"     : "empty",
+            "Sec-Fetch-Mode"     : "cors",
+            "Sec-Fetch-Site"     : "same-origin",
+        }
+        conversation = json.dumps({"history": [{
+            "speaker": "human" if message["role"] == "user" else "bot",
+            "text": message["content"],
+        } for message in messages]})
+        data = {
+            "conversation": conversation,
+            "temperature": 0.7,
+            **kwargs
+        }
+        async with ClientSession(
+            headers=headers
+        ) as session:
+            async with session.post(cls.url + "/api/converse-edge", json=data, proxy=proxy) as response:
+                response.raise_for_status()
+                async for line in response.content:
+                    line = line.decode()
+                    if line.startswith("data: "):
+                        if line.startswith("data: [DONE]"):
+                            break
+                        line = json.loads(line[6:-1])
+                        content = line["choices"][0]["delta"].get("content")
+                        if content:
+                            yield content
+
+
+    @classmethod
+    @property
+    def params(cls):
+        params = [
+            ("model", "str"),
+            ("messages", "list[dict[str, str]]"),
+            ("stream", "bool"),
+            ("temperature", "float"),
+        ]
+        param = ", ".join([": ".join(p) for p in params])
+        return f"g4f.provider.{cls.__name__} supports: ({param})"
\ No newline at end of file
diff --git a/g4f/Provider/Ylokh.py b/g4f/Provider/Ylokh.py
new file mode 100644
index 00000000..3c8b32dd
--- /dev/null
+++ b/g4f/Provider/Ylokh.py
@@ -0,0 +1,74 @@
+from __future__ import annotations
+
+import json
+
+from ..requests import StreamSession
+from .base_provider import AsyncGeneratorProvider
+from ..typing import AsyncGenerator
+
+class Ylokh(AsyncGeneratorProvider):
+    url                   = "https://chat.ylokh.xyz"
+    working               = True
+    supports_gpt_35_turbo = True
+
+
+    @classmethod
+    async def create_async_generator(
+        cls,
+        model: str,
+        messages: list[dict[str, str]],
+        stream: bool = True,
+        proxy: str = None,
+        **kwargs
+    ) -> AsyncGenerator:
+        model = model if model else "gpt-3.5-turbo"
+        headers = {
+            "Origin"             : cls.url,
+            "Referer"            : cls.url + "/",
+        }
+        data = {
+            "messages": messages,
+            "model": model,
+            "temperature": 1,
+            "presence_penalty": 0,
+            "top_p": 1,
+            "frequency_penalty": 0,
+            "allow_fallback": True,
+            "stream": stream,
+            **kwargs
+        }
+        async with StreamSession(
+            headers=headers,
+            proxies={"https": proxy}
+        ) as session:
+            async with session.post("https://chatapi.ylokh.xyz/v1/chat/completions", json=data) as response:
+                response.raise_for_status()
+                if stream:
+                    async for line in response.iter_lines():
+                        line = line.decode()
+                        if line.startswith("data: "):
+                            if line.startswith("data: [DONE]"):
+                                break
+                            line = json.loads(line[6:])
+                            content = line["choices"][0]["delta"].get("content")
+                            if content:
+                                yield content
+                else:
+                    chat = await response.json()
+                    yield chat["choices"][0]["message"].get("content")
+
+
+
+    @classmethod
+    @property
+    def params(cls):
+        params = [
+            ("model", "str"),
+            ("messages", "list[dict[str, str]]"),
+            ("stream", "bool"),
+            ("proxy", "str"),
+            ("temperature", "float"),
+            ("top_p", "float"),
+        ]
+        param = ", ".join([": ".join(p) for p in params])
+        return f"g4f.provider.{cls.__name__} supports: ({param})"
\ No newline at end of file
diff --git a/g4f/Provider/You.py b/g4f/Provider/You.py
new file mode 100644
index 00000000..4f49f15e
--- /dev/null
+++ b/g4f/Provider/You.py
@@ -0,0 +1,40 @@
+from __future__ import annotations
+
+import json
+
+from curl_cffi.requests import AsyncSession
+
+from ..typing import AsyncGenerator
+from .base_provider import AsyncGeneratorProvider, format_prompt
+
+
+class You(AsyncGeneratorProvider):
+    url = "https://you.com"
+    working = True
+    supports_gpt_35_turbo = True
+    supports_stream = False
+
+
+    @classmethod
+    async def create_async_generator(
+        cls,
+        model: str,
+        messages: list[dict[str, str]],
+        proxy: str = None,
+        **kwargs,
+    ) -> AsyncGenerator:
+        async with AsyncSession(proxies={"https": proxy}, impersonate="chrome107") as session:
+            headers = {
+                "Accept": "text/event-stream",
+                "Referer": "https://you.com/search?fromSearchBar=true&tbm=youchat",
+            }
+            response = await session.get(
+                "https://you.com/api/streamingSearch",
+                params={"q": format_prompt(messages), "domain": "youchat", "chat": ""},
+                headers=headers
+            )
+            response.raise_for_status()
+            start = 'data: {"youChatToken": '
+            for line in response.text.splitlines():
+                if line.startswith(start):
+                    yield json.loads(line[len(start): -1])
\ No newline at end of file
diff --git a/g4f/Provider/Yqcloud.py b/g4f/Provider/Yqcloud.py
new file mode 100644
index 00000000..ac93315c
--- /dev/null
+++ b/g4f/Provider/Yqcloud.py
@@ -0,0 +1,48 @@
+from __future__ import annotations
+
+from aiohttp import ClientSession
+
+from ..typing import AsyncGenerator
+from .base_provider import AsyncGeneratorProvider, format_prompt
+
+
+class Yqcloud(AsyncGeneratorProvider):
+    url = "https://chat9.yqcloud.top/"
+    working = True
+    supports_gpt_35_turbo = True
+
+    @staticmethod
+    async def create_async_generator(
+        model: str,
+        messages: list[dict[str, str]],
+        proxy: str = None,
+        **kwargs,
+    ) -> AsyncGenerator:
+        async with ClientSession(
+            headers=_create_header()
+        ) as session:
+            payload = _create_payload(messages)
+            async with session.post("https://api.aichatos.cloud/api/generateStream", proxy=proxy, json=payload) as response:
+                response.raise_for_status()
+                async for stream in response.content.iter_any():
+                    if stream:
+                        yield stream.decode()
+
+
+def _create_header():
+    return {
+        "accept"        : "application/json, text/plain, */*",
+        "content-type"  : "application/json",
+        "origin"        : "https://chat9.yqcloud.top",
+    }
+
+
+def _create_payload(messages: list[dict[str, str]]):
+    return {
+        "prompt": format_prompt(messages),
+        "network": True,
+        "system": "",
+        "withoutContext": False,
+        "stream": True,
+        "userId": "#/chat/1693025544336"
+    }
diff --git a/g4f/Provider/base_provider.py b/g4f/Provider/base_provider.py
new file mode 100644
index 00000000..a21dc871
--- /dev/null
+++ b/g4f/Provider/base_provider.py
@@ -0,0 +1,136 @@
+from __future__ import annotations
+
+from asyncio import AbstractEventLoop
+from concurrent.futures import ThreadPoolExecutor
+from abc import ABC, abstractmethod
+
+from .helper import get_event_loop, get_cookies, format_prompt
+from ..typing import AsyncGenerator, CreateResult
+
+
+class BaseProvider(ABC):
+    url: str
+    working               = False
+    needs_auth            = False
+    supports_stream       = False
+    supports_gpt_35_turbo = False
+    supports_gpt_4        = False
+
+    @staticmethod
+    @abstractmethod
+    def create_completion(
+        model: str,
+        messages: list[dict[str, str]],
+        stream: bool,
+        **kwargs
+    ) -> CreateResult:
+        raise NotImplementedError()
+
+    @classmethod
+    async def create_async(
+        cls,
+        model: str,
+        messages: list[dict[str, str]],
+        *,
+        loop: AbstractEventLoop = None,
+        executor: ThreadPoolExecutor = None,
+        **kwargs
+    ) -> str:
+        if not loop:
+            loop = get_event_loop()
+        def create_func():
+            return "".join(cls.create_completion(
+                model,
+                messages,
+                False,
+                **kwargs
+            ))
+        return await loop.run_in_executor(
+            executor,
+            create_func
+        )
+
+    @classmethod
+    @property
+    def params(cls):
+        params = [
+            ("model", "str"),
+            ("messages", "list[dict[str, str]]"),
+            ("stream", "bool"),
+        ]
+        param = ", ".join([": ".join(p) for p in params])
+        return f"g4f.provider.{cls.__name__} supports: ({param})"
+
+
+class AsyncProvider(BaseProvider):
+    @classmethod
+    def create_completion(
+        cls,
+        model: str,
+        messages: list[dict[str, str]],
+        stream: bool = False,
+        **kwargs
+    ) -> CreateResult:
+        loop = get_event_loop()
+        coro = cls.create_async(model, messages, **kwargs)
+        yield loop.run_until_complete(coro)
+
+    @staticmethod
+    @abstractmethod
+    async def create_async(
+        model: str,
+        messages: list[dict[str, str]],
+        **kwargs
+    ) -> str:
+        raise NotImplementedError()
+
+
+class AsyncGeneratorProvider(AsyncProvider):
+    supports_stream = True
+
+    @classmethod
+    def create_completion(
+        cls,
+        model: str,
+        messages: list[dict[str, str]],
+        stream: bool = True,
+        **kwargs
+    ) -> CreateResult:
+        loop = get_event_loop()
+        generator = cls.create_async_generator(
+            model,
+            messages,
+            stream=stream,
+            **kwargs
+        )
+        gen  = generator.__aiter__()
+        while True:
+            try:
+                yield loop.run_until_complete(gen.__anext__())
+            except StopAsyncIteration:
+                break
+
+    @classmethod
+    async def create_async(
+        cls,
+        model: str,
+        messages: list[dict[str, str]],
+        **kwargs
+    ) -> str:
+        return "".join([
+            chunk async for chunk in cls.create_async_generator(
+                model,
+                messages,
+                stream=False,
+                **kwargs
+            )
+        ])
+        
+    @staticmethod
+    @abstractmethod
+    def create_async_generator(
+        model: str,
+        messages: list[dict[str, str]],
+        **kwargs
+    ) -> AsyncGenerator:
+        raise NotImplementedError()
\ No newline at end of file
diff --git a/g4f/Provider/helper.py b/g4f/Provider/helper.py
new file mode 100644
index 00000000..c127f241
--- /dev/null
+++ b/g4f/Provider/helper.py
@@ -0,0 +1,70 @@
+from __future__ import annotations
+
+import asyncio, sys
+from asyncio import AbstractEventLoop
+from os import path
+import browser_cookie3
+
+# Change event loop policy on windows
+if sys.platform == 'win32':
+    if isinstance(
+        asyncio.get_event_loop_policy(), asyncio.WindowsProactorEventLoopPolicy
+    ):
+        asyncio.set_event_loop_policy(asyncio.WindowsSelectorEventLoopPolicy())
+
+# Local Cookie Storage
+_cookies: dict[str, dict[str, str]] = {}
+
+# If event loop is already running, handle nested event loops
+# If "nest_asyncio" is installed, patch the event loop.
+def get_event_loop() -> AbstractEventLoop:
+    try:
+        asyncio.get_running_loop()
+    except RuntimeError:
+        try:
+            return asyncio.get_event_loop()
+        except RuntimeError:
+            asyncio.set_event_loop(asyncio.new_event_loop())
+            return asyncio.get_event_loop()
+    try:
+        event_loop = asyncio.get_event_loop()
+        if not hasattr(event_loop.__class__, "_nest_patched"):
+            import nest_asyncio
+            nest_asyncio.apply(event_loop)
+        return event_loop
+    except ImportError:
+        raise RuntimeError(
+            'Use "create_async" instead of "create" function in a running event loop. Or install the "nest_asyncio" package.')
+
+# Load cookies for a domain from all supported browser.
+# Cache the results in the "_cookies" variable
+def get_cookies(cookie_domain: str) -> dict:
+    if cookie_domain not in _cookies:
+        _cookies[cookie_domain] = {}
+        try:
+            for cookie in browser_cookie3.load(cookie_domain):
+                _cookies[cookie_domain][cookie.name] = cookie.value
+        except:
+            pass
+    return _cookies[cookie_domain]
+
+
+def format_prompt(messages: list[dict[str, str]], add_special_tokens=False):
+    if add_special_tokens or len(messages) > 1:
+        formatted = "\n".join(
+            ["%s: %s" % ((message["role"]).capitalize(), message["content"]) for message in messages]
+        )
+        return f"{formatted}\nAssistant:"
+    else:
+        return messages[0]["content"]
+    
+
+def get_browser(user_data_dir: str = None):
+    from undetected_chromedriver import Chrome
+    from platformdirs import user_config_dir
+
+    if not user_data_dir:
+        user_data_dir = user_config_dir("g4f")
+        user_data_dir = path.join(user_data_dir, "Default")
+
+    return Chrome(user_data_dir=user_data_dir)
\ No newline at end of file
diff --git a/g4f/Provider/retry_provider.py b/g4f/Provider/retry_provider.py
new file mode 100644
index 00000000..e1a9cd1f
--- /dev/null
+++ b/g4f/Provider/retry_provider.py
@@ -0,0 +1,81 @@
+from __future__ import annotations
+
+import random
+
+from ..typing import CreateResult
+from .base_provider import BaseProvider, AsyncProvider
+
+
+class RetryProvider(AsyncProvider):
+    __name__ = "RetryProvider"
+    working               = True
+    needs_auth            = False
+    supports_stream       = True
+    supports_gpt_35_turbo = False
+    supports_gpt_4        = False
+
+    def __init__(
+        self,
+        providers: list[type[BaseProvider]],
+        shuffle: bool = True
+    ) -> None:
+        self.providers = providers
+        self.shuffle = shuffle
+
+
+    def create_completion(
+        self,
+        model: str,
+        messages: list[dict[str, str]],
+        stream: bool = False,
+        **kwargs
+    ) -> CreateResult:
+        if stream:
+            providers = [provider for provider in self.providers if provider.supports_stream]
+        else:
+            providers = self.providers
+        if self.shuffle:
+            random.shuffle(providers)
+
+        self.exceptions = {}
+        started = False
+        for provider in providers:
+            try:
+                for token in provider.create_completion(model, messages, stream, **kwargs):
+                    yield token
+                    started = True
+                if started:
+                    return
+            except Exception as e:
+                self.exceptions[provider.__name__] = e
+                if started:
+                    break
+
+        self.raise_exceptions()
+
+    async def create_async(
+        self,
+        model: str,
+        messages: list[dict[str, str]],
+        **kwargs
+    ) -> str:
+        providers = [provider for provider in self.providers if issubclass(provider, AsyncProvider)]
+        if self.shuffle:
+            random.shuffle(providers)
+        
+        self.exceptions = {}
+        for provider in providers:
+            try:
+                return await provider.create_async(model, messages, **kwargs)
+            except Exception as e:
+                self.exceptions[provider.__name__] = e
+    
+        self.raise_exceptions()
+    
+    def raise_exceptions(self):
+        if self.exceptions:
+            raise RuntimeError("\n".join(["All providers failed:"] + [
+                f"{p}: {self.exceptions[p].__class__.__name__}: {self.exceptions[p]}" for p in self.exceptions
+            ]))
+        
+        raise RuntimeError("No provider found")
\ No newline at end of file