Vapi MCP Server

mcp-server
examples
#!/usr/bin/env node

import { Client } from '@modelcontextprotocol/sdk/client/index.js';
import { SSEClientTransport } from '@modelcontextprotocol/sdk/client/sse.js';
import dotenv from 'dotenv';
import { parseToolResponse } from '../src/utils/response.js';

// Load environment variables from .env file
dotenv.config();

// Ensure API key is available
if (!process.env.VAPI_TOKEN) {
  console.error('Error: VAPI_TOKEN environment variable is required');
  process.exit(1);
}

async function main() {
  try {
    // Initialize MCP client
    const mcpClient = new Client({
      name: 'vapi-client-example',
      version: '1.0.0',
    });

    // Create SSE transport for connection to remote Vapi MCP server
    const serverUrl = 'https://mcp.vapi.ai/sse';
    const headers = {
      Authorization: `Bearer ${process.env.VAPI_TOKEN}`,
    };
    const options: Record<string, any> = {
      requestInit: { headers: headers },
      eventSourceInit: {
        fetch: (url: string, init?: RequestInit) => {
          return fetch(url, {
            ...(init || {}),
            headers: {
              ...(init?.headers || {}),
              ...headers,
            },
          });
        },
      },
    };
    const transport = new SSEClientTransport(new URL(serverUrl), options);

    console.log('Connecting to Vapi MCP server via SSE...');
    await mcpClient.connect(transport);
    console.log('Connected successfully');

    try {
      // List available tools
      const toolsResult = await mcpClient.listTools();
      console.log('Available tools:');
      toolsResult.tools.forEach((tool) => {
        console.log(`- ${tool.name}: ${tool.description}`);
      });

      // List assistants
      console.log('\nListing assistants...');
      const assistantsResponse = await mcpClient.callTool({
        name: 'list_assistants',
        arguments: {},
      });

      const assistants = parseToolResponse(assistantsResponse);

      if (!(Array.isArray(assistants) && assistants.length > 0)) {
        console.log(
          'No assistants found. Please create an assistant in the Vapi dashboard first.'
        );
        return;
      }

      console.log('Your assistants:');
      assistants.forEach((assistant: any) => {
        console.log(`- ${assistant.name} (${assistant.id})`);
      });

      // List phone numbers
      console.log('\nListing phone numbers...');
      const phoneNumbersResponse = await mcpClient.callTool({
        name: 'list_phone_numbers',
        arguments: {},
      });

      const phoneNumbers = parseToolResponse(phoneNumbersResponse);

      if (!(Array.isArray(phoneNumbers) && phoneNumbers.length > 0)) {
        console.log(
          'No phone numbers found. Please add a phone number in the Vapi dashboard first.'
        );
        return;
      }

      console.log('Your phone numbers:');
      phoneNumbers.forEach((phoneNumber: any) => {
        console.log(`- ${phoneNumber.phoneNumber} (${phoneNumber.id})`);
      });

      // Create a call using the first assistant and first phone number
      const phoneNumberId = phoneNumbers[0].id;
      const assistantId = assistants[0].id;

      console.log(
        `\nCreating a call using assistant (${assistantId}) and phone number (${phoneNumberId})...`
      );
      const createCallResponse = await mcpClient.callTool({
        name: 'create_call',
        arguments: {
          assistantId: assistantId,
          phoneNumberId: phoneNumberId,
          customer: {
            phoneNumber: '+1234567890', // Replace with actual customer phone number
          },
          // Optional: schedule a call for the future
          // scheduledAt: "2025-04-15T15:30:00Z"
        },
      });

      const createdCall = parseToolResponse(createCallResponse);
      console.log('Call created:', JSON.stringify(createdCall, null, 2));

      // List calls
      console.log('\nListing calls...');
      const callsResponse = await mcpClient.callTool({
        name: 'list_calls',
        arguments: {},
      });

      const calls = parseToolResponse(callsResponse);

      if (Array.isArray(calls) && calls.length > 0) {
        console.log('Your calls:');
        calls.forEach((call: any) => {
          const createdAt = call.createdAt ? new Date(call.createdAt).toLocaleString() : 'N/A';
          const customerPhone = call.customer?.phoneNumber || 'N/A';
          const endedReason = call.endedReason || 'N/A';
          
          console.log(`- ID: ${call.id} | Status: ${call.status} | Created: ${createdAt} | Customer: ${customerPhone} | Ended reason: ${endedReason}`);
        });
      } else {
        console.log('No calls found. Try creating a call first.');
      }

    } finally {
      console.log('\nDisconnecting from server...');
      await mcpClient.close();
      console.log('Disconnected');
    }
  } catch (error) {
    console.error('Error:', error);
    process.exit(1);
  }
}

main();