From d468d2fb1a24b60ad5f58428c71f6dfce39951ac Mon Sep 17 00:00:00 2001
From: Martin Preuss <martin@aquamaniac.de>
Date: Tue, 18 Mar 2025 22:57:51 +0100
Subject: [PATCH] aqhome-tool: exchange CONNECT messages for data IPC.

---
 apps/aqhome-tool/data/adddata.c       | 1 +
 apps/aqhome-tool/data/getdatapoints.c | 1 +
 apps/aqhome-tool/data/getdevices.c    | 1 +
 apps/aqhome-tool/data/getvalues.c     | 1 +
 apps/aqhome-tool/data/moddevice.c     | 1 +
 apps/aqhome-tool/data/setdata.c       | 1 +
 apps/aqhome-tool/data/watch.c         | 1 +
 7 files changed, 7 insertions(+)

diff --git a/apps/aqhome-tool/data/adddata.c b/apps/aqhome-tool/data/adddata.c
index cb83337..a748ad4 100644
--- a/apps/aqhome-tool/data/adddata.c
+++ b/apps/aqhome-tool/data/adddata.c
@@ -80,6 +80,7 @@ int AQH_Tool_AddDataPoint(GWEN_DB_NODE *dbGlobalArgs, int argc, char **argv)
 
   eventLoop=AQH_EventLoop_new();
   o=AQH_ToolClient_new(eventLoop, AQH_IPC_PROTOCOL_DATA_ID, AQH_IPC_PROTOCOL_DATA_VERSION, dbGlobalArgs, args);
+  AQH_ToolClient_AddFlags(o, AQH_TOOL_CLIENT_CONNECTFLAGS_WITHCONNECTMSG);
   AQH_ToolClient_SetCreateRequestMessageFn(o, _createRequestMessage);
   rv=AQH_ToolClient_ReadLocalArgs(o, argc, argv);
   if (rv!=0)
diff --git a/apps/aqhome-tool/data/getdatapoints.c b/apps/aqhome-tool/data/getdatapoints.c
index b94576b..cb4c57d 100644
--- a/apps/aqhome-tool/data/getdatapoints.c
+++ b/apps/aqhome-tool/data/getdatapoints.c
@@ -85,6 +85,7 @@ int AQH_Tool_GetDataPoints(GWEN_DB_NODE *dbGlobalArgs, int argc, char **argv)
 
   eventLoop=AQH_EventLoop_new();
   o=AQH_ToolClient_new(eventLoop, AQH_IPC_PROTOCOL_DATA_ID, AQH_IPC_PROTOCOL_DATA_VERSION, dbGlobalArgs, args);
+  AQH_ToolClient_AddFlags(o, AQH_TOOL_CLIENT_CONNECTFLAGS_WITHCONNECTMSG);
   AQH_ToolClient_SetCreateRequestMessageFn(o, _createRequestMessage);
   AQH_ToolClient_SetHandleResponseMessageFn(o, _handleResponseMessage);
   rv=AQH_ToolClient_ReadLocalArgs(o, argc, argv);
diff --git a/apps/aqhome-tool/data/getdevices.c b/apps/aqhome-tool/data/getdevices.c
index d017cfe..6635bf9 100644
--- a/apps/aqhome-tool/data/getdevices.c
+++ b/apps/aqhome-tool/data/getdevices.c
@@ -75,6 +75,7 @@ int AQH_Tool_GetDevices(GWEN_DB_NODE *dbGlobalArgs, int argc, char **argv)
 
   eventLoop=AQH_EventLoop_new();
   o=AQH_ToolClient_new(eventLoop, AQH_IPC_PROTOCOL_DATA_ID, AQH_IPC_PROTOCOL_DATA_VERSION, dbGlobalArgs, args);
+  AQH_ToolClient_AddFlags(o, AQH_TOOL_CLIENT_CONNECTFLAGS_WITHCONNECTMSG);
   AQH_ToolClient_SetCreateRequestMessageFn(o, _createRequestMessage);
   AQH_ToolClient_SetHandleResponseMessageFn(o, _handleResponseMessage);
   rv=AQH_ToolClient_ReadLocalArgs(o, argc, argv);
