esp_gen_cli_model.c

Go to the documentation of this file.

/*****************************************************************************************************************
 * INCLUDES
 ****************************************************************************************************************/
#include "meshx_control_task.h"
#include "interface/ble_mesh/client/meshx_ble_mesh_gen_cli.h"
 
/*****************************************************************************************************************
 * DEFINES
 ****************************************************************************************************************/
#define MESHX_CLIENT_INIT_MAGIC_NO 0x8709 // Magic number to indicate initialization state
 
/*****************************************************************************************************************
 * STATIC VARIABLES
 ****************************************************************************************************************/
static uint16_t meshx_client_init = 0; // Magic number to indicate initialization state

static const char *client_state_str[] =
{
    [ESP_BLE_MESH_GENERIC_CLIENT_PUBLISH_EVT] = "PUBLISH_EVT",
    [ESP_BLE_MESH_GENERIC_CLIENT_TIMEOUT_EVT] = "TIMEOUT_EVT",
    [ESP_BLE_MESH_GENERIC_CLIENT_GET_STATE_EVT] = "GET_STATE_EVT",
    [ESP_BLE_MESH_GENERIC_CLIENT_SET_STATE_EVT] = "SET_STATE_EVT",
};
 
/*****************************************************************************************************************
 * STATIC FUNCTION PROTOTYPES
 ****************************************************************************************************************/
static void esp_ble_mesh_generic_client_cb(MESHX_GEN_CLI_CB_EVT event, MESHX_GEN_CLI_CB_PARAM *param);
/*****************************************************************************************************************
 * STATIC FUNCTION DEFINITIONS
 ****************************************************************************************************************/

 
static void esp_ble_mesh_generic_client_cb(MESHX_GEN_CLI_CB_EVT event,
                                           MESHX_GEN_CLI_CB_PARAM *param)
{
    MESHX_UNUSED(client_state_str);
    MESHX_LOGD(MODULE_ID_MODEL_CLIENT, "%s, err|op|src|dst: %d|%04" PRIx32 "|%04x|%04x",
               client_state_str[event], param->error_code,
               param->params->ctx.recv_op, param->params->ctx.addr, param->params->ctx.recv_dst);
 
    meshx_gen_cli_cb_param_t pub_param = {
        .ctx = {
            .net_idx    = param->params->ctx.net_idx,
            .app_idx    = param->params->ctx.app_idx,
            .dst_addr   = param->params->ctx.recv_dst,
            .src_addr   = param->params->ctx.addr,
            .opcode     = param->params->ctx.recv_op,
            .p_ctx      = &param->params->ctx
        },
        .model = {
            .pub_addr   = param->params->model->pub->publish_addr,
            .model_id   = param->params->model->model_id,
            .el_id      = param->params->model->element_idx,
            .p_model    = param->params->model
        },
        .evt = MESHX_BIT(event),
        .err_code = param->error_code,
    };
 
    /* Copy the msg data from BLE Layer to MeshX Layer */
    memcpy(&pub_param.status, &param->status_cb, sizeof(meshx_gen_client_status_cb_t));
 
    meshx_err_t err = control_task_msg_publish(
        CONTROL_TASK_MSG_CODE_FRM_BLE,
        pub_param.model.model_id,
        &pub_param,
        sizeof(meshx_gen_cli_cb_param_t));
    if (err)
    {
        MESHX_LOGE(MODULE_ID_MODEL_CLIENT, "Failed to publish to control task");
    }
}
 
/*****************************************************************************************************************
 * INTERFACE FUNCTION DEFINITIONS
 ****************************************************************************************************************/
meshx_err_t meshx_plat_gen_cli_init(void)
{
 
    meshx_err_t err = MESHX_SUCCESS;
    if (meshx_client_init == MESHX_CLIENT_INIT_MAGIC_NO)
    {
        return MESHX_SUCCESS; // Already initialized
    }
    meshx_client_init = MESHX_CLIENT_INIT_MAGIC_NO;
 
    // Register the callback for handling messages sent to the BLE layer
    esp_err_t esp_err = esp_ble_mesh_register_generic_client_callback(
        (MESHX_GEN_CLI_CB)&esp_ble_mesh_generic_client_cb);
    if (esp_err != ESP_OK)
        err = MESHX_ERR_PLAT;
 
    return err;
}

meshx_err_t meshx_plat_on_off_gen_cli_create(meshx_ptr_t p_model, meshx_ptr_t* p_pub, meshx_ptr_t* p_onoff_cli)
{
    if (!p_model || !p_pub || !p_onoff_cli)
    {
        return MESHX_INVALID_ARG; // Invalid arguments
    }
    /* SIG On OFF Init */
    uint16_t model_id = ESP_BLE_MESH_MODEL_ID_GEN_ONOFF_CLI;
    memcpy((meshx_ptr_t)&(((MESHX_MODEL *)p_model)->model_id), &model_id, sizeof(model_id));
 
    return meshx_plat_client_create(p_model, p_pub, p_onoff_cli);
}

meshx_err_t meshx_plat_gen_cli_delete(meshx_ptr_t* p_pub, meshx_ptr_t* p_cli)
{
    if (p_cli)
    {
        MESHX_FREE(*p_cli);
        *p_cli = NULL;
    }
 
    return meshx_plat_del_model_pub(p_pub);
}

meshx_err_t meshx_plat_gen_cli_send_msg(
    meshx_ptr_t p_model, meshx_gen_cli_set_t *p_set,
    uint16_t opcode, uint16_t addr,
    uint16_t net_idx, uint16_t app_idx,
    bool is_get_opcode
)
{
    if (!p_model || !p_set)
    {
        return MESHX_INVALID_ARG; // Invalid arguments
    }
 
    esp_ble_mesh_client_common_param_t common = {0};
    common.model        = p_model;
    common.opcode       = opcode;
    common.ctx.addr     = addr;
    common.ctx.net_idx  = net_idx;
    common.ctx.app_idx  = app_idx;
    common.ctx.send_ttl = BLE_MESH_TTL_DEFAULT;
    common.msg_timeout  = 0; /* 0 indicates that timeout value from menuconfig will be used */
 
    esp_err_t err = ESP_OK;
    if(!is_get_opcode)
    {
        p_set->onoff_set.trans_time = 0;
        if(!(p_set->onoff_set.onoff == 0 || p_set->onoff_set.onoff == 1))
        {
            MESHX_LOGE(MODULE_ID_MODEL_CLIENT, "Invalid OnOff value %d", p_set->onoff_set.onoff);
            return MESHX_INVALID_ARG;
        }
        err = esp_ble_mesh_generic_client_set_state(
            &common,
            (esp_ble_mesh_generic_client_set_state_t *)p_set
        );
        if (err != ESP_OK)
        {
            MESHX_LOGE(MODULE_ID_MODEL_CLIENT, "Send Generic OnOff failed: %d", err);
            return MESHX_FAIL;
        }
    }
    else
    {
        err = esp_ble_mesh_generic_client_get_state(
            &common,
            (esp_ble_mesh_generic_client_get_state_t *)p_set
        );
        if (err != ESP_OK)
        {
            MESHX_LOGE(MODULE_ID_MODEL_CLIENT, "Send Generic OnOff Get failed: %d", err);
            return MESHX_FAIL;
        }
    }
    if (!err)
    {
        MESHX_LOGD(MODULE_ID_MODEL_CLIENT, "Client Send Success");
    }
 
    return MESHX_SUCCESS;
}