meshx_gen_server.c

Go to the documentation of this file.

#include "stdlib.h"
#include "meshx_gen_server.h"
 
#if CONFIG_ENABLE_GEN_SERVER
#define MESHX_SERVER_INIT_MAGIC_NO 0x1121
static uint16_t meshx_server_init = 0;

meshx_err_t meshx_is_status_in_gen_srv_grp(uint16_t opcode)
{
    switch(opcode)
    {
        case MESHX_MODEL_OP_GEN_ONOFF_STATUS:
        case MESHX_MODEL_OP_GEN_LEVEL_STATUS:
        case MESHX_MODEL_OP_GEN_DEF_TRANS_TIME_STATUS:
        case MESHX_MODEL_OP_GEN_ONPOWERUP_STATUS:
        case MESHX_MODEL_OP_GEN_POWER_LEVEL_STATUS:
        case MESHX_MODEL_OP_GEN_POWER_LAST_STATUS:
        case MESHX_MODEL_OP_GEN_POWER_DEFAULT_STATUS:
        case MESHX_MODEL_OP_GEN_POWER_RANGE_STATUS:
        case MESHX_MODEL_OP_GEN_BATTERY_STATUS:
        case MESHX_MODEL_OP_GEN_LOC_GLOBAL_STATUS:
        case MESHX_MODEL_OP_GEN_LOC_LOCAL_STATUS:
        case MESHX_MODEL_OP_GEN_MANUFACTURER_PROPERTIES_STATUS:
        case MESHX_MODEL_OP_GEN_MANUFACTURER_PROPERTY_STATUS:
            return MESHX_SUCCESS;
        default:
            return MESHX_FAIL;
    }
}

meshx_err_t meshx_gen_srv_status_send(
    meshx_model_t *p_model,
    meshx_ctx_t *p_ctx,
    meshx_gen_srv_state_change_t state_change,
    size_t data_len)
{
    if (!p_model || !p_ctx || p_ctx->dst_addr == MESHX_ADDR_UNASSIGNED)
        return MESHX_INVALID_ARG;
    if (meshx_is_status_in_gen_srv_grp((uint16_t)p_ctx->opcode) != MESHX_SUCCESS)
        return MESHX_INVALID_ARG;
 
    return meshx_plat_gen_srv_send_status(
        p_model,
        p_ctx,
        &state_change,
        data_len
    );
}

meshx_err_t meshx_gen_srv_send_msg_to_ble(
    control_task_msg_evt_to_ble_t evt,
    const meshx_gen_srv_cb_param_t *params)
{
    if(MESHX_SUCCESS != meshx_is_status_in_gen_srv_grp(
        (uint16_t)(params->ctx.opcode)))
    {
        return MESHX_INVALID_ARG;
    }
 
    return control_task_msg_publish(CONTROL_TASK_MSG_CODE_TO_BLE,
                                    evt,
                                    params,
                                    sizeof(meshx_gen_srv_cb_param_t));
}

meshx_err_t meshx_gen_srv_reg_cb(uint32_t model_id, meshx_server_cb cb)
{
    return control_task_msg_subscribe(
        CONTROL_TASK_MSG_CODE_FRM_BLE,
        model_id,
        (control_task_msg_handle_t)cb);
}

meshx_err_t meshx_gen_srv_dereg_cb(uint32_t model_id, meshx_server_cb cb)
{
    return control_task_msg_unsubscribe(
        CONTROL_TASK_MSG_CODE_FRM_BLE,
        model_id,
        (control_task_msg_handle_t)cb);
}

meshx_err_t meshx_gen_srv_init(void)
{
    if (meshx_server_init == MESHX_SERVER_INIT_MAGIC_NO)
        return MESHX_SUCCESS;
    meshx_server_init = MESHX_SERVER_INIT_MAGIC_NO;
 
    return meshx_plat_gen_srv_init();
}
 
#endif /* CONFIG_ENABLE_GEN_SERVER */