/**
* ZenTao MCP 服务器主入口
*/
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 { loadConfig } from './config';
import { ZenTaoClient } from './client';
import { LRUCache } from './utils/cache';
import { Logger, LogLevel } from './utils/logger';
import { createTools, handleToolCall } from './tools';
async function main() {
// 初始化日志
const logger = new Logger(LogLevel.INFO);
logger.info('启动 ZenTao MCP 服务器...');
try {
// 加载配置
const config = loadConfig();
logger.info(`配置加载完成: ${config.baseUrl}`);
// 创建禅道客户端
const client = new ZenTaoClient(config, logger);
logger.info('禅道 API 客户端已创建');
// 验证连接
const isConnected = await client.verifyConnection();
if (!isConnected) {
logger.error('无法连接到禅道服务器，请检查配置');
process.exit(1);
}
logger.info('连接验证成功');
// 获取版本信息
const version = await client.getVersion();
logger.info(`禅道版本: ${version}`);
// 创建缓存
const cache = new LRUCache<string, any>({
maxSize: 1000,
defaultTtl: 5 * 60 * 1000, // 5 分钟
enableStats: true,
});
logger.info('LRU 缓存已初始化');
// 创建 MCP 服务器
const server = new Server(
{
name: 'zendao-mcp-server',
version: '1.0.0',
},
{
capabilities: {
tools: {},
},
}
);
// 注册工具列表
server.setRequestHandler(ListToolsRequestSchema, async () => {
return {
tools: createTools(),
};
});
// 注册工具调用处理
server.setRequestHandler(CallToolRequestSchema, async (request) => {
const { name, arguments: args } = request.params;
logger.info(`工具调用: ${name}`, args);
try {
const result = await handleToolCall(name, args, client, cache);
logger.info(`工具执行成功: ${name}`);
return result;
} catch (error: any) {
logger.error(`工具执行失败: ${name}`, error);
return {
content: [
{
type: 'text',
text: `执行失败: ${error.message || '未知错误'}`,
},
],
isError: true,
};
}
});
// 使用标准输入输出传输
const transport = new StdioServerTransport();
// 连接服务器
await server.connect(transport);
logger.info('MCP 服务器已启动，等待连接...');
} catch (error: any) {
logger.error('服务器启动失败', error);
process.exit(1);
}
}
// 启动服务器
main().catch((error) => {
console.error('Fatal error:', error);
process.exit(1);
});
