MCP 통합 시스템

// services/mcp/InProcessTransport.ts
class InProcessTransport implements Transport {
  private peer: InProcessTransport | undefined

  async send(message: JSONRPCMessage): Promise<void> {
    // 동기 req/resp 사이클에서 스택 깊이가 커지는 것을 막기 위해 비동기로 전달
    queueMicrotask(() => { this.peer?.onmessage?.(message) })
  }
}

export function createLinkedTransportPair(): [Transport, Transport] {
  const a = new InProcessTransport()
  const b = new InProcessTransport()
  a._setPeer(b); b._setPeer(a)
  return [a, b]
}

// services/mcp/config.ts, 개념적인 병합 순서
const allConfigs = {
  ...enterpriseServers,      // 있으면 우선권 차지
  ...dynamicServers,         // --mcp-config 플래그
  ...claudeAiServers,        // URL 시그니처로 중복 제거
  ...projectServers,         // .mcp.json, 루트부터 아래로
  ...localServers,           // ~/.claude/projects/…
  ...userServers,            // ~/.claude/settings.json
  ...pluginServers,          // 이름공간 부여, 시그니처로 중복 제거
}

// 모든 설정에서 연결 전에 환경 변수를 확장
// 예: command: "npx", args: ["$MY_SERVER_PATH"]

// services/mcp/client.ts (단순화)
const connectPromise = client.connect(transport)
const timeoutPromise = new Promise<never>((_, reject) => {
  const id = setTimeout(() => {
    transport.close().catch(() => {})
    reject(new Error(`MCP server "${name}" timed out after ${timeout}ms`))
  }, getConnectionTimeoutMs())
  connectPromise.then(() => clearTimeout(id), () => clearTimeout(id))
})

await Promise.race([connectPromise, timeoutPromise])

// client.callTool()이 CallToolResult를 반환한 뒤...

// 1. 이미지 콘텐츠 항목, 크기 조정/다운샘플링 후 base64로 반환
if (content.type === 'image' && IMAGE_MIME_TYPES.has(mimeType)) {
  const buf = maybeResizeAndDownsampleImageBuffer(rawBuf)
  // → base64 데이터가 담긴 ContentBlockParam
}

// 2. 바이너리 blob, 디스크에 저장하고 경로를 텍스트로 반환
if (!IMAGE_MIME_TYPES.has(mimeType)) {
  await persistBinaryContent(content)
  // → getBinaryBlobSavedMessage(path)
}

// 3. 전체 결과가 100 KB 초과, 안내 문구와 함께 잘라냄
if (mcpContentNeedsTruncation(result)) {
  result = truncateMcpContentIfNeeded(result)
}

// services/mcp/auth.ts
const NONSTANDARD_INVALID_GRANT_ALIASES = new Set([
  'invalid_refresh_token',
  'expired_refresh_token',
  'token_expired',
])

// fetch를 감싼다. 2xx POST 응답을 들여다보고 오류 본문을 다시 쓴다
// OAuthErrorResponseSchema에는 맞지만 OAuthTokensSchema에는 맞지 않으면
// 가짜 400 응답으로 바꿔서 SDK의 오류 클래스 매핑이 적용되게 한다.

// services/mcp/elicitationHandler.ts
client.setRequestHandler(ElicitRequestSchema, async (request, extra) => {
  // 1. 먼저 hooks를 시도(프로그래밍 방식 응답)
  const hookResponse = await runElicitationHooks(serverName, request.params, extra.signal)
  if (hookResponse) return hookResponse

  // 2. 사용자 상호작용을 위해 큐에 넣기
  const response = new Promise<ElicitResult>(resolve => {
    setAppState(prev => ({
      ...prev,
      elicitation: {
        queue: [...prev.elicitation.queue, {
          serverName, requestId: extra.requestId,
          params: request.params,
          respond: resolve,
        }],
      },
    }))
  })
  return await response
})