summaryrefslogtreecommitdiffstats
path: root/openai_rev/theb
diff options
context:
space:
mode:
Diffstat (limited to 'openai_rev/theb')
-rw-r--r--openai_rev/theb/README.md10
-rw-r--r--openai_rev/theb/__init__.py52
-rw-r--r--openai_rev/theb/theb_test.py4
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)