diff options
author | Alexander Kutsan <AKutsan@luxoft.com> | 2016-08-26 18:48:22 +0300 |
---|---|---|
committer | Alexander Kutsan <AKutsan@luxoft.com> | 2016-08-26 18:48:57 +0300 |
commit | d73e6dc8724c5799fae14efd4dcb214af74e4904 (patch) | |
tree | 9ebed8b422490c4d669e90e70783e4f5b55b65c9 /src/components/transport_manager/test/tcp_transport_adapter_test.cc | |
parent | c201c11a35d360c0b96f36b103a2590bfaeb6026 (diff) | |
parent | 61ef8c42badb879216f53d240e1101b9f83a9bb7 (diff) | |
download | sdl_core-d73e6dc8724c5799fae14efd4dcb214af74e4904.tar.gz |
Merge branch 'release/4.1.0'
Diffstat (limited to 'src/components/transport_manager/test/tcp_transport_adapter_test.cc')
-rw-r--r-- | src/components/transport_manager/test/tcp_transport_adapter_test.cc | 119 |
1 files changed, 51 insertions, 68 deletions
diff --git a/src/components/transport_manager/test/tcp_transport_adapter_test.cc b/src/components/transport_manager/test/tcp_transport_adapter_test.cc index d849d94d48..60732f0328 100644 --- a/src/components/transport_manager/test/tcp_transport_adapter_test.cc +++ b/src/components/transport_manager/test/tcp_transport_adapter_test.cc @@ -33,12 +33,15 @@ #include "gtest/gtest.h" #include "transport_manager/tcp/tcp_transport_adapter.h" #include "transport_manager/transport_adapter/connection.h" -#include "config_profile/profile.h" #include "resumption/last_state.h" #include "protocol/raw_message.h" -#include "include/transport_adapter_listener_mock.h" -#include "include/device_mock.h" -#include "include/connection_mock.h" +#include "transport_manager/transport_adapter_listener_mock.h" +#include "transport_manager/device_mock.h" +#include "transport_manager/connection_mock.h" +#include "transport_manager/tcp/mock_tcp_transport_adapter.h" +#include "transport_manager/mock_transport_manager_settings.h" + +#include "utils/make_shared.h" namespace test { namespace components { @@ -51,45 +54,21 @@ using namespace ::protocol_handler; using namespace ::transport_manager; using namespace transport_manager::transport_adapter; -class TestTCPTransportAdapter : public TcpTransportAdapter { - public: - TestTCPTransportAdapter(uint16_t port) : TcpTransportAdapter(port) { - ::profile::Profile::instance()->config_file_name( - "smartDeviceLink_test.ini"); - } - MOCK_CONST_METHOD2(FindEstablishedConnection, - ConnectionSPtr(const DeviceUID& device_handle, - const ApplicationHandle& app_handle)); - - MOCK_CONST_METHOD1(FindDevice, DeviceSptr(const DeviceUID& device_handle)); - MOCK_METHOD2(Connect, - TransportAdapter::Error(const DeviceUID& device_handle, - const ApplicationHandle& app_handle)); - void CallStore() { Store(); } - bool CallRestore() { return Restore(); } -}; - class TcpAdapterTest : public ::testing::Test { protected: - static void SetUpTestCase() { - ::profile::Profile::instance()->config_file_name( - "smartDeviceLink_test.ini"); - } - virtual void SetUp() { - resumption::LastState::instance()->dictionary = Json::Value(); - } - - virtual void TearDown() { resumption::LastState::destroy(); } - + TcpAdapterTest() : last_state_("app_storage_folder", "app_info_storage") {} + MockTransportManagerSettings transport_manager_settings; + resumption::LastState last_state_; const uint32_t port = 12345; const std::string string_port = "12345"; }; -TEST_F(TcpAdapterTest, DISABLED_StoreDataWithOneDeviceAndOneApplication) { +TEST_F(TcpAdapterTest, StoreDataWithOneDeviceAndOneApplication) { // Prepare - TestTCPTransportAdapter transport_adapter(port); + MockTCPTransportAdapter transport_adapter( + port, last_state_, transport_manager_settings); std::string uniq_id = "unique_device_name"; - utils::SharedPtr<TCPDeviceMock> mockdev = new TCPDeviceMock(port, uniq_id); + utils::SharedPtr<MockTCPDevice> mockdev = new MockTCPDevice(port, uniq_id); transport_adapter.AddDevice(mockdev); std::vector<std::string> devList = transport_adapter.GetDeviceList(); @@ -100,7 +79,7 @@ TEST_F(TcpAdapterTest, DISABLED_StoreDataWithOneDeviceAndOneApplication) { std::vector<int> intList = {app_handle}; EXPECT_CALL(*mockdev, GetApplicationList()).WillOnce(Return(intList)); - ConnectionSPtr mock_connection = new ConnectionMock(); + ConnectionSPtr mock_connection = new MockConnection(); EXPECT_CALL(transport_adapter, FindDevice(uniq_id)).WillOnce(Return(mockdev)); EXPECT_CALL(transport_adapter, FindEstablishedConnection(uniq_id, app_handle)) .WillOnce(Return(mock_connection)); @@ -110,8 +89,8 @@ TEST_F(TcpAdapterTest, DISABLED_StoreDataWithOneDeviceAndOneApplication) { transport_adapter.CallStore(); // Check that value is saved - Json::Value& tcp_dict = resumption::LastState::instance() - ->dictionary["TransportManager"]["TcpAdapter"]; + Json::Value& tcp_dict = + last_state_.dictionary["TransportManager"]["TcpAdapter"]; ASSERT_TRUE(tcp_dict.isObject()); ASSERT_FALSE(tcp_dict["devices"].isNull()); @@ -123,17 +102,18 @@ TEST_F(TcpAdapterTest, DISABLED_StoreDataWithOneDeviceAndOneApplication) { EXPECT_EQ(uniq_id, tcp_dict["devices"][0]["name"].asString()); } -TEST_F(TcpAdapterTest, DISABLED_StoreDataWithSeveralDevicesAndOneApplication) { +TEST_F(TcpAdapterTest, StoreDataWithSeveralDevicesAndOneApplication) { // Prepare - TestTCPTransportAdapter transport_adapter(port); + MockTCPTransportAdapter transport_adapter( + port, last_state_, transport_manager_settings); const uint32_t count_dev = 10; - utils::SharedPtr<TCPDeviceMock> mockdev[count_dev]; + utils::SharedPtr<MockTCPDevice> mockdev[count_dev]; std::string uniq_id[count_dev]; for (uint32_t i = 0; i < count_dev; i++) { char numb[12]; std::snprintf(numb, 12, "%d", i); uniq_id[i] = "unique_device_name" + std::string(numb); - mockdev[i] = new TCPDeviceMock(port, uniq_id[i]); + mockdev[i] = new MockTCPDevice(port, uniq_id[i]); EXPECT_CALL(*(mockdev[i]), IsSameAs(_)).WillRepeatedly(Return(false)); transport_adapter.AddDevice(mockdev[i]); } @@ -145,7 +125,7 @@ TEST_F(TcpAdapterTest, DISABLED_StoreDataWithSeveralDevicesAndOneApplication) { const int app_handle = 1; std::vector<int> intList = {app_handle}; - ConnectionSPtr mock_connection = new ConnectionMock(); + ConnectionSPtr mock_connection = new MockConnection(); for (uint32_t i = 0; i < count_dev; i++) { EXPECT_CALL(transport_adapter, FindDevice(uniq_id[i])) .WillOnce(Return(mockdev[i])); @@ -161,8 +141,8 @@ TEST_F(TcpAdapterTest, DISABLED_StoreDataWithSeveralDevicesAndOneApplication) { transport_adapter.CallStore(); // Check that values are saved - Json::Value& tcp_dict = resumption::LastState::instance() - ->dictionary["TransportManager"]["TcpAdapter"]; + Json::Value& tcp_dict = + last_state_.dictionary["TransportManager"]["TcpAdapter"]; ASSERT_TRUE(tcp_dict.isObject()); ASSERT_FALSE(tcp_dict["devices"].isNull()); for (uint32_t i = 0; i < count_dev; i++) { @@ -175,18 +155,19 @@ TEST_F(TcpAdapterTest, DISABLED_StoreDataWithSeveralDevicesAndOneApplication) { } } -TEST_F(TcpAdapterTest, DISABLED_StoreDataWithSeveralDevicesAndSeveralApplications) { +TEST_F(TcpAdapterTest, StoreDataWithSeveralDevicesAndSeveralApplications) { // Prepare - TestTCPTransportAdapter transport_adapter(port); + MockTCPTransportAdapter transport_adapter( + port, last_state_, transport_manager_settings); const uint32_t count_dev = 10; - utils::SharedPtr<TCPDeviceMock> mockdev[count_dev]; + utils::SharedPtr<MockTCPDevice> mockdev[count_dev]; std::string uniq_id[count_dev]; for (uint32_t i = 0; i < count_dev; i++) { char numb[12]; std::snprintf(numb, 12, "%d", i); uniq_id[i] = "unique_device_name" + std::string(numb); - mockdev[i] = new TCPDeviceMock(port, uniq_id[i]); + mockdev[i] = new MockTCPDevice(port, uniq_id[i]); EXPECT_CALL(*(mockdev[i]), IsSameAs(_)).WillRepeatedly(Return(false)); transport_adapter.AddDevice(mockdev[i]); } @@ -200,7 +181,7 @@ TEST_F(TcpAdapterTest, DISABLED_StoreDataWithSeveralDevicesAndSeveralApplication std::vector<int> intList = {app_handle[0], app_handle[1], app_handle[2]}; const std::string ports[connection_count] = {"11111", "67890", "98765"}; const int int_port[connection_count] = {11111, 67890, 98765}; - ConnectionSPtr mock_connection = new ConnectionMock(); + ConnectionSPtr mock_connection = new MockConnection(); for (uint32_t i = 0; i < count_dev; i++) { EXPECT_CALL(transport_adapter, FindDevice(uniq_id[i])) .WillOnce(Return(mockdev[i])); @@ -217,8 +198,8 @@ TEST_F(TcpAdapterTest, DISABLED_StoreDataWithSeveralDevicesAndSeveralApplication transport_adapter.CallStore(); // Check that value is saved - Json::Value& tcp_dict = resumption::LastState::instance() - ->dictionary["TransportManager"]["TcpAdapter"]; + Json::Value& tcp_dict = + last_state_.dictionary["TransportManager"]["TcpAdapter"]; ASSERT_TRUE(tcp_dict.isObject()); ASSERT_FALSE(tcp_dict["devices"].isNull()); @@ -235,9 +216,10 @@ TEST_F(TcpAdapterTest, DISABLED_StoreDataWithSeveralDevicesAndSeveralApplication TEST_F(TcpAdapterTest, StoreData_ConnectionNotExist_DataNotStored) { // Prepare - TestTCPTransportAdapter transport_adapter(port); + MockTCPTransportAdapter transport_adapter( + port, last_state_, transport_manager_settings); std::string uniq_id = "unique_device_name"; - utils::SharedPtr<TCPDeviceMock> mockdev = new TCPDeviceMock(port, uniq_id); + utils::SharedPtr<MockTCPDevice> mockdev = new MockTCPDevice(port, uniq_id); transport_adapter.AddDevice(mockdev); std::vector<std::string> devList = transport_adapter.GetDeviceList(); @@ -254,25 +236,25 @@ TEST_F(TcpAdapterTest, StoreData_ConnectionNotExist_DataNotStored) { // Check that value is not saved Json::Value& tcp_dict = - resumption::LastState::instance() - ->dictionary["TransportManager"]["TcpAdapter"]["devices"]; + last_state_.dictionary["TransportManager"]["TcpAdapter"]["devices"]; ASSERT_TRUE(tcp_dict.isNull()); } TEST_F(TcpAdapterTest, RestoreData_DataNotStored) { Json::Value& tcp_adapter_dictionary = - resumption::LastState::instance() - ->dictionary["TransportManager"]["TcpAdapter"]; + last_state_.dictionary["TransportManager"]["TcpAdapter"]; tcp_adapter_dictionary = Json::Value(); - TestTCPTransportAdapter transport_adapter(port); + MockTCPTransportAdapter transport_adapter( + port, last_state_, transport_manager_settings); EXPECT_CALL(transport_adapter, Connect(_, _)).Times(0); EXPECT_TRUE(transport_adapter.CallRestore()); } -TEST_F(TcpAdapterTest, DISABLED_StoreDataWithOneDevice_RestoreData) { - TestTCPTransportAdapter transport_adapter(port); +TEST_F(TcpAdapterTest, StoreDataWithOneDevice_RestoreData) { + MockTCPTransportAdapter transport_adapter( + port, last_state_, transport_manager_settings); std::string uniq_id = "unique_device_name"; - utils::SharedPtr<TCPDeviceMock> mockdev = new TCPDeviceMock(port, uniq_id); + utils::SharedPtr<MockTCPDevice> mockdev = new MockTCPDevice(port, uniq_id); transport_adapter.AddDevice(mockdev); std::vector<std::string> devList = transport_adapter.GetDeviceList(); @@ -283,7 +265,7 @@ TEST_F(TcpAdapterTest, DISABLED_StoreDataWithOneDevice_RestoreData) { std::vector<int> intList = {app_handle}; EXPECT_CALL(*mockdev, GetApplicationList()).WillOnce(Return(intList)); - ConnectionSPtr mock_connection = new ConnectionMock(); + ConnectionSPtr mock_connection = new MockConnection(); EXPECT_CALL(transport_adapter, FindDevice(uniq_id)).WillOnce(Return(mockdev)); EXPECT_CALL(transport_adapter, FindEstablishedConnection(uniq_id, app_handle)) .WillOnce(Return(mock_connection)); @@ -302,17 +284,18 @@ TEST_F(TcpAdapterTest, DISABLED_StoreDataWithOneDevice_RestoreData) { EXPECT_EQ(uniq_id, devList[0]); } -TEST_F(TcpAdapterTest, DISABLED_StoreDataWithSeveralDevices_RestoreData) { - TestTCPTransportAdapter transport_adapter(port); +TEST_F(TcpAdapterTest, StoreDataWithSeveralDevices_RestoreData) { + MockTCPTransportAdapter transport_adapter( + port, last_state_, transport_manager_settings); const uint32_t count_dev = 10; - utils::SharedPtr<TCPDeviceMock> mockdev[count_dev]; + utils::SharedPtr<MockTCPDevice> mockdev[count_dev]; std::string uniq_id[count_dev]; for (uint32_t i = 0; i < count_dev; i++) { char numb[12]; std::snprintf(numb, 12, "%d", i); uniq_id[i] = "unique_device_name" + std::string(numb); - mockdev[i] = new TCPDeviceMock(port, uniq_id[i]); + mockdev[i] = new MockTCPDevice(port, uniq_id[i]); EXPECT_CALL(*(mockdev[i]), IsSameAs(_)).WillRepeatedly(Return(false)); transport_adapter.AddDevice(mockdev[i]); } @@ -324,7 +307,7 @@ TEST_F(TcpAdapterTest, DISABLED_StoreDataWithSeveralDevices_RestoreData) { const int app_handle = 1; std::vector<int> intList = {app_handle}; - ConnectionSPtr mock_connection = new ConnectionMock(); + ConnectionSPtr mock_connection = new MockConnection(); for (uint32_t i = 0; i < count_dev; i++) { EXPECT_CALL(transport_adapter, FindDevice(uniq_id[i])) .WillOnce(Return(mockdev[i])); |