import webbrowser
import traceback
import pkg_resources
+import socks
+import socket
+from io import BytesIO
from twitter.stream import TwitterStream, Timeout, HeartbeatTimeout, Hangup
from twitter.api import *
from twitter.oauth import OAuth, read_token_file
'--image-on-term',
action='store_true',
help='Display all image on terminal.')
+ parser.add_argument(
+ '-ph',
+ '--proxy-host',
+ help='Use HTTP/SOCKS proxy for network connections.')
+ parser.add_argument(
+ '-pp',
+ '--proxy-port',
+ default=8080,
+ help='HTTP/SOCKS proxy port (Default: 8080).')
+ parser.add_argument(
+ '-pt',
+ '--proxy-type',
+ default='SOCKS5',
+ help='Proxy type (HTTP, SOCKS4, SOCKS5; Default: SOCKS5).')
return parser.parse_args()
+def proxy_connect(args):
+ """
+ Connect to specified proxy
+ """
+ if args.proxy_host:
+ # Setup proxy by monkeypatching the standard lib
+ if args.proxy_type.lower() == "socks5" or not args.proxy_type:
+ socks.set_default_proxy(
+ socks.SOCKS5, args.proxy_host,
+ int(args.proxy_port))
+ elif args.proxy_type.lower() == "http":
+ socks.set_default_proxy(
+ socks.HTTP, args.proxy_host,
+ int(args.proxy_port))
+ elif args.proxy_type.lower() == "socks4":
+ socks.set_default_proxy(
+ socks.SOCKS4, args.proxy_host,
+ int(args.proxy_port))
+ else:
+ printNicely(
+ magenta("Sorry, wrong proxy type specified! Aborting..."))
+ sys.exit()
+ socket.socket = socks.socksocket
+
+
def authen():
"""
Authenticate with Twitter OAuth
# Kill old thread
g['stream_stop'] = True
args.track_keywords = keyword
- # Set prefix to origin name with public
- g['PREFIX'] = '@' + g['original_name'] + '/public'
+ # Reset prefix
+ g['PREFIX'] = u2str(emojize(c['PREFIX']))
# Start new thread
th = threading.Thread(
target=stream,
elif target == 'mine':
# Kill old thread
g['stream_stop'] = True
- # Set prefix to origin name
- g['PREFIX'] = '@' + g['original_name']
+ # Reset prefix
+ g['PREFIX'] = u2str(emojize(c['PREFIX']))
# Start new thread
th = threading.Thread(
target=stream,
# Block new stream until other one exits
StreamLock.acquire()
g['stream_stop'] = False
+ last_tweet_time = time.time()
for tweet in tweet_iter:
if tweet is None:
printNicely("-- None --")
StreamLock.release()
break
elif tweet.get('text'):
- # Check the semaphore pause and lock (stream process only)
- if g['pause']:
- continue
- while c['lock']:
- time.sleep(0.5)
- # Draw the tweet
- draw(
- t=tweet,
- keyword=args.track_keywords,
- humanize=False,
- fil=args.filter,
- ig=args.ignore,
- )
- # Current readline buffer
- current_buffer = readline.get_line_buffer().strip()
- # There is an unexpected behaviour in MacOSX readline + Python 2:
- # after completely delete a word after typing it,
- # somehow readline buffer still contains
- # the 1st character of that word
- if current_buffer and g['cmd'] != current_buffer:
- sys.stdout.write(
- g['decorated_name'](c['PREFIX']) + str2u(current_buffer))
- sys.stdout.flush()
- elif not c['HIDE_PROMPT']:
- sys.stdout.write(g['decorated_name'](c['PREFIX']))
- sys.stdout.flush()
+ if time.time() - last_tweet_time >= get_config("STREAM_DELAY"):
+ last_tweet_time = time.time()
+ # Check the semaphore pause and lock (stream process only)
+ if g['pause']:
+ continue
+ while c['lock']:
+ time.sleep(0.5)
+ # Draw the tweet
+ draw(
+ t=tweet,
+ keyword=args.track_keywords,
+ humanize=False,
+ fil=args.filter,
+ ig=args.ignore,
+ )
+ # Current readline buffer
+ current_buffer = readline.get_line_buffer().strip()
+ # There is an unexpected behaviour in MacOSX readline + Python 2:
+ # after completely delete a word after typing it,
+ # somehow readline buffer still contains
+ # the 1st character of that word
+ if current_buffer and g['cmd'] != current_buffer:
+ sys.stdout.write(
+ g['decorated_name'](c['PREFIX']) + str2u(current_buffer))
+ sys.stdout.flush()
+ elif not c['HIDE_PROMPT']:
+ sys.stdout.write(g['decorated_name'](c['PREFIX']))
+ sys.stdout.flush()
elif tweet.get('direct_message'):
# Check the semaphore pause and lock (stream process only)
if g['pause']:
# Initial
args = parse_arguments()
try:
+ proxy_connect(args)
init(args)
+ # Twitter API connection problem
except TwitterHTTPError:
printNicely('')
printNicely(
printNicely(magenta("Let's try again later."))
save_history()
sys.exit()
+ # Proxy connection problem
+ except (socks.ProxyConnectionError, URLError):
+ printNicely(
+ magenta("There seems to be a connection problem."))
+ printNicely(
+ magenta("You might want to check your proxy settings (host, port and type)!"))
+ save_history()
+ sys.exit()
+
# Spawn stream thread
th = threading.Thread(
target=stream,