List inbound messages

# Poll once a minute: everything received since your last message (inclusive — de-duplicate on id)
curl -G https://api.wemail.io/v3/inbound/messages \
  -H "Authorization: Bearer afn_live_…" \
  --data-urlencode "since=2026-11-03T08:00:00Z" \
  --data-urlencode "domain=leads.example.com" \
  --data-urlencode "limit=100"

# Next page: pass next_cursor back as cursor while has_more is true
curl -G https://api.wemail.io/v3/inbound/messages \
  -H "Authorization: Bearer afn_live_…" \
  --data-urlencode "cursor=2026-11-03T08:14:21.417Z|6f1c2a1e-7d3b-4b7e-9f0e-2a4c8d9b1e55"

// Walk every page since the last message you processed (ascending, keyset cursor).
let cursor = null;
const since = "2026-11-03T08:00:00Z";
do {
  const qs = new URLSearchParams({ since, limit: "100", ...(cursor ? { cursor } : {}) });
  const res = await fetch("https://api.wemail.io/v3/inbound/messages?" + qs, {
    headers: { Authorization: `Bearer ${process.env.WEMAIL_API_KEY}` },
  });
  const page = await res.json();
  for (const m of page.items) console.log(m.id, m.from, m.subject, m.headers["in-reply-to"]);
  cursor = page.has_more ? page.next_cursor : null;
} while (cursor);

import os, requests

cursor = None
while True:
    params = {"since": "2026-11-03T08:00:00Z", "limit": 100}
    if cursor:
        params["cursor"] = cursor
    r = requests.get(
        "https://api.wemail.io/v3/inbound/messages",
        headers={"Authorization": f"Bearer {os.environ['WEMAIL_API_KEY']}"},
        params=params,
    )
    page = r.json()
    for m in page["items"]:
        print(m["id"], m["from"], m["subject"], m["headers"].get("in-reply-to"))
    if not page["has_more"]:
        break
    cursor = page["next_cursor"]

client, _ := wemail.NewClient(os.Getenv("WEMAIL_API_KEY"))
// Generated layer (client.API.*): pass the key in the context.
ctx := context.WithValue(context.Background(), wemail.ContextAccessToken, os.Getenv("WEMAIL_API_KEY"))
since, _ := time.Parse(time.RFC3339, "2026-11-03T08:00:00Z")
page, _, err := client.API.InboundAPI.ListInboundMessages(ctx).
    Since(since).Domain("leads.example.com").Limit(100).Execute()
for _, m := range page.Items {
    fmt.Println(m.Id, m.From, m.Subject)
}
// next page: .Cursor(page.GetNextCursor()) while page.HasMore

{
  "items": [
    {
      "id": "6f1c2a1e-7d3b-4b7e-9f0e-2a4c8d9b1e55",
      "domain": "leads.example.com",
      "route_id": "0b7e4c2d-9a1f-4e6b-8c3d-5f2a1b9e7d40",
      "message_id": "CAF3k9Qx7Z@mail.gmail.com",
      "from": "Maria Papadopoulou <maria@efood.gr>",
      "to": "kostas@leads.example.com",
      "envelope_to": ["kostas@leads.example.com"],
      "cc": [],
      "subject": "Re: Quick question about your ESP",
      "text": "Hi Kostas, yes — let's talk next week.\n\n> On Mon, Kostas wrote: …",
      "html": "<div dir=\"ltr\">Hi Kostas, yes — let's talk next week.</div>",
      "text_truncated": false,
      "html_truncated": false,
      "headers": {
        "message-id": "<CAF3k9Qx7Z@mail.gmail.com>",
        "in-reply-to": "<msg_01HBYE7K9Z4PMQDR3W@leads.example.com>",
        "references": "<msg_01HBYE7K9Z4PMQDR3W@leads.example.com>",
        "date": "Mon, 3 Nov 2026 10:14:19 +0200",
        "from": "Maria Papadopoulou <maria@efood.gr>",
        "to": "kostas@leads.example.com",
        "subject": "Re: Quick question about your ESP",
        "auto-submitted": "no"
      },
      "attachments": [
        { "filename": "brief.pdf", "content_type": "application/pdf", "size": 48211, "url": null }
      ],
      "auth": { "spf": "pass", "dkim": "pass", "dmarc": "pass" },
      "size_bytes": 71904,
      "received_at": "2026-11-03T08:14:21.417Z",
      "created_at": "2026-11-03T08:14:21.603Z"
    }
  ],
  "has_more": false,
  "next_cursor": null,
  "total_count": 1
}