Twitter Favoriter

config.conf

twitter_api_key="XXXX"
twitter_api_secret="XXXX"
twitter_access_key="XXXX"
twitter_access_secret="XXXX"

config.py

def get(value):  
    config = {}
    execfile('config.conf', config)
    return config[value]

watcher.py

import config
import tweepy

def get_api():
        return tweepy.API(auth)

def get_auth():
        consumer_key = config.get("twitter_api_key")
        consumer_secret = config.get("twitter_api_secret")
        access_token_key = config.get("twitter_access_key")
        access_token_secret = config.get("twitter_access_secret")
        if consumer_key is None or consumer_secret is None or access_token_key is None or access_token_secret is None:
                return None
        auth = tweepy.OAuthHandler(bytes(consumer_key), bytes(consumer_secret))
        auth.set_access_token(bytes(access_token_key), bytes(access_token_secret))
        return auth

auth = get_auth()
api = get_api()

def new_stream():
        s = StreamWatcherListener()
        stream = tweepy.Stream(auth, s, timeout=None)
        stream.filter(track=['#blackhawks"])


class StreamWatcherListener(tweepy.StreamListener):
        def on_status(self, status):
                try:
                        print status.text
                        api.create_favorite(status.id_str)
                except:
                        pass

        def on_error(self, status_code):
                from time import sleep
                print 'An error has occurred! Status code = %s' % status_code
                if str(status_code) == "420":
                        print 'Waiting 3 seconds before restarting streams.'
                        sleep(3000)
                return True

        def on_timeout(self):
                print 'Streaming API timed out...'