import cgi
from Crypto.PublicKey import RSA
from .database import DATABASE
+from .http_debug import http_debug
# generate actor keys if not present
logging.debug('%r >> %r', inbox, message)
- async with aiohttp.ClientSession() as session:
+ async with aiohttp.ClientSession(trace_configs=[http_debug()]) as session:
async with session.post(inbox, data=data, headers=headers) as resp:
resp_payload = await resp.text()
logging.debug('%r >> resp %r', inbox, resp_payload)
--- /dev/null
+import logging
+import aiohttp
+
+
+async def on_request_start(session, trace_config_ctx, params):
+ logging.debug("HTTP START [%r], [%r]", session, params)
+
+
+def http_debug():
+ trace_config = aiohttp.TraceConfig()
+ trace_config.on_request_start.append(on_request_start)
+ return trace_config
import aiohttp
from .database import DATABASE
+from .http_debug import http_debug
ACTORS = DATABASE.get("actors", {})
if uri in ACTORS and not force:
return ACTORS[uri]
- async with aiohttp.ClientSession() as session:
+ async with aiohttp.ClientSession(trace_configs=[http_debug()]) as session:
async with session.get(uri, headers={'Accept': 'application/activity+json'}) as resp:
ACTORS[uri] = (await resp.json(encoding='utf-8', content_type=None))
DATABASE["actors"] = ACTORS