How to read and send direct messages with an API

curl https://api.buzztake.com/v1/accounts/$ACCOUNT_ID/actions \
  -H "Authorization: Bearer $BUZZTAKE_API_KEY" \
  -H "Content-Type: application/json" \
  -H "Idempotency-Key: dm-1101-2026-10-30" \
  -d '{
    "type": "send_message",
    "to": "https://www.instagram.com/direct/t/1101.../",
    "text": "Yes: 50% off with a school email. Reply with yours and I will set it up.",
    "wait": 60
  }'

const api = "https://api.buzztake.com/v1";
const accountId = process.env.ACCOUNT_ID;
const headers = {
  Authorization: `Bearer ${process.env.BUZZTAKE_API_KEY}`,
  "Content-Type": "application/json",
};

async function run(body, idempotencyKey) {
  const res = await fetch(`${api}/accounts/${accountId}/actions`, {
    method: "POST",
    headers: idempotencyKey ? { ...headers, "Idempotency-Key": idempotencyKey } : headers,
    body: JSON.stringify({ ...body, wait: 90 }),
  });
  if (!res.ok) throw new Error(`${res.status}: ${await res.text()}`);
  const action = await res.json();
  if (action.status !== "succeeded") {
    throw new Error(`${body.type} ${action.status}: ${action.error?.message ?? ""}`);
  }
  return action.result;
}

// Your code or your model decides the answer. Return null to skip the conversation.
function draftReply(messages) {
  const question = messages.find((message) => !message.from_me && /discount/i.test(message.text ?? ""));
  return question ? "Yes: 50% off with a school email." : null;
}

const { items: conversations } = await run({ type: "list_conversations", limit: 20 });
for (const conversation of conversations.filter((item) => item.unread)) {
  const ref = conversation.url ?? conversation.id;
  const { items: messages } = await run({ type: "read_conversation", conversation: ref, limit: 20 });
  const text = draftReply(messages);
  if (!text) continue;
  const sent = await run({ type: "send_message", to: ref, text }, `dm-${conversation.id}-${conversation.updated_at}`);
  console.log(conversation.title, "->", sent.url ?? "sent");
}

import os
import re
import requests

api = "https://api.buzztake.com/v1"
account_id = os.environ["ACCOUNT_ID"]
headers = {"Authorization": f"Bearer {os.environ['BUZZTAKE_API_KEY']}"}


def run(body, idempotency_key=None):
    extra = {"Idempotency-Key": idempotency_key} if idempotency_key else {}
    resp = requests.post(
        f"{api}/accounts/{account_id}/actions",
        headers={**headers, **extra},
        json={**body, "wait": 90},
        timeout=100,
    )
    if not resp.ok:
        raise SystemExit(f"{resp.status_code}: {resp.text}")
    action = resp.json()
    if action["status"] != "succeeded":
        raise SystemExit(f"{body['type']} {action['status']}: {action.get('error')}")
    return action["result"]


def draft_reply(messages):
    """Your code or your model decides the answer. Return None to skip the conversation."""
    for message in messages:
        if not message["from_me"] and re.search("discount", message["text"] or "", re.I):
            return "Yes: 50% off with a school email."
    return None


conversations = run({"type": "list_conversations", "limit": 20})["items"]
for conversation in [c for c in conversations if c["unread"]]:
    ref = conversation["url"] or conversation["id"]
    messages = run({"type": "read_conversation", "conversation": ref, "limit": 20})["items"]
    text = draft_reply(messages)
    if not text:
        continue
    key = f"dm-{conversation['id']}-{conversation['updated_at']}"
    sent = run({"type": "send_message", "to": ref, "text": text}, key)
    print(conversation["title"], "->", sent["url"] or "sent")