memory stream client transport

A custom MCP client transport - an alternative for connecting to local MCP servers without subprocesses, simplifying shared memory usage.

Usage

client code

import { MemoryStreamClientTransport } from 'memory-stream-client-transport'
import {createMcpServer} from './server'

const client = new Client({
    name: "example-client",
    version: "1.0.0"
}, {
    capabilities: {}
});

const customTransport = new MemoryStreamClientTransport()

createMcpServer(customTransport)

await client.connect(customTransport);

console.log('connected')

const tools = await client.listTools()
console.log('tools', tools)
const result = await client.callTool({
    name: tools.tools[0].name, 
    arguments: {}
})
console.log('result', result)

server code

import { McpServer } from "@modelcontextprotocol/sdk/server/mcp.js";
import { StdioServerTransport } from "@modelcontextprotocol/sdk/server/stdio.js";

export default async function createMcpServer(clientTransport){
    const server = new McpServer({
        name: "example-server",
        version: "1.0.0"
    }, {
        capabilities: {}
    });


    server.tool('get_current_time', 'get current time', {}, async () => {
        console.log('get_current_time called', Date.now())
        return {
        content: [
            {
            type: 'text',
            text: new Date().toString()
            }
        ]
        }
    })

    const transport = new StdioServerTransport(clientTransport.process.stdin, clientTransport.process.stdout);
    await server.connect(transport);

    return server
}