ayo/threads
1
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

feat: use mastodon's single API endpoint for fetching multiple statuses

Browse source
This commit is contained in:
ayo 2026-03-09 17:51:22 +01:00
parent d151375d63
commit d932c42247
1 changed files with 12 additions and 41 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

53
threads.py
View file

@ -2,13 +2,10 @@ from flask import Blueprint, render_template, current_app
import requests import requests
from datetime import datetime from datetime import datetime
from .cache import cache from .cache import cache
import asyncio
import aiohttp
from . import utils from . import utils
threads = Blueprint('threads', __name__, template_folder='templates', static_folder='static') threads = Blueprint('threads', __name__, template_folder='templates', static_folder='static')
# TODO: move following to an app config or sqlite #########
thread_ids = [ thread_ids = [
'115620814664415087', '115620814664415087',
'115090396384901152', '115090396384901152',
@ -30,19 +27,6 @@ thread_ids = [
'112857903897175549', '112857903897175549',
'112857168376771706', '112857168376771706',
'112524983806134679', '112524983806134679',
# '112461583113763423',
# '112457129122626146',
# '112446314845243621',
# '112438729626526601',
# '112410098697040344',
# '112400284252533385',
# '112365019457303644',
# '112360396639315016',
# '112305891918761955',
# '112258065967208438',
# '111657861089216432',
# '110639728990416918',
# '109545132056133905'
] ]
########################################################### ###########################################################
@ -62,7 +46,6 @@ def get_user_id():
### featured tags ### featured tags
def get_account_tagged_statuses(tag_name): def get_account_tagged_statuses(tag_name):
print(tag_name)
id = get_user_id() id = get_user_id()
ser = server() ser = server()
url = f'{ser}/api/v1/accounts/{id}/statuses?exclude_replies=true&tagged={tag_name}' url = f'{ser}/api/v1/accounts/{id}/statuses?exclude_replies=true&tagged={tag_name}'
@ -98,30 +81,17 @@ def middleware():
attribution['current_year'] = year attribution['current_year'] = year
### statuses ### statuses
async def get(url, session):
try:
async with session.get(url, ssl=False) as response:
if response.status == 200:
res = await response.json()
return utils.clean_status(res)
else:
print(f"No status: {url}")
except Exception as e:
return None
def get_status_url(ser, id): def get_status_url(ser, id):
return f'{ser}/api/v1/statuses/{id}' return f'{ser}/api/v1/statuses/{id}'
async def fetch_statuses(): async def fetch_statuses():
statuses = [] query_params = "&id[]=".join(thread_ids)
urls = [get_status_url(server(), id) for id in thread_ids] response = requests.get(server() + '/api/v1/statuses?id[]=' + query_params )
try: if response.status_code == 200:
async with aiohttp.ClientSession() as session: statuses = response.json()
statuses = await asyncio.gather(*(get(url, session) for url in urls)) return statuses
filtered = [x for x in statuses if x is not None] else:
return filtered return []
except:
return None
def fetch_thread(id): def fetch_thread(id):
response = requests.get(server() + '/api/v1/statuses/' + id ) response = requests.get(server() + '/api/v1/statuses/' + id )
@ -186,10 +156,11 @@ def thread(id):
app = get_app_config() app = get_app_config()
max_length = app.get('max_summary_length', 69) # Configure max summary length max_length = app.get('max_summary_length', 69) # Configure max summary length
status = fetch_thread(id) status = fetch_thread(id)
status['summary'] = utils.clean_html(status['content']).strip() if status is not None:
if len(status['summary']) > max_length: status['summary'] = utils.clean_html(status['content']).strip()
status['summary'] = status['summary'][:max_length] + '...' if len(status['summary']) > max_length:
return render_template('_home.html', threads=[status], app=app, attribution=attribution, render_date=datetime.now()) status['summary'] = status['summary'][:max_length] + '...'
return render_template('_home.html', threads=[status], app=app, attribution=attribution, render_date=datetime.now())
@threads.route('/api') @threads.route('/api')
@cache.cached(timeout=300) @cache.cached(timeout=300)