From f6ef3cb2237d8c336e915ef77ddbe6f37934c4fd Mon Sep 17 00:00:00 2001
From: MIDORIBIN <aquarion123@gmail.com>
Date: Fri, 28 Jul 2023 19:07:17 +0900
Subject: refactor: refactor provider

---
 g4f/Provider/Lockchat.py | 66 ++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 66 insertions(+)
 create mode 100644 g4f/Provider/Lockchat.py

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

diff --git a/g4f/Provider/Lockchat.py b/g4f/Provider/Lockchat.py
new file mode 100644
index 00000000..974d1331
--- /dev/null
+++ b/g4f/Provider/Lockchat.py
@@ -0,0 +1,66 @@
+import json
+
+import requests
+
+from ..typing import Any, CreateResult
+from .base_provider import BaseProvider
+
+
+class Lockchat(BaseProvider):
+    url = "http://supertest.lockchat.app"
+    supports_stream = True
+    supports_gpt_35_turbo = True
+    supports_gpt_4 = True
+
+    @staticmethod
+    def create_completion(
+        model: str,
+        messages: list[dict[str, str]],
+        stream: bool,
+        **kwargs: Any,
+    ) -> CreateResult:
+        temperature = float(kwargs.get("temperature", 0.7))
+        payload = {
+            "temperature": temperature,
+            "messages": messages,
+            "model": model,
+            "stream": True,
+        }
+
+        headers = {
+            "user-agent": "ChatX/39 CFNetwork/1408.0.4 Darwin/22.5.0",
+        }
+        response = requests.post(
+            "http://supertest.lockchat.app/v1/chat/completions",
+            json=payload,
+            headers=headers,
+            stream=True,
+        )
+        response.raise_for_status()
+        for token in response.iter_lines():
+            if b"The model: `gpt-4` does not exist" in token:
+                print("error, retrying...")
+                Lockchat.create_completion(
+                    model=model,
+                    messages=messages,
+                    stream=stream,
+                    temperature=temperature,
+                    **kwargs,
+                )
+            if b"content" in token:
+                token = json.loads(token.decode("utf-8").split("data: ")[1])
+                token = token["choices"][0]["delta"].get("content")
+                if 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})"
-- 
cgit v1.2.3