Python SDK

pip install wazobiamail

from wazobiamail import WazobiaMail

client = WazobiaMail(api_key="wzbm_live_...")
# or read WAZOBIA_API_KEY / WAZOBIAMAIL_API_KEY from the environment:
client = WazobiaMail()

from wazobiamail import WazobiaMail

client = WazobiaMail(api_key="wzbm_live_...")

receipt = client.messages.send(
    to="customer@example.com",
    sender="Acme <hello@mail.example.com>",
    subject="Your order shipped",
    html="<p>Your order is on its way.</p>",
    text="Your order is on its way.",
    idempotency_key="order-1042-shipped",
)
print(receipt.data.tracking_id)

# email_service.py
from functools import lru_cache
from django.conf import settings
from wazobiamail import WazobiaMail

@lru_cache
def get_client() -> WazobiaMail:
    return WazobiaMail(api_key=settings.WAZOBIA_API_KEY)

def send_welcome(user):
    return get_client().messages.send(
        to=user.email,
        subject="Welcome",
        html="<p>Your account is ready.</p>",
        sender="Acme <hello@mail.example.com>",
        idempotency_key=f"welcome-{user.pk}",
    )

from asgiref.sync import sync_to_async
await sync_to_async(send_welcome)(user)

from fastapi import FastAPI, HTTPException
from fastapi.concurrency import run_in_threadpool
from wazobiamail import WazobiaMail, WazobiaError

app = FastAPI()
client = WazobiaMail()

@app.post("/send")
async def send_email():
    try:
        return await run_in_threadpool(
            client.messages.send,
            to="customer@example.com",
            subject="Hello",
            html="<p>Hi there.</p>",
            sender="Acme <hello@mail.example.com>",
        )
    except WazobiaError as exc:
        raise HTTPException(status_code=502, detail=str(exc)) from exc

from django.http import JsonResponse
from django.views.decorators.csrf import csrf_exempt

@csrf_exempt
def wazobia_webhook(request):
    event = get_client().webhooks.construct_event(
        request.body,
        request.headers.get("X-Wazobia-Signature", ""),
        settings.WAZOBIA_WEBHOOK_SECRET,
    )
    return JsonResponse({"received": True})

from fastapi import Request

@app.post("/webhooks/wazobia")
async def wazobia_webhook(request: Request):
    body = await request.body()
    event = client.webhooks.construct_event(
        body,
        request.headers.get("X-Wazobia-Signature", ""),
        WEBHOOK_SECRET,
    )
    return {"received": True}