From 5730d7bff0635dcbdc73ad4b771ad59a1bfff9a2 Mon Sep 17 00:00:00 2001 From: Bob Mottram Date: Mon, 14 Mar 2022 13:45:42 +0000 Subject: [PATCH] Fix missing server parameters --- daemon.py | 2 +- inbox.py | 22 +++++++++++++--------- 2 files changed, 14 insertions(+), 10 deletions(-) diff --git a/daemon.py b/daemon.py index 770225a99..110ced53f 100644 --- a/daemon.py +++ b/daemon.py @@ -20784,7 +20784,7 @@ def run_daemon(crawlers_allowed: [], print('THREAD: Creating inbox queue') httpd.thrInboxQueue = \ thread_with_trace(target=run_inbox_queue, - args=(httpd.recent_posts_cache, + args=(httpd, httpd.recent_posts_cache, httpd.max_recent_posts, project_version, base_dir, http_prefix, httpd.send_threads, diff --git a/inbox.py b/inbox.py index b6ca4c3cc..b3ba36255 100644 --- a/inbox.py +++ b/inbox.py @@ -2671,7 +2671,7 @@ def _group_handle(base_dir: str, handle: str) -> bool: return actor_json['type'] == 'Group' -def _send_to_group_members(session, session_onion, session_i2p, +def _send_to_group_members(server, session, session_onion, session_i2p, base_dir: str, handle: str, port: int, post_json_object: {}, http_prefix: str, federation_list: [], @@ -2735,7 +2735,7 @@ def _send_to_group_members(session, session_onion, session_i2p, debug, __version__, signing_priv_key_pem, curr_domain, onion_domain, i2p_domain) - send_to_followers_thread(session, session_onion, session_i2p, + send_to_followers_thread(server, session, session_onion, session_i2p, base_dir, nickname, domain, onion_domain, i2p_domain, port, http_prefix, federation_list, @@ -3063,7 +3063,7 @@ def _is_valid_dm(base_dir: str, nickname: str, domain: str, port: int, return True -def _receive_question_vote(base_dir: str, nickname: str, domain: str, +def _receive_question_vote(server, base_dir: str, nickname: str, domain: str, http_prefix: str, handle: str, debug: bool, post_json_object: {}, recent_posts_cache: {}, session, session_onion, session_i2p, @@ -3143,7 +3143,7 @@ def _receive_question_vote(base_dir: str, nickname: str, domain: str, question_json['type'] = 'Update' shared_items_federated_domains = [] shared_item_federation_tokens = {} - send_to_followers_thread(session, session_onion, session_i2p, + send_to_followers_thread(server, session, session_onion, session_i2p, base_dir, nickname, domain, onion_domain, i2p_domain, port, http_prefix, federation_list, @@ -3271,7 +3271,8 @@ def _check_for_git_patches(base_dir: str, nickname: str, domain: str, return 0 -def _inbox_after_initial(recent_posts_cache: {}, max_recent_posts: int, +def _inbox_after_initial(server, + recent_posts_cache: {}, max_recent_posts: int, session, session_onion, session_i2p, key_id: str, handle: str, message_json: {}, base_dir: str, http_prefix: str, send_threads: [], @@ -3558,7 +3559,7 @@ def _inbox_after_initial(recent_posts_cache: {}, max_recent_posts: int, populate_replies(base_dir, http_prefix, domain, post_json_object, max_replies, debug) - _receive_question_vote(base_dir, nickname, domain, + _receive_question_vote(server, base_dir, nickname, domain, http_prefix, handle, debug, post_json_object, recent_posts_cache, session, session_onion, session_i2p, @@ -3730,7 +3731,8 @@ def _inbox_after_initial(recent_posts_cache: {}, max_recent_posts: int, # send the post out to group members if is_group: - _send_to_group_members(session, session_onion, session_i2p, + _send_to_group_members(server, + session, session_onion, session_i2p, base_dir, handle, port, post_json_object, http_prefix, federation_list, @@ -4239,7 +4241,8 @@ def _receive_follow_request(session, session_onion, session_i2p, this_domain, onion_domain, i2p_domain) -def run_inbox_queue(recent_posts_cache: {}, max_recent_posts: int, +def run_inbox_queue(server, + recent_posts_cache: {}, max_recent_posts: int, project_version: str, base_dir: str, http_prefix: str, send_threads: [], post_log: [], @@ -4725,7 +4728,8 @@ def run_inbox_queue(recent_posts_cache: {}, max_recent_posts: int, destination = \ queue_json['destination'].replace(inbox_handle, handle) languages_understood = [] - _inbox_after_initial(recent_posts_cache, + _inbox_after_initial(server, + recent_posts_cache, max_recent_posts, session, session_onion, session_i2p, key_id, handle,