1591423b2SMatthias Ringwald /* 2591423b2SMatthias Ringwald * Copyright (C) 2014 BlueKitchen GmbH 3591423b2SMatthias Ringwald * 4591423b2SMatthias Ringwald * Redistribution and use in source and binary forms, with or without 5591423b2SMatthias Ringwald * modification, are permitted provided that the following conditions 6591423b2SMatthias Ringwald * are met: 7591423b2SMatthias Ringwald * 8591423b2SMatthias Ringwald * 1. Redistributions of source code must retain the above copyright 9591423b2SMatthias Ringwald * notice, this list of conditions and the following disclaimer. 10591423b2SMatthias Ringwald * 2. Redistributions in binary form must reproduce the above copyright 11591423b2SMatthias Ringwald * notice, this list of conditions and the following disclaimer in the 12591423b2SMatthias Ringwald * documentation and/or other materials provided with the distribution. 13591423b2SMatthias Ringwald * 3. Neither the name of the copyright holders nor the names of 14591423b2SMatthias Ringwald * contributors may be used to endorse or promote products derived 15591423b2SMatthias Ringwald * from this software without specific prior written permission. 16591423b2SMatthias Ringwald * 4. Any redistribution, use, or modification is done solely for 17591423b2SMatthias Ringwald * personal benefit and not for any commercial purpose or for 18591423b2SMatthias Ringwald * monetary gain. 19591423b2SMatthias Ringwald * 20591423b2SMatthias Ringwald * THIS SOFTWARE IS PROVIDED BY BLUEKITCHEN GMBH AND CONTRIBUTORS 21591423b2SMatthias Ringwald * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT 22591423b2SMatthias Ringwald * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS 23591423b2SMatthias Ringwald * FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL MATTHIAS 24591423b2SMatthias Ringwald * RINGWALD OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, 25591423b2SMatthias Ringwald * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, 26591423b2SMatthias Ringwald * BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS 27591423b2SMatthias Ringwald * OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED 28591423b2SMatthias Ringwald * AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, 29591423b2SMatthias Ringwald * OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF 30591423b2SMatthias Ringwald * THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF 31591423b2SMatthias Ringwald * SUCH DAMAGE. 32591423b2SMatthias Ringwald * 33591423b2SMatthias Ringwald * Please inquire about commercial licensing options at 34591423b2SMatthias Ringwald * [email protected] 35591423b2SMatthias Ringwald * 36591423b2SMatthias Ringwald */ 37591423b2SMatthias Ringwald 38ab2c6ae4SMatthias Ringwald #define __BTSTACK_FILE__ "att_db.c" 39ab2c6ae4SMatthias Ringwald 40591423b2SMatthias Ringwald 41591423b2SMatthias Ringwald #include <stdio.h> 42591423b2SMatthias Ringwald #include <string.h> 43591423b2SMatthias Ringwald 44591423b2SMatthias Ringwald #include "ble/att_db.h" 4559c6af15SMatthias Ringwald #include "ble/core.h" 468ac574d6SMatthias Ringwald #include "bluetooth.h" 47591423b2SMatthias Ringwald #include "btstack_debug.h" 48591423b2SMatthias Ringwald #include "btstack_util.h" 49591423b2SMatthias Ringwald 50591423b2SMatthias Ringwald // Buetooth Base UUID 00000000-0000-1000-8000-00805F9B34FB in little endian 51591423b2SMatthias Ringwald static const uint8_t bluetooth_base_uuid[] = { 0xfb, 0x34, 0x9b, 0x5f, 0x80, 0x00, 0x00, 0x80, 0x00, 0x10, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00 }; 52591423b2SMatthias Ringwald 53591423b2SMatthias Ringwald 54591423b2SMatthias Ringwald static int is_Bluetooth_Base_UUID(uint8_t const *uuid){ 55591423b2SMatthias Ringwald if (memcmp(&uuid[0], &bluetooth_base_uuid[0], 12)) return 0; 56591423b2SMatthias Ringwald if (memcmp(&uuid[14], &bluetooth_base_uuid[14], 2)) return 0; 57591423b2SMatthias Ringwald return 1; 58591423b2SMatthias Ringwald 59591423b2SMatthias Ringwald } 60591423b2SMatthias Ringwald 61591423b2SMatthias Ringwald static uint16_t uuid16_from_uuid(uint16_t uuid_len, uint8_t * uuid){ 62591423b2SMatthias Ringwald if (uuid_len == 2) return little_endian_read_16(uuid, 0); 63591423b2SMatthias Ringwald if (!is_Bluetooth_Base_UUID(uuid)) return 0; 64591423b2SMatthias Ringwald return little_endian_read_16(uuid, 12); 65591423b2SMatthias Ringwald } 66591423b2SMatthias Ringwald 67591423b2SMatthias Ringwald // ATT Database 68591423b2SMatthias Ringwald static uint8_t const * att_db = NULL; 69591423b2SMatthias Ringwald static att_read_callback_t att_read_callback = NULL; 70591423b2SMatthias Ringwald static att_write_callback_t att_write_callback = NULL; 71591423b2SMatthias Ringwald static uint8_t att_prepare_write_error_code = 0; 72591423b2SMatthias Ringwald static uint16_t att_prepare_write_error_handle = 0x0000; 73591423b2SMatthias Ringwald 748ac574d6SMatthias Ringwald static btstack_linked_list_t service_handlers; 758ac574d6SMatthias Ringwald 76591423b2SMatthias Ringwald // new java-style iterator 77591423b2SMatthias Ringwald typedef struct att_iterator { 78591423b2SMatthias Ringwald // private 79591423b2SMatthias Ringwald uint8_t const * att_ptr; 80591423b2SMatthias Ringwald // public 81591423b2SMatthias Ringwald uint16_t size; 82591423b2SMatthias Ringwald uint16_t flags; 83591423b2SMatthias Ringwald uint16_t handle; 84591423b2SMatthias Ringwald uint8_t const * uuid; 85591423b2SMatthias Ringwald uint16_t value_len; 86591423b2SMatthias Ringwald uint8_t const * value; 87591423b2SMatthias Ringwald } att_iterator_t; 88591423b2SMatthias Ringwald 89591423b2SMatthias Ringwald static void att_iterator_init(att_iterator_t *it){ 90591423b2SMatthias Ringwald it->att_ptr = att_db; 91591423b2SMatthias Ringwald } 92591423b2SMatthias Ringwald 93591423b2SMatthias Ringwald static int att_iterator_has_next(att_iterator_t *it){ 94591423b2SMatthias Ringwald return it->att_ptr != NULL; 95591423b2SMatthias Ringwald } 96591423b2SMatthias Ringwald 97591423b2SMatthias Ringwald static void att_iterator_fetch_next(att_iterator_t *it){ 98591423b2SMatthias Ringwald it->size = little_endian_read_16(it->att_ptr, 0); 99591423b2SMatthias Ringwald if (it->size == 0){ 100591423b2SMatthias Ringwald it->flags = 0; 101591423b2SMatthias Ringwald it->handle = 0; 102591423b2SMatthias Ringwald it->uuid = NULL; 103591423b2SMatthias Ringwald it->value_len = 0; 104591423b2SMatthias Ringwald it->value = NULL; 105591423b2SMatthias Ringwald it->att_ptr = NULL; 106591423b2SMatthias Ringwald return; 107591423b2SMatthias Ringwald } 108591423b2SMatthias Ringwald it->flags = little_endian_read_16(it->att_ptr, 2); 109591423b2SMatthias Ringwald it->handle = little_endian_read_16(it->att_ptr, 4); 110591423b2SMatthias Ringwald it->uuid = &it->att_ptr[6]; 111591423b2SMatthias Ringwald // handle 128 bit UUIDs 112591423b2SMatthias Ringwald if (it->flags & ATT_PROPERTY_UUID128){ 113591423b2SMatthias Ringwald it->value_len = it->size - 22; 114591423b2SMatthias Ringwald it->value = &it->att_ptr[22]; 115591423b2SMatthias Ringwald } else { 116591423b2SMatthias Ringwald it->value_len = it->size - 8; 117591423b2SMatthias Ringwald it->value = &it->att_ptr[8]; 118591423b2SMatthias Ringwald } 119591423b2SMatthias Ringwald // advance AFTER setting values 120591423b2SMatthias Ringwald it->att_ptr += it->size; 121591423b2SMatthias Ringwald } 122591423b2SMatthias Ringwald 123591423b2SMatthias Ringwald static int att_iterator_match_uuid16(att_iterator_t *it, uint16_t uuid){ 124591423b2SMatthias Ringwald if (it->handle == 0) return 0; 125591423b2SMatthias Ringwald if (it->flags & ATT_PROPERTY_UUID128){ 126591423b2SMatthias Ringwald if (!is_Bluetooth_Base_UUID(it->uuid)) return 0; 127591423b2SMatthias Ringwald return little_endian_read_16(it->uuid, 12) == uuid; 128591423b2SMatthias Ringwald } 129591423b2SMatthias Ringwald return little_endian_read_16(it->uuid, 0) == uuid; 130591423b2SMatthias Ringwald } 131591423b2SMatthias Ringwald 132591423b2SMatthias Ringwald static int att_iterator_match_uuid(att_iterator_t *it, uint8_t *uuid, uint16_t uuid_len){ 133591423b2SMatthias Ringwald if (it->handle == 0) return 0; 134591423b2SMatthias Ringwald // input: UUID16 135591423b2SMatthias Ringwald if (uuid_len == 2) { 136591423b2SMatthias Ringwald return att_iterator_match_uuid16(it, little_endian_read_16(uuid, 0)); 137591423b2SMatthias Ringwald } 138591423b2SMatthias Ringwald // input and db: UUID128 139591423b2SMatthias Ringwald if (it->flags & ATT_PROPERTY_UUID128){ 140591423b2SMatthias Ringwald return memcmp(it->uuid, uuid, 16) == 0; 141591423b2SMatthias Ringwald } 142591423b2SMatthias Ringwald // input: UUID128, db: UUID16 143591423b2SMatthias Ringwald if (!is_Bluetooth_Base_UUID(uuid)) return 0; 144591423b2SMatthias Ringwald return little_endian_read_16(uuid, 12) == little_endian_read_16(it->uuid, 0); 145591423b2SMatthias Ringwald } 146591423b2SMatthias Ringwald 147591423b2SMatthias Ringwald 148591423b2SMatthias Ringwald static int att_find_handle(att_iterator_t *it, uint16_t handle){ 149591423b2SMatthias Ringwald if (handle == 0) return 0; 150591423b2SMatthias Ringwald att_iterator_init(it); 151591423b2SMatthias Ringwald while (att_iterator_has_next(it)){ 152591423b2SMatthias Ringwald att_iterator_fetch_next(it); 153591423b2SMatthias Ringwald if (it->handle != handle) continue; 154591423b2SMatthias Ringwald return 1; 155591423b2SMatthias Ringwald } 156591423b2SMatthias Ringwald return 0; 157591423b2SMatthias Ringwald } 158591423b2SMatthias Ringwald 1598ac574d6SMatthias Ringwald static att_service_handler_t * att_service_handler_for_handle(uint16_t handle){ 1608ac574d6SMatthias Ringwald btstack_linked_list_iterator_t it; 1618ac574d6SMatthias Ringwald btstack_linked_list_iterator_init(&it, &service_handlers); 1628ac574d6SMatthias Ringwald while (btstack_linked_list_iterator_has_next(&it)){ 1638ac574d6SMatthias Ringwald att_service_handler_t * handler = (att_service_handler_t*) btstack_linked_list_iterator_next(&it); 1648ac574d6SMatthias Ringwald if (handler->start_handle > handle) continue; 1658ac574d6SMatthias Ringwald if (handler->end_handle < handle) continue; 1668ac574d6SMatthias Ringwald return handler; 1678ac574d6SMatthias Ringwald } 1688ac574d6SMatthias Ringwald return NULL; 1698ac574d6SMatthias Ringwald } 1708ac574d6SMatthias Ringwald 1718ac574d6SMatthias Ringwald static att_read_callback_t att_read_callback_for_handle(uint16_t handle){ 1728ac574d6SMatthias Ringwald att_service_handler_t * handler = att_service_handler_for_handle(handle); 1738ac574d6SMatthias Ringwald if (handler) return handler->read_callback; 1748ac574d6SMatthias Ringwald return att_read_callback; 1758ac574d6SMatthias Ringwald } 1768ac574d6SMatthias Ringwald 1778ac574d6SMatthias Ringwald static att_write_callback_t att_write_callback_for_handle(uint16_t handle){ 1788ac574d6SMatthias Ringwald att_service_handler_t * handler = att_service_handler_for_handle(handle); 1798ac574d6SMatthias Ringwald if (handler) return handler->write_callback; 1808ac574d6SMatthias Ringwald return att_write_callback; 1818ac574d6SMatthias Ringwald } 1828ac574d6SMatthias Ringwald 183591423b2SMatthias Ringwald // experimental client API 184fc64f94aSMatthias Ringwald uint16_t att_uuid_for_handle(uint16_t attribute_handle){ 185591423b2SMatthias Ringwald att_iterator_t it; 186fc64f94aSMatthias Ringwald int ok = att_find_handle(&it, attribute_handle); 187591423b2SMatthias Ringwald if (!ok) return 0; 188591423b2SMatthias Ringwald if (it.flags & ATT_PROPERTY_UUID128) return 0; 189591423b2SMatthias Ringwald return little_endian_read_16(it.uuid, 0); 190591423b2SMatthias Ringwald } 191591423b2SMatthias Ringwald // end of client API 192591423b2SMatthias Ringwald 193711e6c80SMatthias Ringwald static void att_update_value_len(att_iterator_t *it, hci_con_handle_t con_handle){ 1948ac574d6SMatthias Ringwald if ((it->flags & ATT_PROPERTY_DYNAMIC) == 0) return; 1958ac574d6SMatthias Ringwald att_read_callback_t callback = att_read_callback_for_handle(it->handle); 1968ac574d6SMatthias Ringwald if (!callback) return; 1978ac574d6SMatthias Ringwald it->value_len = (*callback)(con_handle, it->handle, 0, NULL, 0); 198591423b2SMatthias Ringwald return; 199591423b2SMatthias Ringwald } 200591423b2SMatthias Ringwald 201591423b2SMatthias Ringwald // copy attribute value from offset into buffer with given size 202711e6c80SMatthias Ringwald static int att_copy_value(att_iterator_t *it, uint16_t offset, uint8_t * buffer, uint16_t buffer_size, hci_con_handle_t con_handle){ 203591423b2SMatthias Ringwald 204591423b2SMatthias Ringwald // DYNAMIC 2058ac574d6SMatthias Ringwald if (it->flags & ATT_PROPERTY_DYNAMIC){ 2068ac574d6SMatthias Ringwald att_read_callback_t callback = att_read_callback_for_handle(it->handle); 2078ac574d6SMatthias Ringwald if (!callback) return 0; 2088ac574d6SMatthias Ringwald return (*callback)(con_handle, it->handle, offset, buffer, buffer_size); 209591423b2SMatthias Ringwald } 210591423b2SMatthias Ringwald 211591423b2SMatthias Ringwald // STATIC 212591423b2SMatthias Ringwald uint16_t bytes_to_copy = it->value_len - offset; 213591423b2SMatthias Ringwald if (bytes_to_copy > buffer_size){ 214591423b2SMatthias Ringwald bytes_to_copy = buffer_size; 215591423b2SMatthias Ringwald } 216591423b2SMatthias Ringwald memcpy(buffer, it->value, bytes_to_copy); 217591423b2SMatthias Ringwald return bytes_to_copy; 218591423b2SMatthias Ringwald } 219591423b2SMatthias Ringwald 220591423b2SMatthias Ringwald void att_set_db(uint8_t const * db){ 221591423b2SMatthias Ringwald att_db = db; 222591423b2SMatthias Ringwald } 223591423b2SMatthias Ringwald 224591423b2SMatthias Ringwald void att_set_read_callback(att_read_callback_t callback){ 225591423b2SMatthias Ringwald att_read_callback = callback; 226591423b2SMatthias Ringwald } 227591423b2SMatthias Ringwald 228591423b2SMatthias Ringwald void att_set_write_callback(att_write_callback_t callback){ 229591423b2SMatthias Ringwald att_write_callback = callback; 230591423b2SMatthias Ringwald } 231591423b2SMatthias Ringwald 232591423b2SMatthias Ringwald void att_dump_attributes(void){ 233591423b2SMatthias Ringwald att_iterator_t it; 234591423b2SMatthias Ringwald att_iterator_init(&it); 235591423b2SMatthias Ringwald uint8_t uuid128[16]; 236591423b2SMatthias Ringwald while (att_iterator_has_next(&it)){ 237591423b2SMatthias Ringwald att_iterator_fetch_next(&it); 238591423b2SMatthias Ringwald if (it.handle == 0) { 239591423b2SMatthias Ringwald log_info("Handle: END"); 240591423b2SMatthias Ringwald return; 241591423b2SMatthias Ringwald } 242591423b2SMatthias Ringwald log_info("Handle: 0x%04x, flags: 0x%04x, uuid: ", it.handle, it.flags); 243591423b2SMatthias Ringwald if (it.flags & ATT_PROPERTY_UUID128){ 244591423b2SMatthias Ringwald reverse_128(it.uuid, uuid128); 245591423b2SMatthias Ringwald log_info("%s", uuid128_to_str(uuid128)); 246591423b2SMatthias Ringwald } else { 247591423b2SMatthias Ringwald log_info("%04x", little_endian_read_16(it.uuid, 0)); 248591423b2SMatthias Ringwald } 249591423b2SMatthias Ringwald log_info(", value_len: %u, value: ", it.value_len); 250591423b2SMatthias Ringwald log_info_hexdump(it.value, it.value_len); 251591423b2SMatthias Ringwald } 252591423b2SMatthias Ringwald } 253591423b2SMatthias Ringwald 254591423b2SMatthias Ringwald static void att_prepare_write_reset(void){ 255591423b2SMatthias Ringwald att_prepare_write_error_code = 0; 256591423b2SMatthias Ringwald att_prepare_write_error_handle = 0x0000; 257591423b2SMatthias Ringwald } 258591423b2SMatthias Ringwald 259591423b2SMatthias Ringwald static void att_prepare_write_update_errors(uint8_t error_code, uint16_t handle){ 260591423b2SMatthias Ringwald // first ATT_ERROR_INVALID_ATTRIBUTE_VALUE_LENGTH has highest priority 261591423b2SMatthias Ringwald if (error_code == ATT_ERROR_INVALID_ATTRIBUTE_VALUE_LENGTH && error_code != att_prepare_write_error_code){ 262591423b2SMatthias Ringwald att_prepare_write_error_code = error_code; 263591423b2SMatthias Ringwald att_prepare_write_error_handle = handle; 264591423b2SMatthias Ringwald return; 265591423b2SMatthias Ringwald } 266591423b2SMatthias Ringwald // first ATT_ERROR_INVALID_OFFSET is next 267591423b2SMatthias Ringwald if (error_code == ATT_ERROR_INVALID_OFFSET && att_prepare_write_error_code == 0){ 268591423b2SMatthias Ringwald att_prepare_write_error_code = error_code; 269591423b2SMatthias Ringwald att_prepare_write_error_handle = handle; 270591423b2SMatthias Ringwald return; 271591423b2SMatthias Ringwald } 272591423b2SMatthias Ringwald } 273591423b2SMatthias Ringwald 274591423b2SMatthias Ringwald static uint16_t setup_error(uint8_t * response_buffer, uint16_t request, uint16_t handle, uint8_t error_code){ 275591423b2SMatthias Ringwald response_buffer[0] = ATT_ERROR_RESPONSE; 276591423b2SMatthias Ringwald response_buffer[1] = request; 277591423b2SMatthias Ringwald little_endian_store_16(response_buffer, 2, handle); 278591423b2SMatthias Ringwald response_buffer[4] = error_code; 279591423b2SMatthias Ringwald return 5; 280591423b2SMatthias Ringwald } 281591423b2SMatthias Ringwald 282591423b2SMatthias Ringwald static inline uint16_t setup_error_read_not_permitted(uint8_t * response_buffer, uint16_t request, uint16_t start_handle){ 283591423b2SMatthias Ringwald return setup_error(response_buffer, request, start_handle, ATT_ERROR_READ_NOT_PERMITTED); 284591423b2SMatthias Ringwald } 285591423b2SMatthias Ringwald 286591423b2SMatthias Ringwald static inline uint16_t setup_error_write_not_permitted(uint8_t * response_buffer, uint16_t request, uint16_t start_handle){ 287591423b2SMatthias Ringwald return setup_error(response_buffer, request, start_handle, ATT_ERROR_WRITE_NOT_PERMITTED); 288591423b2SMatthias Ringwald } 289591423b2SMatthias Ringwald 290591423b2SMatthias Ringwald static inline uint16_t setup_error_atribute_not_found(uint8_t * response_buffer, uint16_t request, uint16_t start_handle){ 291591423b2SMatthias Ringwald return setup_error(response_buffer, request, start_handle, ATT_ERROR_ATTRIBUTE_NOT_FOUND); 292591423b2SMatthias Ringwald } 293591423b2SMatthias Ringwald 294591423b2SMatthias Ringwald static inline uint16_t setup_error_invalid_handle(uint8_t * response_buffer, uint16_t request, uint16_t handle){ 295591423b2SMatthias Ringwald return setup_error(response_buffer, request, handle, ATT_ERROR_INVALID_HANDLE); 296591423b2SMatthias Ringwald } 297591423b2SMatthias Ringwald 298591423b2SMatthias Ringwald static inline uint16_t setup_error_invalid_offset(uint8_t * response_buffer, uint16_t request, uint16_t handle){ 299591423b2SMatthias Ringwald return setup_error(response_buffer, request, handle, ATT_ERROR_INVALID_OFFSET); 300591423b2SMatthias Ringwald } 301591423b2SMatthias Ringwald 302591423b2SMatthias Ringwald static uint8_t att_validate_security(att_connection_t * att_connection, att_iterator_t * it){ 303591423b2SMatthias Ringwald int required_encryption_size = it->flags >> 12; 304591423b2SMatthias Ringwald if (required_encryption_size) required_encryption_size++; // store -1 to fit into 4 bit 305591423b2SMatthias Ringwald log_info("att_validate_security. flags 0x%04x - req enc size %u, authorized %u, authenticated %u, encryption_key_size %u", 306591423b2SMatthias Ringwald it->flags, required_encryption_size, att_connection->authorized, att_connection->authenticated, att_connection->encryption_key_size); 307591423b2SMatthias Ringwald if ((it->flags & ATT_PROPERTY_AUTHENTICATION_REQUIRED) && att_connection->authenticated == 0) { 308591423b2SMatthias Ringwald return ATT_ERROR_INSUFFICIENT_AUTHENTICATION; 309591423b2SMatthias Ringwald } 310591423b2SMatthias Ringwald if ((it->flags & ATT_PROPERTY_AUTHORIZATION_REQUIRED) && att_connection->authorized == 0) { 311591423b2SMatthias Ringwald return ATT_ERROR_INSUFFICIENT_AUTHORIZATION; 312591423b2SMatthias Ringwald } 313591423b2SMatthias Ringwald if (required_encryption_size > 0 && att_connection->encryption_key_size == 0){ 314591423b2SMatthias Ringwald return ATT_ERROR_INSUFFICIENT_ENCRYPTION; 315591423b2SMatthias Ringwald } 316591423b2SMatthias Ringwald if (required_encryption_size > att_connection->encryption_key_size){ 317591423b2SMatthias Ringwald return ATT_ERROR_INSUFFICIENT_ENCRYPTION_KEY_SIZE; 318591423b2SMatthias Ringwald } 319591423b2SMatthias Ringwald return 0; 320591423b2SMatthias Ringwald } 321591423b2SMatthias Ringwald 322591423b2SMatthias Ringwald // 323591423b2SMatthias Ringwald // MARK: ATT_EXCHANGE_MTU_REQUEST 324591423b2SMatthias Ringwald // 325591423b2SMatthias Ringwald static uint16_t handle_exchange_mtu_request(att_connection_t * att_connection, uint8_t * request_buffer, uint16_t request_len, 326591423b2SMatthias Ringwald uint8_t * response_buffer){ 327591423b2SMatthias Ringwald 3289ec2630cSMatthias Ringwald UNUSED(request_len); 3299ec2630cSMatthias Ringwald 330591423b2SMatthias Ringwald uint16_t client_rx_mtu = little_endian_read_16(request_buffer, 1); 331591423b2SMatthias Ringwald 332591423b2SMatthias Ringwald // find min(local max mtu, remote mtu) and use as mtu for this connection 333591423b2SMatthias Ringwald if (client_rx_mtu < att_connection->max_mtu){ 334591423b2SMatthias Ringwald att_connection->mtu = client_rx_mtu; 335591423b2SMatthias Ringwald } else { 336591423b2SMatthias Ringwald att_connection->mtu = att_connection->max_mtu; 337591423b2SMatthias Ringwald } 338591423b2SMatthias Ringwald 339591423b2SMatthias Ringwald response_buffer[0] = ATT_EXCHANGE_MTU_RESPONSE; 340591423b2SMatthias Ringwald little_endian_store_16(response_buffer, 1, att_connection->mtu); 341591423b2SMatthias Ringwald return 3; 342591423b2SMatthias Ringwald } 343591423b2SMatthias Ringwald 344591423b2SMatthias Ringwald 345591423b2SMatthias Ringwald // 346591423b2SMatthias Ringwald // MARK: ATT_FIND_INFORMATION_REQUEST 347591423b2SMatthias Ringwald // 348591423b2SMatthias Ringwald // TODO: handle other types then GATT_PRIMARY_SERVICE_UUID and GATT_SECONDARY_SERVICE_UUID 349591423b2SMatthias Ringwald // 350591423b2SMatthias Ringwald static uint16_t handle_find_information_request2(att_connection_t * att_connection, uint8_t * response_buffer, uint16_t response_buffer_size, 351591423b2SMatthias Ringwald uint16_t start_handle, uint16_t end_handle){ 352591423b2SMatthias Ringwald 3539ec2630cSMatthias Ringwald UNUSED(att_connection); 3549ec2630cSMatthias Ringwald 355591423b2SMatthias Ringwald log_info("ATT_FIND_INFORMATION_REQUEST: from %04X to %04X", start_handle, end_handle); 356591423b2SMatthias Ringwald uint8_t request_type = ATT_FIND_INFORMATION_REQUEST; 357591423b2SMatthias Ringwald 358591423b2SMatthias Ringwald if (start_handle > end_handle || start_handle == 0){ 359591423b2SMatthias Ringwald return setup_error_invalid_handle(response_buffer, request_type, start_handle); 360591423b2SMatthias Ringwald } 361591423b2SMatthias Ringwald 362591423b2SMatthias Ringwald uint16_t offset = 1; 363591423b2SMatthias Ringwald uint16_t uuid_len = 0; 364591423b2SMatthias Ringwald 365591423b2SMatthias Ringwald att_iterator_t it; 366591423b2SMatthias Ringwald att_iterator_init(&it); 367591423b2SMatthias Ringwald while (att_iterator_has_next(&it)){ 368591423b2SMatthias Ringwald att_iterator_fetch_next(&it); 369591423b2SMatthias Ringwald if (!it.handle) break; 370591423b2SMatthias Ringwald if (it.handle > end_handle) break; 371591423b2SMatthias Ringwald if (it.handle < start_handle) continue; 372591423b2SMatthias Ringwald 373591423b2SMatthias Ringwald // log_info("Handle 0x%04x", it.handle); 374591423b2SMatthias Ringwald 375591423b2SMatthias Ringwald uint16_t this_uuid_len = (it.flags & ATT_PROPERTY_UUID128) ? 16 : 2; 376591423b2SMatthias Ringwald 377591423b2SMatthias Ringwald // check if value has same len as last one if not first result 378591423b2SMatthias Ringwald if (offset > 1){ 379591423b2SMatthias Ringwald if (this_uuid_len != uuid_len) { 380591423b2SMatthias Ringwald break; 381591423b2SMatthias Ringwald } 382591423b2SMatthias Ringwald } 383591423b2SMatthias Ringwald 384591423b2SMatthias Ringwald // first 385591423b2SMatthias Ringwald if (offset == 1) { 386591423b2SMatthias Ringwald uuid_len = this_uuid_len; 387591423b2SMatthias Ringwald // set format field 388591423b2SMatthias Ringwald response_buffer[offset] = (it.flags & ATT_PROPERTY_UUID128) ? 0x02 : 0x01; 389591423b2SMatthias Ringwald offset++; 390591423b2SMatthias Ringwald } 391591423b2SMatthias Ringwald 392591423b2SMatthias Ringwald // space? 393591423b2SMatthias Ringwald if (offset + 2 + uuid_len > response_buffer_size) break; 394591423b2SMatthias Ringwald 395591423b2SMatthias Ringwald // store 396591423b2SMatthias Ringwald little_endian_store_16(response_buffer, offset, it.handle); 397591423b2SMatthias Ringwald offset += 2; 398591423b2SMatthias Ringwald 399591423b2SMatthias Ringwald memcpy(response_buffer + offset, it.uuid, uuid_len); 400591423b2SMatthias Ringwald offset += uuid_len; 401591423b2SMatthias Ringwald } 402591423b2SMatthias Ringwald 403591423b2SMatthias Ringwald if (offset == 1){ 404591423b2SMatthias Ringwald return setup_error_atribute_not_found(response_buffer, request_type, start_handle); 405591423b2SMatthias Ringwald } 406591423b2SMatthias Ringwald 407591423b2SMatthias Ringwald response_buffer[0] = ATT_FIND_INFORMATION_REPLY; 408591423b2SMatthias Ringwald return offset; 409591423b2SMatthias Ringwald } 410591423b2SMatthias Ringwald 411591423b2SMatthias Ringwald static uint16_t handle_find_information_request(att_connection_t * att_connection, uint8_t * request_buffer, uint16_t request_len, 412591423b2SMatthias Ringwald uint8_t * response_buffer, uint16_t response_buffer_size){ 4139ec2630cSMatthias Ringwald UNUSED(request_len); 414591423b2SMatthias Ringwald return handle_find_information_request2(att_connection, response_buffer, response_buffer_size, little_endian_read_16(request_buffer, 1), little_endian_read_16(request_buffer, 3)); 415591423b2SMatthias Ringwald } 416591423b2SMatthias Ringwald 417591423b2SMatthias Ringwald // 418591423b2SMatthias Ringwald // MARK: ATT_FIND_BY_TYPE_VALUE 419591423b2SMatthias Ringwald // 420591423b2SMatthias Ringwald // "Only attributes with attribute handles between and including the Starting Handle parameter 421591423b2SMatthias Ringwald // and the Ending Handle parameter that match the requested attri- bute type and the attribute 422591423b2SMatthias Ringwald // value that have sufficient permissions to allow reading will be returned" -> (1) 423591423b2SMatthias Ringwald // 424591423b2SMatthias Ringwald // TODO: handle other types then GATT_PRIMARY_SERVICE_UUID and GATT_SECONDARY_SERVICE_UUID 425591423b2SMatthias Ringwald // 426591423b2SMatthias Ringwald // NOTE: doesn't handle DYNAMIC values 427591423b2SMatthias Ringwald // NOTE: only supports 16 bit UUIDs 428591423b2SMatthias Ringwald // 429591423b2SMatthias Ringwald static uint16_t handle_find_by_type_value_request2(att_connection_t * att_connection, uint8_t * response_buffer, uint16_t response_buffer_size, 430591423b2SMatthias Ringwald uint16_t start_handle, uint16_t end_handle, 431591423b2SMatthias Ringwald uint16_t attribute_type, uint16_t attribute_len, uint8_t* attribute_value){ 432591423b2SMatthias Ringwald 4339ec2630cSMatthias Ringwald UNUSED(att_connection); 4349ec2630cSMatthias Ringwald 435591423b2SMatthias Ringwald log_info("ATT_FIND_BY_TYPE_VALUE_REQUEST: from %04X to %04X, type %04X, value: ", start_handle, end_handle, attribute_type); 436591423b2SMatthias Ringwald log_info_hexdump(attribute_value, attribute_len); 437591423b2SMatthias Ringwald uint8_t request_type = ATT_FIND_BY_TYPE_VALUE_REQUEST; 438591423b2SMatthias Ringwald 439591423b2SMatthias Ringwald if (start_handle > end_handle || start_handle == 0){ 440591423b2SMatthias Ringwald return setup_error_invalid_handle(response_buffer, request_type, start_handle); 441591423b2SMatthias Ringwald } 442591423b2SMatthias Ringwald 443591423b2SMatthias Ringwald uint16_t offset = 1; 444591423b2SMatthias Ringwald uint16_t in_group = 0; 445591423b2SMatthias Ringwald uint16_t prev_handle = 0; 446591423b2SMatthias Ringwald 447591423b2SMatthias Ringwald att_iterator_t it; 448591423b2SMatthias Ringwald att_iterator_init(&it); 449591423b2SMatthias Ringwald while (att_iterator_has_next(&it)){ 450591423b2SMatthias Ringwald att_iterator_fetch_next(&it); 451591423b2SMatthias Ringwald 452591423b2SMatthias Ringwald if (it.handle && it.handle < start_handle) continue; 453591423b2SMatthias Ringwald if (it.handle > end_handle) break; // (1) 454591423b2SMatthias Ringwald 455591423b2SMatthias Ringwald // close current tag, if within a group and a new service definition starts or we reach end of att db 456591423b2SMatthias Ringwald if (in_group && 457591423b2SMatthias Ringwald (it.handle == 0 || att_iterator_match_uuid16(&it, GATT_PRIMARY_SERVICE_UUID) || att_iterator_match_uuid16(&it, GATT_SECONDARY_SERVICE_UUID))){ 458591423b2SMatthias Ringwald 459591423b2SMatthias Ringwald log_info("End of group, handle 0x%04x", prev_handle); 460591423b2SMatthias Ringwald little_endian_store_16(response_buffer, offset, prev_handle); 461591423b2SMatthias Ringwald offset += 2; 462591423b2SMatthias Ringwald in_group = 0; 463591423b2SMatthias Ringwald 464591423b2SMatthias Ringwald // check if space for another handle pair available 465591423b2SMatthias Ringwald if (offset + 4 > response_buffer_size){ 466591423b2SMatthias Ringwald break; 467591423b2SMatthias Ringwald } 468591423b2SMatthias Ringwald } 469591423b2SMatthias Ringwald 470591423b2SMatthias Ringwald // keep track of previous handle 471591423b2SMatthias Ringwald prev_handle = it.handle; 472591423b2SMatthias Ringwald 473591423b2SMatthias Ringwald // does current attribute match 474591423b2SMatthias Ringwald if (it.handle && att_iterator_match_uuid16(&it, attribute_type) && attribute_len == it.value_len && memcmp(attribute_value, it.value, it.value_len) == 0){ 475591423b2SMatthias Ringwald log_info("Begin of group, handle 0x%04x", it.handle); 476591423b2SMatthias Ringwald little_endian_store_16(response_buffer, offset, it.handle); 477591423b2SMatthias Ringwald offset += 2; 478591423b2SMatthias Ringwald in_group = 1; 479591423b2SMatthias Ringwald } 480591423b2SMatthias Ringwald } 481591423b2SMatthias Ringwald 482591423b2SMatthias Ringwald if (offset == 1){ 483591423b2SMatthias Ringwald return setup_error_atribute_not_found(response_buffer, request_type, start_handle); 484591423b2SMatthias Ringwald } 485591423b2SMatthias Ringwald 486591423b2SMatthias Ringwald response_buffer[0] = ATT_FIND_BY_TYPE_VALUE_RESPONSE; 487591423b2SMatthias Ringwald return offset; 488591423b2SMatthias Ringwald } 489591423b2SMatthias Ringwald 490591423b2SMatthias Ringwald static uint16_t handle_find_by_type_value_request(att_connection_t * att_connection, uint8_t * request_buffer, uint16_t request_len, 491591423b2SMatthias Ringwald uint8_t * response_buffer, uint16_t response_buffer_size){ 492591423b2SMatthias Ringwald int attribute_len = request_len - 7; 493591423b2SMatthias Ringwald return handle_find_by_type_value_request2(att_connection, response_buffer, response_buffer_size, little_endian_read_16(request_buffer, 1), 494591423b2SMatthias Ringwald little_endian_read_16(request_buffer, 3), little_endian_read_16(request_buffer, 5), attribute_len, &request_buffer[7]); 495591423b2SMatthias Ringwald } 496591423b2SMatthias Ringwald 497591423b2SMatthias Ringwald // 498591423b2SMatthias Ringwald // MARK: ATT_READ_BY_TYPE_REQUEST 499591423b2SMatthias Ringwald // 500591423b2SMatthias Ringwald static uint16_t handle_read_by_type_request2(att_connection_t * att_connection, uint8_t * response_buffer, uint16_t response_buffer_size, 501591423b2SMatthias Ringwald uint16_t start_handle, uint16_t end_handle, 502591423b2SMatthias Ringwald uint16_t attribute_type_len, uint8_t * attribute_type){ 503591423b2SMatthias Ringwald 504591423b2SMatthias Ringwald log_info("ATT_READ_BY_TYPE_REQUEST: from %04X to %04X, type: ", start_handle, end_handle); 505591423b2SMatthias Ringwald log_info_hexdump(attribute_type, attribute_type_len); 506591423b2SMatthias Ringwald uint8_t request_type = ATT_READ_BY_TYPE_REQUEST; 507591423b2SMatthias Ringwald 508591423b2SMatthias Ringwald if (start_handle > end_handle || start_handle == 0){ 509591423b2SMatthias Ringwald return setup_error_invalid_handle(response_buffer, request_type, start_handle); 510591423b2SMatthias Ringwald } 511591423b2SMatthias Ringwald 512591423b2SMatthias Ringwald uint16_t offset = 1; 513591423b2SMatthias Ringwald uint16_t pair_len = 0; 514591423b2SMatthias Ringwald 515591423b2SMatthias Ringwald att_iterator_t it; 516591423b2SMatthias Ringwald att_iterator_init(&it); 517591423b2SMatthias Ringwald uint8_t error_code = 0; 518591423b2SMatthias Ringwald uint16_t first_matching_but_unreadable_handle = 0; 519591423b2SMatthias Ringwald 520591423b2SMatthias Ringwald while (att_iterator_has_next(&it)){ 521591423b2SMatthias Ringwald att_iterator_fetch_next(&it); 522591423b2SMatthias Ringwald 523591423b2SMatthias Ringwald if (!it.handle) break; 524591423b2SMatthias Ringwald if (it.handle < start_handle) continue; 525591423b2SMatthias Ringwald if (it.handle > end_handle) break; // (1) 526591423b2SMatthias Ringwald 527591423b2SMatthias Ringwald // does current attribute match 528591423b2SMatthias Ringwald if (!att_iterator_match_uuid(&it, attribute_type, attribute_type_len)) continue; 529591423b2SMatthias Ringwald 530591423b2SMatthias Ringwald // skip handles that cannot be read but rembember that there has been at least one 531591423b2SMatthias Ringwald if ((it.flags & ATT_PROPERTY_READ) == 0) { 532591423b2SMatthias Ringwald if (first_matching_but_unreadable_handle == 0) { 533591423b2SMatthias Ringwald first_matching_but_unreadable_handle = it.handle; 534591423b2SMatthias Ringwald } 535591423b2SMatthias Ringwald continue; 536591423b2SMatthias Ringwald } 537591423b2SMatthias Ringwald 538591423b2SMatthias Ringwald // check security requirements 539*eb6072adSMatthias Ringwald if ((it.flags & ATT_DB_FLAGS_READ_WITHOUT_AUTHENTICATION) == 0){ 540591423b2SMatthias Ringwald error_code = att_validate_security(att_connection, &it); 541591423b2SMatthias Ringwald if (error_code) break; 542*eb6072adSMatthias Ringwald } 543591423b2SMatthias Ringwald 544591423b2SMatthias Ringwald att_update_value_len(&it, att_connection->con_handle); 545591423b2SMatthias Ringwald 546591423b2SMatthias Ringwald // check if value has same len as last one 547591423b2SMatthias Ringwald uint16_t this_pair_len = 2 + it.value_len; 548591423b2SMatthias Ringwald if (offset > 1){ 549591423b2SMatthias Ringwald if (pair_len != this_pair_len) { 550591423b2SMatthias Ringwald break; 551591423b2SMatthias Ringwald } 552591423b2SMatthias Ringwald } 553591423b2SMatthias Ringwald 554591423b2SMatthias Ringwald // first 555591423b2SMatthias Ringwald if (offset == 1) { 556591423b2SMatthias Ringwald pair_len = this_pair_len; 557591423b2SMatthias Ringwald response_buffer[offset] = pair_len; 558591423b2SMatthias Ringwald offset++; 559591423b2SMatthias Ringwald } 560591423b2SMatthias Ringwald 561591423b2SMatthias Ringwald // space? 562591423b2SMatthias Ringwald if (offset + pair_len > response_buffer_size) { 563591423b2SMatthias Ringwald if (offset > 2) break; 564591423b2SMatthias Ringwald it.value_len = response_buffer_size - 4; 565591423b2SMatthias Ringwald response_buffer[1] = 2 + it.value_len; 566591423b2SMatthias Ringwald } 567591423b2SMatthias Ringwald 568591423b2SMatthias Ringwald // store 569591423b2SMatthias Ringwald little_endian_store_16(response_buffer, offset, it.handle); 570591423b2SMatthias Ringwald offset += 2; 571591423b2SMatthias Ringwald uint16_t bytes_copied = att_copy_value(&it, 0, response_buffer + offset, it.value_len, att_connection->con_handle); 572591423b2SMatthias Ringwald offset += bytes_copied; 573591423b2SMatthias Ringwald } 574591423b2SMatthias Ringwald 575591423b2SMatthias Ringwald // at least one attribute could be read 576591423b2SMatthias Ringwald if (offset > 1){ 577591423b2SMatthias Ringwald response_buffer[0] = ATT_READ_BY_TYPE_RESPONSE; 578591423b2SMatthias Ringwald return offset; 579591423b2SMatthias Ringwald } 580591423b2SMatthias Ringwald 581591423b2SMatthias Ringwald // first attribute had an error 582591423b2SMatthias Ringwald if (error_code){ 583591423b2SMatthias Ringwald return setup_error(response_buffer, request_type, start_handle, error_code); 584591423b2SMatthias Ringwald } 585591423b2SMatthias Ringwald 586591423b2SMatthias Ringwald // no other errors, but all found attributes had been non-readable 587591423b2SMatthias Ringwald if (first_matching_but_unreadable_handle){ 588591423b2SMatthias Ringwald return setup_error_read_not_permitted(response_buffer, request_type, first_matching_but_unreadable_handle); 589591423b2SMatthias Ringwald } 590591423b2SMatthias Ringwald 591591423b2SMatthias Ringwald // attribute not found 592591423b2SMatthias Ringwald return setup_error_atribute_not_found(response_buffer, request_type, start_handle); 593591423b2SMatthias Ringwald } 594591423b2SMatthias Ringwald 595591423b2SMatthias Ringwald static uint16_t handle_read_by_type_request(att_connection_t * att_connection, uint8_t * request_buffer, uint16_t request_len, 596591423b2SMatthias Ringwald uint8_t * response_buffer, uint16_t response_buffer_size){ 597591423b2SMatthias Ringwald int attribute_type_len; 598591423b2SMatthias Ringwald if (request_len <= 7){ 599591423b2SMatthias Ringwald attribute_type_len = 2; 600591423b2SMatthias Ringwald } else { 601591423b2SMatthias Ringwald attribute_type_len = 16; 602591423b2SMatthias Ringwald } 603591423b2SMatthias Ringwald return handle_read_by_type_request2(att_connection, response_buffer, response_buffer_size, little_endian_read_16(request_buffer, 1), little_endian_read_16(request_buffer, 3), attribute_type_len, &request_buffer[5]); 604591423b2SMatthias Ringwald } 605591423b2SMatthias Ringwald 606591423b2SMatthias Ringwald // 607591423b2SMatthias Ringwald // MARK: ATT_READ_BY_TYPE_REQUEST 608591423b2SMatthias Ringwald // 609591423b2SMatthias Ringwald static uint16_t handle_read_request2(att_connection_t * att_connection, uint8_t * response_buffer, uint16_t response_buffer_size, uint16_t handle){ 610591423b2SMatthias Ringwald 611591423b2SMatthias Ringwald log_info("ATT_READ_REQUEST: handle %04x", handle); 612591423b2SMatthias Ringwald uint8_t request_type = ATT_READ_REQUEST; 613591423b2SMatthias Ringwald 614591423b2SMatthias Ringwald att_iterator_t it; 615591423b2SMatthias Ringwald int ok = att_find_handle(&it, handle); 616591423b2SMatthias Ringwald if (!ok){ 617591423b2SMatthias Ringwald return setup_error_invalid_handle(response_buffer, request_type, handle); 618591423b2SMatthias Ringwald } 619591423b2SMatthias Ringwald 620591423b2SMatthias Ringwald // check if handle can be read 621591423b2SMatthias Ringwald if ((it.flags & ATT_PROPERTY_READ) == 0) { 622591423b2SMatthias Ringwald return setup_error_read_not_permitted(response_buffer, request_type, handle); 623591423b2SMatthias Ringwald } 624591423b2SMatthias Ringwald 625591423b2SMatthias Ringwald // check security requirements 626*eb6072adSMatthias Ringwald if ((it.flags & ATT_DB_FLAGS_READ_WITHOUT_AUTHENTICATION) == 0){ 627591423b2SMatthias Ringwald uint8_t error_code = att_validate_security(att_connection, &it); 628591423b2SMatthias Ringwald if (error_code) { 629591423b2SMatthias Ringwald return setup_error(response_buffer, request_type, handle, error_code); 630591423b2SMatthias Ringwald } 631*eb6072adSMatthias Ringwald } 632591423b2SMatthias Ringwald 633591423b2SMatthias Ringwald att_update_value_len(&it, att_connection->con_handle); 634591423b2SMatthias Ringwald 635591423b2SMatthias Ringwald uint16_t offset = 1; 636591423b2SMatthias Ringwald // limit data 637591423b2SMatthias Ringwald if (offset + it.value_len > response_buffer_size) { 638591423b2SMatthias Ringwald it.value_len = response_buffer_size - 1; 639591423b2SMatthias Ringwald } 640591423b2SMatthias Ringwald 641591423b2SMatthias Ringwald // store 642591423b2SMatthias Ringwald uint16_t bytes_copied = att_copy_value(&it, 0, response_buffer + offset, it.value_len, att_connection->con_handle); 643591423b2SMatthias Ringwald offset += bytes_copied; 644591423b2SMatthias Ringwald 645591423b2SMatthias Ringwald response_buffer[0] = ATT_READ_RESPONSE; 646591423b2SMatthias Ringwald return offset; 647591423b2SMatthias Ringwald } 648591423b2SMatthias Ringwald 649591423b2SMatthias Ringwald static uint16_t handle_read_request(att_connection_t * att_connection, uint8_t * request_buffer, uint16_t request_len, 650591423b2SMatthias Ringwald uint8_t * response_buffer, uint16_t response_buffer_size){ 6519ec2630cSMatthias Ringwald UNUSED(request_len); 652591423b2SMatthias Ringwald return handle_read_request2(att_connection, response_buffer, response_buffer_size, little_endian_read_16(request_buffer, 1)); 653591423b2SMatthias Ringwald } 654591423b2SMatthias Ringwald 655591423b2SMatthias Ringwald // 656591423b2SMatthias Ringwald // MARK: ATT_READ_BLOB_REQUEST 0x0c 657591423b2SMatthias Ringwald // 658591423b2SMatthias Ringwald static uint16_t handle_read_blob_request2(att_connection_t * att_connection, uint8_t * response_buffer, uint16_t response_buffer_size, uint16_t handle, uint16_t value_offset){ 659591423b2SMatthias Ringwald log_info("ATT_READ_BLOB_REQUEST: handle %04x, offset %u", handle, value_offset); 660591423b2SMatthias Ringwald uint8_t request_type = ATT_READ_BLOB_REQUEST; 661591423b2SMatthias Ringwald 662591423b2SMatthias Ringwald att_iterator_t it; 663591423b2SMatthias Ringwald int ok = att_find_handle(&it, handle); 664591423b2SMatthias Ringwald if (!ok){ 665591423b2SMatthias Ringwald return setup_error_invalid_handle(response_buffer, request_type, handle); 666591423b2SMatthias Ringwald } 667591423b2SMatthias Ringwald 668591423b2SMatthias Ringwald // check if handle can be read 669591423b2SMatthias Ringwald if ((it.flags & ATT_PROPERTY_READ) == 0) { 670591423b2SMatthias Ringwald return setup_error_read_not_permitted(response_buffer, request_type, handle); 671591423b2SMatthias Ringwald } 672591423b2SMatthias Ringwald 673591423b2SMatthias Ringwald // check security requirements 674*eb6072adSMatthias Ringwald if ((it.flags & ATT_DB_FLAGS_READ_WITHOUT_AUTHENTICATION) == 0){ 675591423b2SMatthias Ringwald uint8_t error_code = att_validate_security(att_connection, &it); 676591423b2SMatthias Ringwald if (error_code) { 677591423b2SMatthias Ringwald return setup_error(response_buffer, request_type, handle, error_code); 678591423b2SMatthias Ringwald } 679*eb6072adSMatthias Ringwald } 680591423b2SMatthias Ringwald 681591423b2SMatthias Ringwald att_update_value_len(&it, att_connection->con_handle); 682591423b2SMatthias Ringwald 683591423b2SMatthias Ringwald if (value_offset > it.value_len){ 684591423b2SMatthias Ringwald return setup_error_invalid_offset(response_buffer, request_type, handle); 685591423b2SMatthias Ringwald } 686591423b2SMatthias Ringwald 687591423b2SMatthias Ringwald // limit data 688591423b2SMatthias Ringwald uint16_t offset = 1; 689591423b2SMatthias Ringwald if (offset + it.value_len - value_offset > response_buffer_size) { 690591423b2SMatthias Ringwald it.value_len = response_buffer_size - 1 + value_offset; 691591423b2SMatthias Ringwald } 692591423b2SMatthias Ringwald 693591423b2SMatthias Ringwald // store 694591423b2SMatthias Ringwald uint16_t bytes_copied = att_copy_value(&it, value_offset, response_buffer + offset, it.value_len - value_offset, att_connection->con_handle); 695591423b2SMatthias Ringwald offset += bytes_copied; 696591423b2SMatthias Ringwald 697591423b2SMatthias Ringwald response_buffer[0] = ATT_READ_BLOB_RESPONSE; 698591423b2SMatthias Ringwald return offset; 699591423b2SMatthias Ringwald } 700591423b2SMatthias Ringwald 701591423b2SMatthias Ringwald static uint16_t handle_read_blob_request(att_connection_t * att_connection, uint8_t * request_buffer, uint16_t request_len, 702591423b2SMatthias Ringwald uint8_t * response_buffer, uint16_t response_buffer_size){ 7039ec2630cSMatthias Ringwald UNUSED(request_len); 704591423b2SMatthias Ringwald return handle_read_blob_request2(att_connection, response_buffer, response_buffer_size, little_endian_read_16(request_buffer, 1), little_endian_read_16(request_buffer, 3)); 705591423b2SMatthias Ringwald } 706591423b2SMatthias Ringwald 707591423b2SMatthias Ringwald // 708591423b2SMatthias Ringwald // MARK: ATT_READ_MULTIPLE_REQUEST 0x0e 709591423b2SMatthias Ringwald // 710591423b2SMatthias Ringwald static uint16_t handle_read_multiple_request2(att_connection_t * att_connection, uint8_t * response_buffer, uint16_t response_buffer_size, uint16_t num_handles, uint8_t * handles){ 711591423b2SMatthias Ringwald log_info("ATT_READ_MULTIPLE_REQUEST: num handles %u", num_handles); 712591423b2SMatthias Ringwald uint8_t request_type = ATT_READ_MULTIPLE_REQUEST; 713591423b2SMatthias Ringwald 714591423b2SMatthias Ringwald // TODO: figure out which error to respond with 715591423b2SMatthias Ringwald // if (num_handles < 2){ 716591423b2SMatthias Ringwald // return setup_error(response_buffer, ATT_READ_MULTIPLE_REQUEST, handle, ???); 717591423b2SMatthias Ringwald // } 718591423b2SMatthias Ringwald 719591423b2SMatthias Ringwald uint16_t offset = 1; 720591423b2SMatthias Ringwald 721591423b2SMatthias Ringwald int i; 722591423b2SMatthias Ringwald uint8_t error_code = 0; 723591423b2SMatthias Ringwald uint16_t handle = 0; 724591423b2SMatthias Ringwald for (i=0;i<num_handles;i++){ 725591423b2SMatthias Ringwald handle = little_endian_read_16(handles, i << 1); 726591423b2SMatthias Ringwald 727591423b2SMatthias Ringwald if (handle == 0){ 728591423b2SMatthias Ringwald return setup_error_invalid_handle(response_buffer, request_type, handle); 729591423b2SMatthias Ringwald } 730591423b2SMatthias Ringwald 731591423b2SMatthias Ringwald att_iterator_t it; 732591423b2SMatthias Ringwald 733591423b2SMatthias Ringwald int ok = att_find_handle(&it, handle); 734591423b2SMatthias Ringwald if (!ok){ 735591423b2SMatthias Ringwald return setup_error_invalid_handle(response_buffer, request_type, handle); 736591423b2SMatthias Ringwald } 737591423b2SMatthias Ringwald 738591423b2SMatthias Ringwald // check if handle can be read 739591423b2SMatthias Ringwald if ((it.flags & ATT_PROPERTY_READ) == 0) { 740591423b2SMatthias Ringwald error_code = ATT_ERROR_READ_NOT_PERMITTED; 741591423b2SMatthias Ringwald break; 742591423b2SMatthias Ringwald } 743591423b2SMatthias Ringwald 744591423b2SMatthias Ringwald // check security requirements 745*eb6072adSMatthias Ringwald if ((it.flags & ATT_DB_FLAGS_READ_WITHOUT_AUTHENTICATION) == 0){ 746591423b2SMatthias Ringwald error_code = att_validate_security(att_connection, &it); 747591423b2SMatthias Ringwald if (error_code) break; 748*eb6072adSMatthias Ringwald } 749591423b2SMatthias Ringwald att_update_value_len(&it, att_connection->con_handle); 750591423b2SMatthias Ringwald 751591423b2SMatthias Ringwald // limit data 752591423b2SMatthias Ringwald if (offset + it.value_len > response_buffer_size) { 753591423b2SMatthias Ringwald it.value_len = response_buffer_size - 1; 754591423b2SMatthias Ringwald } 755591423b2SMatthias Ringwald 756591423b2SMatthias Ringwald // store 757591423b2SMatthias Ringwald uint16_t bytes_copied = att_copy_value(&it, 0, response_buffer + offset, it.value_len, att_connection->con_handle); 758591423b2SMatthias Ringwald offset += bytes_copied; 759591423b2SMatthias Ringwald } 760591423b2SMatthias Ringwald 761591423b2SMatthias Ringwald if (error_code){ 762591423b2SMatthias Ringwald return setup_error(response_buffer, request_type, handle, error_code); 763591423b2SMatthias Ringwald } 764591423b2SMatthias Ringwald 765591423b2SMatthias Ringwald response_buffer[0] = ATT_READ_MULTIPLE_RESPONSE; 766591423b2SMatthias Ringwald return offset; 767591423b2SMatthias Ringwald } 768591423b2SMatthias Ringwald static uint16_t handle_read_multiple_request(att_connection_t * att_connection, uint8_t * request_buffer, uint16_t request_len, 769591423b2SMatthias Ringwald uint8_t * response_buffer, uint16_t response_buffer_size){ 770591423b2SMatthias Ringwald int num_handles = (request_len - 1) >> 1; 771591423b2SMatthias Ringwald return handle_read_multiple_request2(att_connection, response_buffer, response_buffer_size, num_handles, &request_buffer[1]); 772591423b2SMatthias Ringwald } 773591423b2SMatthias Ringwald 774591423b2SMatthias Ringwald // 775591423b2SMatthias Ringwald // MARK: ATT_READ_BY_GROUP_TYPE_REQUEST 0x10 776591423b2SMatthias Ringwald // 777591423b2SMatthias Ringwald // Only handles GATT_PRIMARY_SERVICE_UUID and GATT_SECONDARY_SERVICE_UUID 778591423b2SMatthias Ringwald // Core v4.0, vol 3, part g, 2.5.3 779591423b2SMatthias Ringwald // "The «Primary Service» and «Secondary Service» grouping types may be used in the Read By Group Type Request. 780591423b2SMatthias Ringwald // The «Characteristic» grouping type shall not be used in the ATT Read By Group Type Request." 781591423b2SMatthias Ringwald // 782591423b2SMatthias Ringwald // NOTE: doesn't handle DYNAMIC values 783591423b2SMatthias Ringwald // 784591423b2SMatthias Ringwald // NOTE: we don't check for security as PRIMARY and SECONDAY SERVICE definition shouldn't be protected 785591423b2SMatthias Ringwald // Core 4.0, vol 3, part g, 8.1 786591423b2SMatthias Ringwald // "The list of services and characteristics that a device supports is not considered private or 787591423b2SMatthias Ringwald // confidential information, and therefore the Service and Characteristic Discovery procedures 788591423b2SMatthias Ringwald // shall always be permitted. " 789591423b2SMatthias Ringwald // 790591423b2SMatthias Ringwald static uint16_t handle_read_by_group_type_request2(att_connection_t * att_connection, uint8_t * response_buffer, uint16_t response_buffer_size, 791591423b2SMatthias Ringwald uint16_t start_handle, uint16_t end_handle, 792591423b2SMatthias Ringwald uint16_t attribute_type_len, uint8_t * attribute_type){ 793591423b2SMatthias Ringwald 7949ec2630cSMatthias Ringwald UNUSED(att_connection); 7959ec2630cSMatthias Ringwald 796591423b2SMatthias Ringwald log_info("ATT_READ_BY_GROUP_TYPE_REQUEST: from %04X to %04X, buffer size %u, type: ", start_handle, end_handle, response_buffer_size); 797591423b2SMatthias Ringwald log_info_hexdump(attribute_type, attribute_type_len); 798591423b2SMatthias Ringwald uint8_t request_type = ATT_READ_BY_GROUP_TYPE_REQUEST; 799591423b2SMatthias Ringwald 800591423b2SMatthias Ringwald if (start_handle > end_handle || start_handle == 0){ 801591423b2SMatthias Ringwald return setup_error_invalid_handle(response_buffer, request_type, start_handle); 802591423b2SMatthias Ringwald } 803591423b2SMatthias Ringwald 804591423b2SMatthias Ringwald // assert UUID is primary or secondary service uuid 805591423b2SMatthias Ringwald uint16_t uuid16 = uuid16_from_uuid(attribute_type_len, attribute_type); 806591423b2SMatthias Ringwald if (uuid16 != GATT_PRIMARY_SERVICE_UUID && uuid16 != GATT_SECONDARY_SERVICE_UUID){ 807591423b2SMatthias Ringwald return setup_error(response_buffer, request_type, start_handle, ATT_ERROR_UNSUPPORTED_GROUP_TYPE); 808591423b2SMatthias Ringwald } 809591423b2SMatthias Ringwald 810591423b2SMatthias Ringwald uint16_t offset = 1; 811591423b2SMatthias Ringwald uint16_t pair_len = 0; 812591423b2SMatthias Ringwald uint16_t in_group = 0; 813591423b2SMatthias Ringwald uint16_t group_start_handle = 0; 814591423b2SMatthias Ringwald uint8_t const * group_start_value = NULL; 815591423b2SMatthias Ringwald uint16_t prev_handle = 0; 816591423b2SMatthias Ringwald 817591423b2SMatthias Ringwald att_iterator_t it; 818591423b2SMatthias Ringwald att_iterator_init(&it); 819591423b2SMatthias Ringwald while (att_iterator_has_next(&it)){ 820591423b2SMatthias Ringwald att_iterator_fetch_next(&it); 821591423b2SMatthias Ringwald 822591423b2SMatthias Ringwald if (it.handle && it.handle < start_handle) continue; 823591423b2SMatthias Ringwald if (it.handle > end_handle) break; // (1) 824591423b2SMatthias Ringwald 825591423b2SMatthias Ringwald // log_info("Handle 0x%04x", it.handle); 826591423b2SMatthias Ringwald 827591423b2SMatthias Ringwald // close current tag, if within a group and a new service definition starts or we reach end of att db 828591423b2SMatthias Ringwald if (in_group && 829591423b2SMatthias Ringwald (it.handle == 0 || att_iterator_match_uuid16(&it, GATT_PRIMARY_SERVICE_UUID) || att_iterator_match_uuid16(&it, GATT_SECONDARY_SERVICE_UUID))){ 830591423b2SMatthias Ringwald // log_info("End of group, handle 0x%04x, val_len: %u", prev_handle, pair_len - 4); 831591423b2SMatthias Ringwald 832591423b2SMatthias Ringwald little_endian_store_16(response_buffer, offset, group_start_handle); 833591423b2SMatthias Ringwald offset += 2; 834591423b2SMatthias Ringwald little_endian_store_16(response_buffer, offset, prev_handle); 835591423b2SMatthias Ringwald offset += 2; 836591423b2SMatthias Ringwald memcpy(response_buffer + offset, group_start_value, pair_len - 4); 837591423b2SMatthias Ringwald offset += pair_len - 4; 838591423b2SMatthias Ringwald in_group = 0; 839591423b2SMatthias Ringwald 840591423b2SMatthias Ringwald // check if space for another handle pair available 841591423b2SMatthias Ringwald if (offset + pair_len > response_buffer_size){ 842591423b2SMatthias Ringwald break; 843591423b2SMatthias Ringwald } 844591423b2SMatthias Ringwald } 845591423b2SMatthias Ringwald 846591423b2SMatthias Ringwald // keep track of previous handle 847591423b2SMatthias Ringwald prev_handle = it.handle; 848591423b2SMatthias Ringwald 849591423b2SMatthias Ringwald // does current attribute match 850591423b2SMatthias Ringwald // log_info("compare: %04x == %04x", *(uint16_t*) context->attribute_type, *(uint16_t*) uuid); 851591423b2SMatthias Ringwald if (it.handle && att_iterator_match_uuid(&it, attribute_type, attribute_type_len)) { 852591423b2SMatthias Ringwald 853591423b2SMatthias Ringwald // check if value has same len as last one 854591423b2SMatthias Ringwald uint16_t this_pair_len = 4 + it.value_len; 855591423b2SMatthias Ringwald if (offset > 1){ 856591423b2SMatthias Ringwald if (this_pair_len != pair_len) { 857591423b2SMatthias Ringwald break; 858591423b2SMatthias Ringwald } 859591423b2SMatthias Ringwald } 860591423b2SMatthias Ringwald 861591423b2SMatthias Ringwald // log_info("Begin of group, handle 0x%04x", it.handle); 862591423b2SMatthias Ringwald 863591423b2SMatthias Ringwald // first 864591423b2SMatthias Ringwald if (offset == 1) { 865591423b2SMatthias Ringwald pair_len = this_pair_len; 866591423b2SMatthias Ringwald response_buffer[offset] = this_pair_len; 867591423b2SMatthias Ringwald offset++; 868591423b2SMatthias Ringwald } 869591423b2SMatthias Ringwald 870591423b2SMatthias Ringwald group_start_handle = it.handle; 871591423b2SMatthias Ringwald group_start_value = it.value; 872591423b2SMatthias Ringwald in_group = 1; 873591423b2SMatthias Ringwald } 874591423b2SMatthias Ringwald } 875591423b2SMatthias Ringwald 876591423b2SMatthias Ringwald if (offset == 1){ 877591423b2SMatthias Ringwald return setup_error_atribute_not_found(response_buffer, request_type, start_handle); 878591423b2SMatthias Ringwald } 879591423b2SMatthias Ringwald 880591423b2SMatthias Ringwald response_buffer[0] = ATT_READ_BY_GROUP_TYPE_RESPONSE; 881591423b2SMatthias Ringwald return offset; 882591423b2SMatthias Ringwald } 883591423b2SMatthias Ringwald static uint16_t handle_read_by_group_type_request(att_connection_t * att_connection, uint8_t * request_buffer, uint16_t request_len, 884591423b2SMatthias Ringwald uint8_t * response_buffer, uint16_t response_buffer_size){ 885591423b2SMatthias Ringwald int attribute_type_len; 886591423b2SMatthias Ringwald if (request_len <= 7){ 887591423b2SMatthias Ringwald attribute_type_len = 2; 888591423b2SMatthias Ringwald } else { 889591423b2SMatthias Ringwald attribute_type_len = 16; 890591423b2SMatthias Ringwald } 891591423b2SMatthias Ringwald return handle_read_by_group_type_request2(att_connection, response_buffer, response_buffer_size, little_endian_read_16(request_buffer, 1), little_endian_read_16(request_buffer, 3), attribute_type_len, &request_buffer[5]); 892591423b2SMatthias Ringwald } 893591423b2SMatthias Ringwald 894591423b2SMatthias Ringwald // 895591423b2SMatthias Ringwald // MARK: ATT_WRITE_REQUEST 0x12 896591423b2SMatthias Ringwald static uint16_t handle_write_request(att_connection_t * att_connection, uint8_t * request_buffer, uint16_t request_len, 897591423b2SMatthias Ringwald uint8_t * response_buffer, uint16_t response_buffer_size){ 898591423b2SMatthias Ringwald 8999ec2630cSMatthias Ringwald UNUSED(response_buffer_size); 9009ec2630cSMatthias Ringwald 901591423b2SMatthias Ringwald uint8_t request_type = ATT_WRITE_REQUEST; 902591423b2SMatthias Ringwald 903591423b2SMatthias Ringwald uint16_t handle = little_endian_read_16(request_buffer, 1); 904591423b2SMatthias Ringwald att_iterator_t it; 905591423b2SMatthias Ringwald int ok = att_find_handle(&it, handle); 906591423b2SMatthias Ringwald if (!ok) { 907591423b2SMatthias Ringwald return setup_error_invalid_handle(response_buffer, request_type, handle); 908591423b2SMatthias Ringwald } 9098ac574d6SMatthias Ringwald att_write_callback_t callback = att_write_callback_for_handle(handle); 9108ac574d6SMatthias Ringwald if (!callback) { 911591423b2SMatthias Ringwald return setup_error_write_not_permitted(response_buffer, request_type, handle); 912591423b2SMatthias Ringwald } 913591423b2SMatthias Ringwald if ((it.flags & ATT_PROPERTY_WRITE) == 0) { 914591423b2SMatthias Ringwald return setup_error_write_not_permitted(response_buffer, request_type, handle); 915591423b2SMatthias Ringwald } 916591423b2SMatthias Ringwald if ((it.flags & ATT_PROPERTY_DYNAMIC) == 0) { 917591423b2SMatthias Ringwald return setup_error_write_not_permitted(response_buffer, request_type, handle); 918591423b2SMatthias Ringwald } 919591423b2SMatthias Ringwald // check security requirements 920591423b2SMatthias Ringwald uint8_t error_code = att_validate_security(att_connection, &it); 921591423b2SMatthias Ringwald if (error_code) { 922591423b2SMatthias Ringwald return setup_error(response_buffer, request_type, handle, error_code); 923591423b2SMatthias Ringwald } 9248ac574d6SMatthias Ringwald error_code = (*callback)(att_connection->con_handle, handle, ATT_TRANSACTION_MODE_NONE, 0, request_buffer + 3, request_len - 3); 925591423b2SMatthias Ringwald if (error_code) { 926591423b2SMatthias Ringwald return setup_error(response_buffer, request_type, handle, error_code); 927591423b2SMatthias Ringwald } 928591423b2SMatthias Ringwald response_buffer[0] = ATT_WRITE_RESPONSE; 929591423b2SMatthias Ringwald return 1; 930591423b2SMatthias Ringwald } 931591423b2SMatthias Ringwald 932591423b2SMatthias Ringwald // 933591423b2SMatthias Ringwald // MARK: ATT_PREPARE_WRITE_REQUEST 0x16 934591423b2SMatthias Ringwald static uint16_t handle_prepare_write_request(att_connection_t * att_connection, uint8_t * request_buffer, uint16_t request_len, 935591423b2SMatthias Ringwald uint8_t * response_buffer, uint16_t response_buffer_size){ 936591423b2SMatthias Ringwald 9379ec2630cSMatthias Ringwald UNUSED(response_buffer_size); 9389ec2630cSMatthias Ringwald 939591423b2SMatthias Ringwald uint8_t request_type = ATT_PREPARE_WRITE_REQUEST; 940591423b2SMatthias Ringwald 941591423b2SMatthias Ringwald uint16_t handle = little_endian_read_16(request_buffer, 1); 942591423b2SMatthias Ringwald uint16_t offset = little_endian_read_16(request_buffer, 3); 9438ac574d6SMatthias Ringwald att_write_callback_t callback = att_write_callback_for_handle(handle); 9448ac574d6SMatthias Ringwald if (!callback) { 945591423b2SMatthias Ringwald return setup_error_write_not_permitted(response_buffer, request_type, handle); 946591423b2SMatthias Ringwald } 947591423b2SMatthias Ringwald att_iterator_t it; 948591423b2SMatthias Ringwald int ok = att_find_handle(&it, handle); 949591423b2SMatthias Ringwald if (!ok) { 950591423b2SMatthias Ringwald return setup_error_invalid_handle(response_buffer, request_type, handle); 951591423b2SMatthias Ringwald } 952591423b2SMatthias Ringwald if ((it.flags & ATT_PROPERTY_WRITE) == 0) { 953591423b2SMatthias Ringwald return setup_error_write_not_permitted(response_buffer, request_type, handle); 954591423b2SMatthias Ringwald } 955591423b2SMatthias Ringwald if ((it.flags & ATT_PROPERTY_DYNAMIC) == 0) { 956591423b2SMatthias Ringwald return setup_error_write_not_permitted(response_buffer, request_type, handle); 957591423b2SMatthias Ringwald } 958591423b2SMatthias Ringwald // check security requirements 959591423b2SMatthias Ringwald uint8_t error_code = att_validate_security(att_connection, &it); 960591423b2SMatthias Ringwald if (error_code) { 961591423b2SMatthias Ringwald return setup_error(response_buffer, request_type, handle, error_code); 962591423b2SMatthias Ringwald } 963591423b2SMatthias Ringwald 9648ac574d6SMatthias Ringwald error_code = (*callback)(att_connection->con_handle, handle, ATT_TRANSACTION_MODE_ACTIVE, offset, request_buffer + 5, request_len - 5); 965591423b2SMatthias Ringwald switch (error_code){ 966591423b2SMatthias Ringwald case 0: 967591423b2SMatthias Ringwald break; 968591423b2SMatthias Ringwald case ATT_ERROR_INVALID_OFFSET: 969591423b2SMatthias Ringwald case ATT_ERROR_INVALID_ATTRIBUTE_VALUE_LENGTH: 970591423b2SMatthias Ringwald // postpone to execute write request 971591423b2SMatthias Ringwald att_prepare_write_update_errors(error_code, handle); 972591423b2SMatthias Ringwald break; 973591423b2SMatthias Ringwald default: 974591423b2SMatthias Ringwald return setup_error(response_buffer, request_type, handle, error_code); 975591423b2SMatthias Ringwald } 976591423b2SMatthias Ringwald 977591423b2SMatthias Ringwald // response: echo request 978591423b2SMatthias Ringwald memcpy(response_buffer, request_buffer, request_len); 979591423b2SMatthias Ringwald response_buffer[0] = ATT_PREPARE_WRITE_RESPONSE; 980591423b2SMatthias Ringwald return request_len; 981591423b2SMatthias Ringwald } 982591423b2SMatthias Ringwald 9838ac574d6SMatthias Ringwald static void att_notify_write_callbacks(att_connection_t * att_connection, uint16_t transaction_mode){ 9848ac574d6SMatthias Ringwald // notify all 9858ac574d6SMatthias Ringwald btstack_linked_list_iterator_t it; 9868ac574d6SMatthias Ringwald btstack_linked_list_iterator_init(&it, &service_handlers); 9878ac574d6SMatthias Ringwald while (btstack_linked_list_iterator_has_next(&it)){ 9888ac574d6SMatthias Ringwald att_service_handler_t * handler = (att_service_handler_t*) btstack_linked_list_iterator_next(&it); 9898ac574d6SMatthias Ringwald if (!handler->write_callback) continue; 9908ac574d6SMatthias Ringwald (*handler->write_callback)(att_connection->con_handle, 0, transaction_mode, 0, NULL, 0); 9918ac574d6SMatthias Ringwald } 9928ac574d6SMatthias Ringwald if (!att_write_callback) return; 9938ac574d6SMatthias Ringwald (*att_write_callback)(att_connection->con_handle, 0, transaction_mode, 0, NULL, 0); 9948ac574d6SMatthias Ringwald } 9958ac574d6SMatthias Ringwald 9969b31df63SMatthias Ringwald // returns first reported error or 0 9979b31df63SMatthias Ringwald static uint8_t att_validate_prepared_write(att_connection_t * att_connection){ 9989b31df63SMatthias Ringwald btstack_linked_list_iterator_t it; 9999b31df63SMatthias Ringwald btstack_linked_list_iterator_init(&it, &service_handlers); 10009b31df63SMatthias Ringwald while (btstack_linked_list_iterator_has_next(&it)){ 10019b31df63SMatthias Ringwald att_service_handler_t * handler = (att_service_handler_t*) btstack_linked_list_iterator_next(&it); 10029b31df63SMatthias Ringwald if (!handler->write_callback) continue; 10039b31df63SMatthias Ringwald uint8_t error_code = (*handler->write_callback)(att_connection->con_handle, 0, ATT_TRANSACTION_MODE_VALIDATE, 0, NULL, 0); 10049b31df63SMatthias Ringwald if (error_code) return error_code; 10059b31df63SMatthias Ringwald } 10069b31df63SMatthias Ringwald if (!att_write_callback) return 0; 10079b31df63SMatthias Ringwald return (*att_write_callback)(att_connection->con_handle, 0, ATT_TRANSACTION_MODE_VALIDATE, 0, NULL, 0); 10089b31df63SMatthias Ringwald } 10099b31df63SMatthias Ringwald 1010591423b2SMatthias Ringwald /* 1011591423b2SMatthias Ringwald * @brief transcation queue of prepared writes, e.g., after disconnect 1012591423b2SMatthias Ringwald */ 1013591423b2SMatthias Ringwald void att_clear_transaction_queue(att_connection_t * att_connection){ 10148ac574d6SMatthias Ringwald att_notify_write_callbacks(att_connection, ATT_TRANSACTION_MODE_CANCEL); 1015591423b2SMatthias Ringwald } 1016591423b2SMatthias Ringwald 1017591423b2SMatthias Ringwald // MARK: ATT_EXECUTE_WRITE_REQUEST 0x18 1018591423b2SMatthias Ringwald // NOTE: security has been verified by handle_prepare_write_request 1019591423b2SMatthias Ringwald static uint16_t handle_execute_write_request(att_connection_t * att_connection, uint8_t * request_buffer, uint16_t request_len, 1020591423b2SMatthias Ringwald uint8_t * response_buffer, uint16_t response_buffer_size){ 1021591423b2SMatthias Ringwald 10229ec2630cSMatthias Ringwald UNUSED(request_len); 10239ec2630cSMatthias Ringwald UNUSED(response_buffer_size); 10249ec2630cSMatthias Ringwald 1025591423b2SMatthias Ringwald uint8_t request_type = ATT_EXECUTE_WRITE_REQUEST; 1026591423b2SMatthias Ringwald if (request_buffer[1]) { 10279b31df63SMatthias Ringwald // validate queued write 10289b31df63SMatthias Ringwald if (att_prepare_write_error_code == 0){ 10299b31df63SMatthias Ringwald att_prepare_write_error_code = att_validate_prepared_write(att_connection); 10309b31df63SMatthias Ringwald } 1031591423b2SMatthias Ringwald // deliver queued errors 1032591423b2SMatthias Ringwald if (att_prepare_write_error_code){ 1033591423b2SMatthias Ringwald att_clear_transaction_queue(att_connection); 1034591423b2SMatthias Ringwald uint8_t error_code = att_prepare_write_error_code; 1035591423b2SMatthias Ringwald uint16_t handle = att_prepare_write_error_handle; 1036591423b2SMatthias Ringwald att_prepare_write_reset(); 1037591423b2SMatthias Ringwald return setup_error(response_buffer, request_type, handle, error_code); 1038591423b2SMatthias Ringwald } 10398ac574d6SMatthias Ringwald att_notify_write_callbacks(att_connection, ATT_TRANSACTION_MODE_EXECUTE); 1040591423b2SMatthias Ringwald } else { 1041591423b2SMatthias Ringwald att_clear_transaction_queue(att_connection); 1042591423b2SMatthias Ringwald } 1043591423b2SMatthias Ringwald response_buffer[0] = ATT_EXECUTE_WRITE_RESPONSE; 1044591423b2SMatthias Ringwald return 1; 1045591423b2SMatthias Ringwald } 1046591423b2SMatthias Ringwald 1047591423b2SMatthias Ringwald // MARK: ATT_WRITE_COMMAND 0x52 1048591423b2SMatthias Ringwald // Core 4.0, vol 3, part F, 3.4.5.3 1049591423b2SMatthias Ringwald // "No Error Response or Write Response shall be sent in response to this command" 1050591423b2SMatthias Ringwald static void handle_write_command(att_connection_t * att_connection, uint8_t * request_buffer, uint16_t request_len, 1051591423b2SMatthias Ringwald uint8_t * response_buffer, uint16_t response_buffer_size){ 1052591423b2SMatthias Ringwald 10539ec2630cSMatthias Ringwald UNUSED(response_buffer); 10549ec2630cSMatthias Ringwald UNUSED(response_buffer_size); 10559ec2630cSMatthias Ringwald 1056591423b2SMatthias Ringwald uint16_t handle = little_endian_read_16(request_buffer, 1); 10578ac574d6SMatthias Ringwald att_write_callback_t callback = att_write_callback_for_handle(handle); 10588ac574d6SMatthias Ringwald if (!callback) return; 10598ac574d6SMatthias Ringwald 1060591423b2SMatthias Ringwald att_iterator_t it; 1061591423b2SMatthias Ringwald int ok = att_find_handle(&it, handle); 1062591423b2SMatthias Ringwald if (!ok) return; 1063591423b2SMatthias Ringwald if ((it.flags & ATT_PROPERTY_DYNAMIC) == 0) return; 1064591423b2SMatthias Ringwald if ((it.flags & ATT_PROPERTY_WRITE_WITHOUT_RESPONSE) == 0) return; 1065591423b2SMatthias Ringwald if (att_validate_security(att_connection, &it)) return; 10668ac574d6SMatthias Ringwald (*callback)(att_connection->con_handle, handle, ATT_TRANSACTION_MODE_NONE, 0, request_buffer + 3, request_len - 3); 1067591423b2SMatthias Ringwald } 1068591423b2SMatthias Ringwald 1069591423b2SMatthias Ringwald // MARK: helper for ATT_HANDLE_VALUE_NOTIFICATION and ATT_HANDLE_VALUE_INDICATION 1070591423b2SMatthias Ringwald static uint16_t prepare_handle_value(att_connection_t * att_connection, 1071591423b2SMatthias Ringwald uint16_t handle, 1072591423b2SMatthias Ringwald uint8_t *value, 1073591423b2SMatthias Ringwald uint16_t value_len, 1074591423b2SMatthias Ringwald uint8_t * response_buffer){ 1075591423b2SMatthias Ringwald little_endian_store_16(response_buffer, 1, handle); 1076591423b2SMatthias Ringwald if (value_len > att_connection->mtu - 3){ 1077591423b2SMatthias Ringwald value_len = att_connection->mtu - 3; 1078591423b2SMatthias Ringwald } 1079591423b2SMatthias Ringwald memcpy(&response_buffer[3], value, value_len); 1080591423b2SMatthias Ringwald return value_len + 3; 1081591423b2SMatthias Ringwald } 1082591423b2SMatthias Ringwald 1083591423b2SMatthias Ringwald // MARK: ATT_HANDLE_VALUE_NOTIFICATION 0x1b 1084591423b2SMatthias Ringwald uint16_t att_prepare_handle_value_notification(att_connection_t * att_connection, 1085591423b2SMatthias Ringwald uint16_t handle, 1086591423b2SMatthias Ringwald uint8_t *value, 1087591423b2SMatthias Ringwald uint16_t value_len, 1088591423b2SMatthias Ringwald uint8_t * response_buffer){ 1089591423b2SMatthias Ringwald 1090591423b2SMatthias Ringwald response_buffer[0] = ATT_HANDLE_VALUE_NOTIFICATION; 1091591423b2SMatthias Ringwald return prepare_handle_value(att_connection, handle, value, value_len, response_buffer); 1092591423b2SMatthias Ringwald } 1093591423b2SMatthias Ringwald 1094591423b2SMatthias Ringwald // MARK: ATT_HANDLE_VALUE_INDICATION 0x1d 1095591423b2SMatthias Ringwald uint16_t att_prepare_handle_value_indication(att_connection_t * att_connection, 1096591423b2SMatthias Ringwald uint16_t handle, 1097591423b2SMatthias Ringwald uint8_t *value, 1098591423b2SMatthias Ringwald uint16_t value_len, 1099591423b2SMatthias Ringwald uint8_t * response_buffer){ 1100591423b2SMatthias Ringwald 1101591423b2SMatthias Ringwald response_buffer[0] = ATT_HANDLE_VALUE_INDICATION; 1102591423b2SMatthias Ringwald return prepare_handle_value(att_connection, handle, value, value_len, response_buffer); 1103591423b2SMatthias Ringwald } 1104591423b2SMatthias Ringwald 1105591423b2SMatthias Ringwald // MARK: Dispatcher 1106591423b2SMatthias Ringwald uint16_t att_handle_request(att_connection_t * att_connection, 1107591423b2SMatthias Ringwald uint8_t * request_buffer, 1108591423b2SMatthias Ringwald uint16_t request_len, 1109591423b2SMatthias Ringwald uint8_t * response_buffer){ 1110591423b2SMatthias Ringwald uint16_t response_len = 0; 1111591423b2SMatthias Ringwald uint16_t response_buffer_size = att_connection->mtu; 1112591423b2SMatthias Ringwald 1113591423b2SMatthias Ringwald switch (request_buffer[0]){ 1114591423b2SMatthias Ringwald case ATT_EXCHANGE_MTU_REQUEST: 1115591423b2SMatthias Ringwald response_len = handle_exchange_mtu_request(att_connection, request_buffer, request_len, response_buffer); 1116591423b2SMatthias Ringwald break; 1117591423b2SMatthias Ringwald case ATT_FIND_INFORMATION_REQUEST: 1118591423b2SMatthias Ringwald response_len = handle_find_information_request(att_connection, request_buffer, request_len,response_buffer, response_buffer_size); 1119591423b2SMatthias Ringwald break; 1120591423b2SMatthias Ringwald case ATT_FIND_BY_TYPE_VALUE_REQUEST: 1121591423b2SMatthias Ringwald response_len = handle_find_by_type_value_request(att_connection, request_buffer, request_len, response_buffer, response_buffer_size); 1122591423b2SMatthias Ringwald break; 1123591423b2SMatthias Ringwald case ATT_READ_BY_TYPE_REQUEST: 1124591423b2SMatthias Ringwald response_len = handle_read_by_type_request(att_connection, request_buffer, request_len, response_buffer, response_buffer_size); 1125591423b2SMatthias Ringwald break; 1126591423b2SMatthias Ringwald case ATT_READ_REQUEST: 1127591423b2SMatthias Ringwald response_len = handle_read_request(att_connection, request_buffer, request_len, response_buffer, response_buffer_size); 1128591423b2SMatthias Ringwald break; 1129591423b2SMatthias Ringwald case ATT_READ_BLOB_REQUEST: 1130591423b2SMatthias Ringwald response_len = handle_read_blob_request(att_connection, request_buffer, request_len, response_buffer, response_buffer_size); 1131591423b2SMatthias Ringwald break; 1132591423b2SMatthias Ringwald case ATT_READ_MULTIPLE_REQUEST: 1133591423b2SMatthias Ringwald response_len = handle_read_multiple_request(att_connection, request_buffer, request_len, response_buffer, response_buffer_size); 1134591423b2SMatthias Ringwald break; 1135591423b2SMatthias Ringwald case ATT_READ_BY_GROUP_TYPE_REQUEST: 1136591423b2SMatthias Ringwald response_len = handle_read_by_group_type_request(att_connection, request_buffer, request_len, response_buffer, response_buffer_size); 1137591423b2SMatthias Ringwald break; 1138591423b2SMatthias Ringwald case ATT_WRITE_REQUEST: 1139591423b2SMatthias Ringwald response_len = handle_write_request(att_connection, request_buffer, request_len, response_buffer, response_buffer_size); 1140591423b2SMatthias Ringwald break; 1141591423b2SMatthias Ringwald case ATT_PREPARE_WRITE_REQUEST: 1142591423b2SMatthias Ringwald response_len = handle_prepare_write_request(att_connection, request_buffer, request_len, response_buffer, response_buffer_size); 1143591423b2SMatthias Ringwald break; 1144591423b2SMatthias Ringwald case ATT_EXECUTE_WRITE_REQUEST: 1145591423b2SMatthias Ringwald response_len = handle_execute_write_request(att_connection, request_buffer, request_len, response_buffer, response_buffer_size); 1146591423b2SMatthias Ringwald break; 1147591423b2SMatthias Ringwald case ATT_WRITE_COMMAND: 1148591423b2SMatthias Ringwald handle_write_command(att_connection, request_buffer, request_len, response_buffer, response_buffer_size); 1149591423b2SMatthias Ringwald break; 11507a766ebfSMatthias Ringwald #ifdef ENABLE_LE_SIGNED_WRITE 1151591423b2SMatthias Ringwald case ATT_SIGNED_WRITE_COMMAND: 1152591423b2SMatthias Ringwald log_info("handle_signed_write_command preprocessed by att_server.c"); 1153591423b2SMatthias Ringwald break; 11547a766ebfSMatthias Ringwald #endif 1155591423b2SMatthias Ringwald default: 1156591423b2SMatthias Ringwald log_info("Unhandled ATT Command: %02X, DATA: ", request_buffer[0]); 1157591423b2SMatthias Ringwald log_info_hexdump(&request_buffer[9], request_len-9); 1158591423b2SMatthias Ringwald break; 1159591423b2SMatthias Ringwald } 1160591423b2SMatthias Ringwald return response_len; 1161591423b2SMatthias Ringwald } 1162591423b2SMatthias Ringwald 11638ac574d6SMatthias Ringwald /** 11648ac574d6SMatthias Ringwald * @brief register read/write callbacks for specific handle range 11658ac574d6SMatthias Ringwald * @param att_service_handler_t 11668ac574d6SMatthias Ringwald */ 11678ac574d6SMatthias Ringwald void att_register_service_handler(att_service_handler_t * handler){ 11688ac574d6SMatthias Ringwald if (att_service_handler_for_handle(handler->start_handle) || 11698ac574d6SMatthias Ringwald att_service_handler_for_handle(handler->end_handle)){ 11708ac574d6SMatthias Ringwald log_error("att_register_service_handler: handler for range 0x%04x-0x%04x already registered", handler->start_handle, handler->end_handle); 11718ac574d6SMatthias Ringwald return; 1172591423b2SMatthias Ringwald } 11738ac574d6SMatthias Ringwald btstack_linked_list_add(&service_handlers, (btstack_linked_item_t*) handler); 11748ac574d6SMatthias Ringwald } 11758ac574d6SMatthias Ringwald 1176660ce368SMatthias Ringwald // returns 1 if service found. only primary service. 1177660ce368SMatthias Ringwald int gatt_server_get_get_handle_range_for_service_with_uuid16(uint16_t uuid16, uint16_t * start_handle, uint16_t * end_handle){ 1178660ce368SMatthias Ringwald uint16_t in_group = 0; 1179660ce368SMatthias Ringwald uint16_t prev_handle = 0; 1180660ce368SMatthias Ringwald 1181660ce368SMatthias Ringwald uint8_t attribute_value[2]; 1182660ce368SMatthias Ringwald int attribute_len = sizeof(attribute_value); 1183660ce368SMatthias Ringwald little_endian_store_16(attribute_value, 0, uuid16); 1184660ce368SMatthias Ringwald 1185660ce368SMatthias Ringwald att_iterator_t it; 1186660ce368SMatthias Ringwald att_iterator_init(&it); 1187660ce368SMatthias Ringwald while (att_iterator_has_next(&it)){ 1188660ce368SMatthias Ringwald att_iterator_fetch_next(&it); 1189660ce368SMatthias Ringwald int new_service_started = att_iterator_match_uuid16(&it, GATT_PRIMARY_SERVICE_UUID) || att_iterator_match_uuid16(&it, GATT_SECONDARY_SERVICE_UUID); 1190660ce368SMatthias Ringwald 1191660ce368SMatthias Ringwald // close current tag, if within a group and a new service definition starts or we reach end of att db 1192660ce368SMatthias Ringwald if (in_group && 1193660ce368SMatthias Ringwald (it.handle == 0 || new_service_started)){ 1194660ce368SMatthias Ringwald *end_handle = prev_handle; 1195660ce368SMatthias Ringwald return 1; 1196660ce368SMatthias Ringwald } 1197660ce368SMatthias Ringwald 1198660ce368SMatthias Ringwald // keep track of previous handle 1199660ce368SMatthias Ringwald prev_handle = it.handle; 1200660ce368SMatthias Ringwald 1201660ce368SMatthias Ringwald // check if found 1202660ce368SMatthias Ringwald if (it.handle && new_service_started && attribute_len == it.value_len && memcmp(attribute_value, it.value, it.value_len) == 0){ 1203660ce368SMatthias Ringwald *start_handle = it.handle; 1204660ce368SMatthias Ringwald in_group = 1; 1205660ce368SMatthias Ringwald } 1206660ce368SMatthias Ringwald } 1207660ce368SMatthias Ringwald return 0; 1208660ce368SMatthias Ringwald } 1209660ce368SMatthias Ringwald 1210660ce368SMatthias Ringwald // returns 0 if not found 1211660ce368SMatthias Ringwald uint16_t gatt_server_get_value_handle_for_characteristic_with_uuid16(uint16_t start_handle, uint16_t end_handle, uint16_t uuid16){ 1212660ce368SMatthias Ringwald att_iterator_t it; 1213660ce368SMatthias Ringwald att_iterator_init(&it); 1214660ce368SMatthias Ringwald while (att_iterator_has_next(&it)){ 1215660ce368SMatthias Ringwald att_iterator_fetch_next(&it); 1216660ce368SMatthias Ringwald if (it.handle && it.handle < start_handle) continue; 1217660ce368SMatthias Ringwald if (it.handle > end_handle) break; // (1) 1218660ce368SMatthias Ringwald if (it.handle == 0) break; 1219660ce368SMatthias Ringwald if (att_iterator_match_uuid16(&it, uuid16)) return it.handle; 1220660ce368SMatthias Ringwald } 1221660ce368SMatthias Ringwald return 0; 1222660ce368SMatthias Ringwald } 1223660ce368SMatthias Ringwald 1224660ce368SMatthias Ringwald // returns 0 if not found 1225660ce368SMatthias Ringwald uint16_t gatt_server_get_client_configuration_handle_for_characteristic_with_uuid16(uint16_t start_handle, uint16_t end_handle, uint16_t uuid16){ 1226660ce368SMatthias Ringwald att_iterator_t it; 1227660ce368SMatthias Ringwald att_iterator_init(&it); 1228660ce368SMatthias Ringwald int characteristic_found = 0; 1229660ce368SMatthias Ringwald while (att_iterator_has_next(&it)){ 1230660ce368SMatthias Ringwald att_iterator_fetch_next(&it); 1231660ce368SMatthias Ringwald if (it.handle && it.handle < start_handle) continue; 1232660ce368SMatthias Ringwald if (it.handle > end_handle) break; // (1) 1233660ce368SMatthias Ringwald if (it.handle == 0) break; 1234660ce368SMatthias Ringwald if (att_iterator_match_uuid16(&it, uuid16)){ 1235660ce368SMatthias Ringwald characteristic_found = 1; 1236660ce368SMatthias Ringwald continue; 1237660ce368SMatthias Ringwald } 1238660ce368SMatthias Ringwald if (att_iterator_match_uuid16(&it, GATT_PRIMARY_SERVICE_UUID) 1239660ce368SMatthias Ringwald || att_iterator_match_uuid16(&it, GATT_SECONDARY_SERVICE_UUID) 1240660ce368SMatthias Ringwald || att_iterator_match_uuid16(&it, GATT_CHARACTERISTICS_UUID)){ 1241660ce368SMatthias Ringwald if (characteristic_found) break; 1242660ce368SMatthias Ringwald continue; 1243660ce368SMatthias Ringwald } 1244660ce368SMatthias Ringwald if (att_iterator_match_uuid16(&it, GATT_CLIENT_CHARACTERISTICS_CONFIGURATION)){ 1245660ce368SMatthias Ringwald return it.handle; 1246660ce368SMatthias Ringwald } 1247660ce368SMatthias Ringwald } 1248660ce368SMatthias Ringwald return 0; 1249660ce368SMatthias Ringwald } 1250660ce368SMatthias Ringwald 1251