#!/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 { MonarchTools } from './tools.js';
class MonarchMCPServer {
private server: Server;
private tools: MonarchTools;
constructor() {
this.server = new Server(
{
name: 'monarch-mcp-server',
version: '1.0.0',
},
{
capabilities: {
tools: {},
},
}
);
this.tools = new MonarchTools();
this.setupHandlers();
}
private setupHandlers(): void {
this.server.setRequestHandler(ListToolsRequestSchema, async () => {
return {
tools: this.tools.getToolDefinitions(),
};
});
this.server.setRequestHandler(CallToolRequestSchema, async (request) => {
const { name, arguments: args } = request.params;
try {
const result = await this.tools.executeTool(name, args || {});
return {
content: [
{
type: 'text',
text: JSON.stringify(result, null, 2),
},
],
};
} catch (error) {
const errorMessage =
error instanceof Error ? error.message : 'Unknown error occurred';
return {
content: [
{
type: 'text',
text: `Error: ${errorMessage}`,
},
],
isError: true,
};
}
});
}
async run(): Promise<void> {
const transport = new StdioServerTransport();
await this.server.connect(transport);
console.error('Monarch Money MCP server running on stdio');
process.on('SIGINT', async () => {
console.error('Received SIGINT, shutting down gracefully...');
await this.server.close();
process.exit(0);
});
process.on('SIGTERM', async () => {
console.error('Received SIGTERM, shutting down gracefully...');
await this.server.close();
process.exit(0);
});
}
}
const server = new MonarchMCPServer();
server.run().catch((error) => {
console.error('Failed to start server:', error);
process.exit(1);
});
