mirror of
https://github.com/espressif/esp-matter.git
synced 2026-04-27 19:13:13 +00:00
337 lines
15 KiB
C++
337 lines
15 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_matter_attribute_utils.h"
|
|
#include "esp_rmaker_user_mapping.h"
|
|
#include <esp_err.h>
|
|
#include <esp_log.h>
|
|
#include <nvs_flash.h>
|
|
|
|
#include <esp_matter.h>
|
|
#include <esp_matter_console.h>
|
|
#include <esp_matter_ota.h>
|
|
|
|
#include <esp_rmaker_console.h>
|
|
#include <esp_rmaker_core.h>
|
|
#include <esp_rmaker_scenes.h>
|
|
#include <esp_rmaker_schedule.h>
|
|
#include <esp_rmaker_standard_devices.h>
|
|
#include <esp_rmaker_standard_params.h>
|
|
|
|
#include <app_priv.h>
|
|
#include <app_reset.h>
|
|
#include <app_wifi.h>
|
|
#include <common_macros.h>
|
|
#include "app-common/zap-generated/ids/Attributes.h"
|
|
#include "app-common/zap-generated/ids/Clusters.h"
|
|
#include "platform/CHIPDeviceEvent.h"
|
|
#include "platform/PlatformManager.h"
|
|
#include "wifi_provisioning/manager.h"
|
|
#if CHIP_DEVICE_CONFIG_ENABLE_THREAD
|
|
#include <platform/ESP32/OpenthreadLauncher.h>
|
|
#endif
|
|
#if CHIP_DEVICE_CONFIG_ENABLE_WIFI
|
|
#include <platform/ESP32/ESP32Utils.h>
|
|
#endif
|
|
|
|
#include <app/server/CommissioningWindowManager.h>
|
|
#include <app/server/Server.h>
|
|
#include <wifi_prov_scheme/protocomm_matter_ble.h>
|
|
|
|
static const char *TAG = "app_main";
|
|
uint16_t light_endpoint_id = 0;
|
|
|
|
using namespace esp_matter;
|
|
using namespace esp_matter::attribute;
|
|
using namespace esp_matter::endpoint;
|
|
using namespace chip::app::Clusters;
|
|
|
|
constexpr auto k_timeout_seconds = 300;
|
|
|
|
#if CONFIG_ENABLE_ENCRYPTED_OTA
|
|
extern const char decryption_key_start[] asm("_binary_esp_image_encryption_key_pem_start");
|
|
extern const char decryption_key_end[] asm("_binary_esp_image_encryption_key_pem_end");
|
|
|
|
static const char *s_decryption_key = decryption_key_start;
|
|
static const uint16_t s_decryption_key_len = decryption_key_end - decryption_key_start;
|
|
#endif // CONFIG_ENABLE_ENCRYPTED_OTA
|
|
|
|
static esp_rmaker_device_t *light_device;
|
|
|
|
static void app_event_cb(const ChipDeviceEvent *event, intptr_t arg)
|
|
{
|
|
if (!event) {
|
|
return;
|
|
}
|
|
switch (event->Type) {
|
|
case chip::DeviceLayer::DeviceEventType::kInterfaceIpAddressChanged:
|
|
ESP_LOGI(TAG, "Interface IP Address changed");
|
|
break;
|
|
|
|
case chip::DeviceLayer::DeviceEventType::kCommissioningComplete:
|
|
ESP_LOGI(TAG, "Commissioning complete");
|
|
break;
|
|
|
|
case chip::DeviceLayer::DeviceEventType::kFailSafeTimerExpired:
|
|
ESP_LOGI(TAG, "Commissioning failed, fail safe timer expired");
|
|
break;
|
|
|
|
case chip::DeviceLayer::DeviceEventType::kCommissioningSessionStarted:
|
|
ESP_LOGI(TAG, "Commissioning session started");
|
|
break;
|
|
|
|
case chip::DeviceLayer::DeviceEventType::kCommissioningSessionStopped:
|
|
ESP_LOGI(TAG, "Commissioning session stopped");
|
|
break;
|
|
|
|
case chip::DeviceLayer::DeviceEventType::kCommissioningWindowOpened:
|
|
ESP_LOGI(TAG, "Commissioning window opened");
|
|
break;
|
|
|
|
case chip::DeviceLayer::DeviceEventType::kCommissioningWindowClosed:
|
|
ESP_LOGI(TAG, "Commissioning window closed");
|
|
break;
|
|
|
|
case chip::DeviceLayer::DeviceEventType::kFabricRemoved: {
|
|
ESP_LOGI(TAG, "Fabric removed successfully");
|
|
if (chip::Server::GetInstance().GetFabricTable().FabricCount() == 0) {
|
|
chip::CommissioningWindowManager &commissionMgr =
|
|
chip::Server::GetInstance().GetCommissioningWindowManager();
|
|
constexpr auto kTimeoutSeconds = chip::System::Clock::Seconds16(k_timeout_seconds);
|
|
if (!commissionMgr.IsCommissioningWindowOpen()) {
|
|
/* After removing last fabric, this example does not remove the Wi-Fi credentials
|
|
* and still has IP connectivity so, only advertising on DNS-SD.
|
|
*/
|
|
CHIP_ERROR err = commissionMgr.OpenBasicCommissioningWindow(
|
|
kTimeoutSeconds, chip::CommissioningWindowAdvertisement::kDnssdOnly);
|
|
if (err != CHIP_NO_ERROR) {
|
|
ESP_LOGE(TAG, "Failed to open commissioning window, err:%" CHIP_ERROR_FORMAT, err.Format());
|
|
}
|
|
}
|
|
}
|
|
break;
|
|
}
|
|
|
|
case chip::DeviceLayer::DeviceEventType::kFabricWillBeRemoved:
|
|
ESP_LOGI(TAG, "Fabric will be removed");
|
|
break;
|
|
|
|
case chip::DeviceLayer::DeviceEventType::kFabricUpdated:
|
|
ESP_LOGI(TAG, "Fabric is updated");
|
|
break;
|
|
|
|
case chip::DeviceLayer::DeviceEventType::kFabricCommitted:
|
|
ESP_LOGI(TAG, "Fabric is committed");
|
|
break;
|
|
|
|
case chip::DeviceLayer::DeviceEventType::kBLEDeinitialized:
|
|
ESP_LOGI(TAG, "BLE deinitialized and memory reclaimed");
|
|
break;
|
|
|
|
case chip::DeviceLayer::DeviceEventType::kCHIPoBLEAdvertisingChange:
|
|
if (event->CHIPoBLEAdvertisingChange.Result == chip::DeviceLayer::kActivity_Started) {
|
|
start_secondary_ble_adv();
|
|
}
|
|
|
|
default:
|
|
break;
|
|
}
|
|
}
|
|
|
|
static esp_err_t bulk_write_cb(const esp_rmaker_device_t *device, const esp_rmaker_param_write_req_t write_req[],
|
|
uint8_t count, void *priv_data, esp_rmaker_write_ctx_t *ctx)
|
|
{
|
|
if (ctx) {
|
|
ESP_LOGI(TAG, "Received write request via : %s", esp_rmaker_device_cb_src_to_str(ctx->src));
|
|
}
|
|
ESP_LOGI(TAG, "Light received %d params in write", count);
|
|
app_driver_handle_t light_handle = (app_driver_handle_t)priv_data;
|
|
esp_matter_attr_val_t matter_val;
|
|
for (int i = 0; i < count; i++) {
|
|
const esp_rmaker_param_t *param = write_req[i].param;
|
|
esp_rmaker_param_val_t val = write_req[i].val;
|
|
const char *device_name = esp_rmaker_device_get_name(device);
|
|
const char *param_name = esp_rmaker_param_get_name(param);
|
|
if (strcmp(param_name, ESP_RMAKER_DEF_POWER_NAME) == 0) {
|
|
ESP_LOGI(TAG, "Received value = %s for %s - %s", val.val.b ? "true" : "false", device_name, param_name);
|
|
matter_val.type = ESP_MATTER_VAL_TYPE_BOOLEAN;
|
|
matter_val.val.b = val.val.b;
|
|
app_driver_attribute_update(light_handle, light_endpoint_id, OnOff::Id, OnOff::Attributes::OnOff::Id,
|
|
&matter_val);
|
|
} else if (strcmp(param_name, ESP_RMAKER_DEF_BRIGHTNESS_NAME) == 0) {
|
|
ESP_LOGI(TAG, "Received value = %d for %s - %s", val.val.i, device_name, param_name);
|
|
matter_val.type = ESP_MATTER_VAL_TYPE_UINT8;
|
|
matter_val.val.u8 = (uint8_t)(val.val.i * 254 / 100);
|
|
app_driver_attribute_update(light_handle, light_endpoint_id, LevelControl::Id,
|
|
LevelControl::Attributes::CurrentLevel::Id, &matter_val);
|
|
} else if (strcmp(param_name, ESP_RMAKER_DEF_HUE_NAME) == 0) {
|
|
ESP_LOGI(TAG, "Received value = %d for %s - %s", val.val.i, device_name, param_name);
|
|
matter_val.type = ESP_MATTER_VAL_TYPE_UINT16;
|
|
matter_val.val.u16 = (uint16_t)(val.val.i * 254 / 360);
|
|
app_driver_attribute_update(light_handle, light_endpoint_id, ColorControl::Id,
|
|
ColorControl::Attributes::CurrentHue::Id, &matter_val);
|
|
} else if (strcmp(param_name, ESP_RMAKER_DEF_SATURATION_NAME) == 0) {
|
|
ESP_LOGI(TAG, "Received value = %d for %s - %s", val.val.i, device_name, param_name);
|
|
matter_val.type = ESP_MATTER_VAL_TYPE_UINT16;
|
|
matter_val.val.u16 = (uint16_t)(val.val.i * 254 / 100);
|
|
app_driver_attribute_update(light_handle, light_endpoint_id, ColorControl::Id,
|
|
ColorControl::Attributes::CurrentSaturation::Id, &matter_val);
|
|
} else {
|
|
ESP_LOGI(TAG, "Updating for %s", param_name);
|
|
}
|
|
esp_rmaker_param_update(param, val);
|
|
}
|
|
return ESP_OK;
|
|
}
|
|
|
|
// This callback is invoked when clients interact with the Identify Cluster.
|
|
// In the callback implementation, an endpoint can identify itself. (e.g., by flashing an LED or light).
|
|
static esp_err_t app_identification_cb(identification::callback_type_t type, uint16_t endpoint_id, uint8_t effect_id,
|
|
uint8_t effect_variant, void *priv_data)
|
|
{
|
|
ESP_LOGI(TAG, "Identification callback: type: %u, effect: %u, variant: %u", type, effect_id, effect_variant);
|
|
return ESP_OK;
|
|
}
|
|
|
|
// This callback is called for every attribute update. The callback implementation shall
|
|
// handle the desired attributes and return an appropriate error code. If the attribute
|
|
// is not of your interest, please do not return an error code and strictly return ESP_OK.
|
|
static esp_err_t app_attribute_update_cb(attribute::callback_type_t type, uint16_t endpoint_id, uint32_t cluster_id,
|
|
uint32_t attribute_id, esp_matter_attr_val_t *val, void *priv_data)
|
|
{
|
|
esp_err_t err = ESP_OK;
|
|
|
|
if (type == PRE_UPDATE) {
|
|
/* Driver update */
|
|
app_driver_handle_t driver_handle = (app_driver_handle_t)priv_data;
|
|
err = app_driver_attribute_update(driver_handle, endpoint_id, cluster_id, attribute_id, val);
|
|
}
|
|
|
|
return err;
|
|
}
|
|
|
|
extern "C" void app_main()
|
|
{
|
|
esp_err_t err = ESP_OK;
|
|
|
|
/* Initialize the ESP NVS layer */
|
|
nvs_flash_init();
|
|
|
|
/* Initialize driver */
|
|
app_driver_handle_t light_handle = app_driver_light_init();
|
|
app_driver_button_init();
|
|
|
|
/* Create a Matter node and add the mandatory Root Node device type on endpoint 0 */
|
|
node::config_t node_config;
|
|
|
|
// node handle can be used to add/modify other endpoints.
|
|
node_t *node = node::create(&node_config, app_attribute_update_cb, app_identification_cb);
|
|
ABORT_APP_ON_FAILURE(node != nullptr, ESP_LOGE(TAG, "Failed to create Matter node"));
|
|
|
|
extended_color_light::config_t light_config;
|
|
light_config.on_off.on_off = DEFAULT_POWER;
|
|
light_config.on_off.features.lighting.start_up_on_off = nullptr;
|
|
light_config.level_control.current_level = DEFAULT_BRIGHTNESS;
|
|
light_config.level_control.on_level = DEFAULT_BRIGHTNESS;
|
|
light_config.level_control.features.lighting.start_up_current_level = DEFAULT_BRIGHTNESS;
|
|
light_config.color_control.color_mode = (uint8_t)ColorControl::ColorMode::kColorTemperature;
|
|
light_config.color_control.enhanced_color_mode = (uint8_t)ColorControl::ColorMode::kColorTemperature;
|
|
light_config.color_control.features.color_temperature.startup_color_temperature_mireds = nullptr;
|
|
|
|
light_config.on_off.feature_flags = cluster::on_off::feature::lighting::get_id();
|
|
light_config.level_control.feature_flags = cluster::level_control::feature::lighting::get_id();
|
|
light_config.color_control.feature_flags = cluster::color_control::feature::color_temperature::get_id();
|
|
|
|
// endpoint handles can be used to add/modify clusters.
|
|
endpoint_t *endpoint = extended_color_light::create(node, &light_config, ENDPOINT_FLAG_NONE, light_handle);
|
|
ABORT_APP_ON_FAILURE(endpoint != nullptr, ESP_LOGE(TAG, "Failed to create extended color light endpoint"));
|
|
|
|
light_endpoint_id = endpoint::get_id(endpoint);
|
|
ESP_LOGI(TAG, "Light created with endpoint_id %d", light_endpoint_id);
|
|
|
|
/* Mark deferred persistence for some attributes that might be changed rapidly */
|
|
attribute_t *current_level_attribute =
|
|
attribute::get(light_endpoint_id, LevelControl::Id, LevelControl::Attributes::CurrentLevel::Id);
|
|
attribute::set_deferred_persistence(current_level_attribute);
|
|
|
|
attribute_t *current_x_attribute = attribute::get(light_endpoint_id, ColorControl::Id, ColorControl::Attributes::CurrentX::Id);
|
|
attribute::set_deferred_persistence(current_x_attribute);
|
|
attribute_t *current_y_attribute = attribute::get(light_endpoint_id, ColorControl::Id, ColorControl::Attributes::CurrentY::Id);
|
|
attribute::set_deferred_persistence(current_y_attribute);
|
|
attribute_t *color_temp_attribute =
|
|
attribute::get(light_endpoint_id, ColorControl::Id, ColorControl::Attributes::ColorTemperatureMireds::Id);
|
|
attribute::set_deferred_persistence(color_temp_attribute);
|
|
|
|
err = esp_event_loop_create_default();
|
|
|
|
if (err != ESP_OK) {
|
|
ESP_LOGE(TAG, "Error create default event loop");
|
|
return;
|
|
}
|
|
app_wifi_init();
|
|
esp_rmaker_config_t rainmaker_cfg = {
|
|
.enable_time_sync = false,
|
|
};
|
|
esp_rmaker_node_t *rmaker_node = esp_rmaker_node_init(&rainmaker_cfg, "ESP RainMaker Device", "Lightbulb");
|
|
if (!rmaker_node) {
|
|
ESP_LOGE(TAG, "Could not initialise node. Aborting!!!");
|
|
vTaskDelay(5000 / portTICK_PERIOD_MS);
|
|
abort();
|
|
}
|
|
|
|
light_device = esp_rmaker_lightbulb_device_create("Light", light_handle, DEFAULT_POWER);
|
|
esp_rmaker_device_add_bulk_cb(light_device, bulk_write_cb, NULL);
|
|
|
|
esp_rmaker_device_add_param(light_device,
|
|
esp_rmaker_brightness_param_create(ESP_RMAKER_DEF_BRIGHTNESS_NAME, DEFAULT_BRIGHTNESS));
|
|
esp_rmaker_device_add_param(light_device, esp_rmaker_hue_param_create(ESP_RMAKER_DEF_HUE_NAME, DEFAULT_HUE));
|
|
esp_rmaker_device_add_param(light_device,
|
|
esp_rmaker_saturation_param_create(ESP_RMAKER_DEF_SATURATION_NAME, DEFAULT_SATURATION));
|
|
|
|
esp_rmaker_node_add_device(rmaker_node, light_device);
|
|
|
|
esp_rmaker_ota_enable_default();
|
|
|
|
esp_rmaker_timezone_service_enable();
|
|
|
|
esp_rmaker_schedule_enable();
|
|
|
|
err = app_wifi_set_custom_mfg_data(MGF_DATA_DEVICE_TYPE_LIGHT, MFG_DATA_DEVICE_SUBTYPE_LIGHT);
|
|
|
|
err = app_wifi_start(POP_TYPE_MAC);
|
|
if (err != ESP_OK) {
|
|
ESP_LOGE(TAG, "Could not start Wifi. Aborting!!!");
|
|
abort();
|
|
}
|
|
|
|
/* Matter start */
|
|
err = esp_matter::start(app_event_cb);
|
|
ABORT_APP_ON_FAILURE(err == ESP_OK, ESP_LOGE(TAG, "Failed to start Matter, err:%d", err));
|
|
|
|
/* Starting driver with default values */
|
|
app_driver_light_set_defaults(light_endpoint_id);
|
|
|
|
#if CONFIG_ENABLE_ENCRYPTED_OTA
|
|
err = esp_matter_ota_requestor_encrypted_init(s_decryption_key, s_decryption_key_len);
|
|
ABORT_APP_ON_FAILURE(err == ESP_OK, ESP_LOGE(TAG, "Failed to initialized the encrypted OTA, err: %d", err));
|
|
#endif // CONFIG_ENABLE_ENCRYPTED_OTA
|
|
// If Wi-Fi is provisioned and RainMaker user node mapping is done, deinitialize the BLE.
|
|
bool is_wifi_provisioned = false;
|
|
wifi_prov_mgr_is_provisioned(&is_wifi_provisioned);
|
|
if (is_wifi_provisioned && esp_rmaker_user_node_mapping_get_state() == ESP_RMAKER_USER_MAPPING_DONE) {
|
|
chip::DeviceLayer::PlatformMgr().ScheduleWork([](intptr_t){ chip::DeviceLayer::Internal::BLEMgr().Shutdown(); });
|
|
}
|
|
|
|
#if CONFIG_ENABLE_CHIP_SHELL
|
|
esp_matter::console::diagnostics_register_commands();
|
|
esp_matter::console::wifi_register_commands();
|
|
esp_matter::console::factoryreset_register_commands();
|
|
esp_matter::console::init();
|
|
#endif
|
|
}
|