Give an agent an inbox

curl https://api.machinemail.dev/v0/inboxes \
  -H "Authorization: Bearer $MACHINEMAIL_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{"username": "support-agent", "display_name": "Support agent", "client_id": "support-agent-v1"}'

const res = await fetch('https://api.machinemail.dev/v0/inboxes', {
  method: 'POST',
  headers: {
    Authorization: `Bearer ${process.env.MACHINEMAIL_API_KEY}`,
    'Content-Type': 'application/json',
  },
  body: JSON.stringify({ username: 'support-agent', display_name: 'Support agent', client_id: 'support-agent-v1' }),
});
const inbox = await res.json();
console.log(inbox.inbox_id); // support-agent@machinemail.dev

import os, requests

res = requests.post(
    "https://api.machinemail.dev/v0/inboxes",
    headers={"Authorization": f"Bearer {os.environ['MACHINEMAIL_API_KEY']}"},
    json={"username": "support-agent", "display_name": "Support agent", "client_id": "support-agent-v1"},
)
inbox = res.json()
print(inbox["inbox_id"])  # support-agent@machinemail.dev

const API = 'https://api.machinemail.dev/v0';
const INBOX = 'support-agent@machinemail.dev';
const headers = { Authorization: `Bearer ${process.env.MACHINEMAIL_API_KEY}`, 'Content-Type': 'application/json' };

async function api(path: string, init: RequestInit = {}) {
  const res = await fetch(`${API}${path}`, { ...init, headers });
  if (!res.ok) throw new Error(`${res.status} ${await res.text()}`);
  return res.json();
}

// Replace with your model call. It only ever sees agent-safe text.
async function decide(text: string, level: string): Promise<string | null> {
  if (level === 'suspicious' || level === 'quarantined') return null;
  return `Thanks, we got your message: "${text.slice(0, 80)}"`;
}

async function tick() {
  const page = await api(`/inboxes/${INBOX}/messages?labels=UNREAD&ascending=true&limit=20`);
  for (const item of page.messages) {
    if (item.direction !== 'inbound') continue;
    const msg = await api(`/inboxes/${INBOX}/messages/${item.message_id}`);
    const trust = msg.trust;
    const text = trust?.content?.text ?? msg.extracted_text ?? '';
    const answer = await decide(text, trust?.level ?? 'unknown');
    if (answer) {
      await api(`/inboxes/${INBOX}/messages/${msg.message_id}/reply`, { method: 'POST', body: JSON.stringify({ text: answer }) });
    } else {
      console.warn('Escalating', msg.message_id, trust?.reasons);
    }
    await api(`/inboxes/${INBOX}/messages/${msg.message_id}`, {
      method: 'PATCH',
      body: JSON.stringify({ remove_labels: ['UNREAD'], add_labels: [answer ? 'handled' : 'needs-human'] }),
    });
  }
}

for (;;) {
  await tick().catch((err) => console.error(err));
  await new Promise((r) => setTimeout(r, 5000));
}

import os, time, requests

API = "https://api.machinemail.dev/v0"
INBOX = "support-agent@machinemail.dev"
session = requests.Session()
session.headers["Authorization"] = f"Bearer {os.environ['MACHINEMAIL_API_KEY']}"


def api(method, path, **kwargs):
    res = session.request(method, f"{API}{path}", **kwargs)
    res.raise_for_status()
    return res.json()


def decide(text, level):
    # Replace with your model call. It only ever sees agent-safe text.
    if level in ("suspicious", "quarantined"):
        return None
    return f'Thanks, we got your message: "{text[:80]}"'


def tick():
    page = api("GET", f"/inboxes/{INBOX}/messages", params={"labels": "UNREAD", "ascending": "true", "limit": 20})
    for item in page["messages"]:
        if item["direction"] != "inbound":
            continue
        msg = api("GET", f"/inboxes/{INBOX}/messages/{item['message_id']}")
        trust = msg.get("trust") or {}
        text = (trust.get("content") or {}).get("text") or msg.get("extracted_text") or ""
        answer = decide(text, trust.get("level", "unknown"))
        if answer:
            api("POST", f"/inboxes/{INBOX}/messages/{msg['message_id']}/reply", json={"text": answer})
        else:
            print("Escalating", msg["message_id"], trust.get("reasons"))
        api(
            "PATCH",
            f"/inboxes/{INBOX}/messages/{msg['message_id']}",
            json={"remove_labels": ["UNREAD"], "add_labels": ["handled" if answer else "needs-human"]},
        )


while True:
    try:
        tick()
    except Exception as err:
        print(err)
    time.sleep(5)