Gateways e o token de contato

from niadra import Niadra
from niadra.coordination.token import ContactTokenError
from niadra.models.coordination import ContactMade, ContactMadeDetail

niadra = Niadra()  # a source key of the gateway; pip install 'niadra[gateway]'
gateway = niadra.contact_gateway("wa_gateway", space=SPACE_ID, key=GATEWAY_SHARED_KEY)


def dispatch(message):
    try:
        claims = gateway.verify(message.token, channel="whatsapp", destination=f"phone:{message.to}")
    except ContactTokenError as refused:
        log.warning("refused %s", refused.code)  # never the destination
        return
    provider.send(message)
    niadra.api.declare(
        ContactMade(kind="contact.made", agent="wa_gateway", detail=ContactMadeDetail(jti=claims.jti, purpose=claims.purpose, channel="whatsapp", gateway_id="wa_gateway")),
        idempotency_key=str(claims.jti),
    )

import { Niadra, NiadraContactTokenError } from "@niadra/sdk";

const niadra = new Niadra(); // a source key of the gateway
const gateway = niadra.contactGateway("wa_gateway", { space: SPACE_ID, key: GATEWAY_SHARED_KEY });

async function dispatch(message: Outbound) {
  let claims;
  try {
    claims = await gateway.verify(message.token, { channel: "whatsapp", destination: `phone:${message.to}` });
  } catch (refused) {
    if (refused instanceof NiadraContactTokenError) log.warn("refused", refused.code); // never the destination
    return;
  }
  await provider.send(message);
  await niadra.api.declare({ kind: "contact.made", agent: "wa_gateway", detail: { jti: claims.jti, purpose: claims.purpose, channel: "whatsapp", gateway_id: "wa_gateway", unchecked: false } }, { idempotency_key: claims.jti });
}