import webbrowser
import traceback
import pkg_resources
+import socks
+import socket
from twitter.stream import TwitterStream, Timeout, HeartbeatTimeout, Hangup
from twitter.api import *
from twitter.oauth_dance import oauth_dance
from twitter.util import printNicely
+from urllib import error
+
from .draw import *
from .colors import *
from .config import *
'--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='SOCKS4',
+ help='Proxy type (HTTP, SOCKS4, SOCKS5; Default: SOCKS5).')
return parser.parse_args()
# 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()
t = Twitter(auth=authen())
try:
id = int(g['stuff'].split()[0])
+ tid = c['tweet_dict'][id]
except:
- printNicely(red('Sorry I can\'t understand.'))
+ printNicely(red('Tweet id is not valid.'))
return
- tid = c['tweet_dict'][id]
tweet = t.statuses.show(id=tid)
url = 'https://twitter.com/' + \
tweet['user']['screen_name'] + '/status/' + str(tid)
- os.system("echo '%s' | pbcopy" % url)
- printNicely(green('Copied tweet\'s url to clipboard.'))
+ 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():
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.'))
light_green('ufav 12 ') + ' will unfavorite tweet with ' + \
light_yellow('[id=12]') + '.\n'
usage += s * 2 + \
- light_green('share 12 ') + ' will copy the url of the tweet with ' + \
- light_yellow('[id=12]') + ' to your clipboard.\n'
+ 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)
# Initial
args = parse_arguments()
try:
+ if args.proxy_host:
+ # Setup proxy by monkeypatching the standard lib
+ # You might want to check https://github.com/Anorov/PySocks for further
+ # further info.
+ 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
init(args)
except TwitterHTTPError:
printNicely('')
printNicely(magenta("Let's try again later."))
save_history()
sys.exit()
+ except (ConnectionRefusedError, socks.ProxyConnectionError, error.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