index.ts•4.88 kB
import { Server } from "@modelcontextprotocol/sdk/server/index.js";
import { StdioServerTransport } from "@modelcontextprotocol/sdk/server/stdio.js";
import {
CallToolRequestSchema,
ListToolsRequestSchema,
} from "@modelcontextprotocol/sdk/types.js";
import { IntercomClient } from "./api/client.js";
import { SearchConversationsSchema, listConversationsFromLastWeek } from "./tools/conversations.js";
import { z } from "zod";
const server = new Server(
{
name: "intercom",
version: "1.0.0",
},
{
capabilities: {
tools: {
"search-conversations": {
description:
"Search Intercom conversations with filters for created_at, updated_at, source type, state, open, and read status",
inputSchema: SearchConversationsSchema,
outputSchema: z.any(),
},
"list-conversations-from-last-week": {
description: "Fetch all conversations from the last week (last 7 days)",
inputSchema: z.object({}),
outputSchema: z.any(),
},
},
},
}
);
// List available tools
server.setRequestHandler(ListToolsRequestSchema, async () => {
return {
tools: [
{
name: "search-conversations",
description:
"Search Intercom conversations with filters for created_at, updated_at, source type, state, open, and read status",
inputSchema: {
type: "object",
properties: {
createdAt: {
type: "object",
properties: {
operator: {
type: "string",
description: 'Operator for created_at (e.g., ">", "<", "=")',
},
value: {
type: "integer",
description: "Timestamp value for created_at filter",
},
},
},
updatedAt: {
type: "object",
properties: {
operator: {
type: "string",
description: 'Operator for updated_at (e.g., ">", "<", "=")',
},
value: {
type: "integer",
description: "Timestamp value for updated_at filter",
},
},
},
sourceType: {
type: "string",
description:
'Source type of the conversation (e.g., "email", "chat")',
},
state: {
type: "string",
description:
'Conversation state to filter by (e.g., "open", "closed")',
},
open: {
type: "boolean",
description: "Filter by open status",
},
read: {
type: "boolean",
description: "Filter by read status",
},
},
},
},
{
name: "list-conversations-from-last-week",
description: "Fetch all conversations from the last week (last 7 days)",
inputSchema: {
type: "object",
properties: {},
},
},
],
};
});
// Handle tool execution
server.setRequestHandler(CallToolRequestSchema, async (request) => {
const { name, arguments: args } = request.params;
if (name === "search-conversations") {
try {
const validatedArgs = SearchConversationsSchema.parse(args);
const intercomClient = new IntercomClient();
const conversations = await intercomClient.searchConversations(
validatedArgs
);
return {
content: [
{
type: "text",
text: JSON.stringify(conversations, null, 2),
},
],
};
} catch (error) {
if (error instanceof Error) {
return {
content: [
{
type: "text",
text: `Error: ${error.message}`,
},
],
};
}
throw error;
}
}
if (name === "list-conversations-from-last-week") {
try {
const conversations = await listConversationsFromLastWeek();
return {
content: [
{
type: "text",
text: JSON.stringify(conversations, null, 2),
},
],
};
} catch (error) {
if (error instanceof Error) {
return {
content: [
{
type: "text",
text: `Error: ${error.message}`,
},
],
};
}
throw error;
}
}
throw new Error(`Unknown tool: ${name}`);
});
// Start the server
async function main() {
const transport = new StdioServerTransport();
await server.connect(transport);
console.error("Intercom MCP Server running on stdio");
}
main().catch((error) => {
console.error("Fatal error:", error);
process.exit(1);
});