def process_status()

in social-media/gather-data.py [0:0]


def process_status(status, output_file_handle):
    global sleep_before_get_status
    global sleep_before_get_user
    if status.retweeted_status is not None:
        return False
    record = {}
    record.update(status_to_map('', status))
    record.update(user_to_map('', status.user))
    if record['in_reply_to_status_id'] is not None:
        if sleep_before_get_status:
            sleep_then_update_flags()
        try:
            r2status = twitter_api.GetStatus(record['in_reply_to_status_id'])
            sleep_before_get_status = True
            record.update(status_to_map('r.', r2status))
            record.update(user_to_map('r.', r2status.user))
        except TwitterError as e:
            print(e)
            print('statusId:' + str(record['in_reply_to_status_id']))
    elif record['in_reply_to_user_id'] is not None:
        if sleep_before_get_user:
            sleep_then_update_flags()
        try:
            r2user = twitter_api.GetUser(int(record['in_reply_to_user_id']))
            sleep_before_get_user = True
            record.update(user_to_map('r.', r2user))
        except TwitterError as e:
            print(e)
            print('statusId:' + str(record['in_reply_to_user_id']))
    output_file_handle.write(json.dumps(record))
    output_file_handle.write('\n')
    return True