2 files changed, 125 insertions, 125 deletions

@@ -17,13 +17,13 @@ void dump(const char *text,
   size_t i;
   size_t c;
   unsigned int width=80;
- 
+
   fprintf(stream, "%s, %10.10ld bytes (0x%8.8lx)\n",
           text, (long)size, (long)size);
- 
+
   for(i=0; i<size; i+= width) {
     fprintf(stream, "%4.4lx: ", (long)i);
- 
+
     /* show hex to the left
     for(c = 0; c < width; c++) {
       if(i+c < size)
@@ -31,17 +31,17 @@ void dump(const char *text,
       else
         fputs("   ", stream);
     }*/
- 
+
     /* show data on the right */
     for(c = 0; (c < width) && (i+c < size); c++) {
       char x = (ptr[i+c] >= 0x20 && ptr[i+c] < 0x80) ? ptr[i+c] : '.';
       fputc(x, stream);
     }
- 
+
     fputc('\n', stream); /* newline */
   }
 }
- 
+
 static
 int my_trace(CURL *handle, curl_infotype type,
              char *data, size_t size,
@@ -49,13 +49,13 @@ int my_trace(CURL *handle, curl_infotype type,
 {
   const char *text;
   (void)handle; /* prevent compiler warning */
- 
+
   switch (type) {
   case CURLINFO_TEXT:
     fprintf(stderr, "== Info: %s", data);
   default: /* in case a new one is introduced to shock us */
     return 0;
- 
+
   case CURLINFO_HEADER_OUT:
     text = "=> Send header";
     break;
@@ -75,17 +75,17 @@ int my_trace(CURL *handle, curl_infotype type,
     text = "<= Recv SSL data";
     break;
   }
- 
+
   dump(text, stderr, (unsigned char *)data, size);
   return 0;
 }
 
 namespace twitter {
-  
+
   class request
   {
   public:
-    
+
     explicit request(std::string url) try
       : _ios(_output), _conn(_ios)
     {
@@ -93,10 +93,10 @@ namespace twitter {
     } catch (const curl::curl_easy_exception& error)
     {
       error.print_traceback();
-    
+
       assert(false);
     }
-    
+
     std::string perform()
     {
       try
@@ -106,14 +106,14 @@ namespace twitter {
       {
         std::throw_with_nested(connection_error());
       }
-    
+
       int response_code = _conn.get_info<CURLINFO_RESPONSE_CODE>().get();
       std::string result = _output.str();
-    
+
       if (response_code / 100 != 2)
       {
         nlohmann::json response_json;
-      
+
         try
         {
           response_json = nlohmann::json::parse(result);
@@ -121,12 +121,12 @@ namespace twitter {
         {
           std::throw_with_nested(invalid_response(result));
         }
-    
+
         for (nlohmann::json& error : response_json["errors"])
         {
           int error_code;
           std::string error_message;
-      
+
           try
           {
             error_code = error["code"].get<int>();
@@ -135,44 +135,44 @@ namespace twitter {
           {
             std::throw_with_nested(invalid_response(result));
           }
-      
+
           switch (error_code)
           {
           case 32:
           case 135:
           case 215:
             throw bad_auth(error_message);
-        
+
           case 44:
             throw invalid_media(error_message);
-        
+
           case 64:
             throw account_suspended(error_message);
-        
+
           case 88:
             throw rate_limit_exceeded(error_message);
-        
+
           case 89:
             throw bad_token(error_message);
-        
+
           case 130:
             throw server_overloaded(error_message);
-        
+
           case 131:
             throw server_error(error_message);
-      
+
           case 185:
             throw update_limit_exceeded(error_message);
-        
+
           case 186:
             throw bad_length(error_message);
-        
+
           case 187:
             throw duplicate_status(error_message);
-        
+
           case 226:
             throw suspected_spam(error_message);
-        
+
           case 261:
             throw write_restricted(error_message);
           }
@@ -194,27 +194,27 @@ namespace twitter {
         {
           throw server_timeout("HTTP 504 Gateway Timeout");
         }
-      
+
         throw unknown_error(response_code, result);
       }
-    
+
       return result;
     }
-    
+
   private:
-    
+
     std::ostringstream _output;
     curl::curl_ios<std::ostringstream> _ios;
-    
+
   protected:
-    
+
     curl::curl_easy _conn;
   };
-  
+
   class get : public request
   {
   public:
-    
+
     get(const OAuth::Client& oauth_client, std::string url) try
       : request(url)
     {
@@ -223,31 +223,31 @@ namespace twitter {
       {
         _headers.add(std::move(oauth_header));
       }
-  
+
       _conn.add<CURLOPT_HTTPHEADER>(_headers.get());
     } catch (const OAuth::ParseError& error)
     {
       std::cout << "Error generating OAuth header:" << std::endl;
       std::cout << error.what() << std::endl;
       std::cout << "This is likely due to a malformed URL." << std::endl;
-    
+
       assert(false);
     } catch (const curl::curl_easy_exception& error)
     {
       error.print_traceback();
-  
+
       assert(false);
     }
-    
+
   private:
-    
+
     curl::curl_header _headers;
   };
-  
+
   class post : public request
   {
   public:
-    
+
     post(const OAuth::Client& oauth_client, std::string url, std::string datastr) try
       : request(url)
     {
@@ -256,7 +256,7 @@ namespace twitter {
       {
         _headers.add(std::move(oauth_header));
       }
-  
+
       _conn.add<CURLOPT_HTTPHEADER>(_headers.get());
       _conn.add<CURLOPT_COPYPOSTFIELDS>(datastr.c_str());
     } catch (const OAuth::ParseError& error)
@@ -264,24 +264,24 @@ namespace twitter {
       std::cout << "Error generating OAuth header:" << std::endl;
       std::cout << error.what() << std::endl;
       std::cout << "This is likely due to a malformed URL." << std::endl;
-    
+
       assert(false);
     } catch (const curl::curl_easy_exception& error)
     {
       error.print_traceback();
-  
+
       assert(false);
     }
-    
+
   private:
-    
+
     curl::curl_header _headers;
   };
-  
+
   class multipost : public request
   {
   public:
-    
+
     multipost(const OAuth::Client& oauth_client, std::string url, const curl_httppost* fields) try
       : request(url)
     {
@@ -290,7 +290,7 @@ namespace twitter {
       {
         _headers.add(std::move(oauth_header));
       }
-  
+
       _conn.add<CURLOPT_HTTPHEADER>(_headers.get());
       _conn.add<CURLOPT_HTTPPOST>(fields);
     } catch (const OAuth::ParseError& error)
@@ -298,94 +298,94 @@ namespace twitter {
       std::cout << "Error generating OAuth header:" << std::endl;
       std::cout << error.what() << std::endl;
       std::cout << "This is likely due to a malformed URL." << std::endl;
-    
+
       assert(false);
     } catch (const curl::curl_easy_exception& error)
     {
       error.print_traceback();
-  
+
       assert(false);
     }
-    
+
   private:
-    
+
     curl::curl_header _headers;
   };
-    
+
   client::client(const auth& _arg)
   {
     _oauth_consumer =
       make_unique<OAuth::Consumer>(
         _arg.getConsumerKey(),
         _arg.getConsumerSecret());
-          
+
     _oauth_token =
       make_unique<OAuth::Token>(
         _arg.getAccessKey(),
         _arg.getAccessSecret());
-          
+
     _oauth_client =
       make_unique<OAuth::Client>(
         _oauth_consumer.get(),
         _oauth_token.get());
-    
+
     _current_user =
       make_unique<user>(
         get(*_oauth_client,
           "https://api.twitter.com/1.1/account/verify_credentials.json")
         .perform());
   }
-  
+
   client::~client() = default;
-  
+
   tweet client::updateStatus(std::string msg, std::list<long> media_ids) const
   {
     std::stringstream datastrstream;
     datastrstream << "status=" << OAuth::PercentEncode(msg);
-    
+
     if (!media_ids.empty())
     {
       datastrstream << "&media_ids=";
       datastrstream << twitter::implode(std::begin(media_ids), std::end(media_ids), ",");
     }
-    
+
     return tweet(
       post(*_oauth_client,
         "https://api.twitter.com/1.1/statuses/update.json",
         datastrstream.str())
       .perform());
   }
-  
+
   tweet client::replyToTweet(std::string msg, tweet_id in_response_to, std::list<long> media_ids) const
   {
     std::stringstream datastrstream;
     datastrstream << "status=" << OAuth::PercentEncode(msg);
     datastrstream << "&in_reply_to_status_id=";
     datastrstream << in_response_to;
-    
+
     if (!media_ids.empty())
     {
       datastrstream << "&media_ids=";
       datastrstream << twitter::implode(std::begin(media_ids), std::end(media_ids), ",");
     }
-    
+
     return tweet(
       post(*_oauth_client,
         "https://api.twitter.com/1.1/statuses/update.json",
         datastrstream.str())
       .perform());
   }
-  
+
   tweet client::replyToTweet(std::string msg, const tweet& in_response_to, std::list<long> media_ids) const
   {
     return replyToTweet(msg, in_response_to.getID(), media_ids);
   }
-  
+
   long client::uploadMedia(std::string media_type, const char* data, long data_length) const try
   {
     curl::curl_form form;
     std::string str_data_length = std::to_string(data_length);
-    
+
     curl::curl_pair<CURLformoption, std::string> command_name(CURLFORM_COPYNAME, "command");
     curl::curl_pair<CURLformoption, std::string> command_cont(CURLFORM_COPYCONTENTS, "INIT");
     curl::curl_pair<CURLformoption, std::string> bytes_name(CURLFORM_COPYNAME, "total_bytes");
@@ -402,7 +402,7 @@ namespace twitter {
       curl::curl_pair<CURLformoption, std::string> category_cont(CURLFORM_COPYCONTENTS, "tweet_gif");
       form.add(category_name, category_cont);
     }
-    
+
     std::string init_response =
       multipost(*_oauth_client,
         "https://upload.twitter.com/1.1/media/upload.json",
@@ -410,7 +410,7 @@ namespace twitter {
       .perform();
 
     long media_id;
-    
+
     try
     {
       nlohmann::json response_json = nlohmann::json::parse(init_response);
@@ -434,21 +434,21 @@ namespace twitter {
     {
       assert(false);
     }
-    
+
     multipost(*_oauth_client, "https://upload.twitter.com/1.1/media/upload.json", append_form_post).perform();
-    
+
     curl_formfree(append_form_post);
-    
+
     curl::curl_form finalize_form;
     std::string str_media_id = std::to_string(media_id);
-    
+
     curl::curl_pair<CURLformoption, std::string> command3_name(CURLFORM_COPYNAME, "command");
     curl::curl_pair<CURLformoption, std::string> command3_cont(CURLFORM_COPYCONTENTS, "FINALIZE");
     curl::curl_pair<CURLformoption, std::string> media_id_name(CURLFORM_COPYNAME, "media_id");
     curl::curl_pair<CURLformoption, std::string> media_id_cont(CURLFORM_COPYCONTENTS, str_media_id);
     finalize_form.add(command3_name, command3_cont);
     finalize_form.add(media_id_name, media_id_cont);
-    
+
     std::string finalize_response =
       multipost(*_oauth_client,
         "https://upload.twitter.com/1.1/media/upload.json",
@@ -456,7 +456,7 @@ namespace twitter {
       .perform();
 
     nlohmann::json finalize_json;
-    
+
     try
     {
       finalize_json = nlohmann::json::parse(finalize_response);
@@ -464,26 +464,26 @@ namespace twitter {
     {
       std::throw_with_nested(invalid_response(finalize_response));
     }
-    
+
     if (finalize_json.find("processing_info") != finalize_json.end())
     {
       std::stringstream datastr;
       datastr << "https://upload.twitter.com/1.1/media/upload.json?command=STATUS&media_id=" << media_id;
-      
+
       for (;;)
       {
         std::string status_response = get(*_oauth_client, datastr.str()).perform();
-        
+
         try
         {
           nlohmann::json status_json = nlohmann::json::parse(status_response);
           std::string state = status_json["processing_info"]["state"].get<std::string>();
-          
+
           if (state == "succeeded")
           {
             break;
           }
-          
+
           int ttw = status_json["processing_info"]["check_after_secs"].get<int>();
           std::this_thread::sleep_for(std::chrono::seconds(ttw));
         } catch (const std::invalid_argument& error)
@@ -495,20 +495,20 @@ namespace twitter {
         }
       }
     }
-    
+
     return media_id;
   } catch (const curl::curl_exception& error)
   {
     error.print_traceback();
-    
+
     assert(false);
   }
-  
+
   std::set<user_id> client::getFriends(user_id id) const
   {
     long long cursor = -1;
     std::set<user_id> result;
-    
+
     while (cursor != 0)
     {
       std::stringstream urlstream;
@@ -516,14 +516,14 @@ namespace twitter {
       urlstream << id;
       urlstream << "&cursor=";
       urlstream << cursor;
-  
+
       std::string url = urlstream.str();
       std::string response_data = get(*_oauth_client, url).perform();
-      
+
       try
       {
         nlohmann::json rjs = nlohmann::json::parse(response_data);
-        
+
         cursor = rjs["next_cursor"].get<long long>();
         result.insert(std::begin(rjs["ids"]), std::end(rjs["ids"]));
       } catch (const std::invalid_argument& error)
@@ -534,25 +534,25 @@ namespace twitter {
         std::throw_with_nested(invalid_response(response_data));
       }
     }
-    
+
     return result;
   }
-  
+
   std::set<user_id> client::getFriends(const user& id) const
   {
     return getFriends(id.getID());
   }
-  
+
   std::set<user_id> client::getFriends() const
   {
     return getFriends(getUser().getID());
   }
-  
+
   std::set<user_id> client::getFollowers(user_id id) const
   {
     long long cursor = -1;
     std::set<user_id> result;
-    
+
     while (cursor != 0)
     {
       std::stringstream urlstream;
@@ -560,14 +560,14 @@ namespace twitter {
       urlstream << id;
       urlstream << "&cursor=";
       urlstream << cursor;
-  
+
       std::string url = urlstream.str();
       std::string response_data = get(*_oauth_client, url).perform();
-      
+
       try
       {
         nlohmann::json rjs = nlohmann::json::parse(response_data);
-        
+
         cursor = rjs["next_cursor"].get<long long>();
         result.insert(std::begin(rjs["ids"]), std::end(rjs["ids"]));
       } catch (const std::invalid_argument& error)
@@ -578,15 +578,15 @@ namespace twitter {
         std::throw_with_nested(invalid_response(response_data));
       }
     }
-    
+
     return result;
   }
-  
+
   std::set<user_id> client::getFollowers(const user& id) const
   {
     return getFollowers(id.getID());
   }
-  
+
   std::set<user_id> client::getFollowers() const
   {
     return getFollowers(getUser().getID());
@@ -629,24 +629,24 @@ namespace twitter {
     std::stringstream datastrstream;
     datastrstream << "follow=true&user_id=";
     datastrstream << toFollow;
-    
+
     post(*_oauth_client, "https://api.twitter.com/1.1/friendships/create.json", datastrstream.str()).perform();
   }
-  
+
   void client::follow(const user& toFollow) const
   {
     return follow(toFollow.getID());
   }
-  
+
   void client::unfollow(user_id toUnfollow) const
   {
     std::stringstream datastrstream;
     datastrstream << "user_id=";
     datastrstream << toUnfollow;
-    
+
     post(*_oauth_client, "https://api.twitter.com/1.1/friendships/destroy.json", datastrstream.str()).perform();
   }
-  
+
   void client::unfollow(const user& toUnfollow) const
   {
     return unfollow(toUnfollow.getID());
@@ -656,7 +656,7 @@ namespace twitter {
   {
     return *_current_user;
   }
-  
+
   const configuration& client::getConfiguration() const
   {
     if (!_configuration || (difftime(time(NULL), _last_configuration_update) > 60*60*24))
@@ -669,8 +669,8 @@ namespace twitter {
 
       _last_configuration_update = time(NULL);
     }
-    
+
     return *_configuration;
   }
-  
+
 };
@@ -18,23 +18,23 @@ namespace OAuth {
 };
 
 namespace twitter {
-  
+
   class client {
   public:
-    
+
     client(const auth& _auth);
     ~client();
-    
+
     tweet updateStatus(std::string msg, std::list<long> media_ids = {}) const;
     long uploadMedia(std::string media_type, const char* data, long data_length) const;
-    
+
     tweet replyToTweet(std::string msg, tweet_id in_response_to, std::list<long> media_ids = {}) const;
     tweet replyToTweet(std::string msg, const tweet& in_response_to, std::list<long> media_ids = {}) const;
-    
+
     std::set<user_id> getFriends(user_id id) const;
     std::set<user_id> getFriends(const user& u) const;
     std::set<user_id> getFriends() const;
-    
+
     std::set<user_id> getFollowers(user_id id) const;
     std::set<user_id> getFollowers(const user& u) const;
     std::set<user_id> getFollowers() const;
@@ -43,28 +43,28 @@ namespace twitter {
 
     void follow(user_id toFollow) const;
     void follow(const user& toFollow) const;
-    
+
     void unfollow(user_id toUnfollow) const;
     void unfollow(const user& toUnfollow) const;
-    
+
     const user& getUser() const;
-    
+
     const configuration& getConfiguration() const;
-    
+
   private:
-    
+
     friend class stream;
-    
+
     std::unique_ptr<OAuth::Consumer> _oauth_consumer;
     std::unique_ptr<OAuth::Token> _oauth_token;
     std::unique_ptr<OAuth::Client> _oauth_client;
-    
+
     std::unique_ptr<user> _current_user;
-    
+
     mutable std::unique_ptr<configuration> _configuration;
     mutable time_t _last_configuration_update;
   };
-  
+
 };
 
 #endif /* end of include guard: TWITTER_H_ABFF6A12 */