xref: /btstack/src/classic/pbap_client.c (revision a154fcd6ec9a48d3ca7f5b3855281bc2cefc01e5)
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 #include "btstack_config.h"
41 
42 #include <stdint.h>
43 #include <string.h>
44 
45 #include "hci_cmd.h"
46 #include "btstack_run_loop.h"
47 #include "btstack_debug.h"
48 #include "hci.h"
49 #include "btstack_memory.h"
50 #include "hci_dump.h"
51 #include "l2cap.h"
52 #include "bluetooth_sdp.h"
53 #include "classic/sdp_client_rfcomm.h"
54 #include "btstack_event.h"
55 #include "md5.h"
56 #include "yxml.h"
57 
58 #include "classic/obex.h"
59 #include "classic/obex_iterator.h"
60 #include "classic/goep_client.h"
61 #include "classic/pbap_client.h"
62 
63 // 796135f0-f0c5-11d8-0966- 0800200c9a66
64 static const uint8_t pbap_uuid[] = { 0x79, 0x61, 0x35, 0xf0, 0xf0, 0xc5, 0x11, 0xd8, 0x09, 0x66, 0x08, 0x00, 0x20, 0x0c, 0x9a, 0x66};
65 
66 const char * pbap_phonebook_type     = "x-bt/phonebook";
67 const char * pbap_vcard_listing_type = "x-bt/vcard-listing";
68 const char * pbap_vcard_entry_type   = "x-bt/vcard";
69 
70 const char * pbap_vcard_listing_name = "pb";
71 
72 static uint32_t pbap_supported_features = \
73     PBAP_SUPPORTED_FEATURES_DOWNLOAD |
74     PBAP_SUPPORTED_FEATURES_BROWSING |
75     PBAP_SUPPORTED_FEATURES_DATABASE_IDENTIFIER |
76     PBAP_SUPPORTED_FEATURES_FOLDER_VERSION_COUNTERS |
77     PBAP_SUPPORTED_FEATURES_VCARD_SELECTING |
78     PBAP_SUPPORTED_FEATURES_ENHANCED_MISSED_CALLS |
79     PBAP_SUPPORTED_FEATURES_DEFAULT_CONTACT_IMAGE_FORMAT |
80     PBAP_SUPPORTED_FEATURES_X_BT_UCI_VCARD_PROPERTY |
81     PBAP_SUPPORTED_FEATURES_X_BT_UID_VCARD_PROPERTY |
82     PBAP_SUPPORTED_FEATURES_CONTACT_REFERENCING;
83 
84 typedef enum {
85     PBAP_INIT = 0,
86     PBAP_W4_GOEP_CONNECTION,
87     PBAP_W2_SEND_CONNECT_REQUEST,
88     PBAP_W4_CONNECT_RESPONSE,
89     PBAP_W4_USER_AUTHENTICATION,
90     PBAP_W2_SEND_AUTHENTICATED_CONNECT,
91     PBAP_CONNECT_RESPONSE_RECEIVED,
92     PBAP_CONNECTED,
93     //
94     PBAP_W2_SEND_DISCONNECT_REQUEST,
95     PBAP_W4_DISCONNECT_RESPONSE,
96     //
97     PBAP_W2_PULL_PHONEBOOK,
98     PBAP_W4_PHONEBOOK,
99     PBAP_W2_SET_PATH_ROOT,
100     PBAP_W4_SET_PATH_ROOT_COMPLETE,
101     PBAP_W2_SET_PATH_ELEMENT,
102     PBAP_W4_SET_PATH_ELEMENT_COMPLETE,
103     PBAP_W2_GET_PHONEBOOK_SIZE,
104     PBAP_W4_GET_PHONEBOOK_SIZE_COMPLETE,
105     // - pull vacard liast
106     PBAP_W2_GET_CARD_LIST,
107     PBAP_W4_GET_CARD_LIST_COMPLETE,
108     // - pull vcard entry
109     PBAP_W2_GET_CARD_ENTRY,
110     PBAP_W4_GET_CARD_ENTRY_COMPLETE
111 
112 } pbap_state_t;
113 
114 typedef enum {
115     SRM_DISABLED,
116     SRM_W4_CONFIRM,
117     SRM_ENABLED_BUT_WAITING,
118     SRM_ENABLED
119 } srm_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     int request_number;
130     srm_state_t srm_state;
131     const char * current_folder;
132     const char * phone_number;
133     const char * phonebook_path;
134     const char * vcard_name;
135     uint16_t set_path_offset;
136     /* vcard selector / operator */
137     uint32_t vcard_selector;
138     uint8_t  vcard_selector_operator;
139     uint8_t  vcard_selector_supported;
140     /* abort */
141     uint8_t  abort_operation;
142     /* authentication */
143     uint8_t  authentication_options;
144     uint16_t authentication_nonce[16];
145     const char * authentication_password;
146     /* xml parser */
147     yxml_t  xml_parser;
148     uint8_t xml_buffer[50];
149     /* vcard listing parser */
150     bool parser_card_found;
151     bool parser_name_found;
152     bool parser_handle_found;
153     char parser_name[PBAP_MAX_NAME_LEN];
154     char parser_handle[PBAP_MAX_HANDLE_LEN];
155     /* flow control mode */
156     uint8_t flow_control_enabled;
157     uint8_t flow_next_triggered;
158 } pbap_client_t;
159 
160 static pbap_client_t _pbap_client;
161 static pbap_client_t * pbap_client = &_pbap_client;
162 
163 static void pbap_client_emit_connected_event(pbap_client_t * context, uint8_t status){
164     uint8_t event[15];
165     int pos = 0;
166     event[pos++] = HCI_EVENT_PBAP_META;
167     pos++;  // skip len
168     event[pos++] = PBAP_SUBEVENT_CONNECTION_OPENED;
169     little_endian_store_16(event,pos,context->cid);
170     pos+=2;
171     event[pos++] = status;
172     (void)memcpy(&event[pos], context->bd_addr, 6);
173     pos += 6;
174     little_endian_store_16(event,pos,context->con_handle);
175     pos += 2;
176     event[pos++] = context->incoming;
177     event[1] = pos - 2;
178     if (pos != sizeof(event)) log_error("goep_client_emit_connected_event size %u", pos);
179     context->client_handler(HCI_EVENT_PACKET, context->cid, &event[0], pos);
180 }
181 
182 static void pbap_client_emit_connection_closed_event(pbap_client_t * context){
183     uint8_t event[5];
184     int pos = 0;
185     event[pos++] = HCI_EVENT_PBAP_META;
186     pos++;  // skip len
187     event[pos++] = PBAP_SUBEVENT_CONNECTION_CLOSED;
188     little_endian_store_16(event,pos,context->cid);
189     pos+=2;
190     event[1] = pos - 2;
191     if (pos != sizeof(event)) log_error("pbap_client_emit_connection_closed_event size %u", pos);
192     context->client_handler(HCI_EVENT_PACKET, context->cid, &event[0], pos);
193 }
194 
195 static void pbap_client_emit_operation_complete_event(pbap_client_t * context, uint8_t status){
196     uint8_t event[6];
197     int pos = 0;
198     event[pos++] = HCI_EVENT_PBAP_META;
199     pos++;  // skip len
200     event[pos++] = PBAP_SUBEVENT_OPERATION_COMPLETED;
201     little_endian_store_16(event,pos,context->cid);
202     pos+=2;
203     event[pos++]= status;
204     event[1] = pos - 2;
205     if (pos != sizeof(event)) log_error("pbap_client_emit_can_send_now_event size %u", pos);
206     context->client_handler(HCI_EVENT_PACKET, context->cid, &event[0], pos);
207 }
208 
209 static void pbap_client_emit_phonebook_size_event(pbap_client_t * context, uint8_t status, uint16_t phonebook_size){
210     uint8_t event[8];
211     int pos = 0;
212     event[pos++] = HCI_EVENT_PBAP_META;
213     pos++;  // skip len
214     event[pos++] = PBAP_SUBEVENT_PHONEBOOK_SIZE;
215     little_endian_store_16(event,pos,context->cid);
216     pos+=2;
217     event[pos++] = status;
218     little_endian_store_16(event,pos, phonebook_size);
219     pos+=2;
220     event[1] = pos - 2;
221     if (pos != sizeof(event)) log_error("pbap_client_emit_phonebook_size_event size %u", pos);
222     context->client_handler(HCI_EVENT_PACKET, context->cid, &event[0], pos);
223 }
224 
225 static void pbap_client_emit_authentication_event(pbap_client_t * context, uint8_t options){
226     // split options
227     uint8_t user_id_required = (options & 1) ? 1 : 0;
228     uint8_t full_access      = (options & 2) ? 1 : 0;
229 
230     uint8_t event[7];
231     int pos = 0;
232     event[pos++] = HCI_EVENT_PBAP_META;
233     pos++;  // skip len
234     event[pos++] = PBAP_SUBEVENT_AUTHENTICATION_REQUEST;
235     little_endian_store_16(event,pos,context->cid);
236     pos+=2;
237     event[pos++] = user_id_required;
238     event[pos++] = full_access;
239     if (pos != sizeof(event)) log_error("pbap_client_emit_authentication_event size %u", pos);
240     context->client_handler(HCI_EVENT_PACKET, context->cid, &event[0], pos);
241 }
242 
243 static void pbap_client_emit_card_result_event(pbap_client_t * context, const char * name, const char * handle){
244     uint8_t event[5 + PBAP_MAX_NAME_LEN + PBAP_MAX_HANDLE_LEN];
245     int pos = 0;
246     event[pos++] = HCI_EVENT_PBAP_META;
247     pos++;  // skip len
248     event[pos++] = PBAP_SUBEVENT_CARD_RESULT;
249     little_endian_store_16(event,pos,context->cid);
250     pos+=2;
251     int name_len = btstack_min(PBAP_MAX_NAME_LEN, strlen(name));
252     event[pos++] = name_len;
253     (void)memcpy(&event[pos], name, name_len);
254     pos += name_len;
255     int handle_len = btstack_min(PBAP_MAX_HANDLE_LEN, strlen(handle));
256     event[pos++] = handle_len;
257     (void)memcpy(&event[pos], handle, handle_len);
258     pos += handle_len;
259     event[1] = pos - 2;
260     context->client_handler(HCI_EVENT_PACKET, context->cid, &event[0], pos);
261 }
262 
263 static const uint8_t collon = (uint8_t) ':';
264 
265 static void pbap_client_vcard_listing_init_parser(pbap_client_t * client){
266     yxml_init(&client->xml_parser, client->xml_buffer, sizeof(client->xml_buffer));
267     client->parser_card_found = false;
268     client->parser_name_found = false;
269     client->parser_handle_found = false;
270 }
271 
272 static void pbap_handle_can_send_now(void){
273     uint8_t  path_element[20];
274     uint16_t path_element_start;
275     uint16_t path_element_len;
276     uint8_t  application_parameters[PBAP_MAX_PHONE_NUMBER_LEN + 10];
277     uint8_t  challenge_response[36];
278     int i;
279     uint16_t phone_number_len;
280 
281     MD5_CTX md5_ctx;
282 
283     if (pbap_client->abort_operation){
284         pbap_client->abort_operation = 0;
285         pbap_client->state = PBAP_CONNECTED;
286         goep_client_request_create_abort(pbap_client->goep_cid);
287         goep_client_execute(pbap_client->goep_cid);
288         return;
289     }
290 
291     switch (pbap_client->state){
292         case PBAP_W2_SEND_CONNECT_REQUEST:
293             goep_client_request_create_connect(pbap_client->goep_cid, OBEX_VERSION, 0, OBEX_MAX_PACKETLEN_DEFAULT);
294             goep_client_header_add_target(pbap_client->goep_cid, pbap_uuid, 16);
295             // Mandatory if the PSE advertises a PbapSupportedFeatures attribute in its SDP record, else excluded.
296             if (goep_client_get_pbap_supported_features(pbap_client->goep_cid) != PBAP_FEATURES_NOT_PRESENT){
297                 application_parameters[0] = PBAP_APPLICATION_PARAMETER_PBAP_SUPPORTED_FEATURES;
298                 application_parameters[1] = 4;
299                 big_endian_store_32(application_parameters, 2, pbap_supported_features);
300                 goep_client_header_add_application_parameters(pbap_client->goep_cid, &application_parameters[0], 6);
301             }
302             pbap_client->state = PBAP_W4_CONNECT_RESPONSE;
303             goep_client_execute(pbap_client->goep_cid);
304             break;
305         case PBAP_W2_SEND_AUTHENTICATED_CONNECT:
306             goep_client_request_create_connect(pbap_client->goep_cid, OBEX_VERSION, 0, OBEX_MAX_PACKETLEN_DEFAULT);
307             goep_client_header_add_target(pbap_client->goep_cid, pbap_uuid, 16);
308             // setup authentication challenge response
309             i = 0;
310             challenge_response[i++] = 0;  // Tag Digest
311             challenge_response[i++] = 16; // Len
312             // calculate md5
313             MD5_Init(&md5_ctx);
314             MD5_Update(&md5_ctx, pbap_client->authentication_nonce, 16);
315             MD5_Update(&md5_ctx, &collon, 1);
316             MD5_Update(&md5_ctx, pbap_client->authentication_password, strlen(pbap_client->authentication_password));
317             MD5_Final(&challenge_response[i], &md5_ctx);
318             i += 16;
319             challenge_response[i++] = 2;  // Tag Nonce
320             challenge_response[i++] = 16; // Len
321             (void)memcpy(&challenge_response[i],
322                          pbap_client->authentication_nonce, 16);
323             i += 16;
324             goep_client_header_add_challenge_response(pbap_client->goep_cid, challenge_response, i);
325             pbap_client->state = PBAP_W4_CONNECT_RESPONSE;
326             goep_client_execute(pbap_client->goep_cid);
327             break;
328         case PBAP_W2_SEND_DISCONNECT_REQUEST:
329             goep_client_request_create_disconnect(pbap_client->goep_cid);
330             pbap_client->state = PBAP_W4_DISCONNECT_RESPONSE;
331             goep_client_execute(pbap_client->goep_cid);
332             return;
333         case PBAP_W2_PULL_PHONEBOOK:
334         case PBAP_W2_GET_PHONEBOOK_SIZE:
335             goep_client_request_create_get(pbap_client->goep_cid);
336             if (pbap_client->request_number == 0){
337                 if (!pbap_client->flow_control_enabled){
338                     goep_client_header_add_srm_enable(pbap_client->goep_cid);
339                     pbap_client->srm_state = SRM_W4_CONFIRM;
340                 }
341                 goep_client_header_add_name(pbap_client->goep_cid, pbap_client->phonebook_path);
342                 goep_client_header_add_type(pbap_client->goep_cid, pbap_phonebook_type);
343                 i = 0;
344                 if (pbap_client->vcard_selector_supported){
345                     // vCard Selector
346                     if (pbap_client->vcard_selector){
347                         application_parameters[i++] = PBAP_APPLICATION_PARAMETER_VCARD_SELECTOR;
348                         application_parameters[i++] = 8;
349                         memset(&application_parameters[i], 0, 4);
350                         i += 4;
351                         big_endian_store_32(application_parameters, i, pbap_client->vcard_selector);
352                         i += 4;
353                     }
354                     // vCard Selector Operator
355                     if (pbap_client->vcard_selector_operator != PBAP_VCARD_SELECTOR_OPERATOR_OR){
356                         application_parameters[i++] = PBAP_APPLICATION_PARAMETER_VCARD_SELECTOR_OPERATOR;
357                         application_parameters[i++] = 1;
358                         application_parameters[i++] = pbap_client->vcard_selector_operator;
359                     }
360                 }
361                 if (pbap_client->state == PBAP_W2_GET_PHONEBOOK_SIZE){
362                     // Regular TLV wih 1-byte len
363                     application_parameters[i++] = PBAP_APPLICATION_PARAMETER_MAX_LIST_COUNT;
364                     application_parameters[i++] = 2;
365                     big_endian_store_16(application_parameters, 2, 0);
366                     i += 2;
367                 }
368                 if (i){
369                     goep_client_header_add_application_parameters(pbap_client->goep_cid, application_parameters, i);
370                 }
371             }
372             if (pbap_client->state == PBAP_W2_GET_PHONEBOOK_SIZE){
373                 // state
374                 pbap_client->state = PBAP_W4_GET_PHONEBOOK_SIZE_COMPLETE;
375             } else {
376                 // state
377                 pbap_client->state = PBAP_W4_PHONEBOOK;
378             }
379             // send packet
380             pbap_client->request_number++;
381             goep_client_execute(pbap_client->goep_cid);
382             break;
383         case PBAP_W2_GET_CARD_LIST:
384             goep_client_request_create_get(pbap_client->goep_cid);
385             if (pbap_client->request_number == 0){
386                 if (!pbap_client->flow_control_enabled){
387                     goep_client_header_add_srm_enable(pbap_client->goep_cid);
388                     pbap_client->srm_state = SRM_W4_CONFIRM;
389                 }
390                 goep_client_header_add_name(pbap_client->goep_cid, pbap_client->phonebook_path);
391                 goep_client_header_add_type(pbap_client->goep_cid, pbap_vcard_listing_type);
392                 i = 0;
393                 if (pbap_client->vcard_selector_supported){
394                     // vCard Selector
395                     if (pbap_client->vcard_selector){
396                         application_parameters[i++] = PBAP_APPLICATION_PARAMETER_VCARD_SELECTOR;
397                         application_parameters[i++] = 8;
398                         memset(&application_parameters[i], 0, 4);
399                         i += 4;
400                         big_endian_store_32(application_parameters, i, pbap_client->vcard_selector);
401                         i += 4;
402                     }
403                     // vCard Selector Operator
404                     if (pbap_client->vcard_selector_operator != PBAP_VCARD_SELECTOR_OPERATOR_OR){
405                         application_parameters[i++] = PBAP_APPLICATION_PARAMETER_VCARD_SELECTOR_OPERATOR;
406                         application_parameters[i++] = 1;
407                         application_parameters[i++] = pbap_client->vcard_selector_operator;
408                     }
409                 }
410                 if (pbap_client->phone_number){
411                     // Search by phone number
412                     phone_number_len = btstack_min(PBAP_MAX_PHONE_NUMBER_LEN, strlen(pbap_client->phone_number));
413                     application_parameters[i++] = PBAP_APPLICATION_PARAMETER_SEARCH_VALUE;
414                     application_parameters[i++] = phone_number_len;
415                     (void)memcpy(&application_parameters[i],
416                                  pbap_client->phone_number, phone_number_len);
417                     i += phone_number_len;
418                     application_parameters[i++] = PBAP_APPLICATION_PARAMETER_SEARCH_PROPERTY;
419                     application_parameters[i++] = 1;
420                     application_parameters[i++] = 0x01; // Number
421                 }
422                 if (i){
423                     goep_client_header_add_application_parameters(pbap_client->goep_cid, &application_parameters[0], i);
424                 }
425             }
426 
427             // send packet
428             pbap_client->state = PBAP_W4_GET_CARD_LIST_COMPLETE;
429             pbap_client->request_number++;
430             goep_client_execute(pbap_client->goep_cid);
431             break;
432         case PBAP_W2_GET_CARD_ENTRY:
433             goep_client_request_create_get(pbap_client->goep_cid);
434             if (pbap_client->request_number == 0){
435                 if (!pbap_client->flow_control_enabled){
436                     goep_client_header_add_srm_enable(pbap_client->goep_cid);
437                     pbap_client->srm_state = SRM_W4_CONFIRM;
438                 }
439                 goep_client_header_add_name(pbap_client->goep_cid, pbap_client->vcard_name);
440                 goep_client_header_add_type(pbap_client->goep_cid, pbap_vcard_entry_type);
441                 // TODO: support property selector
442                 // TODO: support format
443                 i = 0;
444                 uint32_t property_selector_lower = 0;
445                 uint32_t property_selector_higher = 0;
446                 if (strncmp(pbap_client->vcard_name, "X-BT-UID:", 9) == 0) {
447                     property_selector_lower = 1U << 31;
448                 }
449                 if (strncmp(pbap_client->vcard_name, "X-BT-UCI:", 9) == 0) {
450                     property_selector_lower = 1U << 30;
451                 }
452                 if (property_selector_lower != 0){
453                     application_parameters[i++] = PBAP_APPLICATION_PARAMETER_PROPERTY_SELECTOR;
454                     application_parameters[i++] = 8;
455                     big_endian_store_32(application_parameters, i, property_selector_higher);
456                     i += 4;
457                     big_endian_store_32(application_parameters, i, property_selector_lower);
458                     i += 4;
459                 }
460                 if (i > 0){
461                     goep_client_header_add_application_parameters(pbap_client->goep_cid, &application_parameters[0], i);
462                 }
463                 pbap_client->state = PBAP_W4_GET_CARD_ENTRY_COMPLETE;
464             }
465             // send packet
466             pbap_client->request_number++;
467             goep_client_execute(pbap_client->goep_cid);
468             break;
469         case PBAP_W2_SET_PATH_ROOT:
470             goep_client_request_create_set_path(pbap_client->goep_cid, 1 << 1); // Don’t create directory
471             goep_client_header_add_name(pbap_client->goep_cid, "");
472             // state
473             pbap_client->state = PBAP_W4_SET_PATH_ROOT_COMPLETE;
474             // send packet
475             goep_client_execute(pbap_client->goep_cid);
476             break;
477         case PBAP_W2_SET_PATH_ELEMENT:
478             // find '/' or '\0'
479             path_element_start = pbap_client->set_path_offset;
480             while ((pbap_client->current_folder[pbap_client->set_path_offset] != '\0') &&
481                 (pbap_client->current_folder[pbap_client->set_path_offset] != '/')){
482                 pbap_client->set_path_offset++;
483             }
484             path_element_len = pbap_client->set_path_offset-path_element_start;
485             (void)memcpy(path_element,
486                          &pbap_client->current_folder[path_element_start],
487                          path_element_len);
488             path_element[path_element_len] = 0;
489 
490             // skip /
491             if (pbap_client->current_folder[pbap_client->set_path_offset] == '/'){
492                 pbap_client->set_path_offset++;
493             }
494 
495             // status
496             log_info("Path element '%s'", path_element);
497 
498             goep_client_request_create_set_path(pbap_client->goep_cid, 1 << 1); // Don’t create directory
499             goep_client_header_add_name(pbap_client->goep_cid, (const char *) path_element); // next element
500             // state
501             pbap_client->state = PBAP_W4_SET_PATH_ELEMENT_COMPLETE;
502             // send packet
503             goep_client_execute(pbap_client->goep_cid);
504             break;
505         default:
506             break;
507     }
508 }
509 
510 static void pbap_parse_authentication_challenge(pbap_client_t * context, const uint8_t * challenge_data, uint16_t challenge_len){
511     int i;
512 
513     for (i=0 ; i<challenge_len ; ){
514         int tag = challenge_data[i];
515         int len = challenge_data[i + 1];
516         i += 2;
517         switch (tag) {
518             case 0:
519                 if (len != 0x10) {
520                     log_error("Invalid OBEX digest len %u", len);
521                     return;
522                 }
523                 (void)memcpy(context->authentication_nonce, &challenge_data[i], 16);
524                 break;
525             case 1:
526                 context->authentication_options = challenge_data[i];
527                 break;
528             case 2:
529                 // TODO: handle charset
530                 // charset_code = challenge_data[i];
531                 break;
532             default:
533                 break;
534         }
535         i += len;
536     }
537 }
538 
539 static void pbap_process_srm_headers(pbap_client_t * context, uint8_t *packet, uint16_t size){
540 
541     if (packet[0] != OBEX_RESP_CONTINUE) return;
542 
543     // get SRM and SRMP Headers
544     int srm_value = OBEX_SRM_DISABLE;
545     int srmp_value = OBEX_SRMP_NEXT;
546     obex_iterator_t it;
547     for (obex_iterator_init_with_response_packet(&it, goep_client_get_request_opcode(context->goep_cid), packet, size); obex_iterator_has_more(&it) ; obex_iterator_next(&it)){
548         uint8_t hi = obex_iterator_get_hi(&it);
549         uint16_t     data_len = obex_iterator_get_data_len(&it);
550         const uint8_t  * data = obex_iterator_get_data(&it);
551         switch (hi){
552             case OBEX_HEADER_SINGLE_RESPONSE_MODE:
553                 if (data_len != 1) break;
554                 srm_value = *data;
555                 break;
556             case OBEX_HEADER_SINGLE_RESPONSE_MODE_PARAMETER:
557                 if (data_len != 1) break;
558                 srmp_value = *data;
559                 break;
560             default:
561                 break;
562         }
563     }
564 
565     // Update SRM state based on SRM haders
566     switch (context->srm_state){
567         case SRM_W4_CONFIRM:
568             switch (srm_value){
569                 case OBEX_SRM_ENABLE:
570                     switch (srmp_value){
571                         case OBEX_SRMP_WAIT:
572                             context->srm_state = SRM_ENABLED_BUT_WAITING;
573                             break;
574                         default:
575                             context->srm_state = SRM_ENABLED;
576                             break;
577                     }
578                     break;
579                 default:
580                     context->srm_state = SRM_DISABLED;
581                     break;
582             }
583             break;
584         case SRM_ENABLED_BUT_WAITING:
585             switch (srmp_value){
586                 case OBEX_SRMP_WAIT:
587                     context->srm_state = SRM_ENABLED_BUT_WAITING;
588                     break;
589                 default:
590                     context->srm_state = SRM_ENABLED;
591                     break;
592             }
593             break;
594         default:
595             break;
596     }
597     log_info("SRM state %u", context->srm_state);
598 }
599 
600 static void pbap_client_process_vcard_listing(uint8_t *packet, uint16_t size){
601     obex_iterator_t it;
602     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)){
603         uint8_t hi = obex_iterator_get_hi(&it);
604         if ((hi == OBEX_HEADER_END_OF_BODY) ||
605             (hi == OBEX_HEADER_BODY)){
606             uint16_t     data_len = obex_iterator_get_data_len(&it);
607             const uint8_t  * data =  obex_iterator_get_data(&it);
608             // now try parsing it
609             uint16_t char_len;
610             while (data_len--){
611                 yxml_ret_t r = yxml_parse(&pbap_client->xml_parser, *data++);
612                 switch (r){
613                     case YXML_ELEMSTART:
614                         pbap_client->parser_card_found = strcmp("card", pbap_client->xml_parser.elem) == 0;
615                         break;
616                     case YXML_ELEMEND:
617                         if (pbap_client->parser_card_found){
618                             pbap_client_emit_card_result_event(pbap_client, pbap_client->parser_name, pbap_client->parser_handle);
619                         }
620                         pbap_client->parser_card_found = false;
621                         break;
622                     case YXML_ATTRSTART:
623                         if (!pbap_client->parser_card_found) break;
624                         if (strcmp("name", pbap_client->xml_parser.attr) == 0){
625                             pbap_client->parser_name_found = true;
626                             pbap_client->parser_name[0]    = 0;
627                             break;
628                         }
629                         if (strcmp("handle", pbap_client->xml_parser.attr) == 0){
630                             pbap_client->parser_handle_found = true;
631                             pbap_client->parser_handle[0]    = 0;
632                             break;
633                         }
634                         break;
635                     case YXML_ATTRVAL:
636                         if (pbap_client->parser_name_found) {
637                             // "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."
638                             char_len = strlen(pbap_client->xml_parser.data);
639                             if ((strlen(pbap_client->parser_name) + char_len + 1) >= sizeof(pbap_client->parser_name)) break;
640                             strcat(pbap_client->parser_name, pbap_client->xml_parser.data);
641                             break;
642                         }
643                         if (pbap_client->parser_handle_found) {
644                             // "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."
645                             char_len = strlen(pbap_client->xml_parser.data);
646                             if ((strlen(pbap_client->parser_handle) + char_len + 1) >= sizeof(pbap_client->parser_handle)) break;
647                             strcat(pbap_client->parser_handle, pbap_client->xml_parser.data);
648                             break;
649                         }
650                         break;
651                     case YXML_ATTREND:
652                         pbap_client->parser_name_found = false;
653                         pbap_client->parser_handle_found = false;
654                         break;
655                     default:
656                         break;
657                 }
658             }
659         }
660     }
661 }
662 static void pbap_packet_handler_hci(uint8_t *packet, uint16_t size){
663     UNUSED(size);
664     uint8_t status;
665     switch (hci_event_packet_get_type(packet)) {
666         case HCI_EVENT_GOEP_META:
667             switch (hci_event_goep_meta_get_subevent_code(packet)){
668                 case GOEP_SUBEVENT_CONNECTION_OPENED:
669                     status = goep_subevent_connection_opened_get_status(packet);
670                     pbap_client->con_handle = goep_subevent_connection_opened_get_con_handle(packet);
671                     pbap_client->incoming = goep_subevent_connection_opened_get_incoming(packet);
672                     goep_subevent_connection_opened_get_bd_addr(packet, pbap_client->bd_addr);
673                     if (status){
674                         log_info("pbap: connection failed %u", status);
675                         pbap_client->state = PBAP_INIT;
676                         pbap_client_emit_connected_event(pbap_client, status);
677                     } else {
678                         log_info("pbap: connection established");
679                         pbap_client->goep_cid = goep_subevent_connection_opened_get_goep_cid(packet);
680                         pbap_client->state = PBAP_W2_SEND_CONNECT_REQUEST;
681                         goep_client_request_can_send_now(pbap_client->goep_cid);
682                     }
683                     break;
684                 case GOEP_SUBEVENT_CONNECTION_CLOSED:
685                     if (pbap_client->state != PBAP_CONNECTED){
686                         pbap_client_emit_operation_complete_event(pbap_client, OBEX_DISCONNECTED);
687                     }
688                     pbap_client->state = PBAP_INIT;
689                     pbap_client_emit_connection_closed_event(pbap_client);
690                     break;
691                 case GOEP_SUBEVENT_CAN_SEND_NOW:
692                     pbap_handle_can_send_now();
693                     break;
694                 default:
695                     break;
696             }
697             break;
698         default:
699             break;
700     }
701 }
702 
703 static void pbap_packet_handler_goep(uint8_t *packet, uint16_t size){
704     obex_iterator_t it;
705     int wait_for_user = 0;
706 
707     // TODO: handle chunked data
708     switch (pbap_client->state){
709         case PBAP_W4_CONNECT_RESPONSE:
710             switch (packet[0]){
711                 case OBEX_RESP_SUCCESS:
712                     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)){
713                         uint8_t hi = obex_iterator_get_hi(&it);
714                         if (hi == OBEX_HEADER_CONNECTION_ID){
715                             goep_client_set_connection_id(pbap_client->goep_cid, obex_iterator_get_data_32(&it));
716                         }
717                     }
718                     pbap_client->state = PBAP_CONNECTED;
719                     pbap_client->vcard_selector_supported = pbap_supported_features & goep_client_get_pbap_supported_features(pbap_client->goep_cid) & PBAP_SUPPORTED_FEATURES_VCARD_SELECTING;
720                     pbap_client_emit_connected_event(pbap_client, 0);
721                     break;
722                 case OBEX_RESP_UNAUTHORIZED:
723                     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)){
724                         uint8_t hi = obex_iterator_get_hi(&it);
725                         if (hi == OBEX_HEADER_AUTHENTICATION_CHALLENGE){
726                             pbap_parse_authentication_challenge(pbap_client, obex_iterator_get_data(&it), obex_iterator_get_data_len(&it));
727                         }
728                     }
729                     pbap_client->state = PBAP_W4_USER_AUTHENTICATION;
730                     pbap_client_emit_authentication_event(pbap_client, pbap_client->authentication_options);
731                     break;
732                 default:
733                     log_info("pbap: obex connect failed, result 0x%02x", packet[0]);
734                     pbap_client->state = PBAP_INIT;
735                     pbap_client_emit_connected_event(pbap_client, OBEX_CONNECT_FAILED);
736                     break;
737             }
738             break;
739         case PBAP_W4_DISCONNECT_RESPONSE:
740             goep_client_disconnect(pbap_client->goep_cid);
741             break;
742         case PBAP_W4_SET_PATH_ROOT_COMPLETE:
743         case PBAP_W4_SET_PATH_ELEMENT_COMPLETE:
744             if (packet[0] == OBEX_RESP_SUCCESS){
745                 // more path?
746                 if (pbap_client->current_folder[pbap_client->set_path_offset]){
747                     pbap_client->state = PBAP_W2_SET_PATH_ELEMENT;
748                     goep_client_request_can_send_now(pbap_client->goep_cid);
749                 } else {
750                     pbap_client->current_folder = NULL;
751                     pbap_client->state = PBAP_CONNECTED;
752                     pbap_client_emit_operation_complete_event(pbap_client, 0);
753                 }
754             } else if (packet[0] == OBEX_RESP_NOT_FOUND){
755                 pbap_client->state = PBAP_CONNECTED;
756                 pbap_client_emit_operation_complete_event(pbap_client, OBEX_NOT_FOUND);
757             } else {
758                 pbap_client->state = PBAP_CONNECTED;
759                 pbap_client_emit_operation_complete_event(pbap_client, OBEX_UNKNOWN_ERROR);
760             }
761             break;
762         case PBAP_W4_PHONEBOOK:
763             pbap_client->flow_next_triggered = 0;
764             wait_for_user = 0;
765             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)){
766                 uint8_t hi = obex_iterator_get_hi(&it);
767                 uint16_t     data_len = obex_iterator_get_data_len(&it);
768                 const uint8_t  * data = obex_iterator_get_data(&it);
769                 switch (hi){
770                     case OBEX_HEADER_BODY:
771                     case OBEX_HEADER_END_OF_BODY:
772                         pbap_client->client_handler(PBAP_DATA_PACKET, pbap_client->cid, (uint8_t *) data, data_len);
773                         wait_for_user++;
774                         if (wait_for_user > 1){
775                             log_error("wait_for_user %u", wait_for_user);
776                         }
777                         break;
778                     default:
779                         break;
780                 }
781             }
782             switch(packet[0]){
783                 case OBEX_RESP_CONTINUE:
784                     pbap_process_srm_headers(pbap_client, packet, size);
785                     if (pbap_client->srm_state ==  SRM_ENABLED) break;
786                     pbap_client->state = PBAP_W2_PULL_PHONEBOOK;
787                     if (!pbap_client->flow_control_enabled || !wait_for_user || pbap_client->flow_next_triggered) {
788                         goep_client_request_can_send_now(pbap_client->goep_cid);
789                     }
790                     break;
791                 case OBEX_RESP_SUCCESS:
792                     pbap_client->state = PBAP_CONNECTED;
793                     pbap_client_emit_operation_complete_event(pbap_client, 0);
794                     break;
795                 default:
796                     log_info("unexpected response 0x%02x", packet[0]);
797                     pbap_client->state = PBAP_CONNECTED;
798                     pbap_client_emit_operation_complete_event(pbap_client, OBEX_UNKNOWN_ERROR);
799                     break;
800             }
801             break;
802         case PBAP_W4_GET_PHONEBOOK_SIZE_COMPLETE:
803             pbap_client->state = PBAP_CONNECTED;
804             if (packet[0] == OBEX_RESP_SUCCESS){
805                 int have_size = 0;
806                 uint16_t phonebook_size;
807                 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)){
808                     uint8_t hi = obex_iterator_get_hi(&it);
809                     if (hi == OBEX_HEADER_APPLICATION_PARAMETERS){
810                         uint16_t     data_len = obex_iterator_get_data_len(&it);
811                         const uint8_t  * data =  obex_iterator_get_data(&it);
812                         // iterate over application headers (TLV with 1 bytes len)
813                         unsigned int i = 0;
814                         while (i<data_len){
815                             uint8_t tag = data[i++];
816                             uint8_t len = data[i++];
817                             if ((tag == PBAP_APPLICATION_PARAMETER_PHONEBOOK_SIZE) && (len == 2)){
818                                 have_size = 1;
819                                 phonebook_size = big_endian_read_16(data, i);
820                             }
821                             i+=len;
822                         }
823                     }
824                 }
825                 if (have_size){
826                     pbap_client_emit_phonebook_size_event(pbap_client, 0, phonebook_size);
827                     break;
828                 }
829             }
830             pbap_client_emit_phonebook_size_event(pbap_client, OBEX_UNKNOWN_ERROR, 0);
831             break;
832         case PBAP_W4_GET_CARD_LIST_COMPLETE:
833             switch (packet[0]){
834                 case OBEX_RESP_CONTINUE:
835                     // process data
836                     pbap_client_process_vcard_listing(packet, size);
837                     // handle continue
838                     pbap_process_srm_headers(pbap_client, packet, size);
839                     if (pbap_client->srm_state ==  SRM_ENABLED) break;
840                     pbap_client->state = PBAP_W2_GET_CARD_LIST;
841                     if (!pbap_client->flow_control_enabled || !wait_for_user || pbap_client->flow_next_triggered) {
842                         goep_client_request_can_send_now(pbap_client->goep_cid);
843                     }
844                     break;
845                 case OBEX_RESP_SUCCESS:
846                     // process data
847                     pbap_client_process_vcard_listing(packet, size);
848                     // done
849                     pbap_client->state = PBAP_CONNECTED;
850                     pbap_client_emit_operation_complete_event(pbap_client, 0);
851                     break;
852                 case OBEX_RESP_NOT_ACCEPTABLE:
853                     pbap_client->state = PBAP_CONNECTED;
854                     pbap_client_emit_operation_complete_event(pbap_client, OBEX_NOT_ACCEPTABLE);
855                     break;
856                 default:
857                     log_info("unexpected response 0x%02x", packet[0]);
858                     pbap_client->state = PBAP_CONNECTED;
859                     pbap_client_emit_operation_complete_event(pbap_client, OBEX_UNKNOWN_ERROR);
860                     break;
861             }
862             break;
863         case PBAP_W4_GET_CARD_ENTRY_COMPLETE:
864             switch (packet[0]){
865                 case OBEX_RESP_CONTINUE:
866                     pbap_process_srm_headers(pbap_client, packet, size);
867                     if (pbap_client->srm_state ==  SRM_ENABLED) break;
868                     pbap_client->state = PBAP_W2_GET_CARD_ENTRY;
869                     if (!pbap_client->flow_control_enabled || !wait_for_user || pbap_client->flow_next_triggered) {
870                         goep_client_request_can_send_now(pbap_client->goep_cid);
871                     }
872                     break;
873                 case OBEX_RESP_SUCCESS:
874                     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)){
875                         uint8_t hi = obex_iterator_get_hi(&it);
876                         if ((hi == OBEX_HEADER_END_OF_BODY) ||
877                             (hi == OBEX_HEADER_BODY)){
878                             // uint16_t     data_len = obex_iterator_get_data_len(&it);
879                             // const uint8_t  * data =  obex_iterator_get_data(&it);
880                             // now try parsing it
881                         }
882                     }
883                     pbap_client->state = PBAP_CONNECTED;
884                     pbap_client_emit_operation_complete_event(pbap_client, 0);
885                     break;
886                 case OBEX_RESP_NOT_ACCEPTABLE:
887                     pbap_client->state = PBAP_CONNECTED;
888                     pbap_client_emit_operation_complete_event(pbap_client, OBEX_NOT_ACCEPTABLE);
889                     break;
890                 default:
891                     log_info("unexpected response 0x%02x", packet[0]);
892                     pbap_client->state = PBAP_CONNECTED;
893                     pbap_client_emit_operation_complete_event(pbap_client, OBEX_UNKNOWN_ERROR);
894                     break;
895             }
896             break;
897         default:
898             break;
899     }
900 }
901 
902 static void pbap_packet_handler(uint8_t packet_type, uint16_t channel, uint8_t *packet, uint16_t size){
903     UNUSED(channel); // ok: there is no channel
904     UNUSED(size);    // ok: handling own geop events
905 
906     switch (packet_type){
907         case HCI_EVENT_PACKET:
908             pbap_packet_handler_hci(packet, size);
909             break;
910         case GOEP_DATA_PACKET:
911             pbap_packet_handler_goep(packet, size);
912             break;
913         default:
914             break;
915     }
916 }
917 
918 void pbap_client_init(void){
919     memset(pbap_client, 0, sizeof(pbap_client_t));
920     pbap_client->state = PBAP_INIT;
921     pbap_client->cid = 1;
922 }
923 
924 void pbap_client_deinit(void){
925 }
926 
927 uint8_t pbap_connect(btstack_packet_handler_t handler, bd_addr_t addr, uint16_t * out_cid){
928     if (pbap_client->state != PBAP_INIT) return BTSTACK_MEMORY_ALLOC_FAILED;
929 
930     pbap_client->state = PBAP_W4_GOEP_CONNECTION;
931     pbap_client->client_handler = handler;
932     pbap_client->vcard_selector = 0;
933     pbap_client->vcard_selector_operator = PBAP_VCARD_SELECTOR_OPERATOR_OR;
934 
935     uint8_t err = goep_client_create_connection(&pbap_packet_handler, addr, BLUETOOTH_SERVICE_CLASS_PHONEBOOK_ACCESS_PSE, &pbap_client->goep_cid);
936     *out_cid = pbap_client->cid;
937     if (err) return err;
938     return 0;
939 }
940 
941 uint8_t pbap_disconnect(uint16_t pbap_cid){
942     UNUSED(pbap_cid);
943     if (pbap_client->state != PBAP_CONNECTED) return BTSTACK_BUSY;
944     pbap_client->state = PBAP_W2_SEND_DISCONNECT_REQUEST;
945     goep_client_request_can_send_now(pbap_client->goep_cid);
946     return 0;
947 }
948 
949 uint8_t pbap_get_phonebook_size(uint16_t pbap_cid, const char * path){
950     UNUSED(pbap_cid);
951     if (pbap_client->state != PBAP_CONNECTED) return BTSTACK_BUSY;
952     pbap_client->state = PBAP_W2_GET_PHONEBOOK_SIZE;
953     pbap_client->phonebook_path = path;
954     pbap_client->request_number = 0;
955     goep_client_request_can_send_now(pbap_client->goep_cid);
956     return 0;
957 }
958 
959 uint8_t pbap_pull_phonebook(uint16_t pbap_cid, const char * path){
960     UNUSED(pbap_cid);
961     if (pbap_client->state != PBAP_CONNECTED) return BTSTACK_BUSY;
962     pbap_client->state = PBAP_W2_PULL_PHONEBOOK;
963     pbap_client->phonebook_path = path;
964     pbap_client->request_number = 0;
965     goep_client_request_can_send_now(pbap_client->goep_cid);
966     return 0;
967 }
968 
969 uint8_t pbap_set_phonebook(uint16_t pbap_cid, const char * path){
970     UNUSED(pbap_cid);
971     if (pbap_client->state != PBAP_CONNECTED) return BTSTACK_BUSY;
972     pbap_client->state = PBAP_W2_SET_PATH_ROOT;
973     pbap_client->current_folder = path;
974     pbap_client->set_path_offset = 0;
975     goep_client_request_can_send_now(pbap_client->goep_cid);
976     return 0;
977 }
978 
979 uint8_t pbap_authentication_password(uint16_t pbap_cid, const char * password){
980     UNUSED(pbap_cid);
981     if (pbap_client->state != PBAP_W4_USER_AUTHENTICATION) return BTSTACK_BUSY;
982     pbap_client->state = PBAP_W2_SEND_AUTHENTICATED_CONNECT;
983     pbap_client->authentication_password = password;
984     goep_client_request_can_send_now(pbap_client->goep_cid);
985     return 0;
986 }
987 
988 uint8_t pbap_pull_vcard_listing(uint16_t pbap_cid, const char * path){
989     UNUSED(pbap_cid);
990     if (pbap_client->state != PBAP_CONNECTED) return BTSTACK_BUSY;
991     pbap_client->state = PBAP_W2_GET_CARD_LIST;
992     pbap_client->phonebook_path = path;
993     pbap_client->phone_number = NULL;
994     pbap_client->request_number = 0;
995     pbap_client_vcard_listing_init_parser(pbap_client);
996     goep_client_request_can_send_now(pbap_client->goep_cid);
997     return 0;
998 }
999 
1000 uint8_t pbap_pull_vcard_entry(uint16_t pbap_cid, const char * path){
1001     UNUSED(pbap_cid);
1002     if (pbap_client->state != PBAP_CONNECTED) return BTSTACK_BUSY;
1003     pbap_client->state = PBAP_W2_GET_CARD_ENTRY;
1004     // pbap_client->phonebook_path = NULL;
1005     // pbap_client->phone_number = NULL;
1006     pbap_client->vcard_name = path;
1007     pbap_client->request_number = 0;
1008     goep_client_request_can_send_now(pbap_client->goep_cid);
1009     return 0;
1010 }
1011 
1012 uint8_t pbap_lookup_by_number(uint16_t pbap_cid, const char * phone_number){
1013     UNUSED(pbap_cid);
1014     if (pbap_client->state != PBAP_CONNECTED) return BTSTACK_BUSY;
1015     pbap_client->state = PBAP_W2_GET_CARD_LIST;
1016     pbap_client->phonebook_path = pbap_vcard_listing_name;
1017     pbap_client->phone_number   = phone_number;
1018     pbap_client->request_number = 0;
1019     pbap_client_vcard_listing_init_parser(pbap_client);
1020     goep_client_request_can_send_now(pbap_client->goep_cid);
1021     return 0;
1022 }
1023 
1024 uint8_t pbap_abort(uint16_t pbap_cid){
1025     UNUSED(pbap_cid);
1026     log_info("abort current operation, state 0x%02x", pbap_client->state);
1027     pbap_client->abort_operation = 1;
1028     return 0;
1029 }
1030 
1031 uint8_t pbap_next_packet(uint16_t pbap_cid){
1032     // log_info("pbap_next_packet, state %x", pbap_client->state);
1033     UNUSED(pbap_cid);
1034     if (!pbap_client->flow_control_enabled) return 0;
1035     switch (pbap_client->state){
1036         case PBAP_W2_PULL_PHONEBOOK:
1037             goep_client_request_can_send_now(pbap_client->goep_cid);
1038             break;
1039         case PBAP_W4_PHONEBOOK:
1040             pbap_client->flow_next_triggered = 1;
1041             break;
1042         default:
1043             break;
1044     }
1045     return 0;
1046 }
1047 
1048 uint8_t pbap_set_flow_control_mode(uint16_t pbap_cid, int enable){
1049     UNUSED(pbap_cid);
1050     if (pbap_client->state != PBAP_CONNECTED) return BTSTACK_BUSY;
1051     pbap_client->flow_control_enabled = enable;
1052     return 0;
1053 }
1054 
1055 uint8_t pbap_set_vcard_selector(uint16_t pbap_cid, uint32_t vcard_selector){
1056     UNUSED(pbap_cid);
1057     pbap_client->vcard_selector = vcard_selector;
1058     return 0;
1059 }
1060 
1061 uint8_t pbap_set_vcard_selector_operator(uint16_t pbap_cid, int vcard_selector_operator){
1062     UNUSED(pbap_cid);
1063     pbap_client->vcard_selector_operator = vcard_selector_operator;
1064     return 0;
1065 }
1066