summaryrefslogtreecommitdiffabout
Unidiff
Diffstat (more/less context) (ignore whitespace changes)
-rw-r--r--lib/discovery.cc10
1 files changed, 7 insertions, 3 deletions
diff --git a/lib/discovery.cc b/lib/discovery.cc
index ea53786..3b184ee 100644
--- a/lib/discovery.cc
+++ b/lib/discovery.cc
@@ -1,14 +1,12 @@
1#include <iostream>
2using namespace std;
3#include <list> 1#include <list>
4#include <opkele/curl.h> 2#include <opkele/curl.h>
5#include <opkele/expat.h> 3#include <opkele/expat.h>
6#include <opkele/uris.h> 4#include <opkele/uris.h>
7#include <opkele/discovery.h> 5#include <opkele/discovery.h>
8#include <opkele/exception.h> 6#include <opkele/exception.h>
9#include <opkele/util.h> 7#include <opkele/util.h>
10 8
11#include "config.h" 9#include "config.h"
12 10
13#define XRDS_HEADER "X-XRDS-Location" 11#define XRDS_HEADER "X-XRDS-Location"
14#define CT_HEADER "Content-Type" 12#define CT_HEADER "Content-Type"
@@ -222,46 +220,49 @@ namespace opkele {
222 if(is_qelement(n,NSURI_XRD "\tXRD")) { 220 if(is_qelement(n,NSURI_XRD "\tXRD")) {
223 assert(xrd); 221 assert(xrd);
224 xrd->clear(); 222 xrd->clear();
225 pt_stack.push_back(n); 223 pt_stack.push_back(n);
226 }else if(xmode&xmode_html) { 224 }else if(xmode&xmode_html) {
227 html_start_element(n,a); 225 html_start_element(n,a);
228 }else{ 226 }else{
229 skipping = -1; 227 skipping = -1;
230 } 228 }
231 }else{ 229 }else{
232 int pt_s = pt_stack.size(); 230 int pt_s = pt_stack.size();
233 if(pt_s==1) { 231 if(pt_s==1) {
234 /* TODO: xrd:XRD/xrd:Expires */
235 if(is_qelement(n,NSURI_XRD "\tCanonicalID")) { 232 if(is_qelement(n,NSURI_XRD "\tCanonicalID")) {
236 assert(xrd); 233 assert(xrd);
237 cdata = &(xrd->canonical_ids.add(element_priority(a),string())); 234 cdata = &(xrd->canonical_ids.add(element_priority(a),string()));
238 }else if(is_qelement(n,NSURI_XRD "\tLocalID")) { 235 }else if(is_qelement(n,NSURI_XRD "\tLocalID")) {
239 assert(xrd); 236 assert(xrd);
240 cdata = &(xrd->local_ids.add(element_priority(a),string())); 237 cdata = &(xrd->local_ids.add(element_priority(a),string()));
241 }else if(is_qelement(n,NSURI_XRD "\tService")) { 238 }else if(is_qelement(n,NSURI_XRD "\tService")) {
242 assert(xrd); 239 assert(xrd);
243 xrd_service = &(xrd->services.add(element_priority(a), 240 xrd_service = &(xrd->services.add(element_priority(a),
244 service_t())); 241 service_t()));
245 pt_stack.push_back(n); 242 pt_stack.push_back(n);
246 }else if(is_qelement(n,NSURI_XRD "\tStatus")) { 243 }else if(is_qelement(n,NSURI_XRD "\tStatus")) {
247 for(;*a;) { 244 for(;*a;) {
248 if(!strcasecmp(*(a++),"code")) { 245 if(!strcasecmp(*(a++),"code")) {
249 if(sscanf(*(a++),"%ld",&status_code)==1 && status_code!=100) { 246 if(sscanf(*(a++),"%ld",&status_code)==1 && status_code!=100) {
250 cdata = &status_string; 247 cdata = &status_string;
251 pt_stack.push_back(n); 248 pt_stack.push_back(n);
252 break; 249 break;
253 } 250 }
254 } 251 }
255 } 252 }
253 }else if(is_qelement(n,NSURI_XRD "\tExpires")) {
254 assert(xrd);
255 cdata_buf.clear();
256 cdata = &cdata_buf;
256 }else if(xmode&xmode_html) { 257 }else if(xmode&xmode_html) {
257 html_start_element(n,a); 258 html_start_element(n,a);
258 }else{ 259 }else{
259 skipping = 1; 260 skipping = 1;
260 } 261 }
261 }else if(pt_s==2) { 262 }else if(pt_s==2) {
262 if(is_qelement(pt_stack.back().c_str(), NSURI_XRD "\tService")) { 263 if(is_qelement(pt_stack.back().c_str(), NSURI_XRD "\tService")) {
263 if(is_qelement(n,NSURI_XRD "\tType")) { 264 if(is_qelement(n,NSURI_XRD "\tType")) {
264 assert(xrd); assert(xrd_service); 265 assert(xrd); assert(xrd_service);
265 cdata_buf.clear(); 266 cdata_buf.clear();
266 cdata = &cdata_buf; 267 cdata = &cdata_buf;
267 }else if(is_qelement(n,NSURI_XRD "\tURI")) { 268 }else if(is_qelement(n,NSURI_XRD "\tURI")) {
@@ -296,24 +297,27 @@ namespace opkele {
296 assert(!pt_stack.empty()); 297 assert(!pt_stack.empty());
297 assert(pt_stack.back()==(NSURI_XRD "\tService")); 298 assert(pt_stack.back()==(NSURI_XRD "\tService"));
298 pt_stack.pop_back(); 299 pt_stack.pop_back();
299 xrd_service = 0; 300 xrd_service = 0;
300 }else if(is_qelement(n,NSURI_XRD "\tStatus")) { 301 }else if(is_qelement(n,NSURI_XRD "\tStatus")) {
301 assert(xrd); 302 assert(xrd);
302 if(is_qelement(pt_stack.back().c_str(),n)) { 303 if(is_qelement(pt_stack.back().c_str(),n)) {
303 assert(cdata==&status_string); 304 assert(cdata==&status_string);
304 pt_stack.pop_back(); 305 pt_stack.pop_back();
305 if(status_code!=100) 306 if(status_code!=100)
306 skipping = -1; 307 skipping = -1;
307 } 308 }
309 }else if(is_qelement(n,NSURI_XRD "\tExpires")) {
310 assert(xrd);
311 xrd->expires = util::w3c_to_time(cdata_buf);
308 }else if((xmode&xmode_html) && is_element(n,"head")) { 312 }else if((xmode&xmode_html) && is_element(n,"head")) {
309 skipping = -1; 313 skipping = -1;
310 } 314 }
311 cdata = 0; 315 cdata = 0;
312 } 316 }
313 void character_data(const XML_Char *s,int l) { 317 void character_data(const XML_Char *s,int l) {
314 if(skipping) return; 318 if(skipping) return;
315 if(cdata) cdata->append(s,l); 319 if(cdata) cdata->append(s,l);
316 } 320 }
317 321
318 void html_start_element(const XML_Char *n,const XML_Char **a) { 322 void html_start_element(const XML_Char *n,const XML_Char **a) {
319 if(is_element(n,"meta")) { 323 if(is_element(n,"meta")) {