vinindkoeb/app/services/postal.py
carsten 34ed5c28d7 Add Postal sending, "annoncér runde" action, and MailLog (task 7b)
POST /purchase-rounds/{id}/announce renders the route's round_announced
MailTemplate with simple {{variable}} substitution (app/services/
mail_rendering.py) for every active participant on the route, sends
via Postal's real HTTP API (app/services/postal.py — request/response
shapes verified directly against docs.postalserver.io, not guessed),
and records one MailLog row per attempt (sent/failed, Postal's
message id + token for the future webhook in 7c, denormalized
rendered_subject so the log reflects what was actually sent even if
the template changes later). A failed send for one participant doesn't
abort the rest — each attempt is isolated and committed individually.

Route gained sender_name/sender_email in 7a; both are now populated
for the real route from the historical emails ("Finn Gram - Fælles
Vinindkøb <finn@vinindkoeb.dk>") directly in the DB, since there's no
Route CRUD API yet.

Verified end-to-end against the real Postal instance: a real test
email was sent and received via an isolated throwaway Organization/
Route/Participant/PurchaseRound/MailTemplate sandbox (never the real
route's 308 participants), MailLog captured the correct Postal message
id/token, and a temporarily-invalid API key produced a clean
sent:0/failed:1 result with Postal's actual error message stored,
not a 500. All test data removed afterward; real route/participant
data confirmed untouched.

Co-Authored-By: Claude Sonnet 5 <noreply@anthropic.com>
2026-09-28 20:16:04 +02:00

47 lines
1.2 KiB
Python

import httpx
from app.core.config import get_settings
class PostalSendError(Exception):
pass
def send_mail(
*,
to: str,
from_name: str,
from_email: str,
subject: str,
html_body: str,
tag: str,
) -> tuple[int, str]:
"""Sender én e-mail via Postal. Returnerer (postal_message_id, token).
Rejser PostalSendError ved fejl."""
settings = get_settings()
try:
response = httpx.post(
f"{settings.postal_base_url}/api/v1/send/message",
headers={
"X-Server-API-Key": settings.postal_api_key,
"Content-Type": "application/json",
},
json={
"to": [to],
"from": f"{from_name} <{from_email}>",
"sender": from_email,
"subject": subject,
"html_body": html_body,
"tag": tag,
},
timeout=10.0,
)
data = response.json()
except httpx.HTTPError as exc:
raise PostalSendError(str(exc)) from exc
if data.get("status") != "success":
raise PostalSendError(str(data.get("data", data)))
message_info = data["data"]["messages"][to]
return message_info["id"], message_info["token"]