From: Aaron Hill <aa1ronham@gmail.com>
Date: Tue, 21 Jan 2014 00:43:05 +0000 (-0500)
Subject: Updated userstream parameters
X-Git-Url: https://vcs.fsf.org/?a=commitdiff_plain;h=9f06a21b7aa6d8d8d04e25af443b9137f8ff812c;p=tweepy.git

Updated userstream parameters
---

diff --git a/tweepy/streaming.py b/tweepy/streaming.py
index a95c0b4..b17b4f9 100644
--- a/tweepy/streaming.py
+++ b/tweepy/streaming.py
@@ -239,12 +239,26 @@ class Stream(object):
         """ Called when the response has been closed by Twitter """
         pass
 
-    def userstream(self, count=None, async=False, secure=True):
+    def userstream(self, stall_warnings=False, _with=None, replies=None,
+            track=None, locations=None, async=False, encoding='utf8'):
         self.parameters = {'delimited': 'length'}
         if self.running:
             raise TweepError('Stream object already connected!')
         self.url = '/%s/user.json?delimited=length' % STREAM_VERSION
         self.host='userstream.twitter.com'
+        if stall_warnings:
+            self.parameters['stall_warnings'] = stall_warnings
+        if _with:
+            self.parameters['with'] = _with
+        if replies:
+            self.parameters['replies'] = replies
+        if locations and len(locations) > 0:
+            assert len(locations) % 4 == 0
+            self.parameters['locations'] = ','.join(['%.2f' % l for l in locations])
+        if track:
+            encoded_track = [s.encode(encoding) for s in track]
+            self.parameters['track'] = ','.join(encoded_track)
+        self.body = urlencode_noplus(self.parameters)
         self._start(async)
 
     def firehose(self, count=None, async=False):