more curl wrapper cosmetics

Signed-off-by: Michael Krelin <hacker@klever.net>

1 files changed, 44 insertions, 61 deletions

diff --git a/lib/consumer.cc b/lib/consumer.cc
index 20f4174..c155157 100644
--- a/lib/consumer.cc
+++ b/lib/consumer.cc
@@ -18,2 +18,3 @@ namespace opkele {
     using namespace std;
+    using util::curl_t;
 
@@ -63,20 +64,2 @@ namespace opkele {
 
-    static CURLcode curl_misc_sets(CURL* c) {
-	CURLcode r;
-	(r=curl_easy_setopt(c,CURLOPT_FOLLOWLOCATION,1))
-	|| (r=curl_easy_setopt(c,CURLOPT_MAXREDIRS,5))
-	|| (r=curl_easy_setopt(c,CURLOPT_DNS_CACHE_TIMEOUT,120))
-	|| (r=curl_easy_setopt(c,CURLOPT_DNS_USE_GLOBAL_CACHE,1))
-	|| (r=curl_easy_setopt(c,CURLOPT_USERAGENT,PACKAGE_NAME"/"PACKAGE_SRC_VERSION))
-	|| (r=curl_easy_setopt(c,CURLOPT_TIMEOUT,20))
-#ifdef	DISABLE_CURL_SSL_VERIFYHOST
-	|| (r=curl_easy_setopt(c,CURLOPT_SSL_VERIFYHOST,0))
-#endif
-#ifdef	DISABLE_CURL_SSL_VERIFYPEER
-	|| (r=curl_easy_setopt(c,CURLOPT_SSL_VERIFYPEER,0))
-#endif
-	;
-	return r;
-    }
-
     static size_t _curl_tostring(void *ptr,size_t size,size_t nmemb,void *stream) {
@@ -103,19 +86,19 @@ namespace opkele {
 	request += util::url_encode(util::bignum_to_base64(dh->pub_key));
-	util::curl_t curl = curl_easy_init();
+	curl_t curl = curl_t::easy_init();
 	if(!curl)
-	    throw exception_curl(OPKELE_CP_ "failed to curl_easy_init()");
+	    throw exception_curl(OPKELE_CP_ "failed to initialize curl");
 	string response;
 	CURLcode r;
-	(r=curl_misc_sets(curl))
-	|| (r=curl_easy_setopt(curl,CURLOPT_URL,server.c_str()))
-	|| (r=curl_easy_setopt(curl,CURLOPT_POST,1))
-	|| (r=curl_easy_setopt(curl,CURLOPT_POSTFIELDS,request.data()))
-	|| (r=curl_easy_setopt(curl,CURLOPT_POSTFIELDSIZE,request.length()))
-	|| (r=curl_easy_setopt(curl,CURLOPT_WRITEFUNCTION,_curl_tostring))
-	|| (r=curl_easy_setopt(curl,CURLOPT_WRITEDATA,&response))
+	(r=curl.misc_sets())
+	|| (r=curl.easy_setopt(CURLOPT_URL,server.c_str()))
+	|| (r=curl.easy_setopt(CURLOPT_POST,1))
+	|| (r=curl.easy_setopt(CURLOPT_POSTFIELDS,request.data()))
+	|| (r=curl.easy_setopt(CURLOPT_POSTFIELDSIZE,request.length()))
+	|| (r=curl.easy_setopt(CURLOPT_WRITEFUNCTION,_curl_tostring))
+	|| (r=curl.easy_setopt(CURLOPT_WRITEDATA,&response))
 	;
 	if(r)
-	    throw exception_curl(OPKELE_CP_ "failed to curl_easy_setopt()",r);
-	if( (r=curl_easy_perform(curl)) )
-	    throw exception_curl(OPKELE_CP_ "failed to curl_easy_perform()",r);
+	    throw exception_curl(OPKELE_CP_ "failed to set curly options",r);
+	if( (r=curl.easy_perform()) )
+	    throw exception_curl(OPKELE_CP_ "failed to perform curly request",r);
 	params_t p; p.parse_keyvalues(response);
@@ -263,19 +246,19 @@ namespace opkele {
 	}
-	util::curl_t curl = curl_easy_init();
+	curl_t curl = curl_t::easy_init();
 	if(!curl)
-	    throw exception_curl(OPKELE_CP_ "failed to curl_easy_init()");
+	    throw exception_curl(OPKELE_CP_ "failed to initialize curl");
 	string response;
 	CURLcode r;
-	(r=curl_misc_sets(curl))
-	|| (r=curl_easy_setopt(curl,CURLOPT_URL,server.c_str()))
-	|| (r=curl_easy_setopt(curl,CURLOPT_POST,1))
-	|| (r=curl_easy_setopt(curl,CURLOPT_POSTFIELDS,request.data()))
-	|| (r=curl_easy_setopt(curl,CURLOPT_POSTFIELDSIZE,request.length()))
-	|| (r=curl_easy_setopt(curl,CURLOPT_WRITEFUNCTION,_curl_tostring))
-	|| (r=curl_easy_setopt(curl,CURLOPT_WRITEDATA,&response))
+	(r=curl.misc_sets())
+	|| (r=curl.easy_setopt(CURLOPT_URL,server.c_str()))
+	|| (r=curl.easy_setopt(CURLOPT_POST,1))
+	|| (r=curl.easy_setopt(CURLOPT_POSTFIELDS,request.data()))
+	|| (r=curl.easy_setopt(CURLOPT_POSTFIELDSIZE,request.length()))
+	|| (r=curl.easy_setopt(CURLOPT_WRITEFUNCTION,_curl_tostring))
+	|| (r=curl.easy_setopt(CURLOPT_WRITEDATA,&response))
 	;
 	if(r)
-	    throw exception_curl(OPKELE_CP_ "failed to curl_easy_setopt()",r);
-	if( (r=curl_easy_perform(curl)) )
-	    throw exception_curl(OPKELE_CP_ "failed to curl_easy_perform()",r);
+	    throw exception_curl(OPKELE_CP_ "failed to set curly options",r);
+	if( (r=curl.easy_perform()) )
+	    throw exception_curl(OPKELE_CP_ "failed to perform curly request",r);
 	params_t pp; pp.parse_keyvalues(response);
@@ -296,17 +279,17 @@ namespace opkele {
 	delegate.erase();
-	util::curl_t curl = curl_easy_init();
+	curl_t curl = curl_t::easy_init();
 	if(!curl)
-	    throw exception_curl(OPKELE_CP_ "failed to curl_easy_init()");
+	    throw exception_curl(OPKELE_CP_ "failed to initialize curl");
 	string html;
 	CURLcode r;
-	(r=curl_misc_sets(curl))
-	|| (r=curl_easy_setopt(curl,CURLOPT_URL,url.c_str()))
-	|| (r=curl_easy_setopt(curl,CURLOPT_WRITEFUNCTION,_curl_tostring))
-	|| (r=curl_easy_setopt(curl,CURLOPT_WRITEDATA,&html))
+	(r=curl.misc_sets())
+	|| (r=curl.easy_setopt(CURLOPT_URL,url.c_str()))
+	|| (r=curl.easy_setopt(CURLOPT_WRITEFUNCTION,_curl_tostring))
+	|| (r=curl.easy_setopt(CURLOPT_WRITEDATA,&html))
 	;
 	if(r)
-	    throw exception_curl(OPKELE_CP_ "failed to curl_easy_setopt()",r);
-	r = curl_easy_perform(curl);
+	    throw exception_curl(OPKELE_CP_ "failed to set curly options",r);
+	r = curl.easy_perform();
 	if(r && r!=CURLE_WRITE_ERROR)
-	    throw exception_curl(OPKELE_CP_ "failed to curl_easy_perform()",r);
+	    throw exception_curl(OPKELE_CP_ "failed to perform curly request",r);
 	static const char *re_bre = "<\\s*body\\b", *re_hdre = "<\\s*head[^>]*>",
@@ -402,20 +385,20 @@ namespace opkele {
 	string rv = normalize(url);
-	util::curl_t curl = curl_easy_init();
+	curl_t curl = curl_t::easy_init();
 	if(!curl)
-	    throw exception_curl(OPKELE_CP_ "failed to curl_easy_init()");
+	    throw exception_curl(OPKELE_CP_ "failed to initialize curl()");
 	string html;
 	CURLcode r;
-	(r=curl_misc_sets(curl))
-	|| (r=curl_easy_setopt(curl,CURLOPT_URL,rv.c_str()))
-	|| (r=curl_easy_setopt(curl,CURLOPT_NOBODY,1))
+	(r=curl.misc_sets())
+	|| (r=curl.easy_setopt(CURLOPT_URL,rv.c_str()))
+	|| (r=curl.easy_setopt(CURLOPT_NOBODY,1))
 	;
 	if(r)
-	    throw exception_curl(OPKELE_CP_ "failed to curl_easy_setopt()",r);
-	r = curl_easy_perform(curl);
+	    throw exception_curl(OPKELE_CP_ "failed to set curly options",r);
+	r = curl.easy_perform();
 	if(r)
-	    throw exception_curl(OPKELE_CP_ "failed to curl_easy_perform()",r);
+	    throw exception_curl(OPKELE_CP_ "failed to perform curly request",r);
 	const char *eu = 0;
-	r = curl_easy_getinfo(curl,CURLINFO_EFFECTIVE_URL,&eu);
+	r = curl.easy_getinfo(CURLINFO_EFFECTIVE_URL,&eu);
 	if(r)
-	    throw exception_curl(OPKELE_CP_ "failed to curl_easy_getinfo(..CURLINFO_EFFECTIVE_URL..)",r);
+	    throw exception_curl(OPKELE_CP_ "failed to get CURLINFO_EFFECTIVE_URL",r);
 	rv = eu;