modelcontextprotocol/typescript-sdk
Watch
1
0
Fork
You've already forked typescript-sdk
 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions 1

chore: switch to module ESNext + moduleResolution bundler (#2095)

Browse source
This commit is contained in:
Matt 2026-06-25 12:49:17 +02:00 • committed by GitHub
commit ee732d64b6
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 668 additions and 863 deletions
Download patch file Download diff file Expand all files Collapse all files

155
scripts/cli.ts
View file

@ -1,155 +0,0 @@
import express from 'express';
import { Client } from '../src/client/index.js';
import { SSEClientTransport } from '../src/client/sse.js';
import { StdioClientTransport } from '../src/client/stdio.js';
import { Server } from '../src/server/index.js';
import { SSEServerTransport } from '../src/server/sse.js';
import { StdioServerTransport } from '../src/server/stdio.js';
import { ListResourcesResultSchema } from '../src/types.js';
async function runClient(url_or_command: string, args: string[]) {
const client = new Client(
{
name: 'mcp-typescript test client',
version: '0.1.0'
},
{
capabilities: {
sampling: {}
}
}
);
let clientTransport;
let url: URL | undefined = undefined;
try {
url = new URL(url_or_command);
} catch {
// Ignore
}
if (url?.protocol === 'http:' || url?.protocol === 'https:') {
clientTransport = new SSEClientTransport(new URL(url_or_command));
} else if (url?.protocol === 'ws:' || url?.protocol === 'wss:') {
throw new Error('WebSocket URLs are no longer supported. Use http(s) or stdio instead.');
} else {
clientTransport = new StdioClientTransport({
command: url_or_command,
args
});
}
console.log('Connected to server.');
await client.connect(clientTransport);
console.log('Initialized.');
await client.request({ method: 'resources/list' }, ListResourcesResultSchema);
await client.close();
console.log('Closed.');
}
async function runServer(port: number | null) {
if (port !== null) {
const app = express();
let servers: Server[] = [];
app.get('/sse', async (req, res) => {
console.log('Got new SSE connection');
const transport = new SSEServerTransport('/message', res);
const server = new Server(
{
name: 'mcp-typescript test server',
version: '0.1.0'
},
{
capabilities: {}
}
);
servers.push(server);
server.onclose = () => {
console.log('SSE connection closed');
servers = servers.filter(s => s !== server);
};
await server.connect(transport);
});
app.post('/message', async (req, res) => {
console.log('Received message');
const sessionId = req.query.sessionId as string;
const transport = servers.map(s => s.transport as SSEServerTransport).find(t => t.sessionId === sessionId);
if (!transport) {
res.status(404).send('Session not found');
return;
}
await transport.handlePostMessage(req, res);
});
app.listen(port, error => {
if (error) {
console.error('Failed to start server:', error);
process.exit(1);
}
console.log(`Server running on http://localhost:${port}/sse`);
});
} else {
const server = new Server(
{
name: 'mcp-typescript test server',
version: '0.1.0'
},
{
capabilities: {
prompts: {},
resources: {},
tools: {},
logging: {}
}
}
);
const transport = new StdioServerTransport();
await server.connect(transport);
console.log('Server running on stdio');
}
}
const args = process.argv.slice(2);
const command = args[0];
switch (command) {
case 'client':
if (args.length < 2) {
console.error('Usage: client <server_url_or_command> [args...]');
process.exit(1);
}
runClient(args[1], args.slice(2)).catch(error => {
console.error(error);
process.exit(1);
});
break;
case 'server': {
const port = args[1] ? parseInt(args[1]) : null;
runServer(port).catch(error => {
console.error(error);
process.exit(1);
});
break;
}
default:
console.error('Unrecognized command:', command);
}