summaryrefslogtreecommitdiffabout
Unidiff
Diffstat (more/less context) (ignore whitespace changes)
-rw-r--r--include/opkele/iterator.h4
-rw-r--r--lib/discovery.cc4
-rw-r--r--lib/message.cc2
-rw-r--r--lib/prequeue_rp.cc4
-rw-r--r--lib/secret.cc2
-rw-r--r--lib/util.cc6
6 files changed, 11 insertions, 11 deletions
diff --git a/include/opkele/iterator.h b/include/opkele/iterator.h
index 28c1c83..8f86234 100644
--- a/include/opkele/iterator.h
+++ b/include/opkele/iterator.h
@@ -94,123 +94,123 @@ namespace opkele {
94 class forward_iterator_proxy : public iterator<forward_iterator_tag,T,void,TP,TR> { 94 class forward_iterator_proxy : public iterator<forward_iterator_tag,T,void,TP,TR> {
95 public: 95 public:
96 basic_forward_iterator_proxy_impl<T,TR,TP> *I; 96 basic_forward_iterator_proxy_impl<T,TR,TP> *I;
97 97
98 template<typename IT> 98 template<typename IT>
99 forward_iterator_proxy(const IT& i) 99 forward_iterator_proxy(const IT& i)
100 : I(new forward_iterator_proxy_impl<IT>(i)) { } 100 : I(new forward_iterator_proxy_impl<IT>(i)) { }
101 forward_iterator_proxy(const forward_iterator_proxy<T,TR,TP>& x) 101 forward_iterator_proxy(const forward_iterator_proxy<T,TR,TP>& x)
102 : I(x.I->dup()) { } 102 : I(x.I->dup()) { }
103 ~forward_iterator_proxy() { delete I; } 103 ~forward_iterator_proxy() { delete I; }
104 104
105 forward_iterator_proxy& operator=(const forward_iterator_proxy<T,TR,TP>& x) { 105 forward_iterator_proxy& operator=(const forward_iterator_proxy<T,TR,TP>& x) {
106 delete I; I = x.I->dup(); } 106 delete I; I = x.I->dup(); }
107 107
108 bool operator==(const forward_iterator_proxy<T,TR,TP>& x) const { 108 bool operator==(const forward_iterator_proxy<T,TR,TP>& x) const {
109 return (*I)==(*(x.I)); } 109 return (*I)==(*(x.I)); }
110 bool operator!=(const forward_iterator_proxy<T,TR,TP>& x) const { 110 bool operator!=(const forward_iterator_proxy<T,TR,TP>& x) const {
111 return (*I)!=(*(x.I)); } 111 return (*I)!=(*(x.I)); }
112 112
113 TR operator*() const { 113 TR operator*() const {
114 return **I; } 114 return **I; }
115 TP operator->() const { 115 TP operator->() const {
116 return I->operator->(); } 116 return I->operator->(); }
117 117
118 forward_iterator_proxy<T,TR,TP>& operator++() { 118 forward_iterator_proxy<T,TR,TP>& operator++() {
119 I->advance(); return *this; } 119 I->advance(); return *this; }
120 forward_iterator_proxy<T,TR,TP>& operator++(int) { 120 forward_iterator_proxy<T,TR,TP>& operator++(int) {
121 forward_iterator_proxy<T,TR,TP> rv(*this); 121 forward_iterator_proxy<T,TR,TP> rv(*this);
122 I->advance(); return rv; } 122 I->advance(); return rv; }
123 }; 123 };
124 124
125 template<typename IT> 125 template<typename IT>
126 class basic_filterator : public iterator< 126 class basic_filterator : public iterator<
127 typename IT::iterator_category, 127 typename IT::iterator_category,
128 typename IT::value_type, 128 typename IT::value_type,
129 typename IT::difference_type, 129 typename IT::difference_type,
130 typename IT::pointer, 130 typename IT::pointer,
131 typename IT::reference> { 131 typename IT::reference> {
132 public: 132 public:
133 IT it; 133 IT it;
134 IT ei; 134 IT ei;
135 bool empty; 135 bool empty;
136 136
137 basic_filterator() : empty(true) { } 137 basic_filterator() : empty(true) { }
138 basic_filterator(const IT& _bi,const IT& _ei) 138 basic_filterator(const IT& _bi,const IT& _ei)
139 : it(_bi), ei(_ei) { empty = (it==ei); } 139 : it(_bi), ei(_ei) { empty = (it==ei); }
140 basic_filterator(const basic_filterator<IT>& x) 140 basic_filterator(const basic_filterator<IT>& x)
141 : it(x.it), ei(x.ei), empty(x.empty) { } 141 : it(x.it), ei(x.ei), empty(x.empty) { }
142 virtual ~basic_filterator() { } 142 virtual ~basic_filterator() { }
143 143
144 bool operator==(const basic_filterator<IT>& x) const { 144 bool operator==(const basic_filterator<IT>& x) const {
145 return empty?x.empty:(it==x.it); } 145 return empty?x.empty:(it==x.it); }
146 bool operator!=(const basic_filterator<IT>& x) const { 146 bool operator!=(const basic_filterator<IT>& x) const {
147 return empty!=x.empty || it!=x.it; } 147 return empty!=x.empty || it!=x.it; }
148 148
149 typename IT::reference operator*() const { 149 typename IT::reference operator*() const {
150 assert(!empty); 150 assert(!empty);
151 return *it; } 151 return *it; }
152 typename IT::pointer operator->() const { 152 typename IT::pointer operator->() const {
153 assert(!empty); 153 assert(!empty);
154 return it.operator->(); } 154 return it.operator->(); }
155 155
156 basic_filterator<IT>& operator++() { 156 basic_filterator<IT>& operator++() {
157 bool found = false; 157 bool found = false;
158 for(++it;!(it==ei || (found=is_interesting()));++it); 158 for(++it;!(it==ei || (found=is_interesting()));++it) ;
159 if(!found) empty=true; 159 if(!found) empty=true;
160 return *this; 160 return *this;
161 } 161 }
162 basic_filterator<IT> operator++(int) { 162 basic_filterator<IT> operator++(int) {
163 basic_filterator<IT> rv(*this); 163 basic_filterator<IT> rv(*this);
164 ++(*this); 164 ++(*this);
165 return rv; 165 return rv;
166 } 166 }
167 167
168 void prepare() { 168 void prepare() {
169 bool found = false; 169 bool found = false;
170 for(;!(it==ei || (found=is_interesting()));++it); 170 for(;!(it==ei || (found=is_interesting()));++it) ;
171 if(!found) empty = true; 171 if(!found) empty = true;
172 } 172 }
173 virtual bool is_interesting() const = 0; 173 virtual bool is_interesting() const = 0;
174 }; 174 };
175 175
176 template<typename IT,typename T=typename IT::value_type::first_type,typename TR=T&,typename TP=T*> 176 template<typename IT,typename T=typename IT::value_type::first_type,typename TR=T&,typename TP=T*>
177 class map_keys_iterator : public iterator< 177 class map_keys_iterator : public iterator<
178 typename IT::iterator_category, 178 typename IT::iterator_category,
179 T,void,TP,TR> { 179 T,void,TP,TR> {
180 public: 180 public:
181 typedef map_keys_iterator<IT,T,TR,TP> self_type; 181 typedef map_keys_iterator<IT,T,TR,TP> self_type;
182 IT it; 182 IT it;
183 IT ei; 183 IT ei;
184 bool empty; 184 bool empty;
185 185
186 map_keys_iterator() : empty(true) { } 186 map_keys_iterator() : empty(true) { }
187 map_keys_iterator(const IT& _bi, 187 map_keys_iterator(const IT& _bi,
188 const IT& _ei) 188 const IT& _ei)
189 : it(_bi), ei(_ei) { empty = (it==ei); } 189 : it(_bi), ei(_ei) { empty = (it==ei); }
190 map_keys_iterator(const self_type& x) 190 map_keys_iterator(const self_type& x)
191 : it(x.it), ei(x.ei), empty(x.empty) { } 191 : it(x.it), ei(x.ei), empty(x.empty) { }
192 192
193 bool operator==(const self_type& x) const { 193 bool operator==(const self_type& x) const {
194 return empty?x.empty:(it==x.it); } 194 return empty?x.empty:(it==x.it); }
195 bool operator!=(const self_type& x) const { 195 bool operator!=(const self_type& x) const {
196 return empty!=x.empty || it!=x.it; } 196 return empty!=x.empty || it!=x.it; }
197 197
198 TR operator*() const { 198 TR operator*() const {
199 assert(!empty); 199 assert(!empty);
200 return it->first; } 200 return it->first; }
201 TP operator->() const { 201 TP operator->() const {
202 assert(!empty); 202 assert(!empty);
203 return &(it->first); } 203 return &(it->first); }
204 204
205 self_type& operator++() { 205 self_type& operator++() {
206 assert(!empty); 206 assert(!empty);
207 empty=((++it)==ei); return *this; } 207 empty=((++it)==ei); return *this; }
208 self_type operator++(int) { 208 self_type operator++(int) {
209 self_type rv(*this); 209 self_type rv(*this);
210 ++(*this); return rv; } 210 ++(*this); return rv; }
211 }; 211 };
212 212
213 } 213 }
214} 214}
215 215
216#endif /* __OPKELE_ITERATOR_H */ 216#endif /* __OPKELE_ITERATOR_H */
diff --git a/lib/discovery.cc b/lib/discovery.cc
index d1989ec..984e308 100644
--- a/lib/discovery.cc
+++ b/lib/discovery.cc
@@ -278,129 +278,129 @@ namespace opkele {
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;
@@ -439,129 +439,129 @@ namespace opkele {
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 }
diff --git a/lib/message.cc b/lib/message.cc
index 524946a..c1f8088 100644
--- a/lib/message.cc
+++ b/lib/message.cc
@@ -97,100 +97,100 @@ namespace opkele {
97 const char *pfx; 97 const char *pfx;
98 98
99 __om_html_outputter(const basic_openid_message& m,ostream& s,const char *p=0) 99 __om_html_outputter(const basic_openid_message& m,ostream& s,const char *p=0)
100 : om(m), os(s), pfx(p) { } 100 : om(m), os(s), pfx(p) { }
101 101
102 result_type operator()(argument_type f) { 102 result_type operator()(argument_type f) {
103 os << 103 os <<
104 "<input type=\"hidden\"" 104 "<input type=\"hidden\""
105 " name=\""; 105 " name=\"";
106 if(pfx) 106 if(pfx)
107 os << util::attr_escape(pfx); 107 os << util::attr_escape(pfx);
108 os << util::attr_escape(f) << "\"" 108 os << util::attr_escape(f) << "\""
109 " value=\"" << util::attr_escape(om.get_field(f)) << "\" />"; 109 " value=\"" << util::attr_escape(om.get_field(f)) << "\" />";
110 } 110 }
111 }; 111 };
112 112
113 void basic_openid_message::to_htmlhiddens(ostream& o,const char* pfx) const { 113 void basic_openid_message::to_htmlhiddens(ostream& o,const char* pfx) const {
114 for_each(fields_begin(),fields_end(),__om_html_outputter(*this,o,pfx)); 114 for_each(fields_begin(),fields_end(),__om_html_outputter(*this,o,pfx));
115 } 115 }
116 116
117 void basic_openid_message::add_to_signed(const string& fields) { 117 void basic_openid_message::add_to_signed(const string& fields) {
118 string::size_type fnc = fields.find_first_not_of(","); 118 string::size_type fnc = fields.find_first_not_of(",");
119 if(fnc==string::npos) 119 if(fnc==string::npos)
120 throw bad_input(OPKELE_CP_ "Trying to add nothing in particular to the list of signed fields"); 120 throw bad_input(OPKELE_CP_ "Trying to add nothing in particular to the list of signed fields");
121 string signeds; 121 string signeds;
122 try { 122 try {
123 signeds = get_field("signed"); 123 signeds = get_field("signed");
124 string::size_type lnc = signeds.find_last_not_of(","); 124 string::size_type lnc = signeds.find_last_not_of(",");
125 if(lnc==string::npos) 125 if(lnc==string::npos)
126 signeds.assign(fields,fnc,fields.size()-fnc); 126 signeds.assign(fields,fnc,fields.size()-fnc);
127 else{ 127 else{
128 string::size_type ss = signeds.size(); 128 string::size_type ss = signeds.size();
129 if(lnc==(ss-1)) { 129 if(lnc==(ss-1)) {
130 signeds+= ','; 130 signeds+= ',';
131 signeds.append(fields,fnc,fields.size()-fnc); 131 signeds.append(fields,fnc,fields.size()-fnc);
132 }else{ 132 }else{
133 if(lnc<(ss-2)) 133 if(lnc<(ss-2))
134 signeds.replace(lnc+2,ss-lnc-2, 134 signeds.replace(lnc+2,ss-lnc-2,
135 fields,fnc,fields.size()-fnc); 135 fields,fnc,fields.size()-fnc);
136 else 136 else
137 signeds.append(fields,fnc,fields.size()-fnc); 137 signeds.append(fields,fnc,fields.size()-fnc);
138 } 138 }
139 } 139 }
140 }catch(failed_lookup&) { 140 }catch(failed_lookup&) {
141 signeds.assign(fields,fnc,fields.size()-fnc); 141 signeds.assign(fields,fnc,fields.size()-fnc);
142 } 142 }
143 set_field("signed",signeds); 143 set_field("signed",signeds);
144 } 144 }
145 145
146 string basic_openid_message::find_ns(const string& uri,const char *pfx) const { 146 string basic_openid_message::find_ns(const string& uri,const char *pfx) const {
147 try { 147 try {
148 return get_ns(uri); 148 return get_ns(uri);
149 }catch(failed_lookup&) { 149 }catch(failed_lookup&) {
150 return pfx; 150 return pfx;
151 } 151 }
152 } 152 }
153 string basic_openid_message::allocate_ns(const string& uri,const char *pfx) { 153 string basic_openid_message::allocate_ns(const string& uri,const char *pfx) {
154 if(!has_field("ns")) 154 if(!has_field("ns"))
155 return pfx; 155 return pfx;
156 if(has_ns(uri)) 156 if(has_ns(uri))
157 throw bad_input(OPKELE_CP_ "OpenID message already contains namespace"); 157 throw bad_input(OPKELE_CP_ "OpenID message already contains namespace");
158 string rv = pfx; 158 string rv = pfx;
159 if(has_field("ns."+rv)) { 159 if(has_field("ns."+rv)) {
160 string::reference c=rv[rv.length()]; 160 string::reference c=rv[rv.length()];
161 for(c='a';c<='z' && has_field("ns."+rv);++c); 161 for(c='a';c<='z' && has_field("ns."+rv);++c) ;
162 if(c=='z') 162 if(c=='z')
163 throw exception(OPKELE_CP_ "Failed to allocate namespace"); 163 throw exception(OPKELE_CP_ "Failed to allocate namespace");
164 } 164 }
165 set_field("ns."+rv,uri); 165 set_field("ns."+rv,uri);
166 return rv; 166 return rv;
167 } 167 }
168 168
169 bool openid_message_t::has_field(const string& n) const { 169 bool openid_message_t::has_field(const string& n) const {
170 return find(n)!=end(); 170 return find(n)!=end();
171 } 171 }
172 const string& openid_message_t::get_field(const string& n) const { 172 const string& openid_message_t::get_field(const string& n) const {
173 const_iterator i=find(n); 173 const_iterator i=find(n);
174 if(i==end()) 174 if(i==end())
175 throw failed_lookup(OPKELE_CP_ n+": no such field"); 175 throw failed_lookup(OPKELE_CP_ n+": no such field");
176 return i->second; 176 return i->second;
177 } 177 }
178 178
179 openid_message_t::fields_iterator openid_message_t::fields_begin() const { 179 openid_message_t::fields_iterator openid_message_t::fields_begin() const {
180 return util::map_keys_iterator<const_iterator,string,const string&,const string*>(begin(),end()); 180 return util::map_keys_iterator<const_iterator,string,const string&,const string*>(begin(),end());
181 } 181 }
182 openid_message_t::fields_iterator openid_message_t::fields_end() const { 182 openid_message_t::fields_iterator openid_message_t::fields_end() const {
183 return util::map_keys_iterator<const_iterator,string,const string&,const string*>(end(),end()); 183 return util::map_keys_iterator<const_iterator,string,const string&,const string*>(end(),end());
184 } 184 }
185 185
186 void openid_message_t::reset_fields() { 186 void openid_message_t::reset_fields() {
187 clear(); 187 clear();
188 } 188 }
189 void openid_message_t::set_field(const string& n,const string& v) { 189 void openid_message_t::set_field(const string& n,const string& v) {
190 (*this)[n]=v; 190 (*this)[n]=v;
191 } 191 }
192 void openid_message_t::reset_field(const string& n) { 192 void openid_message_t::reset_field(const string& n) {
193 erase(n); 193 erase(n);
194 } 194 }
195 195
196} 196}
diff --git a/lib/prequeue_rp.cc b/lib/prequeue_rp.cc
index e499d08..886efae 100644
--- a/lib/prequeue_rp.cc
+++ b/lib/prequeue_rp.cc
@@ -1,86 +1,86 @@
1#include <iostream> 1#include <iostream>
2#include <openssl/sha.h> 2#include <openssl/sha.h>
3#include <openssl/hmac.h> 3#include <openssl/hmac.h>
4#include <opkele/exception.h> 4#include <opkele/exception.h>
5#include <opkele/prequeue_rp.h> 5#include <opkele/prequeue_rp.h>
6#include <opkele/discovery.h> 6#include <opkele/discovery.h>
7#include <opkele/uris.h> 7#include <opkele/uris.h>
8#include <opkele/data.h> 8#include <opkele/data.h>
9#include <opkele/util.h> 9#include <opkele/util.h>
10#include <opkele/curl.h> 10#include <opkele/curl.h>
11#include <opkele/debug.h> 11#include <opkele/debug.h>
12 12
13namespace opkele { 13namespace opkele {
14 14
15 class __OP_verifier_good_input : public exception { 15 class __OP_verifier_good_input : public exception {
16 public: 16 public:
17 __OP_verifier_good_input(OPKELE_E_PARS) 17 __OP_verifier_good_input(OPKELE_E_PARS)
18 : exception(OPKELE_E_CONS) { } 18 : exception(OPKELE_E_CONS) { }
19 }; 19 };
20 20
21 class OP_verifier : public iterator<output_iterator_tag,openid_endpoint_t,void> { 21 class OP_verifier : public iterator<output_iterator_tag,openid_endpoint_t,void> {
22 public: 22 public:
23 const string& OP; 23 const string& OP;
24 const string& id; 24 const string& id;
25 25
26 OP_verifier(const string& o,const string& i) 26 OP_verifier(const string& o,const string& i)
27 : OP(o), id(i) { } 27 : OP(o), id(i) { }
28 28
29 OP_verifier& operator*() { return *this; } 29 OP_verifier& operator*() { return *this; }
30 OP_verifier& operator=(const openid_endpoint_t& oep) { 30 OP_verifier& operator=(const openid_endpoint_t& oep) {
31 if(oep.uri==OP) { 31 if(oep.uri==OP) {
32 if(oep.claimed_id==IDURI_SELECT20 32 if(oep.claimed_id==IDURI_SELECT20
33 || oep.local_id==IDURI_SELECT20 ) 33 || oep.local_id==IDURI_SELECT20 )
34 throw bad_input(OPKELE_CP_ "claimed_id is an OP-Id"); 34 throw bad_input(OPKELE_CP_ "claimed_id is an OP-Id");
35 if(oep.local_id==id) 35 if(oep.local_id==id)
36 throw __OP_verifier_good_input(OPKELE_CP_ "Found corresponding endpoint"); 36 throw __OP_verifier_good_input(OPKELE_CP_ "Found corresponding endpoint");
37 } 37 }
38 return *this; 38 return *this;
39 } 39 }
40 40
41 OP_verifier& operator++() { return *this; } 41 OP_verifier& operator++() { return *this; }
42 OP_verifier& operator++(int) { return *this; } 42 OP_verifier& operator++(int) { return *this; }
43 }; 43 };
44 44
45 void prequeue_RP::verify_OP(const string& OP,const string& claimed_id,const string& id) const { 45 void prequeue_RP::verify_OP(const string& OP,const string& _claimed_id,const string& id) const {
46 try { 46 try {
47 discover(OP_verifier(OP,id),claimed_id); 47 discover(OP_verifier(OP,id),_claimed_id);
48 throw id_res_unauthorized(OPKELE_CP_ 48 throw id_res_unauthorized(OPKELE_CP_
49 "OP is not authorized to make an assertion regarding the identity"); 49 "OP is not authorized to make an assertion regarding the identity");
50 }catch(__OP_verifier_good_input& ovgi) { 50 }catch(__OP_verifier_good_input& ovgi) {
51 } 51 }
52 } 52 }
53 53
54 class endpoint_queuer : public iterator<output_iterator_tag,openid_endpoint_t,void> { 54 class endpoint_queuer : public iterator<output_iterator_tag,openid_endpoint_t,void> {
55 public: 55 public:
56 prequeue_RP& rp; 56 prequeue_RP& rp;
57 57
58 endpoint_queuer(prequeue_RP& r) : rp(r) { } 58 endpoint_queuer(prequeue_RP& r) : rp(r) { }
59 59
60 endpoint_queuer& operator*() { return *this; } 60 endpoint_queuer& operator*() { return *this; }
61 endpoint_queuer& operator=(const openid_endpoint_t& oep) { 61 endpoint_queuer& operator=(const openid_endpoint_t& oep) {
62 rp.queue_endpoint(oep); return *this; } 62 rp.queue_endpoint(oep); return *this; }
63 63
64 endpoint_queuer& operator++() { return *this; } 64 endpoint_queuer& operator++() { return *this; }
65 endpoint_queuer& operator++(int) { return *this; } 65 endpoint_queuer& operator++(int) { return *this; }
66 }; 66 };
67 67
68 void prequeue_RP::initiate(const string& usi) { 68 void prequeue_RP::initiate(const string& usi) {
69 begin_queueing(); 69 begin_queueing();
70 set_normalized_id( discover(endpoint_queuer(*this),usi) ); 70 set_normalized_id( discover(endpoint_queuer(*this),usi) );
71 end_queueing(); 71 end_queueing();
72 } 72 }
73 73
74 void prequeue_RP::set_normalized_id(const string&) { 74 void prequeue_RP::set_normalized_id(const string&) {
75 } 75 }
76 76
77 const string prequeue_RP::get_normalized_id() const { 77 const string prequeue_RP::get_normalized_id() const {
78 throw not_implemented(OPKELE_CP_ "get_normalized_id() is not implemented"); 78 throw not_implemented(OPKELE_CP_ "get_normalized_id() is not implemented");
79 } 79 }
80 80
81 const string prequeue_RP::discover(openid_endpoint_output_iterator it, 81 const string prequeue_RP::discover(openid_endpoint_output_iterator it,
82 const string& id) const { 82 const string& id) const {
83 return idiscover(it,id); 83 return idiscover(it,id);
84 } 84 }
85 85
86} 86}
diff --git a/lib/secret.cc b/lib/secret.cc
index d538890..3f1e39c 100644
--- a/lib/secret.cc
+++ b/lib/secret.cc
@@ -1,45 +1,45 @@
1#include <algorithm> 1#include <algorithm>
2#include <functional> 2#include <functional>
3#include <opkele/types.h> 3#include <opkele/types.h>
4#include <opkele/exception.h> 4#include <opkele/exception.h>
5#include <opkele/util.h> 5#include <opkele/util.h>
6 6
7namespace opkele { 7namespace opkele {
8 using namespace std; 8 using namespace std;
9 9
10 template<class __a1,class __a2,class __r> 10 template<class __a1,class __a2,class __r>
11 struct bitwise_xor : public binary_function<__a1,__a2,__r> { 11 struct bitwise_xor : public binary_function<__a1,__a2,__r> {
12 __r operator() (const __a1& a1,const __a2& a2) const { 12 __r operator() (const __a1& a1,const __a2& a2) const {
13 return a1^a2; 13 return (__r)(a1^a2);
14 } 14 }
15 }; 15 };
16 16
17 void secret_t::enxor_to_base64(const unsigned char *key_d,string& rv) const { 17 void secret_t::enxor_to_base64(const unsigned char *key_d,string& rv) const {
18 vector<unsigned char> tmp; 18 vector<unsigned char> tmp;
19 transform( 19 transform(
20 begin(), end(), 20 begin(), end(),
21 key_d, 21 key_d,
22 back_insert_iterator<vector<unsigned char> >(tmp), 22 back_insert_iterator<vector<unsigned char> >(tmp),
23 bitwise_xor<unsigned char,unsigned char,unsigned char>() ); 23 bitwise_xor<unsigned char,unsigned char,unsigned char>() );
24 rv = util::encode_base64(&(tmp.front()),tmp.size()); 24 rv = util::encode_base64(&(tmp.front()),tmp.size());
25 } 25 }
26 26
27 void secret_t::enxor_from_base64(const unsigned char *key_d,const string& b64) { 27 void secret_t::enxor_from_base64(const unsigned char *key_d,const string& b64) {
28 clear(); 28 clear();
29 util::decode_base64(b64,*this); 29 util::decode_base64(b64,*this);
30 transform( 30 transform(
31 begin(), end(), 31 begin(), end(),
32 key_d, 32 key_d,
33 begin(), 33 begin(),
34 bitwise_xor<unsigned char,unsigned char,unsigned char>() ); 34 bitwise_xor<unsigned char,unsigned char,unsigned char>() );
35 } 35 }
36 36
37 void secret_t::to_base64(string& rv) const { 37 void secret_t::to_base64(string& rv) const {
38 rv = util::encode_base64(&(front()),size()); 38 rv = util::encode_base64(&(front()),size());
39 } 39 }
40 40
41 void secret_t::from_base64(const string& b64) { 41 void secret_t::from_base64(const string& b64) {
42 util::decode_base64(b64,*this); 42 util::decode_base64(b64,*this);
43 } 43 }
44 44
45} 45}
diff --git a/lib/util.cc b/lib/util.cc
index b702291..d979502 100644
--- a/lib/util.cc
+++ b/lib/util.cc
@@ -150,129 +150,129 @@ namespace opkele {
150 throw failed_conversion(OPKELE_CP_ "failed to mktime()"); 150 throw failed_conversion(OPKELE_CP_ "failed to mktime()");
151 return rv-timezone; 151 return rv-timezone;
152 } 152 }
153 153
154 /* 154 /*
155 * 155 *
156 */ 156 */
157 157
158 static inline bool isrfc3986unreserved(int c) { 158 static inline bool isrfc3986unreserved(int c) {
159 if(c<'-') return false; 159 if(c<'-') return false;
160 if(c<='.') return true; 160 if(c<='.') return true;
161 if(c<'0') return false; if(c<='9') return true; 161 if(c<'0') return false; if(c<='9') return true;
162 if(c<'A') return false; if(c<='Z') return true; 162 if(c<'A') return false; if(c<='Z') return true;
163 if(c<'_') return false; 163 if(c<'_') return false;
164 if(c=='_') return true; 164 if(c=='_') return true;
165 if(c<'a') return false; if(c<='z') return true; 165 if(c<'a') return false; if(c<='z') return true;
166 if(c=='~') return true; 166 if(c=='~') return true;
167 return false; 167 return false;
168 } 168 }
169 169
170 struct __url_encoder : public unary_function<char,void> { 170 struct __url_encoder : public unary_function<char,void> {
171 public: 171 public:
172 string& rv; 172 string& rv;
173 173
174 __url_encoder(string& r) : rv(r) { } 174 __url_encoder(string& r) : rv(r) { }
175 175
176 result_type operator()(argument_type c) { 176 result_type operator()(argument_type c) {
177 if(isrfc3986unreserved(c)) 177 if(isrfc3986unreserved(c))
178 rv += c; 178 rv += c;
179 else{ 179 else{
180 char tmp[4]; 180 char tmp[4];
181 snprintf(tmp,sizeof(tmp),"%%%02X", 181 snprintf(tmp,sizeof(tmp),"%%%02X",
182 (c&0xff)); 182 (c&0xff));
183 rv += tmp; 183 rv += tmp;
184 } 184 }
185 } 185 }
186 }; 186 };
187 187
188 string url_encode(const string& str) { 188 string url_encode(const string& str) {
189 string rv; 189 string rv;
190 for_each(str.begin(),str.end(), 190 for_each(str.begin(),str.end(),
191 __url_encoder(rv)); 191 __url_encoder(rv));
192 return rv; 192 return rv;
193 } 193 }
194 194
195 string url_decode(const string& str) { 195 string url_decode(const string& str) {
196 string rv; 196 string rv;
197 back_insert_iterator<string> ii(rv); 197 back_insert_iterator<string> ii(rv);
198 for(string::const_iterator i=str.begin(),ie=str.end(); 198 for(string::const_iterator i=str.begin(),ie=str.end();
199 i!=ie;++i) { 199 i!=ie;++i) {
200 switch(*i) { 200 switch(*i) {
201 case '+': 201 case '+':
202 *(ii++) = ' '; break; 202 *(ii++) = ' '; break;
203 case '%': 203 case '%':
204 ++i; 204 ++i;
205 static char tmp[3] = {0,0,0}; 205 static char tmp[3] = {0,0,0};
206 if(i==ie) 206 if(i==ie)
207 throw failed_conversion(OPKELE_CP_ "trailing percent in the url-encoded string"); 207 throw failed_conversion(OPKELE_CP_ "trailing percent in the url-encoded string");
208 tmp[0] = *(i++); 208 tmp[0] = *(i++);
209 if(i==ie) 209 if(i==ie)
210 throw failed_conversion(OPKELE_CP_ "not enough hexadecimals after the percent sign in url-encoded string"); 210 throw failed_conversion(OPKELE_CP_ "not enough hexadecimals after the percent sign in url-encoded string");
211 tmp[1] = *i; 211 tmp[1] = *i;
212 if(!(isxdigit(tmp[0]) && isxdigit(tmp[1]))) 212 if(!(isxdigit(tmp[0]) && isxdigit(tmp[1])))
213 throw failed_conversion(OPKELE_CP_ "non-hex follows percent in url-encoded string"); 213 throw failed_conversion(OPKELE_CP_ "non-hex follows percent in url-encoded string");
214 *(ii++) = strtol(tmp,0,16); 214 *(ii++) = (char)strtol(tmp,0,16);
215 break; 215 break;
216 default: 216 default:
217 *(ii++) = *i; break; 217 *(ii++) = *i; break;
218 } 218 }
219 } 219 }
220 return rv; 220 return rv;
221 } 221 }
222 222
223 string attr_escape(const string& str) { 223 string attr_escape(const string& str) {
224 static const char *unsafechars = "<>&\n\"'"; 224 static const char *unsafechars = "<>&\n\"'";
225 string rv; 225 string rv;
226 string::size_type p=0; 226 string::size_type p=0;
227 while(true) { 227 while(true) {
228 string::size_type us = str.find_first_of(unsafechars,p); 228 string::size_type us = str.find_first_of(unsafechars,p);
229 if(us==string::npos) { 229 if(us==string::npos) {
230 if(p!=str.length()) 230 if(p!=str.length())
231 rv.append(str,p,str.length()-p); 231 rv.append(str,p,str.length()-p);
232 return rv; 232 return rv;
233 } 233 }
234 rv.append(str,p,us-p); 234 rv.append(str,p,us-p);
235 rv += "&#"; 235 rv += "&#";
236 rv += long_to_string((long)str[us]); 236 rv += long_to_string((long)str[us]);
237 rv += ';'; 237 rv += ';';
238 p = us+1; 238 p = us+1;
239 } 239 }
240 } 240 }
241 241
242 string long_to_string(long l) { 242 string long_to_string(long l) {
243 char rv[32]; 243 char rv[32];
244 int r=snprintf(rv,sizeof(rv),"%ld",l); 244 int r=snprintf(rv,sizeof(rv),"%ld",l);
245 if(r<0 || r>=(int)sizeof(rv)) 245 if(r<0 || r>=(int)sizeof(rv))
246 throw failed_conversion(OPKELE_CP_ "failed to snprintf()"); 246 throw failed_conversion(OPKELE_CP_ "failed to snprintf()");
247 return rv; 247 return rv;
248 } 248 }
249 249
250 long string_to_long(const string& s) { 250 long string_to_long(const string& s) {
251 char *endptr = 0; 251 char *endptr = 0;
252 long rv = strtol(s.c_str(),&endptr,10); 252 long rv = strtol(s.c_str(),&endptr,10);
253 if((!endptr) || endptr==s.c_str()) 253 if((!endptr) || endptr==s.c_str())
254 throw failed_conversion(OPKELE_CP_ "failed to strtol()"); 254 throw failed_conversion(OPKELE_CP_ "failed to strtol()");
255 return rv; 255 return rv;
256 } 256 }
257 257
258 /* 258 /*
259 * Normalize URL according to the rules, described in rfc 3986, section 6 259 * Normalize URL according to the rules, described in rfc 3986, section 6
260 * 260 *
261 * - uppercase hex triplets (e.g. %ab -> %AB) 261 * - uppercase hex triplets (e.g. %ab -> %AB)
262 * - lowercase scheme and host 262 * - lowercase scheme and host
263 * - decode %-encoded characters, specified as unreserved in rfc 3986, section 2.3, 263 * - decode %-encoded characters, specified as unreserved in rfc 3986, section 2.3,
264 * that is - [:alpha:][:digit:]._~- 264 * that is - [:alpha:][:digit:]._~-
265 * - remove dot segments 265 * - remove dot segments
266 * - remove empty and default ports 266 * - remove empty and default ports
267 * - if there's no path component, add '/' 267 * - if there's no path component, add '/'
268 */ 268 */
269 string rfc_3986_normalize_uri(const string& uri) { 269 string rfc_3986_normalize_uri(const string& uri) {
270 string rv; 270 string rv;
271 string::size_type ns = uri.find_first_not_of(data::_whitespace_chars); 271 string::size_type ns = uri.find_first_not_of(data::_whitespace_chars);
272 if(ns==string::npos) 272 if(ns==string::npos)
273 throw bad_input(OPKELE_CP_ "Can't normalize empty URI"); 273 throw bad_input(OPKELE_CP_ "Can't normalize empty URI");
274 string::size_type colon = uri.find(':',ns); 274 string::size_type colon = uri.find(':',ns);
275 if(colon==string::npos) 275 if(colon==string::npos)
276 throw bad_input(OPKELE_CP_ "No scheme specified in URI"); 276 throw bad_input(OPKELE_CP_ "No scheme specified in URI");
277 transform( 277 transform(
278 uri.begin()+ns, uri.begin()+colon+1, 278 uri.begin()+ns, uri.begin()+colon+1,
@@ -287,132 +287,132 @@ namespace opkele {
287 s = false; 287 s = false;
288 else if(rv=="https:") 288 else if(rv=="https:")
289 s = true; 289 s = true;
290 else{ 290 else{
291 /* TODO: support more schemes. e.g. xri. How do we normalize 291 /* TODO: support more schemes. e.g. xri. How do we normalize
292 * xri? 292 * xri?
293 */ 293 */
294 rv.append(uri,colon+1,ul-colon-1); 294 rv.append(uri,colon+1,ul-colon-1);
295 return rv; 295 return rv;
296 } 296 }
297 rv += "//"; 297 rv += "//";
298 string::size_type interesting = uri.find_first_of(":/#?",colon+3); 298 string::size_type interesting = uri.find_first_of(":/#?",colon+3);
299 if(interesting==string::npos) { 299 if(interesting==string::npos) {
300 transform( 300 transform(
301 uri.begin()+colon+3,uri.begin()+ul, 301 uri.begin()+colon+3,uri.begin()+ul,
302 back_inserter(rv), ::tolower ); 302 back_inserter(rv), ::tolower );
303 rv += '/'; return rv; 303 rv += '/'; return rv;
304 } 304 }
305 transform( 305 transform(
306 uri.begin()+colon+3,uri.begin()+interesting, 306 uri.begin()+colon+3,uri.begin()+interesting,
307 back_inserter(rv), ::tolower ); 307 back_inserter(rv), ::tolower );
308 bool qf = false; 308 bool qf = false;
309 char ic = uri[interesting]; 309 char ic = uri[interesting];
310 if(ic==':') { 310 if(ic==':') {
311 string::size_type ni = uri.find_first_of("/#?%",interesting+1); 311 string::size_type ni = uri.find_first_of("/#?%",interesting+1);
312 const char *nptr = uri.data()+interesting+1; 312 const char *nptr = uri.data()+interesting+1;
313 char *eptr = 0; 313 char *eptr = 0;
314 long port = strtol(nptr,&eptr,10); 314 long port = strtol(nptr,&eptr,10);
315 if( (port>0) && (port<65535) && port!=(s?443:80) ) { 315 if( (port>0) && (port<65535) && port!=(s?443:80) ) {
316 char tmp[8]; 316 char tmp[8];
317 snprintf(tmp,sizeof(tmp),":%ld",port); 317 snprintf(tmp,sizeof(tmp),":%ld",port);
318 rv += tmp; 318 rv += tmp;
319 } 319 }
320 if(ni==string::npos) { 320 if(ni==string::npos) {
321 rv += '/'; return rv; 321 rv += '/'; return rv;
322 } 322 }
323 interesting = ni; 323 interesting = ni;
324 }else if(ic!='/') { 324 }else if(ic!='/') {
325 rv += '/'; rv += ic; 325 rv += '/'; rv += ic;
326 qf = true; 326 qf = true;
327 ++interesting; 327 ++interesting;
328 } 328 }
329 string::size_type n = interesting; 329 string::size_type n = interesting;
330 char tmp[3] = { 0,0,0 }; 330 char tmp[3] = { 0,0,0 };
331 stack<string::size_type> psegs; psegs.push(rv.length()); 331 stack<string::size_type> psegs; psegs.push(rv.length());
332 string pseg; 332 string pseg;
333 for(;n<ul;) { 333 for(;n<ul;) {
334 string::size_type unsafe = uri.find_first_of(qf?"%":"%/?#",n); 334 string::size_type unsafe = uri.find_first_of(qf?"%":"%/?#",n);
335 if(unsafe==string::npos) { 335 if(unsafe==string::npos) {
336 pseg.append(uri,n,ul-n-1); n = ul-1; 336 pseg.append(uri,n,ul-n-1); n = ul-1;
337 }else{ 337 }else{
338 pseg.append(uri,n,unsafe-n); 338 pseg.append(uri,n,unsafe-n);
339 n = unsafe; 339 n = unsafe;
340 } 340 }
341 char c = uri[n++]; 341 char c = uri[n++];
342 if(c=='%') { 342 if(c=='%') {
343 if((n+1)>=ul) 343 if((n+1)>=ul)
344 throw bad_input(OPKELE_CP_ "Unexpected end of URI encountered while parsing percent-encoded character"); 344 throw bad_input(OPKELE_CP_ "Unexpected end of URI encountered while parsing percent-encoded character");
345 tmp[0] = uri[n++]; 345 tmp[0] = uri[n++];
346 tmp[1] = uri[n++]; 346 tmp[1] = uri[n++];
347 if(!( isxdigit(tmp[0]) && isxdigit(tmp[1]) )) 347 if(!( isxdigit(tmp[0]) && isxdigit(tmp[1]) ))
348 throw bad_input(OPKELE_CP_ "Invalid percent-encoded character in URI being normalized"); 348 throw bad_input(OPKELE_CP_ "Invalid percent-encoded character in URI being normalized");
349 int cc = strtol(tmp,0,16); 349 int cc = strtol(tmp,0,16);
350 if( isalpha(cc) || isdigit(cc) || strchr("._~-",cc) ) 350 if( isalpha(cc) || isdigit(cc) || strchr("._~-",cc) )
351 pseg += cc; 351 pseg += (char)cc;
352 else{ 352 else{
353 pseg += '%'; 353 pseg += '%';
354 pseg += toupper(tmp[0]); pseg += toupper(tmp[1]); 354 pseg += (char)toupper(tmp[0]); pseg += (char)toupper(tmp[1]);
355 } 355 }
356 }else if(qf) { 356 }else if(qf) {
357 rv += pseg; rv += c; 357 rv += pseg; rv += c;
358 pseg.clear(); 358 pseg.clear();
359 }else if(n>=ul || strchr("?/#",c)) { 359 }else if(n>=ul || strchr("?/#",c)) {
360 if(pseg.empty() || pseg==".") { 360 if(pseg.empty() || pseg==".") {
361 }else if(pseg=="..") { 361 }else if(pseg=="..") {
362 if(psegs.size()>1) { 362 if(psegs.size()>1) {
363 rv.resize(psegs.top()); psegs.pop(); 363 rv.resize(psegs.top()); psegs.pop();
364 } 364 }
365 }else{ 365 }else{
366 psegs.push(rv.length()); 366 psegs.push(rv.length());
367 if(c!='/') { 367 if(c!='/') {
368 pseg += c; 368 pseg += c;
369 qf = true; 369 qf = true;
370 } 370 }
371 rv += '/'; rv += pseg; 371 rv += '/'; rv += pseg;
372 } 372 }
373 if(c=='/' && (n>=ul || strchr("?#",uri[n])) ) { 373 if(c=='/' && (n>=ul || strchr("?#",uri[n])) ) {
374 rv += '/'; 374 rv += '/';
375 if(n<ul) 375 if(n<ul)
376 qf = true; 376 qf = true;
377 }else if(strchr("?#",c)) { 377 }else if(strchr("?#",c)) {
378 if(psegs.size()==1 && psegs.top()==rv.length()) 378 if(psegs.size()==1 && psegs.top()==rv.length())
379 rv += '/'; 379 rv += '/';
380 if(pseg.empty()) 380 if(pseg.empty())
381 rv += c; 381 rv += c;
382 qf = true; 382 qf = true;
383 } 383 }
384 pseg.clear(); 384 pseg.clear();
385 }else{ 385 }else{
386 pseg += c; 386 pseg += c;
387 } 387 }
388 } 388 }
389 if(!pseg.empty()) { 389 if(!pseg.empty()) {
390 if(!qf) rv += '/'; 390 if(!qf) rv += '/';
391 rv += pseg; 391 rv += pseg;
392 } 392 }
393 return rv; 393 return rv;
394 } 394 }
395 395
396 string& strip_uri_fragment_part(string& u) { 396 string& strip_uri_fragment_part(string& u) {
397 string::size_type q = u.find('?'), f = u.find('#'); 397 string::size_type q = u.find('?'), f = u.find('#');
398 if(q==string::npos) { 398 if(q==string::npos) {
399 if(f!=string::npos) 399 if(f!=string::npos)
400 u.erase(f); 400 u.erase(f);
401 }else{ 401 }else{
402 if(f!=string::npos) { 402 if(f!=string::npos) {
403 if(f<q) 403 if(f<q)
404 u.erase(f,q-f); 404 u.erase(f,q-f);
405 else 405 else
406 u.erase(f); 406 u.erase(f);
407 } 407 }
408 } 408 }
409 return u; 409 return u;
410 } 410 }
411 411
412 bool uri_matches_realm(const string& uri,const string& realm) { 412 bool uri_matches_realm(const string& uri,const string& realm) {
413 string nrealm = opkele::util::rfc_3986_normalize_uri(realm); 413 string nrealm = opkele::util::rfc_3986_normalize_uri(realm);
414 string nu = opkele::util::rfc_3986_normalize_uri(uri); 414 string nu = opkele::util::rfc_3986_normalize_uri(uri);
415 string::size_type pr = nrealm.find("://"); 415 string::size_type pr = nrealm.find("://");
416 string::size_type pu = nu.find("://"); 416 string::size_type pu = nu.find("://");
417 assert(!(pr==string::npos || pu==string::npos)); 417 assert(!(pr==string::npos || pu==string::npos));
418 pr += sizeof("://")-1; 418 pr += sizeof("://")-1;