xref: /btstack/src/mesh/mesh_access.h (revision 43e3439045c68999ee8e8cc89c20a281fb5662e4)
1 /*
2  * Copyright (C) 2018 BlueKitchen GmbH
3  *
4  * Redistribution and use in source and binary forms, with or without
5  * modification, are permitted provided that the following conditions
6  * are met:
7  *
8  * 1. Redistributions of source code must retain the above copyright
9  *    notice, this list of conditions and the following disclaimer.
10  * 2. Redistributions in binary form must reproduce the above copyright
11  *    notice, this list of conditions and the following disclaimer in the
12  *    documentation and/or other materials provided with the distribution.
13  * 3. Neither the name of the copyright holders nor the names of
14  *    contributors may be used to endorse or promote products derived
15  *    from this software without specific prior written permission.
16  * 4. Any redistribution, use, or modification is done solely for
17  *    personal benefit and not for any commercial purpose or for
18  *    monetary gain.
19  *
20  * THIS SOFTWARE IS PROVIDED BY BLUEKITCHEN GMBH AND CONTRIBUTORS
21  * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
22  * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS
23  * FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL MATTHIAS
24  * RINGWALD OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT,
25  * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING,
26  * BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS
27  * OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED
28  * AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
29  * OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF
30  * THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
31  * SUCH DAMAGE.
32  *
33  * Please inquire about commercial licensing options at
34  * [email protected]
35  *
36  */
37 
38 #ifndef __MESH_ACCESS_H
39 #define __MESH_ACCESS_H
40 
41 #include <stdint.h>
42 #include <stdarg.h>
43 
44 #include "bluetooth_company_id.h"
45 #include "btstack_linked_list.h"
46 
47 #include "mesh/mesh_lower_transport.h"
48 #include "mesh/mesh_keys.h"
49 #include "mesh/mesh_node.h"
50 
51 #ifdef __cplusplus
52 extern "C"
53 {
54 #endif
55 
56 #define MESH_SEQUENCE_NUMBER_STORAGE_INTERVAL 1000
57 
58 typedef enum {
59     MESH_DEFAULT_TRANSITION_STEP_RESOLUTION_100ms = 0x00u,
60     MESH_DEFAULT_TRANSITION_STEP_RESOLUTION_1s,
61     MESH_DEFAULT_TRANSITION_STEP_RESOLUTION_10s,
62     MESH_DEFAULT_TRANSITION_STEP_RESOLUTION_10min
63 } mesh_default_transition_step_resolution_t;
64 
65 typedef enum {
66     MODEL_STATE_UPDATE_REASON_SET = 0x00u,
67     MODEL_STATE_UPDATE_REASON_TRANSITION_START,
68     MODEL_STATE_UPDATE_REASON_TRANSITION_ACTIVE,
69     MODEL_STATE_UPDATE_REASON_TRANSITION_END,
70     MODEL_STATE_UPDATE_REASON_TRANSITION_ABORT,
71     // MODEL_STATE_UPDATE_REASON_BOUND_STATE,
72     MODEL_STATE_UPDATE_REASON_APPLICATION_CHANGE
73  } model_state_update_reason_t;
74 
75 typedef enum {
76     TRANSITION_START,
77     TRANSITION_UPDATE
78 } transition_event_t;
79 
80 typedef enum {
81     MESH_TRANSITION_STATE_IDLE,
82     MESH_TRANSITION_STATE_DELAYED,
83     MESH_TRANSITION_STATE_ACTIVE
84 } mesh_transition_state_t;
85 
86 typedef enum {
87     MODEL_STATE_ID_GENERIC_ON_OFF = (BLUETOOTH_COMPANY_ID_BLUETOOTH_SIG_INC << 16) | 0u,
88     MODEL_STATE_ID_GENERIC_LEVEL  = (BLUETOOTH_COMPANY_ID_BLUETOOTH_SIG_INC << 16) | 1u,
89 } model_state_id_t;
90 
91 #define MESH_MAX_NUM_FAULTS 5
92 
93 typedef struct {
94     // linked list item
95     btstack_linked_item_t item;
96     uint8_t  test_id;
97     uint16_t company_id;
98     uint16_t num_current_faults;
99     uint16_t num_registered_faults;
100     uint8_t  current_faults[MESH_MAX_NUM_FAULTS];
101     uint8_t  registered_faults[MESH_MAX_NUM_FAULTS];
102 } mesh_health_fault_t;
103 
104 typedef struct {
105     // linked list of mesh_health_fault items
106     btstack_linked_list_t faults;
107     uint8_t fast_period_divisor;
108 } mesh_health_state_t;
109 
110 typedef struct {
111     uint32_t opcode;
112     uint8_t * data;
113     uint16_t len;
114 } mesh_access_parser_state_t;
115 
116 typedef struct {
117     uint32_t     opcode;
118     const char * format;
119 } mesh_access_message_t;
120 
121 typedef enum {
122     MESH_TRANSACTION_STATUS_NEW = 0,
123     MESH_TRANSACTION_STATUS_RETRANSMISSION,
124     MESH_TRANSACTION_STATUS_DIFFERENT_DST_OR_SRC
125 } mesh_transaction_status_t;
126 
127 typedef struct mesh_transition {
128     btstack_linked_item_t item;
129 
130     mesh_transition_state_t state;
131 
132     uint8_t  transaction_identifier;
133     uint32_t transaction_timestamp_ms;
134     uint16_t src_address;
135     uint16_t dst_address;
136 
137     uint8_t num_steps;
138 
139     uint32_t step_duration_ms;
140     uint32_t phase_start_ms;
141     uint32_t remaining_delay_time_ms;
142     uint32_t remaining_transition_time_ms;
143     // to send events and/or publish changes
144     mesh_model_t * mesh_model;
145 
146     // to execute transition
147     void (* transition_callback)(struct mesh_transition * transition, transition_event_t event, uint32_t current_timestamp);
148 } mesh_transition_t;
149 
150 /**
151  * @brief Init access layer
152  */
153 void mesh_access_init(void);
154 
155 /**
156  * @brief Inform access layer that access message was processed by higher layer
157  * @param pdu
158  */
159 void mesh_access_message_processed(mesh_pdu_t * pdu);
160 
161 /**
162  * @brief Get number of retransmissions used by default
163  */
164 uint8_t mesh_access_acknowledged_message_retransmissions(void);
165 
166 /**
167  * @brief Get retransmission timeout
168  */
169 uint32_t mesh_access_acknowledged_message_timeout_ms(void);
170 
171 /**
172  * @brief Send unacknowledged message
173  * @param pdu
174  */
175 void mesh_access_send_unacknowledged_pdu(mesh_pdu_t * pdu);
176 
177 /**
178  * @brief Send acknowledged message. Retransmits message if no acknowledgement with expected opcode is received
179  * @param pdu
180  * @param retransmissions
181  * @param ack_opcode opcode of acknowledgement
182  */
183 void mesh_access_send_acknowledged_pdu(mesh_pdu_t * pdu, uint8_t retransmissions, uint32_t ack_opcode);
184 
185 uint8_t mesh_access_transitions_num_steps_from_gdtt(uint8_t time_gdtt);
186 uint32_t mesh_access_time_gdtt2ms(uint8_t time_gdtt);
187 uint8_t mesh_access_time_as_gdtt(uint32_t step_resolution_ms, uint32_t time_ms);
188 
189 void mesh_access_emit_state_update_bool(btstack_packet_handler_t event_handler, uint8_t element_index, uint32_t model_identifier,
190     model_state_id_t state_identifier, model_state_update_reason_t reason, uint8_t value);
191 void mesh_access_emit_state_update_int16(btstack_packet_handler_t event_handler, uint8_t element_index, uint32_t model_identifier,
192     model_state_id_t state_identifier, model_state_update_reason_t reason, int16_t value);
193 
194 // Mesh Model Transitions
195 void mesh_access_transitions_setup_transaction(mesh_transition_t * transition, uint8_t transaction_identifier, uint16_t src_address, uint16_t dst_address);
196 void mesh_access_transitions_abort_transaction(mesh_transition_t * transition);
197 mesh_transaction_status_t mesh_access_transitions_transaction_status(mesh_transition_t * transition, uint8_t transaction_identifier, uint16_t src_address, uint16_t dst_address);
198 
199 void mesh_access_transitions_setup(mesh_transition_t * transition, mesh_model_t * mesh_model,
200     uint8_t transition_time_gdtt, uint8_t delay_gdtt,
201     void (* transition_callback)(struct mesh_transition * transition, transition_event_t event, uint32_t current_timestamp));
202 
203 void mesh_access_transitions_add(mesh_transition_t * transition);
204 void mesh_access_transitions_remove(mesh_transition_t * transition);
205 uint8_t mesh_access_transactions_get_next_transaction_id(void);
206 
207 // Mesh Model Publicaation
208 
209 /**
210  * Inform Mesh Access that the state of a model has changed. may trigger state publication
211  * @param mesh_model
212  */
213 void mesh_access_state_changed(mesh_model_t * mesh_model);
214 
215 /**
216  * Start Model Publication
217  * @param mesh_model
218  */
219 void mesh_model_publication_start(mesh_model_t * mesh_model);
220 
221 /**
222  * Stop Model Publication
223  * @param mesh_model
224  */
225 void mesh_model_publication_stop(mesh_model_t * mesh_model);
226 
227 // Mesh PDU Getter
228 uint16_t mesh_pdu_ctl(mesh_pdu_t * pdu);
229 uint16_t mesh_pdu_ttl(mesh_pdu_t * pdu);
230 uint16_t mesh_pdu_src(mesh_pdu_t * pdu);
231 uint16_t mesh_pdu_dst(mesh_pdu_t * pdu);
232 uint16_t mesh_pdu_netkey_index(mesh_pdu_t * pdu);
233 uint16_t mesh_pdu_appkey_index(mesh_pdu_t * pdu);
234 uint16_t mesh_pdu_len(mesh_pdu_t * pdu);
235 uint8_t * mesh_pdu_data(mesh_pdu_t * pdu);
236 uint8_t  mesh_pdu_control_opcode(mesh_pdu_t * pdu);
237 
238 // Mesh Access Parser
239 int mesh_access_pdu_get_opcode(mesh_pdu_t * pdu, uint32_t * opcode, uint16_t * opcode_size);
240 int  mesh_access_parser_init(mesh_access_parser_state_t * state, mesh_pdu_t * pdu);
241 void mesh_access_parser_skip(mesh_access_parser_state_t * state, uint16_t bytes_to_skip);
242 uint16_t mesh_access_parser_available(mesh_access_parser_state_t * state);
243 uint8_t mesh_access_parser_get_u8(mesh_access_parser_state_t * state);
244 uint16_t mesh_access_parser_get_u16(mesh_access_parser_state_t * state);
245 uint32_t mesh_access_parser_get_u24(mesh_access_parser_state_t * state);
246 uint32_t mesh_access_parser_get_u32(mesh_access_parser_state_t * state);
247 void mesh_access_parser_get_u128(mesh_access_parser_state_t * state, uint8_t * dest);
248 void mesh_access_parser_get_label_uuid(mesh_access_parser_state_t * state, uint8_t * dest);
249 void mesh_access_parser_get_key(mesh_access_parser_state_t * state, uint8_t * dest);
250 uint32_t mesh_access_parser_get_model_identifier(mesh_access_parser_state_t * parser);
251 
252 // message builder transport
253 mesh_transport_pdu_t * mesh_access_transport_init(uint32_t opcode);
254 void mesh_access_transport_add_uint8(mesh_transport_pdu_t * pdu, uint8_t value);
255 void mesh_access_transport_add_uint16(mesh_transport_pdu_t * pdu, uint16_t value);
256 void mesh_access_transport_add_uint24(mesh_transport_pdu_t * pdu, uint32_t value);
257 void mesh_access_transport_add_uint32(mesh_transport_pdu_t * pdu, uint32_t value);
258 void mesh_access_transport_add_model_identifier(mesh_transport_pdu_t * pdu, uint32_t model_identifier);
259 
260 // message builder network
261 mesh_network_pdu_t * mesh_access_network_init(uint32_t opcode);
262 void mesh_access_network_add_uint8(mesh_network_pdu_t * pdu, uint8_t value);
263 void mesh_access_network_add_uint16(mesh_network_pdu_t * pdu, uint16_t value);
264 void mesh_access_network_add_uint24(mesh_network_pdu_t * pdu, uint16_t value);
265 void mesh_access_network_add_uint32(mesh_network_pdu_t * pdu, uint16_t value);
266 void mesh_access_network_add_model_identifier(mesh_network_pdu_t * pdu, uint32_t model_identifier);
267 
268 // message builder using template
269 mesh_network_pdu_t * mesh_access_setup_unsegmented_message(const mesh_access_message_t *message_template, ...);
270 mesh_transport_pdu_t * mesh_access_setup_segmented_message(const mesh_access_message_t *message_template, ...);
271 
272 #ifdef __cplusplus
273 } /* end of extern "C" */
274 #endif
275 
276 #endif
277