Merge branch 'controller/shutdown-all-subss' into 'main'

components/esp_matter_controller: support for shutdown all subscriptions

See merge request app-frameworks/esp-matter!944

Author: chshu

components/esp_matter_controller/commands/esp_matter_controller_subscribe_command.cpp

@@ -294,5 +294,23 @@ esp_err_t send_shutdown_subscription(uint64_t node_id, uint32_t subscription_id)
     return ESP_OK;
 }
 
+void send_shutdown_subscriptions(uint64_t node_id)
+{
+    InteractionModelEngine::GetInstance()->ShutdownSubscriptions(
+#if CONFIG_ESP_MATTER_COMMISSIONER_ENABLE
+        matter_controller_client::get_instance().get_commissioner()->GetFabricIndex(),
+#else
+        get_fabric_index(),
+#endif
+        node_id);
+    ESP_LOGI(TAG, "Shutdown Subscriptions for node:0x%llx", node_id);
+}
+
+void send_shutdown_all_subscriptions()
+{
+    InteractionModelEngine::GetInstance()->ShutdownAllSubscriptions();
+    ESP_LOGI(TAG, "Shutdown all Subscriptions");
+}
+
 } // namespace controller
 } // namespace esp_matter

components/esp_matter_controller/commands/esp_matter_controller_subscribe_command.h

@@ -118,6 +118,8 @@ class subscribe_command : public ReadClient::Callback {
 
     CHIP_ERROR OnResubscriptionNeeded(ReadClient *apReadClient, CHIP_ERROR aTerminationCause) override;
 
+    uint32_t get_subscription_id() { return m_subscription_id; }
+
 private:
     uint64_t m_node_id;
     uint16_t m_min_interval;
@@ -222,7 +224,28 @@ esp_err_t send_subscribe_attr_command(uint64_t node_id, uint16_t endpoint_id, ui
 esp_err_t send_subscribe_event_command(uint64_t node_id, uint16_t endpoint_id, uint32_t cluster_id, uint32_t event_id,
                                        uint16_t min_interval, uint16_t max_interval, bool auto_resubscribe = true);
 
+/** Shut down a subscription for given node id and subscription id
+ *
+ * @param[in] node_id Node id
+ * @param[in] subscription_id Subscription id
+ *
+ * @return ESP_OK on success.
+ * @return ESP_FAIL in case of failure.
+ */
 esp_err_t send_shutdown_subscription(uint64_t node_id, uint32_t subscription_id);
 
+/** Shut down all subscriptions for a given node id
+ *
+ * @param[in] node_id Node id
+ * @return None
+ */
+void send_shutdown_subscriptions(uint64_t node_id);
+
+/** Shut down all subscriptions to all nodes
+ * @param[in] None
+ * @return None
+ */
+void send_shutdown_all_subscriptions();
+
 } // namespace controller
 } // namespace esp_matter

components/esp_matter_controller/core/esp_matter_controller_console.cpp

@@ -534,6 +534,25 @@ static esp_err_t controller_shutdown_subscription_handler(int argc, char **argv)
     return controller::send_shutdown_subscription(node_id, subscription_id);
 }
 
+static esp_err_t controller_shutdown_subscriptions_handler(int argc, char **argv)
+{
+    if (argc != 1) {
+        return ESP_ERR_INVALID_ARG;
+    }
+    uint64_t node_id = string_to_uint64(argv[0]);
+    controller::send_shutdown_subscriptions(node_id);
+    return ESP_OK;
+}
+
+static esp_err_t controller_shutdown_all_subscriptions_handler(int argc, char **argv)
+{
+    if (argc != 0) {
+        return ESP_ERR_INVALID_ARG;
+    }
+    controller::send_shutdown_all_subscriptions();
+    return ESP_OK;
+}
+
 static esp_err_t controller_dispatch(int argc, char **argv)
 {
     if (argc == 0) {
@@ -648,10 +667,22 @@ esp_err_t controller_register_commands()
         },
         {
             .name = "shutdown-subs",
-            .description = "Shutdown subscription.\n"
+            .description = "Shutdown subscription for given node id and subscription id.\n"
                            "\tUsage: controller shutdown-subs <node-id> <subscription-id>",
             .handler = controller_shutdown_subscription_handler,
         },
+        {
+            .name = "shutdown-subss",
+            .description = "Shutdown all subscriptions for a given node.\n"
+                           "\tUsage: controller shutdown-subss <node-id>",
+            .handler = controller_shutdown_subscriptions_handler,
+        },
+        {
+            .name = "shutdown-all-subss",
+            .description = "Shutdown all subscriptions to all nodes.\n"
+                           "\tUsage: controller shutdown-all-subss",
+            .handler = controller_shutdown_all_subscriptions_handler,
+        },
     };
 
     const static command_t controller_command = {