diff options
Diffstat (limited to 'src/test/DBusProxyTest.cpp')
| -rw-r--r-- | src/test/DBusProxyTest.cpp | 515 |
1 files changed, 0 insertions, 515 deletions
diff --git a/src/test/DBusProxyTest.cpp b/src/test/DBusProxyTest.cpp deleted file mode 100644 index a70a84a..0000000 --- a/src/test/DBusProxyTest.cpp +++ /dev/null @@ -1,515 +0,0 @@ -// Copyright (C) 2013-2015 Bayerische Motoren Werke Aktiengesellschaft (BMW AG) -// This Source Code Form is subject to the terms of the Mozilla Public -// License, v. 2.0. If a copy of the MPL was not distributed with this -// file, You can obtain one at http://mozilla.org/MPL/2.0/. - -#ifndef _GLIBCXX_USE_NANOSLEEP -#define _GLIBCXX_USE_NANOSLEEP -#endif - -#include <CommonAPI/CommonAPI.hpp> - -#ifndef COMMONAPI_INTERNAL_COMPILATION -#define COMMONAPI_INTERNAL_COMPILATION -#endif - -#include <CommonAPI/DBus/DBusInputStream.hpp> -#include <CommonAPI/DBus/DBusMessage.hpp> -#include <CommonAPI/DBus/DBusProxy.hpp> -#include <CommonAPI/DBus/DBusConnection.hpp> -#include <CommonAPI/DBus/DBusStubAdapter.hpp> -#include <CommonAPI/DBus/DBusFactory.hpp> - -#include <v1/commonapi/tests/TestInterfaceDBusProxy.hpp> -#include <v1/commonapi/tests/TestInterfaceDBusStubAdapter.hpp> -#include <v1/commonapi/tests/TestInterfaceStubDefault.hpp> - -#include <v1/commonapi/tests/ExtendedInterfaceProxy.hpp> -#include <v1/commonapi/tests/ExtendedInterfaceDBusProxy.hpp> -#include <v1/commonapi/tests/ExtendedInterfaceDBusStubAdapter.hpp> -#include <v1/commonapi/tests/ExtendedInterfaceStubDefault.hpp> - -#include "DBusTestUtils.hpp" - -#include <gtest/gtest.h> - -#include <algorithm> -#include <cstdint> -#include <iostream> -#include <string> -#include <thread> -#include <vector> - -static const std::string domain = "local"; -static const std::string commonApiAddress = "CommonAPI.DBus.tests.DBusProxyTestService"; -static const std::string commonApiAddressExtended = "CommonAPI.DBus.tests.DBusProxyTestService2"; -static const std::string commonApiServiceName = "CommonAPI.DBus.tests.DBusProxyTestInterface"; -static const std::string interfaceName = "commonapi.tests.TestInterface"; -static const std::string busName = "commonapi.tests.TestInterface_CommonAPI.DBus.tests.DBusProxyTestService"; -static const std::string objectPath = "/CommonAPI/DBus/tests/DBusProxyTestService"; -static const std::string objectPathExtended = "/CommonAPI/DBus/tests/DBusProxyTestService2"; -static const std::string commonApiAddressFreedesktop = "CommonAPI.DBus.tests.DBusProxyTestInterface"; - -#define VERSION v1_0 - -class ProxyTest: public ::testing::Test { -protected: - void SetUp() { - runtime_ = CommonAPI::Runtime::get(); - - proxyDBusConnection_ = CommonAPI::DBus::DBusConnection::getBus(CommonAPI::DBus::DBusType_t::SESSION, "clientConnection"); - ASSERT_TRUE(proxyDBusConnection_->connect()); - - proxy_ = std::make_shared<VERSION::commonapi::tests::TestInterfaceDBusProxy>( - CommonAPI::DBus::DBusAddress(busName, objectPath, interfaceName), - proxyDBusConnection_); - proxy_->init(); - } - - std::shared_ptr<CommonAPI::Runtime> runtime_; - - virtual void TearDown() { - usleep(300000); - } - - void registerTestStub() { - stubDefault_ = std::make_shared<VERSION::commonapi::tests::TestInterfaceStubDefault>(); - bool isTestStubAdapterRegistered_ = runtime_->registerService<VERSION::commonapi::tests::TestInterfaceStub>(domain, commonApiAddress, stubDefault_, "serviceConnection"); - ASSERT_TRUE(isTestStubAdapterRegistered_); - - usleep(100000); - } - - void registerExtendedStub() { - stubExtended_ = std::make_shared<VERSION::commonapi::tests::ExtendedInterfaceStubDefault>(); - - bool isExtendedStubAdapterRegistered_ = runtime_->registerService<VERSION::commonapi::tests::ExtendedInterfaceStub>(domain, commonApiAddressExtended, stubExtended_, "serviceConnection"); - ASSERT_TRUE(isExtendedStubAdapterRegistered_); - - usleep(100000); - } - - void deregisterTestStub() { - const bool isStubAdapterUnregistered = CommonAPI::Runtime::get()->unregisterService( - domain, stubDefault_->getStubAdapter()->getInterface(), commonApiAddress); - ASSERT_TRUE(isStubAdapterUnregistered); - stubDefault_.reset(); - isTestStubAdapterRegistered_ = false; - } - - void deregisterExtendedStub() { - const bool isStubAdapterUnregistered = runtime_->unregisterService( - domain, stubExtended_->CommonAPI::Stub<VERSION::commonapi::tests::ExtendedInterfaceStubAdapter, VERSION::commonapi::tests::ExtendedInterfaceStubRemoteEvent>::getStubAdapter()->VERSION::commonapi::tests::ExtendedInterface::getInterface(), commonApiAddressExtended); - ASSERT_TRUE(isStubAdapterUnregistered); - stubExtended_.reset(); - isExtendedStubAdapterRegistered_ = false; - } - - void proxyRegisterForAvailabilityStatus() { - proxyAvailabilityStatus_ = CommonAPI::AvailabilityStatus::UNKNOWN; - - proxyStatusSubscription_ = proxy_->getProxyStatusEvent().subscribe([&](const CommonAPI::AvailabilityStatus& availabilityStatus) { - proxyAvailabilityStatus_ = availabilityStatus; - }); - usleep(100000); - } - - void proxyDeregisterForAvailabilityStatus() { - proxy_->getProxyStatusEvent().unsubscribe(proxyStatusSubscription_); - } - - bool proxyWaitForAvailabilityStatus(const CommonAPI::AvailabilityStatus& availabilityStatus) const { - for (int i = 0; i < 10; i++) { - if (proxyAvailabilityStatus_ == availabilityStatus) { - return true; - } - usleep(200000); - } - - return false; - } - - bool isExtendedStubAdapterRegistered_; - bool isTestStubAdapterRegistered_; - - std::shared_ptr<CommonAPI::DBus::DBusConnection> proxyDBusConnection_; - std::shared_ptr<VERSION::commonapi::tests::TestInterfaceDBusProxy> proxy_; - - CommonAPI::AvailabilityStatus proxyAvailabilityStatus_; - - CommonAPI::ProxyStatusEvent::Subscription proxyStatusSubscription_; - - std::shared_ptr<VERSION::commonapi::tests::ExtendedInterfaceStubDefault> stubExtended_; - std::shared_ptr<VERSION::commonapi::tests::TestInterfaceStubDefault> stubDefault_; -}; - -TEST_F(ProxyTest, HasCorrectConnectionName) { - std::string actualName = proxy_->getDBusAddress().getService(); - EXPECT_EQ(busName, actualName); -} - -TEST_F(ProxyTest, HasCorrectObjectPath) { - std::string actualPath = proxy_->getDBusAddress().getObjectPath(); - EXPECT_EQ(objectPath, actualPath); -} - -TEST_F(ProxyTest, HasCorrectInterfaceName) { - std::string actualName = proxy_->getDBusAddress().getInterface(); - EXPECT_EQ(interfaceName, actualName); -} - -TEST_F(ProxyTest, IsNotAvailable) { - bool isAvailable = proxy_->isAvailable(); - EXPECT_FALSE(isAvailable); -} - -TEST_F(ProxyTest, IsConnected) { - ASSERT_TRUE(proxy_->getDBusConnection()->isConnected()); -} - -TEST_F(ProxyTest, DBusProxyStatusEventBeforeServiceIsRegistered) { - proxyRegisterForAvailabilityStatus(); - - EXPECT_NE(proxyAvailabilityStatus_, CommonAPI::AvailabilityStatus::AVAILABLE); - - registerTestStub(); - - EXPECT_TRUE(proxyWaitForAvailabilityStatus(CommonAPI::AvailabilityStatus::AVAILABLE)); - - deregisterTestStub(); - usleep(100000); - - EXPECT_TRUE(proxyWaitForAvailabilityStatus(CommonAPI::AvailabilityStatus::NOT_AVAILABLE)); - - proxyDeregisterForAvailabilityStatus(); -} - -/* -This test fails in Windows. Calling disconnect and then connect again somehow -damages the connection in libdbus. In Linux this all works fine. -*/ -#ifndef WIN32 -TEST_F(ProxyTest, DBusProxyStatusEventAfterServiceIsRegistered) { - proxyDBusConnection_->disconnect(); - - registerTestStub(); - - EXPECT_TRUE(proxyDBusConnection_->connect()); - - proxyRegisterForAvailabilityStatus(); - - EXPECT_TRUE(proxyWaitForAvailabilityStatus(CommonAPI::AvailabilityStatus::AVAILABLE)); - - deregisterTestStub(); - usleep(100000); - - EXPECT_TRUE(proxyWaitForAvailabilityStatus(CommonAPI::AvailabilityStatus::NOT_AVAILABLE)); - - proxyDeregisterForAvailabilityStatus(); -} -#endif - - -TEST_F(ProxyTest, IsAvailableBlocking) { - registerTestStub(); - - // blocking in terms of "if it's still unknown" - for (int i = 0; !proxy_->isAvailableBlocking() && i < 3; i++) { - std::this_thread::sleep_for(std::chrono::milliseconds(100)); - } - - EXPECT_TRUE(proxy_->isAvailableBlocking()); - - deregisterTestStub(); -} - -TEST_F(ProxyTest, HasNecessaryAttributesAndEvents) { - (proxy_->getInterfaceVersionAttribute()); - (proxy_->getProxyStatusEvent()); -} - -TEST_F(ProxyTest, TestInterfaceVersionAttribute) { - CommonAPI::InterfaceVersionAttribute& versionAttribute = proxy_->getInterfaceVersionAttribute(); - CommonAPI::Version version; - CommonAPI::CallStatus status; - ASSERT_NO_THROW(versionAttribute.getValue(status, version)); - ASSERT_EQ(CommonAPI::CallStatus::NOT_AVAILABLE, status); -} - -TEST_F(ProxyTest, AsyncCallbacksAreCalledIfServiceNotAvailable) { - ::commonapi::tests::DerivedTypeCollection::TestEnumExtended2 testInputStruct; - ::commonapi::tests::DerivedTypeCollection::TestMap testInputMap; - CommonAPI::CallInfo info; - std::promise<bool> wasCalledPromise; - std::future<bool> wasCalledFuture = wasCalledPromise.get_future(); - proxy_->testDerivedTypeMethodAsync(testInputStruct, testInputMap, [&] ( - const CommonAPI::CallStatus& callStatus, - const ::commonapi::tests::DerivedTypeCollection::TestEnumExtended2&, - const ::commonapi::tests::DerivedTypeCollection::TestMap&) { - ASSERT_EQ(callStatus, CommonAPI::CallStatus::NOT_AVAILABLE); - wasCalledPromise.set_value(true); - } - , &info); - ASSERT_TRUE(wasCalledFuture.get()); -} - - -TEST_F(ProxyTest, CallMethodFromExtendedInterface) { - registerExtendedStub(); - - auto extendedProxy = runtime_->buildProxy<VERSION::commonapi::tests::ExtendedInterfaceProxy>(domain, commonApiAddressExtended); - - // give the proxy time to become available - for (uint32_t i = 0; !extendedProxy->isAvailable() && i < 200; ++i) { - usleep(20 * 1000); - } - - EXPECT_TRUE(extendedProxy->isAvailable()); - - uint32_t inInt; - bool wasCalled = false; - extendedProxy->TestIntMethodExtendedAsync( - inInt, - [&](const CommonAPI::CallStatus& callStatus) { - ASSERT_EQ(callStatus, CommonAPI::CallStatus::SUCCESS); - wasCalled = true; - }); - usleep(100000); - - EXPECT_TRUE(wasCalled); - deregisterExtendedStub(); -} - -TEST_F(ProxyTest, CallMethodFromParentInterface) { - registerExtendedStub(); - - auto extendedProxy = runtime_->buildProxy<VERSION::commonapi::tests::ExtendedInterfaceProxy>(domain, commonApiAddressExtended); - - for (uint32_t i = 0; !extendedProxy->isAvailable() && i < 200; ++i) { - usleep(10 * 1000); - } - EXPECT_TRUE(extendedProxy->isAvailable()); - - bool wasCalled = false; - extendedProxy->testEmptyMethodAsync( - [&](const CommonAPI::CallStatus& callStatus) { - ASSERT_EQ(callStatus, CommonAPI::CallStatus::SUCCESS); - wasCalled = true; - }); - usleep(100000); - EXPECT_TRUE(wasCalled); - - deregisterExtendedStub(); -} - -TEST_F(ProxyTest, CanHandleRemoteAttribute) { - registerTestStub(); - - for (uint32_t i = 0; !proxy_->isAvailable() && i < 200; ++i) { - usleep(20 * 1000); - } - ASSERT_TRUE(proxy_->isAvailable()); - - CommonAPI::CallStatus callStatus(CommonAPI::CallStatus::REMOTE_ERROR); - uint32_t value; - - auto& testAttribute = proxy_->getTestPredefinedTypeAttributeAttribute(); - - testAttribute.getValue(callStatus, value); - - EXPECT_EQ(callStatus, CommonAPI::CallStatus::SUCCESS); - - value = 7; - uint32_t responseValue; - testAttribute.setValue(value, callStatus, responseValue); - - EXPECT_EQ(callStatus, CommonAPI::CallStatus::SUCCESS); - EXPECT_EQ(value, responseValue); - - usleep(50000); - deregisterTestStub(); -} - - -TEST_F(ProxyTest, CanHandleRemoteAttributeFromParentInterface) { - registerExtendedStub(); - - auto extendedProxy = runtime_->buildProxy<VERSION::commonapi::tests::ExtendedInterfaceProxy>(domain, commonApiAddressExtended); - - for (uint32_t i = 0; !extendedProxy->isAvailable() && i < 200; ++i) { - usleep(20 * 1000); - } - ASSERT_TRUE(extendedProxy->isAvailable()); - - CommonAPI::CallStatus callStatus(CommonAPI::CallStatus::REMOTE_ERROR); - uint32_t value; - - usleep(50000); - - auto& testAttribute = extendedProxy->getTestPredefinedTypeAttributeAttribute(); - - testAttribute.getValue(callStatus, value); - - EXPECT_EQ(callStatus, CommonAPI::CallStatus::SUCCESS); - - value = 7; - uint32_t responseValue; - testAttribute.setValue(value, callStatus, responseValue); - - EXPECT_EQ(callStatus, CommonAPI::CallStatus::SUCCESS); - EXPECT_EQ(value, responseValue); - - usleep(50000); - deregisterExtendedStub(); -} - -TEST_F(ProxyTest, ProxyCanFetchVersionAttributeFromInheritedInterfaceStub) { - registerExtendedStub(); - - auto extendedProxy = runtime_->buildProxy<VERSION::commonapi::tests::ExtendedInterfaceProxy>(domain, commonApiAddressExtended); - - for (uint32_t i = 0; !extendedProxy->isAvailable() && i < 200; ++i) { - usleep(20 * 1000); - } - EXPECT_TRUE(extendedProxy->isAvailable()); - - - CommonAPI::InterfaceVersionAttribute& versionAttribute = extendedProxy->getInterfaceVersionAttribute(); - - CommonAPI::Version version; - bool wasCalled = false; - - std::future<CommonAPI::CallStatus> futureVersion = versionAttribute.getValueAsync([&](const CommonAPI::CallStatus& callStatus, CommonAPI::Version version) { - EXPECT_EQ(callStatus, CommonAPI::CallStatus::SUCCESS); - EXPECT_TRUE(version.Major > 0 || version.Minor > 0); - wasCalled = true; - }); - - futureVersion.wait(); - usleep(100000); - - EXPECT_TRUE(wasCalled); - - deregisterExtendedStub(); -} - -// this test does not build its proxies within SetUp -class ProxyTest2: public ::testing::Test { -protected: - virtual void SetUp() { - runtime_ = CommonAPI::Runtime::get(); - } - - virtual void TearDown() { - std::this_thread::sleep_for(std::chrono::milliseconds(300)); - } - - void registerTestStub(const std::string commonApiAddress) { - stubDefault_ = std::make_shared<VERSION::commonapi::tests::TestInterfaceStubDefault>(); - bool isTestStubAdapterRegistered_ = runtime_->registerService< - VERSION::commonapi::tests::TestInterfaceStub>(domain, commonApiAddress, stubDefault_, "serviceConnection"); - ASSERT_TRUE(isTestStubAdapterRegistered_); - - usleep(100000); - } - - void deregisterTestStub(const std::string commonApiAddress) { - const bool isStubAdapterUnregistered = CommonAPI::Runtime::get()->unregisterService(domain, stubDefault_->getStubAdapter()->getInterface(), commonApiAddress); - ASSERT_TRUE(isStubAdapterUnregistered); - stubDefault_.reset(); - isTestStubAdapterRegistered_ = false; - } - - void proxyRegisterForAvailabilityStatus() { - proxyAvailabilityStatus_ = CommonAPI::AvailabilityStatus::UNKNOWN; - - proxyStatusSubscription_ = proxy_->getProxyStatusEvent().subscribe( - [&](const CommonAPI::AvailabilityStatus& availabilityStatus) { - proxyAvailabilityStatus_ = availabilityStatus; - }); - std::this_thread::sleep_for(std::chrono::milliseconds(100)); - } - - void proxyDeregisterForAvailabilityStatus() { - proxy_->getProxyStatusEvent().unsubscribe(proxyStatusSubscription_); - } - - bool proxyWaitForAvailabilityStatus(const CommonAPI::AvailabilityStatus& availabilityStatus) const { - for (int i = 0; i < 100; i++) { - if (proxyAvailabilityStatus_ == availabilityStatus) - return true; - std::this_thread::sleep_for(std::chrono::milliseconds(100)); - } - - return false; - } - - bool isTestStubAdapterRegistered_; - std::shared_ptr<CommonAPI::Runtime> runtime_; - - std::shared_ptr<CommonAPI::DBus::DBusConnection> proxyDBusConnection_; - std::shared_ptr<VERSION::commonapi::tests::TestInterfaceDBusProxy> proxy_; - CommonAPI::AvailabilityStatus proxyAvailabilityStatus_; - - CommonAPI::ProxyStatusEvent::Subscription proxyStatusSubscription_; - - std::shared_ptr<VERSION::commonapi::tests::TestInterfaceStubDefault> stubDefault_; -}; - -TEST_F(ProxyTest2, DBusProxyStatusEventAfterServiceIsRegistered) { - registerTestStub(commonApiAddress); - - proxyDBusConnection_ = CommonAPI::DBus::DBusConnection::getBus(CommonAPI::DBus::DBusType_t::SESSION, "clientConnection"); - ASSERT_TRUE(proxyDBusConnection_->connect()); - - proxy_ = std::make_shared<VERSION::commonapi::tests::TestInterfaceDBusProxy>(CommonAPI::DBus::DBusAddress(busName, objectPath, interfaceName), proxyDBusConnection_); - proxy_->init(); - - proxyRegisterForAvailabilityStatus(); - - EXPECT_TRUE(proxyWaitForAvailabilityStatus(CommonAPI::AvailabilityStatus::AVAILABLE)); - - deregisterTestStub(commonApiAddress); - usleep(100000); - - EXPECT_TRUE(proxyWaitForAvailabilityStatus(CommonAPI::AvailabilityStatus::NOT_AVAILABLE)); - - proxyDeregisterForAvailabilityStatus(); -} - -TEST_F(ProxyTest2, DBusProxyCanUseOrgFreedesktopAddress) { - registerTestStub(commonApiAddressFreedesktop); - - std::shared_ptr<VERSION::commonapi::tests::TestInterfaceProxy<>> proxy = - runtime_->buildProxy<VERSION::commonapi::tests::TestInterfaceProxy>(domain, commonApiAddressFreedesktop); - - for (int i = 0; i < 100; i++) { - if (proxy->isAvailable()) - break; - std::this_thread::sleep_for(std::chrono::milliseconds(100)); - } - - const bool proxyIsAvailable = proxy->isAvailable(); - - EXPECT_TRUE(proxyIsAvailable); - - if(proxyIsAvailable) { // if we are not available, we failed the test and do not check a method call - bool wasCalled = false; - proxy->testEmptyMethodAsync( - [&](const CommonAPI::CallStatus& callStatus) { - ASSERT_EQ(callStatus, CommonAPI::CallStatus::SUCCESS); - wasCalled = true; - }); - usleep(100000); - EXPECT_TRUE(wasCalled); - } - - deregisterTestStub(commonApiAddressFreedesktop); -} - -#ifndef __NO_MAIN__ -int main(int argc, char** argv) { - ::testing::InitGoogleTest(&argc, argv); - return RUN_ALL_TESTS(); -} -#endif |