WhatsApp Plugin

npm install @astreus-ai/astreus @astreus-ai/whatsapp-plugin

# WhatsApp Cloud API configuration
WHATSAPP_API_VERSION=v17.0
WHATSAPP_API_TOKEN=your_api_access_token_here
WHATSAPP_PHONE_NUMBER_ID=your_phone_number_id_here
WHATSAPP_BUSINESS_ACCOUNT_ID=your_business_account_id_here

# Cache configuration (in seconds)
CACHE_MESSAGE_SECONDS=300
CACHE_CONTACT_SECONDS=3600

# Default response timeout in milliseconds
DEFAULT_REQUEST_TIMEOUT=30000

# Logging options
LOG_LEVEL=info  # Options: error, warn, info, debug

import { createAgent, createMemory, createProvider, createDatabase, PluginManager } from '@astreus-ai/astreus';
import WhatsAppPlugin from '@astreus-ai/whatsapp-plugin';

async function main() {
  // Initialize Astreus components
  const db = await createDatabase();
  const memory = await createMemory({ database: db, tableName: 'memories' });
  const provider = createProvider({ type: 'openai', model: 'gpt-4o-mini' });
  
  // Initialize WhatsApp Plugin
  const whatsAppPlugin = new WhatsAppPlugin();
  await whatsAppPlugin.init();
  
  // Create a plugin manager and add the WhatsApp plugin
  const pluginManager = new PluginManager({
    name: 'messaging-plugins',
    tools: whatsAppPlugin.getTools()
  });
  
  // Create an agent
  const agent = await createAgent({
    name: 'WhatsApp Agent',
    description: 'An assistant that can interact with WhatsApp',
    provider: provider,
    memory: memory,
    database: db,
    plugins: [pluginManager],
    systemPrompt: `You are a helpful assistant that can interact with WhatsApp.
Help the user send messages, media, and manage WhatsApp communications.`
  });
  
  // Your agent is now ready to interact with WhatsApp
  const response = await agent.chat('Send a WhatsApp message to +1234567890 saying "Hello, how are you?"');
  console.log(response);
}

main();

import WhatsAppPlugin from '@astreus-ai/whatsapp-plugin';

// Create a plugin with custom configuration
const whatsAppPlugin = new WhatsAppPlugin({
  apiVersion: 'v17.0',
  apiToken: 'your_api_token',
  phoneNumberId: 'your_phone_number_id',
  businessAccountId: 'your_business_account_id',
  cacheMessageSeconds: 600,
  logLevel: 'debug'  // Set logging verbosity
});

// Initialize the plugin
await whatsAppPlugin.init();

const response = await agent.execute('whatsapp_send_message', {
  to: '+1234567890',
  message: 'Hello! This is a message from Astreus WhatsApp Plugin.'
});

console.log(`Message sent with ID: ${response.messageId}`);

const response = await agent.execute('whatsapp_send_template', {
  to: '+1234567890',
  templateName: 'welcome_message',
  templateLanguage: 'en',
  templateParameters: [
    { type: 'text', text: 'John Doe' },
    { type: 'text', text: 'Welcome to our service!' }
  ]
});

console.log(`Template message sent with ID: ${response.messageId}`);

const response = await agent.execute('whatsapp_send_media', {
  to: '+1234567890',
  mediaType: 'image',
  mediaUrl: 'https://example.com/image.jpg',
  caption: 'Check out this image!'
});

console.log(`Media message sent with ID: ${response.messageId}`);

// Button message
const response = await agent.execute('whatsapp_send_interactive', {
  to: '+1234567890',
  interactiveType: 'button',
  bodyText: 'Please choose an option:',
  buttons: [
    { id: 'option1', title: 'Option 1' },
    { id: 'option2', title: 'Option 2' },
    { id: 'option3', title: 'Option 3' }
  ]
});

// List message
const listResponse = await agent.execute('whatsapp_send_interactive', {
  to: '+1234567890',
  interactiveType: 'list',
  bodyText: 'Please select from the menu:',
  buttonText: 'View Menu',
  sections: [
    {
      title: 'Main Dishes',
      rows: [
        { id: 'dish1', title: 'Pasta', description: 'Delicious pasta dish' },
        { id: 'dish2', title: 'Pizza', description: 'Fresh pizza' }
      ]
    }
  ]
});

const response = await agent.execute('whatsapp_send_location', {
  to: '+1234567890',
  latitude: 37.7749,
  longitude: -122.4194,
  name: 'San Francisco',
  address: 'San Francisco, CA, USA'
});

console.log(`Location message sent with ID: ${response.messageId}`);

