xref: /btstack/src/classic/pbap_client.c (revision 16ded4fec137bd21c09b6ce46f3427c6f1c9cc24)
1 /*
2  * Copyright (C) 2014 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 #define __BTSTACK_FILE__ "pbap_client.c"
39 
40 // *****************************************************************************
41 //
42 #if 0
43     0x0000 = uint32(65542),
44     // BLUETOOTH_SERVICE_CLASS_PHONEBOOK_ACCESS_PSE
45     0x0001 = { uuid16(11 2f) },
46     // BLUETOOTH_PROTOCOL_L2CAP, BLUETOOTH_PROTOCOL_RFCOMM, BLUETOOTH_PROTOCOL_OBEX
47     0x0004 = { { uuid16(01 00) }, { uuid16(00 03), uint8(19) }, { uuid16(00 08) } }
48     0x0005 = { uuid16(10 02) },
49     // BLUETOOTH_SERVICE_CLASS_PHONEBOOK_ACCESS, v1.01 = 0x101
50     0x0009 = { { uuid16(11 30), uint16(257) } },
51     0x0100 = string(OBEX Phonebook Access Server
52     // BLUETOOTH_ATTRIBUTE_SUPPORTED_FEATURES -- should be 0x317 BLUETOOTH_ATTRIBUTE_PBAP_SUPPORTED_FEATURES?
53     0x0311 = uint8(3),
54     // BLUETOOTH_ATTRIBUTE_SUPPORTED_REPOSITORIES
55     0x0314 = uint8(1),
56 #endif
57 //
58 // *****************************************************************************
59 
60 #include "btstack_config.h"
61 
62 #include <stdint.h>
63 #include <stdio.h>
64 #include <stdlib.h>
65 #include <string.h>
66 
67 #include "hci_cmd.h"
68 #include "btstack_run_loop.h"
69 #include "btstack_debug.h"
70 #include "hci.h"
71 #include "btstack_memory.h"
72 #include "hci_dump.h"
73 #include "l2cap.h"
74 #include "bluetooth_sdp.h"
75 #include "classic/sdp_client_rfcomm.h"
76 #include "btstack_event.h"
77 #include "md5.h"
78 #include "yxml.h"
79 
80 #include "classic/obex.h"
81 #include "classic/obex_iterator.h"
82 #include "classic/goep_client.h"
83 #include "classic/pbap_client.h"
84 
85 // 796135f0-f0c5-11d8-0966- 0800200c9a66
86 uint8_t pbap_uuid[] = { 0x79, 0x61, 0x35, 0xf0, 0xf0, 0xc5, 0x11, 0xd8, 0x09, 0x66, 0x08, 0x00, 0x20, 0x0c, 0x9a, 0x66};
87 
88 const char * pbap_phonebook_type = "x-bt/phonebook";
89 const char * pbap_phonebook_name = "pb.vcf";
90 
91 const char * pbap_vcard_listing_type = "x-bt/vcard-listing";
92 const char * pbap_vcard_listing_name = "pb";
93 
94 typedef enum {
95     PBAP_INIT = 0,
96     PBAP_W4_GOEP_CONNECTION,
97     PBAP_W2_SEND_CONNECT_REQUEST,
98     PBAP_W4_CONNECT_RESPONSE,
99     PBAP_W4_USER_AUTHENTICATION,
100     PBAP_W2_SEND_AUTHENTICATED_CONNECT,
101     PBAP_CONNECT_RESPONSE_RECEIVED,
102     PBAP_CONNECTED,
103     //
104     PBAP_W2_SEND_DISCONNECT_REQUEST,
105     PBAP_W4_DISCONNECT_RESPONSE,
106     //
107     PBAP_W2_PULL_PHONEBOOK,
108     PBAP_W4_PHONEBOOK,
109     PBAP_W2_SET_PATH_ROOT,
110     PBAP_W4_SET_PATH_ROOT_COMPLETE,
111     PBAP_W2_SET_PATH_ELEMENT,
112     PBAP_W4_SET_PATH_ELEMENT_COMPLETE,
113     PBAP_W2_GET_PHONEBOOK_SIZE,
114     PBAP_W4_GET_PHONEBOOK_SIZE_COMPLETE,
115     //
116     PBAP_W2_GET_CARD_LIST,
117     PBAP_W4_GET_CARD_LIST_COMPLETE,
118 
119 } pbap_state_t;
120 
121 typedef struct pbap_client {
122     pbap_state_t state;
123     uint16_t  cid;
124     bd_addr_t bd_addr;
125     hci_con_handle_t con_handle;
126     uint8_t   incoming;
127     uint16_t  goep_cid;
128     btstack_packet_handler_t client_handler;
129     const char * current_folder;
130     const char * phone_number;
131     uint16_t set_path_offset;
132     uint8_t  authentication_options;
133     uint16_t authentication_nonce[16];
134     const char * authentication_password;
135     yxml_t  xml_parser;
136     uint8_t xml_buffer[50];
137 } pbap_client_t;
138 
139 static pbap_client_t _pbap_client;
140 static pbap_client_t * pbap_client = &_pbap_client;
141 
142 static void pbap_client_emit_connected_event(pbap_client_t * context, uint8_t status){
143     uint8_t event[15];
144     int pos = 0;
145     event[pos++] = HCI_EVENT_PBAP_META;
146     pos++;  // skip len
147     event[pos++] = PBAP_SUBEVENT_CONNECTION_OPENED;
148     little_endian_store_16(event,pos,context->cid);
149     pos+=2;
150     event[pos++] = status;
151     memcpy(&event[pos], context->bd_addr, 6);
152     pos += 6;
153     little_endian_store_16(event,pos,context->con_handle);
154     pos += 2;
155     event[pos++] = context->incoming;
156     event[1] = pos - 2;
157     if (pos != sizeof(event)) log_error("goep_client_emit_connected_event size %u", pos);
158     context->client_handler(HCI_EVENT_PACKET, context->cid, &event[0], pos);
159 }
160 
161 static void pbap_client_emit_connection_closed_event(pbap_client_t * context){
162     uint8_t event[5];
163     int pos = 0;
164     event[pos++] = HCI_EVENT_PBAP_META;
165     pos++;  // skip len
166     event[pos++] = PBAP_SUBEVENT_CONNECTION_CLOSED;
167     little_endian_store_16(event,pos,context->cid);
168     pos+=2;
169     event[1] = pos - 2;
170     if (pos != sizeof(event)) log_error("pbap_client_emit_connection_closed_event size %u", pos);
171     context->client_handler(HCI_EVENT_PACKET, context->cid, &event[0], pos);
172 }
173 
174 static void pbap_client_emit_operation_complete_event(pbap_client_t * context, uint8_t status){
175     uint8_t event[6];
176     int pos = 0;
177     event[pos++] = HCI_EVENT_PBAP_META;
178     pos++;  // skip len
179     event[pos++] = PBAP_SUBEVENT_OPERATION_COMPLETED;
180     little_endian_store_16(event,pos,context->cid);
181     pos+=2;
182     event[pos++]= status;
183     event[1] = pos - 2;
184     if (pos != sizeof(event)) log_error("pbap_client_emit_can_send_now_event size %u", pos);
185     context->client_handler(HCI_EVENT_PACKET, context->cid, &event[0], pos);
186 }
187 
188 static void pbap_client_emit_phonebook_size_event(pbap_client_t * context, uint8_t status, uint16_t phonebook_size){
189     uint8_t event[8];
190     int pos = 0;
191     event[pos++] = HCI_EVENT_PBAP_META;
192     pos++;  // skip len
193     event[pos++] = PBAP_SUBEVENT_PHONEBOOK_SIZE;
194     little_endian_store_16(event,pos,context->cid);
195     pos+=2;
196     event[pos++] = status;
197     little_endian_store_16(event,pos, phonebook_size);
198     pos+=2;
199     event[1] = pos - 2;
200     if (pos != sizeof(event)) log_error("pbap_client_emit_phonebook_size_event size %u", pos);
201     context->client_handler(HCI_EVENT_PACKET, context->cid, &event[0], pos);
202 }
203 
204 static void pbap_client_emit_authentication_event(pbap_client_t * context, uint8_t options){
205     // split options
206     uint8_t user_id_required = options & 1 ? 1 : 0;
207     uint8_t full_access      = options & 2 ? 1 : 0;
208 
209     uint8_t event[7];
210     int pos = 0;
211     event[pos++] = HCI_EVENT_PBAP_META;
212     pos++;  // skip len
213     event[pos++] = PBAP_SUBEVENT_AUTHENTICATION_REQUEST;
214     little_endian_store_16(event,pos,context->cid);
215     pos+=2;
216     event[pos++] = user_id_required;
217     event[pos++] = full_access;
218     if (pos != sizeof(event)) log_error("pbap_client_emit_authentication_event size %u", pos);
219     context->client_handler(HCI_EVENT_PACKET, context->cid, &event[0], pos);
220 }
221 
222 static void pbap_client_emit_card_result_event(pbap_client_t * context, const char * name, const char * handle){
223     uint8_t event[5 + PBAP_MAX_NAME_LEN + PBAP_MAX_HANDLE_LEN];
224     int pos = 0;
225     event[pos++] = HCI_EVENT_PBAP_META;
226     pos++;  // skip len
227     event[pos++] = PBAP_SUBEVENT_CARD_RESULT;
228     little_endian_store_16(event,pos,context->cid);
229     pos+=2;
230     int name_len = btstack_min(PBAP_MAX_NAME_LEN, strlen(name));
231     event[pos++] = name_len;
232     memcpy(&event[pos], name, name_len);
233     pos += name_len;
234     int handle_len = btstack_min(PBAP_MAX_HANDLE_LEN, strlen(handle));
235     event[pos++] = handle_len;
236     memcpy(&event[pos], handle, handle_len);
237     pos += handle_len;
238     event[1] = pos - 2;
239     context->client_handler(HCI_EVENT_PACKET, context->cid, &event[0], pos);
240 }
241 
242 static const uint8_t collon = (uint8_t) ':';
243 
244 static void pbap_handle_can_send_now(void){
245     uint8_t  path_element[20];
246     uint16_t path_element_start;
247     uint16_t path_element_len;
248     uint8_t  application_parameters[PBAP_MAX_PHONE_NUMBER_LEN + 10];
249     uint8_t  challenge_response[36];
250     int i;
251     uint16_t phone_number_len;
252 
253     MD5_CTX md5_ctx;
254 
255     switch (pbap_client->state){
256         case PBAP_W2_SEND_CONNECT_REQUEST:
257             goep_client_create_connect_request(pbap_client->goep_cid, OBEX_VERSION, 0, OBEX_MAX_PACKETLEN_DEFAULT);
258             goep_client_add_header_target(pbap_client->goep_cid, 16, pbap_uuid);
259             // Add PbapSupportedFeatures
260             application_parameters[0] = PBAP_APPLICATION_PARAMETER_PBAP_SUPPORTED_FEATURES;
261             application_parameters[1] = 4;
262             big_endian_store_32(application_parameters, 2, goep_client_get_pbap_supported_features(pbap_client->goep_cid));
263             goep_client_add_header_application_parameters(pbap_client->goep_cid, 6, &application_parameters[0]);
264             pbap_client->state = PBAP_W4_CONNECT_RESPONSE;
265             goep_client_execute(pbap_client->goep_cid);
266             break;
267         case PBAP_W2_SEND_AUTHENTICATED_CONNECT:
268             goep_client_create_connect_request(pbap_client->goep_cid, OBEX_VERSION, 0, OBEX_MAX_PACKETLEN_DEFAULT);
269             goep_client_add_header_target(pbap_client->goep_cid, 16, pbap_uuid);
270             // setup authentication challenge response
271             i = 0;
272             challenge_response[i++] = 0;  // Tag Digest
273             challenge_response[i++] = 16; // Len
274             // calculate md5
275             MD5_Init(&md5_ctx);
276             MD5_Update(&md5_ctx, pbap_client->authentication_nonce, 16);
277             MD5_Update(&md5_ctx, &collon, 1);
278             MD5_Update(&md5_ctx, pbap_client->authentication_password, strlen(pbap_client->authentication_password));
279             MD5_Final(&challenge_response[i], &md5_ctx);
280             i += 16;
281             challenge_response[i++] = 2;  // Tag Nonce
282             challenge_response[i++] = 16; // Len
283             memcpy(&challenge_response[i], pbap_client->authentication_nonce, 16);
284             i += 16;
285             goep_client_add_header_challenge_response(pbap_client->goep_cid, i, challenge_response);
286             pbap_client->state = PBAP_W4_CONNECT_RESPONSE;
287             goep_client_execute(pbap_client->goep_cid);
288             break;
289         case PBAP_W2_SEND_DISCONNECT_REQUEST:
290             goep_client_create_disconnect_request(pbap_client->goep_cid);
291             pbap_client->state = PBAP_W4_DISCONNECT_RESPONSE;
292             goep_client_execute(pbap_client->goep_cid);
293             return;
294         case PBAP_W2_PULL_PHONEBOOK:
295         case PBAP_W2_GET_PHONEBOOK_SIZE:
296             goep_client_create_get_request(pbap_client->goep_cid);
297             goep_client_add_header_type(pbap_client->goep_cid, pbap_phonebook_type);
298             goep_client_add_header_name(pbap_client->goep_cid, pbap_phonebook_name);
299             if (pbap_client->state == PBAP_W2_GET_PHONEBOOK_SIZE){
300                 // Regular TLV wih 1-byte len
301                 application_parameters[0] = PBAP_APPLICATION_PARAMETER_MAX_LIST_COUNT;
302                 application_parameters[1] = 2;
303                 big_endian_store_16(application_parameters, 2, 0);
304                 goep_client_add_header_application_parameters(pbap_client->goep_cid, 4, &application_parameters[0]);
305                 // state
306                 pbap_client->state = PBAP_W4_GET_PHONEBOOK_SIZE_COMPLETE;
307             } else {
308                 // state
309                 pbap_client->state = PBAP_W4_PHONEBOOK;
310             }
311             // send packet
312             goep_client_execute(pbap_client->goep_cid);
313             break;
314         case PBAP_W2_GET_CARD_LIST:
315             goep_client_create_get_request(pbap_client->goep_cid);
316             goep_client_add_header_type(pbap_client->goep_cid, pbap_vcard_listing_type);
317             goep_client_add_header_name(pbap_client->goep_cid, pbap_vcard_listing_name);
318             // Regular TLV wih 1-byte len
319             i = 0;
320             phone_number_len = btstack_min(PBAP_MAX_PHONE_NUMBER_LEN, strlen(pbap_client->phone_number));
321             application_parameters[i++] = PBAP_APPLICATION_PARAMETER_SEARCH_VALUE;
322             application_parameters[i++] = phone_number_len;
323             memcpy(&application_parameters[i], pbap_client->phone_number, phone_number_len);
324             i += phone_number_len;
325             application_parameters[i++] = PBAP_APPLICATION_PARAMETER_SEARCH_PROPERTY;
326             application_parameters[i++] = 1;
327             application_parameters[i++] = 0x01; // Number
328             goep_client_add_header_application_parameters(pbap_client->goep_cid, i, &application_parameters[0]);
329             pbap_client->state = PBAP_W4_GET_CARD_LIST_COMPLETE;
330             // send packet
331             goep_client_execute(pbap_client->goep_cid);
332             break;
333         case PBAP_W2_SET_PATH_ROOT:
334             goep_client_create_set_path_request(pbap_client->goep_cid, 1 << 1); // Don’t create directory
335             // On Android 4.2 Cyanogenmod, using "" as path fails
336             // goep_client_add_header_name(pbap_client->goep_cid, "");     // empty == /
337             // state
338             pbap_client->state = PBAP_W4_SET_PATH_ROOT_COMPLETE;
339             // send packet
340             goep_client_execute(pbap_client->goep_cid);
341             break;
342         case PBAP_W2_SET_PATH_ELEMENT:
343             // find '/' or '\0'
344             path_element_start = pbap_client->set_path_offset;
345             while (pbap_client->current_folder[pbap_client->set_path_offset] != '\0' &&
346                 pbap_client->current_folder[pbap_client->set_path_offset] != '/'){
347                 pbap_client->set_path_offset++;
348             }
349             // skip /
350             if (pbap_client->current_folder[pbap_client->set_path_offset] == '/'){
351                 pbap_client->set_path_offset++;
352             }
353             path_element_len = pbap_client->set_path_offset-path_element_start;
354             memcpy(path_element, &pbap_client->current_folder[path_element_start], path_element_len);
355             path_element[path_element_len] = 0;
356 
357             goep_client_create_set_path_request(pbap_client->goep_cid, 1 << 1); // Don’t create directory
358             goep_client_add_header_name(pbap_client->goep_cid, (const char *) path_element); // next element
359             // state
360             pbap_client->state = PBAP_W4_SET_PATH_ELEMENT_COMPLETE;
361             // send packet
362             goep_client_execute(pbap_client->goep_cid);
363             break;
364         default:
365             break;
366     }
367 }
368 
369 static void pbap_parse_authentication_challenge(pbap_client_t * context, const uint8_t * challenge_data, uint16_t challenge_len){
370     // printf("Challenge:  ");
371     // printf_hexdump(challenge_data, challenge_len);
372     int i;
373     // uint8_t charset_code = 0;
374     for (i=0 ; i<challenge_len ; ){
375         int tag = challenge_data[i];
376         int len = challenge_data[i + 1];
377         i += 2;
378         switch (tag) {
379             case 0:
380                 if (len != 0x10) {
381                     log_error("Invalid OBEX digest len %u", len);
382                     return;
383                 }
384                 memcpy(context->authentication_nonce, &challenge_data[i], 16);
385                 // printf("Nonce: ");
386                 // printf_hexdump(context->authentication_nonce, 16);
387                 break;
388             case 1:
389                 context->authentication_options = challenge_data[i];
390                 // printf("Options %u\n", context->authentication_options);
391                 break;
392             case 2:
393                 // TODO: handle charset
394                 // charset_code = challenge_data[i];
395                 break;
396         }
397         i += len;
398     }
399 }
400 
401 static void pbap_packet_handler(uint8_t packet_type, uint16_t channel, uint8_t *packet, uint16_t size){
402 
403     UNUSED(channel); // ok: there is no channel
404     UNUSED(size);    // ok: handling own geop events
405 
406     obex_iterator_t it;
407     uint8_t status;
408     switch (packet_type){
409         case HCI_EVENT_PACKET:
410             switch (hci_event_packet_get_type(packet)) {
411                 case HCI_EVENT_GOEP_META:
412                     switch (hci_event_goep_meta_get_subevent_code(packet)){
413                         case GOEP_SUBEVENT_CONNECTION_OPENED:
414                             status = goep_subevent_connection_opened_get_status(packet);
415                             pbap_client->con_handle = goep_subevent_connection_opened_get_con_handle(packet);
416                             pbap_client->incoming = goep_subevent_connection_opened_get_incoming(packet);
417                             goep_subevent_connection_opened_get_bd_addr(packet, pbap_client->bd_addr);
418                             if (status){
419                                 log_info("pbap: connection failed %u", status);
420                                 pbap_client->state = PBAP_INIT;
421                                 pbap_client_emit_connected_event(pbap_client, status);
422                             } else {
423                                 log_info("pbap: connection established");
424                                 pbap_client->goep_cid = goep_subevent_connection_opened_get_goep_cid(packet);
425                                 pbap_client->state = PBAP_W2_SEND_CONNECT_REQUEST;
426                                 goep_client_request_can_send_now(pbap_client->goep_cid);
427                             }
428                             break;
429                         case GOEP_SUBEVENT_CONNECTION_CLOSED:
430                             if (pbap_client->state != PBAP_CONNECTED){
431                                 pbap_client_emit_operation_complete_event(pbap_client, OBEX_DISCONNECTED);
432                             }
433                             pbap_client->state = PBAP_INIT;
434                             pbap_client_emit_connection_closed_event(pbap_client);
435                             break;
436                         case GOEP_SUBEVENT_CAN_SEND_NOW:
437                             pbap_handle_can_send_now();
438                             break;
439                     }
440                     break;
441                 default:
442                     break;
443             }
444             break;
445         case GOEP_DATA_PACKET:
446             // TODO: handle chunked data
447             // obex_dump_packet(goep_client_get_request_opcode(pbap_client->goep_cid), packet, size);
448             switch (pbap_client->state){
449                 case PBAP_W4_CONNECT_RESPONSE:
450                     switch (packet[0]){
451                         case OBEX_RESP_SUCCESS:
452                             for (obex_iterator_init_with_response_packet(&it, goep_client_get_request_opcode(pbap_client->goep_cid), packet, size); obex_iterator_has_more(&it) ; obex_iterator_next(&it)){
453                                 uint8_t hi = obex_iterator_get_hi(&it);
454                                 if (hi == OBEX_HEADER_CONNECTION_ID){
455                                     goep_client_set_connection_id(pbap_client->goep_cid, obex_iterator_get_data_32(&it));
456                                 }
457                             }
458                             pbap_client->state = PBAP_CONNECTED;
459                             pbap_client_emit_connected_event(pbap_client, 0);
460                             break;
461                         case OBEX_RESP_UNAUTHORIZED:
462                             for (obex_iterator_init_with_response_packet(&it, goep_client_get_request_opcode(pbap_client->goep_cid), packet, size); obex_iterator_has_more(&it) ; obex_iterator_next(&it)){
463                                 uint8_t hi = obex_iterator_get_hi(&it);
464                                 if (hi == OBEX_HEADER_AUTHENTICATION_CHALLENGE){
465                                     pbap_parse_authentication_challenge(pbap_client, obex_iterator_get_data(&it), obex_iterator_get_data_len(&it));
466                                 }
467                             }
468                             pbap_client->state = PBAP_W4_USER_AUTHENTICATION;
469                             pbap_client_emit_authentication_event(pbap_client, pbap_client->authentication_options);
470                             break;
471                         default:
472                             log_info("pbap: obex connect failed, result 0x%02x", packet[0]);
473                             pbap_client->state = PBAP_INIT;
474                             pbap_client_emit_connected_event(pbap_client, OBEX_CONNECT_FAILED);
475                             break;
476                     }
477                     break;
478                 case PBAP_W4_DISCONNECT_RESPONSE:
479                         goep_client_disconnect(pbap_client->goep_cid);
480                         break;
481                 case PBAP_W4_SET_PATH_ROOT_COMPLETE:
482                 case PBAP_W4_SET_PATH_ELEMENT_COMPLETE:
483                     if (packet[0] == OBEX_RESP_SUCCESS){
484                         if (pbap_client->current_folder){
485                             pbap_client->state = PBAP_W2_SET_PATH_ELEMENT;
486                             goep_client_request_can_send_now(pbap_client->goep_cid);
487                         } else {
488                             pbap_client_emit_operation_complete_event(pbap_client, 0);
489                         }
490                     } else if (packet[0] == OBEX_RESP_NOT_FOUND){
491                         pbap_client->state = PBAP_CONNECTED;
492                         pbap_client_emit_operation_complete_event(pbap_client, OBEX_NOT_FOUND);
493                     } else {
494                         pbap_client->state = PBAP_CONNECTED;
495                         pbap_client_emit_operation_complete_event(pbap_client, OBEX_UNKNOWN_ERROR);
496                     }
497                     break;
498                 case PBAP_W4_PHONEBOOK:
499                     for (obex_iterator_init_with_response_packet(&it, goep_client_get_request_opcode(pbap_client->goep_cid), packet, size); obex_iterator_has_more(&it) ; obex_iterator_next(&it)){
500                         uint8_t hi = obex_iterator_get_hi(&it);
501                         if (hi == OBEX_HEADER_BODY || hi == OBEX_HEADER_END_OF_BODY){
502                             uint16_t     data_len = obex_iterator_get_data_len(&it);
503                             const uint8_t  * data =  obex_iterator_get_data(&it);
504                             pbap_client->client_handler(PBAP_DATA_PACKET, pbap_client->cid, (uint8_t *) data, data_len);
505                         }
506                     }
507                     switch(packet[0]){
508                         case OBEX_RESP_CONTINUE:
509                             pbap_client->state = PBAP_W2_PULL_PHONEBOOK;
510                             goep_client_request_can_send_now(pbap_client->goep_cid);
511                             break;
512                         case OBEX_RESP_SUCCESS:
513                             pbap_client->state = PBAP_CONNECTED;
514                             pbap_client_emit_operation_complete_event(pbap_client, 0);
515                             break;
516                         default:
517                             log_info("unexpected response 0x%02x", packet[0]);
518                             pbap_client->state = PBAP_CONNECTED;
519                             pbap_client_emit_operation_complete_event(pbap_client, OBEX_UNKNOWN_ERROR);
520                             break;
521                     }
522                     break;
523                 case PBAP_W4_GET_PHONEBOOK_SIZE_COMPLETE:
524                     pbap_client->state = PBAP_CONNECTED;
525                     if (packet[0] == OBEX_RESP_SUCCESS){
526                         int have_size = 0;
527                         uint16_t phonebook_size;
528                         for (obex_iterator_init_with_response_packet(&it, goep_client_get_request_opcode(pbap_client->goep_cid), packet, size); obex_iterator_has_more(&it) ; obex_iterator_next(&it)){
529                             uint8_t hi = obex_iterator_get_hi(&it);
530                             if (hi == OBEX_HEADER_APPLICATION_PARAMETERS){
531                                 uint16_t     data_len = obex_iterator_get_data_len(&it);
532                                 const uint8_t  * data =  obex_iterator_get_data(&it);
533                                 // iterate over application headers (TLV with 1 bytes len)
534                                 unsigned int i = 0;
535                                 while (i<data_len){
536                                     uint8_t tag = data[i++];
537                                     uint8_t len = data[i++];
538                                     if (tag == PBAP_APPLICATION_PARAMETER_PHONEBOOK_SIZE && len == 2){
539                                         have_size = 1;
540                                         phonebook_size = big_endian_read_16(data, i);
541                                     }
542                                     i+=len;
543                                 }
544                             }
545                         }
546                         if (have_size){
547                             pbap_client_emit_phonebook_size_event(pbap_client, 0, phonebook_size);
548                             break;
549                         }
550                     }
551                     pbap_client_emit_phonebook_size_event(pbap_client, OBEX_UNKNOWN_ERROR, 0);
552                     break;
553                 case PBAP_W4_GET_CARD_LIST_COMPLETE:
554                     switch (packet[0]){
555                         case OBEX_RESP_CONTINUE:
556                             pbap_client->state = PBAP_W2_GET_CARD_LIST;
557                             goep_client_request_can_send_now(pbap_client->goep_cid);
558                             break;
559                         case OBEX_RESP_SUCCESS:
560                             for (obex_iterator_init_with_response_packet(&it, goep_client_get_request_opcode(pbap_client->goep_cid), packet, size); obex_iterator_has_more(&it) ; obex_iterator_next(&it)){
561                                 uint8_t hi = obex_iterator_get_hi(&it);
562                                 if (hi == OBEX_HEADER_END_OF_BODY){
563                                     uint16_t     data_len = obex_iterator_get_data_len(&it);
564                                     const uint8_t  * data =  obex_iterator_get_data(&it);
565                                     // now try parsing it
566                                     yxml_init(&pbap_client->xml_parser, pbap_client->xml_buffer, sizeof(pbap_client->xml_buffer));
567                                     int card_found = 0;
568                                     int name_found = 0;
569                                     int handle_found = 0;
570                                     char name[PBAP_MAX_NAME_LEN];
571                                     char handle[PBAP_MAX_HANDLE_LEN];
572                                     name[0] = 0;
573                                     handle[0] = 0;
574                                     while (data_len--){
575                                         yxml_ret_t r = yxml_parse(&pbap_client->xml_parser, *data++);
576                                         switch (r){
577                                             case YXML_ELEMSTART:
578                                                 card_found = strcmp("card", pbap_client->xml_parser.elem) == 0;
579                                                 break;
580                                             case YXML_ELEMEND:
581                                                 if (card_found){
582                                                     pbap_client_emit_card_result_event(pbap_client, name, handle);
583                                                 }
584                                                 card_found = 0;
585                                                 break;
586                                             case YXML_ATTRSTART:
587                                                 if (!card_found) break;
588                                                 if (strcmp("name", pbap_client->xml_parser.attr) == 0){
589                                                     name_found = 1;
590                                                     break;
591                                                 }
592                                                 if (strcmp("handle", pbap_client->xml_parser.attr) == 0){
593                                                     handle_found = 1;
594                                                     break;
595                                                 }
596                                                 break;
597                                             case YXML_ATTRVAL:
598                                                 if (name_found) {
599                                                     // "In UTF-8, characters from the U+0000..U+10FFFF range (the UTF-16 accessible range) are encoded using sequences of 1 to 4 octets."
600                                                     if (strlen(name) + 4 + 1 >= sizeof(name)) break;
601                                                     strcat(name, pbap_client->xml_parser.data);
602                                                     break;
603                                                 }
604                                                 if (handle_found) {
605                                                     // "In UTF-8, characters from the U+0000..U+10FFFF range (the UTF-16 accessible range) are encoded using sequences of 1 to 4 octets."
606                                                     if (strlen(handle) + 4 + 1 >= sizeof(handle)) break;
607                                                     strcat(handle, pbap_client->xml_parser.data);
608                                                     break;
609                                                 }
610                                                 break;
611                                             case YXML_ATTREND:
612                                                 name_found = 0;
613                                                 handle_found = 0;
614                                                 break;
615                                             default:
616                                                 break;
617                                         }
618                                     }
619                                     //
620                                     pbap_client->state = PBAP_CONNECTED;
621                                     pbap_client_emit_operation_complete_event(pbap_client, 0);
622                                 }
623                             }
624                             break;
625                         case OBEX_RESP_NOT_ACCEPTABLE:
626                             pbap_client->state = PBAP_CONNECTED;
627                             pbap_client_emit_operation_complete_event(pbap_client, OBEX_NOT_ACCEPTABLE);
628                             break;
629                         default:
630                             log_info("unexpected response 0x%02x", packet[0]);
631                             pbap_client->state = PBAP_CONNECTED;
632                             pbap_client_emit_operation_complete_event(pbap_client, OBEX_UNKNOWN_ERROR);
633                             break;
634                     }
635                     break;
636                 default:
637                     break;
638             }
639             break;
640         default:
641             break;
642     }
643 }
644 
645 void pbap_client_init(void){
646     memset(pbap_client, 0, sizeof(pbap_client_t));
647     pbap_client->state = PBAP_INIT;
648     pbap_client->cid = 1;
649 }
650 
651 uint8_t pbap_connect(btstack_packet_handler_t handler, bd_addr_t addr, uint16_t * out_cid){
652     if (pbap_client->state != PBAP_INIT) return BTSTACK_MEMORY_ALLOC_FAILED;
653     pbap_client->state = PBAP_W4_GOEP_CONNECTION;
654     pbap_client->client_handler = handler;
655     uint8_t err = goep_client_create_connection(&pbap_packet_handler, addr, BLUETOOTH_SERVICE_CLASS_PHONEBOOK_ACCESS_PSE, &pbap_client->goep_cid);
656     *out_cid = pbap_client->cid;
657     if (err) return err;
658     return 0;
659 }
660 
661 uint8_t pbap_disconnect(uint16_t pbap_cid){
662     UNUSED(pbap_cid);
663     if (pbap_client->state != PBAP_CONNECTED) return BTSTACK_BUSY;
664     pbap_client->state = PBAP_W2_SEND_DISCONNECT_REQUEST;
665     goep_client_request_can_send_now(pbap_client->goep_cid);
666     return 0;
667 }
668 
669 uint8_t pbap_get_phonebook_size(uint16_t pbap_cid){
670     UNUSED(pbap_cid);
671     if (pbap_client->state != PBAP_CONNECTED) return BTSTACK_BUSY;
672     pbap_client->state = PBAP_W2_GET_PHONEBOOK_SIZE;
673     goep_client_request_can_send_now(pbap_client->goep_cid);
674     return 0;
675 }
676 
677 uint8_t pbap_pull_phonebook(uint16_t pbap_cid){
678     UNUSED(pbap_cid);
679     if (pbap_client->state != PBAP_CONNECTED) return BTSTACK_BUSY;
680     pbap_client->state = PBAP_W2_PULL_PHONEBOOK;
681     goep_client_request_can_send_now(pbap_client->goep_cid);
682     return 0;
683 }
684 
685 uint8_t pbap_set_phonebook(uint16_t pbap_cid, const char * path){
686     UNUSED(pbap_cid);
687     if (pbap_client->state != PBAP_CONNECTED) return BTSTACK_BUSY;
688     pbap_client->state = PBAP_W2_SET_PATH_ROOT;
689     pbap_client->current_folder = path;
690     pbap_client->set_path_offset = 0;
691     goep_client_request_can_send_now(pbap_client->goep_cid);
692     return 0;
693 }
694 
695 uint8_t pbap_authentication_password(uint16_t pbap_cid, const char * password){
696     UNUSED(pbap_cid);
697     if (pbap_client->state != PBAP_W4_USER_AUTHENTICATION) return BTSTACK_BUSY;
698     pbap_client->state = PBAP_W2_SEND_AUTHENTICATED_CONNECT;
699     pbap_client->authentication_password = password;
700     goep_client_request_can_send_now(pbap_client->goep_cid);
701     return 0;
702 }
703 
704 uint8_t pbap_lookup_by_number(uint16_t pbap_cid, const char * phone_number){
705     UNUSED(pbap_cid);
706     if (pbap_client->state != PBAP_CONNECTED) return BTSTACK_BUSY;
707     pbap_client->state = PBAP_W2_GET_CARD_LIST;
708     pbap_client->phone_number = phone_number;
709     goep_client_request_can_send_now(pbap_client->goep_cid);
710     return 0;
711 }
712