-rw-r--r-- | lib/consumer.cc | 2 |
1 files changed, 0 insertions, 2 deletions
diff --git a/lib/consumer.cc b/lib/consumer.cc index af309c1..8f66688 100644 --- a/lib/consumer.cc +++ b/lib/consumer.cc | |||
@@ -19,258 +19,256 @@ namespace opkele { | |||
19 | class curl_t { | 19 | class curl_t { |
20 | public: | 20 | public: |
21 | CURL *_c; | 21 | CURL *_c; |
22 | 22 | ||
23 | curl_t() : _c(0) { } | 23 | curl_t() : _c(0) { } |
24 | curl_t(CURL *c) : _c(c) { } | 24 | curl_t(CURL *c) : _c(c) { } |
25 | ~curl_t() throw() { if(_c) curl_easy_cleanup(_c); } | 25 | ~curl_t() throw() { if(_c) curl_easy_cleanup(_c); } |
26 | 26 | ||
27 | curl_t& operator=(CURL *c) { if(_c) curl_easy_cleanup(_c); _c=c; return *this; } | 27 | curl_t& operator=(CURL *c) { if(_c) curl_easy_cleanup(_c); _c=c; return *this; } |
28 | 28 | ||
29 | operator const CURL*(void) const { return _c; } | 29 | operator const CURL*(void) const { return _c; } |
30 | operator CURL*(void) { return _c; } | 30 | operator CURL*(void) { return _c; } |
31 | }; | 31 | }; |
32 | 32 | ||
33 | static CURLcode curl_misc_sets(CURL* c) { | 33 | static CURLcode curl_misc_sets(CURL* c) { |
34 | CURLcode r; | 34 | CURLcode r; |
35 | (r=curl_easy_setopt(c,CURLOPT_FOLLOWLOCATION,1)) | 35 | (r=curl_easy_setopt(c,CURLOPT_FOLLOWLOCATION,1)) |
36 | || (r=curl_easy_setopt(c,CURLOPT_MAXREDIRS,5)) | 36 | || (r=curl_easy_setopt(c,CURLOPT_MAXREDIRS,5)) |
37 | || (r=curl_easy_setopt(c,CURLOPT_DNS_CACHE_TIMEOUT,120)) | 37 | || (r=curl_easy_setopt(c,CURLOPT_DNS_CACHE_TIMEOUT,120)) |
38 | || (r=curl_easy_setopt(c,CURLOPT_DNS_USE_GLOBAL_CACHE,1)) | 38 | || (r=curl_easy_setopt(c,CURLOPT_DNS_USE_GLOBAL_CACHE,1)) |
39 | || (r=curl_easy_setopt(c,CURLOPT_USERAGENT,PACKAGE_NAME"/"PACKAGE_VERSION)) | 39 | || (r=curl_easy_setopt(c,CURLOPT_USERAGENT,PACKAGE_NAME"/"PACKAGE_VERSION)) |
40 | || (r=curl_easy_setopt(c,CURLOPT_TIMEOUT,20)) | 40 | || (r=curl_easy_setopt(c,CURLOPT_TIMEOUT,20)) |
41 | #ifdefDISABLE_CURL_SSL_VERIFYHOST | 41 | #ifdefDISABLE_CURL_SSL_VERIFYHOST |
42 | || (r=curl_easy_setopt(c,CURLOPT_SSL_VERIFYHOST,0)) | 42 | || (r=curl_easy_setopt(c,CURLOPT_SSL_VERIFYHOST,0)) |
43 | #endif | 43 | #endif |
44 | #ifdefDISABLE_CURL_SSL_VERIFYPEER | 44 | #ifdefDISABLE_CURL_SSL_VERIFYPEER |
45 | || (r=curl_easy_setopt(c,CURLOPT_SSL_VERIFYPEER,0)) | 45 | || (r=curl_easy_setopt(c,CURLOPT_SSL_VERIFYPEER,0)) |
46 | #endif | 46 | #endif |
47 | ; | 47 | ; |
48 | return r; | 48 | return r; |
49 | } | 49 | } |
50 | 50 | ||
51 | static size_t _curl_tostring(void *ptr,size_t size,size_t nmemb,void *stream) { | 51 | static size_t _curl_tostring(void *ptr,size_t size,size_t nmemb,void *stream) { |
52 | string *str = (string*)stream; | 52 | string *str = (string*)stream; |
53 | size_t bytes = size*nmemb; | 53 | size_t bytes = size*nmemb; |
54 | size_t get = min(16384-str->length(),bytes); | 54 | size_t get = min(16384-str->length(),bytes); |
55 | str->append((const char*)ptr,get); | 55 | str->append((const char*)ptr,get); |
56 | return get; | 56 | return get; |
57 | } | 57 | } |
58 | 58 | ||
59 | assoc_t consumer_t::associate(const string& server) { | 59 | assoc_t consumer_t::associate(const string& server) { |
60 | util::dh_t dh = DH_new(); | 60 | util::dh_t dh = DH_new(); |
61 | if(!dh) | 61 | if(!dh) |
62 | throw exception_openssl(OPKELE_CP_ "failed to DH_new()"); | 62 | throw exception_openssl(OPKELE_CP_ "failed to DH_new()"); |
63 | dh->p = util::dec_to_bignum(data::_default_p); | 63 | dh->p = util::dec_to_bignum(data::_default_p); |
64 | dh->g = util::dec_to_bignum(data::_default_g); | 64 | dh->g = util::dec_to_bignum(data::_default_g); |
65 | if(!DH_generate_key(dh)) | 65 | if(!DH_generate_key(dh)) |
66 | throw exception_openssl(OPKELE_CP_ "failed to DH_generate_key()"); | 66 | throw exception_openssl(OPKELE_CP_ "failed to DH_generate_key()"); |
67 | string request = | 67 | string request = |
68 | "openid.mode=associate" | 68 | "openid.mode=associate" |
69 | "&openid.assoc_type=HMAC-SHA1" | 69 | "&openid.assoc_type=HMAC-SHA1" |
70 | "&openid.session_type=DH-SHA1" | 70 | "&openid.session_type=DH-SHA1" |
71 | "&openid.dh_consumer_public="; | 71 | "&openid.dh_consumer_public="; |
72 | request += util::url_encode(util::bignum_to_base64(dh->pub_key)); | 72 | request += util::url_encode(util::bignum_to_base64(dh->pub_key)); |
73 | curl_t curl = curl_easy_init(); | 73 | curl_t curl = curl_easy_init(); |
74 | if(!curl) | 74 | if(!curl) |
75 | throw exception_curl(OPKELE_CP_ "failed to curl_easy_init()"); | 75 | throw exception_curl(OPKELE_CP_ "failed to curl_easy_init()"); |
76 | string response; | 76 | string response; |
77 | CURLcode r; | 77 | CURLcode r; |
78 | (r=curl_misc_sets(curl)) | 78 | (r=curl_misc_sets(curl)) |
79 | || (r=curl_easy_setopt(curl,CURLOPT_URL,server.c_str())) | 79 | || (r=curl_easy_setopt(curl,CURLOPT_URL,server.c_str())) |
80 | || (r=curl_easy_setopt(curl,CURLOPT_POST,1)) | 80 | || (r=curl_easy_setopt(curl,CURLOPT_POST,1)) |
81 | || (r=curl_easy_setopt(curl,CURLOPT_POSTFIELDS,request.data())) | 81 | || (r=curl_easy_setopt(curl,CURLOPT_POSTFIELDS,request.data())) |
82 | || (r=curl_easy_setopt(curl,CURLOPT_POSTFIELDSIZE,request.length())) | 82 | || (r=curl_easy_setopt(curl,CURLOPT_POSTFIELDSIZE,request.length())) |
83 | || (r=curl_easy_setopt(curl,CURLOPT_WRITEFUNCTION,_curl_tostring)) | 83 | || (r=curl_easy_setopt(curl,CURLOPT_WRITEFUNCTION,_curl_tostring)) |
84 | || (r=curl_easy_setopt(curl,CURLOPT_WRITEDATA,&response)) | 84 | || (r=curl_easy_setopt(curl,CURLOPT_WRITEDATA,&response)) |
85 | ; | 85 | ; |
86 | if(r) | 86 | if(r) |
87 | throw exception_curl(OPKELE_CP_ "failed to curl_easy_setopt()",r); | 87 | throw exception_curl(OPKELE_CP_ "failed to curl_easy_setopt()",r); |
88 | if(r=curl_easy_perform(curl)) | 88 | if(r=curl_easy_perform(curl)) |
89 | throw exception_curl(OPKELE_CP_ "failed to curl_easy_perform()",r); | 89 | throw exception_curl(OPKELE_CP_ "failed to curl_easy_perform()",r); |
90 | params_t p; p.parse_keyvalues(response); | 90 | params_t p; p.parse_keyvalues(response); |
91 | if(p.has_param("assoc_type") && p.get_param("assoc_type")!="HMAC-SHA1") | 91 | if(p.has_param("assoc_type") && p.get_param("assoc_type")!="HMAC-SHA1") |
92 | throw bad_input(OPKELE_CP_ "unsupported assoc_type"); | 92 | throw bad_input(OPKELE_CP_ "unsupported assoc_type"); |
93 | string st; | 93 | string st; |
94 | if(p.has_param("session_type")) st = p.get_param("session_type"); | 94 | if(p.has_param("session_type")) st = p.get_param("session_type"); |
95 | if((!st.empty()) && st!="DH-SHA1") | 95 | if((!st.empty()) && st!="DH-SHA1") |
96 | throw bad_input(OPKELE_CP_ "unsupported session_type"); | 96 | throw bad_input(OPKELE_CP_ "unsupported session_type"); |
97 | secret_t secret; | 97 | secret_t secret; |
98 | if(st.empty()) { | 98 | if(st.empty()) { |
99 | secret.from_base64(p.get_param("mac_key")); | 99 | secret.from_base64(p.get_param("mac_key")); |
100 | }else{ | 100 | }else{ |
101 | util::bignum_t s_pub = util::base64_to_bignum(p.get_param("dh_server_public")); | 101 | util::bignum_t s_pub = util::base64_to_bignum(p.get_param("dh_server_public")); |
102 | vector<unsigned char> ck(DH_size(dh)+1); | 102 | vector<unsigned char> ck(DH_size(dh)+1); |
103 | unsigned char *ckptr = &(ck.front())+1; | 103 | unsigned char *ckptr = &(ck.front())+1; |
104 | int cklen = DH_compute_key(ckptr,s_pub,dh); | 104 | int cklen = DH_compute_key(ckptr,s_pub,dh); |
105 | if(cklen<0) | 105 | if(cklen<0) |
106 | throw exception_openssl(OPKELE_CP_ "failed to DH_compute_key()"); | 106 | throw exception_openssl(OPKELE_CP_ "failed to DH_compute_key()"); |
107 | if(cklen && (*ckptr)&0x80) { | 107 | if(cklen && (*ckptr)&0x80) { |
108 | (*(--ckptr)) = 0; ++cklen; | 108 | (*(--ckptr)) = 0; ++cklen; |
109 | } | 109 | } |
110 | unsigned char key_sha1[SHA_DIGEST_LENGTH]; | 110 | unsigned char key_sha1[SHA_DIGEST_LENGTH]; |
111 | SHA1(ckptr,cklen,key_sha1); | 111 | SHA1(ckptr,cklen,key_sha1); |
112 | secret.enxor_from_base64(key_sha1,p.get_param("enc_mac_key")); | 112 | secret.enxor_from_base64(key_sha1,p.get_param("enc_mac_key")); |
113 | } | 113 | } |
114 | int expires_in = 0; | 114 | int expires_in = 0; |
115 | if(p.has_param("expires_in")) { | 115 | if(p.has_param("expires_in")) { |
116 | expires_in = util::string_to_long(p.get_param("expires_in")); | 116 | expires_in = util::string_to_long(p.get_param("expires_in")); |
117 | }else if(p.has_param("issued") && p.has_param("expiry")) { | 117 | }else if(p.has_param("issued") && p.has_param("expiry")) { |
118 | expires_in = util::w3c_to_time(p.get_param("expiry"))-util::w3c_to_time(p.get_param("issued")); | 118 | expires_in = util::w3c_to_time(p.get_param("expiry"))-util::w3c_to_time(p.get_param("issued")); |
119 | }else | 119 | }else |
120 | throw bad_input(OPKELE_CP_ "no expiration information"); | 120 | throw bad_input(OPKELE_CP_ "no expiration information"); |
121 | return store_assoc(server,p.get_param("assoc_handle"),secret,expires_in); | 121 | return store_assoc(server,p.get_param("assoc_handle"),secret,expires_in); |
122 | } | 122 | } |
123 | 123 | ||
124 | string consumer_t::checkid_immediate(const string& identity,const string& return_to,const string& trust_root,extension_t *ext) { | 124 | string consumer_t::checkid_immediate(const string& identity,const string& return_to,const string& trust_root,extension_t *ext) { |
125 | return checkid_(mode_checkid_immediate,identity,return_to,trust_root,ext); | 125 | return checkid_(mode_checkid_immediate,identity,return_to,trust_root,ext); |
126 | } | 126 | } |
127 | string consumer_t::checkid_setup(const string& identity,const string& return_to,const string& trust_root,extension_t *ext) { | 127 | string consumer_t::checkid_setup(const string& identity,const string& return_to,const string& trust_root,extension_t *ext) { |
128 | return checkid_(mode_checkid_setup,identity,return_to,trust_root,ext); | 128 | return checkid_(mode_checkid_setup,identity,return_to,trust_root,ext); |
129 | } | 129 | } |
130 | string consumer_t::checkid_(mode_t mode,const string& identity,const string& return_to,const string& trust_root,extension_t *ext) { | 130 | string consumer_t::checkid_(mode_t mode,const string& identity,const string& return_to,const string& trust_root,extension_t *ext) { |
131 | params_t p; | 131 | params_t p; |
132 | if(mode==mode_checkid_immediate) | 132 | if(mode==mode_checkid_immediate) |
133 | p["mode"]="checkid_immediate"; | 133 | p["mode"]="checkid_immediate"; |
134 | else if(mode==mode_checkid_setup) | 134 | else if(mode==mode_checkid_setup) |
135 | p["mode"]="checkid_setup"; | 135 | p["mode"]="checkid_setup"; |
136 | else | 136 | else |
137 | throw bad_input(OPKELE_CP_ "unknown checkid_* mode"); | 137 | throw bad_input(OPKELE_CP_ "unknown checkid_* mode"); |
138 | string iurl = canonicalize(identity); | 138 | string iurl = canonicalize(identity); |
139 | string server, delegate; | 139 | string server, delegate; |
140 | retrieve_links(iurl,server,delegate); | 140 | retrieve_links(iurl,server,delegate); |
141 | p["identity"] = delegate.empty()?iurl:delegate; | 141 | p["identity"] = delegate.empty()?iurl:delegate; |
142 | if(!trust_root.empty()) | 142 | if(!trust_root.empty()) |
143 | p["trust_root"] = trust_root; | 143 | p["trust_root"] = trust_root; |
144 | p["return_to"] = return_to; | 144 | p["return_to"] = return_to; |
145 | try { | 145 | try { |
146 | string ah = find_assoc(server)->handle(); | 146 | string ah = find_assoc(server)->handle(); |
147 | if(ah->is_expired()) /* TODO: or should I throw some other exception to force programmer fix his implementation? */ | ||
148 | throw failed_lookup(OPKELE_CP_ "find_assoc() has returned expired handle"); | ||
149 | p["assoc_handle"] = ah; | 147 | p["assoc_handle"] = ah; |
150 | }catch(failed_lookup& fl) { | 148 | }catch(failed_lookup& fl) { |
151 | string ah = associate(server)->handle(); | 149 | string ah = associate(server)->handle(); |
152 | p["assoc_handle"] = ah; | 150 | p["assoc_handle"] = ah; |
153 | } | 151 | } |
154 | if(ext) ext->checkid_hook(p,identity); | 152 | if(ext) ext->checkid_hook(p,identity); |
155 | return p.append_query(server); | 153 | return p.append_query(server); |
156 | } | 154 | } |
157 | 155 | ||
158 | void consumer_t::id_res(const params_t& pin,const string& identity,extension_t *ext) { | 156 | void consumer_t::id_res(const params_t& pin,const string& identity,extension_t *ext) { |
159 | if(pin.has_param("openid.user_setup_url")) | 157 | if(pin.has_param("openid.user_setup_url")) |
160 | throw id_res_setup(OPKELE_CP_ "assertion failed, setup url provided",pin.get_param("openid.user_setup_url")); | 158 | throw id_res_setup(OPKELE_CP_ "assertion failed, setup url provided",pin.get_param("openid.user_setup_url")); |
161 | string server,delegate; | 159 | string server,delegate; |
162 | retrieve_links(identity.empty()?pin.get_param("openid.identity"):canonicalize(identity),server,delegate); | 160 | retrieve_links(identity.empty()?pin.get_param("openid.identity"):canonicalize(identity),server,delegate); |
163 | params_t ps; | 161 | params_t ps; |
164 | try { | 162 | try { |
165 | assoc_t assoc = retrieve_assoc(server,pin.get_param("openid.assoc_handle")); | 163 | assoc_t assoc = retrieve_assoc(server,pin.get_param("openid.assoc_handle")); |
166 | if(assoc->is_expired()) /* TODO: or should I throw some other exception to force programmer fix his implementation? */ | 164 | if(assoc->is_expired()) /* TODO: or should I throw some other exception to force programmer fix his implementation? */ |
167 | throw failed_lookup(OPKELE_CP_ "retrieve_assoc() has returned expired handle"); | 165 | throw failed_lookup(OPKELE_CP_ "retrieve_assoc() has returned expired handle"); |
168 | const string& sigenc = pin.get_param("openid.sig"); | 166 | const string& sigenc = pin.get_param("openid.sig"); |
169 | vector<unsigned char> sig; | 167 | vector<unsigned char> sig; |
170 | util::decode_base64(sigenc,sig); | 168 | util::decode_base64(sigenc,sig); |
171 | const string& slist = pin.get_param("openid.signed"); | 169 | const string& slist = pin.get_param("openid.signed"); |
172 | string kv; | 170 | string kv; |
173 | string::size_type p = 0; | 171 | string::size_type p = 0; |
174 | while(true) { | 172 | while(true) { |
175 | string::size_type co = slist.find(',',p); | 173 | string::size_type co = slist.find(',',p); |
176 | string f = (co==string::npos)?slist.substr(p):slist.substr(p,co-p); | 174 | string f = (co==string::npos)?slist.substr(p):slist.substr(p,co-p); |
177 | kv += f; | 175 | kv += f; |
178 | kv += ':'; | 176 | kv += ':'; |
179 | f.insert(0,"openid."); | 177 | f.insert(0,"openid."); |
180 | kv += pin.get_param(f); | 178 | kv += pin.get_param(f); |
181 | kv += '\n'; | 179 | kv += '\n'; |
182 | if(ext) ps[f.substr(sizeof("openid.")-1)] = pin.get_param(f); | 180 | if(ext) ps[f.substr(sizeof("openid.")-1)] = pin.get_param(f); |
183 | if(co==string::npos) | 181 | if(co==string::npos) |
184 | break; | 182 | break; |
185 | p = co+1; | 183 | p = co+1; |
186 | } | 184 | } |
187 | secret_t secret = assoc->secret(); | 185 | secret_t secret = assoc->secret(); |
188 | unsigned int md_len = 0; | 186 | unsigned int md_len = 0; |
189 | unsigned char *md = HMAC( | 187 | unsigned char *md = HMAC( |
190 | EVP_sha1(), | 188 | EVP_sha1(), |
191 | &(secret.front()),secret.size(), | 189 | &(secret.front()),secret.size(), |
192 | (const unsigned char *)kv.data(),kv.length(), | 190 | (const unsigned char *)kv.data(),kv.length(), |
193 | 0,&md_len); | 191 | 0,&md_len); |
194 | if(sig.size()!=md_len || memcmp(&(sig.front()),md,md_len)) | 192 | if(sig.size()!=md_len || memcmp(&(sig.front()),md,md_len)) |
195 | throw id_res_mismatch(OPKELE_CP_ "signature mismatch"); | 193 | throw id_res_mismatch(OPKELE_CP_ "signature mismatch"); |
196 | }catch(failed_lookup& e) { /* XXX: more specific? */ | 194 | }catch(failed_lookup& e) { /* XXX: more specific? */ |
197 | const string& slist = pin.get_param("openid.signed"); | 195 | const string& slist = pin.get_param("openid.signed"); |
198 | string::size_type pp = 0; | 196 | string::size_type pp = 0; |
199 | params_t p; | 197 | params_t p; |
200 | while(true) { | 198 | while(true) { |
201 | string::size_type co = slist.find(',',pp); | 199 | string::size_type co = slist.find(',',pp); |
202 | string f = "openid."; | 200 | string f = "openid."; |
203 | f += (co==string::npos)?slist.substr(pp):slist.substr(pp,co-pp); | 201 | f += (co==string::npos)?slist.substr(pp):slist.substr(pp,co-pp); |
204 | p[f] = pin.get_param(f); | 202 | p[f] = pin.get_param(f); |
205 | if(co==string::npos) | 203 | if(co==string::npos) |
206 | break; | 204 | break; |
207 | pp = co+1; | 205 | pp = co+1; |
208 | } | 206 | } |
209 | p["openid.assoc_handle"] = pin.get_param("openid.assoc_handle"); | 207 | p["openid.assoc_handle"] = pin.get_param("openid.assoc_handle"); |
210 | p["openid.sig"] = pin.get_param("openid.sig"); | 208 | p["openid.sig"] = pin.get_param("openid.sig"); |
211 | p["openid.signed"] = pin.get_param("openid.signed"); | 209 | p["openid.signed"] = pin.get_param("openid.signed"); |
212 | try { | 210 | try { |
213 | string ih = pin.get_param("openid.invalidate_handle"); | 211 | string ih = pin.get_param("openid.invalidate_handle"); |
214 | p["openid.invalidate_handle"] = ih; | 212 | p["openid.invalidate_handle"] = ih; |
215 | }catch(failed_lookup& fl) { } | 213 | }catch(failed_lookup& fl) { } |
216 | try { | 214 | try { |
217 | check_authentication(server,p); | 215 | check_authentication(server,p); |
218 | }catch(failed_check_authentication& fca) { | 216 | }catch(failed_check_authentication& fca) { |
219 | throw id_res_failed(OPKELE_CP_ "failed to check_authentication()"); | 217 | throw id_res_failed(OPKELE_CP_ "failed to check_authentication()"); |
220 | } | 218 | } |
221 | } | 219 | } |
222 | if(ext) ext->id_res_hook(pin,ps,identity); | 220 | if(ext) ext->id_res_hook(pin,ps,identity); |
223 | } | 221 | } |
224 | 222 | ||
225 | void consumer_t::check_authentication(const string& server,const params_t& p) { | 223 | void consumer_t::check_authentication(const string& server,const params_t& p) { |
226 | string request = "openid.mode=check_authentication"; | 224 | string request = "openid.mode=check_authentication"; |
227 | for(params_t::const_iterator i=p.begin();i!=p.end();++i) { | 225 | for(params_t::const_iterator i=p.begin();i!=p.end();++i) { |
228 | if(i->first!="openid.mode") { | 226 | if(i->first!="openid.mode") { |
229 | request += '&'; | 227 | request += '&'; |
230 | request += i->first; | 228 | request += i->first; |
231 | request += '='; | 229 | request += '='; |
232 | request += util::url_encode(i->second); | 230 | request += util::url_encode(i->second); |
233 | } | 231 | } |
234 | } | 232 | } |
235 | curl_t curl = curl_easy_init(); | 233 | curl_t curl = curl_easy_init(); |
236 | if(!curl) | 234 | if(!curl) |
237 | throw exception_curl(OPKELE_CP_ "failed to curl_easy_init()"); | 235 | throw exception_curl(OPKELE_CP_ "failed to curl_easy_init()"); |
238 | string response; | 236 | string response; |
239 | CURLcode r; | 237 | CURLcode r; |
240 | (r=curl_misc_sets(curl)) | 238 | (r=curl_misc_sets(curl)) |
241 | || (r=curl_easy_setopt(curl,CURLOPT_URL,server.c_str())) | 239 | || (r=curl_easy_setopt(curl,CURLOPT_URL,server.c_str())) |
242 | || (r=curl_easy_setopt(curl,CURLOPT_POST,1)) | 240 | || (r=curl_easy_setopt(curl,CURLOPT_POST,1)) |
243 | || (r=curl_easy_setopt(curl,CURLOPT_POSTFIELDS,request.data())) | 241 | || (r=curl_easy_setopt(curl,CURLOPT_POSTFIELDS,request.data())) |
244 | || (r=curl_easy_setopt(curl,CURLOPT_POSTFIELDSIZE,request.length())) | 242 | || (r=curl_easy_setopt(curl,CURLOPT_POSTFIELDSIZE,request.length())) |
245 | || (r=curl_easy_setopt(curl,CURLOPT_WRITEFUNCTION,_curl_tostring)) | 243 | || (r=curl_easy_setopt(curl,CURLOPT_WRITEFUNCTION,_curl_tostring)) |
246 | || (r=curl_easy_setopt(curl,CURLOPT_WRITEDATA,&response)) | 244 | || (r=curl_easy_setopt(curl,CURLOPT_WRITEDATA,&response)) |
247 | ; | 245 | ; |
248 | if(r) | 246 | if(r) |
249 | throw exception_curl(OPKELE_CP_ "failed to curl_easy_setopt()",r); | 247 | throw exception_curl(OPKELE_CP_ "failed to curl_easy_setopt()",r); |
250 | if(r=curl_easy_perform(curl)) | 248 | if(r=curl_easy_perform(curl)) |
251 | throw exception_curl(OPKELE_CP_ "failed to curl_easy_perform()",r); | 249 | throw exception_curl(OPKELE_CP_ "failed to curl_easy_perform()",r); |
252 | params_t pp; pp.parse_keyvalues(response); | 250 | params_t pp; pp.parse_keyvalues(response); |
253 | if(pp.has_param("invalidate_handle")) | 251 | if(pp.has_param("invalidate_handle")) |
254 | invalidate_assoc(server,pp.get_param("invalidate_handle")); | 252 | invalidate_assoc(server,pp.get_param("invalidate_handle")); |
255 | if(pp.has_param("is_valid")) { | 253 | if(pp.has_param("is_valid")) { |
256 | if(pp.get_param("is_valid")=="true") | 254 | if(pp.get_param("is_valid")=="true") |
257 | return; | 255 | return; |
258 | }else if(pp.has_param("lifetime")) { | 256 | }else if(pp.has_param("lifetime")) { |
259 | if(util::string_to_long(pp.get_param("lifetime"))) | 257 | if(util::string_to_long(pp.get_param("lifetime"))) |
260 | return; | 258 | return; |
261 | } | 259 | } |
262 | throw failed_check_authentication(OPKELE_CP_ "failed to verify response"); | 260 | throw failed_check_authentication(OPKELE_CP_ "failed to verify response"); |
263 | } | 261 | } |
264 | 262 | ||
265 | void consumer_t::retrieve_links(const string& url,string& server,string& delegate) { | 263 | void consumer_t::retrieve_links(const string& url,string& server,string& delegate) { |
266 | server.erase(); | 264 | server.erase(); |
267 | delegate.erase(); | 265 | delegate.erase(); |
268 | curl_t curl = curl_easy_init(); | 266 | curl_t curl = curl_easy_init(); |
269 | if(!curl) | 267 | if(!curl) |
270 | throw exception_curl(OPKELE_CP_ "failed to curl_easy_init()"); | 268 | throw exception_curl(OPKELE_CP_ "failed to curl_easy_init()"); |
271 | string html; | 269 | string html; |
272 | CURLcode r; | 270 | CURLcode r; |
273 | (r=curl_misc_sets(curl)) | 271 | (r=curl_misc_sets(curl)) |
274 | || (r=curl_easy_setopt(curl,CURLOPT_URL,url.c_str())) | 272 | || (r=curl_easy_setopt(curl,CURLOPT_URL,url.c_str())) |
275 | || (r=curl_easy_setopt(curl,CURLOPT_WRITEFUNCTION,_curl_tostring)) | 273 | || (r=curl_easy_setopt(curl,CURLOPT_WRITEFUNCTION,_curl_tostring)) |
276 | || (r=curl_easy_setopt(curl,CURLOPT_WRITEDATA,&html)) | 274 | || (r=curl_easy_setopt(curl,CURLOPT_WRITEDATA,&html)) |