Function runAgentDeviceMcpServer

src/mcp/server.ts:9–37

()

type MessageWriter = (message: unknown) => void;

export async function runAgentDeviceMcpServer(): Promise<void> {
  const payloadQueue = createMcpPayloadQueue();
  const decoder = new McpMessageDecoder((payload) => {
    payloadQueue.push(payload);
  });

  process.stdin.setEncoding('utf8');
  process.stdin.on('data', (chunk: string) => {
    try {
      decoder.push(chunk);
    } catch (error) {
      writeMessage({
        jsonrpc: '2.0',
        id: null,
        error: {
          code: -32700,
          message: error instanceof Error ? error.message : String(error),
        },
      });
    }
  });

  await new Promise<void>((resolve) => {
    process.stdin.on('end', resolve);
    process.stdin.on('close', resolve);
    process.stdin.resume();
  });
  await payloadQueue.idle();
}

export function createMcpPayloadQueue(
  options: {