diff --git a/apps/aqhome-tool/data/getvalues.c b/apps/aqhome-tool/data/getvalues.c
index e1a093f..c91d0ea 100644
--- a/apps/aqhome-tool/data/getvalues.c
+++ b/apps/aqhome-tool/data/getvalues.c
@@ -74,6 +74,7 @@ int AQH_Tool_GetValues(GWEN_DB_NODE *dbGlobalArgs, int argc, char **argv)
 
   eventLoop=AQH_EventLoop_new();
   o=AQH_ToolClient_new(eventLoop, AQH_IPC_PROTOCOL_DATA_ID, AQH_IPC_PROTOCOL_DATA_VERSION, dbGlobalArgs, args);
+  AQH_ToolClient_AddFlags(o, AQH_TOOL_CLIENT_CONNECTFLAGS_WITHCONNECTMSG);
   AQH_ToolClient_SetCreateRequestMessageFn(o, _createRequestMessage);
   AQH_ToolClient_SetHandleResponseMessageFn(o, _handleResponseMessage);
   rv=AQH_ToolClient_ReadLocalArgs(o, argc, argv);
diff --git a/apps/aqhome-tool/data/moddevice.c b/apps/aqhome-tool/data/moddevice.c
index 2c53f70..c0c17b0 100644
--- a/apps/aqhome-tool/data/moddevice.c
+++ b/apps/aqhome-tool/data/moddevice.c
@@ -76,6 +76,7 @@ int AQH_Tool_ModDevice(GWEN_DB_NODE *dbGlobalArgs, int argc, char **argv)
 
   eventLoop=AQH_EventLoop_new();
   o=AQH_ToolClient_new(eventLoop, AQH_IPC_PROTOCOL_DATA_ID, AQH_IPC_PROTOCOL_DATA_VERSION, dbGlobalArgs, args);
+  AQH_ToolClient_AddFlags(o, AQH_TOOL_CLIENT_CONNECTFLAGS_WITHCONNECTMSG);
   AQH_ToolClient_SetCreateRequestMessageFn(o, _createRequestMessage);
   rv=AQH_ToolClient_ReadLocalArgs(o, argc, argv);
   if (rv!=0)
diff --git a/apps/aqhome-tool/data/setdata.c b/apps/aqhome-tool/data/setdata.c
index c366926..2faee5a 100644
--- a/apps/aqhome-tool/data/setdata.c
+++ b/apps/aqhome-tool/data/setdata.c
@@ -74,6 +74,7 @@ int AQH_Tool_SetData(GWEN_DB_NODE *dbGlobalArgs, int argc, char **argv)
 
   eventLoop=AQH_EventLoop_new();
   o=AQH_ToolClient_new(eventLoop, AQH_IPC_PROTOCOL_DATA_ID, AQH_IPC_PROTOCOL_DATA_VERSION, dbGlobalArgs, args);
+  AQH_ToolClient_AddFlags(o, AQH_TOOL_CLIENT_CONNECTFLAGS_WITHCONNECTMSG);
   AQH_ToolClient_SetCreateRequestMessageFn(o, _createRequestMessage);
   rv=AQH_ToolClient_ReadLocalArgs(o, argc, argv);
   if (rv!=0)
diff --git a/apps/aqhome-tool/data/watch.c b/apps/aqhome-tool/data/watch.c
index 5ef55e4..0f7e670 100644
--- a/apps/aqhome-tool/data/watch.c
+++ b/apps/aqhome-tool/data/watch.c
@@ -76,6 +76,7 @@ int AQH_Tool_Watch(GWEN_DB_NODE *dbGlobalArgs, int argc, char **argv)
 
   eventLoop=AQH_EventLoop_new();
   o=AQH_ToolClient_new(eventLoop, AQH_IPC_PROTOCOL_DATA_ID, AQH_IPC_PROTOCOL_DATA_VERSION, dbGlobalArgs, args);
+  AQH_ToolClient_AddFlags(o, AQH_TOOL_CLIENT_CONNECTFLAGS_WITHCONNECTMSG);
   AQH_ToolClient_AddFlags(o, AQH_ENDPOINT_FLAGS_WANTUPDATES);
   AQH_ToolClient_SetHandleResponseMessageFn(o, _handleResponseMessage);
   rv=AQH_ToolClient_ReadLocalArgs(o, argc, argv);