aboutsummaryrefslogtreecommitdiff
path: root/modules
diff options
context:
space:
mode:
authorGravatar jesopo2019-09-16 15:49:03 +0100
committerGravatar jesopo2019-09-16 15:49:03 +0100
commit6959bba5f3889e0661d6f586f2d0cde28915323b (patch)
treea4f016b954d15c4c0d696aa16f086baa021ef9a8 /modules
parentEventRoot._hook's `kwarg` should be a list of tuples (diff)
signature
move getting private_key/our_actor to __init__ (for main thread)
Diffstat (limited to 'modules')
-rw-r--r--modules/fediverse/ap_server.py14
1 files changed, 8 insertions, 6 deletions
diff --git a/modules/fediverse/ap_server.py b/modules/fediverse/ap_server.py
index 0df2eac5..f408b8e0 100644
--- a/modules/fediverse/ap_server.py
+++ b/modules/fediverse/ap_server.py
@@ -12,12 +12,6 @@ class Server(object):
self.username = username
self.instance = instance
- self._request_queue = queue.Queue()
- self._request_thread = threading.Thread(target=self._request_loop)
- self._request_thread.daemon = True
- self._request_thread.start()
-
- def _request_loop(self):
url_for = self.exports.get_one("url-for")
key_id = self._ap_keyid_url(url_for)
@@ -28,6 +22,14 @@ class Server(object):
del url_for
+ self._request_queue = queue.Queue()
+ self._request_thread = threading.Thread(target=self._request_loop,
+ args=(private_key, our_actor))
+ self._request_thread.daemon = True
+ self._request_thread.start()
+
+ def _request_loop(self, private_key, our_actor):
+
while True:
obj = self._request_queue.get()
if obj == "kill":