dailyBot.py

#!/usr/bin/python3.8

import tweepy
import logging
from config import create_api
from random import seed
from random import randint
import time

seed(1)
logging.basicConfig(level=logging.INFO)
logger = logging.getLogger()

class FavRetweetListener(tweepy.StreamListener):
    def __init__(self, api):
        self.start_time = time.time()
        self.limit = 5 * 60
        self.api = api
        self.me = api.me()

    def on_status(self, tweet):
        stream_time = time.time() - self.start_time
        if stream_time < self.limit:
            logger.info(f"Processing tweet id {tweet.id}")
            time.sleep(randint(0, 10))
            if tweet.in_reply_to_status_id is not None or \
                tweet.user.id == self.me.id:
                # This tweet is a reply or I'm its author so, ignore it
                return
            if not tweet.favorited:
                # Mark it as Liked, since we have not done it yet
                try:
                    tweet.favorite()
                except Exception as e:
                    logger.error("Error on fav", exc_info=True)
            if not tweet.retweeted:
                # Retweet, since we have not retweeted it yet
                try:
                    should_retweet = randint(0, 10)
                    if should_retweet < 4:
                        logger.info("Retwweting...")
                        tweet.retweet()
                except Exception as e:
                    logger.error("Error retweet", exc_info=True)
            if not tweet.user.following:
                # Retweet, since we have not retweeted it yet
                try:
                    if should_retweet < 1:
                        logger.info("Following...")
                        self.api.create_friendship(tweet.user.id)
                except Exception as e:
                    logger.error("Error on follow", exc_info=True)
        else:
            logger.info(f"Closing stream, you have been streaming for: {stream_time}")
            return False

    def on_error(self, status):
        logger.error(status)

def main(keywords):
    api = create_api()
    tweets_listener = FavRetweetListener(api)
    stream = tweepy.Stream(api.auth, tweets_listener)
    stream.filter(track=keywords, languages=["en"])
    
if __name__ == "__main__":
    main(["Day #100DaysOfCode"])