From: Josh Roesslein <jroesslein@gmail.com>
Date: Sun, 10 Oct 2010 03:53:25 +0000 (-0500)
Subject: Allow for secure streams and make sure to properly apply auth for OAuth.
X-Git-Url: https://vcs.fsf.org/?a=commitdiff_plain;h=ce2964726fe3e4b1af43e2c3c3b687c339c67e6e;p=tweepy.git

Allow for secure streams and make sure to properly apply auth for OAuth.
---

diff --git a/tweepy/streaming.py b/tweepy/streaming.py
index b22764c..661a3bb 100644
--- a/tweepy/streaming.py
+++ b/tweepy/streaming.py
@@ -69,7 +69,8 @@ class Stream(object):
     host = 'stream.twitter.com'
 
     def __init__(self, auth, listener, timeout=5.0, retry_count = None,
-                    retry_time = 10.0, snooze_time = 5.0, buffer_size=1500, headers=None):
+                    retry_time = 10.0, snooze_time = 5.0, buffer_size=1500,
+                    headers=None, secure=False):
         self.auth = auth
         self.running = False
         self.timeout = timeout
@@ -80,11 +81,16 @@ class Stream(object):
         self.listener = listener
         self.api = API()
         self.headers = headers or {}
+        if secure:
+            self.scheme = "https://"
+        else:
+            self.scheme = "http://"
         self.body = None
 
     def _run(self):
         # setup
-        self.auth.apply_auth(None, None, self.headers, None)
+        url = "%s%s%s" % (self.scheme, self.host, self.url)
+        self.auth.apply_auth(url, 'GET', self.headers, None)
 
         # enter loop
         error_counter = 0