summaryrefslogtreecommitdiffabout
path: root/lib/discovery.cc
Unidiff
Diffstat (limited to 'lib/discovery.cc') (more/less context) (ignore whitespace changes)
-rw-r--r--lib/discovery.cc4
1 files changed, 2 insertions, 2 deletions
diff --git a/lib/discovery.cc b/lib/discovery.cc
index d1989ec..984e308 100644
--- a/lib/discovery.cc
+++ b/lib/discovery.cc
@@ -246,339 +246,339 @@ namespace opkele {
246 throw exception_curl(OPKELE_CP_ "failed to perform curly request",r); 246 throw exception_curl(OPKELE_CP_ "failed to perform curly request",r);
247 247
248 if(!parser_choked) { 248 if(!parser_choked) {
249 parse(0,0,true); 249 parse(0,0,true);
250 }else if(xmode&xmode_html){ 250 }else if(xmode&xmode_html){
251 /* TODO: do not bother if we've seen xml */ 251 /* TODO: do not bother if we've seen xml */
252 try { 252 try {
253 util::tidy_doc_t td = util::tidy_doc_t::create(); 253 util::tidy_doc_t td = util::tidy_doc_t::create();
254 if(!td) 254 if(!td)
255 throw exception_tidy(OPKELE_CP_ "failed to create htmltidy document"); 255 throw exception_tidy(OPKELE_CP_ "failed to create htmltidy document");
256#ifndef NDEBUG 256#ifndef NDEBUG
257 td.opt_set(TidyQuiet,false); 257 td.opt_set(TidyQuiet,false);
258 td.opt_set(TidyShowWarnings,false); 258 td.opt_set(TidyShowWarnings,false);
259#endif /* NDEBUG */ 259#endif /* NDEBUG */
260 td.opt_set(TidyForceOutput,true); 260 td.opt_set(TidyForceOutput,true);
261 td.opt_set(TidyXhtmlOut,true); 261 td.opt_set(TidyXhtmlOut,true);
262 td.opt_set(TidyDoctypeMode,TidyDoctypeOmit); 262 td.opt_set(TidyDoctypeMode,TidyDoctypeOmit);
263 td.opt_set(TidyMark,false); 263 td.opt_set(TidyMark,false);
264 td.opt_set(TidyNumEntities,true); 264 td.opt_set(TidyNumEntities,true);
265 if(td.parse_string(save_html)<=0) 265 if(td.parse_string(save_html)<=0)
266 throw exception_tidy(OPKELE_CP_ "tidy failed to parse document"); 266 throw exception_tidy(OPKELE_CP_ "tidy failed to parse document");
267 if(td.clean_and_repair()<=0) 267 if(td.clean_and_repair()<=0)
268 throw exception_tidy(OPKELE_CP_ "tidy failed to clean and repair"); 268 throw exception_tidy(OPKELE_CP_ "tidy failed to clean and repair");
269 util::tidy_buf_t tide; 269 util::tidy_buf_t tide;
270 if(td.save_buffer(tide)<=0) 270 if(td.save_buffer(tide)<=0)
271 throw exception_tidy(OPKELE_CP_ "tidy failed to save buffer"); 271 throw exception_tidy(OPKELE_CP_ "tidy failed to save buffer");
272 prepare_to_parse(); 272 prepare_to_parse();
273 parse(tide.c_str(),tide.size(),true); 273 parse(tide.c_str(),tide.size(),true);
274 }catch(exception_tidy& et) { } 274 }catch(exception_tidy& et) { }
275 } 275 }
276 save_html.clear(); 276 save_html.clear();
277 } 277 }
278 278
279 void prepare_to_parse() { 279 void prepare_to_parse() {
280 (*(expat_t*)this) = parser_create_ns(); 280 (*(expat_t*)this) = parser_create_ns();
281 set_user_data(); set_element_handler(); 281 set_user_data(); set_element_handler();
282 set_character_data_handler(); 282 set_character_data_handler();
283 283
284 if(xmode&xmode_html) { 284 if(xmode&xmode_html) {
285 html_openid1.clear(); html_openid2.clear(); 285 html_openid1.clear(); html_openid2.clear();
286 parser_choked = false; 286 parser_choked = false;
287 } 287 }
288 288
289 cdata = 0; xrd_service = 0; skipping = 0; 289 cdata = 0; xrd_service = 0; skipping = 0;
290 pt_stack.clear(); 290 pt_stack.clear();
291 status_code = 100; status_string.clear(); 291 status_code = 100; status_string.clear();
292 } 292 }
293 293
294 void html2xrd(endpoint_discovery_iterator& oi,idiscovery_t& id) { 294 void html2xrd(endpoint_discovery_iterator& oi,idiscovery_t& id) {
295 XRD_t& x = id.xrd; 295 XRD_t& x = id.xrd;
296 if(!html_openid2.uris.empty()) { 296 if(!html_openid2.uris.empty()) {
297 html_openid2.types.insert(STURI_OPENID20); 297 html_openid2.types.insert(STURI_OPENID20);
298 x.services.add(-1,html_openid2); 298 x.services.add(-1,html_openid2);
299 queue_endpoints(oi,id,&op_service_types[st_index_2]); 299 queue_endpoints(oi,id,&op_service_types[st_index_2]);
300 } 300 }
301 if(!html_openid1.uris.empty()) { 301 if(!html_openid1.uris.empty()) {
302 html_openid1.types.insert(STURI_OPENID11); 302 html_openid1.types.insert(STURI_OPENID11);
303 x.services.add(-1,html_openid1); 303 x.services.add(-1,html_openid1);
304 queue_endpoints(oi,id,&op_service_types[st_index_1]); 304 queue_endpoints(oi,id,&op_service_types[st_index_1]);
305 } 305 }
306 } 306 }
307 307
308 size_t write(void *p,size_t s,size_t nm) { 308 size_t write(void *p,size_t s,size_t nm) {
309 /* TODO: limit total size */ 309 /* TODO: limit total size */
310 size_t bytes = s*nm; 310 size_t bytes = s*nm;
311 const char *inbuf = (const char*)p; 311 const char *inbuf = (const char*)p;
312 if(xmode&xmode_html) { 312 if(xmode&xmode_html) {
313 size_t mbts = save_html.capacity()-save_html.size(); 313 size_t mbts = save_html.capacity()-save_html.size();
314 size_t bts = 0; 314 size_t bts = 0;
315 if(mbts>0) { 315 if(mbts>0) {
316 bts = (bytes>mbts)?mbts:bytes; 316 bts = (bytes>mbts)?mbts:bytes;
317 save_html.append(inbuf,bts); 317 save_html.append(inbuf,bts);
318 } 318 }
319 if(skipping<0) return bts; 319 if(skipping<0) return bts;
320 } 320 }
321 if(skipping<0) return 0; 321 if(skipping<0) return 0;
322 bool rp = parse(inbuf,bytes,false); 322 bool rp = parse(inbuf,bytes,false);
323 if(!rp) { 323 if(!rp) {
324 parser_choked = true; 324 parser_choked = true;
325 skipping = -1; 325 skipping = -1;
326 if(!(xmode&xmode_html)) 326 if(!(xmode&xmode_html))
327 bytes = 0; 327 bytes = 0;
328 } 328 }
329 return bytes; 329 return bytes;
330 } 330 }
331 size_t header(void *p,size_t s,size_t nm) { 331 size_t header(void *p,size_t s,size_t nm) {
332 size_t bytes = s*nm; 332 size_t bytes = s*nm;
333 const char *h = (const char*)p; 333 const char *h = (const char*)p;
334 const char *colon = (const char*)memchr(p,':',bytes); 334 const char *colon = (const char*)memchr(p,':',bytes);
335 const char *space = (const char*)memchr(p,' ',bytes); 335 const char *space = (const char*)memchr(p,' ',bytes);
336 if(space && ( (!colon) || space<colon ) ) { 336 if(space && ( (!colon) || space<colon ) ) {
337 xrds_location.clear(); http_content_type.clear(); 337 xrds_location.clear(); http_content_type.clear();
338 }else if(colon) { 338 }else if(colon) {
339 const char *hv = ++colon; 339 const char *hv = ++colon;
340 size_t hnl = colon-h; 340 size_t hnl = colon-h;
341 int rb; 341 int rb;
342 for(rb = bytes-hnl-1;rb>0 && isspace(*hv);++hv,--rb); 342 for(rb = bytes-hnl-1;rb>0 && isspace(*hv);++hv,--rb) ;
343 while(rb>0 && isspace(hv[rb-1])) --rb; 343 while(rb>0 && isspace(hv[rb-1])) --rb;
344 if(rb) { 344 if(rb) {
345 if( (hnl>=sizeof(XRDS_HEADER)) 345 if( (hnl>=sizeof(XRDS_HEADER))
346 && !strncasecmp(h,XRDS_HEADER":", 346 && !strncasecmp(h,XRDS_HEADER":",
347 sizeof(XRDS_HEADER)) ) { 347 sizeof(XRDS_HEADER)) ) {
348 xrds_location.assign(hv,rb); 348 xrds_location.assign(hv,rb);
349 }else if( (hnl>=sizeof(CT_HEADER)) 349 }else if( (hnl>=sizeof(CT_HEADER))
350 && !strncasecmp(h,CT_HEADER":", 350 && !strncasecmp(h,CT_HEADER":",
351 sizeof(CT_HEADER)) ) { 351 sizeof(CT_HEADER)) ) {
352 const char *sc = (const char*)memchr( 352 const char *sc = (const char*)memchr(
353 hv,';',rb); 353 hv,';',rb);
354 http_content_type.assign(hv,sc?(sc-hv):rb); 354 http_content_type.assign(hv,sc?(sc-hv):rb);
355 } 355 }
356 } 356 }
357 } 357 }
358 return curl_t::header(p,s,nm); 358 return curl_t::header(p,s,nm);
359 } 359 }
360 360
361 void start_element(const XML_Char *n,const XML_Char **a) { 361 void start_element(const XML_Char *n,const XML_Char **a) {
362 if(skipping<0) return; 362 if(skipping<0) return;
363 if(skipping) { 363 if(skipping) {
364 if(xmode&xmode_html) 364 if(xmode&xmode_html)
365 html_start_element(n,a); 365 html_start_element(n,a);
366 ++skipping; return; 366 ++skipping; return;
367 } 367 }
368 if(pt_stack.empty()) { 368 if(pt_stack.empty()) {
369 if(is_qelement(n,NSURI_XRDS "\tXRDS")) 369 if(is_qelement(n,NSURI_XRDS "\tXRDS"))
370 return; 370 return;
371 if(is_qelement(n,NSURI_XRD "\tXRD")) { 371 if(is_qelement(n,NSURI_XRD "\tXRD")) {
372 assert(xrd); 372 assert(xrd);
373 xrd->clear(); 373 xrd->clear();
374 pt_stack.push_back(n); 374 pt_stack.push_back(n);
375 }else if(xmode&xmode_html) { 375 }else if(xmode&xmode_html) {
376 html_start_element(n,a); 376 html_start_element(n,a);
377 }else{ 377 }else{
378 skipping = -1; 378 skipping = -1;
379 } 379 }
380 }else{ 380 }else{
381 int pt_s = pt_stack.size(); 381 int pt_s = pt_stack.size();
382 if(pt_s==1) { 382 if(pt_s==1) {
383 if(is_qelement(n,NSURI_XRD "\tCanonicalID")) { 383 if(is_qelement(n,NSURI_XRD "\tCanonicalID")) {
384 assert(xrd); 384 assert(xrd);
385 cdata = &(xrd->canonical_ids.add(element_priority(a),string())); 385 cdata = &(xrd->canonical_ids.add(element_priority(a),string()));
386 }else if(is_qelement(n,NSURI_XRD "\tLocalID")) { 386 }else if(is_qelement(n,NSURI_XRD "\tLocalID")) {
387 assert(xrd); 387 assert(xrd);
388 cdata = &(xrd->local_ids.add(element_priority(a),string())); 388 cdata = &(xrd->local_ids.add(element_priority(a),string()));
389 }else if(is_qelement(n,NSURI_XRD "\tProviderID")) { 389 }else if(is_qelement(n,NSURI_XRD "\tProviderID")) {
390 assert(xrd); 390 assert(xrd);
391 cdata = &(xrd->provider_id); 391 cdata = &(xrd->provider_id);
392 }else if(is_qelement(n,NSURI_XRD "\tService")) { 392 }else if(is_qelement(n,NSURI_XRD "\tService")) {
393 assert(xrd); 393 assert(xrd);
394 xrd_service = &(xrd->services.add(element_priority(a), 394 xrd_service = &(xrd->services.add(element_priority(a),
395 service_t())); 395 service_t()));
396 pt_stack.push_back(n); 396 pt_stack.push_back(n);
397 }else if(is_qelement(n,NSURI_XRD "\tStatus")) { 397 }else if(is_qelement(n,NSURI_XRD "\tStatus")) {
398 for(;*a;) { 398 for(;*a;) {
399 if(!strcasecmp(*(a++),"code")) { 399 if(!strcasecmp(*(a++),"code")) {
400 if(sscanf(*(a++),"%ld",&status_code)==1 && status_code!=100) { 400 if(sscanf(*(a++),"%ld",&status_code)==1 && status_code!=100) {
401 cdata = &status_string; 401 cdata = &status_string;
402 pt_stack.push_back(n); 402 pt_stack.push_back(n);
403 break; 403 break;
404 } 404 }
405 }else 405 }else
406 ++a; 406 ++a;
407 } 407 }
408 }else if(is_qelement(n,NSURI_XRD "\tExpires")) { 408 }else if(is_qelement(n,NSURI_XRD "\tExpires")) {
409 assert(xrd); 409 assert(xrd);
410 cdata_buf.clear(); 410 cdata_buf.clear();
411 cdata = &cdata_buf; 411 cdata = &cdata_buf;
412 }else if(xmode&xmode_html) { 412 }else if(xmode&xmode_html) {
413 html_start_element(n,a); 413 html_start_element(n,a);
414 }else{ 414 }else{
415 skipping = 1; 415 skipping = 1;
416 } 416 }
417 }else if(pt_s==2) { 417 }else if(pt_s==2) {
418 if(is_qelement(pt_stack.back().c_str(), NSURI_XRD "\tService")) { 418 if(is_qelement(pt_stack.back().c_str(), NSURI_XRD "\tService")) {
419 if(is_qelement(n,NSURI_XRD "\tType")) { 419 if(is_qelement(n,NSURI_XRD "\tType")) {
420 assert(xrd); assert(xrd_service); 420 assert(xrd); assert(xrd_service);
421 cdata_buf.clear(); 421 cdata_buf.clear();
422 cdata = &cdata_buf; 422 cdata = &cdata_buf;
423 }else if(is_qelement(n,NSURI_XRD "\tURI")) { 423 }else if(is_qelement(n,NSURI_XRD "\tURI")) {
424 assert(xrd); assert(xrd_service); 424 assert(xrd); assert(xrd_service);
425 const char *append = element_attr(a,"append"); 425 const char *append = element_attr(a,"append");
426 xrd::uri_t& uri = xrd_service->uris.add(element_priority(a),xrd::uri_t("",append?append:"")); 426 xrd::uri_t& uri = xrd_service->uris.add(element_priority(a),xrd::uri_t("",append?append:""));
427 cdata = &uri.uri; 427 cdata = &uri.uri;
428 }else if(is_qelement(n,NSURI_XRD "\tLocalID") 428 }else if(is_qelement(n,NSURI_XRD "\tLocalID")
429 || is_qelement(n,NSURI_OPENID10 "\tDelegate") ) { 429 || is_qelement(n,NSURI_OPENID10 "\tDelegate") ) {
430 assert(xrd); assert(xrd_service); 430 assert(xrd); assert(xrd_service);
431 cdata = &(xrd_service->local_ids.add(element_priority(a),string())); 431 cdata = &(xrd_service->local_ids.add(element_priority(a),string()));
432 }else if(is_qelement(n,NSURI_XRD "\tProviderID")) { 432 }else if(is_qelement(n,NSURI_XRD "\tProviderID")) {
433 assert(xrd); assert(xrd_service); 433 assert(xrd); assert(xrd_service);
434 cdata = &(xrd_service->provider_id); 434 cdata = &(xrd_service->provider_id);
435 }else{ 435 }else{
436 skipping = 1; 436 skipping = 1;
437 } 437 }
438 }else 438 }else
439 skipping = 1; 439 skipping = 1;
440 }else if(xmode&xmode_html) { 440 }else if(xmode&xmode_html) {
441 html_start_element(n,a); 441 html_start_element(n,a);
442 }else{ 442 }else{
443 skipping = 1; 443 skipping = 1;
444 } 444 }
445 } 445 }
446 } 446 }
447 void end_element(const XML_Char *n) { 447 void end_element(const XML_Char *n) {
448 if(skipping<0) return; 448 if(skipping<0) return;
449 if(skipping) { 449 if(skipping) {
450 --skipping; return; 450 --skipping; return;
451 } 451 }
452 if(is_qelement(n,NSURI_XRD "\tType")) { 452 if(is_qelement(n,NSURI_XRD "\tType")) {
453 assert(xrd); assert(xrd_service); assert(cdata==&cdata_buf); 453 assert(xrd); assert(xrd_service); assert(cdata==&cdata_buf);
454 xrd_service->types.insert(cdata_buf); 454 xrd_service->types.insert(cdata_buf);
455 }else if(is_qelement(n,NSURI_XRD "\tService")) { 455 }else if(is_qelement(n,NSURI_XRD "\tService")) {
456 assert(xrd); assert(xrd_service); 456 assert(xrd); assert(xrd_service);
457 assert(!pt_stack.empty()); 457 assert(!pt_stack.empty());
458 assert(pt_stack.back()==(NSURI_XRD "\tService")); 458 assert(pt_stack.back()==(NSURI_XRD "\tService"));
459 pt_stack.pop_back(); 459 pt_stack.pop_back();
460 xrd_service = 0; 460 xrd_service = 0;
461 }else if(is_qelement(n,NSURI_XRD "\tStatus")) { 461 }else if(is_qelement(n,NSURI_XRD "\tStatus")) {
462 assert(xrd); 462 assert(xrd);
463 if(is_qelement(pt_stack.back().c_str(),n)) { 463 if(is_qelement(pt_stack.back().c_str(),n)) {
464 assert(cdata==&status_string); 464 assert(cdata==&status_string);
465 pt_stack.pop_back(); 465 pt_stack.pop_back();
466 if(status_code!=100) 466 if(status_code!=100)
467 skipping = -1; 467 skipping = -1;
468 } 468 }
469 }else if(is_qelement(n,NSURI_XRD "\tExpires")) { 469 }else if(is_qelement(n,NSURI_XRD "\tExpires")) {
470 assert(xrd); 470 assert(xrd);
471 xrd->expires = util::w3c_to_time(cdata_buf); 471 xrd->expires = util::w3c_to_time(cdata_buf);
472 }else if((xmode&xmode_html) && is_element(n,"head")) { 472 }else if((xmode&xmode_html) && is_element(n,"head")) {
473 skipping = -1; 473 skipping = -1;
474 } 474 }
475 cdata = 0; 475 cdata = 0;
476 } 476 }
477 void character_data(const XML_Char *s,int l) { 477 void character_data(const XML_Char *s,int l) {
478 if(skipping) return; 478 if(skipping) return;
479 if(cdata) cdata->append(s,l); 479 if(cdata) cdata->append(s,l);
480 } 480 }
481 481
482 void html_start_element(const XML_Char *n,const XML_Char **a) { 482 void html_start_element(const XML_Char *n,const XML_Char **a) {
483 if(is_element(n,"meta")) { 483 if(is_element(n,"meta")) {
484 bool heq = false; 484 bool heq = false;
485 string l; 485 string l;
486 for(;*a;a+=2) { 486 for(;*a;a+=2) {
487 if(!( strcasecmp(a[0],"http-equiv") 487 if(!( strcasecmp(a[0],"http-equiv")
488 || strcasecmp(a[1],XRDS_HEADER) )) 488 || strcasecmp(a[1],XRDS_HEADER) ))
489 heq = true; 489 heq = true;
490 else if(!strcasecmp(a[0],"content")) 490 else if(!strcasecmp(a[0],"content"))
491 l.assign(a[1]); 491 l.assign(a[1]);
492 } 492 }
493 if(heq) 493 if(heq)
494 xrds_location = l; 494 xrds_location = l;
495 }else if(is_element(n,"link")) { 495 }else if(is_element(n,"link")) {
496 string rels; 496 string rels;
497 string href; 497 string href;
498 for(;*a;a+=2) { 498 for(;*a;a+=2) {
499 if( !strcasecmp(a[0],"rel") ) { 499 if( !strcasecmp(a[0],"rel") ) {
500 rels.assign(a[1]); 500 rels.assign(a[1]);
501 }else if( !strcasecmp(a[0],"href") ) { 501 }else if( !strcasecmp(a[0],"href") ) {
502 const char *ns = a[1]; 502 const char *ns = a[1];
503 for(;*ns && isspace(*ns);++ns); 503 for(;*ns && isspace(*ns);++ns) ;
504 href.assign(ns); 504 href.assign(ns);
505 string::size_type lns=href.find_last_not_of(data::_whitespace_chars); 505 string::size_type lns=href.find_last_not_of(data::_whitespace_chars);
506 href.erase(lns+1); 506 href.erase(lns+1);
507 } 507 }
508 } 508 }
509 for(string::size_type ns=rels.find_first_not_of(data::_whitespace_chars); 509 for(string::size_type ns=rels.find_first_not_of(data::_whitespace_chars);
510 ns!=string::npos; ns=rels.find_first_not_of(data::_whitespace_chars,ns)) { 510 ns!=string::npos; ns=rels.find_first_not_of(data::_whitespace_chars,ns)) {
511 string::size_type s = rels.find_first_of(data::_whitespace_chars,ns); 511 string::size_type s = rels.find_first_of(data::_whitespace_chars,ns);
512 string rel; 512 string rel;
513 if(s==string::npos) { 513 if(s==string::npos) {
514 rel.assign(rels,ns,string::npos); 514 rel.assign(rels,ns,string::npos);
515 ns = string::npos; 515 ns = string::npos;
516 }else{ 516 }else{
517 rel.assign(rels,ns,s-ns); 517 rel.assign(rels,ns,s-ns);
518 ns = s; 518 ns = s;
519 } 519 }
520 if(rel=="openid.server") 520 if(rel=="openid.server")
521 html_openid1.uris.add(-1,xrd::uri_t(href)); 521 html_openid1.uris.add(-1,xrd::uri_t(href));
522 else if(rel=="openid.delegate") 522 else if(rel=="openid.delegate")
523 html_openid1.local_ids.add(-1,href); 523 html_openid1.local_ids.add(-1,href);
524 else if(rel=="openid2.provider") 524 else if(rel=="openid2.provider")
525 html_openid2.uris.add(-1,xrd::uri_t(href)); 525 html_openid2.uris.add(-1,xrd::uri_t(href));
526 else if(rel=="openid2.local_id") 526 else if(rel=="openid2.local_id")
527 html_openid2.local_ids.add(-1,href); 527 html_openid2.local_ids.add(-1,href);
528 } 528 }
529 }else if(is_element(n,"body")) { 529 }else if(is_element(n,"body")) {
530 skipping = -1; 530 skipping = -1;
531 } 531 }
532 } 532 }
533 533
534 void queue_endpoints(endpoint_discovery_iterator& oi, 534 void queue_endpoints(endpoint_discovery_iterator& oi,
535 const idiscovery_t &id, 535 const idiscovery_t &id,
536 const service_type_t *st) { 536 const service_type_t *st) {
537 openid_endpoint_t ep; 537 openid_endpoint_t ep;
538 ep.claimed_id = id.canonicalized_id; 538 ep.claimed_id = id.canonicalized_id;
539 for(xrd::services_t::const_iterator isvc=id.xrd.services.begin(); 539 for(xrd::services_t::const_iterator isvc=id.xrd.services.begin();
540 isvc!=id.xrd.services.end(); ++isvc) { 540 isvc!=id.xrd.services.end(); ++isvc) {
541 const xrd::service_t svc = isvc->second; 541 const xrd::service_t svc = isvc->second;
542 if(svc.types.find(st->uri)==svc.types.end()) continue; 542 if(svc.types.find(st->uri)==svc.types.end()) continue;
543 for(xrd::uris_t::const_iterator iu=svc.uris.begin();iu!=svc.uris.end();++iu) { 543 for(xrd::uris_t::const_iterator iu=svc.uris.begin();iu!=svc.uris.end();++iu) {
544 ep.uri = iu->second.uri; 544 ep.uri = iu->second.uri;
545 if(id.xri_identity) { 545 if(id.xri_identity) {
546 if(iu->second.append=="qxri") { 546 if(iu->second.append=="qxri") {
547 ep.uri += id.normalized_id; 547 ep.uri += id.normalized_id;
548 } /* TODO: else handle other append attribute values */ 548 } /* TODO: else handle other append attribute values */
549 } 549 }
550 if(st->forceid) { 550 if(st->forceid) {
551 ep.local_id = ep.claimed_id = st->forceid; 551 ep.local_id = ep.claimed_id = st->forceid;
552 *(oi++) = ep; 552 *(oi++) = ep;
553 }else{ 553 }else{
554 if(svc.local_ids.empty()) { 554 if(svc.local_ids.empty()) {
555 ep.local_id = ep.claimed_id; 555 ep.local_id = ep.claimed_id;
556 *(oi++) = ep; 556 *(oi++) = ep;
557 }else{ 557 }else{
558 for(xrd::local_ids_t::const_iterator ilid=svc.local_ids.begin(); 558 for(xrd::local_ids_t::const_iterator ilid=svc.local_ids.begin();
559 ilid!=svc.local_ids.end(); ++ilid) { 559 ilid!=svc.local_ids.end(); ++ilid) {
560 ep.local_id = ilid->second; 560 ep.local_id = ilid->second;
561 *(oi++) = ep; 561 *(oi++) = ep;
562 } 562 }
563 } 563 }
564 } 564 }
565 } 565 }
566 } 566 }
567 } 567 }
568 568
569 }; 569 };
570 570
571 string idiscover(endpoint_discovery_iterator oi,const string& identity) { 571 string idiscover(endpoint_discovery_iterator oi,const string& identity) {
572 idigger_t idigger; 572 idigger_t idigger;
573 return idigger.discover(oi,identity); 573 return idigger.discover(oi,identity);
574 } 574 }
575 575
576 void yadiscover(endpoint_discovery_iterator oi,const string& yurl,const char **types,bool redirs) try { 576 void yadiscover(endpoint_discovery_iterator oi,const string& yurl,const char **types,bool redirs) try {
577 idigger_t idigger; 577 idigger_t idigger;
578 idigger.yadiscover(oi,yurl,types,redirs); 578 idigger.yadiscover(oi,yurl,types,redirs);
579 }catch(exception_curl& ec) { 579 }catch(exception_curl& ec) {
580 if(redirs || ec._error!=CURLE_TOO_MANY_REDIRECTS) 580 if(redirs || ec._error!=CURLE_TOO_MANY_REDIRECTS)
581 throw; 581 throw;
582 } 582 }
583 583
584} 584}