Mirrors/catask
1
0
Fork 0
mirror of https://codeberg.org/catask-org/catask.git synced 2025-04-19 13:23:41 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

add crosspost functionality

Browse source
This commit is contained in:
mst 2025-03-11 16:07:34 +03:00
parent 845590c1ce
commit bdc61c31bc
No known key found for this signature in database
1 changed files with 31 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

31
functions.py
View file

@ -7,6 +7,7 @@ from pathlib import Path
from mistune import HTMLRenderer, escape from mistune import HTMLRenderer, escape
from PIL import Image from PIL import Image
from psycopg.rows import dict_row from psycopg.rows import dict_row
from mastodon import Mastodon
import base64 import base64
import time import time
import zipfile import zipfile
@ -291,6 +292,7 @@ def addAnswer(question_id: int, answer: str, cw: str) -> dict:
cursor.execute("UPDATE questions SET answered=%s, answer_id=%s WHERE id=%s", (True, answer_id, question_id)) cursor.execute("UPDATE questions SET answered=%s, answer_id=%s WHERE id=%s", (True, answer_id, question_id))
conn.commit() conn.commit()
# except Exception as e: # except Exception as e:
# conn.rollback() # conn.rollback()
# app.logger.error(e) # app.logger.error(e)
@ -301,6 +303,35 @@ def addAnswer(question_id: int, answer: str, cw: str) -> dict:
return jsonify({'message': _('Answer added successfully!')}), 201 return jsonify({'message': _('Answer added successfully!')}), 201
def postOnFediverse(question_id: int, answer: str, cw: str) -> None:
# reloading config file
cfg = loadJSON(const.configFile)
conn = connectToDb()
cursor = conn.cursor()
app.logger.debug(f"[postOnFediverse] Grabbing question {question_id} from database...")
cursor.execute("SELECT id, content FROM questions WHERE id=%s", (question_id,))
question = cursor.fetchone()
app.logger.debug("[postOnFediverse] Initializing Mastodon client...")
client = Mastodon(
client_id = cfg['crosspost']['fediverse']['client']['id'],
client_secret = cfg['crosspost']['fediverse']['client']['secret'],
api_base_url = 'https://' + cfg['crosspost']['fediverse']['instance'],
access_token = cfg['crosspost']['fediverse']['token']
)
if cw:
warning = f"{cfg['crosspost']['fediverse']['cw']}, {cw}"
else:
warning = cfg['crosspost']['fediverse']['cw']
post_content = f"{question['content']} — {answer} {cfg['instance']['fullBaseUrl']}/q/{question['id']}/"
client.status_post(post_content, visibility=cfg['crosspost']['fediverse']['visibility'], spoiler_text=warning)
app.logger.debug(f"[postOnFediverse] Made Fediverse post: {post_content}")
def ntfySend(cw, return_val, from_who, question) -> None: def ntfySend(cw, return_val, from_who, question) -> None:
app.logger.debug("[CatAsk/functions/ntfySend] started ntfy flow") app.logger.debug("[CatAsk/functions/ntfySend] started ntfy flow")
ntfy_cw = f" [CW: {cw}]" if cw else "" ntfy_cw = f" [CW: {cw}]" if cw else ""