Skip to content
GitLab
Menu
Projects
Groups
Snippets
Loading...
Help
Help
Support
Community forum
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in
Toggle navigation
Menu
Open sidebar
Zahra Rajabi
tweepy
Commits
eb1d8bb8
Commit
eb1d8bb8
authored
Nov 20, 2009
by
Joshua Roesslein
Browse files
Move parameters into POST body in streaming.py to avoid "head too big" errors. Thanks Pascal!
parent
5a804ffa
Changes
1
Hide whitespace changes
Inline
Side-by-side
tweepy/streaming.py
View file @
eb1d8bb8
...
...
@@ -6,6 +6,7 @@ import httplib
from
socket
import
timeout
from
threading
import
Thread
from
time
import
sleep
import
urllib
from
tweepy.auth
import
BasicAuthHandler
from
tweepy.parsers
import
parse_status
...
...
@@ -64,11 +65,12 @@ class Stream(object):
self
.
buffer_size
=
buffer_size
self
.
listener
=
listener
self
.
api
=
API
()
self
.
headers
=
{}
self
.
body
=
None
def
_run
(
self
):
# setup
headers
=
{}
self
.
auth
.
apply_auth
(
None
,
None
,
headers
,
None
)
self
.
auth
.
apply_auth
(
None
,
None
,
self
.
headers
,
None
)
# enter loop
error_counter
=
0
...
...
@@ -81,7 +83,7 @@ class Stream(object):
conn
=
httplib
.
HTTPConnection
(
self
.
host
)
conn
.
connect
()
conn
.
sock
.
settimeout
(
self
.
timeout
)
conn
.
request
(
'POST'
,
self
.
url
,
headers
=
headers
)
conn
.
request
(
'POST'
,
self
.
url
,
self
.
body
,
headers
=
self
.
headers
)
resp
=
conn
.
getresponse
()
if
resp
.
status
!=
200
:
if
self
.
listener
.
on_error
(
resp
.
status
)
is
False
:
...
...
@@ -168,13 +170,16 @@ class Stream(object):
Thread
(
target
=
self
.
_run
).
start
()
def
filter
(
self
,
follow
=
None
,
track
=
None
):
params
=
{}
self
.
headers
[
'Content-type'
]
=
"application/x-www-form-urlencoded"
if
self
.
running
:
raise
TweepError
(
'Stream object already connected!'
)
self
.
url
=
'/%i/statuses/filter.json?delimited=length'
%
STREAM_VERSION
if
follow
:
self
.
url
+=
'&follow=%s'
%
','
.
join
(
follow
)
params
[
'follow'
]
=
','
.
join
(
map
(
str
,
follow
)
)
if
track
:
self
.
url
+=
'&track=%s'
%
','
.
join
(
track
)
params
[
'track'
]
=
','
.
join
(
map
(
str
,
track
))
self
.
body
=
urllib
.
urlencode
(
params
)
self
.
running
=
True
Thread
(
target
=
self
.
_run
).
start
()
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
.
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment