diff options
Diffstat (limited to 'openai_rev/theb')
-rw-r--r-- | openai_rev/theb/README.md | 10 | ||||
-rw-r--r-- | openai_rev/theb/__init__.py | 52 | ||||
-rw-r--r-- | openai_rev/theb/theb_test.py | 4 |
3 files changed, 0 insertions, 66 deletions
diff --git a/openai_rev/theb/README.md b/openai_rev/theb/README.md deleted file mode 100644 index bd37ba3f..00000000 --- a/openai_rev/theb/README.md +++ /dev/null @@ -1,10 +0,0 @@ -### Example: `theb` (use like openai pypi package) <a name="example-theb"></a> - -```python -# import library -from openai_rev import theb - -# simple streaming completion -for token in theb.Completion.create('hello world'): - print(token, end='', flush=True) -```
\ No newline at end of file diff --git a/openai_rev/theb/__init__.py b/openai_rev/theb/__init__.py deleted file mode 100644 index fa79fdd9..00000000 --- a/openai_rev/theb/__init__.py +++ /dev/null @@ -1,52 +0,0 @@ -from json import loads -from queue import Queue, Empty -from re import findall -from threading import Thread - -from curl_cffi import requests - - -class Completion: - # experimental - part1 = '{"role":"assistant","id":"chatcmpl' - part2 = '"},"index":0,"finish_reason":null}]}}' - regex = rf'{part1}(.*){part2}' - - timer = None - message_queue = Queue() - stream_completed = False - - @classmethod - def request(cls, prompt: str): - headers = { - 'authority': 'chatbot.theb.ai', - 'content-type': 'application/json', - 'origin': 'https://chatbot.theb.ai', - 'user-agent': 'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/112.0.0.0 Safari/537.36', - } - - requests.post( - 'https://chatbot.theb.ai/api/chat-process', - headers=headers, - content_callback=Completion.handle_stream_response, - json={'prompt': prompt, 'options': {}}, - ) - - Completion.stream_completed = True - - @staticmethod - def create(prompt: str): - Thread(target=Completion.request, args=[prompt]).start() - - while not Completion.stream_completed or not Completion.message_queue.empty(): - try: - message = Completion.message_queue.get(timeout=0.01) - for message in findall(Completion.regex, message): - yield loads(Completion.part1 + message + Completion.part2)['delta'] - - except Empty: - pass - - @staticmethod - def handle_stream_response(response): - Completion.message_queue.put(response.decode()) diff --git a/openai_rev/theb/theb_test.py b/openai_rev/theb/theb_test.py deleted file mode 100644 index 805ef094..00000000 --- a/openai_rev/theb/theb_test.py +++ /dev/null @@ -1,4 +0,0 @@ -from openai_rev import theb - -for token in theb.Completion.create('hello world'): - print(token, end='', flush=True) |