ticketfrei/retweetbot.py

190 lines
6.1 KiB
Python
Raw Normal View History

2017-06-17 17:55:52 +00:00
#!/usr/bin/env python
import twitter
import requests
import pytoml as toml
import trigger
2017-06-17 17:55:52 +00:00
from time import sleep
__encoding__ = "utf-8"
2017-06-17 17:55:52 +00:00
2017-06-17 20:11:44 +00:00
class RetweetBot(object):
2017-06-17 17:55:52 +00:00
"""
This bot retweets all tweets which
1) mention him,
2) contain at least one of the triggerwords provided.
2017-06-17 17:55:52 +00:00
api: The api object, generated with your oAuth keys, responsible for communication with twitter rest API
triggers: a list of words, one of them has to be in a tweet for it to be retweeted
last_mention: the ID of the last tweet which mentioned you
"""
def __init__(self, trigger, config,
2017-06-17 17:55:52 +00:00
historypath="last_mention",
user_id="801098086005243904",
screen_name="links_tech"):
2017-06-17 17:55:52 +00:00
"""
Initializes the bot and loads all the necessary data.
:param historypath: Path to the file with ID of the last retweeted Tweet
"""
self.config = config
keys = self.get_api_keys()
self.api = twitter.Api(consumer_key=keys[0],
consumer_secret=keys[1],
access_token_key=keys[2],
access_token_secret=keys[3])
2017-06-17 17:55:52 +00:00
self.historypath = historypath
self.user_id = user_id
self.screen_name = screen_name
2017-06-17 20:32:20 +00:00
self.last_mention = self.get_history(self.historypath)
self.trigger = trigger
2017-06-17 17:55:52 +00:00
def get_api_keys(self):
2017-06-17 17:55:52 +00:00
"""
How to get these keys is described in doc/twitter_api.md
After you received keys, store them in your ticketfrei.cfg like this:
[tapp]
consumer_key = "..."
consumer_secret = "..."
[tuser]
access_token_key = "..."
access_token_secret = "..."
:return: keys: list of these 4 strings.
2017-06-17 17:55:52 +00:00
"""
keys = []
keys.append(self.config['tapp']['consumer_key'])
keys.append(self.config['tapp']['consumer_secret'])
keys.append(self.config['tuser']['access_token_key'])
keys.append(self.config['tuser']['access_token_secret'])
2017-06-17 17:55:52 +00:00
return keys
def get_history(self, path):
""" This counter is needed to keep track of your mentions, so you don't double RT them
:param path: string: contains path to the file where the ID of the last_mention is stored.
:return: last_mention: ID of the last tweet which mentioned the bot
"""
2017-06-17 20:32:20 +00:00
try:
with open(path, "r+") as f:
last_mention = f.read()
except IOError:
with open(path, "w+"):
last_mention = ""
2017-06-17 17:55:52 +00:00
return last_mention
def format_mastodon(self, status):
2017-06-17 17:55:52 +00:00
"""
Bridge your Retweets to mastodon.
:todo vmann: add all the mastodon API magic.
:param status: Object of a tweet.
:return: toot: text tooted on mastodon, e.g. "_b3yond: There are uniformed controllers in the U2 at Opernhaus."
"""
toot = status.user.name + ": " + status.text
return toot
def crawl_mentions(self):
"""
crawls all Tweets which mention the bot from the twitter rest API.
:return: list of Status objects
"""
while 1:
try:
mentions = self.api.GetMentions(since_id=self.last_mention)
return mentions
2017-06-17 22:35:34 +00:00
except twitter.TwitterError:
print("[ERROR] Rate Limit exceeded, trying again once a minute")
sleep(60)
except requests.exceptions.ConnectionError:
print("[ERROR] Bad Connection.")
sleep(10)
def retweet(self, status):
"""
Retweets a given tweet.
:param status: A tweet object.
:return: toot: string of the tweet, to toot on mastodon.
"""
while 1:
try:
self.api.PostRetweet(status.id)
return self.format_mastodon(status)
# maybe one day we get rid of this error. If not, try to uncomment these lines.
except twitter.error.TwitterError:
print("[ERROR] probably you already retweeted this tweet.")
return None
except requests.exceptions.ConnectionError:
print("[ERROR] Bad Connection.")
sleep(10)
def tweet(self, post):
"""
Tweet a post.
:param post: String with the text to tweet.
"""
while 1:
try:
self.api.PostUpdate(status=post)
return
except requests.exceptions.ConnectionError:
print("[ERROR] Bad Connection.")
sleep(10)
def flow(self, to_tweet=()):
""" The flow of crawling mentions and retweeting them.
:param to_tweet: list of strings to tweet
:return list of retweeted tweets, to toot on mastodon
"""
# Tweet the toots the Retootbot gives to us
for post in to_tweet:
self.tweet(post)
2017-06-17 17:55:52 +00:00
# Store all mentions in a list of Status Objects
mentions = self.crawl_mentions()
mastodon = []
for status in mentions:
# Is the Text of the Tweet in the triggerlist?
2017-06-25 17:15:38 +00:00
if self.trigger.is_ok(status.text):
2017-06-17 20:11:44 +00:00
# Retweet status
mastodon.append(self.retweet(status))
# save the id so it doesn't get crawled again
self.last_mention = status.id
2017-06-17 20:11:44 +00:00
# Return Retweets for tooting on mastodon
return mastodon
def shutdown(self):
""" If something breaks, it shuts down the bot and messages the owner. """
2017-06-25 17:15:38 +00:00
print("[ERROR] Shit went wrong, closing down.")
with open(self.historypath, "w") as f:
f.write(str(self.last_mention))
self.api.PostDirectMessage("Help! I broke down. restart me pls :$", self.user_id, self.screen_name)
2017-06-17 17:55:52 +00:00
2017-06-17 20:32:20 +00:00
if __name__ == "__main__":
2017-06-17 17:55:52 +00:00
# create an Api object
with open('ticketfrei.cfg') as configfile:
config = toml.load(configfile)
trigger = trigger.Trigger(config)
bot = RetweetBot(trigger, config)
2017-06-17 20:32:20 +00:00
while True:
bot.flow()
try:
pass
except:
bot.shutdown()
sleep(1)