Store book events when sending posts

merge-requests/30/head
Bob Mottram 2024-01-03 19:11:17 +00:00
parent 1edcc9a3a1
commit 4b91b19fbb
3 changed files with 21 additions and 3 deletions

View File

@ -2073,7 +2073,10 @@ class PubServer(BaseHTTPRequestHandler):
self.server.dogwhistles,
self.server.min_images_for_accounts,
self.server.buy_sites,
self.server.sites_unavailable)
self.server.sites_unavailable,
self.server.max_recent_books,
self.server.books_cache,
self.server.max_cached_readers)
def _get_outbox_thread_index(self, nickname: str,
max_outbox_threads_per_account: int) -> int:

View File

@ -62,6 +62,7 @@ from shares import outbox_share_upload
from shares import outbox_undo_share_upload
from webapp_post import individual_post_as_html
from speaker import update_speaker
from reading import store_book_events
def _person_receive_update_outbox(base_dir: str, http_prefix: str,
@ -246,7 +247,10 @@ def post_message_to_outbox(session, translate: {},
dogwhistles: {},
min_images_for_accounts: [],
buy_sites: {},
sites_unavailable: []) -> bool:
sites_unavailable: [],
max_recent_books: int,
books_cache: {},
max_cached_readers: int) -> bool:
"""post is received by the outbox
Client to server message post
https://www.w3.org/TR/activitypub/#client-to-server-outbox-delivery
@ -498,6 +502,14 @@ def post_message_to_outbox(session, translate: {},
theme, system_language,
outbox_name)
store_book_events(base_dir,
message_json,
system_language, [],
translate, debug,
max_recent_books,
books_cache,
max_cached_readers)
# save all instance blogs to the news actor
if post_to_nickname != 'news' and outbox_name == 'tlblogs':
if '/' in saved_filename:

View File

@ -152,7 +152,10 @@ def _update_post_schedule(base_dir: str, handle: str, httpd,
httpd.dogwhistles,
httpd.min_images_for_accounts,
httpd.buy_sites,
httpd.sites_unavailable):
httpd.sites_unavailable,
httpd.max_recent_books,
httpd.books_cache,
httpd.max_cached_readers):
index_lines.remove(line)
try:
os.remove(post_filename)