Copy commands and events when duplicating endpoint (#1461)

* Copy commands and events when duplicating endpoint

- When duplicating an endpoint, only attribute states are copied. This PR extends to copy command and event states.

- fix issue #1441

- Jira: GHM_ZAP-457

src-electron/db/query-command.js

@@ -24,6 +24,83 @@
 const dbApi = require('./db-api.js')
 const dbMapping = require('./db-mapping.js')
 
+/**
+ * Promises to select all endpoint type commands filtered by EndpointTypeRef and ClusterRef.
+ *
+ * @export
+ * @param {*} db
+ * @param {*} endpointTypeRef
+ * @param {*} endpointTypeClusterRef
+ * @returns Records of selected Endpoint Type Commands.
+ */
+async function selectEndpointTypeCommandsByEndpointTypeRefAndClusterRef(
+ db,
+ endpointTypeRef,
+ endpointTypeClusterRef
+) {
+ let rows = await dbApi.dbAll(
+ db,
+ `
+ SELECT
+ ENDPOINT_TYPE_COMMAND.ENDPOINT_TYPE_COMMAND_ID,
+ ENDPOINT_TYPE_CLUSTER.ENDPOINT_TYPE_REF,
+ ENDPOINT_TYPE_COMMAND.ENDPOINT_TYPE_CLUSTER_REF AS 'CLUSTER_REF',
+ ENDPOINT_TYPE_COMMAND.COMMAND_REF,
+ ENDPOINT_TYPE_COMMAND.IS_INCOMING,
+ ENDPOINT_TYPE_COMMAND.IS_ENABLED
+ FROM
+ ENDPOINT_TYPE_COMMAND
+ INNER JOIN
+ ENDPOINT_TYPE_CLUSTER
+ ON
+ ENDPOINT_TYPE_COMMAND.ENDPOINT_TYPE_CLUSTER_REF = ENDPOINT_TYPE_CLUSTER.ENDPOINT_TYPE_CLUSTER_ID
+ WHERE
+ ENDPOINT_TYPE_CLUSTER.ENDPOINT_TYPE_REF = ?
+ AND
+ ENDPOINT_TYPE_COMMAND.ENDPOINT_TYPE_CLUSTER_REF = ?`,
+ [endpointTypeRef, endpointTypeClusterRef]
+ )
+ return rows.map(dbMapping.map.endpointTypeCommand)
+}
+
+/**
+ * Promises to duplicate endpoint type commands.
+ *
+ * @export
+ * @param {*} db
+ * @param {*} newEndpointTypeClusterRef
+ * @param {*} command
+ * @returns Promise duplicated endpoint type command's id.
+ */
+async function duplicateEndpointTypeCommand(
+ db,
+ newEndpointTypeClusterRef,
+ command
+) {
+ return await dbApi.dbInsert(
+ db,
+ `INSERT INTO
+ ENDPOINT_TYPE_COMMAND (
+ ENDPOINT_TYPE_CLUSTER_REF,
+ COMMAND_REF,
+ IS_INCOMING,
+ IS_ENABLED
+ )
+ VALUES (
+ ?,
+ ?,
+ ?,
+ ?
+ )`,
+ [
+ newEndpointTypeClusterRef,
+ command.commandRef,
+ command.isIncoming,
+ command.isEnabled
+ ]
+ )
+}
+
 /**
  * Returns the count of the number of cluster commands with cli for a cluster
  * @param {*} db
@@ -2008,3 +2085,6 @@ exports.selectAllClustersWithOutgoingCommands =
  selectAllClustersWithOutgoingCommands
 exports.selectAllOutgoingCommandsForCluster =
  selectAllOutgoingCommandsForCluster
+exports.selectEndpointTypeCommandsByEndpointTypeRefAndClusterRef =
+ selectEndpointTypeCommandsByEndpointTypeRefAndClusterRef
+exports.duplicateEndpointTypeCommand = duplicateEndpointTypeCommand

src-electron/db/query-event.js

@@ -24,6 +24,75 @@
 const dbApi = require('./db-api.js')
 const dbMapping = require('./db-mapping.js')
 
+/**
+ * Promises to select all endpoint type events filtered by EndpointTypeRef and ClusterRef.
+ *
+ * @export
+ * @param {*} db
+ * @param {*} endpointTypeRef
+ * @param {*} endpointTypeClusterRef
+ * @returns Records of selected Endpoint Type Events.
+ */
+async function selectEndpointTypeEventsByEndpointTypeRefAndClusterRef(
+ db,
+ endpointTypeRef,
+ endpointTypeClusterRef
+) {
+ let rows = await dbApi.dbAll(
+ db,
+ `
+ SELECT
+ ENDPOINT_TYPE_EVENT.ENDPOINT_TYPE_EVENT_ID,
+ ENDPOINT_TYPE_CLUSTER.ENDPOINT_TYPE_REF,
+ ENDPOINT_TYPE_EVENT.ENDPOINT_TYPE_CLUSTER_REF AS 'CLUSTER_REF',
+ ENDPOINT_TYPE_EVENT.EVENT_REF,
+ ENDPOINT_TYPE_EVENT.INCLUDED
+ FROM
+ ENDPOINT_TYPE_EVENT
+ INNER JOIN
+ ENDPOINT_TYPE_CLUSTER
+ ON
+ ENDPOINT_TYPE_EVENT.ENDPOINT_TYPE_CLUSTER_REF = ENDPOINT_TYPE_CLUSTER.ENDPOINT_TYPE_CLUSTER_ID
+ WHERE
+ ENDPOINT_TYPE_CLUSTER.ENDPOINT_TYPE_REF = ?
+ AND
+ ENDPOINT_TYPE_EVENT.ENDPOINT_TYPE_CLUSTER_REF = ?`,
+ [endpointTypeRef, endpointTypeClusterRef]
+ )
+ return rows.map(dbMapping.map.endpointTypeEvent)
+}
+
+/**
+ * Promises to duplicate endpoint type events.
+ *
+ * @export
+ * @param {*} db
+ * @param {*} newEndpointTypeClusterRef
+ * @param {*} event
+ * @returns Promise duplicated endpoint type event's id.
+ */
+async function duplicateEndpointTypeEvent(
+ db,
+ newEndpointTypeClusterRef,
+ event
+) {
+ return await dbApi.dbInsert(
+ db,
+ `INSERT INTO
+ ENDPOINT_TYPE_EVENT (
+ ENDPOINT_TYPE_CLUSTER_REF,
+ EVENT_REF,
+ INCLUDED
+ )
+ VALUES (
+ ?,
+ ?,
+ ?
+ )`,
+ [newEndpointTypeClusterRef, event.eventRef, event.included]
+ )
+}
+
 /**
  * Retrieves events for a given cluster Id.
  *
@@ -166,3 +235,6 @@ exports.selectEventsByClusterId = selectEventsByClusterId
 exports.selectAllEvents = selectAllEvents
 exports.selectAllEventFields = selectAllEventFields
 exports.selectEventFieldsByEventId = selectEventFieldsByEventId
+exports.selectEndpointTypeEventsByEndpointTypeRefAndClusterRef =
+ selectEndpointTypeEventsByEndpointTypeRefAndClusterRef
+exports.duplicateEndpointTypeEvent = duplicateEndpointTypeEvent

src-electron/rest/user-data.js

@@ -25,6 +25,7 @@ const env = require('../util/env')
 const queryZcl = require('../db/query-zcl.js')
 const queryAttribute = require('../db/query-attribute.js')
 const queryCommand = require('../db/query-command.js')
+const queryEvent = require('../db/query-event.js')
 const queryFeature = require('../db/query-feature')
 const queryConfig = require('../db/query-config.js')
 const upgrade = require('../sdk/matter.js')
@@ -1045,6 +1046,32 @@ async function duplicateEndpointTypeClusters(
  attrubute
  )
  })
+ let oldCommands =
+ await queryCommand.selectEndpointTypeCommandsByEndpointTypeRefAndClusterRef(
+ db,
+ oldEndpointTypeId,
+ endpointTypeCluster.endpointTypeClusterId
+ )
+ oldCommands.forEach(async (command) => {
+ await queryCommand.duplicateEndpointTypeCommand(
+ db,
+ newEndpointTypeClusterId,
+ command
+ )
+ })
+ let oldEvents =
+ await queryEvent.selectEndpointTypeEventsByEndpointTypeRefAndClusterRef(
+ db,
+ oldEndpointTypeId,
+ endpointTypeCluster.endpointTypeClusterId
+ )
+ oldEvents.forEach(async (event) => {
+ await queryEvent.duplicateEndpointTypeEvent(
+ db,
+ newEndpointTypeClusterId,
+ event
+ )
+ })
  })
 }