add IPC command to modify device info on the server.

2023-10-02 23:22:59 +02:00
parent 043541f936
commit 253b3862da
12 changed files with 504 additions and 11 deletions
--- a/apps/aqhome-data/c_moddevice.c
+++ b/apps/aqhome-data/c_moddevice.c
@@ -0,0 +1,112 @@
+/****************************************************************************
+ * This file is part of the project AqHome.
+ * AqHome (c) by 2023 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 <config.h>
+#endif
+
+
+#include "./c_getlastdatapoint.h"
+#include "./aqhome_data_p.h"
+#include "aqhome/ipc/data/ipc_data.h"
+#include "aqhome/ipc/data/msg_data_devices.h"
+#include "aqhome/ipc/endpoint_ipc.h"
+#include "aqhome/ipc/msg_ipc_result.h"
+#include "aqhome/ipc/msg_ipc_tag16.h"
+
+#include <gwenhywfar/debug.h>
+#include <gwenhywfar/text.h>
+
+
+
+/* ------------------------------------------------------------------------------------------------
+ * defines
+ * ------------------------------------------------------------------------------------------------
+ */
+
+
+
+/* ------------------------------------------------------------------------------------------------
+ * forward declarations
+ * ------------------------------------------------------------------------------------------------
+ */
+
+
+
+/* ------------------------------------------------------------------------------------------------
+ * implementations
+ * ------------------------------------------------------------------------------------------------
+ */
+
+
+void AqHomeData_HandleModDevice(AQHOME_DATA *aqh, GWEN_MSG_ENDPOINT *ep, GWEN_MSG *recvdMsg)
+{
+  GWEN_MSG *outMsg;
+  int resultCode=AQH_MSG_IPC_SUCCESS;
+
+  if (AQH_IpcEndpoint_GetPermissions(ep) & AQH_IPCENDPOINT_PERMS_MODDEVICE) {
+    AQH_DEVICE *device;
+
+    AQH_DevicesDataIpcMsg_Parse(recvdMsg, 0);
+    device=AQH_DevicesDataIpcMsg_ReadFirstDevice(recvdMsg);
+    if (device) {
+      const char *deviceNameForSystem;
+
+      deviceNameForSystem=AQH_Device_GetNameForSystem(device);
+      if (deviceNameForSystem && *deviceNameForSystem) {
+        AQH_DEVICE *storedDevice;
+
+        storedDevice=AQH_Storage_GetDeviceByNameForSystem(aqh->storage, deviceNameForSystem);
+        if (storedDevice) {
+          const char *s;
+
+          s=AQH_Device_GetNameForGui(device);
+          if (s && *s)
+            AQH_Device_SetNameForGui(storedDevice, s);
+
+          s=AQH_Device_GetRoomName(device);
+          if (s && *s)
+            AQH_Device_SetRoomName(storedDevice, s);
+
+          s=AQH_Device_GetLocation(device);
+          if (s && *s)
+            AQH_Device_SetLocation(storedDevice, s);
+
+          s=AQH_Device_GetDescription(device);
+          if (s && *s)
+            AQH_Device_SetDescription(storedDevice, s);
+
+          AQH_Storage_AddRuntimeFlags(aqh->storage, AQH_STORAGE_RTFLAGS_MODIFIED);
+          resultCode=AQH_MSG_IPC_SUCCESS;
+        }
+        else {
+          DBG_INFO(NULL, "Device \"%s\" not found", deviceNameForSystem);
+          resultCode=AQH_MSG_IPC_ERROR_NOTFOUND;
+        }
+      }
+      else {
+        DBG_INFO(NULL, "No name for value");
+        resultCode=AQH_MSG_IPC_ERROR_NOTFOUND;
+      }
+    }
+    else {
+      DBG_INFO(NULL, "No device info in message");
+      resultCode=AQH_MSG_IPC_ERROR_INVALID;
+    }
+  }
+  else {
+    DBG_ERROR(AQH_LOGDOMAIN, "No permissions to read data");
+    resultCode=AQH_MSG_IPC_ERROR_PERMS;
+  }
+
+  outMsg=AQH_ResultIpcMsg_new(AQH_MSGTYPE_IPC_DATA_RESULT, resultCode);
+  GWEN_MsgEndpoint_AddSendMessage(ep, outMsg);
+}
+
+
+