Retrieve messages by AI contact with pagination

x-api-key: your_api_key_here

curl --request GET \
  'https://api.vambe.me/api/public/contact/v2/df980fc8-b6db-4820-bf22-2969482d106d/messages?page=1' \
  --header 'x-api-key: your_api_key_here'

curl --request GET \
  'https://api.vambe.me/api/public/contact/v2/df980fc8-b6db-4820-bf22-2969482d106d/messages?page=2' \
  --header 'x-api-key: your_api_key_here'

{
  "messages": [
    {
      "id": "msg-001",
      "body": "Hola! Necesito ayuda con mi pedido",
      "created_at": "2024-09-30T10:00:00.000Z",
      "direction": "INBOUND",
      "from": "+56912345678",
      "to": "+56987654321",
      "type": "text",
      "status": "delivered",
      "media_url": null,
      "client_id": "550e8400-e29b-41d4-a716-446655440000",
      "ai_contact_id": "df980fc8-b6db-4820-bf22-2969482d106d"
    },
    {
      "id": "msg-002",
      "body": "Por supuesto! ¿Cuál es tu número de pedido?",
      "created_at": "2024-09-30T10:01:30.000Z",
      "direction": "OUTBOUND",
      "from": "+56987654321",
      "to": "+56912345678",
      "type": "text",
      "status": "read",
      "media_url": null,
      "client_id": "550e8400-e29b-41d4-a716-446655440000",
      "ai_contact_id": "df980fc8-b6db-4820-bf22-2969482d106d"
    }
  ],
  "page": 1,
  "hasMore": true,
  "total": 127
}

const getAllMessages = async (contactId) => {
  let allMessages = [];
  let page = 1;
  let hasMore = true;

  while (hasMore) {
    const response = await fetch(
      `https://api.vambe.me/api/public/contact/v2/${contactId}/messages?page=${page}`,
      {
        headers: {
          'x-api-key': 'your_api_key_here',
        },
      },
    );

    const data = await response.json();
    allMessages = allMessages.concat(data.messages);
    hasMore = data.hasMore;
    page++;

    console.log(
      `Fetched page ${page - 1}, total messages: ${allMessages.length}`,
    );
  }

  console.log(`Retrieved all ${allMessages.length} messages`);
  return allMessages;
};

const exportMessagesToCSV = async (contactId) => {
  const allMessages = await getAllMessages(contactId);

  const csvRows = [
    'Timestamp,Direction,From,To,Message,Type,Status',
    ...allMessages.map((msg) => {
      const timestamp = new Date(msg.created_at).toISOString();
      const message = msg.body.replace(/"/g, '""'); // Escape quotes
      return `"${timestamp}","${msg.direction}","${msg.from}","${msg.to}","${message}","${msg.type}","${msg.status}"`;
    }),
  ];

  const csvContent = csvRows.join('\n');
  console.log('CSV export ready');

  return csvContent;
};

const calculateResponseMetrics = async (contactId) => {
  const allMessages = await getAllMessages(contactId);

  const responseTimes = [];

  for (let i = 0; i < allMessages.length - 1; i++) {
    const current = allMessages[i];
    const next = allMessages[i + 1];

    // If customer message followed by agent message
    if (current.direction === 'INBOUND' && next.direction === 'OUTBOUND') {
      const responseTime =
        new Date(next.created_at) - new Date(current.created_at);
      responseTimes.push(responseTime);
    }
  }

  const averageResponseTime =
    responseTimes.reduce((sum, time) => sum + time, 0) / responseTimes.length;

  const metrics = {
    totalMessages: allMessages.length,
    inboundMessages: allMessages.filter((m) => m.direction === 'INBOUND')
      .length,
    outboundMessages: allMessages.filter((m) => m.direction === 'OUTBOUND')
      .length,
    averageResponseTimeMinutes: (averageResponseTime / 1000 / 60).toFixed(2),
    fastestResponseMinutes: (Math.min(...responseTimes) / 1000 / 60).toFixed(2),
    slowestResponseMinutes: (Math.max(...responseTimes) / 1000 / 60).toFixed(2),
  };

  console.log('Response Metrics:', metrics);
  return metrics;
};

const findMessagesContaining = async (contactId, searchTerm) => {
  const allMessages = await getAllMessages(contactId);

  const matches = allMessages.filter((msg) =>
    msg.body.toLowerCase().includes(searchTerm.toLowerCase()),
  );

  console.log(`Found ${matches.length} messages containing "${searchTerm}"`);

  return matches;
};

// Usage
const orderMentions = await findMessagesContaining('contact-id', 'order');
const urgentMessages = await findMessagesContaining('contact-id', 'urgent');

const getLatestMessages = async (contactId, limit = 20) => {
  const response = await fetch(
    `https://api.vambe.me/api/public/contact/v2/${contactId}/messages?page=1`,
    {
      headers: {
        'x-api-key': 'your_api_key_here',
      },
    },
  );

  const data = await response.json();
  const latestMessages = data.messages.slice(0, limit);

  console.log(`Retrieved ${latestMessages.length} latest messages`);
  return latestMessages;
};

// Helper function to fetch all pages
const fetchAllPages = async (contactId) => {
  let currentPage = 1;
  let allMessages = [];
  let hasMore = true;

  while (hasMore) {
    const response = await fetch(
      `https://api.vambe.me/api/public/contact/v2/${contactId}/messages?page=${currentPage}`,
      {
        headers: { 'x-api-key': 'your_api_key_here' },
      },
    );

    const data = await response.json();

    if (data.messages.length === 0) {
      hasMore = false;
    } else {
      allMessages.push(...data.messages);
      currentPage++;
    }
  }

  return allMessages;
};

const getMessagesPage = async (contactId, page) => {
  const response = await fetch(
    `https://api.vambe.me/api/public/contact/v2/${contactId}/messages?page=${page}`,
    {
      headers: { 'x-api-key': 'your_api_key_here' },
    },
  );

  const data = await response.json();

  if (data.messages.length === 0) {
    console.log('No more messages');
    return null;
  }

  return data;
};

const fetchWithDelay = async (contactId, maxPages) => {
  const allMessages = [];

  for (let page = 1; page <= maxPages; page++) {
    const data = await getMessagesPage(contactId, page);

    if (!data || data.messages.length === 0) break;

    allMessages.push(...data.messages);

    // Add delay to avoid rate limiting
    await new Promise((resolve) => setTimeout(resolve, 100));
  }

  return allMessages;
};

const messageCache = new Map();

const getCachedMessagesPage = async (contactId, page) => {
  const cacheKey = `${contactId}-${page}`;

  if (messageCache.has(cacheKey)) {
    return messageCache.get(cacheKey);
  }

  const response = await fetch(
    `https://api.vambe.me/api/public/contact/v2/${contactId}/messages?page=${page}`,
    {
      headers: { 'x-api-key': 'your_api_key_here' },
    },
  );

  const data = await response.json();
  messageCache.set(cacheKey, data);

  return data;
};