diff options
Diffstat (limited to 'PluginCommandInterfaceDbus/DBUSMessageHandler.cpp')
| -rw-r--r-- | PluginCommandInterfaceDbus/DBUSMessageHandler.cpp | 343 |
1 files changed, 343 insertions, 0 deletions
diff --git a/PluginCommandInterfaceDbus/DBUSMessageHandler.cpp b/PluginCommandInterfaceDbus/DBUSMessageHandler.cpp new file mode 100644 index 0000000..6f335c6 --- /dev/null +++ b/PluginCommandInterfaceDbus/DBUSMessageHandler.cpp @@ -0,0 +1,343 @@ + + +#include "headers.h" +#include <stdlib.h> + +DBUSMessageHandler::DBUSMessageHandler() +: m_MessageIter() +, m_pReply(0) +, m_serial(0) +, m_pConnection(0) +{ + dbus_error_init(&m_err); + + // connect to the bus and check for errors + m_pConnection = dbus_bus_get(DBUS_BUS_SESSION, &m_err); + if (dbus_error_is_set(&m_err)) + { + DLT_LOG(DBusPlugin,DLT_LOG_INFO, DLT_STRING("DBUSCommunicator Connection error")); + dbus_error_free(&m_err); + } + if (NULL == m_pConnection) + { + DLT_LOG(DBusPlugin,DLT_LOG_INFO, DLT_STRING("DBUSCommunicator Connection is null")); + exit(1); + } + int ret = dbus_bus_request_name(m_pConnection,DBUS_SERVICE_PREFIX, DBUS_NAME_FLAG_REPLACE_EXISTING, &m_err); + if (dbus_error_is_set(&m_err)) + { + DLT_LOG(DBusPlugin,DLT_LOG_INFO, DLT_STRING("DBUSCommunicator Name Error"),DLT_STRING(m_err.message)); + dbus_error_free(&m_err); + } + if (DBUS_REQUEST_NAME_REPLY_PRIMARY_OWNER != ret) + { + DLT_LOG(DBusPlugin,DLT_LOG_INFO, DLT_STRING("DBUSCommunicatorNot Primary Owner"), DLT_INT(ret)); + exit(1); + } +} + +DBUSMessageHandler::~DBUSMessageHandler() +{ + DBusError err; + dbus_error_init(&err); + bool errorset = dbus_error_is_set(&err); + if (errorset) + { + DLT_LOG(DBusPlugin,DLT_LOG_ERROR, DLT_STRING("there was an dbus error")); + } + dbus_bus_name_has_owner(m_pConnection, DBUS_SERVICE_PREFIX, &err); + errorset = dbus_error_is_set(&err); + if (errorset) + { + DLT_LOG(DBusPlugin,DLT_LOG_ERROR, DLT_STRING("there was an dbus error")); + } + dbus_error_init(&err); + dbus_bus_release_name(m_pConnection, DBUS_SERVICE_PREFIX, &err); +} + +void DBUSMessageHandler::initReceive(DBusMessage* msg) +{ + if (!dbus_message_iter_init(msg, &m_MessageIter)) + { + DLT_LOG(DBusPlugin,DLT_LOG_ERROR, DLT_STRING("DBUS Message has no arguments!")); + } +} + +void DBUSMessageHandler::initReply(DBusMessage* msg) +{ + // create a reply from the message + m_pReply = dbus_message_new_method_return(msg); + dbus_message_iter_init_append(m_pReply, &m_MessageIter); +} + +void DBUSMessageHandler::closeReply() +{ + // send the reply && flush the connection + if (!dbus_connection_send(m_pConnection, m_pReply, &m_serial)) + { + DLT_LOG(DBusPlugin,DLT_LOG_ERROR, DLT_STRING("DBUS handler Out Of Memory!")); + exit(1); + } + DLT_LOG(DBusPlugin,DLT_LOG_ERROR, DLT_STRING("DBUS handler sending reply!")); + dbus_connection_flush(m_pConnection); + + // free the reply + dbus_message_unref(m_pReply); + m_pReply = NULL; +} + +void DBUSMessageHandler::ReplyError(DBusMessage* msg, const char* errorname, const char* errorMsg) +{ + m_pReply = dbus_message_new_error(msg, errorname, errorMsg); + // send the reply && flush the connection + if (!dbus_connection_send(m_pConnection, m_pReply, &m_serial)) + { + DLT_LOG(DBusPlugin,DLT_LOG_ERROR, DLT_STRING("DBUS handler Out Of Memory!")); + exit(1); + } + DLT_LOG(DBusPlugin,DLT_LOG_ERROR, DLT_STRING("DBUS handler sending reply with error!")); + dbus_connection_flush(m_pConnection); + + // free the reply + dbus_message_unref(m_pReply); +} + +char* DBUSMessageHandler::getString() +{ + char* param; + + if (DBUS_TYPE_STRING != dbus_message_iter_get_arg_type(&m_MessageIter)) + { + DLT_LOG(DBusPlugin,DLT_LOG_ERROR, DLT_STRING("DBUS handler argument is no string!")); + } + else + { + dbus_message_iter_get_basic(&m_MessageIter, ¶m); + dbus_message_iter_next(&m_MessageIter); + } + return param; +} + +dbus_bool_t DBUSMessageHandler::getBool() +{ + dbus_bool_t boolparam; + + if (DBUS_TYPE_BOOLEAN != dbus_message_iter_get_arg_type(&m_MessageIter)) + { + DLT_LOG(DBusPlugin,DLT_LOG_ERROR, DLT_STRING("DBUS handler argument is no bool!")); + } + else + { + dbus_message_iter_get_basic(&m_MessageIter, &boolparam); + dbus_message_iter_next(&m_MessageIter); + } + return boolparam; +} + +char DBUSMessageHandler::getByte() +{ + char param; + + if (DBUS_TYPE_BYTE != dbus_message_iter_get_arg_type(&m_MessageIter)) + { + DLT_LOG(DBusPlugin,DLT_LOG_ERROR, DLT_STRING("DBUS handler argument is no byte!")); + } + else + { + dbus_message_iter_get_basic(&m_MessageIter, ¶m); + dbus_message_iter_next(&m_MessageIter); + } + return param; +} + +dbus_uint32_t DBUSMessageHandler::getUInt() +{ + dbus_uint32_t param; + + if (DBUS_TYPE_UINT32 != dbus_message_iter_get_arg_type(&m_MessageIter)) + { + DLT_LOG(DBusPlugin,DLT_LOG_ERROR, DLT_STRING("DBUS handler argument is no uint32_t!")); + } + else + { + dbus_message_iter_get_basic(&m_MessageIter, ¶m); + dbus_message_iter_next(&m_MessageIter); + } + return param; +} + +double DBUSMessageHandler::getDouble() +{ + double param; + + if (DBUS_TYPE_DOUBLE != dbus_message_iter_get_arg_type(&m_MessageIter)) + { + DLT_LOG(DBusPlugin,DLT_LOG_ERROR, DLT_STRING("DBUS handler argument is no double!")); + } + else + { + dbus_message_iter_get_basic(&m_MessageIter, ¶m); + dbus_message_iter_next(&m_MessageIter); + } + return param; +} + +void DBUSMessageHandler::getArrayOfUInt(int* pLength, unsigned int** ppArray) +{ + if (DBUS_TYPE_ARRAY != dbus_message_iter_get_arg_type(&m_MessageIter)) + { + DLT_LOG(DBusPlugin,DLT_LOG_ERROR, DLT_STRING("DBUS handler argument is no array!")); + return; + } + + DBusMessageIter arrayIter; + dbus_message_iter_recurse(&m_MessageIter, &arrayIter); + + uint* localArray; + dbus_message_iter_get_fixed_array(&arrayIter, &localArray, pLength); + + *ppArray = new uint[*pLength]; + for (int i = 0; i < *pLength; i++) + { + (*ppArray)[i] = localArray[i]; + } +} + +void DBUSMessageHandler::getArrayOfString(std::vector<std::string>* stringVector) +{ + if (DBUS_TYPE_ARRAY != dbus_message_iter_get_arg_type(&m_MessageIter)) + { + DLT_LOG(DBusPlugin,DLT_LOG_ERROR, DLT_STRING("DBUS handler argument is no array!")); + return; + } + + DBusMessageIter arrayIter; + dbus_message_iter_recurse(&m_MessageIter, &arrayIter); + bool hasNext = true; + while (hasNext) + { + if (DBUS_TYPE_STRING != dbus_message_iter_get_arg_type(&arrayIter)) + { + DLT_LOG(DBusPlugin,DLT_LOG_ERROR, DLT_STRING("DBUS handler argument is no string!")); + } + char* param; + dbus_message_iter_get_basic(&arrayIter, ¶m); + + stringVector->push_back(std::string(param)); + + if (dbus_message_iter_has_next(&arrayIter)) + { + dbus_message_iter_next(&arrayIter); + } + else + { + hasNext = false; + } + } +} + +void DBUSMessageHandler::appendBool(dbus_bool_t toAppend) +{ + if (!dbus_message_iter_append_basic(&m_MessageIter, DBUS_TYPE_BOOLEAN, &toAppend)) + { + DLT_LOG(DBusPlugin,DLT_LOG_ERROR, DLT_STRING("DBUS handler Out Of Memory!")); + exit(1); + } +} + +void DBUSMessageHandler::appendUInt(dbus_uint32_t toAppend) +{ + if (!dbus_message_iter_append_basic(&m_MessageIter, DBUS_TYPE_UINT32, &toAppend)) + { + DLT_LOG(DBusPlugin,DLT_LOG_ERROR, DLT_STRING("DBUS handler Out Of Memory!")); + exit(1); + } +} + +void DBUSMessageHandler::appendDouble(double toAppend) +{ + if (!dbus_message_iter_append_basic(&m_MessageIter, DBUS_TYPE_DOUBLE, &toAppend)) + { + DLT_LOG(DBusPlugin,DLT_LOG_ERROR, DLT_STRING("DBUS handler Out Of Memory!")); + exit(1); + } +} + +void DBUSMessageHandler::appendByte(char toAppend) +{ + if (!dbus_message_iter_append_basic(&m_MessageIter, DBUS_TYPE_BYTE, &toAppend)) + { + DLT_LOG(DBusPlugin,DLT_LOG_ERROR, DLT_STRING("DBUS handler Out Of Memory!")); + exit(1); + } +} + +void DBUSMessageHandler::appendArrayOfUInt(unsigned int length, unsigned int *IDs) +{ + DBusMessageIter arrayIter; + dbus_message_iter_open_container(&m_MessageIter, DBUS_TYPE_ARRAY, "u", &arrayIter); + for(unsigned int i = 0; i < length; i++) + { + dbus_message_iter_append_basic(&arrayIter, DBUS_TYPE_UINT32, &IDs[i]); + } + dbus_message_iter_close_container(&m_MessageIter, &arrayIter); +} + +void DBUSMessageHandler::sendSignal(const char* name, const char* signal) { + dbus_uint32_t serial = 0; + DBusMessage* msg; + DBusMessageIter args; + + msg = dbus_message_new_signal(DBUS_SERVICE_PREFIX, signal, name); + + if (NULL == msg) + { + DLT_LOG(DBusPlugin,DLT_LOG_ERROR, DLT_STRING("Message null!")); + this->~DBUSMessageHandler(); + } + + if (!dbus_connection_send(m_pConnection, msg, &serial)) { + DLT_LOG(DBusPlugin,DLT_LOG_ERROR, DLT_STRING("DBUS handler Out Of Memory!")); + this->~DBUSMessageHandler(); + } + + dbus_connection_flush(m_pConnection); + + // free the message + dbus_message_unref(msg); +} + +void DBUSMessageHandler::appendArrayOfStringUInt(std::list<stringAndUInt> list){ + DBusMessageIter arrayIter; + dbus_message_iter_open_container(&m_MessageIter, DBUS_TYPE_ARRAY, "si", &arrayIter); + + std::list<stringAndUInt>::iterator Ilist; + std::list<stringAndUInt>::iterator Ibegin=list.begin(); + std::list<stringAndUInt>::iterator Iend=list.end(); + for(Ilist=Ibegin;Ilist!=Iend; Ilist++) + { + dbus_message_iter_append_basic(&arrayIter, DBUS_TYPE_STRING, &Ilist->string); + dbus_message_iter_append_basic(&arrayIter, DBUS_TYPE_UINT32, &Ilist->integer); + } + dbus_message_iter_close_container(&m_MessageIter, &arrayIter); +} + +void DBUSMessageHandler::appendArrayOfStringString(std::list<stringString> list){ + DBusMessageIter arrayIter; + dbus_message_iter_open_container(&m_MessageIter, DBUS_TYPE_ARRAY, "ss", &arrayIter); + + std::list<stringString>::iterator Ilist; + std::list<stringString>::iterator Ibegin=list.begin(); + std::list<stringString>::iterator Iend=list.end(); + for(Ilist=Ibegin;Ilist!=Iend; Ilist++) + { + dbus_message_iter_append_basic(&arrayIter, DBUS_TYPE_STRING, &Ilist->string1); + dbus_message_iter_append_basic(&arrayIter, DBUS_TYPE_STRING, &Ilist->string2); + } + dbus_message_iter_close_container(&m_MessageIter, &arrayIter); + +} + + + + |