From bd893a45991c2f214bef556071623cc9c2449fdf Mon Sep 17 00:00:00 2001 From: killua4396 <1223086337@qq.com> Date: Mon, 13 May 2024 15:14:54 +0800 Subject: [PATCH] =?UTF-8?q?update:=20=E6=9B=B4=E6=96=B0=E7=A8=8B=E5=BA=8F?= =?UTF-8?q?=EF=BC=8C=E5=A2=9E=E5=8A=A0=E4=BA=86=E5=B9=B6=E5=8F=91=E6=B5=8B?= =?UTF-8?q?=E8=AF=95=E7=A8=8B=E5=BA=8F?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- tests/integration_test/backend_test.py | 33 +++------------- tests/unit_test/character_test.py | 9 ++++- tests/unit_test/chat_test.py | 12 +++--- tests/unit_test/concurrent_chat_test.py | 12 ++++++ tests/unit_test/user_test.py | 52 +++++++++++++++++++++++-- 5 files changed, 79 insertions(+), 39 deletions(-) create mode 100644 tests/unit_test/concurrent_chat_test.py diff --git a/tests/integration_test/backend_test.py b/tests/integration_test/backend_test.py index a85f79e..d33eefc 100644 --- a/tests/integration_test/backend_test.py +++ b/tests/integration_test/backend_test.py @@ -1,31 +1,10 @@ -from tests.unit_test.user_test import UserServiceTest -from tests.unit_test.character_test import CharacterServiceTest -from tests.unit_test.chat_test import ChatServiceTest +from tests.unit_test.user_test import user_test +from tests.unit_test.character_test import character_test +from tests.unit_test.chat_test import chat_test import asyncio if __name__ == '__main__': - user_service_test = UserServiceTest() - character_service_test = CharacterServiceTest() - chat_service_test = ChatServiceTest() - - user_service_test.test_user_create() - user_service_test.test_user_update() - user_service_test.test_user_query() - user_service_test.test_hardware_bind() - user_service_test.test_hardware_unbind() - user_service_test.test_user_delete() - - character_service_test.test_character_create() - character_service_test.test_character_update() - character_service_test.test_character_query() - character_service_test.test_character_delete() - - chat_service_test.test_create_chat() - chat_service_test.test_session_id_query() - chat_service_test.test_session_content_query() - chat_service_test.test_session_update() - asyncio.run(chat_service_test.test_chat_temporary()) - asyncio.run(chat_service_test.test_chat_lasting()) - asyncio.run(chat_service_test.test_voice_call()) - chat_service_test.test_chat_delete() + user_test() + character_test() + chat_test() print("全部测试成功") \ No newline at end of file diff --git a/tests/unit_test/character_test.py b/tests/unit_test/character_test.py index 740897e..638442e 100644 --- a/tests/unit_test/character_test.py +++ b/tests/unit_test/character_test.py @@ -66,9 +66,14 @@ class CharacterServiceTest: else: raise Exception("角色删除测试失败") -if __name__ == '__main__': + +def character_test(): character_service_test = CharacterServiceTest() character_service_test.test_character_create() character_service_test.test_character_update() character_service_test.test_character_query() - character_service_test.test_character_delete() \ No newline at end of file + character_service_test.test_character_delete() + + +if __name__ == '__main__': + character_test() \ No newline at end of file diff --git a/tests/unit_test/chat_test.py b/tests/unit_test/chat_test.py index 3ffa262..030a92d 100644 --- a/tests/unit_test/chat_test.py +++ b/tests/unit_test/chat_test.py @@ -292,7 +292,6 @@ class ChatServiceTest: async with websockets.connect(url) as websocket: await asyncio.gather(audio_stream(websocket)) - #测试删除聊天 def test_chat_delete(self): @@ -312,18 +311,19 @@ class ChatServiceTest: response = requests.request("DELETE", url) if response.status_code != 200: raise Exception("角色删除测试失败") - -if __name__ == '__main__': + +def chat_test(): chat_service_test = ChatServiceTest() chat_service_test.test_create_chat() chat_service_test.test_session_id_query() chat_service_test.test_session_content_query() chat_service_test.test_session_update() asyncio.run(chat_service_test.test_chat_temporary()) - asyncio.run(chat_service_test.test_chat_lasting()) - asyncio.run(chat_service_test.test_voice_call()) + # asyncio.run(chat_service_test.test_chat_lasting()) + # asyncio.run(chat_service_test.test_voice_call()) chat_service_test.test_chat_delete() - +if __name__ == '__main__': + chat_test() \ No newline at end of file diff --git a/tests/unit_test/concurrent_chat_test.py b/tests/unit_test/concurrent_chat_test.py new file mode 100644 index 0000000..9ae5288 --- /dev/null +++ b/tests/unit_test/concurrent_chat_test.py @@ -0,0 +1,12 @@ +from chat_test import chat_test +import multiprocessing + +if __name__ == '__main__': + processes = [] + for _ in range(2): + p = multiprocessing.Process(target=chat_test) + processes.append(p) + p.start() + + for p in processes: + p.join() \ No newline at end of file diff --git a/tests/unit_test/user_test.py b/tests/unit_test/user_test.py index 2884f92..73f8f25 100644 --- a/tests/unit_test/user_test.py +++ b/tests/unit_test/user_test.py @@ -66,7 +66,7 @@ class UserServiceTest: mac = "08:00:20:0A:8C:6G" payload = json.dumps({ "mac":mac, - "user_id":1, + "user_id":self.id, "firmware":"v1.0", "model":"香橙派" }) @@ -87,13 +87,57 @@ class UserServiceTest: print("硬件解绑测试成功") else: raise Exception("硬件解绑测试失败") - -if __name__ == '__main__': + + def test_hardware_bind_change(self): + url = f"{self.socket}/users/hardware/{self.hd_id}/bindchange" + payload = json.dumps({ + "user_id" : self.id + }) + headers = { + 'Content-Type': 'application/json' + } + response = requests.request("PUT", url, headers=headers, data=payload) + if response.status_code == 200: + print("硬件换绑测试成功") + else: + raise Exception("硬件换绑测试失败") + + def test_hardware_update(self): + url = f"{self.socket}/users/hardware/{self.hd_id}/info" + payload = json.dumps({ + "mac":"08:00:20:0A:8C:6G", + "firmware":"v1.0", + "model":"香橙派" + }) + headers = { + 'Content-Type': 'application/json' + } + response = requests.request("PUT", url, headers=headers, data=payload) + if response.status_code == 200: + print("硬件信息更新测试成功") + else: + raise Exception("硬件信息更新测试失败") + + def test_hardware_query(self): + url = f"{self.socket}/users/hardware/{self.hd_id}" + response = requests.request("GET", url) + if response.status_code == 200: + print("硬件查询测试成功") + else: + raise Exception("硬件查询测试失败") + +def user_test(): user_service_test = UserServiceTest() user_service_test.test_user_create() user_service_test.test_user_update() user_service_test.test_user_query() user_service_test.test_hardware_bind() + user_service_test.test_hardware_bind_change() + user_service_test.test_hardware_update() + user_service_test.test_hardware_query() user_service_test.test_hardware_unbind() user_service_test.test_user_delete() - \ No newline at end of file + + +if __name__ == '__main__': + user_test() \ No newline at end of file