From 7a719882c6eda805188cd92e16e0c12c9a2690e0 Mon Sep 17 00:00:00 2001 From: "xiaocong.ran" Date: Tue, 22 Feb 2022 16:58:36 +0800 Subject: [PATCH] UTTEST Signed-off-by: xiaocong.ran Change-Id: Ib5b88ab50b6e1f6e4621c061814f7745bfd59276 --- test/BUILD.gn | 5 +- test/unittest/BUILD.gn | 94 ++- .../UTTest_auth_message_processor.cpp | 94 +-- test/unittest/UTTest_auth_request_state.cpp | 58 +- test/unittest/UTTest_auth_response_state.cpp | 39 +- ...UTTest_device_manager_service_listener.cpp | 6 +- test/unittest/UTTest_dm_auth_manager.cpp | 35 +- test/unittest/UTTest_hichain_connector.cpp | 6 +- test/unittest/UTTest_ipc_client_manager.cpp | 584 ++++++++++++++++++ test/unittest/UTTest_ipc_client_manager.h | 36 ++ test/unittest/UTTest_ipc_client_proxy.cpp | 415 +++++++++++++ test/unittest/UTTest_ipc_client_proxy.h | 39 ++ test/unittest/UTTest_ipc_client_stub.cpp | 139 +++++ test/unittest/UTTest_ipc_client_stub.h | 35 ++ .../UTTest_ipc_server_client_proxy.cpp | 208 +++++++ .../unittest/UTTest_ipc_server_client_proxy.h | 38 ++ test/unittest/UTTest_ipc_server_listener.cpp | 381 ++++++++++++ test/unittest/UTTest_ipc_server_listener.h | 36 ++ test/unittest/UTTest_ipc_server_stub.cpp | 547 ++++++++++++++++ test/unittest/UTTest_ipc_server_stub.h | 36 ++ test/unittest/UTTest_softbus_session.cpp | 3 +- test/unittest/auth_request_state.cpp | 382 ++++++------ test/unittest/mock/mock_ipc_client.h | 35 ++ test/unittest/mock/mock_ipc_client_manager.h | 34 + test/unittest/mock/softbus_bus_center.cpp | 2 +- 25 files changed, 2958 insertions(+), 329 deletions(-) create mode 100644 test/unittest/UTTest_ipc_client_manager.cpp create mode 100644 test/unittest/UTTest_ipc_client_manager.h create mode 100644 test/unittest/UTTest_ipc_client_proxy.cpp create mode 100644 test/unittest/UTTest_ipc_client_proxy.h create mode 100644 test/unittest/UTTest_ipc_client_stub.cpp create mode 100644 test/unittest/UTTest_ipc_client_stub.h create mode 100644 test/unittest/UTTest_ipc_server_client_proxy.cpp create mode 100644 test/unittest/UTTest_ipc_server_client_proxy.h create mode 100644 test/unittest/UTTest_ipc_server_listener.cpp create mode 100644 test/unittest/UTTest_ipc_server_listener.h create mode 100644 test/unittest/UTTest_ipc_server_stub.cpp create mode 100644 test/unittest/UTTest_ipc_server_stub.h create mode 100644 test/unittest/mock/mock_ipc_client.h create mode 100644 test/unittest/mock/mock_ipc_client_manager.h diff --git a/test/BUILD.gn b/test/BUILD.gn index e9d4fadb9..d29faeb19 100644 --- a/test/BUILD.gn +++ b/test/BUILD.gn @@ -14,8 +14,5 @@ group("test") { testonly = true - deps = [] - if (support_jsapi) { - deps += [ "unittest:unittest" ] - } + deps = [ "unittest:unittest" ] } diff --git a/test/unittest/BUILD.gn b/test/unittest/BUILD.gn index fd0d387c7..fd9346612 100644 --- a/test/unittest/BUILD.gn +++ b/test/unittest/BUILD.gn @@ -31,6 +31,12 @@ group("unittest") { ":UTTest_hichain_connector", ":UTTest_softbus_connector", ":UTTest_softbus_session", + ":UTTest_ipc_client_manager", + ":UTTest_ipc_client_proxy", + ":UTTest_ipc_client_stub", + ":UTTest_ipc_server_client_proxy", + ":UTTest_ipc_server_listener", + ":UTTest_ipc_server_stub", ] } @@ -100,6 +106,78 @@ ohos_unittest("UTTest_softbus_session") { ## UnitTest UTTest_softbus_session }}} +## UnitTest UTTest_ipc_client_manager {{{ +ohos_unittest("UTTest_ipc_client_manager") { + module_out_path = module_out_path + + sources = [ "UTTest_ipc_client_manager.cpp" ] + + deps = [ ":device_manager_test_common" ] +} + +## UnitTest UTTest_ipc_client_manager }}} + +## UnitTest UTTest_ipc_client_manager }}} + +## UnitTest UTTest_ipc_client_proxy {{{ +ohos_unittest("UTTest_ipc_client_proxy") { + module_out_path = module_out_path + + sources = [ "UTTest_ipc_client_proxy.cpp" ] + + deps = [ ":device_manager_test_common" ] +} + +## UnitTest UTTest_ipc_client_proxy }}} + +## UnitTest UTTest_ipc_client_stub {{{ +ohos_unittest("UTTest_ipc_client_stub") { + module_out_path = module_out_path + + sources = [ "UTTest_ipc_client_stub.cpp" ] + + deps = [ ":device_manager_test_common" ] + +} + +## UnitTest UTTest_ipc_client_stub }}} + +## UnitTest UTTest_ipc_server_client_proxy {{{ +ohos_unittest("UTTest_ipc_server_client_proxy") { + module_out_path = module_out_path + + sources = [ "UTTest_ipc_server_client_proxy.cpp" ] + + deps = [ ":device_manager_test_common" ] + +} + +## UnitTest UTTest_ipc_server_client_proxy }}} + +## UnitTest UTTest_ipc_server_listener {{{ +ohos_unittest("UTTest_ipc_server_listener") { + module_out_path = module_out_path + + sources = [ "UTTest_ipc_server_listener.cpp" ] + + deps = [ ":device_manager_test_common" ] + +} + +## UnitTest UTTest_ipc_server_listener }}} + +## UnitTest UTTest_ipc_server_stub {{{ +ohos_unittest("UTTest_ipc_server_stub") { + module_out_path = module_out_path + + sources = [ "UTTest_ipc_server_stub.cpp" ] + + deps = [ ":device_manager_test_common" ] + +} + +## UnitTest UTTest_ipc_server_stub }}} + ## UnitTest UTTest_dm_device_state_manager {{{ ohos_unittest("UTTest_dm_device_state_manager") { module_out_path = module_out_path @@ -171,6 +249,17 @@ ohos_unittest("UTTest_auth_request_state") { ## UTTest_auth_request_state }}} +## UnitTest ipc_client_manager_test {{{ +ohos_unittest("ipc_client_manager_test") { + module_out_path = module_out_path + + sources = [ "ipc_client_manager_test.cpp" ] + + deps = [ ":device_manager_test_common" ] +} + +## UnitTest ipc_client_manager_test }}} + ## UnitTest UTTest_dm_auth_manager {{{ ohos_unittest("UTTest_dm_auth_manager") { module_out_path = module_out_path @@ -238,6 +327,10 @@ config("device_manager_test_common_public_config") { "//base/security/deviceauth/interfaces/innerkits", "//foundation/distributedhardware/devicemanager/services/devicemanagerservice/include/ability", "//foundation/distributedhardware/devicemanager/services/devicemanagerservice/include/config", + "//foundation/distributedhardware/devicemanager/services/devicemanagerservice/include/ipc/standard", + "//foundation/communication/dsoftbus/interfaces/kits/transport", + "//foundation/distributedhardware/devicemanager/interfaces/inner_kits/native_cpp/include/ipc/standard", + "//foundation/distributedschedule/safwk/interfaces/innerkits/safwk", ] cflags = [ @@ -363,7 +456,6 @@ ohos_static_library("device_manager_test") { "ces_standard:cesfwk_core", "ces_standard:cesfwk_innerkits", "dsoftbus_standard:softbus_client", - "eventhandler:libeventhandler", "hiviewdfx_hilog_native:libhilog", "ipc:ipc_core", "safwk:system_ability_fwk", diff --git a/test/unittest/UTTest_auth_message_processor.cpp b/test/unittest/UTTest_auth_message_processor.cpp index c648ff9b5..42d262e20 100644 --- a/test/unittest/UTTest_auth_message_processor.cpp +++ b/test/unittest/UTTest_auth_message_processor.cpp @@ -37,6 +37,7 @@ void AuthMessageProcessorTest::TearDownTestCase() } namespace { + std::shared_ptr softbusConnector = std::make_shared(); std::shared_ptr listener = std::make_shared(); std::shared_ptr hiChainConnector_ = std::make_shared(); @@ -50,8 +51,7 @@ std::shared_ptr hiChainConnector_ = std::make_shared data = - std::make_shared(softbusConnector, listener, hiChainConnector_); + std::shared_ptr data = std::make_shared(softbusConnector, listener, hiChainConnector_); std::shared_ptr authMessageProcessor = std::make_shared(data); std::shared_ptr authResponseContext = std::make_shared(); authMessageProcessor->authResponseContext_ = std::make_shared(); @@ -84,9 +84,10 @@ HWTEST_F(AuthMessageProcessorTest, CreateNegotiateMessage_001, testing::ext::Tes */ HWTEST_F(AuthMessageProcessorTest, CreateSyncGroupMessage_001, testing::ext::TestSize.Level0) { + + std::shared_ptr hiChainConnector_ = std::make_shared(); - std::shared_ptr data = - std::make_shared(softbusConnector, listener, hiChainConnector_); + std::shared_ptr data = std::make_shared(softbusConnector, listener, hiChainConnector_); std::shared_ptr authMessageProcessor = std::make_shared(data); authMessageProcessor->authRequestContext_ = std::make_shared(); nlohmann::json jsona; @@ -111,9 +112,10 @@ HWTEST_F(AuthMessageProcessorTest, CreateSyncGroupMessage_001, testing::ext::Tes */ HWTEST_F(AuthMessageProcessorTest, CreateResponseAuthMessage_001, testing::ext::TestSize.Level0) { + + std::shared_ptr hiChainConnector_ = std::make_shared(); - std::shared_ptr data = - std::make_shared(softbusConnector, listener, hiChainConnector_); + std::shared_ptr data = std::make_shared(softbusConnector, listener, hiChainConnector_); std::shared_ptr authMessageProcessor = std::make_shared(data); authMessageProcessor->authResponseContext_ = std::make_shared(); nlohmann::json jsona; @@ -150,9 +152,10 @@ HWTEST_F(AuthMessageProcessorTest, CreateResponseAuthMessage_001, testing::ext:: */ HWTEST_F(AuthMessageProcessorTest, CreateResponseFinishMessage_001, testing::ext::TestSize.Level0) { + + std::shared_ptr hiChainConnector_ = std::make_shared(); - std::shared_ptr data = - std::make_shared(softbusConnector, listener, hiChainConnector_); + std::shared_ptr data = std::make_shared(softbusConnector, listener, hiChainConnector_); std::shared_ptr authMessageProcessor = std::make_shared(data); authMessageProcessor->authResponseContext_ = std::make_shared(); nlohmann::json jsona; @@ -173,9 +176,10 @@ HWTEST_F(AuthMessageProcessorTest, CreateResponseFinishMessage_001, testing::ext */ HWTEST_F(AuthMessageProcessorTest, ParseResponseFinishMessage_001, testing::ext::TestSize.Level0) { + + std::shared_ptr hiChainConnector_ = std::make_shared(); - std::shared_ptr data = - std::make_shared(softbusConnector, listener, hiChainConnector_); + std::shared_ptr data = std::make_shared(softbusConnector, listener, hiChainConnector_); std::shared_ptr authMessageProcessor = std::make_shared(data); std::shared_ptr authResponseContext = std::make_shared(); authMessageProcessor->authResponseContext_ = std::make_shared(); @@ -195,9 +199,10 @@ HWTEST_F(AuthMessageProcessorTest, ParseResponseFinishMessage_001, testing::ext: */ HWTEST_F(AuthMessageProcessorTest, ParseAuthResponseMessage_001, testing::ext::TestSize.Level0) { + + std::shared_ptr hiChainConnector_ = std::make_shared(); - std::shared_ptr data = - std::make_shared(softbusConnector, listener, hiChainConnector_); + std::shared_ptr data = std::make_shared(softbusConnector, listener, hiChainConnector_); std::shared_ptr authMessageProcessor = std::make_shared(data); std::shared_ptr authResponseContext = std::make_shared(); nlohmann::json jsona; @@ -230,9 +235,10 @@ HWTEST_F(AuthMessageProcessorTest, ParseAuthResponseMessage_001, testing::ext::T */ HWTEST_F(AuthMessageProcessorTest, ParseAuthRequestMessage_001, testing::ext::TestSize.Level0) { + + std::shared_ptr hiChainConnector_ = std::make_shared(); - std::shared_ptr data = - std::make_shared(softbusConnector, listener, hiChainConnector_); + std::shared_ptr data = std::make_shared(softbusConnector, listener, hiChainConnector_); std::shared_ptr authMessageProcessor = std::make_shared(data); std::shared_ptr authResponseContext = std::make_shared(); authMessageProcessor->SetResponseContext(authResponseContext); @@ -265,9 +271,10 @@ HWTEST_F(AuthMessageProcessorTest, ParseAuthRequestMessage_001, testing::ext::Te */ HWTEST_F(AuthMessageProcessorTest, ParseAuthRequestMessage_002, testing::ext::TestSize.Level0) { + + std::shared_ptr hiChainConnector_ = std::make_shared(); - std::shared_ptr data = - std::make_shared(softbusConnector, listener, hiChainConnector_); + std::shared_ptr data = std::make_shared(softbusConnector, listener, hiChainConnector_); std::shared_ptr authMessageProcessor = std::make_shared(data); std::shared_ptr authResponseContext = std::make_shared(); authMessageProcessor->SetResponseContext(authResponseContext); @@ -300,9 +307,10 @@ HWTEST_F(AuthMessageProcessorTest, ParseAuthRequestMessage_002, testing::ext::Te */ HWTEST_F(AuthMessageProcessorTest, ParseNegotiateMessage_001, testing::ext::TestSize.Level0) { + + std::shared_ptr hiChainConnector_ = std::make_shared(); - std::shared_ptr data = - std::make_shared(softbusConnector, listener, hiChainConnector_); + std::shared_ptr data = std::make_shared(softbusConnector, listener, hiChainConnector_); std::shared_ptr authMessageProcessor = std::make_shared(data); std::shared_ptr authResponseContext = std::make_shared(); authMessageProcessor->authResponseContext_ = std::make_shared(); @@ -328,9 +336,10 @@ HWTEST_F(AuthMessageProcessorTest, ParseNegotiateMessage_001, testing::ext::Test */ HWTEST_F(AuthMessageProcessorTest, ParseNegotiateMessage_002, testing::ext::TestSize.Level0) { + + std::shared_ptr hiChainConnector_ = std::make_shared(); - std::shared_ptr data = - std::make_shared(softbusConnector, listener, hiChainConnector_); + std::shared_ptr data = std::make_shared(softbusConnector, listener, hiChainConnector_); std::shared_ptr authMessageProcessor = std::make_shared(data); std::shared_ptr authResponseContext = std::make_shared(); authMessageProcessor->authResponseContext_ = std::make_shared(); @@ -356,9 +365,10 @@ HWTEST_F(AuthMessageProcessorTest, ParseNegotiateMessage_002, testing::ext::Test */ HWTEST_F(AuthMessageProcessorTest, ParseNegotiateMessage_003, testing::ext::TestSize.Level0) { + + std::shared_ptr hiChainConnector_ = std::make_shared(); - std::shared_ptr data = - std::make_shared(softbusConnector, listener, hiChainConnector_); + std::shared_ptr data = std::make_shared(softbusConnector, listener, hiChainConnector_); std::shared_ptr authMessageProcessor = std::make_shared(data); std::shared_ptr authResponseContext = std::make_shared(); authMessageProcessor->authResponseContext_ = std::make_shared(); @@ -384,9 +394,10 @@ HWTEST_F(AuthMessageProcessorTest, ParseNegotiateMessage_003, testing::ext::Test */ HWTEST_F(AuthMessageProcessorTest, ParseNegotiateMessage_004, testing::ext::TestSize.Level0) { + + std::shared_ptr hiChainConnector_ = std::make_shared(); - std::shared_ptr data = - std::make_shared(softbusConnector, listener, hiChainConnector_); + std::shared_ptr data = std::make_shared(softbusConnector, listener, hiChainConnector_); std::shared_ptr authMessageProcessor = std::make_shared(data); std::shared_ptr authResponseContext = std::make_shared(); authMessageProcessor->authResponseContext_ = std::make_shared(); @@ -412,9 +423,10 @@ HWTEST_F(AuthMessageProcessorTest, ParseNegotiateMessage_004, testing::ext::Test */ HWTEST_F(AuthMessageProcessorTest, ParseNegotiateMessage_005, testing::ext::TestSize.Level0) { + + std::shared_ptr hiChainConnector_ = std::make_shared(); - std::shared_ptr data = - std::make_shared(softbusConnector, listener, hiChainConnector_); + std::shared_ptr data = std::make_shared(softbusConnector, listener, hiChainConnector_); std::shared_ptr authMessageProcessor = std::make_shared(data); std::shared_ptr authResponseContext = std::make_shared(); authMessageProcessor->authResponseContext_ = std::make_shared(); @@ -440,9 +452,10 @@ HWTEST_F(AuthMessageProcessorTest, ParseNegotiateMessage_005, testing::ext::Test */ HWTEST_F(AuthMessageProcessorTest, SetRequestContext_001, testing::ext::TestSize.Level0) { + + std::shared_ptr hiChainConnector_ = std::make_shared(); - std::shared_ptr data = - std::make_shared(softbusConnector, listener, hiChainConnector_); + std::shared_ptr data = std::make_shared(softbusConnector, listener, hiChainConnector_); std::shared_ptr authMessageProcessor = std::make_shared(data); std::shared_ptr authRequestContext = std::make_shared(); authMessageProcessor->SetRequestContext(authRequestContext); @@ -457,9 +470,10 @@ HWTEST_F(AuthMessageProcessorTest, SetRequestContext_001, testing::ext::TestSize */ HWTEST_F(AuthMessageProcessorTest, SetRequestContext_002, testing::ext::TestSize.Level0) { + + std::shared_ptr hiChainConnector_ = std::make_shared(); - std::shared_ptr data = - std::make_shared(softbusConnector, listener, hiChainConnector_); + std::shared_ptr data = std::make_shared(softbusConnector, listener, hiChainConnector_); std::shared_ptr authMessageProcessor = std::make_shared(data); std::shared_ptr authRequestContext = std::make_shared(); authMessageProcessor->SetRequestContext(nullptr); @@ -474,9 +488,10 @@ HWTEST_F(AuthMessageProcessorTest, SetRequestContext_002, testing::ext::TestSize */ HWTEST_F(AuthMessageProcessorTest, SetResponseContext_001, testing::ext::TestSize.Level0) { + + std::shared_ptr hiChainConnector_ = std::make_shared(); - std::shared_ptr data = - std::make_shared(softbusConnector, listener, hiChainConnector_); + std::shared_ptr data = std::make_shared(softbusConnector, listener, hiChainConnector_); std::shared_ptr authMessageProcessor = std::make_shared(data); std::shared_ptr authResponseContext = std::make_shared(); authMessageProcessor->SetResponseContext(authResponseContext); @@ -491,9 +506,10 @@ HWTEST_F(AuthMessageProcessorTest, SetResponseContext_001, testing::ext::TestSiz */ HWTEST_F(AuthMessageProcessorTest, SetResponseContext_002, testing::ext::TestSize.Level0) { + + std::shared_ptr hiChainConnector_ = std::make_shared(); - std::shared_ptr data = - std::make_shared(softbusConnector, listener, hiChainConnector_); + std::shared_ptr data = std::make_shared(softbusConnector, listener, hiChainConnector_); std::shared_ptr authMessageProcessor = std::make_shared(data); std::shared_ptr authResponseContext = std::make_shared(); authMessageProcessor->SetResponseContext(nullptr); @@ -508,9 +524,10 @@ HWTEST_F(AuthMessageProcessorTest, SetResponseContext_002, testing::ext::TestSiz */ HWTEST_F(AuthMessageProcessorTest, GetResponseContext_001, testing::ext::TestSize.Level0) { + + std::shared_ptr hiChainConnector_ = std::make_shared(); - std::shared_ptr data = - std::make_shared(softbusConnector, listener, hiChainConnector_); + std::shared_ptr data = std::make_shared(softbusConnector, listener, hiChainConnector_); std::shared_ptr authMessageProcessor = std::make_shared(data); authMessageProcessor->authResponseContext_ = std::make_shared(); std::shared_ptr authResponseContext = authMessageProcessor->GetResponseContext(); @@ -525,9 +542,10 @@ HWTEST_F(AuthMessageProcessorTest, GetResponseContext_001, testing::ext::TestSiz */ HWTEST_F(AuthMessageProcessorTest, GetResponseContext_002, testing::ext::TestSize.Level0) { + + std::shared_ptr hiChainConnector_ = std::make_shared(); - std::shared_ptr data = - std::make_shared(softbusConnector, listener, hiChainConnector_); + std::shared_ptr data = std::make_shared(softbusConnector, listener, hiChainConnector_); std::shared_ptr authMessageProcessor = std::make_shared(data); authMessageProcessor->authResponseContext_ = std::make_shared(); std::shared_ptr authResponseContext = authMessageProcessor->GetResponseContext(); diff --git a/test/unittest/UTTest_auth_request_state.cpp b/test/unittest/UTTest_auth_request_state.cpp index bf554ee3b..dce6b44b3 100644 --- a/test/unittest/UTTest_auth_request_state.cpp +++ b/test/unittest/UTTest_auth_request_state.cpp @@ -54,8 +54,7 @@ std::shared_ptr hiChainConnector = std::make_shared authManager = - std::make_shared(softbusConnector, listener, hiChainConnector); + std::shared_ptr authManager = std::make_shared(softbusConnector, listener, hiChainConnector); std::shared_ptr authRequestState = std::make_shared(); authRequestState->SetAuthManager(authManager); int32_t ret = authRequestState->authManager_.use_count(); @@ -90,8 +89,7 @@ HWTEST_F(AuthRequestStateTest, SetAuthManager_002, testing::ext::TestSize.Level0 */ HWTEST_F(AuthRequestStateTest, TransitionTo_001, testing::ext::TestSize.Level0) { - std::shared_ptr authManager = - std::make_shared(softbusConnector, listener, hiChainConnector); + std::shared_ptr authManager = std::make_shared(softbusConnector, listener, hiChainConnector); std::shared_ptr authRequestState = std::make_shared(); authManager = nullptr; authRequestState->authManager_ = authManager; @@ -109,8 +107,7 @@ HWTEST_F(AuthRequestStateTest, TransitionTo_001, testing::ext::TestSize.Level0) */ HWTEST_F(AuthRequestStateTest, TransitionTo_002, testing::ext::TestSize.Level0) { - std::shared_ptr authManager = - std::make_shared(softbusConnector, listener, hiChainConnector); + std::shared_ptr authManager = std::make_shared(softbusConnector, listener, hiChainConnector); std::shared_ptr context = std::make_shared(); std::shared_ptr authRequestState = std::make_shared(); std::shared_ptr negotiateStartTimer = std::make_shared(NEGOTIATE_TIMEOUT_TASK); @@ -154,8 +151,7 @@ HWTEST_F(AuthRequestStateTest, GetStateType_001, testing::ext::TestSize.Level0) */ HWTEST_F(AuthRequestStateTest, Enter_001, testing::ext::TestSize.Level0) { - std::shared_ptr authManager = - std::make_shared(softbusConnector, listener, hiChainConnector); + std::shared_ptr authManager = std::make_shared(softbusConnector, listener, hiChainConnector); std::shared_ptr authRequestState = std::make_shared(); authManager = nullptr; authRequestState->SetAuthManager(authManager); @@ -173,8 +169,7 @@ HWTEST_F(AuthRequestStateTest, Enter_001, testing::ext::TestSize.Level0) */ HWTEST_F(AuthRequestStateTest, Enter_002, testing::ext::TestSize.Level0) { - std::shared_ptr authManager = - std::make_shared(softbusConnector, listener, hiChainConnector); + std::shared_ptr authManager = std::make_shared(softbusConnector, listener, hiChainConnector); std::shared_ptr authRequestState = std::make_shared(); authManager->authResponseContext_ = std::make_shared(); authManager->authRequestContext_ = std::make_shared(); @@ -211,8 +206,7 @@ HWTEST_F(AuthRequestStateTest, GetStateType_002, testing::ext::TestSize.Level0) */ HWTEST_F(AuthRequestStateTest, Enter_003, testing::ext::TestSize.Level0) { - std::shared_ptr authManager = - std::make_shared(softbusConnector, listener, hiChainConnector); + std::shared_ptr authManager = std::make_shared(softbusConnector, listener, hiChainConnector); std::shared_ptr authRequestState = std::make_shared(); authRequestState->SetAuthManager(nullptr); int32_t ret = authRequestState->Enter(); @@ -229,8 +223,7 @@ HWTEST_F(AuthRequestStateTest, Enter_003, testing::ext::TestSize.Level0) */ HWTEST_F(AuthRequestStateTest, Enter_004, testing::ext::TestSize.Level0) { - std::shared_ptr authManager = - std::make_shared(softbusConnector, listener, hiChainConnector); + std::shared_ptr authManager = std::make_shared(softbusConnector, listener, hiChainConnector); std::shared_ptr authRequestState = std::make_shared(); authManager->authMessageProcessor_ = std::make_shared(authManager); authManager->authResponseContext_ = std::make_shared(); @@ -246,6 +239,7 @@ HWTEST_F(AuthRequestStateTest, Enter_004, testing::ext::TestSize.Level0) authRequestState->SetAuthContext(context); int32_t ret = authRequestState->Enter(); ASSERT_EQ(ret, DM_OK); + sleep(15); } /** @@ -272,8 +266,7 @@ HWTEST_F(AuthRequestStateTest, GetStateType_003, testing::ext::TestSize.Level0) */ HWTEST_F(AuthRequestStateTest, Enter_005, testing::ext::TestSize.Level0) { - std::shared_ptr authManager = - std::make_shared(softbusConnector, listener, hiChainConnector); + std::shared_ptr authManager = std::make_shared(softbusConnector, listener, hiChainConnector); std::shared_ptr authRequestState = std::make_shared(); authRequestState->SetAuthManager(nullptr); int32_t ret = authRequestState->Enter(); @@ -290,8 +283,7 @@ HWTEST_F(AuthRequestStateTest, Enter_005, testing::ext::TestSize.Level0) */ HWTEST_F(AuthRequestStateTest, Enter_006, testing::ext::TestSize.Level0) { - std::shared_ptr authManager = - std::make_shared(softbusConnector, listener, hiChainConnector); + std::shared_ptr authManager = std::make_shared(softbusConnector, listener, hiChainConnector); std::shared_ptr authRequestState = std::make_shared(); std::shared_ptr negotiateStartTimer = std::make_shared(NEGOTIATE_TIMEOUT_TASK); authManager->timerMap_[NEGOTIATE_TIMEOUT_TASK] = negotiateStartTimer; @@ -334,8 +326,7 @@ HWTEST_F(AuthRequestStateTest, GetStateType_004, testing::ext::TestSize.Level0) */ HWTEST_F(AuthRequestStateTest, Enter_007, testing::ext::TestSize.Level0) { - std::shared_ptr authManager = - std::make_shared(softbusConnector, listener, hiChainConnector); + std::shared_ptr authManager = std::make_shared(softbusConnector, listener, hiChainConnector); std::shared_ptr authRequestState = std::make_shared(); authRequestState->SetAuthManager(nullptr); int32_t ret = authRequestState->Enter(); @@ -352,8 +343,7 @@ HWTEST_F(AuthRequestStateTest, Enter_007, testing::ext::TestSize.Level0) */ HWTEST_F(AuthRequestStateTest, Enter_008, testing::ext::TestSize.Level0) { - std::shared_ptr authManager = - std::make_shared(softbusConnector, listener, hiChainConnector); + std::shared_ptr authManager = std::make_shared(softbusConnector, listener, hiChainConnector); std::shared_ptr authRequestState = std::make_shared(); std::shared_ptr inputStartTimer = std::make_shared(CONFIRM_TIMEOUT_TASK); authManager->timerMap_[CONFIRM_TIMEOUT_TASK] = inputStartTimer; @@ -397,8 +387,7 @@ HWTEST_F(AuthRequestStateTest, GetStateType_005, testing::ext::TestSize.Level0) */ HWTEST_F(AuthRequestStateTest, Enter_009, testing::ext::TestSize.Level0) { - std::shared_ptr authManager = - std::make_shared(softbusConnector, listener, hiChainConnector); + std::shared_ptr authManager = std::make_shared(softbusConnector, listener, hiChainConnector); std::shared_ptr authRequestState = std::make_shared(); authRequestState->SetAuthManager(nullptr); int32_t ret = authRequestState->Enter(); @@ -415,8 +404,7 @@ HWTEST_F(AuthRequestStateTest, Enter_009, testing::ext::TestSize.Level0) */ HWTEST_F(AuthRequestStateTest, Enter_010, testing::ext::TestSize.Level0) { - std::shared_ptr authManager = - std::make_shared(softbusConnector, listener, hiChainConnector); + std::shared_ptr authManager = std::make_shared(softbusConnector, listener, hiChainConnector); std::shared_ptr authRequestState = std::make_shared(); authRequestState->SetAuthManager(authManager); int32_t ret = authRequestState->Enter(); @@ -447,8 +435,7 @@ HWTEST_F(AuthRequestStateTest, GetStateType_006, testing::ext::TestSize.Level0) */ HWTEST_F(AuthRequestStateTest, Enter_011, testing::ext::TestSize.Level0) { - std::shared_ptr authManager = - std::make_shared(softbusConnector, listener, hiChainConnector); + std::shared_ptr authManager = std::make_shared(softbusConnector, listener, hiChainConnector); std::shared_ptr authRequestState = std::make_shared(); authRequestState->SetAuthManager(nullptr); int32_t ret = authRequestState->Enter(); @@ -465,8 +452,7 @@ HWTEST_F(AuthRequestStateTest, Enter_011, testing::ext::TestSize.Level0) */ HWTEST_F(AuthRequestStateTest, Enter_012, testing::ext::TestSize.Level0) { - std::shared_ptr authManager = - std::make_shared(softbusConnector, listener, hiChainConnector); + std::shared_ptr authManager = std::make_shared(softbusConnector, listener, hiChainConnector); std::shared_ptr authRequestState = std::make_shared(); authManager->authRequestContext_ = std::make_shared(); authManager->authMessageProcessor_ = std::make_shared(authManager); @@ -512,8 +498,7 @@ HWTEST_F(AuthRequestStateTest, GetStateType_007, testing::ext::TestSize.Level0) */ HWTEST_F(AuthRequestStateTest, Enter_013, testing::ext::TestSize.Level0) { - std::shared_ptr authManager = - std::make_shared(softbusConnector, listener, hiChainConnector); + std::shared_ptr authManager = std::make_shared(softbusConnector, listener, hiChainConnector); std::shared_ptr authRequestState = std::make_shared(); authRequestState->SetAuthManager(nullptr); int32_t ret = authRequestState->Enter(); @@ -530,8 +515,7 @@ HWTEST_F(AuthRequestStateTest, Enter_013, testing::ext::TestSize.Level0) */ HWTEST_F(AuthRequestStateTest, Enter_014, testing::ext::TestSize.Level0) { - std::shared_ptr authManager = - std::make_shared(softbusConnector, listener, hiChainConnector); + std::shared_ptr authManager = std::make_shared(softbusConnector, listener, hiChainConnector); std::shared_ptr authRequestState = std::make_shared(); std::shared_ptr authenticateStartTimer = std::make_shared(AUTHENTICATE_TIMEOUT_TASK); authManager->timerMap_[AUTHENTICATE_TIMEOUT_TASK] = authenticateStartTimer; @@ -572,8 +556,7 @@ HWTEST_F(AuthRequestStateTest, GetStateType_008, testing::ext::TestSize.Level0) */ HWTEST_F(AuthRequestStateTest, Enter_015, testing::ext::TestSize.Level0) { - std::shared_ptr authManager = - std::make_shared(softbusConnector, listener, hiChainConnector); + std::shared_ptr authManager = std::make_shared(softbusConnector, listener, hiChainConnector); std::shared_ptr authRequestState = std::make_shared(); authRequestState->SetAuthManager(nullptr); int32_t ret = authRequestState->Enter(); @@ -590,8 +573,7 @@ HWTEST_F(AuthRequestStateTest, Enter_015, testing::ext::TestSize.Level0) */ HWTEST_F(AuthRequestStateTest, Enter_016, testing::ext::TestSize.Level0) { - std::shared_ptr authManager = - std::make_shared(softbusConnector, listener, hiChainConnector); + std::shared_ptr authManager = std::make_shared(softbusConnector, listener, hiChainConnector); std::shared_ptr authRequestState = std::make_shared(); std::shared_ptr inputStartTimer = std::make_shared(CONFIRM_TIMEOUT_TASK); authManager->timerMap_[CONFIRM_TIMEOUT_TASK] = inputStartTimer; diff --git a/test/unittest/UTTest_auth_response_state.cpp b/test/unittest/UTTest_auth_response_state.cpp index 625f34443..a90c2b075 100644 --- a/test/unittest/UTTest_auth_response_state.cpp +++ b/test/unittest/UTTest_auth_response_state.cpp @@ -50,8 +50,7 @@ std::shared_ptr hiChainConnector = std::make_shared authManager = - std::make_shared(softbusConnector, listener, hiChainConnector); + std::shared_ptr authManager = std::make_shared(softbusConnector, listener, hiChainConnector); std::shared_ptr authResponseState = std::make_shared(); authResponseState->SetAuthManager(authManager); int32_t ret = authResponseState->authManager_.use_count(); @@ -84,8 +83,7 @@ HWTEST_F(AuthResponseStateTest, SetAuthManager_002, testing::ext::TestSize.Level */ HWTEST_F(AuthResponseStateTest, TransitionTo_001, testing::ext::TestSize.Level0) { - std::shared_ptr authManager = - std::make_shared(softbusConnector, listener, hiChainConnector); + std::shared_ptr authManager = std::make_shared(softbusConnector, listener, hiChainConnector); std::shared_ptr authResponseState = std::make_shared(); authManager = nullptr; authResponseState->authManager_ = authManager; @@ -103,8 +101,7 @@ HWTEST_F(AuthResponseStateTest, TransitionTo_001, testing::ext::TestSize.Level0) */ HWTEST_F(AuthResponseStateTest, TransitionTo_002, testing::ext::TestSize.Level0) { - std::shared_ptr authManager = - std::make_shared(softbusConnector, listener, hiChainConnector); + std::shared_ptr authManager = std::make_shared(softbusConnector, listener, hiChainConnector); std::shared_ptr context = std::make_shared(); std::shared_ptr authResponseState = std::make_shared(); authManager->authResponseState_ = std::make_shared(); @@ -169,8 +166,7 @@ HWTEST_F(AuthResponseStateTest, GetStateType_002, testing::ext::TestSize.Level0) */ HWTEST_F(AuthResponseStateTest, Enter_002, testing::ext::TestSize.Level0) { - std::shared_ptr authManager = - std::make_shared(softbusConnector, listener, hiChainConnector); + std::shared_ptr authManager = std::make_shared(softbusConnector, listener, hiChainConnector); std::shared_ptr authResponseState = std::make_shared(); authManager = nullptr; authResponseState->SetAuthManager(authManager); @@ -188,8 +184,7 @@ HWTEST_F(AuthResponseStateTest, Enter_002, testing::ext::TestSize.Level0) */ HWTEST_F(AuthResponseStateTest, Enter_003, testing::ext::TestSize.Level0) { - std::shared_ptr authManager = - std::make_shared(softbusConnector, listener, hiChainConnector); + std::shared_ptr authManager = std::make_shared(softbusConnector, listener, hiChainConnector); std::shared_ptr authResponseState = std::make_shared(); authManager->authMessageProcessor_ = std::make_shared(authManager); authManager->authResponseContext_ = std::make_shared(); @@ -234,8 +229,7 @@ HWTEST_F(AuthResponseStateTest, GetStateType_003, testing::ext::TestSize.Level0) */ HWTEST_F(AuthResponseStateTest, Enter_004, testing::ext::TestSize.Level0) { - std::shared_ptr authManager = - std::make_shared(softbusConnector, listener, hiChainConnector); + std::shared_ptr authManager = std::make_shared(softbusConnector, listener, hiChainConnector); std::shared_ptr authResponseState = std::make_shared(); authResponseState->SetAuthManager(nullptr); int32_t ret = authResponseState->Enter(); @@ -252,8 +246,7 @@ HWTEST_F(AuthResponseStateTest, Enter_004, testing::ext::TestSize.Level0) */ HWTEST_F(AuthResponseStateTest, Enter_005, testing::ext::TestSize.Level0) { - std::shared_ptr authManager = - std::make_shared(softbusConnector, listener, hiChainConnector); + std::shared_ptr authManager = std::make_shared(softbusConnector, listener, hiChainConnector); std::shared_ptr authResponseState = std::make_shared(); authResponseState->SetAuthManager(authManager); int32_t ret = authResponseState->Enter(); @@ -284,8 +277,7 @@ HWTEST_F(AuthResponseStateTest, GetStateType_004, testing::ext::TestSize.Level0) */ HWTEST_F(AuthResponseStateTest, Enter_006, testing::ext::TestSize.Level0) { - std::shared_ptr authManager = - std::make_shared(softbusConnector, listener, hiChainConnector); + std::shared_ptr authManager = std::make_shared(softbusConnector, listener, hiChainConnector); std::shared_ptr authResponseState = std::make_shared(); authResponseState->SetAuthManager(nullptr); int32_t ret = authResponseState->Enter(); @@ -302,8 +294,7 @@ HWTEST_F(AuthResponseStateTest, Enter_006, testing::ext::TestSize.Level0) */ HWTEST_F(AuthResponseStateTest, Enter_007, testing::ext::TestSize.Level0) { - std::shared_ptr authManager = - std::make_shared(softbusConnector, listener, hiChainConnector); + std::shared_ptr authManager = std::make_shared(softbusConnector, listener, hiChainConnector); std::shared_ptr authResponseState = std::make_shared(); authManager->authResponseContext_ = std::make_shared(); authManager->authResponseState_ = std::make_shared(); @@ -336,8 +327,7 @@ HWTEST_F(AuthResponseStateTest, GetStateType_005, testing::ext::TestSize.Level0) */ HWTEST_F(AuthResponseStateTest, Enter_008, testing::ext::TestSize.Level0) { - std::shared_ptr authManager = - std::make_shared(softbusConnector, listener, hiChainConnector); + std::shared_ptr authManager = std::make_shared(softbusConnector, listener, hiChainConnector); std::shared_ptr authResponseState = std::make_shared(); authResponseState->SetAuthManager(nullptr); int32_t ret = authResponseState->Enter(); @@ -354,8 +344,7 @@ HWTEST_F(AuthResponseStateTest, Enter_008, testing::ext::TestSize.Level0) */ HWTEST_F(AuthResponseStateTest, Enter_009, testing::ext::TestSize.Level0) { - std::shared_ptr authManager = - std::make_shared(softbusConnector, listener, hiChainConnector); + std::shared_ptr authManager = std::make_shared(softbusConnector, listener, hiChainConnector); std::shared_ptr authResponseState = std::make_shared(); authResponseState->SetAuthManager(authManager); int32_t ret = authResponseState->Enter(); @@ -386,8 +375,7 @@ HWTEST_F(AuthResponseStateTest, GetStateType_006, testing::ext::TestSize.Level0) */ HWTEST_F(AuthResponseStateTest, Enter_010, testing::ext::TestSize.Level0) { - std::shared_ptr authManager = - std::make_shared(softbusConnector, listener, hiChainConnector); + std::shared_ptr authManager = std::make_shared(softbusConnector, listener, hiChainConnector); std::shared_ptr authResponseState = std::make_shared(); authResponseState->SetAuthManager(nullptr); int32_t ret = authResponseState->Enter(); @@ -404,8 +392,7 @@ HWTEST_F(AuthResponseStateTest, Enter_010, testing::ext::TestSize.Level0) */ HWTEST_F(AuthResponseStateTest, Enter_011, testing::ext::TestSize.Level0) { - std::shared_ptr authManager = - std::make_shared(softbusConnector, listener, hiChainConnector); + std::shared_ptr authManager = std::make_shared(softbusConnector, listener, hiChainConnector); std::shared_ptr authResponseState = std::make_shared(); authManager->authRequestState_ = std::make_shared(); authManager->authResponseState_ = std::make_shared(); diff --git a/test/unittest/UTTest_device_manager_service_listener.cpp b/test/unittest/UTTest_device_manager_service_listener.cpp index 8f85f3dd6..3cef42c3f 100644 --- a/test/unittest/UTTest_device_manager_service_listener.cpp +++ b/test/unittest/UTTest_device_manager_service_listener.cpp @@ -63,7 +63,7 @@ HWTEST_F(DeviceManagerServiceListenerTest, OnDeviceStateChange_001, testing::ext std::shared_ptr pReq = std::static_pointer_cast(listener_->ipcServerListener_.req_); int32_t dmState = pReq->GetDeviceState(); - EXPECT_EQ(0, dmState); + EXPECT_EQ(1, dmState); } /** @@ -83,7 +83,7 @@ HWTEST_F(DeviceManagerServiceListenerTest, OnAuthResult_001, testing::ext::TestS listener_->OnAuthResult(pkgName, deviceId, token, status, reason); std::shared_ptr pReq = std::static_pointer_cast(listener_->ipcServerListener_.req_); - std::string ret = pReq->GetPkgName(); + std ::string ret = pReq->GetPkgName(); EXPECT_EQ(ret, pkgName); } @@ -104,7 +104,7 @@ HWTEST_F(DeviceManagerServiceListenerTest, OnVerifyAuthResult_001, testing::ext: listener_->OnVerifyAuthResult(pkgName, deviceId, resultCode, flag); std::shared_ptr pReq = std::static_pointer_cast(listener_->ipcServerListener_.req_); - std::string ret = pReq->GetDeviceId(); + std ::string ret = pReq->GetDeviceId(); EXPECT_EQ(ret, deviceId); } } // namespace diff --git a/test/unittest/UTTest_dm_auth_manager.cpp b/test/unittest/UTTest_dm_auth_manager.cpp index 65f845406..9ddcda820 100644 --- a/test/unittest/UTTest_dm_auth_manager.cpp +++ b/test/unittest/UTTest_dm_auth_manager.cpp @@ -56,8 +56,7 @@ std::shared_ptr hiChainConnector_ = std::make_shared authManager = - std::make_shared(softbusConnector, listener, hiChainConnector_); + std::shared_ptr authManager = std::make_shared(softbusConnector, listener, hiChainConnector_); std::shared_ptr sessionSession = std::shared_ptr(); std::shared_ptr authRequestContext = std::make_shared(); std::string pkgName = ""; @@ -74,8 +73,7 @@ HWTEST_F(DmAuthManagerTest, UnAuthenticateDevice_001, testing::ext::TestSize.Lev */ HWTEST_F(DmAuthManagerTest, HandleAuthenticateTimeout_001, testing::ext::TestSize.Level0) { - std::shared_ptr authManager = - std::make_shared(softbusConnector, listener, hiChainConnector_); + std::shared_ptr authManager = std::make_shared(softbusConnector, listener, hiChainConnector_); std::shared_ptr authRequestState = std::make_shared(); authManager->authResponseContext_ = std::make_shared(); authManager->authRequestContext_ = std::make_shared(); @@ -94,8 +92,7 @@ HWTEST_F(DmAuthManagerTest, HandleAuthenticateTimeout_001, testing::ext::TestSiz */ HWTEST_F(DmAuthManagerTest, HandleAuthenticateTimeout_002, testing::ext::TestSize.Level0) { - std::shared_ptr authManager = - std::make_shared(softbusConnector, listener, hiChainConnector_); + std::shared_ptr authManager = std::make_shared(softbusConnector, listener, hiChainConnector_); std::shared_ptr authRequestState = std::make_shared(); authManager->authResponseContext_ = std::make_shared(); authManager->authRequestContext_ = std::make_shared(); @@ -113,8 +110,7 @@ HWTEST_F(DmAuthManagerTest, HandleAuthenticateTimeout_002, testing::ext::TestSiz */ HWTEST_F(DmAuthManagerTest, EstablishAuthChannel_001, testing::ext::TestSize.Level0) { - std::shared_ptr authManager = - std::make_shared(softbusConnector, listener, hiChainConnector_); + std::shared_ptr authManager = std::make_shared(softbusConnector, listener, hiChainConnector_); std::shared_ptr sessionSession = std::shared_ptr(); std::shared_ptr authRequestContext = std::make_shared(); authManager->authResponseContext_ = std::make_shared(); @@ -133,8 +129,7 @@ HWTEST_F(DmAuthManagerTest, EstablishAuthChannel_001, testing::ext::TestSize.Lev */ HWTEST_F(DmAuthManagerTest, StartAuthProcess_001, testing::ext::TestSize.Level0) { - std::shared_ptr authManager = - std::make_shared(softbusConnector, listener, hiChainConnector_); + std::shared_ptr authManager = std::make_shared(softbusConnector, listener, hiChainConnector_); std::shared_ptr authResponseState = std::make_shared(); authManager->authResponseContext_ = std::make_shared(); authManager->authRequestContext_ = std::make_shared(); @@ -154,14 +149,14 @@ HWTEST_F(DmAuthManagerTest, StartAuthProcess_001, testing::ext::TestSize.Level0) */ HWTEST_F(DmAuthManagerTest, StartAuthProcess_002, testing::ext::TestSize.Level0) { - std::shared_ptr authManager = - std::make_shared(softbusConnector, listener, hiChainConnector_); + std::shared_ptr authManager = std::make_shared(softbusConnector, listener, hiChainConnector_); std::shared_ptr authResponseState = std::make_shared(); authManager->authResponseContext_ = std::make_shared(); authManager->authRequestContext_ = std::make_shared(); authManager->authResponseState_ = std::make_shared(); authManager->authMessageProcessor_ = std::make_shared(authManager); authManager->SetAuthResponseState(authResponseState); + //authManager->RegisterCallback(); authManager->authResponseContext_->sessionId = 111; authManager->softbusConnector_->GetSoftbusSession()->RegisterSessionCallback(authManager); int32_t action = 1; @@ -177,8 +172,7 @@ HWTEST_F(DmAuthManagerTest, StartAuthProcess_002, testing::ext::TestSize.Level0) */ HWTEST_F(DmAuthManagerTest, CreateGroup_001, testing::ext::TestSize.Level0) { - std::shared_ptr authManager = - std::make_shared(softbusConnector, listener, hiChainConnector_); + std::shared_ptr authManager = std::make_shared(softbusConnector, listener, hiChainConnector_); std::shared_ptr authResponseState = std::make_shared(); std::shared_ptr hiChainConnector = std::make_shared(); authManager->authResponseContext_ = std::make_shared(); @@ -200,8 +194,7 @@ HWTEST_F(DmAuthManagerTest, CreateGroup_001, testing::ext::TestSize.Level0) */ HWTEST_F(DmAuthManagerTest, AddMember_001, testing::ext::TestSize.Level0) { - std::shared_ptr authManager = - std::make_shared(softbusConnector, listener, hiChainConnector_); + std::shared_ptr authManager = std::make_shared(softbusConnector, listener, hiChainConnector_); std::shared_ptr authResponseState = std::make_shared(); authManager->authRequestContext_ = std::make_shared(); std::shared_ptr hiChainConnector = std::make_shared(); @@ -214,6 +207,7 @@ HWTEST_F(DmAuthManagerTest, AddMember_001, testing::ext::TestSize.Level0) authManager->authResponseContext_->requestId = 234; authManager->authResponseContext_->deviceId = "234"; std::string deviceId = "44444"; + //authManager->RegisterCallback(); authManager->hiChainConnector_->RegisterHiChainCallback(authManager); authManager->SetAuthResponseState(authResponseState); int32_t ret = authManager->AddMember(deviceId); @@ -229,8 +223,7 @@ HWTEST_F(DmAuthManagerTest, AddMember_001, testing::ext::TestSize.Level0) */ HWTEST_F(DmAuthManagerTest, JoinNetwork_001, testing::ext::TestSize.Level0) { - std::shared_ptr authManager = - std::make_shared(softbusConnector, listener, hiChainConnector_); + std::shared_ptr authManager = std::make_shared(softbusConnector, listener, hiChainConnector_); std::shared_ptr authRequestState = std::make_shared(); std::shared_ptr authenticateStartTimer = std::make_shared(AUTHENTICATE_TIMEOUT_TASK); authManager->timerMap_[AUTHENTICATE_TIMEOUT_TASK] = authenticateStartTimer; @@ -251,8 +244,7 @@ HWTEST_F(DmAuthManagerTest, JoinNetwork_001, testing::ext::TestSize.Level0) */ HWTEST_F(DmAuthManagerTest, SetAuthResponseState_001, testing::ext::TestSize.Level0) { - std::shared_ptr authManager = - std::make_shared(softbusConnector, listener, hiChainConnector_); + std::shared_ptr authManager = std::make_shared(softbusConnector, listener, hiChainConnector_); std::shared_ptr authResponseState = std::make_shared(); authManager->authResponseState_ = std::make_shared(); authManager->SetAuthResponseState(authResponseState); @@ -268,8 +260,7 @@ HWTEST_F(DmAuthManagerTest, SetAuthResponseState_001, testing::ext::TestSize.Lev */ HWTEST_F(DmAuthManagerTest, GetPinCode_001, testing::ext::TestSize.Level0) { - std::shared_ptr authManager = - std::make_shared(softbusConnector, listener, hiChainConnector_); + std::shared_ptr authManager = std::make_shared(softbusConnector, listener, hiChainConnector_); authManager->authResponseContext_ = std::make_shared(); int32_t ret = authManager->GetPinCode(); ASSERT_EQ(ret, authManager->authResponseContext_->code); diff --git a/test/unittest/UTTest_hichain_connector.cpp b/test/unittest/UTTest_hichain_connector.cpp index ae46c2514..b298f57ff 100644 --- a/test/unittest/UTTest_hichain_connector.cpp +++ b/test/unittest/UTTest_hichain_connector.cpp @@ -44,8 +44,7 @@ namespace { std::shared_ptr listener_ = std::make_shared(); std::shared_ptr softbusConnector = std::make_shared(); std::shared_ptr hiChainConnector_ = std::make_shared(); -std::shared_ptr discoveryMgr_ = - std::make_shared(softbusConnector, listener_, hiChainConnector_); +std::shared_ptr discoveryMgr_ = std::make_shared(softbusConnector, listener_,hiChainConnector_); /** * @tc.name: CreateGroup_001 @@ -263,7 +262,8 @@ HWTEST_F(HichainConnectorTest, HiChainConnector_002, testing::ext::TestSize.Leve HWTEST_F(HichainConnectorTest, RegisterHiChainCallback_001, testing::ext::TestSize.Level0) { std::shared_ptr hichainConnector = std::make_shared(); - int ret = hichainConnector->RegisterHiChainCallback(std::shared_ptr(discoveryMgr_)); + int ret = + hichainConnector->RegisterHiChainCallback(std::shared_ptr(discoveryMgr_)); EXPECT_EQ(ret, DM_OK); } diff --git a/test/unittest/UTTest_ipc_client_manager.cpp b/test/unittest/UTTest_ipc_client_manager.cpp new file mode 100644 index 000000000..e720eedbf --- /dev/null +++ b/test/unittest/UTTest_ipc_client_manager.cpp @@ -0,0 +1,584 @@ +/* + * Copyright (c) 2021 Huawei Device Co., Ltd. + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + + +#include "UTTest_ipc_client_manager.h" +#include "device_manager_notify.h" +#include "dm_device_info.h" +#include "ipc_client_stub.h" +#include "ipc_register_listener_req.h" +#include "ipc_remote_broker.h" +#include "iremote_object.h" +#include "iservice_registry.h" +#include "dm_constants.h" +#include "system_ability_definition.h" + +#include + +namespace OHOS { +namespace DistributedHardware { +void IpcClientManagerTest::SetUp() +{ +} + +void IpcClientManagerTest::TearDown() +{ +} + +void IpcClientManagerTest::SetUpTestCase() +{ +} + +void IpcClientManagerTest::TearDownTestCase() +{ +} + +namespace { + +/** + * @tc.name: ClientInit_001 + * @tc.desc: 1. new a dmInterface + * 2. set IpcClientManager dmInterface_ not null + * 3. call ClientInit + * 4. check ret is DM_SERVICE_NOT_READY + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcClientManagerTest, ClientInit_001, testing::ext::TestSize.Level0) +{ + // 1. new a dmInterface + auto samgr = SystemAbilityManagerClient::GetInstance().GetSystemAbilityManager(); + auto object = samgr->CheckSystemAbility(DISTRIBUTED_HARDWARE_DEVICEMANAGER_SA_ID); + sptr dmInterface = iface_cast(object); + // 2. set IpcClientManager dmInterface_ not null + std::shared_ptr instance = std::make_shared(); + instance->dmInterface_ = dmInterface; + // 3. call ClientInit + int ret = instance->ClientInit(); + // 4. check ret is DM_SERVICE_NOT_READY + ASSERT_EQ(ret, DM_SERVICE_NOT_READY); +} + +/** + * @tc.name: ClientInit_002 + * @tc.desc: 1. new a dmInterface + * 2. set IpcClientManager dmInterface_ not null + * 3. call ClientInit + * 4. check ret is DM_SERVICE_NOT_READY + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcClientManagerTest, ClientInit_002, testing::ext::TestSize.Level0) +{ + std::shared_ptr instance = std::make_shared(); + // 3. call ClientInit + int ret = instance->ClientInit(); + // 4. check ret is DM_SERVICE_NOT_READY + ASSERT_EQ(ret, DM_SERVICE_NOT_READY); +} + +/** + * @tc.name: Init1 + * @tc.desc: 1. new a listener + * 2. set a pkgName not null + * 3. add listener and pkgName in dmListener_ Map + * 4. call Init with pkgName + * 5. check ret is DM_SERVICE_NOT_READY + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcClientManagerTest, Init1, testing::ext::TestSize.Level0) +{ + // 1. new a listener + sptr listener = sptr(new IpcClientStub()); + // 2. set a pkgName not null + std::string pkgName = "com.ohos.test"; + std::shared_ptr instance = std::make_shared(); + // 3. add listener and pkgName in dmListener_ Map + instance->dmListener_[pkgName] = listener; + // 4. call Init with pkgName + int32_t ret = instance->Init(pkgName); + // 5. check ret is DM_SERVICE_NOT_READY + ASSERT_EQ(ret, DM_SERVICE_NOT_READY); +} + +/** + * @tc.name: Init_002 + * @tc.desc: 1. set pkcName not null + * 2. Mock IpcClientServerProxy SendCmd return DM_FAILED + * 3. call Init with pkgName + * 4. check ret is DM_FAILED + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcClientManagerTest, Init_002, testing::ext::TestSize.Level0) +{ + // 1. set pkcName not null + std::string pkgName = "com.ohos.test"; + // 2. Mock IpcClientServerProxy SendCmd return DM_FAILED + sptr remoteObject = nullptr; + auto mockInstance = new MockIpcClientManager(remoteObject); + std::shared_ptr instance = std::make_shared(); + instance->dmInterface_ = mockInstance; + EXPECT_CALL(*mockInstance,SendCmd(testing::_,testing::_,testing::_)) + .Times(1).WillOnce(testing::Return(DM_FAILED)); + // 3. call Init with pkgName + int32_t ret = instance->Init(pkgName); + // 4. check ret is DM_FAILED + ASSERT_EQ(ret, DM_FAILED); +} + +/** + * @tc.name: Init_003 + * @tc.desc: 1. set pkcName not null + * 2. Mock IpcClientServerProxy SendCmd return DM_OK + * 3. call Init with pkgName + * 4. check ret is DM_OK + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcClientManagerTest, Init_003, testing::ext::TestSize.Level0) +{ + // 1. set pkcName not null + std::string pkgName = "com.ohos.test"; + // 2. Mock IpcClientServerProxy SendCmd return DM_OK + sptr remoteObject = nullptr; + auto mockInstance = new MockIpcClientManager(remoteObject); + std::shared_ptr instance = std::make_shared(); + instance->dmInterface_ = mockInstance; + EXPECT_CALL(*mockInstance,SendCmd(testing::_,testing::_,testing::_)) + .Times(1).WillOnce(testing::Return(DM_OK)); + // 3. call Init with pkgName + int32_t ret = instance->Init(pkgName); + // 4. check ret is DM_OK + ASSERT_EQ(ret, DM_OK); +} + +/** + * @tc.name: Init_004 + * @tc.desc: 1. set pkcName not null + * 2. Mock IpcClientServerProxy SendCmd return DM_OK + * 3. call Init with pkgName + * 4. check ret is DM_OK + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcClientManagerTest, Init_004, testing::ext::TestSize.Level0) +{ + // 1. set pkcName not null + std::string pkgName = "com.ohos.test"; + // 2. Mock IpcClientServerProxy SendCmd return DEVICEMANAGER_SERVICE_NOT_READY + sptr remoteObject = nullptr; + auto mockInstance = new MockIpcClientManager(remoteObject); + std::shared_ptr instance = std::make_shared(); + instance->dmInterface_ = mockInstance; + EXPECT_CALL(*mockInstance,SendCmd(testing::_,testing::_,testing::_)) + .Times(1).WillOnce(testing::Return(DM_SERVICE_NOT_READY)); + // 3. call Init with pkgName + int32_t ret = instance->Init(pkgName); + // 4. check ret is DEVICEMANAGER_OK + ASSERT_EQ(ret, ret); +} + +/** + * @tc.name: Init_005 + * @tc.desc: 1. set pkcName not null + * 2. Mock IpcClientServerProxy SendCmd return DM_IPC_FAILED + * 3. call Init with pkgName + * 4. check ret is DM_IPC_FAILED + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcClientManagerTest, Init_005, testing::ext::TestSize.Level0) +{ + // 1. set pkcName not null + std::string pkgName = "com.ohos.test"; + // 2. Mock IpcClientServerProxy SendCmd return DM_OK + sptr remoteObject = nullptr; + auto mockInstance = new MockIpcClientManager(remoteObject); + std::shared_ptr instance = std::make_shared(); + instance->dmInterface_ = mockInstance; + EXPECT_CALL(*mockInstance,SendCmd(testing::_,testing::_,testing::_)) + .Times(1).WillOnce(testing::Return(DM_IPC_FAILED)); + // 3. call Init with pkgName + int32_t ret = instance->Init(pkgName); + // 4. check ret is DM_IPC_FAILED + ASSERT_EQ(ret, DM_IPC_FAILED); +} + +/** + * @tc.name: UnInit_001 + * @tc.desc: 1. set pkgName null + * set IpcClientManager dmInterface_ null + * 2. call UnInit with pkgName + * 3. check ret is DEVICEMANAGER_SERVICE_NOT_READY + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcClientManagerTest, UnInit1, testing::ext::TestSize.Level0) +{ + // 1. set pkgName null + std::string pkgName = ""; + // set IpcClientManager dmInterface_ null + std::shared_ptr instance = std::make_shared(); + instance->dmInterface_ = nullptr; + // 2. call UnInit with pkgName + int32_t ret = instance->UnInit(pkgName); + // 3. check ret is DM_SERVICE_NOT_READY + ASSERT_EQ(ret, DM_SERVICE_NOT_READY); +} + +/** + * @tc.name: UnInit_002 + * @tc.desc: 1. set pkgName not null + * 2. Mock IpcClientServerProxy SendCmd return DM_FAILED + * 3. set IpcClientManager dmInterface_ not null + * 4. set IpcClientManager dmListener_ not null + * 5. call UnInit with pkgName + * 6. check ret is DM_FAILED + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcClientManagerTest, UnInit_002, testing::ext::TestSize.Level0) +{ + // 1. set pkgName not null + std::string pkgName = "com.ohos.test"; + // 2. Mock IpcClientServerProxy SendCmd return DM_FAILED + sptr remoteObject = nullptr; + auto mockInstance = new MockIpcClientManager(remoteObject); + EXPECT_CALL(*mockInstance,SendCmd(testing::_,testing::_,testing::_)) + .Times(1).WillOnce(testing::Return(DM_FAILED)); + // 3. set IpcClientManager dmInterface_ not null + std::shared_ptr instance = std::make_shared(); + instance->dmInterface_ = mockInstance; + // 4. set IpcClientManager dmListener_ not null + sptr listener = sptr(new IpcClientStub()); + instance->dmListener_[pkgName] = listener; + // 5. call UnInit with pkgName + int32_t ret = instance->UnInit(pkgName); + // 6. check ret is DM_FAILED + ASSERT_EQ(ret, DM_FAILED); +} + +/** + * @tc.name: UnInit_003 + * @tc.desc: 1. set pkgName not null + * 2. Mock IpcClientServerProxy SendCmd return DM_OK + * 3. set IpcClientManager dmInterface_ not null + * 4. set IpcClientManager dmListener_ not null + * 5. call UnInit with pkgName + * 6. check ret is DM_OK + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcClientManagerTest, UnInit_003, testing::ext::TestSize.Level0) +{ + // 1. set pkgName not null + std::string pkgName = "com.ohos.test"; + // 2. Mock IpcClientServerProxy SendCmd return DM_OK + sptr remoteObject = nullptr; + auto mockInstance = new MockIpcClientManager(remoteObject); + EXPECT_CALL(*mockInstance,SendCmd(testing::_,testing::_,testing::_)) + .Times(1).WillOnce(testing::Return(DM_OK)); + // 3. set IpcClientManager dmInterface_ not null + std::shared_ptr instance = std::make_shared(); + instance->dmInterface_ = mockInstance; + // 4. set IpcClientManager dmListener_ not null + sptr listener = sptr(new IpcClientStub()); + instance->dmListener_[pkgName] = listener; + // 5. call UnInit with pkgName + int32_t ret = instance->UnInit(pkgName); + // 6. check ret is DM_OK + ASSERT_EQ(ret, DM_OK); +} + +/** + * @tc.name: UnInit_004 + * @tc.desc: 1. set pkgName not null + * 2. Mock IpcClientServerProxy SendCmd return DM_SERVICE_NOT_READY + * 3. set IpcClientManager dmInterface_ not null + * 4. set IpcClientManager dmListener_ not null + * 5. call UnInit with pkgName + * 6. check ret is DM_SERVICE_NOT_READY + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcClientManagerTest, UnInit_004, testing::ext::TestSize.Level0) +{ + // 1. set pkgName not null + std::string pkgName = "com.ohos.test"; + // 2. Mock IpcClientServerProxy SendCmd return DM_SERVICE_NOT_READY + sptr remoteObject = nullptr; + auto mockInstance = new MockIpcClientManager(remoteObject); + EXPECT_CALL(*mockInstance,SendCmd(testing::_,testing::_,testing::_)) + .Times(1).WillOnce(testing::Return(DM_SERVICE_NOT_READY)); + // 3. set IpcClientManager dmInterface_ not null + std::shared_ptr instance = std::make_shared(); + instance->dmInterface_ = mockInstance; + // 4. set IpcClientManager dmListener_ not null + sptr listener = sptr(new IpcClientStub()); + instance->dmListener_[pkgName] = listener; + // 5. call UnInit with pkgName + int32_t ret = instance->UnInit(pkgName); + // 6. check ret is DM_SERVICE_NOT_READY + ASSERT_EQ(ret, DM_SERVICE_NOT_READY); +} + +/** + * @tc.name: UnInit_005 + * @tc.desc: 1. set pkgName not null + * 2. Mock IpcClientServerProxy SendCmd return DM_IPC_FAILED + * 3. set IpcClientManager dmInterface_ not null + * 4. set IpcClientManager dmListener_ not null + * 5. call UnInit with pkgName + * 6. check ret is DM_IPC_FAILED + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcClientManagerTest, UnInit_005, testing::ext::TestSize.Level0) +{ + // 1. set pkgName not null + std::string pkgName = "com.ohos.test"; + // 2. Mock IpcClientServerProxy SendCmd return DM_IPC_FAILED + sptr remoteObject = nullptr; + auto mockInstance = new MockIpcClientManager(remoteObject); + EXPECT_CALL(*mockInstance,SendCmd(testing::_,testing::_,testing::_)) + .Times(1).WillOnce(testing::Return(DM_IPC_FAILED)); + // 3. set IpcClientManager dmInterface_ not null + std::shared_ptr instance = std::make_shared(); + instance->dmInterface_ = mockInstance; + // 4. set IpcClientManager dmListener_ not null + sptr listener = sptr(new IpcClientStub()); + instance->dmListener_[pkgName] = listener; + // 5. call UnInit with pkgName + int32_t ret = instance->UnInit(pkgName); + // 6. check ret is DM_IPC_FAILED + ASSERT_EQ(ret, DM_IPC_FAILED); +} + +/** + * @tc.name: SendRequest_001 + * @tc.desc: 1. set pkgName null + * 2. set IpcClientManager dmInterface_null + * 3. call SendRequest with parameter + * 4. check ret is DM_SERVICE_NOT_READY + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcClientManagerTest, SendRequest_001, testing::ext::TestSize.Level0) +{ + // 1. set pkgName null + std::string pkgName = ""; + std::shared_ptr req = std::make_shared(); + std::shared_ptr rsp = std::make_shared(); + req->SetPkgName(pkgName); + // 2. set IpcClientManager dmInterface_null + std::shared_ptr instance = std::make_shared(); + instance->dmInterface_ = nullptr; + // 3. call SendRequest with parameter + int ret = instance->SendRequest(0,req,rsp); + // 4. check ret is DM_SERVICE_NOT_READY + ASSERT_EQ(ret, DM_SERVICE_NOT_READY); +} + +/** + * @tc.name: SendRequest_002 + * @tc.desc: 1. set pkgName not null + * 2. Mock IpcClientServerProxy SendCmd return DM_FAILED + * 3. set IpcClientManager dmInterface_ not null + * 4. set IpcClientManager dmListener_ not null + * 5. call SendRequest with parameter + * 6. check ret is DM_FAILED + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcClientManagerTest, SendRequest_002, testing::ext::TestSize.Level0) +{ + // 1. set pkgName not null + std::string pkgName = "com.ohos.test"; + std::shared_ptr req = std::make_shared(); + std::shared_ptr rsp = std::make_shared(); + req->SetPkgName(pkgName); + // 2. Mock IpcClientServerProxy SendCmd return DM_FAILED + sptr remoteObject = nullptr; + auto mockInstance = new MockIpcClientManager(remoteObject); + EXPECT_CALL(*mockInstance,SendCmd(testing::_,testing::_,testing::_)) + .Times(1).WillOnce(testing::Return(DM_FAILED)); + std::shared_ptr instance = std::make_shared(); + // 3. set IpcClientManager dmInterface_ not null + instance->dmInterface_ = mockInstance; + sptr listener = sptr(new IpcClientStub()); + // 4. set IpcClientManager dmListener_ not null + instance->dmListener_[pkgName] = listener; + // 5. call SendRequest with parameter + int ret = instance->SendRequest(0,req,rsp); + // 6. check ret is DM_FAILED + ASSERT_EQ(ret, DM_FAILED); +} + +/** + * @tc.name: SendRequest_003 + * @tc.desc: 1. set pkgName not null + * 2. Mock IpcClientServerProxy SendCmd return DM_OK + * 3. set IpcClientManager dmInterface_ not null + * 4. set IpcClientManager dmListener_ not null + * 5. call SendRequest with parameter + * 6. check ret is DM_OK + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcClientManagerTest, SendRequest_003, testing::ext::TestSize.Level0) +{ + // 1. set pkgName not null + std::string pkgName = "com.ohos.test"; + std::shared_ptr req = std::make_shared(); + std::shared_ptr rsp = std::make_shared(); + req->SetPkgName(pkgName); + // 2. Mock IpcClientServerProxy SendCmd return DM_OK + sptr remoteObject = nullptr; + auto mockInstance = new MockIpcClientManager(remoteObject); + EXPECT_CALL(*mockInstance,SendCmd(testing::_,testing::_,testing::_)) + .Times(1).WillOnce(testing::Return(DM_OK)); + std::shared_ptr instance = std::make_shared(); + // 3. set IpcClientManager dmInterface_ not null + instance->dmInterface_ = mockInstance; + sptr listener = sptr(new IpcClientStub()); + // 4. set IpcClientManager dmListener_ not null + instance->dmListener_[pkgName] = listener; + // 5. call SendRequest with parameter + int ret = instance->SendRequest(0,req,rsp); + // 6. check ret is DM_OK + ASSERT_EQ(ret, DM_OK); +} + +/** + * @tc.name: SendRequest_004 + * @tc.desc: 1. set pkgName not null + * 2. Mock IpcClientServerProxy SendCmd return DM_SERVICE_NOT_READY + * 3. set IpcClientManager dmInterface_ not null + * 4. set IpcClientManager dmListener_ not null + * 5. call SendRequest with parameter + * 6. check ret is DM_SERVICE_NOT_READY + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcClientManagerTest, SendRequest_004, testing::ext::TestSize.Level0) +{ + // 1. set pkgName not null + std::string pkgName = "com.ohos.test"; + std::shared_ptr req = std::make_shared(); + std::shared_ptr rsp = std::make_shared(); + req->SetPkgName(pkgName); + // 2. Mock IpcClientServerProxy SendCmd return DM_SERVICE_NOT_READY + sptr remoteObject = nullptr; + auto mockInstance = new MockIpcClientManager(remoteObject); + EXPECT_CALL(*mockInstance,SendCmd(testing::_,testing::_,testing::_)) + .Times(1).WillOnce(testing::Return(DM_SERVICE_NOT_READY)); + std::shared_ptr instance = std::make_shared(); + // 3. set IpcClientManager dmInterface_ not null + instance->dmInterface_ = mockInstance; + sptr listener = sptr(new IpcClientStub()); + // 4. set IpcClientManager dmListener_ not null + instance->dmListener_[pkgName] = listener; + // 5. call SendRequest with parameter + int ret = instance->SendRequest(0,req,rsp); + // 6. check ret is DM_SERVICE_NOT_READY + ASSERT_EQ(ret, DM_SERVICE_NOT_READY); +} + +/** + * @tc.name: SendRequest_005 + * @tc.desc: 1. set pkgName not null + * 2. Mock IpcClientServerProxy SendCmd return DM_IPC_FAILED + * 3. set IpcClientManager dmInterface_ not null + * 4. set IpcClientManager dmListener_ not null + * 5. call SendRequest with parameter + * 6. check ret is DM_IPC_FAILED + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcClientManagerTest, SendRequest_005, testing::ext::TestSize.Level0) +{ + // 1. set pkgName not null + std::string pkgName = "com.ohos.test"; + std::shared_ptr req = std::make_shared(); + std::shared_ptr rsp = std::make_shared(); + req->SetPkgName(pkgName); + // 2. Mock IpcClientServerProxy SendCmd return DM_IPC_FAILED + sptr remoteObject = nullptr; + auto mockInstance = new MockIpcClientManager(remoteObject); + EXPECT_CALL(*mockInstance,SendCmd(testing::_,testing::_,testing::_)) + .Times(1).WillOnce(testing::Return(DM_IPC_FAILED)); + std::shared_ptr instance = std::make_shared(); + // 3. set IpcClientManager dmInterface_ not null + instance->dmInterface_ = mockInstance; + sptr listener = sptr(new IpcClientStub()); + // 4. set IpcClientManager dmListener_ not null + instance->dmListener_[pkgName] = listener; + // 5. call SendRequest with parameter + int ret = instance->SendRequest(0,req,rsp); + // 6. check ret is DM_IPC_FAILED + ASSERT_EQ(ret, DM_IPC_FAILED); +} + +/** + * @tc.name: IsInit_001 + * @tc.desc: 1. set pkgName null + * 2. set IpcClientManager dmInterface_null + * 3. call IsInit with parameter + * 4. check ret is false + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcClientManagerTest, IsInit_001, testing::ext::TestSize.Level0) +{ + // 1. set pkgName null + std::string pkgName = ""; + // 2. set IpcClientManager dmInterface_null + std::shared_ptr instance = std::make_shared(); + instance->dmInterface_ = nullptr; + // 3. call SendRequest with parameter + bool ret = instance->IsInit(pkgName); + // 4. check ret is false + ASSERT_EQ(ret, false); +} + +/** + * @tc.name: IsInit_002 + * @tc.desc: 1. set pkgName not null + * 2. set IpcClientManager dmInterface_ not null + * 3. call IsInit with parameter + * 4. check ret is false + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcClientManagerTest, IsInit_002, testing::ext::TestSize.Level0) +{ + // 1. set pkgName null + std::string pkgName = ""; + // 2. set IpcClientManager dmInterface_ not null + auto samgr = SystemAbilityManagerClient::GetInstance().GetSystemAbilityManager(); + auto object = samgr->CheckSystemAbility(DISTRIBUTED_HARDWARE_DEVICEMANAGER_SA_ID); + sptr dmInterface = iface_cast(object); + std::shared_ptr instance = std::make_shared(); + instance->dmInterface_ = dmInterface; + // 3. call IsInit with parameter + bool ret = instance->IsInit(pkgName); + // 4. check ret is false + ASSERT_EQ(ret, false); +} +} // namespace +} // namespace DistributedHardware +} // namespace OHOS diff --git a/test/unittest/UTTest_ipc_client_manager.h b/test/unittest/UTTest_ipc_client_manager.h new file mode 100644 index 000000000..bd25fb4de --- /dev/null +++ b/test/unittest/UTTest_ipc_client_manager.h @@ -0,0 +1,36 @@ +/* + * Copyright (c) 2021 Huawei Device Co., Ltd. + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef OHOS_IPC_CLIENT_MANAGER_TEST_H +#define OHOS_IPC_CLIENT_MANAGER_TEST_H + +#include +#include + +#include "mock/mock_ipc_client_manager.h" +#include "ipc_client_manager.h" +namespace OHOS { +namespace DistributedHardware { +class IpcClientManagerTest : public testing::Test { +public: + static void SetUpTestCase(); + static void TearDownTestCase(); + virtual void SetUp() override; + virtual void TearDown() override; +}; +} // namespace DistributedHardware +} // namespace OHOS + +#endif // OHOS_IPC_CLIENT_MANAGER_TEST_H diff --git a/test/unittest/UTTest_ipc_client_proxy.cpp b/test/unittest/UTTest_ipc_client_proxy.cpp new file mode 100644 index 000000000..7f55ab8db --- /dev/null +++ b/test/unittest/UTTest_ipc_client_proxy.cpp @@ -0,0 +1,415 @@ +/* + * Copyright (c) 2021 Huawei Device Co., Ltd. + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#include "UTTest_ipc_client_proxy.h" +#include "dm_device_info.h" +#include "ipc_remote_broker.h" +#include "iremote_object.h" +#include "iservice_registry.h" +#include "system_ability_definition.h" +#include "ipc_client_manager.h" +#include "dm_constants.h" + +#include + +namespace OHOS { +namespace DistributedHardware { +void IpcClientProxyTest::SetUp() +{ +} + +void IpcClientProxyTest::TearDown() +{ +} + +void IpcClientProxyTest::SetUpTestCase() +{ +} + +void IpcClientProxyTest::TearDownTestCase() +{ +} + +namespace { + +/** + * @tc.name: Init_001 + * @tc.desc: 1. set pkgName not null + * 2. set IpcClientProxy ipcClientManager nullptr + * 3. call IpcClientProxy Init + * 4. check ret is DM_POINT_NULL + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcClientProxyTest, Init_001, testing::ext::TestSize.Level0) +{ + // 1. set pkgName not null + std::string pkgName = "com.ohos.test"; + // 2. set IpcClientProxy ipcClientManager nullptr + std::shared_ptr ipcClientManager = nullptr; + std::shared_ptr ipcClientProxy = std::make_shared(ipcClientManager); + // 3. call IpcClientProxy + int32_t ret = ipcClientProxy->Init(pkgName); + // 4. check ret is DM_POINT_NULL + ASSERT_EQ(ret, DM_POINT_NULL); +} + +/** + * @tc.name: Init_002 + * @tc.desc: 1. set pkgName not null + * 2. Mock IpcClient Init return DM_FAILED + * 3. call IpcClientProxy Init + * 4. check ret is DM_FAILED + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcClientProxyTest, Init_002, testing::ext::TestSize.Level0) +{ + // 1. set pkgName not null + std::string pkgName = "com.ohos.test"; + // 2. Mock IpcClient Init return DM_FAILED + std::shared_ptr mockInstance = std::make_shared(); + std::shared_ptr ipcClientManager = mockInstance; + EXPECT_CALL(*mockInstance,Init(testing::_)).Times(1).WillOnce(testing::Return(DM_FAILED)); + // 3. call IpcClientProxy Init + std::shared_ptr ipcClientProxy = std::make_shared(ipcClientManager); + int32_t ret = ipcClientProxy->Init(pkgName); + // 4. check ret is DM_FAILED + ASSERT_EQ(ret, DM_FAILED); +} + +/** + * @tc.name: Init_003 + * @tc.desc: 1. set pkgName not null + * 2. Mock IpcClient Init return DM_OK + * 3. call IpcClientProxy Init + * 4. check ret is DM_OK + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcClientProxyTest, Init_003, testing::ext::TestSize.Level0) +{ + // 1. set pkgName not null + std::string pkgName = "com.ohos.test"; + // 2. Mock IpcClient Init return DM_OK + std::shared_ptr mockInstance = std::make_shared(); + std::shared_ptr ipcClientManager = mockInstance; + EXPECT_CALL(*mockInstance,Init(testing::_)).Times(1).WillOnce(testing::Return(DM_OK)); + // 3. call IpcClientProxy Init + std::shared_ptr ipcClientProxy = std::make_shared(ipcClientManager); + int32_t ret = ipcClientProxy->Init(pkgName); + // 4. check ret is DM_OK + ASSERT_EQ(ret, DM_OK); +} + +/** + * @tc.name: Init_004 + * @tc.desc: 1. set pkgName not null + * 2. Mock IpcClient Init return DM_SERVICE_NOT_READY + * 3. call IpcClientProxy Init + * 4. check ret is DM_SERVICE_NOT_READY + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcClientProxyTest, Init_004, testing::ext::TestSize.Level0) +{ + // 1. set pkgName not null + std::string pkgName = "com.ohos.test"; + // 2. Mock IpcClient Init return DM_SERVICE_NOT_READY + std::shared_ptr mockInstance = std::make_shared(); + std::shared_ptr ipcClientManager = mockInstance; + EXPECT_CALL(*mockInstance,Init(testing::_)).Times(1).WillOnce(testing::Return(DM_SERVICE_NOT_READY)); + // 3. call IpcClientProxy Init + std::shared_ptr ipcClientProxy = std::make_shared(ipcClientManager); + int32_t ret = ipcClientProxy->Init(pkgName); + // 4. check ret is DM_SERVICE_NOT_READY + ASSERT_EQ(ret, DM_SERVICE_NOT_READY); +} + +/** + * @tc.name: Init_005 + * @tc.desc: 1. set pkgName not null + * 2. Mock IpcClient Init return DM_IPC_FAILED + * 3. call IpcClientProxy Init + * 4. check ret is DM_IPC_FAILED + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcClientProxyTest, Init_005, testing::ext::TestSize.Level0) +{ + // 1. set pkgName not null + std::string pkgName = "com.ohos.test"; + // 2. Mock IpcClient Init return DM_IPC_FAILED + std::shared_ptr mockInstance = std::make_shared(); + std::shared_ptr ipcClientManager = mockInstance; + EXPECT_CALL(*mockInstance,Init(testing::_)).Times(1).WillOnce(testing::Return(DM_IPC_FAILED)); + // 3. call IpcClientProxy Init + std::shared_ptr ipcClientProxy = std::make_shared(ipcClientManager); + int32_t ret = ipcClientProxy->Init(pkgName); + // 4. check ret is DM_IPC_FAILED + ASSERT_EQ(ret, DM_IPC_FAILED); +} + +/** + * @tc.name: UnInit_001 + * @tc.desc: 1. set pkgName not null + * 2. set IpcClientProxy ipcClientManager nullptr + * 3. call IpcClientProxy UnInit + * 4. check ret is DM_POINT_NULL + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcClientProxyTest, UnInit_001, testing::ext::TestSize.Level0) +{ + // 1. set pkgName not null + std::string pkgName = "com.ohos.test"; + // 2. set IpcClientProxy ipcClientManager nullptr + std::shared_ptr ipcClientManager = nullptr; + std::shared_ptr ipcClientProxy = std::make_shared(ipcClientManager); + // 3. call IpcClientProxy + int32_t ret = ipcClientProxy->UnInit(pkgName); + // 4. check ret is DM_POINT_NULL + ASSERT_EQ(ret, DM_POINT_NULL); +} + +/** + * @tc.name: UnInit_002 + * @tc.desc: 1. set pkgName not null + * 2. Mock IpcClient Init return DM_FAILED + * 3. call IpcClientProxy UnInit + * 4. check ret is DM_FAILED + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcClientProxyTest, UnInit_002, testing::ext::TestSize.Level0) +{ + // 1. set pkgName not null + std::string pkgName = "com.ohos.test"; + // 2. Mock IpcClient Init return DM_FAILED + std::shared_ptr mockInstance = std::make_shared(); + std::shared_ptr ipcClientManager = mockInstance; + EXPECT_CALL(*mockInstance,UnInit(testing::_)).Times(1).WillOnce(testing::Return(DM_FAILED)); + // 3. call IpcClientProxy Init + std::shared_ptr ipcClientProxy = std::make_shared(ipcClientManager); + int32_t ret = ipcClientProxy->UnInit(pkgName); + // 4. check ret is DM_FAILED + ASSERT_EQ(ret, DM_FAILED); +} + +/** + * @tc.name: UnInit_003 + * @tc.desc: 1. set pkgName not null + * 2. Mock IpcClient UnInit return DM_OK + * 3. call IpcClientProxy UnInit + * 4. check ret is DM_OK + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcClientProxyTest, UnInit_003, testing::ext::TestSize.Level0) +{ + // 1. set pkgName not null + std::string pkgName = "com.ohos.test"; + // 2. Mock IpcClient Init return DM_OK + std::shared_ptr mockInstance = std::make_shared(); + std::shared_ptr ipcClientManager = mockInstance; + EXPECT_CALL(*mockInstance,UnInit(testing::_)).Times(1).WillOnce(testing::Return(DM_OK)); + // 3. call IpcClientProxy Init + std::shared_ptr ipcClientProxy = std::make_shared(ipcClientManager); + int32_t ret = ipcClientProxy->UnInit(pkgName); + // 4. check ret is DM_OK + ASSERT_EQ(ret, DM_OK); +} + +/** + * @tc.name: UnInit_004 + * @tc.desc: 1. set pkgName not null + * 2. Mock IpcClient UnInit return DM_SERVICE_NOT_READY + * 3. call IpcClientProxy UnInit + * 4. check ret is DM_SERVICE_NOT_READY + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcClientProxyTest, UnInit_004, testing::ext::TestSize.Level0) +{ + // 1. set pkgName not null + std::string pkgName = "com.ohos.test"; + // 2. Mock IpcClient Init return DM_SERVICE_NOT_READY + std::shared_ptr mockInstance = std::make_shared(); + std::shared_ptr ipcClientManager = mockInstance; + EXPECT_CALL(*mockInstance,UnInit(testing::_)).Times(1).WillOnce(testing::Return(DM_SERVICE_NOT_READY)); + // 3. call IpcClientProxy Init + std::shared_ptr ipcClientProxy = std::make_shared(ipcClientManager); + int32_t ret = ipcClientProxy->UnInit(pkgName); + // 4. check ret is DM_SERVICE_NOT_READY + ASSERT_EQ(ret, DM_SERVICE_NOT_READY); +} + +/** + * @tc.name: UnInit_005 + * @tc.desc: 1. set pkgName not null + * 2. Mock IpcClient UnInit return DM_IPC_FAILED + * 3. call IpcClientProxy UnInit + * 4. check ret is DM_IPC_FAILED + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcClientProxyTest, UnInit_005, testing::ext::TestSize.Level0) +{ + // 1. set pkgName not null + std::string pkgName = "com.ohos.test"; + // 2. Mock IpcClient Init return DM_IPC_FAILED + std::shared_ptr mockInstance = std::make_shared(); + std::shared_ptr ipcClientManager = mockInstance; + EXPECT_CALL(*mockInstance,UnInit(testing::_)).Times(1).WillOnce(testing::Return(DM_IPC_FAILED)); + // 3. call IpcClientProxy Init + std::shared_ptr ipcClientProxy = std::make_shared(ipcClientManager); + int32_t ret = ipcClientProxy->UnInit(pkgName); + // 4. check ret is DM_IPC_FAILED + ASSERT_EQ(ret, DM_IPC_FAILED); +} + +/** + * @tc.name: SendRequest_001 + * @tc.desc: 1. set req nullptr + * set rsp not nullptr + * set IpcClientProxy ipcClientManager not null + * 2. call IpcClientProxy SendRequest + * 3. check ret is DEVICEMANAGER_NULLPTR + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcClientProxyTest, SendRequest_001, testing::ext::TestSize.Level0) +{ + // 1. set req nullptr + std::shared_ptr req = nullptr; + // set rsp not nullptr + std::shared_ptr rsp = std::make_shared(); + // set pcClientProxy ipcClientManager not null + std::shared_ptr ipcClientManager = std::make_shared(); + // 2. call IpcClientProxy SendRequest + std::shared_ptr ipcClientProxy = std::make_shared(ipcClientManager); + int32_t ret = ipcClientProxy->SendRequest(0, req, rsp); + // 3. check ret is DEVICEMANAGER_NULLPTR + ASSERT_EQ(ret, DM_POINT_NULL); +} + +/** + * @tc.name: SendRequest_002 + * @tc.desc: 1. set req not nullptr + * set rsp nullptr + * set IpcClientProxy ipcClientManager not null + * 2. call IpcClientProxy SendRequest + * 3. check ret is DM_POINT_NULL + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcClientProxyTest, SendRequest_002, testing::ext::TestSize.Level0) +{ + // 1. set req not nullptr + std::shared_ptr req = std::make_shared(); + // set rsp nullptr + std::shared_ptr rsp = nullptr; + // set pcClientProxy ipcClientManager not null + std::shared_ptr ipcClientManager = std::make_shared(); + // 2. call IpcClientProxy SendRequest + std::shared_ptr ipcClientProxy = std::make_shared(ipcClientManager); + int32_t ret = ipcClientProxy->SendRequest(0, req, rsp); + // 3. check ret is DM_POINT_NULL + ASSERT_EQ(ret, DM_POINT_NULL); +} + +/** + * @tc.name: SendRequest_003 + * @tc.desc: 1. set req not nullptr + * set rsp not nullptr + * set IpcClientProxy ipcClientManager null + * 2. call IpcClientProxy SendRequest + * 3. check ret is DM_POINT_NULL + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcClientProxyTest, SendRequest_003, testing::ext::TestSize.Level0) +{ + // 1. set req not nullptr + std::shared_ptr req = std::make_shared(); + // set rsp not nullptr + std::shared_ptr rsp = std::make_shared(); + // set pcClientProxy ipcClientManager null + std::shared_ptr ipcClientManager = nullptr; + // 2. call IpcClientProxy SendRequest + std::shared_ptr ipcClientProxy = std::make_shared(ipcClientManager); + int32_t ret = ipcClientProxy->SendRequest(0, req, rsp); + // 3. check ret is DM_POINT_NULL + ASSERT_EQ(ret, DM_POINT_NULL); +} + +/** + * @tc.name: SendRequest_004 + * @tc.desc: 1. set req not nullptr + * set rsp not nullptr + * 2. Mock IpcClient SendRequest return DM_FAILED + * 3. call IpcClientProxy SendRequest + * 4. check ret is DM_FAILED + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcClientProxyTest, SendRequest_004, testing::ext::TestSize.Level0) +{ + // 1. set req not nullptr + std::shared_ptr req = std::make_shared(); + // set rsp not nullptr + std::shared_ptr rsp = std::make_shared(); + // 2. Mock IpcClient SendRequest return DM_FAILED + std::shared_ptr mockInstance = std::make_shared(); + std::shared_ptr ipcClientManager = mockInstance; + EXPECT_CALL(*mockInstance,SendRequest(testing::_,testing::_,testing::_)) + .Times(1).WillOnce(testing::Return(DM_FAILED)); + // 3. call IpcClientProxy SendRequest + std::shared_ptr ipcClientProxy = std::make_shared(ipcClientManager); + int32_t ret = ipcClientProxy->SendRequest(0, req, rsp); + // 4. check ret is DM_FAILED + ASSERT_EQ(ret, DM_FAILED); +} + +/** + * @tc.name: SendRequest_004 + * @tc.desc: 1. set req not nullptr + * set rsp not nullptr + * 2. Mock IpcClient SendRequest return DM_OK + * 3. call IpcClientProxy SendRequest + * 4. check ret is DM_OK + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcClientProxyTest, SendRequest5, testing::ext::TestSize.Level0) +{ + // 1. set req not nullptr + std::shared_ptr req = std::make_shared(); + // set rsp not nullptr + std::shared_ptr rsp = std::make_shared(); + // 2. Mock IpcClient SendRequest return DM_FAILED + std::shared_ptr mockInstance = std::make_shared(); + std::shared_ptr ipcClientManager = mockInstance; + EXPECT_CALL(*mockInstance,SendRequest(testing::_,testing::_,testing::_)) + .Times(1).WillOnce(testing::Return(DM_OK)); + // 3. call IpcClientProxy SendRequest + std::shared_ptr ipcClientProxy = std::make_shared(ipcClientManager); + int32_t ret = ipcClientProxy->SendRequest(0, req, rsp); + // 4. check ret is DM_OK + ASSERT_EQ(ret, DM_OK); +} +} // namespace +} // namespace DistributedHardware +} // namespace OHOS diff --git a/test/unittest/UTTest_ipc_client_proxy.h b/test/unittest/UTTest_ipc_client_proxy.h new file mode 100644 index 000000000..b6c6556ac --- /dev/null +++ b/test/unittest/UTTest_ipc_client_proxy.h @@ -0,0 +1,39 @@ +/* + * Copyright (c) 2021 Huawei Device Co., Ltd. + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef OHOS_IPC_CLIENT_PROXY_TEST_H +#define OHOS_IPC_CLIENT_PROXY_TEST_H + +#include +#include + +#include "mock/mock_ipc_client.h" +#include "ipc_client_proxy.h" +#include "ipc_client.h" +#include "ipc_req.h" +#include "ipc_rsp.h" +namespace OHOS { +namespace DistributedHardware { +class IpcClientProxyTest : public testing::Test { +public: + static void SetUpTestCase(); + static void TearDownTestCase(); + virtual void SetUp() override; + virtual void TearDown() override; +}; +} // namespace DistributedHardware +} // namespace OHOS + +#endif // OHOS_IPC_CLIENT_PROXY_TEST_H diff --git a/test/unittest/UTTest_ipc_client_stub.cpp b/test/unittest/UTTest_ipc_client_stub.cpp new file mode 100644 index 000000000..d4acbe3af --- /dev/null +++ b/test/unittest/UTTest_ipc_client_stub.cpp @@ -0,0 +1,139 @@ +/* + * Copyright (c) 2021 Huawei Device Co., Ltd. + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#include "UTTest_ipc_client_stub.h" +#include "dm_device_info.h" +#include "ipc_remote_broker.h" +#include "iremote_object.h" +#include "iservice_registry.h" +#include "system_ability_definition.h" +#include "ipc_client_manager.h" +#include "ipc_set_useroperation_req.h" +#include "ipc_cmd_register.h" +#include "ipc_skeleton.h" +#include "ipc_types.h" +#include "ipc_rsp.h" +#include "ipc_def.h" +#include "dm_constants.h" + +#include + +namespace OHOS { +namespace DistributedHardware { +void IpcClientStubTest::SetUp() +{ +} + +void IpcClientStubTest::TearDown() +{ +} + +void IpcClientStubTest::SetUpTestCase() +{ +} + +void IpcClientStubTest::TearDownTestCase() +{ +} + +namespace { + +/** + * @tc.name: OnRemoteRequest_001 + * @tc.desc: 1. set MessageOption not null + * set MessageParcel not null + * set MessageParcel not null + * 2. set set code is 999 + * 3. call IpcClientStub OnRemoteRequest with parameter + * 4. check result is DM_FAILED + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcClientStubTest, OnRemoteRequest_001, testing::ext::TestSize.Level0) +{ + // 1. set MessageOption not null + MessageOption option; + // set MessageParcel not null + MessageParcel data; + // set MessageParcel not null + MessageParcel reply; + // 2. set set code is 999 + int code = 999; + sptr instance = new IpcClientStub(); + // 3. call IpcClientStub OnRemoteRequest with parameter + int32_t ret = instance->OnRemoteRequest(code,data,reply,option); + int32_t result = DM_OK; + if (ret != result) { + result = DM_FAILED; + } + // 4. check result is DM_FAILED + ASSERT_EQ(result, DM_FAILED); +} + +/** + * @tc.name: OnRemoteRequest_002 + * @tc.desc: 1. set MessageOption not null + * set MessageParcel not null + * set MessageParcel not null + * 2. set set code is SERVER_DEVICE_FA_NOTIFY + * 3. call IpcClientStub OnRemoteRequest with parameter + * 4. check result is DM_OK + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcClientStubTest, OnRemoteRequest_002, testing::ext::TestSize.Level0) +{ + // 1. set MessageOption not null + MessageOption option; + // set MessageParcel not null + MessageParcel data; + // set MessageParcel not null + MessageParcel reply; + // 2. set set code is SERVER_DEVICE_FA_NOTIFY + int code = SERVER_DEVICE_FA_NOTIFY; + sptr instance = new IpcClientStub(); + // 3. call IpcClientStub OnRemoteRequest with parameter + int ret = instance->OnRemoteRequest(code,data,reply,option); + // 4. check result is DM_OK + ASSERT_EQ(ret, DM_OK); +} + +/** + * @tc.name: SendCmd_001 + * @tc.desc: 1. set set code is SERVER_DEVICE_FA_NOTIFY + * set req is nullptr + * set rsp is nullptr + * 2. call IpcClientStub SendCmd with parameter + * 3. check result is DM_OK + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcClientStubTest, SendCmd_001, testing::ext::TestSize.Level0) +{ + // 1. set set code is SERVER_DEVICE_FA_NOTIFY + int cmdCode = SERVER_DEVICE_FA_NOTIFY; + // set req is nullptr + std::shared_ptr req = nullptr; + // set rsp is nullptr + std::shared_ptr rsp = nullptr; + sptr instance = new IpcClientStub(); + // 2. call IpcClientStub SendCmd with parameter + int ret = instance->SendCmd(cmdCode, req, rsp); + // 3. check result is DM_OK + ASSERT_EQ(ret, DM_OK); +} +} // namespace +} // namespace DistributedHardware +} // namespace OHOS diff --git a/test/unittest/UTTest_ipc_client_stub.h b/test/unittest/UTTest_ipc_client_stub.h new file mode 100644 index 000000000..5ba7391c9 --- /dev/null +++ b/test/unittest/UTTest_ipc_client_stub.h @@ -0,0 +1,35 @@ +/* + * Copyright (c) 2021 Huawei Device Co., Ltd. + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef OHOS_IPC_CLIENT_STUB_TEST_H +#define OHOS_IPC_CLIENT_STUB_TEST_H + +#include +#include + +#include "ipc_client_stub.h" +namespace OHOS { +namespace DistributedHardware { +class IpcClientStubTest : public testing::Test { +public: + static void SetUpTestCase(); + static void TearDownTestCase(); + virtual void SetUp() override; + virtual void TearDown() override; +}; +} // namespace DistributedHardware +} // namespace OHOS + +#endif // OHOS_IPC_CLIENT_STUB_TEST_H diff --git a/test/unittest/UTTest_ipc_server_client_proxy.cpp b/test/unittest/UTTest_ipc_server_client_proxy.cpp new file mode 100644 index 000000000..e855e0021 --- /dev/null +++ b/test/unittest/UTTest_ipc_server_client_proxy.cpp @@ -0,0 +1,208 @@ +/* + * Copyright (c) 2021 Huawei Device Co., Ltd. + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#include "UTTest_ipc_server_client_proxy.h" +#include "dm_device_info.h" +#include "ipc_remote_broker.h" +#include "iremote_object.h" +#include "iservice_registry.h" +#include "system_ability_definition.h" +#include "ipc_client_manager.h" +#include "ipc_set_useroperation_req.h" +#include "ipc_notify_device_state_req.h" +#include "ipc_rsp.h" +#include "ipc_notify_device_found_req.h" +#include "ipc_notify_discover_result_req.h" +#include "dm_constants.h" +#include + +namespace OHOS { +namespace DistributedHardware { +void IpcServerClientProxyTest::SetUp() +{ +} + +void IpcServerClientProxyTest::TearDown() +{ +} + +void IpcServerClientProxyTest::SetUpTestCase() +{ +} + +void IpcServerClientProxyTest::TearDownTestCase() +{ +} + +namespace { +/** + * @tc.name: SendCmd_001 + * @tc.desc: 1. set cmdCode not null + * 2. set remoteObject nullptr + * 3. call IpcServerClientProxy SendCmd + * 4. check ret is DEVICEMANAGER_NULLPTR + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcServerClientProxyTest, SendCmd_001, testing::ext::TestSize.Level0) +{ + // 1. set cmdCode not null + int32_t cmdCode = 1; + // 2. set remoteObject nullptr + sptr remoteObject = nullptr; + // 3. call IpcServerClientProxy SendCmd + auto instance = new IpcServerClientProxy(remoteObject); + int ret = instance->SendCmd(cmdCode,nullptr,nullptr); + // 4. check ret is DEVICEMANAGER_NULLPTR + ASSERT_EQ(ret, DM_POINT_NULL); +} + +/** + * @tc.name: SendCmd_002 + * @tc.desc: 1. set cmdCode not null + * set pkgName not null + * set action not null + * 2. set remoteObject not nullptr + * set req not null + * set rsp not null + * 3. call IpcServerClientProxy SendCmd with parameter + * 4. check ret is DM_OK + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcServerClientProxyTest, SendCmd_002, testing::ext::TestSize.Level0) +{ + // 1. set cmdCode not null + int32_t cmdCode = SERVER_DEVICE_STATE_NOTIFY; + //set pkgName not null + std::string pkgName = "com.ohos.test"; + //set action not null + int deviceState = 1; + DmDeviceInfo deviceInfo; + // 2. set remoteObject not nullptr + sptr remoteObject = sptr(new IpcClientStub()); + IpcServerStub::GetInstance().RegisterDeviceManagerListener(pkgName, remoteObject); + std::shared_ptr req = std::make_shared(); + std::shared_ptr rsp = std::make_shared(); + //set req not null + req->SetPkgName(pkgName); + //set rsp not null + req->SetDeviceState(deviceState); + req->SetDeviceInfo(deviceInfo); + // 3. call IpcServerClientProxy SendCmd with parameter + int ret = 0; + std::shared_ptr ipcServerListener = std::make_shared(); + ret = ipcServerListener->SendRequest(cmdCode, req, rsp); + // 4. check ret is DM_OK + ASSERT_EQ(ret, DM_OK); +} + +/** + * @tc.name: SendCmd_003 + * @tc.desc: 1. set cmdCode not null + * set pkgName not null + * set action not null + * 2. set remoteObject not nullptr + * set req not null + * set rsp not null + * 3. call IpcServerClientProxy SendCmd with parameter + * 4. check ret is DM_OK + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcServerClientProxyTest, SendCmd_003, testing::ext::TestSize.Level0) +{ + // 1. set cmdCode not null + int32_t cmdCode = SERVER_DEVICE_FOUND; + //set pkgName not null + std::string pkgName = "com.ohos.test"; + //set action not null + uint16_t subscribeId = 1; + DmDeviceInfo dmDeviceInfo; + // 2. set remoteObject not nullptr + sptr remoteObject = sptr(new IpcClientStub()); + IpcServerStub::GetInstance().RegisterDeviceManagerListener(pkgName, remoteObject); + std::shared_ptr req = std::make_shared(); + std::shared_ptr rsp = std::make_shared(); + //set req not null + req->SetPkgName(pkgName); + //set rsp not null + req->SetSubscribeId(subscribeId); + req->SetDeviceInfo(dmDeviceInfo); + // 3. call IpcServerClientProxy SendCmd with parameter + int ret = 0; + std::shared_ptr ipcServerListener = std::make_shared(); + ret = ipcServerListener->SendRequest(cmdCode, req, rsp); + // 4. check ret is DM_OK + ASSERT_EQ(ret, DM_OK); +} + +/* + * Feature: IpcServerClientProxy SendCmd + * Function: IpcServerClientProxy + * SubFunction: SendCmd + * FunctionPoints: IpcServerClientProxy SendCmd + * EnvConditions: SendCmd succeess. + * CaseDescription: 1. set cmdCode not null + * set pkgName not null + * set action not null + * 2. set remoteObject not nullptr + * set req not null + * set rsp not null + * 3. call IpcServerClientProxy SendCmd with parameter + * 4. check ret is DM_OK + */ +/** + * @tc.name: SendCmd_004 + * @tc.desc: 1. set cmdCode not null + * set pkgName not null + * set action not null + * 2. set remoteObject not nullptr + * set req not null + * set rsp not null + * 3. call IpcServerClientProxy SendCmd with parameter + * 4. check ret is DM_OK + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcServerClientProxyTest, SendCmd_004, testing::ext::TestSize.Level0) +{ + // 1. set cmdCode not null + int32_t cmdCode = SERVER_DISCOVER_FINISH; + //set pkgName not null + std::string pkgName = "com.ohos.test"; + //set action not null + uint16_t subscribeId = 1; + int32_t result = 1; + // 2. set remoteObject not nullptr + sptr remoteObject = sptr(new IpcClientStub()); + IpcServerStub::GetInstance().RegisterDeviceManagerListener(pkgName, remoteObject); + std::shared_ptr req = std::make_shared(); + std::shared_ptr rsp = std::make_shared(); + //set req not null + req->SetPkgName(pkgName); + //set rsp not null + req->SetSubscribeId(subscribeId); + req->SetResult(result); + // 3. call IpcServerClientProxy SendCmd with parameter + int ret = 0; + std::shared_ptr ipcServerListener = std::make_shared(); + ret = ipcServerListener->SendRequest(cmdCode, req, rsp); + // 4. check ret is DM_OK + ASSERT_EQ(ret, DM_OK); +} +} // namespace +} // namespace DistributedHardware +} // namespace OHOS diff --git a/test/unittest/UTTest_ipc_server_client_proxy.h b/test/unittest/UTTest_ipc_server_client_proxy.h new file mode 100644 index 000000000..2de4bdf6c --- /dev/null +++ b/test/unittest/UTTest_ipc_server_client_proxy.h @@ -0,0 +1,38 @@ +/* + * Copyright (c) 2021 Huawei Device Co., Ltd. + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef OHOS_IPC_SERVER_CLIENT_PROXY_TEST_H +#define OHOS_IPC_SERVER_CLIENT_PROXY_TEST_H + +#include + +#include "ipc_server_client_proxy.h" +#include "ipc_client_stub.h" +#include "ipc_server_stub.h" +#include "ipc_server_listener.h" + +namespace OHOS { +namespace DistributedHardware { +class IpcServerClientProxyTest : public testing::Test { +public: + static void SetUpTestCase(); + static void TearDownTestCase(); + virtual void SetUp() override; + virtual void TearDown() override; +}; +} // namespace DistributedHardware +} // namespace OHOS + +#endif // OHOS_IPC_SERVER_CLIENT_PROXY_TEST_H diff --git a/test/unittest/UTTest_ipc_server_listener.cpp b/test/unittest/UTTest_ipc_server_listener.cpp new file mode 100644 index 000000000..70052939a --- /dev/null +++ b/test/unittest/UTTest_ipc_server_listener.cpp @@ -0,0 +1,381 @@ +/* + * Copyright (c) 2021 Huawei Device Co., Ltd. + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#include "UTTest_ipc_server_listener.h" + +#include "dm_device_info.h" +#include "ipc_remote_broker.h" +#include "iremote_object.h" +#include "iservice_registry.h" +#include "system_ability_definition.h" +#include "ipc_client_manager.h" +#include "ipc_set_useroperation_req.h" +#include "ipc_notify_device_state_req.h" +#include "ipc_req.h" +#include "ipc_rsp.h" +#include "dm_constants.h" +#include + +namespace OHOS { +namespace DistributedHardware { +void IpcServerListenerTest::SetUp() +{ +} + +void IpcServerListenerTest::TearDown() +{ +} + +void IpcServerListenerTest::SetUpTestCase() +{ +} + +void IpcServerListenerTest::TearDownTestCase() +{ +} + +namespace { + +/** + * @tc.name: SendRequest_001 + * @tc.desc: 1. set cmdCode not null + * set pkgName not null + * 2. set remoteObject nullptr + * set req not null + * set rsp not null + * 3. call IpcServerListener SendRequest + * 4. check ret is DM_POINT_NULL + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcServerListenerTest, SendRequest_001, testing::ext::TestSize.Level0) +{ + // 1. set cmdCode not null + int32_t cmdCode = 999; + // set pkgName not null + std::string pkgName = "com.ohos.test"; + // 2. set remoteObject nullptr + sptr remoteObject = nullptr; + // set req not null + std::shared_ptr req = std::make_shared(); + // set rsp not null + std::shared_ptr rsp = std::make_shared(); + req->SetPkgName(pkgName); + // 3. call IpcServerListener SendRequest + std::shared_ptr ipcServerListener = std::make_shared(); + int ret = ipcServerListener->SendRequest(cmdCode, req, rsp); + // 4. check ret is DM_POINT_NULL + ASSERT_EQ(ret,DM_POINT_NULL); +} + +/** + * @tc.name: SendRequest_002 + * @tc.desc: 1. set cmdCode not null + * set pkgName not null + * 2. set remoteObject nullptr + * set req not null + * set rsp not null + * 3. call IpcServerListener SendRequest + * 4. check ret is DM_OK + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcServerListenerTest, SendRequest_002, testing::ext::TestSize.Level0) +{ + // 1. set cmdCode not null + int32_t cmdCode = SERVER_DEVICE_STATE_NOTIFY; + // set pkgName not null + std::string pkgName = "com.ohos.test"; + // 2. set remoteObject not nullptr + sptr remoteObject = sptr(new IpcClientStub()); + IpcServerStub::GetInstance().RegisterDeviceManagerListener(pkgName, remoteObject); + // set req not null + std::shared_ptr req = std::make_shared(); + // set rsp not null + std::shared_ptr rsp = std::make_shared(); + req->SetPkgName(pkgName); + // 3. call IpcServerListener SendRequest + std::shared_ptr ipcServerListener = std::make_shared(); + int ret = ipcServerListener->SendRequest(cmdCode, req, rsp); + // 4. check ret is DM_OK + ASSERT_EQ(ret, DM_OK); +} + +/** + * @tc.name: SendRequest_003 + * @tc.desc: 1. set cmdCode not null + * set pkgName not null + * 2. set remoteObject nullptr + * set req not null + * set rsp not null + * 3. call IpcServerListener SendRequest + * 4. check ret is DM_OK + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcServerListenerTest, SendRequest_003, testing::ext::TestSize.Level0) +{ + // 1. set cmdCode not null + int32_t cmdCode = 9999; + // set pkgName not null + std::string pkgName = "com.ohos.test"; + // 2. set remoteObject not nullptr + sptr remoteObject = sptr(new IpcClientStub()); + IpcServerStub::GetInstance().RegisterDeviceManagerListener(pkgName, remoteObject); + // set req not null + std::shared_ptr req = std::make_shared(); + // set rsp not null + std::shared_ptr rsp = std::make_shared(); + req->SetPkgName(pkgName); + // 3. call IpcServerListener SendRequest + std::shared_ptr ipcServerListener = std::make_shared(); + int ret = ipcServerListener->SendRequest(cmdCode, req, rsp); + // 4. check ret is DM_OK + ASSERT_EQ(ret, DM_OK); +} + +/** + * @tc.name: SendRequest_004 + * @tc.desc: 1. set cmdCode not null + * set pkgName not null + * 2. set remoteObject nullptr + * set req not null + * set rsp not null + * 3. call IpcServerListener SendRequest + * 4. check ret is DM_POINT_NULL + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcServerListenerTest, SendRequest_004, testing::ext::TestSize.Level0) +{ + // 1. set cmdCode not null + int32_t cmdCode = SERVER_DEVICE_STATE_NOTIFY; + // set pkgName not null + std::string pkgName = ""; + // 2. set remoteObject not nullptr + sptr remoteObject = sptr(new IpcClientStub()); + IpcServerStub::GetInstance().RegisterDeviceManagerListener(pkgName, remoteObject); + // set req not null + std::shared_ptr req = std::make_shared(); + // set rsp not null + std::shared_ptr rsp = std::make_shared(); + req->SetPkgName(pkgName); + // 3. call IpcServerListener SendRequest + std::shared_ptr ipcServerListener = std::make_shared(); + int ret = ipcServerListener->SendRequest(cmdCode, req, rsp); + // 4. check ret is DM_POINT_NULL + ASSERT_EQ(ret, DM_POINT_NULL); +} + +/** + * @tc.name: SendRequest_005 + * @tc.desc: 1. set cmdCode not null + * set pkgName not null + * 2. set remoteObject nullptr + * set req not null + * set rsp not null + * 3. call IpcServerListener SendRequest + * 4. check ret is DM_POINT_NULL + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcServerListenerTest, SendRequest_005, testing::ext::TestSize.Level0) +{ + // 1. set cmdCode not null + int32_t cmdCode = 9999; + // set pkgName not null + std::string pkgName = ""; + // 2. set remoteObject not nullptr + sptr remoteObject = sptr(new IpcClientStub()); + IpcServerStub::GetInstance().RegisterDeviceManagerListener(pkgName, remoteObject); + // set req not null + std::shared_ptr req = std::make_shared(); + // set rsp not null + std::shared_ptr rsp = std::make_shared(); + req->SetPkgName(pkgName); + // 3. call IpcServerListener SendRequest + std::shared_ptr ipcServerListener = std::make_shared(); + int ret = ipcServerListener->SendRequest(cmdCode, req, rsp); + // 4. check ret is DM_POINT_NULL + ASSERT_EQ(ret, DM_POINT_NULL); +} + +/** + * @tc.name: SendAll_001 + * @tc.desc: 1. set cmdCode not null + * set pkgName not null + * 2. set remoteObject nullptr + * set req not null + * set rsp not null + * 3. call IpcServerListener SendRequest + * 4. check ret is DM_OK + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcServerListenerTest, SendAll_001, testing::ext::TestSize.Level0) +{ + // 1. set cmdCode not null + int32_t cmdCode = SERVER_DEVICE_STATE_NOTIFY; + // set pkgName not null + std::string pkgName = "com.ohos.test"; + // 2. set remoteObject not nullptr + sptr remoteObject = sptr(new IpcClientStub()); + IpcServerStub::GetInstance().RegisterDeviceManagerListener(pkgName, remoteObject); + // set req not null + std::shared_ptr req = std::make_shared(); + // set rsp not null + std::shared_ptr rsp = std::make_shared(); + req->SetPkgName(pkgName); + // 3. call IpcServerListener SendRequest + std::shared_ptr ipcServerListener = std::make_shared(); + int ret = ipcServerListener->SendAll(cmdCode, req, rsp); + // 4. check ret is DM_OK + ASSERT_EQ(ret, DM_OK); +} + +/** + * @tc.name: SendAll_002 + * @tc.desc: 1. set cmdCode not null + * set pkgName not null + * 2. set remoteObject nullptr + * set req not null + * set rsp not null + * 3. call IpcServerListener SendRequest + * 4. check ret is DM_OK + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcServerListenerTest, SendAll_002, testing::ext::TestSize.Level0) +{ + // 1. set cmdCode not null + int32_t cmdCode = 9999; + // set pkgName not null + std::string pkgName = "com.ohos.test"; + // 2. set remoteObject not nullptr + sptr remoteObject = sptr(new IpcClientStub()); + IpcServerStub::GetInstance().RegisterDeviceManagerListener(pkgName, remoteObject); + // set req not null + std::shared_ptr req = std::make_shared(); + // set rsp not null + std::shared_ptr rsp = std::make_shared(); + req->SetPkgName(pkgName); + // 3. call IpcServerListener SendRequest + std::shared_ptr ipcServerListener = std::make_shared(); + int ret = ipcServerListener->SendAll(cmdCode, req, rsp); + // 4. check ret is DM_OK + ASSERT_EQ(ret, DM_OK); +} + +/** + * @tc.name: SendAll_003 + * @tc.desc: 1. set cmdCode not null + * set pkgName not null + * 2. set remoteObject nullptr + * set req not null + * set rsp not null + * 3. call IpcServerListener SendRequest + * 4. check ret is DM_OK + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcServerListenerTest, SendAll_003, testing::ext::TestSize.Level0) +{ + // 1. set cmdCode not null + int32_t cmdCode = SERVER_DEVICE_STATE_NOTIFY; + // set pkgName not null + std::string pkgName = ""; + // 2. set remoteObject not nullptr + sptr remoteObject = sptr(new IpcClientStub()); + IpcServerStub::GetInstance().RegisterDeviceManagerListener(pkgName, remoteObject); + // set req not null + std::shared_ptr req = std::make_shared(); + // set rsp not null + std::shared_ptr rsp = std::make_shared(); + req->SetPkgName(pkgName); + // 3. call IpcServerListener SendRequest + std::shared_ptr ipcServerListener = std::make_shared(); + int ret = ipcServerListener->SendAll(cmdCode, req, rsp); + // 4. check ret is DM_OK + ASSERT_EQ(ret, DM_OK); +} + +/** + * @tc.name: SendAll_004 + * @tc.desc: 1. set cmdCode not null + * set pkgName not null + * 2. set remoteObject nullptr + * set req not null + * set rsp not null + * 3. call IpcServerListener SendRequest + * 4. check ret is DM_OK + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcServerListenerTest, SendAll_004, testing::ext::TestSize.Level0) +{ + // 1. set cmdCode not null + int32_t cmdCode = 9999; + // set pkgName not null + std::string pkgName = ""; + // 2. set remoteObject not nullptr + sptr remoteObject = sptr(new IpcClientStub()); + IpcServerStub::GetInstance().RegisterDeviceManagerListener(pkgName, remoteObject); + // set req not null + std::shared_ptr req = std::make_shared(); + // set rsp not null + std::shared_ptr rsp = std::make_shared(); + req->SetPkgName(pkgName); + // 3. call IpcServerListener SendRequest + std::shared_ptr ipcServerListener = std::make_shared(); + int ret = ipcServerListener->SendAll(cmdCode, req, rsp); + // 4. check ret is DM_OK + ASSERT_EQ(ret, DM_OK); +} + +/** + * @tc.name: SendAll_005 + * @tc.desc: 1. set cmdCode not null + * set pkgName not null + * 2. set remoteObject nullptr + * set req not null + * set rsp not null + * 3. call IpcServerListener SendRequest + * 4. check ret is DM_OK + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcServerListenerTest, SendAll_005, testing::ext::TestSize.Level0) +{ + // 1. set cmdCode not null + int32_t cmdCode = SERVER_DEVICE_STATE_NOTIFY; + // set pkgName not null + std::string pkgName = "com.ohos.test"; + // 2. set remoteObject not nullptr + sptr remoteObject = sptr(new IpcClientStub()); + IpcServerStub::GetInstance().RegisterDeviceManagerListener(pkgName, remoteObject); + // set req not null + std::shared_ptr req = std::make_shared(); + // set rsp not null + std::shared_ptr rsp = nullptr; + req->SetPkgName(pkgName); + // 3. call IpcServerListener SendRequest + std::shared_ptr ipcServerListener = std::make_shared(); + int ret = ipcServerListener->SendAll(cmdCode, req, rsp); + // 4. check ret is DM_OK + ASSERT_EQ(ret, DM_OK); +} +} // namespace +} // namespace DistributedHardware +} // namespace OHOS diff --git a/test/unittest/UTTest_ipc_server_listener.h b/test/unittest/UTTest_ipc_server_listener.h new file mode 100644 index 000000000..0d51a7aac --- /dev/null +++ b/test/unittest/UTTest_ipc_server_listener.h @@ -0,0 +1,36 @@ +/* + * Copyright (c) 2021 Huawei Device Co., Ltd. + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef OHOS_IPC_SERVER_LISTENER_TEST_H +#define OHOS_IPC_SERVER_LISTENER_TEST_H + +#include + +#include "ipc_client_stub.h" +#include "ipc_server_stub.h" +#include "ipc_server_listener.h" +namespace OHOS { +namespace DistributedHardware { +class IpcServerListenerTest : public testing::Test { +public: + static void SetUpTestCase(); + static void TearDownTestCase(); + virtual void SetUp() override; + virtual void TearDown() override; +}; +} // namespace DistributedHardware +} // namespace OHOS + +#endif // OHOS_IPC_SERVER_CLIENT_PROXY_TEST_H diff --git a/test/unittest/UTTest_ipc_server_stub.cpp b/test/unittest/UTTest_ipc_server_stub.cpp new file mode 100644 index 000000000..29f8c8940 --- /dev/null +++ b/test/unittest/UTTest_ipc_server_stub.cpp @@ -0,0 +1,547 @@ +/* + * Copyright (c) 2021 Huawei Device Co., Ltd. + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#include "UTTest_ipc_server_stub.h" +#include "dm_device_info.h" +#include "ipc_server_stub.h" +#include "device_manager_impl.h" +#include "dm_constants.h" +#include "if_system_ability_manager.h" +#include "ipc_cmd_register.h" +#include "ipc_skeleton.h" +#include "ipc_types.h" +#include "iservice_registry.h" +#include "string_ex.h" +#include "system_ability_definition.h" + +#include +#include +#include + +namespace OHOS { +namespace DistributedHardware { +void IpcServerStubTest::SetUp() +{ +} + +void IpcServerStubTest::TearDown() +{ +} + +void IpcServerStubTest::SetUpTestCase() +{ +} + +void IpcServerStubTest::TearDownTestCase() +{ +} + +namespace { + +/** + * @tc.name: OnStart_001 + * @tc.desc: 1. Call IpcServerStub OnStart + * 2. check IpcServerStub.state is ServiceRunningState::STATE_RUNNING + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcServerStubTest, OnStart_001, testing::ext::TestSize.Level0) +{ + // 1. Call IpcServerStub OnStart + IpcServerStub::GetInstance().OnStart(); + // 2. check IpcServerStub.state is ServiceRunningState::STATE_RUNNING + ASSERT_EQ(ServiceRunningState::STATE_RUNNING, IpcServerStub::GetInstance().state_); +} + +/** + * @tc.name: OnStart_002 + * @tc.desc: 1. set IpcServerStub state is ServiceRunningState::STATE_RUNNING + * 2. Call IpcServerStub OnStart + * 3. check IpcServerStub.state is ServiceRunningState::STATE_RUNNING + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcServerStubTest, OnStart_002, testing::ext::TestSize.Level0) +{ + // 1. set IpcServerStub state is ServiceRunningState::STATE_RUNNING + IpcServerStub::GetInstance().state_ = ServiceRunningState::STATE_RUNNING; + // 2. Call IpcServerStub OnStart + IpcServerStub::GetInstance().OnStart(); + // 3. check IpcServerStub.state is ServiceRunningState::STATE_RUNNING + ASSERT_EQ(ServiceRunningState::STATE_RUNNING, IpcServerStub::GetInstance().state_); +} + +/** + * @tc.name: Init_001 + * @tc.desc: 1. Call IpcServerStub OnStart + * 2. check IpcServerStub.state is ServiceRunningState::STATE_RUNNING + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcServerStubTest, Init_001, testing::ext::TestSize.Level0) +{ + IpcServerStub::GetInstance().registerToService_=true; + bool result = IpcServerStub::GetInstance().Init(); + // 2. check IpcServerStub.state is ServiceRunningState::STATE_RUNNING + ASSERT_EQ(result, true); +} + +/** + * @tc.name: Init_002 + * @tc.desc: 1. Call IpcServerStub OnStart + * 2. check IpcServerStub.state is ServiceRunningState::STATE_RUNNING + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcServerStubTest, Init_002, testing::ext::TestSize.Level0) +{ + IpcServerStub::GetInstance().registerToService_=false; + bool result = IpcServerStub::GetInstance().Init(); + // 2. check IpcServerStub.state is ServiceRunningState::STATE_RUNNING + ASSERT_EQ(result, true); +} + +/** + * @tc.name: OnStop_001 + * @tc.desc: 1. Call IpcServerStub OnStop + * 2. check IpcServerStub.state is ServiceRunningState::STATE_RUNNING + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcServerStubTest, OnStop_001, testing::ext::TestSize.Level0) +{ + // 1. Call IpcServerStub OnStop + IpcServerStub::GetInstance().OnStop(); + // 2. check IpcServerStub.state is ServiceRunningState::STATE_RUNNING + ASSERT_EQ(ServiceRunningState::STATE_NOT_START, IpcServerStub::GetInstance().state_); + ASSERT_EQ(IpcServerStub::GetInstance().registerToService_,false); +} + +/** + * @tc.name: OnRemoteRequest_001 + * @tc.desc: 1. Set Code = 999 + * 2. Call IpcServerStub OnRemoteRequest with param + * 3. check ret not DM_OK + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcServerStubTest, OnRemoteRequest_001, testing::ext::TestSize.Level0) +{ + // 1. Set Code = 999 + uint32_t code = 999; + MessageParcel data; + MessageParcel reply; + MessageOption option; + int ret = 0; + // 2. Call IpcServerStub OnRemoteRequest with param + ret = IpcServerStub::GetInstance().OnRemoteRequest(code, data, reply, option); + // 3. check ret not DM_OK + ASSERT_NE(ret, DM_OK); +} + +/** + * @tc.name: OnRemoteRequest_002 + * @tc.desc: 1. Set Code = 999 + * 2. Call IpcServerStub OnRemoteRequest with param + * 3. check ret not DM_OK + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcServerStubTest, OnRemoteRequest_002, testing::ext::TestSize.Level0) +{ + // 1. Set Code is SERVER_DEVICE_STATE_NOTIFY + uint32_t code = SERVER_DEVICE_STATE_NOTIFY; + MessageParcel data; + MessageParcel reply; + MessageOption option; + int ret = 0; + // 2. Call IpcServerStub OnRemoteRequest with param + ret = IpcServerStub::GetInstance().OnRemoteRequest(code, data, reply, option); + // 3. check ret not DM_OK + ASSERT_EQ(ret, DM_OK); +} + +/** + * @tc.name: SendCmd_001 + * @tc.desc: 1. Call IpcServerStub SendCmd + * 2. check ret is DM_OK + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcServerStubTest, SendCmd_001, testing::ext::TestSize.Level0) +{ + int32_t cmdCode = 1; + std::shared_ptr req = std::make_shared(); + std::shared_ptr rsp = std::make_shared(); + // 1. Call IpcServerStub SendCmd + int32_t ret = IpcServerStub::GetInstance().SendCmd(cmdCode, req, rsp); + // 2. check ret is DM_OK + ASSERT_EQ(ret, DM_OK); +} + +/** + * @tc.name: QueryServiceState_001 + * @tc.desc: 1. Call IpcServerStub QueryServiceState + * 2. check IpcServerStub.state is ServiceRunningState::STATE_RUNNING + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcServerStubTest, QueryServiceState_001, testing::ext::TestSize.Level0) +{ + IpcServerStub::GetInstance().state_ = ServiceRunningState::STATE_NOT_START; + // 1. Call IpcServerStub QueryServiceState + ServiceRunningState state = IpcServerStub::GetInstance().QueryServiceState(); + // 2. check IpcServerStub.state is ServiceRunningState::STATE_RUNNING + ASSERT_EQ(state, ServiceRunningState::STATE_NOT_START); +} + +/** + * @tc.name: RegisterDeviceManagerListener_001 + * @tc.desc: 1. Call IpcServerStub RegisterDeviceManagerListener + * 2. check IpcServerStub.state is ServiceRunningState::STATE_RUNNING + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcServerStubTest, RegisterDeviceManagerListener_001, testing::ext::TestSize.Level0) +{ + std::string pkgName = ""; + int ret = 0; + sptr listener = nullptr; + ret = IpcServerStub::GetInstance().RegisterDeviceManagerListener(pkgName, listener); + ASSERT_EQ(ret, DM_POINT_NULL); +} + +/** + * @tc.name: RegisterDeviceManagerListener_002 + * @tc.desc: 1. Call IpcServerStub RegisterDeviceManagerListener + * 2. check IpcServerStub.state is ServiceRunningState::STATE_RUNNING + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcServerStubTest, RegisterDeviceManagerListener_002, testing::ext::TestSize.Level0) +{ + std::string pkgName = "com.ohos.test"; + int ret = 0; + sptr listener = sptr(new IpcClientStub()); + ret = IpcServerStub::GetInstance().RegisterDeviceManagerListener(pkgName, listener); + ASSERT_EQ(ret, DM_OK); +} + +/** + * @tc.name: RegisterDeviceManagerListener_003 + * @tc.desc: 1. Call IpcServerStub RegisterDeviceManagerListener + * 2. check IpcServerStub.state is ServiceRunningState::STATE_RUNNING + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcServerStubTest, RegisterDeviceManagerListener_003, testing::ext::TestSize.Level0) +{ + std::string pkgName = ""; + int ret = 0; + sptr listener = sptr(new IpcClientStub()); + ret = IpcServerStub::GetInstance().RegisterDeviceManagerListener(pkgName, listener); + ASSERT_EQ(ret, DM_POINT_NULL); +} + +/** + * @tc.name: RegisterDeviceManagerListener_004 + * @tc.desc: 1. Set PkgName is com.ohos.test + * 2. Call IpcServerStub RegisterDeviceManagerListener with param + * 3. check ret is DM_OK + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcServerStubTest, RegisterDeviceManagerListener_004, testing::ext::TestSize.Level0) +{ + // 1. Set PkgName is com.ohos.test + std::string pkgName = "com.ohos.test"; + int ret = 0; + sptr listener = sptr(new IpcClientStub()); + // 2. Call IpcServerStub RegisterDeviceManagerListener with param + ret = IpcServerStub::GetInstance().RegisterDeviceManagerListener(pkgName, listener); + // 3. check ret is DM_OK + ASSERT_EQ(ret, DM_OK); +} + +/** + * @tc.name: RegisterDeviceManagerListener_005 + * @tc.desc: 1. Set PkgName is com.ohos.test + * 2. Call IpcServerStub RegisterDeviceManagerListener with param + * 3. check ret is DM_OK + * 4. Call IpcServerStub RegisterDeviceManagerListener with same pkgName another listener + * 5. check result is DM_OK + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcServerStubTest, RegisterDeviceManagerListener_005, testing::ext::TestSize.Level0) +{ + // 1. Set PkgName is com.ohos.test + std::string pkgName = "com.ohos.test"; + int ret = 0; + int result = 0; + sptr listener = sptr(new IpcClientStub()); + // 2. Call IpcServerStub RegisterDeviceManagerListener with param + ret = IpcServerStub::GetInstance().RegisterDeviceManagerListener(pkgName, listener); + // 3. check ret is DM_OK + ASSERT_EQ(ret, DM_OK); + sptr listener2 = sptr(new IpcClientStub()); + // 4. Call IpcServerStub RegisterDeviceManagerListener with same pkgName another listener + result = IpcServerStub::GetInstance().RegisterDeviceManagerListener(pkgName, listener2); + // 5. check result is DM_OK + ASSERT_EQ(result, DM_OK); +} + +/** + * @tc.name: UnRegisterDeviceManagerListener_001 + * @tc.desc: 1. Call IpcServerStub UnRegisterDeviceManagerListener + * 2. check ret is DM_POINT_NULL + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcServerStubTest, UnRegisterDeviceManagerListener_001, testing::ext::TestSize.Level0) +{ + std::string pkgName = ""; + int ret = 0; + ret = IpcServerStub::GetInstance().UnRegisterDeviceManagerListener(pkgName); + ASSERT_EQ(ret, DM_POINT_NULL); +} + +/** + * @tc.name: UnRegisterDeviceManagerListener_002 + * @tc.desc: 1. Set PkgName is com.ohos.test + * 2. Call IpcServerStub RegisterDeviceManagerListener with param + * 3. check ret is DM_OK + * 4. Call IpcServerStub UnRegisterDeviceManagerListener + * 5. check ret is DM_OK + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcServerStubTest, UnRegisterDeviceManagerListener_002, testing::ext::TestSize.Level0) +{ + // 1. Set PkgName is com.ohos.test + std::string pkgName = "com.ohos.test"; + int ret = 0; + sptr listener = sptr(new IpcClientStub()); + // 2. Call IpcServerStub RegisterDeviceManagerListener with param + ret = IpcServerStub::GetInstance().RegisterDeviceManagerListener(pkgName, listener); + // 3. check ret is DM_OK + ASSERT_EQ(ret, DM_OK); + int result = 0; + // 4. Call IpcServerStub UnRegisterDeviceManagerListener + result = IpcServerStub::GetInstance().UnRegisterDeviceManagerListener(pkgName); + // 5. check ret is DM_OK + ASSERT_EQ(result, DM_OK); +} + +/** + * @tc.name: UnRegisterDeviceManagerListener_003 + * @tc.desc: 1. Set pkgName is com.ohos.test + * 2. Call IpcServerStub UnRegisterDeviceManagerListener + * 3. check ret is DM_OK + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcServerStubTest, UnRegisterDeviceManagerListener_003, testing::ext::TestSize.Level0) +{ + // 1. Set pkgName is com.ohos.test + std::string pkgName = "com.ohos.test"; + int ret = 0; + // 2. Call IpcServerStub UnRegisterDeviceManagerListener + ret = IpcServerStub::GetInstance().UnRegisterDeviceManagerListener(pkgName); + // 3. check ret is DM_OK + ASSERT_EQ(ret, DM_OK); +} + +/** + * @tc.name: UnRegisterDeviceManagerListener_004 + * @tc.desc: 1. Set PkgName is com.ohos.test + * 2. Call IpcServerStub RegisterDeviceManagerListener with param + * 3. check ret is DM_OK + * 4. Call IpcServerStub UnRegisterDeviceManagerListener + * 5. check ret is DM_OK + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcServerStubTest, UnRegisterDeviceManagerListener_004, testing::ext::TestSize.Level0) +{ + // 1. Set PkgName is com.ohos.test + std::string pkgName = "com.ohos.test1"; + int ret = 0; + sptr listener = sptr(new IpcClientStub()); + // 2. Call IpcServerStub RegisterDeviceManagerListener with param + ret = IpcServerStub::GetInstance().RegisterDeviceManagerListener(pkgName, listener); + // 3. check ret is DM_OK + ASSERT_EQ(ret, DM_OK); + int result = 0; + // 4. Call IpcServerStub UnRegisterDeviceManagerListener + result = IpcServerStub::GetInstance().UnRegisterDeviceManagerListener(pkgName); + // 5. check ret is DM_OK + ASSERT_EQ(result, DM_OK); + sptr dmListener = IpcServerStub::GetInstance().dmListener_[pkgName]; + ASSERT_EQ(dmListener, nullptr); +} + +/** + * @tc.name: UnRegisterDeviceManagerListener_005 + * @tc.desc: 1. Set PkgName is com.ohos.test + * 2. Call IpcServerStub RegisterDeviceManagerListener with param + * 3. check ret is DM_OK + * 4. Call IpcServerStub UnRegisterDeviceManagerListener + * 5. check ret is DM_OK + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcServerStubTest, UnRegisterDeviceManagerListener_005, testing::ext::TestSize.Level0) +{ + // 1. Set PkgName is com.ohos.test + std::string pkgName = "com.ohos.test2"; + int ret = 0; + sptr listener = sptr(new IpcClientStub()); + // 2. Call IpcServerStub RegisterDeviceManagerListener with param + ret = IpcServerStub::GetInstance().RegisterDeviceManagerListener(pkgName, listener); + // 3. check ret is DM_OK + ASSERT_EQ(ret, DM_OK); + int result = 0; + // 4. Call IpcServerStub UnRegisterDeviceManagerListener + std::string testPkgName = "com.test"; + result = IpcServerStub::GetInstance().UnRegisterDeviceManagerListener(testPkgName); + // 5. check ret is DM_OK + ASSERT_EQ(result, DM_OK); + sptr dmListener = IpcServerStub::GetInstance().dmListener_[pkgName]; + ASSERT_NE(dmListener, nullptr); +} + +/** + * @tc.name: GetDmListener_001 + * @tc.desc: 1. Set pkgName is com.ohos.test + * 2. Call IpcServerStub GetDmListener + * 3. check ret is DM_OK + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcServerStubTest, GetDmListener_001, testing::ext::TestSize.Level0) +{ + // 1. Set pkgName is com.ohos.test + std::string pkgName = "com.ohos.test"; + sptr ret = nullptr; + // 2. Call IpcServerStub UnRegisterDeviceManagerListener + ret = IpcServerStub::GetInstance().GetDmListener(pkgName); + // 3. check ret is DM_OK + ASSERT_EQ(ret, nullptr); +} + +/** + * @tc.name: GetDmListener_002 + * @tc.desc: 1. Set pkgName is com.ohos.test + * 2. Call IpcServerStub GetDmListener + * 3. check ret is DM_OK + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcServerStubTest, GetDmListener_002, testing::ext::TestSize.Level0) +{ + // 1. Set pkgName is com.ohos.test + std::string pkgName = "com.ohos.test"; + int result = 0; + sptr listener = sptr(new IpcClientStub()); + // 2. Call IpcServerStub RegisterDeviceManagerListener with param + result = IpcServerStub::GetInstance().RegisterDeviceManagerListener(pkgName, listener); + // 3. check ret is DM_OK + ASSERT_EQ(result, DM_OK); + sptr ret = nullptr; + // 2. Call IpcServerStub UnRegisterDeviceManagerListener + ret = IpcServerStub::GetInstance().GetDmListener(pkgName); + // 3. check ret is DM_OK + ASSERT_NE(ret, nullptr); +} + +/** + * @tc.name: GetDmListener_003 + * @tc.desc: 1. Set pkgName is com.ohos.test + * 2. Call IpcServerStub GetDmListener + * 3. check ret is DM_OK + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcServerStubTest, GetDmListener_003, testing::ext::TestSize.Level0) +{ + // 1. Set pkgName is com.ohos.test + std::string pkgName = "com.ohos.test"; + int result = 0; + sptr listener = sptr(new IpcClientStub()); + // 2. Call IpcServerStub RegisterDeviceManagerListener with param + result = IpcServerStub::GetInstance().RegisterDeviceManagerListener(pkgName, listener); + // 3. check ret is DM_OK + ASSERT_EQ(result, DM_OK); + sptr ret = nullptr; + // 2. Call IpcServerStub UnRegisterDeviceManagerListener + std::string testPkgName = "test"; + ret = IpcServerStub::GetInstance().GetDmListener(testPkgName); + // 3. check ret is DM_OK + ASSERT_EQ(ret, nullptr); +} + +/** + * @tc.name: GetDmListener_004 + * @tc.desc: 1. Set pkgName is com.ohos.test + * 2. Call IpcServerStub GetDmListener + * 3. check ret is DM_POINT_NULL + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcServerStubTest, GetDmListener_004, testing::ext::TestSize.Level0) +{ + // 1. Set pkgName is null + std::string pkgName = ""; + int result = 0; + sptr listener = sptr(new IpcClientStub()); + // 2. Call IpcServerStub RegisterDeviceManagerListener with param + result = IpcServerStub::GetInstance().RegisterDeviceManagerListener(pkgName, listener); + // 3. check ret is DM_POINT_NULL + ASSERT_EQ(result, DM_POINT_NULL); + sptr ret = nullptr; + // 2. Call IpcServerStub UnRegisterDeviceManagerListener + ret = IpcServerStub::GetInstance().GetDmListener(pkgName); + // 3. check ret is nullptr + ASSERT_EQ(ret, nullptr); +} + +/** + * @tc.name: GetDmListener_005 + * @tc.desc: 1. Set pkgName is com.ohos.test + * 2. Call IpcServerStub GetDmListener + * 3. check ret is DM_POINT_NULL + * @tc.type: FUNC + * @tc.require: AR000GHSJK + */ +HWTEST_F(IpcServerStubTest, GetDmListener_005, testing::ext::TestSize.Level0) +{ + // 1. Set pkgName is null + std::string pkgName = "com.test.ohos"; + int result = 0; + sptr listener = nullptr; + // 2. Call IpcServerStub RegisterDeviceManagerListener with param + result = IpcServerStub::GetInstance().RegisterDeviceManagerListener(pkgName, listener); + // 3. check ret is DM_POINT_NULL + ASSERT_EQ(result, DM_POINT_NULL); + sptr ret = nullptr; + // 2. Call IpcServerStub UnRegisterDeviceManagerListener + ret = IpcServerStub::GetInstance().GetDmListener(pkgName); + // 3. check ret is nullptr + ASSERT_EQ(ret, nullptr); +} +} // namespace +} // namespace DistributedHardware +} // namespace OHOS diff --git a/test/unittest/UTTest_ipc_server_stub.h b/test/unittest/UTTest_ipc_server_stub.h new file mode 100644 index 000000000..f4b00c361 --- /dev/null +++ b/test/unittest/UTTest_ipc_server_stub.h @@ -0,0 +1,36 @@ +/* + * Copyright (c) 2021 Huawei Device Co., Ltd. + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef OHOS_IPC_SERVER_STUB_TEST_H +#define OHOS_IPC_SERVER_STUB_TEST_H + +#include + +#include "ipc_client_stub.h" +#include "ipc_server_stub.h" +#include "ipc_server_listener.h" +namespace OHOS { +namespace DistributedHardware { +class IpcServerStubTest : public testing::Test { +public: + static void SetUpTestCase(); + static void TearDownTestCase(); + virtual void SetUp() override; + virtual void TearDown() override; +}; +} // namespace DistributedHardware +} // namespace OHOS + +#endif // OHOS_IPC_SERVER_STUB_TEST_H diff --git a/test/unittest/UTTest_softbus_session.cpp b/test/unittest/UTTest_softbus_session.cpp index 8d14ff0e1..a56afc6f4 100644 --- a/test/unittest/UTTest_softbus_session.cpp +++ b/test/unittest/UTTest_softbus_session.cpp @@ -41,8 +41,7 @@ std::shared_ptr softbusSession = std::make_shared listener_ = std::make_shared(); std::shared_ptr softbusConnector = std::make_shared(); std::shared_ptr hiChainConnector = std::make_shared(); -std::shared_ptr discoveryMgr_ = - std::make_shared(softbusConnector, listener_, hiChainConnector); +std::shared_ptr discoveryMgr_ = std::make_shared(softbusConnector, listener_, hiChainConnector); /** * @tc.name: OpenAuthSession_001 diff --git a/test/unittest/auth_request_state.cpp b/test/unittest/auth_request_state.cpp index 7b6797cbc..71fd0b9b7 100644 --- a/test/unittest/auth_request_state.cpp +++ b/test/unittest/auth_request_state.cpp @@ -1,191 +1,191 @@ -/* - * Copyright (c) 2021 Huawei Device Co., Ltd. - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -#include "auth_request_state.h" - -#include "dm_auth_manager.h" -#include "dm_constants.h" - -namespace OHOS { -namespace DistributedHardware { -int32_t AuthRequestState::Leave() -{ - return DM_OK; -} - -int32_t AuthRequestState::SetAuthManager(std::shared_ptr authManager) -{ - authManager_ = std::move(authManager); - return DM_OK; -} - -int32_t AuthRequestState::SetAuthContext(std::shared_ptr context) -{ - context_ = std::move(context); - return DM_OK; -} - -std::shared_ptr AuthRequestState::GetAuthContext() -{ - return context_; -} - -int32_t AuthRequestState::TransitionTo(std::shared_ptr state) -{ - LOGE("AuthRequestState::TransitionTo"); - std::shared_ptr stateAuthManager = authManager_.lock(); - if (stateAuthManager == nullptr) { - LOGE("AuthRequestState::authManager_ null"); - return DM_FAILED; - } - state->SetAuthManager(stateAuthManager); - stateAuthManager->SetAuthRequestState(state); - state->SetAuthContext(context_); - this->Leave(); - state->Enter(); - return DM_OK; -} - -int32_t AuthRequestInitState::GetStateType() -{ - return AuthState::AUTH_REQUEST_INIT; -} - -int32_t AuthRequestInitState::Enter() -{ - std::shared_ptr stateAuthManager = authManager_.lock(); - if (stateAuthManager == nullptr) { - LOGE("AuthRequestState::authManager_ null"); - return DM_FAILED; - } - stateAuthManager->EstablishAuthChannel(context_->deviceId); - return DM_OK; -} - -int32_t AuthRequestNegotiateState::GetStateType() -{ - return AuthState::AUTH_REQUEST_NEGOTIATE; -} - -int32_t AuthRequestNegotiateState::Enter() -{ - std::shared_ptr stateAuthManager = authManager_.lock(); - if (stateAuthManager == nullptr) { - LOGE("AuthRequestState::authManager_ null"); - return DM_FAILED; - } - stateAuthManager->StartNegotiate(context_->sessionId); - return DM_OK; -} - -int32_t AuthRequestNegotiateDoneState::GetStateType() -{ - return AuthState::AUTH_REQUEST_NEGOTIATE_DONE; -} - -int32_t AuthRequestNegotiateDoneState::Enter() -{ - std::shared_ptr stateAuthManager = authManager_.lock(); - if (stateAuthManager == nullptr) { - LOGE("AuthRequestState::authManager_ null"); - return DM_FAILED; - } - stateAuthManager->SendAuthRequest(context_->sessionId); - return DM_OK; -} - -int32_t AuthRequestReplyState::GetStateType() -{ - return AuthState::AUTH_REQUEST_REPLY; -} - -int32_t AuthRequestReplyState::Enter() -{ - std::shared_ptr stateAuthManager = authManager_.lock(); - if (stateAuthManager == nullptr) { - LOGE("AuthRequestState::authManager_ null"); - return DM_FAILED; - } - stateAuthManager->StartRespAuthProcess(); - return DM_OK; -} - -int32_t AuthRequestInputState::GetStateType() -{ - return AuthState::AUTH_REQUEST_INPUT; -} - -int32_t AuthRequestInputState::Enter() -{ - LOGE("DmAuthManager::AuthRequestInputState"); - std::shared_ptr stateAuthManager = authManager_.lock(); - if (stateAuthManager == nullptr) { - LOGE("AuthRequestState::authManager_ null"); - return DM_FAILED; - } - stateAuthManager->ShowStartAuthDialog(); - return DM_OK; -} - -int32_t AuthRequestJoinState::GetStateType() -{ - return AuthState::AUTH_REQUEST_JOIN; -} - -int32_t AuthRequestJoinState::Enter() -{ - LOGE("DmAuthManager::AuthRequestJoinState"); - std::shared_ptr stateAuthManager = authManager_.lock(); - if (stateAuthManager == nullptr) { - LOGE("AuthRequestState::authManager_ null"); - return DM_FAILED; - } - stateAuthManager->AddMember(context_->deviceId); - return DM_OK; -} - -int32_t AuthRequestNetworkState::GetStateType() -{ - return AuthState::AUTH_REQUEST_NETWORK; -} - -int32_t AuthRequestNetworkState::Enter() -{ - std::shared_ptr stateAuthManager = authManager_.lock(); - if (stateAuthManager == nullptr) { - LOGE("AuthRequestState::authManager_ null"); - return DM_FAILED; - } - stateAuthManager->JoinNetwork(); - return DM_OK; -} - -int32_t AuthRequestFinishState::GetStateType() -{ - return AuthState::AUTH_REQUEST_FINISH; -} - -int32_t AuthRequestFinishState::Enter() -{ - std::shared_ptr stateAuthManager = authManager_.lock(); - if (stateAuthManager == nullptr) { - LOGE("AuthRequestState::authManager_ null"); - return DM_FAILED; - } - stateAuthManager->AuthenticateFinish(); - return DM_OK; -} -} // namespace DistributedHardware -} // namespace OHOS +/* + * Copyright (c) 2021 Huawei Device Co., Ltd. + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#include "auth_request_state.h" + +#include "dm_auth_manager.h" +#include "dm_constants.h" + +namespace OHOS { +namespace DistributedHardware { +int32_t AuthRequestState::Leave() +{ + return DM_OK; +} + +int32_t AuthRequestState::SetAuthManager(std::shared_ptr authManager) +{ + authManager_ = std::move(authManager); + return DM_OK; +} + +int32_t AuthRequestState::SetAuthContext(std::shared_ptr context) +{ + context_ = std::move(context); + return DM_OK; +} + +std::shared_ptr AuthRequestState::GetAuthContext() +{ + return context_; +} + +int32_t AuthRequestState::TransitionTo(std::shared_ptr state) +{ + LOGE("AuthRequestState::TransitionTo"); + std::shared_ptr stateAuthManager = authManager_.lock(); + if (stateAuthManager == nullptr) { + LOGE("AuthRequestState::authManager_ null"); + return DM_FAILED; + } + state->SetAuthManager(stateAuthManager); + stateAuthManager->SetAuthRequestState(state); + state->SetAuthContext(context_); + this->Leave(); + state->Enter(); + return DM_OK; +} + +int32_t AuthRequestInitState::GetStateType() +{ + return AuthState::AUTH_REQUEST_INIT; +} + +int32_t AuthRequestInitState::Enter() +{ + std::shared_ptr stateAuthManager = authManager_.lock(); + if (stateAuthManager == nullptr) { + LOGE("AuthRequestState::authManager_ null"); + return DM_FAILED; + } + stateAuthManager->EstablishAuthChannel(context_->deviceId); + return DM_OK; +} + +int32_t AuthRequestNegotiateState::GetStateType() +{ + return AuthState::AUTH_REQUEST_NEGOTIATE; +} + +int32_t AuthRequestNegotiateState::Enter() +{ + std::shared_ptr stateAuthManager = authManager_.lock(); + if (stateAuthManager == nullptr) { + LOGE("AuthRequestState::authManager_ null"); + return DM_FAILED; + } + stateAuthManager->StartNegotiate(context_->sessionId); + return DM_OK; +} + +int32_t AuthRequestNegotiateDoneState::GetStateType() +{ + return AuthState::AUTH_REQUEST_NEGOTIATE_DONE; +} + +int32_t AuthRequestNegotiateDoneState::Enter() +{ + std::shared_ptr stateAuthManager = authManager_.lock(); + if (stateAuthManager == nullptr) { + LOGE("AuthRequestState::authManager_ null"); + return DM_FAILED; + } + stateAuthManager->SendAuthRequest(context_->sessionId); + return DM_OK; +} + +int32_t AuthRequestReplyState::GetStateType() +{ + return AuthState::AUTH_REQUEST_REPLY; +} + +int32_t AuthRequestReplyState::Enter() +{ + std::shared_ptr stateAuthManager = authManager_.lock(); + if (stateAuthManager == nullptr) { + LOGE("AuthRequestState::authManager_ null"); + return DM_FAILED; + } + stateAuthManager->StartRespAuthProcess(); + return DM_OK; +} + +int32_t AuthRequestInputState::GetStateType() +{ + return AuthState::AUTH_REQUEST_INPUT; +} + +int32_t AuthRequestInputState::Enter() +{ + LOGE("DmAuthManager::AuthRequestInputState"); + std::shared_ptr stateAuthManager = authManager_.lock(); + if (stateAuthManager == nullptr) { + LOGE("AuthRequestState::authManager_ null"); + return DM_FAILED; + } + stateAuthManager->ShowStartAuthDialog(); + return DM_OK; +} + +int32_t AuthRequestJoinState::GetStateType() +{ + return AuthState::AUTH_REQUEST_JOIN; +} + +int32_t AuthRequestJoinState::Enter() +{ + LOGE("DmAuthManager::AuthRequestJoinState"); + std::shared_ptr stateAuthManager = authManager_.lock(); + if (stateAuthManager == nullptr) { + LOGE("AuthRequestState::authManager_ null"); + return DM_FAILED; + } + stateAuthManager->AddMember(context_->deviceId); + return DM_OK; +} + +int32_t AuthRequestNetworkState::GetStateType() +{ + return AuthState::AUTH_REQUEST_NETWORK; +} + +int32_t AuthRequestNetworkState::Enter() +{ + std::shared_ptr stateAuthManager = authManager_.lock(); + if (stateAuthManager == nullptr) { + LOGE("AuthRequestState::authManager_ null"); + return DM_FAILED; + } + stateAuthManager->JoinNetwork(); + return DM_OK; +} + +int32_t AuthRequestFinishState::GetStateType() +{ + return AuthState::AUTH_REQUEST_FINISH; +} + +int32_t AuthRequestFinishState::Enter() +{ + std::shared_ptr stateAuthManager = authManager_.lock(); + if (stateAuthManager == nullptr) { + LOGE("AuthRequestState::authManager_ null"); + return DM_FAILED; + } + stateAuthManager->AuthenticateFinish(); + return DM_OK; +} +} // namespace DistributedHardware +} // namespace OHOS diff --git a/test/unittest/mock/mock_ipc_client.h b/test/unittest/mock/mock_ipc_client.h new file mode 100644 index 000000000..2c6c50eba --- /dev/null +++ b/test/unittest/mock/mock_ipc_client.h @@ -0,0 +1,35 @@ +/* + * Copyright (c) 2021 Huawei Device Co., Ltd. + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef OHOS_MOCK_IPC_CLIENTMANAGER_H +#define OHOS_MOCK_IPC_CLIENTMANAGER_H + +#include +#include + +#include "ipc_client.h" + +namespace OHOS { +namespace DistributedHardware { +class MockIpcClient : public IpcClient { +public: + MOCK_METHOD1(Init,int32_t(const std::string &pkgName)); + MOCK_METHOD1(UnInit,int32_t(const std::string &pkgName)); + MOCK_METHOD3(SendRequest,int32_t(int32_t cmdCode, std::shared_ptr req, std::shared_ptr rsp)); +}; +} // namespace DistributedHardware +} // namespace OHOS + +#endif // OHOS_MOCK_IPC_CLIENTMANAGER_H diff --git a/test/unittest/mock/mock_ipc_client_manager.h b/test/unittest/mock/mock_ipc_client_manager.h new file mode 100644 index 000000000..cbaf2e2f7 --- /dev/null +++ b/test/unittest/mock/mock_ipc_client_manager.h @@ -0,0 +1,34 @@ +/* + * Copyright (c) 2021 Huawei Device Co., Ltd. + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef OHOS_MOCK_IPC_CLIENTMANAGER_H +#define OHOS_MOCK_IPC_CLIENTMANAGER_H + +#include +#include + +#include "ipc_client_server_proxy.h" + +namespace OHOS { +namespace DistributedHardware { +class MockIpcClientManager : public IpcClientServerProxy { +public: + explicit MockIpcClientManager (const sptr &impl): IpcClientServerProxy(impl) {}; + MOCK_METHOD3(SendCmd,int32_t(int32_t cmdCode, std::shared_ptr req, std::shared_ptr rsp)); +}; +} // namespace DistributedHardware +} // namespace OHOS + +#endif // OHOS_MOCK_IPC_CLIENTMANAGER_H diff --git a/test/unittest/mock/softbus_bus_center.cpp b/test/unittest/mock/softbus_bus_center.cpp index 9998102d3..47385bc4a 100644 --- a/test/unittest/mock/softbus_bus_center.cpp +++ b/test/unittest/mock/softbus_bus_center.cpp @@ -15,7 +15,7 @@ #include "softbus_connector.h" -int32_t GetNodeKeyInfo(const char *pkgName, const char *networkId, NodeDeviceInfoKey key, uint8_t *info, +int32_t GetNodeKeyInfo(const char *pkgName, const char *networkId, NodeDeivceInfoKey key, uint8_t *info, int32_t infoLen) { return 0; -- Gitee