Remove all embedding tests that require downloading the model for fas…

…ter testing

Signed-off-by: SimFG <[email protected]>

gptcache/adapter/openai.py

@@ -1,30 +1,28 @@
-import json
-from typing import Any, AsyncGenerator, Iterator, List, Mapping
-from deprecated import deprecated
+from typing import Any, AsyncGenerator, Iterator
 
 from gptcache import cache
-from gptcache.adapter.adapter import aadapt, adapt
-from gptcache.adapter.base import BaseCacheLLM
+from gptcache.adapter.adapter import adapt
 from gptcache.manager.scalar_data.base import Answer, DataType
-from gptcache.utils import import_openai, import_pillow
+from gptcache.utils import import_openai
 from gptcache.utils.error import wrap_error
 from gptcache.utils.response import (
-    get_audio_text_from_openai_answer,
-    get_image_from_openai_b64,
-    get_image_from_openai_url,
-    get_message_from_openai_answer,
+    # get_audio_text_from_openai_answer,
+    # get_image_from_openai_b64,
+    # get_image_from_openai_url,
+    # get_message_from_openai_answer,
     get_message_from_openai_answer2,
     get_stream_message_from_openai_answer,
-    get_stream_message_from_openai_answer2,
-    get_text_from_openai_answer,
+    # get_stream_message_from_openai_answer2,
+    # get_text_from_openai_answer,
 )
 from gptcache.utils.token import token_counter
 from ._util import (
-    _construct_audio_text_from_cache,
-    _construct_image_create_resp_from_cache,
+    # _construct_audio_text_from_cache,
+    # _construct_image_create_resp_from_cache,
     _construct_resp_from_cache,
     _construct_stream_resp_from_cache,
-    _construct_text_from_cache, _num_tokens_from_messages
+    # _construct_text_from_cache,
+    _num_tokens_from_messages,
 )
 
 import_openai()

gptcache/embedding/openai.py

@@ -9,6 +9,8 @@
 
 import openai  # pylint: disable=C0413
 
