MCP 服务器

MCP Agent TypeScript Port

MCP Agent 框架的 TypeScript 实现，提供构建具有高级工作流管理、日志记录和执行能力的情境感知代理的工具。

AI集成系统

访问服务器

README

MCP Agent TypeScript 端口

概述

MCP (模型上下文协议) Agent TypeScript 端口是 MCP Agent 系统的健壮且类型安全的实现。它提供了一个灵活的框架，用于构建具有高级工作流管理、日志记录和执行功能的智能上下文感知代理。

这是 lastmile-ai 的原始 MCP Agent 框架的 TypeScript 端口。

特性

🚀 模块化架构
- 完整的 TypeScript 实现
- 灵活、可扩展的设计
- 类型安全的接口
📊 高级工作流管理
- 基于步骤的工作流执行
- 并发任务处理
- 详细的上下文跟踪
🔍 强大的日志系统
- 可配置的日志级别
- 上下文丰富的日志记录
- 日志导出功能
🧰 灵活的执行器
- 任务队列
- 超时处理
- 并发任务管理
🖥️ CLI 支持
- 命令行界面
- 轻松的代理管理

安装

npm install @waldzell/mcp-agent-ts

快速开始

创建一个工作流

import { BaseWorkflow } from '@waldzell/mcp-agent-ts';

class MyDataProcessingWorkflow extends BaseWorkflow {
  constructor() {
    super('my-workflow', 'Data Processing');

    this.addStep({
      id: 'extract',
      name: 'Data Extraction',
      execute: async (context) => {
        // Implement data extraction logic
        return { data: ['item1', 'item2'] };
      }
    });

    this.addStep({
      id: 'transform',
      name: 'Data Transformation',
      execute: async (context) => {
        // Implement data transformation logic
        return { transformedData: ['ITEM1', 'ITEM2'] };
      }
    });
  }
}

async function runWorkflow() {
  const workflow = new MyDataProcessingWorkflow();
  const results = await workflow.execute();
  console.log(results);
}

日志记录

import { debug, info, warn, error } from '@waldzell/mcp-agent-ts';

// Log with different levels
debug('Debugging information', { userId: 123 });
info('System started');
warn('Potential issue detected');
error('Critical error occurred');

CLI 用法

# 启动 MCP Agent
npx mcp-agent start

# 列出可用工具
npx mcp-agent list-tools

# 设置日志级别
npx mcp-agent log-level debug

执行器用法

import { BaseExecutor, Task } from '@waldzell/mcp-agent-ts';

const executor = new BaseExecutor({ 
  maxConcurrentTasks: 3,
  timeout: 60000 // 1-minute timeout
});

const task: Task = {
  id: 'example-task',
  name: 'Sample Task',
  execute: async () => {
    // Task implementation
    return 'Task completed';
  }
};

await executor.enqueueTask(task);