1 files changed, 19 insertions, 15 deletions

@@ -7,32 +7,35 @@
 #include <chrono>
 #include <thread>
 #include "bounding_box.h"
+#include "auth.h"
+#include "user.h"
 
 namespace twitter {
-  
-  class client;
+
   class notification;
-  
-  class stream {
+
+  class
+  [[deprecated("The Twitter streaming API will sunset on August 16th, 2018")]]
+  stream {
   public:
-    
+
     typedef std::function<void(notification _notification)> notify_callback;
-    
+
     stream(
-      const client& tclient,
+      const auth& tauth,
       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,
@@ -40,18 +43,18 @@ namespace twitter {
       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;
+
+    const auth& _auth;
     notify_callback _notify;
     bool _stop = false;
     std::string _buffer;
@@ -59,9 +62,10 @@ namespace twitter {
     bool _established = false;
     backoff _backoff_type = backoff::none;
     std::chrono::milliseconds _backoff_amount;
+    user _currentUser;
     std::thread _thread;
   };
-  
+
 }
 
 #endif /* end of include guard: STREAM_H_E9146952 */