mirror of
https://github.com/espressif/esp-matter.git
synced 2026-04-27 19:13:13 +00:00
Pavel Borcin
259 lines
10 KiB
C++
259 lines
10 KiB
C++
/*
|
|
This example code is in the Public Domain (or CC0 licensed, at your option.)
|
|
|
|
Unless required by applicable law or agreed to in writing, this
|
|
software is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
|
|
CONDITIONS OF ANY KIND, either express or implied.
|
|
*/
|
|
|
|
#include <esp_log.h>
|
|
#include <stdlib.h>
|
|
#include <string.h>
|
|
|
|
#include <esp_matter.h>
|
|
#include <esp_matter_console.h>
|
|
#include "bsp/esp-bsp.h"
|
|
|
|
#include <app_priv.h>
|
|
#include <app_reset.h>
|
|
|
|
#include <app/server/Server.h>
|
|
|
|
using chip::kInvalidClusterId;
|
|
static constexpr chip::CommandId kInvalidCommandId = 0xFFFF'FFFF;
|
|
|
|
using namespace chip::app::Clusters;
|
|
using namespace esp_matter;
|
|
using namespace esp_matter::cluster;
|
|
|
|
static const char *TAG = "app_driver";
|
|
extern uint16_t switch_endpoint_id;
|
|
|
|
#if CONFIG_ENABLE_CHIP_SHELL
|
|
static char console_buffer[101] = {0};
|
|
static esp_err_t app_driver_bound_console_handler(int argc, char **argv)
|
|
{
|
|
if (argc == 1 && strncmp(argv[0], "help", sizeof("help")) == 0) {
|
|
printf("Bound commands:\n"
|
|
"\thelp: Print help\n"
|
|
"\tinvoke: <local_endpoint_id> <cluster_id> <command_id> parameters ... \n"
|
|
"\t\tExample: matter esp bound invoke 0x0001 0x0003 0x0000 0x78.\n");
|
|
} else if (argc >= 4 && strncmp(argv[0], "invoke", sizeof("invoke")) == 0) {
|
|
client::command_handle_t cmd_handle;
|
|
uint16_t local_endpoint_id = strtoul((const char *)&argv[1][2], NULL, 16);
|
|
cmd_handle.cluster_id = strtoul((const char *)&argv[2][2], NULL, 16);
|
|
cmd_handle.command_id = strtoul((const char *)&argv[3][2], NULL, 16);
|
|
|
|
if (argc > 4) {
|
|
console_buffer[0] = argc - 4;
|
|
for (int i = 0; i < (argc - 4); i++) {
|
|
if ((argv[4 + i][0] != '0') || (argv[4 + i][1] != 'x') ||
|
|
(strlen((const char *)&argv[4 + i][2]) > 10)) {
|
|
ESP_LOGE(TAG, "Incorrect arguments. Check help for more details.");
|
|
return ESP_ERR_INVALID_ARG;
|
|
}
|
|
strcpy((console_buffer + 1 + 10 * i), &argv[4 + i][2]);
|
|
}
|
|
|
|
cmd_handle.command_data = console_buffer;
|
|
}
|
|
|
|
client::cluster_update(local_endpoint_id, &cmd_handle);
|
|
} else {
|
|
ESP_LOGE(TAG, "Incorrect arguments. Check help for more details.");
|
|
return ESP_ERR_INVALID_ARG;
|
|
}
|
|
|
|
return ESP_OK;
|
|
}
|
|
|
|
static esp_err_t app_driver_client_console_handler(int argc, char **argv)
|
|
{
|
|
if (argc == 1 && strncmp(argv[0], "help", sizeof("help")) == 0) {
|
|
printf("Client commands:\n"
|
|
"\thelp: Print help\n"
|
|
"\tinvoke: <fabric_index> <remote_node_id> <remote_endpoint_id> <cluster_id> <command_id> parameters "
|
|
"... \n"
|
|
"\t\tExample: matter esp client invoke 0x0001 0xBC5C01 0x0001 0x0003 0x0000 0x78.\n"
|
|
"\tinvoke-group: <fabric_index> <group_id> <cluster_id> <command_id> parameters ... \n"
|
|
"\t\tExample: matter esp client invoke-group 0x0001 0x257 0x0003 0x0000 0x78.\n");
|
|
} else if (argc >= 6 && strncmp(argv[0], "invoke", sizeof("invoke")) == 0) {
|
|
client::command_handle_t cmd_handle;
|
|
uint8_t fabric_index = strtoul((const char *)&argv[1][2], NULL, 16);
|
|
uint64_t node_id = strtoull((const char *)&argv[2][2], NULL, 16);
|
|
cmd_handle.endpoint_id = strtoul((const char *)&argv[3][2], NULL, 16);
|
|
cmd_handle.cluster_id = strtoul((const char *)&argv[4][2], NULL, 16);
|
|
cmd_handle.command_id = strtoul((const char *)&argv[5][2], NULL, 16);
|
|
|
|
if (argc > 6) {
|
|
console_buffer[0] = argc - 6;
|
|
for (int i = 0; i < (argc - 6); i++) {
|
|
if ((argv[6 + i][0] != '0') || (argv[6 + i][1] != 'x') ||
|
|
(strlen((const char *)&argv[6 + i][2]) > 10)) {
|
|
ESP_LOGE(TAG, "Incorrect arguments. Check help for more details.");
|
|
return ESP_ERR_INVALID_ARG;
|
|
}
|
|
strcpy((console_buffer + 1 + 10 * i), &argv[6 + i][2]);
|
|
}
|
|
|
|
cmd_handle.command_data = console_buffer;
|
|
}
|
|
auto &server = chip::Server::GetInstance();
|
|
client::connect(server.GetCASESessionManager(), fabric_index, node_id, &cmd_handle);
|
|
} else if (argc >= 5 && strncmp(argv[0], "invoke-group", sizeof("invoke-group")) == 0) {
|
|
client::command_handle_t cmd_handle;
|
|
uint8_t fabric_index = strtoul((const char *)&argv[1][2], NULL, 16);
|
|
cmd_handle.group_id = strtoul((const char *)&argv[2][2], NULL, 16);
|
|
cmd_handle.cluster_id = strtoul((const char *)&argv[3][2], NULL, 16);
|
|
cmd_handle.command_id = strtoul((const char *)&argv[4][2], NULL, 16);
|
|
|
|
if (argc > 5) {
|
|
console_buffer[0] = argc - 5;
|
|
for (int i = 0; i < (argc - 5); i++) {
|
|
if ((argv[5 + i][0] != '0') || (argv[5 + i][1] != 'x') ||
|
|
(strlen((const char *)&argv[5 + i][2]) > 10)) {
|
|
ESP_LOGE(TAG, "Incorrect arguments. Check help for more details.");
|
|
return ESP_ERR_INVALID_ARG;
|
|
}
|
|
strcpy((console_buffer + 1 + 10 * i), &argv[5 + i][2]);
|
|
}
|
|
|
|
cmd_handle.command_data = console_buffer;
|
|
}
|
|
|
|
client::group_command_send(fabric_index, &cmd_handle);
|
|
} else {
|
|
ESP_LOGE(TAG, "Incorrect arguments. Check help for more details.");
|
|
return ESP_ERR_INVALID_ARG;
|
|
}
|
|
|
|
return ESP_OK;
|
|
}
|
|
|
|
static void app_driver_register_commands()
|
|
{
|
|
/* Add console command for bound devices */
|
|
static const esp_matter::console::command_t bound_command = {
|
|
.name = "bound",
|
|
.description = "This can be used to simulate on-device control for bound devices."
|
|
"Usage: matter esp bound <bound_command>. "
|
|
"Bound commands: help, invoke",
|
|
.handler = app_driver_bound_console_handler,
|
|
};
|
|
esp_matter::console::add_commands(&bound_command, 1);
|
|
|
|
/* Add console command for client to control non-bound devices */
|
|
static const esp_matter::console::command_t client_command = {
|
|
.name = "client",
|
|
.description = "This can be used to simulate on-device control for client devices."
|
|
"Usage: matter esp client <client_command>. "
|
|
"Client commands: help, invoke",
|
|
.handler = app_driver_client_console_handler,
|
|
};
|
|
esp_matter::console::add_commands(&client_command, 1);
|
|
}
|
|
#endif // CONFIG_ENABLE_CHIP_SHELL
|
|
|
|
void app_driver_client_command_callback(client::peer_device_t *peer_device, client::command_handle_t *cmd_handle,
|
|
void *priv_data)
|
|
{
|
|
// on_off light switch should support on_off cluster and identify cluster commands sending.
|
|
if (cmd_handle->cluster_id == OnOff::Id) {
|
|
switch (cmd_handle->command_id) {
|
|
case OnOff::Commands::Off::Id: {
|
|
on_off::command::send_off(peer_device, cmd_handle->endpoint_id);
|
|
break;
|
|
};
|
|
case OnOff::Commands::On::Id: {
|
|
on_off::command::send_on(peer_device, cmd_handle->endpoint_id);
|
|
break;
|
|
};
|
|
case OnOff::Commands::Toggle::Id: {
|
|
on_off::command::send_toggle(peer_device, cmd_handle->endpoint_id);
|
|
break;
|
|
};
|
|
default:
|
|
break;
|
|
}
|
|
} else if (cmd_handle->cluster_id == Identify::Id) {
|
|
if (cmd_handle->command_id == Identify::Commands::Identify::Id) {
|
|
if (((char *)cmd_handle->command_data)[0] != 1) {
|
|
ESP_LOGE(TAG, "Number of parameters error");
|
|
return;
|
|
}
|
|
identify::command::send_identify(peer_device, cmd_handle->endpoint_id,
|
|
strtoul((const char *)(cmd_handle->command_data) + 1, NULL, 16));
|
|
} else {
|
|
ESP_LOGE(TAG, "Unsupported command");
|
|
}
|
|
} else {
|
|
ESP_LOGE(TAG, "Unsupported cluster");
|
|
}
|
|
}
|
|
|
|
void app_driver_client_group_command_callback(uint8_t fabric_index, client::command_handle_t *cmd_handle,
|
|
void *priv_data)
|
|
{
|
|
// on_off light switch should support on_off cluster and identify cluster commands sending.
|
|
if (cmd_handle->cluster_id == OnOff::Id) {
|
|
switch (cmd_handle->command_id) {
|
|
case OnOff::Commands::Off::Id: {
|
|
on_off::command::group_send_off(fabric_index, cmd_handle->group_id);
|
|
break;
|
|
}
|
|
case OnOff::Commands::On::Id: {
|
|
on_off::command::group_send_on(fabric_index, cmd_handle->group_id);
|
|
break;
|
|
}
|
|
case OnOff::Commands::Toggle::Id: {
|
|
on_off::command::group_send_toggle(fabric_index, cmd_handle->group_id);
|
|
break;
|
|
}
|
|
default:
|
|
break;
|
|
}
|
|
} else if (cmd_handle->cluster_id == Identify::Id) {
|
|
if (cmd_handle->command_id == Identify::Commands::Identify::Id) {
|
|
if (((char *)cmd_handle->command_data)[0] != 1) {
|
|
ESP_LOGE(TAG, "Number of parameters error");
|
|
return;
|
|
}
|
|
identify::command::group_send_identify(fabric_index, cmd_handle->group_id,
|
|
strtoul((const char *)(cmd_handle->command_data) + 1, NULL, 16));
|
|
} else {
|
|
ESP_LOGE(TAG, "Unsupported command");
|
|
}
|
|
} else {
|
|
ESP_LOGE(TAG, "Unsupported cluster");
|
|
}
|
|
}
|
|
|
|
static void app_driver_button_toggle_cb(void *arg, void *data)
|
|
{
|
|
ESP_LOGI(TAG, "Toggle button pressed");
|
|
client::command_handle_t cmd_handle;
|
|
cmd_handle.cluster_id = OnOff::Id;
|
|
cmd_handle.command_id = OnOff::Commands::Toggle::Id;
|
|
|
|
lock::chip_stack_lock(portMAX_DELAY);
|
|
client::cluster_update(switch_endpoint_id, &cmd_handle);
|
|
lock::chip_stack_unlock();
|
|
}
|
|
|
|
app_driver_handle_t app_driver_switch_init()
|
|
{
|
|
/* Initialize button */
|
|
|
|
button_handle_t btns[BSP_BUTTON_NUM];
|
|
ESP_ERROR_CHECK(bsp_iot_button_create(btns, NULL, BSP_BUTTON_NUM));
|
|
ESP_ERROR_CHECK(iot_button_register_cb(btns[0], BUTTON_PRESS_DOWN, app_driver_button_toggle_cb, NULL));
|
|
|
|
/* Other initializations */
|
|
#if CONFIG_ENABLE_CHIP_SHELL
|
|
app_driver_register_commands();
|
|
#endif // CONFIG_ENABLE_CHIP_SHELL
|
|
client::set_command_callback(app_driver_client_command_callback, app_driver_client_group_command_callback, NULL);
|
|
|
|
return (app_driver_handle_t)btns[0];
|
|
}
|