Storage System Overview

import { WhatsAppClient } from 'whatsapp-client-sdk';

const client = new WhatsAppClient({
  accessToken: process.env.WHATSAPP_ACCESS_TOKEN!,
  phoneNumberId: process.env.WHATSAPP_PHONE_NUMBER_ID!,

  // Enable storage
  storage: {
    enabled: true,
    provider: 'supabase',
    options: {
      url: process.env.SUPABASE_URL!,
      apiKey: process.env.SUPABASE_KEY!
    },
    features: {
      persistIncoming: true,
      persistOutgoing: true,
      persistStatus: true,
      autoConversations: true
    }
  }
});

// Initialize storage
await client.initializeStorage();

// Incoming messages are saved automatically via webhooks
const webhookProcessor = client.createWebhookProcessor({
  onTextMessage: async (message) => {
    // Message is already saved to database
    await client.sendText(message.from, 'Got your message!');
    // Response is also saved automatically
  }
});

// Outgoing messages are saved when sent
await client.sendText('+1234567890', 'Hello!');
// Saved to database automatically

// Get conversation history
const conversation = await client.getConversation('+1234567890', {
  limit: 50
});

// Search messages
const results = await client.searchMessages({
  text: 'order',
  phoneNumber: '+1234567890'
});

// Get analytics
const analytics = await client.getConversationAnalytics('+1234567890');

storage: {
  enabled: true,
  provider: 'supabase',
  options: { /* ... */ },
  features: {
    persistIncoming: true,   // Save incoming messages
    persistOutgoing: true,   // Save outgoing messages
    persistStatus: true,     // Update message status (sent, delivered, read)
    autoConversations: true, // Auto-create conversations
    createThreads: true,     // Track message threads/replies
    enableSearch: true,      // Enable full-text search
    retentionDays: 90       // Auto-delete messages after 90 days
  }
}

// Configure automatic cleanup
features: {
  retentionDays: 90  // Delete messages older than 90 days
}

// Or manually trigger cleanup
const deletedCount = await client.cleanupOldMessages();
console.log(`Deleted ${deletedCount} old messages`);

// Get customer conversation history
const history = await client.getConversation(customerPhone);

// Analyze response patterns
const analytics = await client.getConversationAnalytics(customerPhone, {
  from: new Date('2024-01-01'),
  to: new Date()
});

console.log(`Average response time: ${analytics.averageResponseTime}ms`);
console.log(`Total conversations: ${analytics.totalMessages}`);

// Find all messages about a specific order
const orderMessages = await client.searchMessages({
  text: 'ORDER-12345',
  dateFrom: new Date('2024-01-01')
});

// Export for analysis
const exportData = await client.exportConversation(customerPhone, {
  format: 'json'
});

// Export conversation for audit trail
const auditLog = await client.exportConversation('+1234567890', {
  format: 'csv',
  dateFrom: new Date('2024-01-01'),
  dateTo: new Date('2024-12-31')
});

// Save to compliance system
await saveToComplianceSystem(auditLog);

// Good: Paginated queries
const page1 = await client.getConversation(phone, { limit: 50, offset: 0 });
const page2 = await client.getConversation(phone, { limit: 50, offset: 50 });

// Avoid: Loading all messages at once
const allMessages = await client.getConversation(phone, { limit: 10000 });

const cache = new Map();

async function getCachedConversation(phone: string) {
  if (cache.has(phone)) {
    return cache.get(phone);
  }

  const conversation = await client.getConversation(phone);
  cache.set(phone, conversation);

  // Cache for 5 minutes
  setTimeout(() => cache.delete(phone), 5 * 60 * 1000);

  return conversation;
}