aknuth
/
docker
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

another logging

This commit is contained in:
Andreas Knuth 2025-06-13 16:15:49 -05:00
parent 434f94f882
commit 67b97f514b
1 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
email_api/email_api/app.py
View File

@ -60,24 +60,23 @@ def process_email(domain):
if not data:
return jsonify({'error': 'Invalid payload'}), 400
logger.info(f"[{request_id}] INCOMING POST /process/{domain}: payload={data}")
request_id = data.get('request_id', 'no-request-id')
content = data.get('email_content')
compressed = data.get('compressed', False)
raw = base64.b64decode(content)
email_bytes = gzip.decompress(raw) if compressed else raw
logger.info(f"[{request_id}] INCOMING POST /process/{domain}: "
f"payload_keys={list(data.keys())}")
msg = BytesParser(policy=default).parsebytes(email_bytes)
from_addr = getaddresses(msg.get_all('from', []))[0][1] if msg.get_all('from') else f'lambda@{domain}'
logger.debug(f"[{request_id}] Parsed email: from={from_addr}, recipients={recipients}")
recipients = []
for hdr in ('to', 'cc', 'bcc'):
recipients += [addr for _n, addr in getaddresses(msg.get_all(hdr, []))]
logger.debug(f"[{request_id}] Parsed email: from={from_addr}, recipients={recipients}")
if not recipients:
return jsonify({'error': 'No recipients'}), 400