Vapi MCP Server

1
#!/usr/bin/env node
2
import { Client } from '@modelcontextprotocol/sdk/client/index.js';
3
import { SSEClientTransport } from '@modelcontextprotocol/sdk/client/sse.js';
4
import dotenv from 'dotenv';
5
6
// Load environment variables from .env file
7
dotenv.config();
8
9
// Ensure API key is available
10
if (!process.env.VAPI_TOKEN) {
11
  console.error('Error: VAPI_TOKEN environment variable is required');
12
  process.exit(1);
13
}
14
15
async function main() {
16
  try {
17
    // Initialize MCP client
18
    const mcpClient = new Client({
19
      name: 'vapi-client-example',
20
      version: '1.0.0',
21
    });
22
    
23
    // Create SSE transport for connection to remote Vapi MCP server
24
    const serverUrl = 'https://mcp.vapi.ai/sse';
25
    const headers = {
26
      Authorization: `Bearer ${process.env.VAPI_TOKEN}`,
27
    };
28
    const options = {
29
      requestInit: { headers: headers },
30
      eventSourceInit: {
31
        fetch: (url, init) => {
32
          return fetch(url, {
33
            ...(init || {}),
34
            headers: {
35
              ...(init?.headers || {}),
36
              ...headers,
37
            },
38
          });
39
        },
40
      },
41
    };
42
    const transport = new SSEClientTransport(new URL(serverUrl), options);
43
    
44
    console.log('Connecting to Vapi MCP server via SSE...');
45
    await mcpClient.connect(transport);
46
    console.log('Connected successfully');
47
48
    // Helper function to parse tool responses
49
    function parseToolResponse(response) {
50
      if (!response?.content) return response;
51
      const textItem = response.content.find(item => item.type === 'text');
52
      if (textItem?.text) {
53
        try {
54
          return JSON.parse(textItem.text);
55
        } catch {
56
          return textItem.text;
57
        }
58
      }
59
      return response;
60
    }
61
    
62
    try {
63
      // List available tools
64
      const toolsResult = await mcpClient.listTools();
65
      console.log('Available tools:');
66
      toolsResult.tools.forEach((tool) => {
67
        console.log(`- ${tool.name}: ${tool.description}`);
68
      });
69
      
70
      // List assistants
71
      console.log('\nListing assistants...');
72
      const assistantsResponse = await mcpClient.callTool({
73
        name: 'list_assistants',
74
        arguments: {},
75
      });
76
      
77
      const assistants = parseToolResponse(assistantsResponse);
78
      if (!(Array.isArray(assistants) && assistants.length > 0)) {
79
        console.log('No assistants found. Please create an assistant in the Vapi dashboard first.');
80
        return;
81
      }
82
      
83
      console.log('Your assistants:');
84
      assistants.forEach((assistant) => {
85
        console.log(`- ${assistant.name} (${assistant.id})`);
86
      });
87
      
88
      // List phone numbers
89
      console.log('\nListing phone numbers...');
90
      const phoneNumbersResponse = await mcpClient.callTool({
91
        name: 'list_phone_numbers',
92
        arguments: {},
93
      });
94
      
95
      const phoneNumbers = parseToolResponse(phoneNumbersResponse);
96
      if (!(Array.isArray(phoneNumbers) && phoneNumbers.length > 0)) {
97
        console.log('No phone numbers found. Please add a phone number in the Vapi dashboard first.');
98
        return;
99
      }
100
      
101
      console.log('Your phone numbers:');
102
      phoneNumbers.forEach((phoneNumber) => {
103
        console.log(`- ${phoneNumber.phoneNumber} (${phoneNumber.id})`);
104
      });
105
      
106
      // Create a call using the first assistant and first phone number
107
      const phoneNumberId = phoneNumbers[0].id;
108
      const assistantId = assistants[0].id;
109
      
110
      console.log(`\nCreating a call using assistant (${assistantId}) and phone number (${phoneNumberId})...`);
111
      const createCallResponse = await mcpClient.callTool({
112
        name: 'create_call',
113
        arguments: {
114
          assistantId: assistantId,
115
          phoneNumberId: phoneNumberId,
116
          customer: {
117
            phoneNumber: "+1234567890"  // Replace with actual customer phone number
118
          }
119
          // Optional: schedule a call for the future
120
          // scheduledAt: "2025-04-15T15:30:00Z"
121
        },
122
      });
123
      
124
      const createdCall = parseToolResponse(createCallResponse);
125
      console.log('Call created:', JSON.stringify(createdCall, null, 2));
126
    } finally {
127
      console.log('\nDisconnecting from server...');
128
      await mcpClient.close();
129
      console.log('Disconnected');
130
    }
131
  } catch (error) {
132
    console.error('Error:', error);
133
    process.exit(1);
134
  }
135
}
136
137
main();