1 files changed, 67 insertions, 0 deletions

@@ -0,0 +1,67 @@
+#ifndef STREAM_H_E9146952
+#define STREAM_H_E9146952
+
+#include <functional>
+#include <list>
+#include <string>
+#include <chrono>
+#include <thread>
+#include "bounding_box.h"
+
+namespace twitter {
+  
+  class client;
+  class notification;
+  
+  class stream {
+  public:
+    
+    typedef std::function<void(const notification& _notification)> notify_callback;
+    
+    stream(
+      const client& tclient,
+      notify_callback callback,
+      bool with_followings = true,
+      bool receive_all_replies = false,
+      std::list<std::string> track = {},
+      std::list<bounding_box> locations = {});
+      
+    ~stream();
+    
+    stream(const stream& other) = delete;
+    stream(stream&& other) = delete;
+    stream& operator=(const stream& other) = delete;
+    stream& operator=(stream&& other) = delete;
+    
+  private:
+    enum class backoff {
+      none,
+      network,
+      http,
+      rate_limit
+    };
+    
+    static std::string generateUrl(
+      bool with_followings,
+      bool receive_all_replies,
+      std::list<std::string> track,
+      std::list<bounding_box> locations);
+    
+    void run(std::string url);
+    int progress();
+    size_t write(char* ptr, size_t size, size_t nmemb);
+    
+    const client& _client;
+    notify_callback _notify;
+    bool _stop = false;
+    std::string _buffer;
+    time_t _last_write;
+    bool _established = false;
+    backoff _backoff_type = backoff::none;
+    std::chrono::milliseconds _backoff_amount;
+    std::thread _thread;
+  };
+  
+}
+
+#endif /* end of include guard: STREAM_H_E9146952 */