From 63ebcbadc9a4a2eff1a61c307eeb0465ef36a586 Mon Sep 17 00:00:00 2001 From: Martin Preuss Date: Wed, 25 Jun 2025 00:01:12 +0200 Subject: [PATCH] added msg "getValues" --- aqhome/msg/ipc/data/0BUILD | 2 + aqhome/msg/ipc/data/m_ipcd_getvalues.c | 81 ++++++++++++++++++++++++++ aqhome/msg/ipc/data/m_ipcd_getvalues.h | 36 ++++++++++++ 3 files changed, 119 insertions(+) create mode 100644 aqhome/msg/ipc/data/m_ipcd_getvalues.c create mode 100644 aqhome/msg/ipc/data/m_ipcd_getvalues.h diff --git a/aqhome/msg/ipc/data/0BUILD b/aqhome/msg/ipc/data/0BUILD index 3962eb1..527384b 100644 --- a/aqhome/msg/ipc/data/0BUILD +++ b/aqhome/msg/ipc/data/0BUILD @@ -51,6 +51,7 @@ m_ipcd_values.h m_ipcd_getdata.h m_ipcd_setdata.h + m_ipcd_getvalues.h @@ -67,6 +68,7 @@ m_ipcd_values.c m_ipcd_getdata.c m_ipcd_setdata.c + m_ipcd_getvalues.c diff --git a/aqhome/msg/ipc/data/m_ipcd_getvalues.c b/aqhome/msg/ipc/data/m_ipcd_getvalues.c new file mode 100644 index 0000000..d90e0b1 --- /dev/null +++ b/aqhome/msg/ipc/data/m_ipcd_getvalues.c @@ -0,0 +1,81 @@ +/**************************************************************************** + * This file is part of the project AqHome. + * AqHome (c) by 2025 Martin Preuss, all rights reserved. + * + * The license for this file can be found in the file COPYING which you + * should have received along with this file. + ****************************************************************************/ + +#ifdef HAVE_CONFIG_H +# include +#endif + + +#include "aqhome/msg/ipc/data/m_ipcd_getvalues.h" +#include "aqhome/msg/ipc/m_ipc_tag16.h" +#include "aqhome/msg/ipc/data/m_ipcd.h" +#include "aqhome/msg/ipc/m_ipc.h" + +#include +#include +#include +#include + + + +/* ------------------------------------------------------------------------------------------------ + * forward declarations + * ------------------------------------------------------------------------------------------------ + */ + + + +/* ------------------------------------------------------------------------------------------------ + * implementation + * ------------------------------------------------------------------------------------------------ + */ + +AQH_MESSAGE *AQH_IpcdMessageGetValues_new(uint16_t code, uint32_t msgId, uint32_t refMsgId, + const char *deviceName, int modality) +{ + AQH_MESSAGE *msg; + GWEN_BUFFER *buf; + + buf=GWEN_Buffer_new(0, 256, 0, 1); + + if (deviceName && *deviceName) + GWEN_Tag16_WriteStringTagToBuffer(AQH_MSGDATA_GETVALUES_TAGS_DEVICENAME, deviceName, buf); + GWEN_Tag16_WriteUint64TagToBuffer(AQH_MSGDATA_GETVALUES_TAGS_MODALITY, modality, buf); + + msg=AQH_IpcMessage_new(AQH_IPC_PROTOCOL_DATA_ID, AQH_IPC_PROTOCOL_DATA_VERSION, code, msgId, refMsgId, + GWEN_Buffer_GetUsedBytes(buf), (const uint8_t*) GWEN_Buffer_GetStart(buf)); + GWEN_Buffer_free(buf); + return msg; +} + + + +void AQH_IpcdMessageGetValues_DumpToBuffer(const AQH_MESSAGE *msg, const GWEN_TAG16_LIST *tagList, + GWEN_BUFFER *dbuf, const char *sText) +{ + char *deviceName; + uint64_t modality; + + deviceName=tagList?AQH_Tag16_GetTagDataAsNewString(tagList, AQH_MSGDATA_GETVALUES_TAGS_DEVICENAME, NULL):NULL; + modality=tagList?AQH_Tag16_GetTagDataAsUint64(tagList, AQH_MSGDATA_GETVALUES_TAGS_MODALITY, 0):0; + + GWEN_Buffer_AppendArgs(dbuf, + "GETVALUES(%s) %s (code=%d, proto=%d, proto version=%d, device=%s, modality=%s)\n", + AQH_IpcdMessage_MsgTypeToChar(AQH_IpcMessage_GetCode(msg)), + sText?sText:"", + AQH_IpcMessage_GetCode(msg), + AQH_IpcMessage_GetProtoId(msg), + AQH_IpcMessage_GetProtoVersion(msg), + deviceName?deviceName:"", + AQH_ValueModality_toString(modality)); + free(deviceName); +} + + + + diff --git a/aqhome/msg/ipc/data/m_ipcd_getvalues.h b/aqhome/msg/ipc/data/m_ipcd_getvalues.h new file mode 100644 index 0000000..9680eae --- /dev/null +++ b/aqhome/msg/ipc/data/m_ipcd_getvalues.h @@ -0,0 +1,36 @@ +/**************************************************************************** + * This file is part of the project AqHome. + * AqHome (c) by 2025 Martin Preuss, all rights reserved. + * + * The license for this file can be found in the file COPYING which you + * should have received along with this file. + ****************************************************************************/ + +#ifndef AQH_M_IPCD_GETVALUES_H +#define AQH_M_IPCD_GETVALUES_H + + + +#include +#include +#include + +#include +#include + + + +#define AQH_MSGDATA_GETVALUES_TAGS_DEVICENAME 0x0001 +#define AQH_MSGDATA_GETVALUES_TAGS_MODALITY 0x0002 + + + +AQHOME_API AQH_MESSAGE *AQH_IpcdMessageGetValues_new(uint16_t code, uint32_t msgId, uint32_t refMsgId, + const char *deviceName, int modality); + +AQHOME_API void AQH_IpcdMessageGetValues_DumpToBuffer(const AQH_MESSAGE *msg, const GWEN_TAG16_LIST *tagList, + GWEN_BUFFER *dbuf, const char *sText); + + + +#endif