From 4b91b19fbb2c70456aa0368cc20901badc9aa1aa Mon Sep 17 00:00:00 2001 From: Bob Mottram Date: Wed, 3 Jan 2024 19:11:17 +0000 Subject: [PATCH] Store book events when sending posts --- daemon.py | 5 ++++- outbox.py | 14 +++++++++++++- schedule.py | 5 ++++- 3 files changed, 21 insertions(+), 3 deletions(-) diff --git a/daemon.py b/daemon.py index 44d3bb0a3..7cc7b9aaf 100644 --- a/daemon.py +++ b/daemon.py @@ -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: diff --git a/outbox.py b/outbox.py index 863fb4b7b..c22e109a2 100644 --- a/outbox.py +++ b/outbox.py @@ -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: diff --git a/schedule.py b/schedule.py index ed5e77d64..8796fc566 100644 --- a/schedule.py +++ b/schedule.py @@ -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)