Added timeline polling

Because the streaming API will sunset on August 16th, it is essential to implement timeline polling so that the library can still be used to access tweets. This commit breaks the current API even for clients still using the streaming API because the OAuth connection data was pulled from twitter::client into twitter::auth. Other than that, almost everything works the same, and if a client wants to update their libtwitter++ within the next week and a half, they are free to.

1 files changed, 82 insertions, 0 deletions

@@ -0,0 +1,82 @@
+#include "timeline.h"
+#include <sstream>
+#include <json.hpp>
+#include "codes.h"
+#include "util.h"
+#include "request.h"
+
+namespace twitter {
+
+  timeline::timeline(
+    const auth& tauth,
+    std::string url) :
+      auth_(tauth),
+      url_(std::move(url))
+  {
+  }
+
+  std::list<tweet> timeline::poll()
+  {
+    tweet_id maxId;
+    std::list<tweet> result;
+
+    for (int i = 0; i < 5; i++)
+    {
+      std::ostringstream urlstr;
+      urlstr << url_;
+
+      std::list<std::string> arguments;
+
+      if (i > 0)
+      {
+        arguments.push_back("max_id=" + std::to_string(maxId));
+      }
+
+      if (hasSince_)
+      {
+        arguments.push_back("since_id=" + std::to_string(sinceId_));
+      }
+
+      if (!arguments.empty())
+      {
+        urlstr << "?";
+        urlstr << implode(std::begin(arguments), std::end(arguments), "&");
+      }
+
+      std::string theUrl = urlstr.str();
+      std::string response = get(auth_, theUrl).perform();
+
+      try
+      {
+        nlohmann::json rjs = nlohmann::json::parse(response);
+
+        if (rjs.empty())
+        {
+          break;
+        }
+
+        for (auto& single : rjs)
+        {
+          result.emplace_back(single.dump());
+        }
+      } catch (const std::invalid_argument& error)
+      {
+        std::throw_with_nested(invalid_response(response));
+      } catch (const std::domain_error& error)
+      {
+        std::throw_with_nested(invalid_response(response));
+      }
+
+      maxId = result.back().getID() - 1;
+    }
+
+    if (!result.empty())
+    {
+      sinceId_ = result.front().getID();
+      hasSince_ = true;
+    }
+
+    return result;
+  }
+
+};