onesound71/enhanced-mcp-server

// 예: 급여 정보는 HR 부서만 접근 가능
if (requestType === 'salary' && !user.hasRole('HR')) {
  throw new Error('권한이 없습니다');
}

// 실시간 시스템 모니터링
async getRealtimeSystemStatus() {
  return {
    cpu: getCurrentCPUUsage(),
    memory: getCurrentMemoryUsage(),
    timestamp: new Date().toISOString()
  };
}

// enhanced-server.js의 핵심 부분
class EnhancedMcpServer {
  constructor() {
    // 🗄️ 회사 데이터베이스 (AI가 모르는 정보!)
    this.companyDatabase = {
      employees: [
        { id: 'EMP001', name: '김개발', department: 'Engineering', salary: 8500 },
        // ... 더 많은 직원 정보
      ]
    };
    
    // 🔧 MCP 서버 생성
    this.server = new Server({
      name: 'enhanced-mcp-server',
      version: '2.0.0'
    });
  }
}

// AI가 사용할 수 있는 도구들을 정의
{
  name: 'query_employee_database',
  description: '🏢 회사 직원 데이터베이스에서 정보를 조회합니다',
  inputSchema: {
    type: 'object',
    properties: {
      query_type: { type: 'string', enum: ['all', 'by_department', 'by_name'] },
      filter: { type: 'string', description: '필터 값' }
    }
  }
}

// AI가 도구를 호출하면 실행되는 함수
async queryEmployeeDatabase(queryType, filter) {
  const employees = this.companyDatabase.employees;
  
  switch (queryType) {
    case 'by_name':
      return employees.filter(emp => emp.name.includes(filter));
    case 'by_department':
      return employees.filter(emp => emp.department === filter);
    default:
      return employees;
  }
}

{
  "name": "enhanced-mcp-server",
  "version": "2.0.0",
  "type": "module",                    // ← ES6 모듈 사용
  "dependencies": {
    "@modelcontextprotocol/sdk": "^0.4.0"  // ← MCP 공식 SDK
  }
}

{
  "mcpServers": {
    "enhanced-mcp-server": {
      "command": "node",
      "args": ["enhanced-server.js"],
      "cwd": "/Users/sangsoonhwang/Documents/GitHub/enhanced-mcp-server"
    }
  }
}

class EnhancedMcpServer {
  constructor() {
    this.companyDatabase = { /* 데이터 */ };  // 📊 데이터 저장소
    this.server = new Server(/* 설정 */);     // 🔧 MCP 서버
    this.setupToolHandlers();                 // 🛠️ 도구 설정
  }
}

setupToolHandlers() {
  // 📋 사용 가능한 도구 목록 제공
  this.server.setRequestHandler(ListToolsRequestSchema, async () => {
    return {
      tools: [
        {
          name: 'query_employee_database',
          description: '직원 정보 조회',
          inputSchema: { /* 입력 형식 정의 */ }
        }
        // ... 더 많은 도구들
      ]
    };
  });

  // 🔧 도구 실행 처리
  this.server.setRequestHandler(CallToolRequestSchema, async (request) => {
    const { name, arguments: args } = request.params;
    
    switch (name) {
      case 'query_employee_database':
        return await this.queryEmployeeDatabase(args.query_type, args.filter);
      // ... 다른 도구들
    }
  });
}

async queryEmployeeDatabase(queryType, filter) {
  console.log(`🔍 직원 조회: ${queryType}, 필터: ${filter}`);
  
  const employees = this.companyDatabase.employees;
  let result;

  switch (queryType) {
    case 'by_name':
      result = employees.filter(emp => emp.name.includes(filter));
      break;
    case 'by_department':
      result = employees.filter(emp => emp.department === filter);
      break;
    case 'all':
    default:
      result = employees;
  }

  return {
    content: [{
      type: 'text',
      text: `📊 조회 결과: ${JSON.stringify(result, null, 2)}`
    }]
  };
}

npm install

npm test

npm start

{
  "nodes": [
    {
      "name": "MCP Server Call",
      "type": "n8n-nodes-base.httpRequest",
      "parameters": {
        "url": "http://localhost:3000/mcp",
        "method": "POST",
        "body": {
          "tool": "query_employee_database",
          "args": {
            "query_type": "by_department",
            "filter": "Engineering"
          }
        }
      }
    }
  ]
}

// Make.com HTTP 모듈 설정
{
  "url": "http://localhost:3000/mcp",
  "method": "POST",
  "headers": {
    "Content-Type": "application/json"
  },
  "body": {
    "tool": "get_project_status",
    "args": {
      "project_name": "MCP-Integration"
    }
  }
}

# curl을 사용한 직접 호출
curl -X POST http://localhost:3000/mcp \
  -H "Content-Type: application/json" \
  -d '{
    "tool": "query_employee_database",
    "args": {
      "query_type": "by_name",
      "filter": "김개발"
    }
  }'

import requests

def get_employee_info(name):
    response = requests.post('http://localhost:3000/mcp', json={
        'tool': 'query_employee_database',
        'args': {
            'query_type': 'by_name',
            'filter': name
        }
    })
    return response.json()

# 사용 예
employee = get_employee_info('김개발')
print(f"직원 정보: {employee}")

// setupToolHandlers() 메서드의 tools 배열에 추가
{
  name: 'calculate_bonus',
  description: '직원 보너스 계산',
  inputSchema: {
    type: 'object',
    properties: {
      employee_id: { type: 'string', description: '직원 ID' },
      performance_score: { type: 'number', description: '성과 점수 (1-10)' }
    },
    required: ['employee_id', 'performance_score']
  }
}

// CallToolRequestSchema 핸들러의 switch문에 추가
case 'calculate_bonus':
  return await this.calculateBonus(args.employee_id, args.performance_score);

async calculateBonus(employeeId, performanceScore) {
  const employee = this.companyDatabase.employees.find(emp => emp.id === employeeId);
  
  if (!employee) {
    throw new McpError(ErrorCode.InvalidRequest, `직원 ${employeeId}를 찾을 수 없습니다`);
  }

  const baseBonus = employee.salary * 0.1; // 기본 보너스 10%
  const performanceMultiplier = performanceScore / 10;
  const finalBonus = baseBonus * performanceMultiplier;

  return {
    content: [{
      type: 'text',
      text: `💰 ${employee.name}님의 보너스: ${finalBonus.toLocaleString()}만원 (성과점수: ${performanceScore}/10)`
    }]
  };
}