+# TODO should adapt to the new openai library
+
 class OpenAI(BaseEmbedding):
     """Generate text embedding for given text using OpenAI.
 

tests/integration_tests/examples/map/test_example_map.py

@@ -34,7 +34,11 @@ def test_map():
         )
 
     expect_answer = "receiver the foo 15"
-    answer = openai.ChatCompletion.create(
+    from openai import OpenAI
+    answer = openai.cache_openai_chat_complete(
+        OpenAI(
+            api_key="API_KEY",
+        ),
         model="gpt-3.5-turbo",
         messages=mock_messages,
     )
@@ -48,7 +52,10 @@ def test_map():
         data_manager=get_data_manager(data_path=data_file, max_size=10),
         next_cache=bak_cache2,
     )
-    answer = openai.ChatCompletion.create(
+    answer = openai.cache_openai_chat_complete(
+        OpenAI(
+            api_key="API_KEY",
+        ),
         model="gpt-3.5-turbo",
         messages=mock_messages,
     )

tests/integration_tests/examples/sqlite_faiss_mock/test_example_sqlite_faiss.py

@@ -43,7 +43,11 @@ def test_sqlite_faiss():
         [f"foo{i}" for i in range(10)], [f"receiver the foo {i}" for i in range(10)]
     )
 
-    answer = openai.ChatCompletion.create(
+    from openai import OpenAI
+    answer = openai.cache_openai_chat_complete(
+        OpenAI(
+            api_key="API_KEY",
+        ),
         model="gpt-3.5-turbo",
         messages=mock_messages,
     )
@@ -60,7 +64,10 @@ def test_sqlite_faiss():
             similarity_threshold=0,
         ),
     )
-    answer = openai.ChatCompletion.create(
+    answer = openai.cache_openai_chat_complete(
+        OpenAI(
+            api_key="API_KEY",
+        ),
         model="gpt-3.5-turbo",
         messages=mock_messages,
     )

tests/integration_tests/examples/sqlite_faiss_onnx/test_example_sqlite_faiss_onnx.py

@@ -41,7 +41,12 @@ def log_time_func(func_name, delta_time):
     ]
 
     start_time = time.time()
-    answer = openai.ChatCompletion.create(
+    from openai import OpenAI
+    openai_client = OpenAI(
+        api_key="API_KEY",
+    )
+    answer = openai.cache_openai_chat_complete(
+        openai_client,
         model="gpt-3.5-turbo",
         messages=mock_messages,
     )
@@ -51,7 +56,8 @@ def log_time_func(func_name, delta_time):
 
     is_exception = False
     try:
-        openai.ChatCompletion.create(
+        openai.cache_openai_chat_complete(
+            openai_client,
             model="gpt-3.5-turbo",
             messages=mock_messages,
             cache_factor=100,
@@ -67,7 +73,8 @@ def log_time_func(func_name, delta_time):
     ]
     is_exception = False
     try:
-        openai.ChatCompletion.create(
+        openai.cache_openai_chat_complete(
+            openai_client,
             model="gpt-3.5-turbo",
             messages=mock_messages,
         )
@@ -78,7 +85,8 @@ def log_time_func(func_name, delta_time):
 
     is_exception = False
     try:
-        openai.ChatCompletion.create(
+        openai.cache_openai_chat_complete(
+            openai_client,
             model="gpt-3.5-turbo",
             messages=mock_messages,
             cache_factor=0.5,

tests/integration_tests/processor/pre/test_pre_without_prompt.py

@@ -22,7 +22,9 @@ def test_pre_without_prompt():
             [f"receiver the foo {i}" for i in range(10)],
         )
 
-    answer = openai.ChatCompletion.create(
+    from openai import OpenAI
+    answer = openai.cache_openai_chat_complete(
+        OpenAI(),
         model="gpt-3.5-turbo",
         messages=[
             {"role": "system", "content": "You are a helpful assistant."},

tests/integration_tests/test_redis_onnx.py

@@ -36,34 +36,14 @@ def test_redis_sqlite():
         )
         question = "what's github"
         expect_answer = "GitHub is an online platform used primarily for version control and coding collaborations."
-        with patch("openai.ChatCompletion.create") as mock_create:
-            datas = {
-                "choices": [
-                    {
-                        "message": {"content": expect_answer, "role": "assistant"},
-                        "finish_reason": "stop",
-                        "index": 0,
-                    }
-                ],
-                "created": 1677825464,
-                "id": "chatcmpl-6ptKyqKOGXZT6iQnqiXAH8adNLUzD",
-                "model": "gpt-3.5-turbo-0301",
-                "object": "chat.completion.chunk",
-            }
-            mock_create.return_value = datas
 
-            response = openai.ChatCompletion.create(
-                model="gpt-3.5-turbo",
-                messages=[
-                    {"role": "system", "content": "You are a helpful assistant."},
-                    {"role": "user", "content": question},
-                ],
-                cache_obj=redis_cache,
-            )
+        redis_cache.data_manager.save(question, expect_answer, redis_cache.embedding_func(question))
 
-            assert get_message_from_openai_answer(response) == expect_answer, response
-
-        response = openai.ChatCompletion.create(
+        from openai import OpenAI
+        response = openai.cache_openai_chat_complete(
+            OpenAI(
+                api_key="API_KEY",
+            ),
             model="gpt-3.5-turbo",
             messages=[
                 {"role": "system", "content": "You are a helpful assistant."},

tests/integration_tests/test_sqlite_faiss_onnx.py

@@ -68,7 +68,11 @@ def test_no_openai_key(self):
 
         is_exception = False
         try:
-            openai.ChatCompletion.create(
+            from openai import OpenAI
+            openai.cache_openai_chat_complete(
+                OpenAI(
+                    api_key="API_KEY",
+                ),
                 model="gpt-3.5-turbo",
                 messages=[
                     {"role": "system", "content": "You are a helpful assistant."},
@@ -114,7 +118,11 @@ def test_hit_default(self):
         answer = "chatgpt is a good application"
         cache.data_manager.save(question, answer, cache.embedding_func(question))
 
-        openai.ChatCompletion.create(
+        from openai import OpenAI
+        openai.cache_openai_chat_complete(
+            OpenAI(
+                api_key="API_KEY",
+            ),
             model="gpt-3.5-turbo",
             messages=[
                 {"role": "system", "content": "You are a helpful assistant."},
@@ -147,7 +155,11 @@ def test_hit(self):
         answer = "chatgpt is a good application"
         cache.data_manager.save(question, answer, cache.embedding_func(question))
 
-        openai.ChatCompletion.create(
+        from openai import OpenAI
+        openai.cache_openai_chat_complete(
+            OpenAI(
+                api_key="API_KEY",
+            ),
             model="gpt-3.5-turbo",
             messages=[
                 {"role": "system", "content": "You are a helpful assistant."},
@@ -181,7 +193,11 @@ def test_miss(self):
 
         is_exception = False
         try:
-            openai.ChatCompletion.create(
+            from openai import OpenAI
+            openai.cache_openai_chat_complete(
+                OpenAI(
+                    api_key="API_KEY",
+                ),
                 model="gpt-3.5-turbo",
                 messages=[
                     {"role": "system", "content": "You are a helpful assistant."},
@@ -221,7 +237,11 @@ def test_disable_cache(self):
 
         is_exception = False
         try:
-            openai.ChatCompletion.create(
+            from openai import OpenAI
+            openai.cache_openai_chat_complete(
+                OpenAI(
+                    api_key="API_KEY",
+                ),
                 model="gpt-3.5-turbo",
                 messages=[
                     {"role": "system", "content": "You are a helpful assistant."},