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]]
# 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( '(waiting 16mn for rate limits reasons...)' )
- time.sleep(16*60)
+ 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] + '.')
# 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):
"""