xref: /btstack/src/mesh/mesh_access.h (revision 4439045c0d98140b31e403a03c6ff7b62426103a)
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 3
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_faults;
99     uint8_t  faults[MESH_MAX_NUM_FAULTS];
100 } mesh_fault_t;
101 
102 typedef struct {
103     btstack_linked_list_t current_faults;
104     btstack_linked_list_t registered_faults;
105 
106     uint8_t fast_period_divisor;
107 } mesh_health_state_t;
108 
109 typedef struct {
110     uint32_t opcode;
111     uint8_t * data;
112     uint16_t len;
113 } mesh_access_parser_state_t;
114 
115 typedef struct {
116     uint32_t     opcode;
117     const char * format;
118 } mesh_access_message_t;
119 
120 typedef enum {
121     MESH_TRANSACTION_STATUS_NEW = 0,
122     MESH_TRANSACTION_STATUS_RETRANSMISSION,
123     MESH_TRANSACTION_STATUS_DIFFERENT_DST_OR_SRC
124 } mesh_transaction_status_t;
125 
126 typedef struct mesh_transition {
127     btstack_linked_item_t item;
128 
129     mesh_transition_state_t state;
130 
131     uint8_t  transaction_identifier;
132     uint32_t transaction_timestamp_ms;
133     uint16_t src_address;
134     uint16_t dst_address;
135 
136     mesh_default_transition_step_resolution_t step_duration_ms;
137     uint32_t phase_start_ms;
138     uint32_t remaining_delay_time_ms;
139     uint32_t remaining_transition_time_ms;
140     // to send events and/or publish changes
141     mesh_model_t * mesh_model;
142 
143     // to execute transition
144     void (* transition_callback)(struct mesh_transition * transition, transition_event_t event, uint32_t current_timestamp);
145 } mesh_transition_t;
146 
147 /**
148  * @brief Init access layer
149  */
150 void mesh_access_init(void);
151 
152 /**
153  * @brief Inform access layer that access message was processed by higher layer
154  * @param pdu
155  */
156 void mesh_access_message_processed(mesh_pdu_t * pdu);
157 
158 /**
159  * @brief Get number of retransmissions used by default
160  */
161 uint8_t mesh_access_acknowledged_message_retransmissions(void);
162 
163 /**
164  * @brief Get retransmission timeout
165  */
166 uint32_t mesh_access_acknowledged_message_timeout_ms(void);
167 
168 /**
169  * @brief Send unacknowledged message
170  * @param pdu
171  */
172 void mesh_access_send_unacknowledged_pdu(mesh_pdu_t * pdu);
173 
174 /**
175  * @brief Send acknowledged message. Retransmits message if no acknowledgement with expected opcode is received
176  * @param pdu
177  * @param retransmissions
178  * @param ack_opcode opcode of acknowledgement
179  */
180 void mesh_access_send_acknowledged_pdu(mesh_pdu_t * pdu, uint8_t retransmissions, uint32_t ack_opcode);
181 
182 uint8_t mesh_access_transitions_num_steps_from_gdtt(uint8_t time_gdtt);
183 uint32_t mesh_access_time_gdtt2ms(uint8_t time_gdtt);
184 
185 void mesh_access_emit_state_update_bool(btstack_packet_handler_t event_handler, uint8_t element_index, uint32_t model_identifier,
186     model_state_id_t state_identifier, model_state_update_reason_t reason, uint8_t value);
187 void mesh_access_emit_state_update_int16(btstack_packet_handler_t event_handler, uint8_t element_index, uint32_t model_identifier,
188     model_state_id_t state_identifier, model_state_update_reason_t reason, int16_t value);
189 
190 // Mesh Model Transitions
191 void mesh_access_transitions_setup_transaction(mesh_transition_t * transition, uint8_t transaction_identifier, uint16_t src_address, uint16_t dst_address);
192 void mesh_access_transitions_abort_transaction(mesh_transition_t * transition);
193 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);
194 
195 void mesh_access_transitions_setup(mesh_transition_t * transition, mesh_model_t * mesh_model,
196     uint8_t transition_time_gdtt, uint8_t delay_gdtt,
197     void (* transition_callback)(struct mesh_transition * transition, transition_event_t event, uint32_t current_timestamp));
198 
199 void mesh_access_transitions_add(mesh_transition_t * transition);
200 void mesh_access_transitions_remove(mesh_transition_t * transition);
201 uint8_t mesh_access_transactions_get_next_transaction_id(void);
202 
203 // Mesh Model Publicaation
204 
205 /**
206  * Inform Mesh Access that the state of a model has changed. may trigger state publication
207  * @param mesh_model
208  */
209 void mesh_access_state_changed(mesh_model_t * mesh_model);
210 
211 /**
212  * Start Model Publication
213  * @param mesh_model
214  */
215 void mesh_model_publication_start(mesh_model_t * mesh_model);
216 
217 /**
218  * Stop Model Publication
219  * @param mesh_model
220  */
221 void mesh_model_publication_stop(mesh_model_t * mesh_model);
222 
223 // Mesh PDU Getter
224 uint16_t mesh_pdu_ctl(mesh_pdu_t * pdu);
225 uint16_t mesh_pdu_ttl(mesh_pdu_t * pdu);
226 uint16_t mesh_pdu_src(mesh_pdu_t * pdu);
227 uint16_t mesh_pdu_dst(mesh_pdu_t * pdu);
228 uint16_t mesh_pdu_netkey_index(mesh_pdu_t * pdu);
229 uint16_t mesh_pdu_appkey_index(mesh_pdu_t * pdu);
230 uint16_t mesh_pdu_len(mesh_pdu_t * pdu);
231 uint8_t * mesh_pdu_data(mesh_pdu_t * pdu);
232 uint8_t  mesh_pdu_control_opcode(mesh_pdu_t * pdu);
233 
234 // Mesh Access Parser
235 int mesh_access_pdu_get_opcode(mesh_pdu_t * pdu, uint32_t * opcode, uint16_t * opcode_size);
236 int  mesh_access_parser_init(mesh_access_parser_state_t * state, mesh_pdu_t * pdu);
237 void mesh_access_parser_skip(mesh_access_parser_state_t * state, uint16_t bytes_to_skip);
238 uint16_t mesh_access_parser_available(mesh_access_parser_state_t * state);
239 uint8_t mesh_access_parser_get_u8(mesh_access_parser_state_t * state);
240 uint16_t mesh_access_parser_get_u16(mesh_access_parser_state_t * state);
241 uint32_t mesh_access_parser_get_u24(mesh_access_parser_state_t * state);
242 uint32_t mesh_access_parser_get_u32(mesh_access_parser_state_t * state);
243 void mesh_access_parser_get_u128(mesh_access_parser_state_t * state, uint8_t * dest);
244 void mesh_access_parser_get_label_uuid(mesh_access_parser_state_t * state, uint8_t * dest);
245 void mesh_access_parser_get_key(mesh_access_parser_state_t * state, uint8_t * dest);
246 uint32_t mesh_access_parser_get_model_identifier(mesh_access_parser_state_t * parser);
247 
248 // message builder transport
249 mesh_transport_pdu_t * mesh_access_transport_init(uint32_t opcode);
250 void mesh_access_transport_add_uint8(mesh_transport_pdu_t * pdu, uint8_t value);
251 void mesh_access_transport_add_uint16(mesh_transport_pdu_t * pdu, uint16_t value);
252 void mesh_access_transport_add_uint24(mesh_transport_pdu_t * pdu, uint32_t value);
253 void mesh_access_transport_add_uint32(mesh_transport_pdu_t * pdu, uint32_t value);
254 void mesh_access_transport_add_model_identifier(mesh_transport_pdu_t * pdu, uint32_t model_identifier);
255 
256 // message builder network
257 mesh_network_pdu_t * mesh_access_network_init(uint32_t opcode);
258 void mesh_access_network_add_uint8(mesh_network_pdu_t * pdu, uint8_t value);
259 void mesh_access_network_add_uint16(mesh_network_pdu_t * pdu, uint16_t value);
260 void mesh_access_network_add_uint24(mesh_network_pdu_t * pdu, uint16_t value);
261 void mesh_access_network_add_uint32(mesh_network_pdu_t * pdu, uint16_t value);
262 void mesh_access_network_add_model_identifier(mesh_network_pdu_t * pdu, uint32_t model_identifier);
263 
264 // message builder using template
265 mesh_network_pdu_t * mesh_access_setup_unsegmented_message(const mesh_access_message_t *message_template, ...);
266 mesh_transport_pdu_t * mesh_access_setup_segmented_message(const mesh_access_message_t *message_template, ...);
267 
268 #ifdef __cplusplus
269 } /* end of extern "C" */
270 #endif
271 
272 #endif
273