const response = await agent.execute('whatsapp_mark_as_read', {
  messageId: 'message_id_to_mark_as_read'
});

console.log('Message marked as read');

const response = await agent.execute('whatsapp_get_contact_info', {
  phoneNumber: '+1234567890'
});

console.log('Contact info:', response.contact);

// Get business profile
const profile = await agent.execute('whatsapp_get_business_profile');
console.log('Business profile:', profile);

// Update business profile
const updateResponse = await agent.execute('whatsapp_update_business_profile', {
  about: 'We are a customer service company powered by AI',
  description: '24/7 AI-powered customer support',
  email: 'support@example.com',
  websites: ['https://example.com']
});

try {
  const response = await agent.execute('whatsapp_send_message', {
    to: '+1234567890',
    message: 'Hello World!'
  });
  console.log(`Message sent with ID: ${response.messageId}`);
} catch (error) {
  console.error('Failed to send WhatsApp message:', error.message);
}

import { createAgent, createMemory, createProvider, createDatabase } from '@astreus-ai/astreus';
import WhatsAppPlugin from '@astreus-ai/whatsapp-plugin';

async function createSupportBot() {
  const db = await createDatabase();
  const memory = await createMemory({ database: db, tableName: 'memories' });
  const provider = createProvider({ type: 'openai', model: 'gpt-4o-mini' });
  
  const whatsAppPlugin = new WhatsAppPlugin();
  await whatsAppPlugin.init();
  
  const agent = await createAgent({
    name: 'WhatsApp Support Bot',
    description: 'Provides customer support via WhatsApp',
    provider: provider,
    memory: memory,
    database: db,
    systemPrompt: `You are a helpful customer support assistant on WhatsApp.
    Help customers with their questions and provide quick, friendly responses.
    If you can't help with something, offer to connect them with a human agent.`
  });
  
  // Add plugin tools to agent
  whatsAppPlugin.getTools().forEach(tool => agent.addTool(tool));
  
  return agent;
}

// Handle incoming messages
async function handleIncomingMessage(phoneNumber: string, message: string) {
  const agent = await createSupportBot();
  
  try {
    // Process the message and generate a response
    const response = await agent.chat(`Customer ${phoneNumber} says: "${message}". Please respond appropriately.`);
    
    // Send the response back via WhatsApp
    await agent.execute('whatsapp_send_message', {
      to: phoneNumber,
      message: response
    });
    
    console.log(`Responded to ${phoneNumber}: ${response}`);
  } catch (error) {
    console.error('Error handling message:', error.message);
    
    // Send error message to customer
    await agent.execute('whatsapp_send_message', {
      to: phoneNumber,
      message: 'Sorry, I encountered an error. Please try again or contact our support team.'
    });
  }
}

async function sendBroadcast(contacts: string[], message: string) {
  const agent = await createSupportBot();
  
  const promises = contacts.map(async (phoneNumber) => {
    try {
      const response = await agent.execute('whatsapp_send_message', {
        to: phoneNumber,
        message: message
      });
      return { phoneNumber, success: true, messageId: response.messageId };
    } catch (error) {
      return { phoneNumber, success: false, error: error.message };
    }
  });
  
  const results = await Promise.all(promises);
  return results;
}

// Usage
const contacts = ['+1234567890', '+0987654321', '+1122334455'];
const message = 'Hello! This is a broadcast message from our service.';
const results = await sendBroadcast(contacts, message);
console.log('Broadcast results:', results);

async function sendMainMenu(phoneNumber: string) {
  const agent = await createSupportBot();
  
  await agent.execute('whatsapp_send_interactive', {
    to: phoneNumber,
    interactiveType: 'button',
    bodyText: 'Welcome! How can I help you today?',
    buttons: [
      { id: 'support', title: '🛠️ Support' },
      { id: 'info', title: 'ℹ️ Information' },
      { id: 'contact', title: '📞 Contact Us' }
    ]
  });
}

async function handleMenuSelection(phoneNumber: string, selection: string) {
  const agent = await createSupportBot();
  
  switch (selection) {
    case 'support':
      await agent.execute('whatsapp_send_message', {
        to: phoneNumber,
        message: 'Please describe your issue and I\'ll help you resolve it.'
      });
      break;
    case 'info':
      await sendInfoMenu(phoneNumber);
      break;
    case 'contact':
      await agent.execute('whatsapp_send_message', {
        to: phoneNumber,
        message: 'You can reach us at:\n📧 support@example.com\n📞 +1-800-123-4567\n🌐 https://example.com'
      });
      break;
  }
}