Python

import os

from wajub import Wajub

# Reads WAJUB_API_KEY and WAJUB_WEBHOOK_SECRET from the environment.
wajub = Wajub()

# Or pass them yourself.
wajub = Wajub(
    api_key=os.environ["WAJUB_API_KEY"],
    webhook_secret=os.environ["WAJUB_WEBHOOK_SECRET"],
)

# A script, a task, a notebook: let the block close the pool.
with Wajub() as wajub:
    payment = wajub.payments.create({"amount": 25000, "currency": "XAF"})

# A Django or FastAPI process: build it once at import and leave it open.
wajub = Wajub()

payment = wajub.payments.create(
    {
        "amount": 25000,
        "currency": "XAF",
        "email": "amina@example.com",
        "description": "Order 4172",
        "reference": "order-4172",
        "callback": "https://shop.example.com/complete",
    }
)

print(payment.id)
print(payment.authorization_url)

payment.authorization_url
payment["authorization_url"]

# A field the API added after this release is still reachable.
payment["settlement_batch_id"]

page = wajub.payments.list({"status": "success", "per_page": 50})

# page.data holds plain dicts, not ApiObject, so use item access here.
for payment in page.data:
    print(payment["id"], payment["amount"])

if page.has_more:
    page = page.get_next_page()

# Or let it walk every page for you.
for payment in wajub.payments.list().auto_paging_iter():
    reconcile(payment)

from wajub import RequestOptions

wajub.payments.create(
    params,
    RequestOptions(idempotency_key=f"order-{order_id}"),
)

from wajub import RequestOptions

wajub.payments.create(
    {"amount": 25000, "currency": "XAF", "email": buyer.email},
    RequestOptions(sync=seller.wajub_account_id),
)

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

from .wajub_client import wajub

@csrf_exempt
def wajub_webhook(request):
    try:
        event = wajub.webhooks.construct_event(
            request.body,
            request.headers["X-Wajub-Signature"],
            request.headers["X-Wajub-Timestamp"],
        )
    except Exception:
        return HttpResponse(status=400)

    if event["event"] == "payment.succeeded":
        fulfil(event["data"])

    return HttpResponse(status=200)

from wajub import InvalidRequestError, RateLimitError, WajubError

try:
    wajub.payments.create(params)
except InvalidRequestError as error:
    # error.errors is {"amount": ["The amount must be at least 25."]}
    return JsonResponse({"fields": error.errors}, status=422)
except RateLimitError as error:
    return HttpResponse(status=503, headers={"Retry-After": str(error.retry_after or 5)})
except WajubError as error:
    logger.error("wajub failed", extra={"code": error.code, "status": error.http_status})
    raise

from typing import TypedDict

class Checkout(TypedDict):
    session_token: str
    pay_url: str

def start_checkout(order_id: str, amount: float, email: str) -> Checkout:
    payment = wajub.payments.create(
        {
            "amount": amount,
            "currency": "XAF",
            "email": email,
            "reference": order_id,
        },
        RequestOptions(idempotency_key=f"order-{order_id}"),
    )

    return {
        "session_token": payment.authorization_token,
        "pay_url": payment.authorization_url,
    }

payment = wajub.payments.create(
    {"amount": 25000, "currency": "XAF", "phone": "+237670000000"}
)

wajub.payments.process(
    payment.id,
    {"channel": "cm.mtn", "phone": "+237670000000"},
)

transfer = wajub.transfers.create(
    {
        "amount": 100000,
        "currency": "XAF",
        "beneficiary": {
            "name": "Amina Diallo",
            "channel": "cm.mtn",
            "phone": "+237670000000",
        },
        "reference": "payout-892",
    },
    RequestOptions(idempotency_key="payout-892"),
)

wajub listen --forward-to localhost:8000/webhooks/wajub
wajub trigger payment.succeeded