try {
  const message = await orbit.request("POST", "/messages/wechat", body);
  console.log(message.data.id);
} catch (error) {
  if (error.code === "MESSAGE_SEND_FAILED") {
    // error.message carries the upstream WeChat detail, e.g.
    // "WeChat errcode 40001: access_token expired"
    const errcode = error.message.match(/WeChat errcode (\d+)/)?.[1];
    if (errcode === "40001") {
      // Access token expired — connect a fresh one under
      // Settings → Channels → WeChat, then retry once.
      throw new Error(`WeChat credential refresh needed: ${error.message}`);
    }
    if (errcode === "40003") {
      // Invalid openid — do NOT retry; the recipient is not a follower.
      console.error("Recipient is not a follower — skipping", body.to);
      return;
    }
    // Unexpected errcode — surface it, choose your own backoff.
    throw new Error(`WeChat errcode ${errcode}: ${error.message}`);
  }
  throw error;
}

try:
    message = client.request("POST", "/messages/wechat", json_body=body)
    print(message["data"]["id"])
except OrbitAPIError as error:
    if error.code == "MESSAGE_SEND_FAILED":
        # error.message carries the upstream WeChat detail, e.g.
        # "WeChat errcode 40001: access_token expired"
        errcode = re.search(r"WeChat errcode (\d+)", error.message)
        errcode = errcode.group(1) if errcode else None
        if errcode == "40001":
            # Access token expired — connect a fresh one under
            # Settings → Channels → WeChat, then retry once.
            raise RuntimeError(f"WeChat credential refresh needed: {error.message}")
        if errcode == "40003":
            # Invalid openid — do NOT retry; the recipient is not a follower.
            print("Recipient is not a follower — skipping", body["to"])
            return
        # Unexpected errcode — surface it, choose your own backoff.
        raise RuntimeError(f"WeChat errcode {errcode}: {error.message}")
    raise

import { createOrbitWebhookHandler } from "@devotel-orbit/node";

// The handler verifies the webhook signature before your code runs.
const onEvent = createOrbitWebhookHandler(process.env.ORBIT_WEBHOOK_SECRET, (event) => {
  if (event.type === "message.received" && event.data.channel === "wechat") {
    // Normalized inbound reply — openid under event.data.from, body under
    // event.data.body, and any metadata you sent echoed under event.data.metadata.
    routeReply(event.data.from, event.data.body, event.data.metadata);
  }

  if (event.type === "message.status" && event.data.channel === "wechat") {
    // TEMPLATESENDJOBFINISH callback — terminal state under event.data.status.
    reconcileStatus(event.data.id, event.data.status);
  }
});

from orbit_sdk import verify_webhook

@app.post("/webhooks/orbit")
def orbit_webhook(request):
    # verify_webhook raises on a bad signature before your code runs.
    event = verify_webhook(request.body, request.headers, ORBIT_WEBHOOK_SECRET)
    if event["type"] == "message.received" and event["data"]["channel"] == "wechat":
        # Normalized inbound reply — openid under event["data"]["from"],
        # body under event["data"]["body"], metadata echoed under
        # event["data"]["metadata"].
        route_reply(
            event["data"]["from"],
            event["data"]["body"],
            event["data"].get("metadata"),
        )
    return {"received": True}