Function createMcpPayloadQueue

src/mcp/server.ts:39–74

(
  options: {
    handlePayload?: PayloadHandler;
    write?: MessageWriter;
  } = {},
)

}

export function createMcpPayloadQueue(
  options: {
    handlePayload?: PayloadHandler;
    write?: MessageWriter;
  } = {},
): {
  push: (payload: unknown) => void;
  idle: () => Promise<void>;
} {
  const handlePayload = options.handlePayload ?? handleMcpPayload;
  const write = options.write ?? writeMessage;
  let pending = Promise.resolve();
  return {
    push: (payload) => {
      const fallbackId = fallbackErrorId(payload);
      pending = pending
        .then(async () => {
          const response = await handlePayload(payload);
          if (response) write(response);
        })
        .catch((error: unknown) => {
          write({
            jsonrpc: '2.0',
            id: fallbackId,
            error: {
              code: -32603,
              message: error instanceof Error ? error.message : String(error),
            },
          });
        });
    },
    idle: async () => {
      await pending;
    },
  };
}

export function handleMcpPayload(payload: unknown): Promise<unknown | null> {
  if (Array.isArray(payload)) {