'--proxy-type',
default='SOCKS5',
help='Proxy type (HTTP, SOCKS4, SOCKS5; Default: SOCKS5).')
+ parser.add_argument(
+ '-ta',
+ '--twitter-auth',
+ default=os.environ.get('HOME', os.environ.get('USERPROFILE', '')) + os.sep + '.rainbow_oauth',
+ help='Specify which OAuth profile to use for twitter. Default: ~/.rainbow_oauth.')
+ parser.add_argument(
+ '-pa',
+ '--pocket-auth',
+ default=os.environ.get('HOME', os.environ.get('USERPROFILE', '')) + os.sep + '.rainbow_pckt_oauth',
+ help='Specify which OAuth profile to use for pocket. Default: ~/.rainbow_pckt_oauth.')
return parser.parse_args()
Authenticate with Twitter OAuth
"""
# When using rainbow stream you must authorize.
- twitter_credential = os.environ.get(
- 'HOME',
- os.environ.get(
- 'USERPROFILE',
- '')) + os.sep + '.rainbow_oauth'
+ twitter_credential = g['twitter_oauth_path']
if not os.path.exists(twitter_credential):
oauth_dance('Rainbow Stream',
CONSUMER_KEY,
"""
Authenticate with Pocket OAuth
"""
- pocket_credential = os.environ.get(
- 'HOME',
- os.environ.get(
- 'USERPROFILE',
- '')) + os.sep + '.rainbow_pckt_oauth'
-
+ pocket_credential = g['pocket_oauth_path']
if not os.path.exists(pocket_credential):
request_token = Pocket.get_request_token(consumer_key=PCKT_CONSUMER_KEY)
auth_url = Pocket.get_auth_url(code=request_token, redirect_uri="/")
# Handle Ctrl C
ctrl_c_handler = lambda signum, frame: quit()
signal.signal(signal.SIGINT, ctrl_c_handler)
+ # Set OAuth file path (needs to happen before authen is called)
+ g['twitter_oauth_path'] = args.twitter_auth
+ g['pocket_oauth_path'] = args.pocket_auth
# Upgrade notify
upgrade_center()
# Get name
credential = t.account.verify_credentials()
screen_name = '@' + credential['screen_name']
name = credential['name']
+ g['id_str'] = credential['id_str']
c['original_name'] = g['original_name'] = screen_name[1:]
g['listname'] = g['keyword'] = ''
g['PREFIX'] = u2str(emojize(format_prefix()))
print_trends(trends)
+def poll():
+ """
+ Fetch stream based on since_id
+ """
+ t = Twitter(auth=authen())
+
+ num = c['HOME_TWEET_NUM']
+ kwargs = {'count': num}
+
+ if 'since_id' in g:
+ kwargs['since_id'] = g['since_id']
+
+ kwargs = add_tweetmode_parameter(kwargs)
+ result = t.statuses.home_timeline(**kwargs)
+ if result:
+ g['since_id'] = result[0]['id']
+ for tweet in reversed(result):
+ draw(t=tweet)
+ if result:
+ printNicely('')
+
def home():
"""
Home
num = c['HOME_TWEET_NUM']
if g['stuff'].isdigit():
num = int(g['stuff'])
- for tweet in reversed(t.statuses.home_timeline(count=num)):
+ kwargs = {'count': num}
+ kwargs = add_tweetmode_parameter(kwargs)
+ for tweet in reversed(t.statuses.home_timeline(**kwargs)):
draw(t=tweet)
printNicely('')
num = c['HOME_TWEET_NUM']
if g['stuff'].isdigit():
num = int(g['stuff'])
- for tweet in reversed(t.statuses.mentions_timeline(count=num)):
+ kwargs = {'count': num}
+ kwargs = add_tweetmode_parameter(kwargs)
+ for tweet in reversed(t.statuses.mentions_timeline(**kwargs)):
draw(t=tweet)
printNicely('')
num = int(g['stuff'].split()[1])
except:
num = c['HOME_TWEET_NUM']
- for tweet in reversed(
- t.statuses.user_timeline(count=num, screen_name=user[1:])):
+ kwargs = {'count': num, 'screen_name': user[1:]}
+ kwargs = add_tweetmode_parameter(kwargs)
+ for tweet in reversed(t.statuses.user_timeline(**kwargs)):
draw(t=tweet)
printNicely('')
else:
num = int(g['stuff'])
except:
num = c['HOME_TWEET_NUM']
+ kwargs = {'count': num, 'screen_name': g['original_name']}
+ kwargs = add_tweetmode_parameter(kwargs)
for tweet in reversed(
- t.statuses.user_timeline(count=num, screen_name=g['original_name'])):
+ t.statuses.user_timeline(**kwargs)):
draw(t=tweet)
printNicely('')
type = 'mixed'
max_record = c['SEARCH_MAX_RECORD']
count = min(max_record, 100)
+ kwargs = {
+ 'q': query,
+ 'type': type,
+ 'count': count,
+ }
+ kwargs = add_tweetmode_parameter(kwargs)
# Perform search
- rel = t.search.tweets(
- q=query,
- type=type,
- count=count
- )['statuses']
+ rel = t.search.tweets(**kwargs)['statuses']
# Return results
if rel:
printNicely('Newest tweets:')
- for i in reversed(xrange(count)):
+ for i in reversed(xrange(min(len(rel), count))):
draw(t=rel[i], keyword=query)
printNicely('')
else:
printNicely(red('Sorry I can\'t understand.'))
return
tid = c['tweet_dict'][id]
- tweet = t.statuses.show(id=tid)
+ kwargs = {'id': tid}
+ kwargs = add_tweetmode_parameter(kwargs)
+ tweet = t.statuses.show(**kwargs)
# Get formater
formater = format_quote(tweet)
if not formater:
except:
num = c['RETWEETS_SHOW_NUM']
# Get result and display
- rt_ary = t.statuses.retweets(id=tid, count=num)
+ kwargs = {'id': tid, 'count': num}
+ kwargs = add_tweetmode_parameter(kwargs)
+ rt_ary = t.statuses.retweets(**kwargs)
if not rt_ary:
printNicely(magenta('This tweet has no retweet.'))
return
printNicely(red('Sorry I can\'t understand.'))
return
tid = c['tweet_dict'][id]
- tweet = t.statuses.show(id=tid)
+ kwargs = {'id': tid}
+ kwargs = add_tweetmode_parameter(kwargs)
+ tweet = t.statuses.show(**kwargs)
limit = c['CONVERSATION_MAX']
thread_ref = []
thread_ref.append(tweet)
prev_tid = tweet['in_reply_to_status_id']
while prev_tid and limit:
limit -= 1
- tweet = t.statuses.show(id=prev_tid)
+ kwargs['id'] = prev_tid
+ tweet = t.statuses.show(**kwargs)
prev_tid = tweet['in_reply_to_status_id']
thread_ref.append(tweet)
tid = c['tweet_dict'][id]
user = t.statuses.show(id=tid)['user']['screen_name']
status = ' '.join(g['stuff'].split()[1:])
- status = '@' + user + ' ' + str2u(status)
+ # don't include own username for tweet chains
+ # for details see issue https://github.com/DTVD/rainbowstream/issues/163
+ if user == g['original_name']:
+ status = str2u(status)
+ else:
+ status = '@' + user + ' ' + str2u(status)
t.statuses.update(status=status, in_reply_to_status_id=tid)
tid = c['tweet_dict'][id]
t.favorites.create(_id=tid, include_entities=False)
printNicely(green('Favorited.'))
- draw(t.statuses.show(id=tid))
+ kwargs = {'id': tid}
+ kwargs = add_tweetmode_parameter(kwargs)
+ draw(t.statuses.show(**kwargs))
printNicely('')
tid = c['tweet_dict'][id]
t.favorites.destroy(_id=tid)
printNicely(green('Okay it\'s unfavorited.'))
- draw(t.statuses.show(id=tid))
+ kwargs = {'id': tid}
+ kwargs = add_tweetmode_parameter(kwargs)
+ draw(t.statuses.show(**kwargs))
printNicely('')
except:
printNicely(red('Tweet id is not valid.'))
return
- tweet = t.statuses.show(id=tid)
+ kwargs = {'id': tid}
+ kwargs = add_tweetmode_parameter(kwargs)
+ tweet = t.statuses.show(**kwargs)
url = 'https://twitter.com/' + \
tweet['user']['screen_name'] + '/status/' + str(tid)
import platform
num = c['MESSAGES_DISPLAY']
if g['stuff'].isdigit():
num = g['stuff']
+
+ def inboxFilter(message):
+ return message['message_create']['sender_id'] == g['id_str']
+ def sentFilter(message):
+ return message['message_create']['target']['recipient_id'] == g['id_str']
+
+ def map_message(message):
+ message_create = message['message_create']
+ sender = t.users.show(id=int(message_create['sender_id']),include_entities=False)
+ recipient = t.users.show(id=int(message_create['target']['recipient_id']),include_entities=False)
+ message['sender_screen_name'] = sender['screen_name']
+ message['sender_name'] = sender['name']
+ message['recipient_screen_name'] = recipient['screen_name']
+ message['recipient_name'] = recipient['name']
+ message['text'] = message['message_create']['message_data']['text']
+ message['created_at'] = message['created_timestamp']
+ return message
+
# Get inbox messages
- cur_page = 1
- inbox = []
- while num > 20:
- inbox = inbox + t.direct_messages(
- count=20,
- page=cur_page,
- include_entities=False,
- skip_status=False
- )
- num -= 20
- cur_page += 1
- inbox = inbox + t.direct_messages(
- count=num,
- page=cur_page,
- include_entities=False,
- skip_status=False
- )
- # Get sent messages
- num = c['MESSAGES_DISPLAY']
- if g['stuff'].isdigit():
- num = g['stuff']
- cur_page = 1
- sent = []
- while num > 20:
- sent = sent + t.direct_messages.sent(
- count=20,
- page=cur_page,
- include_entities=False,
- skip_status=False
- )
- num -= 20
- cur_page += 1
- sent = sent + t.direct_messages.sent(
- count=num,
- page=cur_page,
- include_entities=False,
- skip_status=False
- )
+ messages = t.direct_messages.events.list()['events']
+ messages = list(map(map_message, messages))
+ inbox = list(filter(inboxFilter, messages))
+ sent = list(filter(sentFilter, messages))
d = {}
uniq_inbox = list(set(
- [(m['sender_screen_name'], m['sender']['name']) for m in inbox]
+ [(m['sender_screen_name'], m['sender_name']) for m in inbox]
))
uniq_sent = list(set(
- [(m['recipient_screen_name'], m['recipient']['name']) for m in sent]
+ [(m['recipient_screen_name'], m['recipient_name']) for m in sent]
))
for partner in uniq_inbox:
inbox_ary = [m for m in inbox if m['sender_screen_name'] == partner[0]]
d = {'fl': 'followers', 'fr': 'friends'}
next_cursor = -1
rel = {}
+
+ printNicely('All ' + d[target] + ':')
+
# Cursor loop
+ number_of_users = 0
while next_cursor != 0:
+
list = getattr(t, d[target]).list(
screen_name=name,
cursor=next_cursor,
skip_status=True,
include_entities=False,
)
+
for u in list['users']:
- rel[u['name']] = '@' + u['screen_name']
+
+ number_of_users += 1
+
+ # Print out result
+ printNicely( ' ' \
+ + cycle_color( u['name'] ) \
+ + color_func(c['TWEET']['nick'])( ' @' \
+ + u['screen_name'] \
+ + ' ' ) )
+
next_cursor = list['next_cursor']
- # Print out result
- printNicely('All: ' + str(len(rel)) + ' ' + d[target] + '.')
- for name in rel:
- user = ' ' + cycle_color(name)
- user += color_func(c['TWEET']['nick'])(' ' + rel[name] + ' ')
- printNicely(user)
+ # 300 users means 15 calls to the related API. The rate limit is 15
+ # calls per 15mn periods (see Twitter documentation).
+ if ( number_of_users % 300 == 0 ):
+ printNicely(light_yellow( 'We reached the limit of Twitter API.' ))
+ printNicely(light_yellow( 'You may need to wait about 15 minutes.' ))
+ break
+
+ printNicely('All: ' + str(number_of_users) + ' ' + d[target] + '.')
def follow():
"""
printNicely(light_magenta(guide))
only = raw_input('Only nicks [Ex: @xxx,@yy]: ')
ignore = raw_input('Ignore nicks [Ex: @xxx,@yy]: ')
- args.filter = filter(None, only.split(','))
- args.ignore = filter(None, ignore.split(','))
+ args.filter = list(filter(None, only.split(',')))
+ args.ignore = list(filter(None, ignore.split(',')))
except:
printNicely(red('Sorry, wrong format.'))
return
# Redefine decorated_name
g['decorated_name'] = lambda x: color_func(
c['DECORATED_NAME'])(
- '[' + x + ']: ')
+ '[' + x + ']: ', rl=True)
printNicely(green('Theme changed.'))
except:
printNicely(red('No such theme exists.'))
if key == 'THEME':
c['THEME'] = reload_theme(value, c['THEME'])
g['decorated_name'] = lambda x: color_func(
- c['DECORATED_NAME'])('[' + x + ']: ')
+ c['DECORATED_NAME'])('[' + x + ']: ', rl=True)
elif key == 'PREFIX':
g['PREFIX'] = u2str(emojize(format_prefix(
listname=g['listname'],
query_args = dict()
if args.track_keywords:
query_args['track'] = args.track_keywords
- # Get stream
- stream = TwitterStream(
- auth=authen(),
- domain=domain,
- **stream_args)
- try:
- if domain == c['USER_DOMAIN']:
- tweet_iter = stream.user(**query_args)
- elif domain == c['SITE_DOMAIN']:
- tweet_iter = stream.site(**query_args)
- else:
- if args.track_keywords:
- tweet_iter = stream.statuses.filter(**query_args)
- else:
- tweet_iter = stream.statuses.sample()
- # 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 --')
- elif tweet is Timeout:
- # Because the stream check for each 0.3s
- # so we shouldn't output anything here
- if(g['stream_stop']):
- StreamLock.release()
- break
- elif tweet is HeartbeatTimeout:
- printNicely('-- Heartbeat Timeout --')
- reconn_notice()
- StreamLock.release()
- break
- elif tweet is Hangup:
- printNicely('-- Hangup --')
- reconn_notice()
- StreamLock.release()
- break
- elif tweet.get('text'):
- # Slow down the stream by STREAM_DELAY config key
- if time.time() - last_tweet_time < c['STREAM_DELAY']:
- continue
- 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'](g['PREFIX']) + current_buffer)
- sys.stdout.flush()
- elif not c['HIDE_PROMPT']:
- sys.stdout.write(g['decorated_name'](g['PREFIX']))
- sys.stdout.flush()
- elif tweet.get('direct_message'):
- # Check the semaphore pause and lock (stream process only)
- if g['pause']:
- continue
- while c['lock']:
- time.sleep(0.5)
- print_message(tweet['direct_message'])
- elif tweet.get('event'):
- c['events'].append(tweet)
- print_event(tweet)
- except TwitterHTTPError as e:
- printNicely('')
- printNicely(
- magenta('We have connection problem with twitter stream API right now :('))
- detail_twitter_error(e)
- sys.stdout.write(g['decorated_name'](g['PREFIX']))
- sys.stdout.flush()
- except (URLError):
- printNicely(
- magenta('There seems to be a connection problem.'))
- save_history()
- sys.exit()
+ polling_time = 90
+ while True:
+ time.sleep(polling_time)
+ poll()
def spawn_public_stream(args, keyword=None):
"""
projects / rainbowstream.git / blobdiff