FlowIQ Getting Started

// Retrieve conversation messages
const response = await fetch(
  'https://api.flowiq.live/conversations?tenantId=YOUR_TENANT_ID&whatsappNumber=27123456789&limit=10',
  {
    headers: {
      'Authorization': 'Bearer YOUR_BEARER_TOKEN'
    }
  }
);

const data = await response.json();
console.log('Messages:', data.messages);
console.log('Total:', data.pagination.totalMessages);

class FlowIQClient {
  constructor(bearerToken, tenantId) {
    this.baseUrl = 'https://api.flowiq.live';
    this.token = bearerToken;
    this.tenantId = tenantId;
  }

  // Get conversation messages
  async getConversations(whatsappNumber, options = {}) {
    const { limit = 10, page = 1, search = '' } = options;
    const params = new URLSearchParams({
      tenantId: this.tenantId,
      whatsappNumber,
      limit,
      page,
      ...(search && { search })
    });

    const response = await fetch(
      `${this.baseUrl}/conversations?${params}`,
      {
        headers: {
          'Authorization': `Bearer ${this.token}`
        }
      }
    );

    if (!response.ok) {
      throw new Error(`API Error: ${response.status}`);
    }

    return await response.json();
  }

  // List all contacts
  async listContacts(options = {}) {
    const { limit = 20, page = 1, search = '' } = options;
    const params = new URLSearchParams({
      action: 'contacts',
      tenantId: this.tenantId,
      limit,
      page,
      ...(search && { search })
    });

    const response = await fetch(
      `${this.baseUrl}/conversations?${params}`,
      {
        headers: {
          'Authorization': `Bearer ${this.token}`
        }
      }
    );

    return await response.json();
  }

  // Find contact by phone
  async findContactByPhone(phoneNumber) {
    const params = new URLSearchParams({
      action: 'find-by-phone',
      tenantId: this.tenantId,
      phoneNumber
    });

    const response = await fetch(
      `${this.baseUrl}/conversations?${params}`,
      {
        headers: {
          'Authorization': `Bearer ${this.token}`
        }
      }
    );

    return await response.json();
  }

  // Fetch all messages (handles pagination)
  async getAllMessages(whatsappNumber) {
    let allMessages = [];
    let currentPage = 1;
    let hasMore = true;

    while (hasMore) {
      const data = await this.getConversations(whatsappNumber, {
        limit: 50,
        page: currentPage
      });

      allMessages = allMessages.concat(data.messages);
      hasMore = data.pagination.hasNextPage;
      currentPage++;
    }

    return allMessages;
  }
}

// Usage Example
const client = new FlowIQClient(
  'YOUR_BEARER_TOKEN',
  'YOUR_TENANT_ID'
);

// Get recent messages
const conversations = await client.getConversations('27123456789', {
  limit: 20,
  page: 1
});
console.log('Recent messages:', conversations.messages);

// Search contacts
const contacts = await client.listContacts({ search: 'John' });
console.log('Found contacts:', contacts.contacts);

// Lookup specific contact
const contact = await client.findContactByPhone('27123456789');
console.log('Contact details:', contact.contact);

// Get all messages (with automatic pagination)
const allMessages = await client.getAllMessages('27123456789');
console.log('Total messages retrieved:', allMessages.length);