60 lines
2.0 KiB
Python
Executable File
60 lines
2.0 KiB
Python
Executable File
#!/usr/bin/env python3
|
|
# This Source Code Form is subject to the terms of the Mozilla Public
|
|
# License, v. 2.0. If a copy of the MPL was not distributed with this
|
|
# file, You can obtain one at http://mozilla.org/MPL/2.0/.
|
|
|
|
import mastodon
|
|
import os, random, re, json
|
|
import functions
|
|
from bs4 import BeautifulSoup
|
|
|
|
cfg = json.load(open('config.json', 'r'))
|
|
threads = {}
|
|
|
|
client = mastodon.Mastodon(
|
|
client_id=cfg['client']['id'],
|
|
client_secret=cfg['client']['secret'],
|
|
access_token=cfg['secret'],
|
|
api_base_url=cfg['site'])
|
|
|
|
def extract_toot(toot):
|
|
text = functions.extract_toot(toot)
|
|
text = re.sub(r"^@[^@]+@[^ ]+\s*", r"", text) #remove the initial mention
|
|
text = text.lower() #treat text as lowercase for easier keyword matching (if this bot uses it)
|
|
return text
|
|
|
|
class ReplyListener(mastodon.StreamListener):
|
|
def on_notification(self, notification): #listen for notifications
|
|
if notification['type'] == 'mention': #if we're mentioned:
|
|
acct = "@" + notification['account']['acct'] #get the account's @
|
|
post_id = notification['status']['id']
|
|
# check if we've already been participating in this thread
|
|
try:
|
|
context = client.status_context(post_id)
|
|
except:
|
|
print("failed to fetch thread context")
|
|
return
|
|
me = client.account_verify_credentials()['id']
|
|
posts = 0
|
|
for post in context['ancestors']:
|
|
if post['account']['id'] == me:
|
|
posts += 1
|
|
if posts >= cfg['max_thread_length']:
|
|
# stop replying
|
|
print("didn't reply (max_thread_length exceeded)")
|
|
return
|
|
|
|
threads[post_id] = [time.time(), 0]
|
|
mention = extract_toot(notification['status']['content'])
|
|
toot = functions.make_toot(True)['toot'] #generate a toot
|
|
toot = acct + " " + toot #prepend the @
|
|
print(acct + " says " + mention) #logging
|
|
visibility = notification['status']['visibility']
|
|
if visibility == "public":
|
|
visibility = "unlisted"
|
|
client.status_post(toot, post_id, visibility=visibility, spoiler_text = cfg['cw']) #send toost
|
|
print("replied with " + toot) #logging
|
|
|
|
rl = ReplyListener()
|
|
client.stream_user(rl) #go!
|