summaryrefslogtreecommitdiffabout
path: root/lib
Unidiff
Diffstat (limited to 'lib') (more/less context) (ignore whitespace changes)
-rw-r--r--lib/consumer.cc2
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))