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
# Image on term
c['IMAGE_ON_TERM'] = args.image_on_term
set_config('IMAGE_ON_TERM', str(c['IMAGE_ON_TERM']))
+ # Check type of ONLY_LIST and IGNORE_LIST
+ if not isinstance(c['ONLY_LIST'], list):
+ printNicely(red('ONLY_LIST is not a valid list value.'))
+ c['ONLY_LIST'] = []
+ if not isinstance(c['IGNORE_LIST'], list):
+ printNicely(red('IGNORE_LIST is not a valid list value.'))
+ c['IGNORE_LIST'] = []
# Mute dict
c['IGNORE_LIST'] += build_mute_dict()
printNicely('')
+def share():
+ """
+ Copy url of a tweet to clipboard
+ """
+ t = Twitter(auth=authen())
+ try:
+ id = int(g['stuff'].split()[0])
+ tid = c['tweet_dict'][id]
+ except:
+ printNicely(red('Tweet id is not valid.'))
+ return
+ tweet = t.statuses.show(id=tid)
+ url = 'https://twitter.com/' + \
+ tweet['user']['screen_name'] + '/status/' + str(tid)
+ import platform
+ if platform.system().lower() == 'darwin':
+ os.system("echo '%s' | pbcopy" % url)
+ printNicely(green('Copied tweet\'s url to clipboard.'))
+ else:
+ printNicely('Direct link: ' + yellow(url))
+
+
def delete():
"""
Delete
owner_screen_name=owner,
count=c['LIST_MAX'],
include_entities=False)
- for tweet in res:
+ for tweet in reversed(res):
draw(t=tweet)
printNicely('')
ignore = raw_input('Ignore nicks [Ex: @xxx,@yy]: ')
args.filter = filter(None, only.split(','))
args.ignore = filter(None, ignore.split(','))
- elif g['stuff'].split()[-1] == '-d':
- args.filter = c['ONLY_LIST']
- args.ignore = c['IGNORE_LIST']
except:
printNicely(red('Sorry, wrong format.'))
return
# Kill old thread
g['stream_stop'] = True
args.track_keywords = keyword
+ # 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
+ # Reset prefix
+ g['PREFIX'] = u2str(emojize(c['PREFIX']))
# Start new thread
th = threading.Thread(
target=stream,
elif target == 'list':
owner, slug = get_slug()
# Force python 2 not redraw readline buffer
- g['cmd'] = '/'.join([owner, slug])
+ g['PREFIX'] = g['cmd'] = '/'.join([owner, slug])
printNicely(light_yellow('getting list members ...'))
# Get members
t = Twitter(auth=authen())
if args.ignore:
printNicely(red('Ignore: ' + str(len(args.ignore)) + ' people.'))
printNicely('')
- except Exception:
+ except:
debug_option()
printNicely(red('Sorry I can\'t understand.'))
value = get_default_config(key)
line = ' ' * 2 + green(key) + ': ' + light_magenta(value)
printNicely(line)
- except Exception as e:
- printNicely(red(e))
+ except:
+ debug_option()
+ printNicely(red('Just can not get the default.'))
# Delete specific config key in config file
elif len(g['stuff'].split()) == 2 and g['stuff'].split()[-1] == 'drop':
key = g['stuff'].split()[0]
try:
delete_config(key)
printNicely(green('Config key is dropped.'))
- except Exception as e:
- printNicely(red(e))
+ except:
+ debug_option()
+ printNicely(red('Just can not drop the key.'))
# Set specific config
elif len(g['stuff'].split()) == 3 and g['stuff'].split()[1] == '=':
key = g['stuff'].split()[0]
return
try:
set_config(key, value)
- # Apply theme immediately
+ # Keys that needs to be apply immediately
if key == 'THEME':
c['THEME'] = reload_theme(value, c['THEME'])
g['decorated_name'] = lambda x: color_func(
c['DECORATED_NAME'])('[' + x + ']: ')
+ elif key == 'PREFIX':
+ g['PREFIX'] = u2str(emojize(c['PREFIX']))
reload_config()
printNicely(green('Updated successfully.'))
- except Exception as e:
- printNicely(red(e))
+ except:
+ debug_option()
+ printNicely(red('Just can not set the key.'))
else:
printNicely(light_magenta('Sorry I can\'s understand.'))
usage += s * 2 + \
light_green('ufav 12 ') + ' will unfavorite tweet with ' + \
light_yellow('[id=12]') + '.\n'
+ usage += s * 2 + \
+ light_green('share 12 ') + ' will get the direct link of the tweet with ' + \
+ light_yellow('[id=12]') + '.\n'
usage += s * 2 + \
light_green('del 12 ') + ' will delete tweet with ' + \
light_yellow('[id=12]') + '.\n'
' filter will decide nicks will be INCLUDE ONLY.\n'
usage += s * 3 + light_yellow('Ignore nicks') + \
' filter will decide nicks will be EXCLUDE.\n'
- usage += s * 2 + light_green('switch mine -d') + \
- ' will use the config\'s ONLY_LIST and IGNORE_LIST.\n'
usage += s * 2 + light_green('switch list') + \
' will switch to a Twitter list\'s stream. You will be asked for list name\n'
printNicely(usage)
'rep',
'del',
'ufav',
+ 'share',
's',
'mes',
'show',
reply,
delete,
unfavorite,
+ share,
search,
message,
show,
[], # reply
[], # delete
[], # unfavorite
+ [], # url
['#'], # search
['@'], # message
['image'], # show image
# 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,
projects / rainbowstream.git / blobdiff