Twitter DM API for message history & CRM sync

curl -G https://xquik.com/api/v1/x/dm/44196397/history \
  --data-urlencode "account=your_handle" \
  -H "x-api-key: xq_YOUR_KEY_HERE" | jq

# Page 2
curl -G https://xquik.com/api/v1/x/dm/44196397/history \
  --data-urlencode "account=your_handle" \
  --data-urlencode "cursor=abc123" \
  -H "x-api-key: xq_YOUR_KEY_HERE" | jq

const userId = "44196397";
const account = "your_handle";

function historyUrl(userId, account, cursor) {
  const params = new URLSearchParams({ account });
  if (cursor) params.set("cursor", cursor);
  return `https://xquik.com/api/v1/x/dm/${userId}/history?${params}`;
}

function toDmHistoryRows(page, { account, userId }) {
  return page.messages.map((message) => ({
    record_type: "dm_history",
    conversation_user_id: userId,
    sender_account: account,
    message_id: message.id,
    sender_id: message.senderId,
    receiver_id: message.receiverId,
    message_text: message.text ?? null,
    created_at: message.createdAt ?? null,
    media_url: message.mediaUrl ?? null,
    page_next_cursor: page.has_next_page ? page.next_cursor : null,
    source_endpoint: `/api/v1/x/dm/${userId}/history`,
  }));
}

async function savePrivateDmHistoryRows(rows) {
  // Replace this with a private CRM, warehouse, or agent memory write.
  return rows.length;
}

const response = await fetch(historyUrl(userId, account), {
  headers: { "x-api-key": "xq_YOUR_KEY_HERE" },
});
const data = await response.json();
const historyRows = toDmHistoryRows(data, { account, userId });
await savePrivateDmHistoryRows(historyRows);

// Paginate
if (data.has_next_page) {
  const next = await fetch(historyUrl(userId, account, data.next_cursor), {
    headers: { "x-api-key": "xq_YOUR_KEY_HERE" },
  });
  const nextData = await next.json();
  const nextRows = toDmHistoryRows(nextData, { account, userId });
  await savePrivateDmHistoryRows(nextRows);
}

import requests

def to_dm_history_rows(page, account, user_id):
    return [
        {
            "record_type": "dm_history",
            "conversation_user_id": user_id,
            "sender_account": account,
            "message_id": message["id"],
            "sender_id": message["senderId"],
            "receiver_id": message["receiverId"],
            "message_text": message.get("text"),
            "created_at": message.get("createdAt"),
            "media_url": message.get("mediaUrl"),
            "page_next_cursor": page["next_cursor"] if page["has_next_page"] else None,
            "source_endpoint": f"/api/v1/x/dm/{user_id}/history",
        }
        for message in page["messages"]
    ]

def save_private_dm_history_rows(rows):
    # Replace this with a private CRM, warehouse, or agent memory write.
    return len(rows)

response = requests.get(
    "https://xquik.com/api/v1/x/dm/44196397/history",
    params={"account": "your_handle"},
    headers={"x-api-key": "xq_YOUR_KEY_HERE"},
)
data = response.json()
history_rows = to_dm_history_rows(data, "your_handle", "44196397")
save_private_dm_history_rows(history_rows)

# Paginate
while data["has_next_page"]:
    data = requests.get(
        "https://xquik.com/api/v1/x/dm/44196397/history",
        params={"account": "your_handle", "cursor": data["next_cursor"]},
        headers={"x-api-key": "xq_YOUR_KEY_HERE"},
    ).json()
    next_rows = to_dm_history_rows(data, "your_handle", "44196397")
    save_private_dm_history_rows(next_rows)