diff options
Diffstat (limited to 'Projects/P-NUCLEO-WB55.Nucleo/Applications/BLE/BLE_MeshLightingProvisioner/STM32_WPAN/app/models_if.c')
| -rw-r--r-- | Projects/P-NUCLEO-WB55.Nucleo/Applications/BLE/BLE_MeshLightingProvisioner/STM32_WPAN/app/models_if.c | 627 |
1 files changed, 627 insertions, 0 deletions
diff --git a/Projects/P-NUCLEO-WB55.Nucleo/Applications/BLE/BLE_MeshLightingProvisioner/STM32_WPAN/app/models_if.c b/Projects/P-NUCLEO-WB55.Nucleo/Applications/BLE/BLE_MeshLightingProvisioner/STM32_WPAN/app/models_if.c new file mode 100644 index 000000000..f82f3b293 --- /dev/null +++ b/Projects/P-NUCLEO-WB55.Nucleo/Applications/BLE/BLE_MeshLightingProvisioner/STM32_WPAN/app/models_if.c @@ -0,0 +1,627 @@ +/** + ****************************************************************************** + * @file models_if.c + * @author BLE Mesh Team + * @brief Mesh Modes interface file of the application + ****************************************************************************** + * @attention + * + * <h2><center>© Copyright (c) 2019 STMicroelectronics. + * All rights reserved.</center></h2> + * + * This software component is licensed by ST under Ultimate Liberty license + * SLA0044, the "License"; You may not use this file except in compliance with + * the License. You may obtain a copy of the License at: + * www.st.com/SLA0044 + * + ****************************************************************************** + */ + +/* Includes ------------------------------------------------------------------*/ +#include "hal_common.h" +#include "appli_mesh.h" +#include "vendor.h" +#include "light.h" +#include "sensors.h" +#include "generic.h" +#include "time_scene.h" +#include "common.h" +#include "appli_generic.h" +#include "appli_vendor.h" +#include "appli_light.h" +#include "appli_sensor.h" +#include "appli_nvm.h" +#include "ble_hci_le.h" +#include "models_if.h" + +#include "PWM_config.h" +#include "PWM_handlers.h" +#include "appli_light_lc.h" +#include "light_lc.h" +#include "appli_generic_client.h" +#include "config_client.h" +#include "generic_client.h" +#include "appli_light_client.h" + +/** @addtogroup ST_BLE_Mesh +* @{ +*/ + +/** @addtogroup Application_Mesh_Models +* @{ +*/ + +/* Private typedef -----------------------------------------------------------*/ +#pragma pack(1) +typedef struct +{ + MOBLE_ADDRESS peer; + MOBLE_ADDRESS dst; + MOBLEUINT8 command; + MOBLEUINT8 data[DATA_BUFFER_LENGTH]; /* 8-Bytes response packet */ + MOBLEUINT32 length; +} APPLI_SEND_RESPONSE_MODULE; + +typedef struct +{ + MOBLEUINT8 packet_count; + MOBLEUINT32 send_time; + APPLI_SEND_RESPONSE_MODULE* head; + MOBLEUINT8 head_index; + APPLI_SEND_RESPONSE_MODULE packet[MAX_PENDING_PACKETS_QUE_SIZE]; +} APPLI_PENDING_PACKETS; +#pragma pack(4) + +/* Private define ------------------------------------------------------------*/ +/* Private macro -------------------------------------------------------------*/ + + +/* Private variables ---------------------------------------------------------*/ +APPLI_PENDING_PACKETS Appli_PendingPackets = {0}; + +__attribute__((aligned(4))) +const MOBLE_VENDOR_CB_MAP vendor_cb = +{ + Vendor_WriteLocalDataCb, + Vendor_ReadLocalDataCb, + Vendor_OnResponseDataCb +}; + +__attribute__((aligned(4))) +const Appli_Vendor_cb_t VendorAppli_cb = +{ + /*Vendor Commads*/ + Appli_Vendor_LEDControl, + Appli_Vendor_DeviceInfo, + Appli_Vendor_Test, + Appli_LedCtrl, + Appli_GetTestValue, + Appli_Vendor_Data_write +}; + +__attribute__((aligned(4))) +const Appli_Generic_cb_t GenericAppli_cb = +{ + /* Generic OnOff callbacks */ + Appli_Generic_OnOff_Set, + /* Generic OnOff Status callbacks */ + Appli_Generic_OnOff_Status, + /* Generic Level callbacks */ + Appli_Generic_Level_Set, + Appli_Generic_Delta_Set, + Appli_Generic_Move_Set, + /* Generic Level Status callbacks */ + Appli_Generic_Level_Status, + /* Generic Power on off callbacks */ + Appli_Generic_PowerOnOff_Set, + /* Generic Power on off callbacks */ + Appli_Generic_PowerOnOff_Status, + + /* Generic Default transition time callbacks */ + Appli_Generic_DefaultTransitionTime_Set, + /* Generic Default transition time callbacks */ + Appli_Generic_DefaultTransitionTime_Status +}; + +__attribute__((aligned(4))) +const Appli_Generic_State_cb_t Appli_GenericState_cb = +{ + + /* Generic Get On Off status */ + Appli_Generic_GetOnOffStatus, + Appli_Generic_GetOnOffValue, + /* Generic Get level status */ + Appli_Generic_GetLevelStatus, + /* Generic Get Power on off status */ + Appli_Generic_GetPowerOnOffStatus, + /* Generic Get Default transition time status */ + Appli_Generic_GetDefaultTransitionStatus +}; + +__attribute__((aligned(4))) +const Appli_Light_GetStatus_cb_t Appli_Light_GetStatus_cb = +{ + Appli_Light_GetLightnessStatus, + Appli_Light_GetLightnessLinearStatus, + Appli_Light_GetLightnessDefaultStatus, + Appli_Light_GetLightnessLastStatus, + Appli_Light_GetLightnessRangeStatus, + Appli_Light_GetCtlLightStatus, + Appli_Light_GetCtlTemperatureStatus, + Appli_Light_GetCtlTemperatureRange, + Appli_Light_GetCtlDefaultStatus, + Appli_Light_GetHslStatus, + Appli_Light_GetHslHueStatus, + Appli_Light_GetHslSaturationStatus, + Appli_Light_GetHslHueRange, + Appli_Light_GetHslSatRange, + Appli_Light_GetHslDefaultStatus +}; + + +__attribute__((aligned(4))) +const Appli_Light_cb_t LightAppli_cb = +{ + /* Light Lightness callbacks */ + Appli_Light_Lightness_Set, + Appli_Light_Lightness_Status, + + Appli_Light_Lightness_Linear_Set, + Appli_Light_Lightness_Linear_Status, + + Appli_Light_Lightness_Default_Set, + Appli_Light_Lightness_Default_Status, + + Appli_Light_Lightness_Range_Set, + Appli_Light_Lightness_Range_Status, + + Appli_Light_Ctl_Set, + Appli_Light_Ctl_Status, + + Appli_Light_CtlTemperature_Set, + Appli_Light_CtlTemperature_Status, + + Appli_Light_CtlTemperature_Range_Set, + Appli_Light_CtlTemperature_Range_Status, + + Appli_Light_CtlDefault_Set, + Appli_Light_CtlDefault_Status, + + Appli_Light_Hsl_Set, + Appli_Light_Hsl_Status, + + Appli_Light_HslHue_Set, + Appli_Light_HslHue_Status, + + Appli_Light_HslSaturation_Set, + Appli_Light_HslSaturation_Status, + + Appli_Light_HslDefault_Set, + Appli_Light_HslDefault_Status, + + Appli_Light_HslRange_Set, + Appli_Light_HslRange_Status +}; + + +__attribute__((aligned(4))) +const Appli_Light_Ctrl_cb_t LightLCAppli_cb = +{ + /* Light LC mode set callbacks */ + Appli_LightLC_Mode_Set, + Appli_LightLC_OM_Set, + Appli_LightLC_OnOff_Set, +}; + +__attribute__((aligned(4))) +const Appli_LightLC_GetStatus_cb_t Appli_LightLC_GetStatus_cb = +{ + Appli_LightLC_Get_ModeStatus, + Appli_LightLC_Get_OMModeStatus, + Appli_LightLC_Get_OnOffStatus, + Appli_LightLC_Get_AmbientLuxLevelOutput, + Appli_Light_LC_PIRegulatorOutput, +}; + +#ifdef ENABLE_SENSOR_MODEL_SERVER + +__attribute__((aligned(4))) +const Appli_Sensor_cb_t SensorAppli_cb = +{ + /* Sensor Model callbacks */ + Appli_Sensor_Cadence_Set, + Appli_Sensor_Data_Status, + Appli_Sensor_Descriptor_Status , + Appli_Sensor_Setting_Set +}; + +__attribute__((aligned(4))) +const Appli_Sensor_GetStatus_cb_t Appli_Sensor_GetStatus_cb = +{ + Appli_Sensor_GetSettingStatus, + Appli_Sensor_GetSetting_IDStatus +}; + +#endif + + +__attribute__((aligned(4))) +const MODEL_SIG_cb_t Model_SIG_cb[] = +{ +#ifdef ENABLE_GENERIC_MODEL_SERVER + { + GenericModelServer_GetOpcodeTableCb, + GenericModelServer_GetStatusRequestCb, + GenericModelServer_ProcessMessageCb + }, +#endif + +#ifdef ENABLE_LIGHT_MODEL_SERVER + { + LightModelServer_GetOpcodeTableCb, + LightModelServer_GetStatusRequestCb, + LightModelServer_ProcessMessageCb + }, +#endif +#ifdef ENABLE_SENSOR_MODEL_SERVER +{ + SensorModelServer_GetOpcodeTableCb, + SensorModelServer_GetStatusRequestCb, + SensorModelServer_ProcessMessageCb + }, +#endif +#ifdef ENABLE_TIME_SCENE_MODEL_SERVER + { + Time_SceneModelServer_GetOpcodeTableCb, + Time_SceneModelServer_GetStatusRequestCb, + Time_SceneModelServer_ProcessMessageCb + }, +#endif +#ifdef ENABLE_LIGHT_MODEL_SERVER_LC + { + Light_LC_ModelServer_GetOpcodeTableCb, + Light_LC_ModelServer_GetStatusRequestCb, + Light_LC_ModelServer_ProcessMessageCb + }, +#endif +#ifdef ENABLE_GENERIC_MODEL_CLIENT + { + GenericModelClient_GetOpcodeTableCb, + GenericModelClient_GetStatusRequestCb, + GenericModelClient_ProcessMessageCb + }, +#endif +#ifdef ENABLE_CONFIG_MODEL_CLIENT + { + ConfigClientModel_GetOpcodeTableCb, + ConfigClientModel_GetStatusRequestCb, + ConfigClientModel_ProcessMessageCb + }, +#endif + + { 0, 0,0 } +}; + +__attribute__((aligned(4))) const APPLI_SAVE_MODEL_STATE_CB SaveModelState_cb = AppliNvm_SaveModelState; + +#define MODEL_SIG_COUNT ( ( sizeof(Model_SIG_cb)/sizeof(Model_SIG_cb[0]) - 1 )) + +__attribute__((aligned(4))) +const MODEL_Vendor_cb_t Model_Vendor_cb[] = +{ +#ifdef ENABLE_VENDOR_MODEL_SERVER + { + VendorModel_PID1_GetOpcodeTableCb, + VendorModel_PID1_GetStatusRequestCb, + VendorModel_PID1_ProcessMessageCb + }, +#endif + { 0, 0,0 } +}; + +#define MODEL_VENDOR_COUNT ( ( sizeof(Model_Vendor_cb)/sizeof(Model_Vendor_cb[0]) - 1 )) + +extern MOBLEUINT8 NumberOfElements; + +/* Private function prototypes -----------------------------------------------*/ +/* Private functions ---------------------------------------------------------*/ + +void GetApplicationVendorModels(const MODEL_Vendor_cb_t** pModelsTable, MOBLEUINT32* VendorModelscount) +{ + *pModelsTable = Model_Vendor_cb ; + *VendorModelscount = MODEL_VENDOR_COUNT; + + TRACE_M(TF_VENDOR,"GetApplicationVendorModels \r\n"); +} + +/** +* @brief Initialization Commands for Models +* @param void +* @retval void +*/ +void BLEMesh_ModelsInit(void) +{ + +#ifdef ENABLE_SAVE_MODEL_STATE_NVM + + MOBLEUINT8 modelStateLoad_Size; + MOBLEUINT8 modelStateLoadBuff[APP_NVM_MODEL_SIZE]; + +#ifdef CLIENT + MOBLEUINT8 PrvnStateLoad_Size; + MOBLEUINT8 PrvnlStateLoadBuff[16]; +#endif + + /* Callbacks used by BlueNRG-Mesh Models */ + BLEMesh_SetSIGModelsCbMap(Model_SIG_cb, MODEL_SIG_COUNT); + + /* Load generic model states from nvm */ + AppliNvm_LoadModelState(modelStateLoadBuff, &modelStateLoad_Size); + +#ifdef CLIENT + AppliPrvnNvm_LoadData(PrvnlStateLoadBuff,&PrvnStateLoad_Size); +#endif + + if (modelStateLoad_Size != 0) + { + /* update states of generic model */ + Model_RestoreStates(modelStateLoadBuff, modelStateLoad_Size); + } + +#if defined ENABLE_SENSOR_MODEL_SERVER && !defined CUSTOM_BOARD_PWM_SELECTION + /* Initiallization of sensors */ + Appli_Sensor_Init(); +#endif + +#endif +} + +/** +* @brief Process Commands for Models +* @param void +* @retval void +*/ +void BLEMesh_ModelsProcess(void) +{ +#ifdef ENABLE_GENERIC_MODEL_SERVER + Generic_Process(); +#endif + +#ifdef ENABLE_LIGHT_MODEL_SERVER + Lighting_Process(); +#endif + +#ifdef ENABLE_VENDOR_MODEL_SERVER + Vendor_Process(); +#endif +/* Define this Macro to enable the publication of sensors data.*/ +#if defined ENABLE_SENSOR_MODEL_SERVER + Sensor_Process(); +#endif + +#if ENABLE_APPLI_TEST + Test_Process(); +#endif + +#ifdef ENABLE_SAVE_MODEL_STATE_NVM + ModelSave_Process(); +#endif + +#ifdef ENABLE_LIGHT_MODEL_SERVER_LC + Light_control_Process(); +#endif +} + +/** +* @brief Publish Command for Models +* @param void +* @retval void +*/ +void BLEMesh_ModelsCommand(void) +{ +#ifdef VENDOR_CLIENT_MODEL_PUBLISH + Vendor_Publish(BLEMesh_GetAddress()); +#endif + +#ifdef GENERIC_CLIENT_MODEL_PUBLISH + Appli_GenericClient_OnOff_Set(); +#endif + +#ifndef CLIENT +/* if CLIENT and SERVER => Publish is already done in CLIENT */ +#ifdef GENERIC_SERVER_MODEL_PUBLISH + Generic_Publish(BLEMesh_GetAddress()); +#endif +#endif + +} + +/** +* @brief Get the Element Number for selected Model +* @param dst_peer : Destination Address received +* @retval MOBLEUINT8 : elementIndex +*/ +MOBLEUINT8 BLEMesh_ModelsGetElementNumber(MOBLE_ADDRESS dst_peer) +{ + + MOBLE_ADDRESS nodeAddress; + MOBLEUINT8 elementNumber; + + nodeAddress = BLEMesh_GetAddress(); + elementNumber = ((dst_peer - nodeAddress)+1); + + return elementNumber; +} + +/** +* @brief Check Subscription of Elements for Group Address for selected Model +* @param dst_peer : Destination Address received +* @param elementNumber : Number of element to check Subscription +* @retval MOBLE_RESULT status of result +*/ +MOBLE_RESULT BLEMesh_ModelsCheckSubscription(MOBLE_ADDRESS dst_peer, \ + MOBLEUINT8 elementNumber) +{ + MOBLE_RESULT status = MOBLE_RESULT_FAIL; + MOBLE_ADDRESS subscriptionList[10] = {0}; + MOBLEUINT8 length; + MOBLEUINT32 modelId = GENERIC_MODEL_SERVER_LEVEL_MODEL_ID; + BLEMesh_GetSubscriptionAddress(subscriptionList,&length,elementNumber, modelId); + + + for(uint8_t list=0; list<length; list++) + { + if(dst_peer == subscriptionList[list]) + { + status = MOBLE_RESULT_SUCCESS; + break; + } + } + + return status; +} + +/** +* @brief Schedule a packet to be sent with randomized send timestamp +* If a que is empty, random timestamp is calculated +* Subsequent packets are sent in sequence +* @param peer: Address of the peer +* @param dst : Address of the node +* @param status: Command status +* @param data: Data buffer. +* @param length: Length of data in bytes. +* @retval None +*/ +void BLEMesh_ModelsDelayPacket(MOBLE_ADDRESS peer, + MOBLE_ADDRESS dst, + MOBLEUINT8 command, + MOBLEUINT8 const * data, + MOBLEUINT32 length) +{ + MOBLEUINT8 random_time[8]; + + if (Appli_PendingPackets.packet_count == 0) + { + Appli_PendingPackets.packet_count = 1; + hci_le_rand(random_time); + Appli_PendingPackets.send_time = Clock_Time() + + DEFAULT_DELAY_PACKET_FROM + + (random_time[0] + random_time[1]*256)\ + %DEFAULT_DELAY_PACKET_RANDOM_TIME; + Appli_PendingPackets.head = Appli_PendingPackets.packet; + Appli_PendingPackets.head_index = 0; + TRACE_M(TF_MISC, "Randomized time: %ld\n\r", Appli_PendingPackets.send_time - Clock_Time()); + } + else + { + Appli_PendingPackets.packet_count += 1; + Appli_PendingPackets.packet_count = (Appli_PendingPackets.packet_count)%\ + (MAX_PENDING_PACKETS_QUE_SIZE+1); + + if (Appli_PendingPackets.head != (Appli_PendingPackets.packet + \ + MAX_PENDING_PACKETS_QUE_SIZE - 1)) + { + Appli_PendingPackets.head = Appli_PendingPackets.head +1; + Appli_PendingPackets.head_index = Appli_PendingPackets.head_index+1; + } + else + { + Appli_PendingPackets.head = Appli_PendingPackets.packet; + Appli_PendingPackets.head_index = 0; + } + } + + Appli_PendingPackets.head->peer = peer; + Appli_PendingPackets.head->dst = dst; + Appli_PendingPackets.head->command = command; + Appli_PendingPackets.head->length = length; + for (MOBLEUINT8 count=0; count<length; count++) + Appli_PendingPackets.head->data[count] = data[count]; +} + + +/** +* @brief If send timestamp is reached and que is not empty, send all packets +* @param None +* @retval None +*/ +void BLEMesh_ModelsSendDelayedPacket(void) +{ + APPLI_SEND_RESPONSE_MODULE* ptr; + MOBLEUINT8 temp_index; + + if ((Appli_PendingPackets.packet_count != 0) && + (Appli_PendingPackets.send_time <= Clock_Time())) + { + for (MOBLEUINT8 count=Appli_PendingPackets.packet_count; count!=0; count--) + { + TRACE_M(TF_MISC, "Sending randomized packets. Packet count: %d \n\r",\ + Appli_PendingPackets.packet_count - count + 1); + temp_index = ((Appli_PendingPackets.head_index+MAX_PENDING_PACKETS_QUE_SIZE+1)\ + -count)%MAX_PENDING_PACKETS_QUE_SIZE; + ptr = Appli_PendingPackets.packet + temp_index; + + VendorModel_SendResponse(VENDOR_STMICRO_CID, + ptr->peer, + ptr->dst, + ptr->command, + ptr->data, + ptr->length); + } + + Appli_PendingPackets.packet_count = 0; + } +} + +/** \brief Set remote publication for the given Model ID & node Address +* User is responsible for serializing data into \a data buffer. Vendor_WriteLocalDataCb +* callback will be called on the remote device. +* @param modelId ID of the model. +* @param srcAddress element Address of the Node +* @param command vendor model commands +* @param data Data buffer. +* @param length Length of data in bytes. +* @param response If 'MOBLE_TRUE', used to get the response. If 'MOBLE_FALSE', no response +* @return MOBLE_RESULT_SUCCESS on success. +*/ +MOBLE_RESULT MeshClient_SetRemotePublication(MOBLEUINT32 modelId, MOBLEUINT16 elementIdx, + MOBLEUINT16 msg_opcode, MOBLEUINT8 const *msg_buff, + MOBLEUINT32 length, MOBLEBOOL ack_flag, + MOBLEUINT8 isVendor) +{ + MOBLE_ADDRESS srcAddress; + + srcAddress = BLEMesh_GetAddress(); + srcAddress += elementIdx; /* Get the Address to send in the message */ + + return BLEMesh_SetRemotePublication(GENERIC_MODEL_SERVER_ONOFF_MODEL_ID, + srcAddress , + msg_opcode , + msg_buff, length, + ack_flag, + MOBLE_FALSE); +} + +/** +* @brief Convert ASCII value into Character +* @param tempValue : 8bit value for conversion +* @retval MOBLEUINT8 +*/ +MOBLEUINT8 BLEMesh_ModelsASCII_To_Char(MOBLEUINT8 tempValue) +{ + tempValue = tempValue - 0x30; + return tempValue; +} + +__weak void Test_Process(void) +{ +} +/** +* @} +*/ + +/** +* @} +*/ + +/******************* (C) COPYRIGHT 2019 STMicroelectronics *****END OF FILE****/ |