#!/usr/bin/env node
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 { OutlookManager, EmailMessage, EmailDraft } from './outlook-manager.js';
const server = new Server(
{
name: 'outlook-mcp-server',
version: '1.0.0',
},
{
capabilities: {
tools: {},
},
}
);
const outlookManager = new OutlookManager();
// List available tools
server.setRequestHandler(ListToolsRequestSchema, async () => {
return {
tools: [
{
name: "get_inbox_emails",
description: "Get inbox email list",
inputSchema: {
type: "object",
properties: {
count: {
type: "number",
description: "Number of emails to retrieve",
default: 10
}
}
}
},
{
name: "get_email_by_id",
description: "Get specific email by ID",
inputSchema: {
type: "object",
properties: {
id: {
type: "string",
description: "Email ID"
}
},
required: ["id"]
}
},
{
name: "summarize_email",
description: "Summarize individual email content",
inputSchema: {
type: "object",
properties: {
email_id: {
type: "string",
description: "Email ID to summarize"
}
},
required: ["email_id"]
}
},
{
name: "summarize_inbox",
description: "Summarize inbox emails",
inputSchema: {
type: "object",
properties: {
count: {
type: "number",
description: "Number of emails to summarize",
default: 10
}
}
}
},
{
name: "create_draft",
description: "Create new email draft",
inputSchema: {
type: "object",
properties: {
to: {
type: "array",
items: { type: "string" },
description: "Recipient email addresses"
},
subject: {
type: "string",
description: "Email subject"
},
body: {
type: "string",
description: "Email content"
},
cc: {
type: "array",
items: { type: "string" },
description: "CC email addresses"
},
bcc: {
type: "array",
items: { type: "string" },
description: "BCC email addresses"
}
},
required: ["to", "subject", "body"]
}
},
{
name: "mark_email_as_read",
description: "Mark email as read",
inputSchema: {
type: "object",
properties: {
email_id: {
type: "string",
description: "Email ID"
}
},
required: ["email_id"]
}
},
{
name: "search_inbox_emails",
description: "Search inbox emails",
inputSchema: {
type: "object",
properties: {
query: {
type: "string",
description: "Search keywords"
},
count: {
type: "number",
description: "Number of results to return",
default: 10
}
},
required: ["query"]
}
},
{
name: "search_sent_emails",
description: "Search sent emails",
inputSchema: {
type: "object",
properties: {
query: {
type: "string",
description: "Search keywords"
},
count: {
type: "number",
description: "Number of results to return",
default: 10
}
},
required: ["query"]
}
},
{
name: "get_sent_emails",
description: "Get sent emails list",
inputSchema: {
type: "object",
properties: {
count: {
type: "number",
description: "Number of sent emails to retrieve",
default: 10
}
}
}
},
{
name: "get_draft_emails",
description: "Get draft emails list",
inputSchema: {
type: "object",
properties: {
count: {
type: "number",
description: "Number of draft emails to retrieve",
default: 10
}
}
}
},
{
name: "search_draft_emails",
description: "Search draft emails",
inputSchema: {
type: "object",
properties: {
query: {
type: "string",
description: "Search keywords"
},
count: {
type: "number",
description: "Number of results to return",
default: 10
}
},
required: ["query"]
}
},
{
name: "duplicate_email_as_draft",
description: "Duplicate existing email as draft (preserving complete format)",
inputSchema: {
type: "object",
properties: {
source_email_id: {
type: "string",
description: "Original email ID to duplicate"
},
store_id: {
type: "string",
description: "Store ID for the original email (optional but recommended)"
},
new_subject: {
type: "string",
description: "New email subject (optional)"
},
new_recipients: {
type: "array",
items: { type: "string" },
description: "New recipient list (optional)"
}
},
required: ["source_email_id"]
}
}
]
};
});
// Handle tool calls
server.setRequestHandler(CallToolRequestSchema, async (request) => {
const { name, arguments: args } = request.params;
try {
switch (name) {
case 'get_inbox_emails': {
const count = (args as any)?.count || 10;
const emails = await outlookManager.getInboxEmails(count);
return {
content: [
{
type: 'text',
text: `📊 **Email Overview**\nTotal: ${emails.length} emails\nUnread: ${emails.filter(e => !e.isRead).length} emails\n\n📋 **Email List:**\n` +
emails.map((email, index) =>
`${index + 1}. ${email.isRead ? '✅' : '📩'} **${email.subject}**\n From: ${email.sender}\n Time: ${email.receivedTime}\n Preview: ${email.body?.substring(0, 100)}...\n`
).join('\n')
},
],
};
}
case 'get_email_by_id': {
const id = (args as any)?.id;
if (!id) {
throw new Error('Email ID is required');
}
const email = await outlookManager.getEmailById(id);
return {
content: [
{
type: 'text',
text: JSON.stringify(email, null, 2),
},
],
};
}
case 'summarize_email': {
const emailId = (args as any)?.email_id;
if (!emailId) {
throw new Error('Email ID is required');
}
const email = await outlookManager.getEmailById(emailId);
return {
content: [
{
type: 'text',
text: `📧 **Email Details**\n\n**Subject:** ${email.subject}\n**From:** ${email.sender}\n**To:** ${email.recipients?.join(', ')}\n**Time:** ${email.receivedTime}\n**Read:** ${email.isRead ? 'Yes' : 'No'}\n\n**Content Summary:**\n${email.body?.substring(0, 500)}${email.body && email.body.length > 500 ? '...' : ''}`,
},
],
};
}
case 'summarize_inbox': {
const count = (args as any)?.count || 10;
const emails = await outlookManager.getInboxEmails(count);
const unreadCount = emails.filter(e => !e.isRead).length;
return {
content: [
{
type: 'text',
text: `📊 **Inbox Summary**\nTotal: ${emails.length} emails\nUnread: ${unreadCount} emails\n\n📋 **Recent Emails:**\n` +
emails.slice(0, 5).map((email, index) =>
`${index + 1}. ${email.isRead ? '✅' : '📩'} **${email.subject}**\n From: ${email.sender}\n Time: ${email.receivedTime}\n`
).join('\n')
},
],
};
}
case 'create_draft': {
const draft: EmailDraft = {
to: (args as any)?.to || [],
subject: (args as any)?.subject || '',
body: (args as any)?.body || '',
cc: (args as any)?.cc,
bcc: (args as any)?.bcc,
};
const result = await outlookManager.createDraft(draft);
return {
content: [
{
type: 'text',
text: `✅ **Email Draft Created Successfully**\n\n**Subject:** ${draft.subject}\n**To:** ${draft.to.join(', ')}\n${draft.cc ? `**CC:** ${draft.cc.join(', ')}\n` : ''}**Result:** ${result}`,
},
],
};
}
case 'mark_email_as_read': {
const emailId = (args as any)?.email_id;
if (!emailId) {
throw new Error('Email ID is required');
}
await outlookManager.markAsRead(emailId);
return {
content: [
{
type: 'text',
text: `✅ **Email marked as read**\nEmail ID: ${emailId}`,
},
],
};
}
case 'search_inbox_emails': {
const query = (args as any)?.query;
const count = (args as any)?.count || 10;
if (!query) {
throw new Error('Search query is required');
}
const emails = await outlookManager.searchInboxEmails(query, count);
return {
content: [
{
type: 'text',
text: `🔍 **Search Results: "${query}"**\nTotal: ${emails.length} items\nUnread: ${emails.filter(e => !e.isRead).length} items\n\n📋 **Search Results List:**\n` +
emails.map((email, index) =>
`${index + 1}. ${email.isRead ? '✅' : '📩'} **${email.subject}**\n From: ${email.sender}\n Time: ${email.receivedTime}\n EntryID: ${email.id}\n StoreID: ${email.storeId || 'N/A'}\n Search Context: ${email.body?.includes(query) ? 'Match in content' : 'Match in subject'}: ${email.subject}\n Preview: ${email.body?.substring(0, 100)}...\n`
).join('\n')
},
],
};
}
case 'search_sent_emails': {
const query = (args as any)?.query;
const count = (args as any)?.count || 10;
if (!query) {
throw new Error('Search query is required');
}
const emails = await outlookManager.searchSentEmails(query, count);
return {
content: [
{
type: 'text',
text: `🔍 **Search Results: "${query}"**\nTotal: ${emails.length} items\nUnread: ${emails.filter(e => !e.isRead).length} items\n\n📋 **Search Results List:**\n` +
emails.map((email, index) =>
`${index + 1}. ${email.isRead ? '✅' : '📩'} **${email.subject}**\n From: ${email.sender}\n Time: ${email.receivedTime}\n EntryID: ${email.id}\n StoreID: ${email.storeId || 'N/A'}\n Search Context: ${email.body?.includes(query) ? 'Match in content' : 'Match in subject'}: ${email.subject}\n Preview: ${email.body?.substring(0, 100)}...\n`
).join('\n')
},
],
};
}
case 'get_sent_emails': {
const count = (args as any)?.count || 10;
const emails = await outlookManager.getSentEmails(count);
return {
content: [
{
type: 'text',
text: `📊 **Email Overview**\nTotal: ${emails.length} emails\nUnread: ${emails.filter(e => !e.isRead).length} emails\n\n📋 **Email List:**\n` +
emails.map((email, index) =>
`${index + 1}. ${email.isRead ? '✅' : '📩'} **${email.subject}**\n From: ${email.sender}\n Time: ${email.receivedTime}\n EntryID: ${email.id}\n StoreID: ${email.storeId || 'N/A'}\n Preview: ${email.body?.substring(0, 100)}...\n`
).join('\n')
},
],
};
}
case 'get_draft_emails': {
const count = (args as any)?.count || 10;
const drafts = await outlookManager.getDraftEmails(count);
return {
content: [
{
type: 'text',
text: `📂 **Draft Email Overview**\nTotal: ${drafts.length} drafts\n\n📝 **Draft Email List:**\n` +
drafts.map((draft, index) =>
`${index + 1}. **${draft.subject}**\n From: ${draft.sender}\n Time: ${draft.receivedTime}\n EntryID: ${draft.id}\n StoreID: ${draft.storeId || 'N/A'}\n Preview: ${draft.body?.substring(0, 100)}...\n`
).join('\n')
},
],
};
}
case 'search_draft_emails': {
const query = (args as any)?.query;
const count = (args as any)?.count || 10;
if (!query) {
throw new Error('Search query is required');
}
const drafts = await outlookManager.searchDraftEmails(query, count);
return {
content: [
{
type: 'text',
text: `🔍 **Draft Search Results: "${query}"**\nTotal: ${drafts.length} items\n\n📋 **Draft Search Results List:**\n` +
drafts.map((draft, index) =>
`${index + 1}. **${draft.subject}**\n From: ${draft.sender}\n Time: ${draft.receivedTime}\n EntryID: ${draft.id}\n StoreID: ${draft.storeId || 'N/A'}\n Search Context: ${draft.body?.includes(query) ? 'Match in content' : 'Match in subject'}: ${draft.subject}\n Preview: ${draft.body?.substring(0, 100)}...\n`
).join('\n')
},
],
};
}
case 'duplicate_email_as_draft': {
const sourceEmailId = (args as any)?.source_email_id;
const newSubject = (args as any)?.new_subject;
const newRecipients = (args as any)?.new_recipients;
const storeId = (args as any)?.store_id;
if (!sourceEmailId) {
throw new Error('Source email ID is required');
}
const result = await outlookManager.duplicateEmailAsDraft(
sourceEmailId,
newSubject,
newRecipients,
storeId
);
return {
content: [
{
type: 'text',
text: `✅ **Email duplicated successfully**\n\n**Result:** ${result}${newSubject ? `\n**New Subject:** ${newSubject}` : ''}${newRecipients ? `\n**New Recipients:** ${newRecipients.join(', ')}` : ''}`,
},
],
};
}
default:
throw new Error(`Unknown tool: ${name}`);
}
} catch (error) {
return {
content: [
{
type: 'text',
text: `❌ **Error:** ${error instanceof Error ? error.message : String(error)}`,
},
],
isError: true,
};
}
});
async function runServer() {
const transport = new StdioServerTransport();
await server.connect(transport);
console.error('Outlook MCP Server running on stdio');
}
runServer().catch(console.error);
