diff options
Diffstat (limited to 'include/CommonAPI/DBus/DBusAttribute.hpp')
| -rw-r--r-- | include/CommonAPI/DBus/DBusAttribute.hpp | 156 |
1 files changed, 156 insertions, 0 deletions
diff --git a/include/CommonAPI/DBus/DBusAttribute.hpp b/include/CommonAPI/DBus/DBusAttribute.hpp new file mode 100644 index 0000000..3d9170d --- /dev/null +++ b/include/CommonAPI/DBus/DBusAttribute.hpp @@ -0,0 +1,156 @@ +// 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/. + +#if !defined (COMMONAPI_INTERNAL_COMPILATION) +#error "Only <CommonAPI/CommonAPI.hpp> can be included directly, this file may disappear or change contents." +#endif + +#ifndef COMMONAPI_DBUS_DBUS_ATTRIBUTE_HPP_ +#define COMMONAPI_DBUS_DBUS_ATTRIBUTE_HPP_ + +#include <cassert> +#include <cstdint> +#include <tuple> + +#include <CommonAPI/DBus/DBusConfig.hpp> +#include <CommonAPI/DBus/DBusEvent.hpp> +#include <CommonAPI/DBus/DBusProxyHelper.hpp> + +namespace CommonAPI { +namespace DBus { + +template <typename _AttributeType, typename _AttributeDepl = EmptyDeployment> +class DBusReadonlyAttribute: public _AttributeType { +public: + typedef typename _AttributeType::ValueType ValueType; + typedef _AttributeDepl ValueTypeDepl; + typedef typename _AttributeType::AttributeAsyncCallback AttributeAsyncCallback; + + DBusReadonlyAttribute(DBusProxy &_proxy, + const char *setMethodSignature, const char *getMethodName, + _AttributeDepl *_depl = nullptr) + : proxy_(_proxy), + getMethodName_(getMethodName), + setMethodSignature_(setMethodSignature), + depl_(_depl) { + assert(getMethodName); + } + + void getValue(CommonAPI::CallStatus &_status, ValueType &_value, const CommonAPI::CallInfo *_info) const { + CommonAPI::Deployable<ValueType, _AttributeDepl> deployedValue(depl_); + DBusProxyHelper< + DBusSerializableArguments< + >, + DBusSerializableArguments< + CommonAPI::Deployable< + ValueType, + _AttributeDepl + > + > + >::callMethodWithReply(proxy_, getMethodName_, "", (_info ? _info : &defaultCallInfo), _status, deployedValue); + _value = deployedValue.getValue(); + } + + std::future<CallStatus> getValueAsync(AttributeAsyncCallback _callback, const CommonAPI::CallInfo *_info) { + CommonAPI::Deployable<ValueType, _AttributeDepl> deployedValue(depl_); + return DBusProxyHelper< + DBusSerializableArguments<>, + DBusSerializableArguments<CommonAPI::Deployable<ValueType, _AttributeDepl>> + >::callMethodAsync(proxy_, getMethodName_, "", (_info ? _info : &defaultCallInfo), + [_callback](CommonAPI::CallStatus _status, CommonAPI::Deployable<ValueType, _AttributeDepl> _response) { + _callback(_status, _response.getValue()); + }, + std::make_tuple(deployedValue)); + } + + protected: + DBusProxy &proxy_; + const char *getMethodName_; + const char *setMethodSignature_; + _AttributeDepl *depl_; +}; + +template <typename _AttributeType, typename _AttributeDepl = EmptyDeployment> +class DBusAttribute: public DBusReadonlyAttribute<_AttributeType, _AttributeDepl> { +public: + typedef typename _AttributeType::ValueType ValueType; + typedef typename _AttributeType::AttributeAsyncCallback AttributeAsyncCallback; + + DBusAttribute(DBusProxy &_proxy, + const char *_setMethodName, const char *_setMethodSignature, const char *_getMethodName, + _AttributeDepl *_depl = nullptr) + : DBusReadonlyAttribute<_AttributeType, _AttributeDepl>(_proxy, _setMethodSignature, _getMethodName, _depl), + setMethodName_(_setMethodName), + setMethodSignature_(_setMethodSignature) { + assert(_setMethodName); + assert(_setMethodSignature); + } + + void setValue(const ValueType &_request, CommonAPI::CallStatus &_status, ValueType &_response, const CommonAPI::CallInfo *_info) { + CommonAPI::Deployable<ValueType, _AttributeDepl> deployedRequest(_request, this->depl_); + CommonAPI::Deployable<ValueType, _AttributeDepl> deployedResponse(this->depl_); + DBusProxyHelper<DBusSerializableArguments<CommonAPI::Deployable<ValueType, _AttributeDepl>>, + DBusSerializableArguments<CommonAPI::Deployable<ValueType, _AttributeDepl>> >::callMethodWithReply( + this->proxy_, + setMethodName_, + setMethodSignature_, + (_info ? _info : &defaultCallInfo), + deployedRequest, + _status, + deployedResponse); + _response = deployedResponse.getValue(); + } + + + std::future<CallStatus> setValueAsync(const ValueType &_request, AttributeAsyncCallback _callback, const CommonAPI::CallInfo *_info) { + CommonAPI::Deployable<ValueType, _AttributeDepl> deployedRequest(_request, this->depl_); + CommonAPI::Deployable<ValueType, _AttributeDepl> deployedResponse(this->depl_); + return DBusProxyHelper<DBusSerializableArguments<CommonAPI::Deployable<ValueType, _AttributeDepl>>, + DBusSerializableArguments<CommonAPI::Deployable<ValueType, _AttributeDepl>> >::callMethodAsync( + this->proxy_, + setMethodName_, + setMethodSignature_, + (_info ? _info : &defaultCallInfo), + deployedRequest, + [_callback](CommonAPI::CallStatus _status, CommonAPI::Deployable<ValueType, _AttributeDepl> _response) { + _callback(_status, _response.getValue()); + }, + std::make_tuple(deployedResponse)); + } + + protected: + const char* setMethodName_; + const char* setMethodSignature_; +}; + +template <typename _AttributeType> +class DBusObservableAttribute: public _AttributeType { +public: + typedef typename _AttributeType::ValueType ValueType; + typedef typename _AttributeType::ValueTypeDepl ValueTypeDepl; + typedef typename _AttributeType::AttributeAsyncCallback AttributeAsyncCallback; + typedef typename _AttributeType::ChangedEvent ChangedEvent; + + template <typename... _AttributeTypeArguments> + DBusObservableAttribute(DBusProxy &_proxy, + const char *_changedEventName, + _AttributeTypeArguments... arguments) + : _AttributeType(_proxy, arguments...), + changedEvent_(_proxy, _changedEventName, this->setMethodSignature_, + std::make_tuple(CommonAPI::Deployable<ValueType, ValueTypeDepl>(this->depl_))) { + } + + ChangedEvent &getChangedEvent() { + return changedEvent_; + } + + protected: + DBusEvent<ChangedEvent, CommonAPI::Deployable<ValueType, ValueTypeDepl> > changedEvent_; +}; + +} // namespace DBus +} // namespace CommonAPI + +#endif // COMMONAPI_DBUS_DBUS_ATTRIBUTE_HPP_ |