File tree Expand file tree Collapse file tree 2 files changed +9
-4
lines changed Expand file tree Collapse file tree 2 files changed +9
-4
lines changed Original file line number Diff line number Diff line change 1- import { nanoid } from 'nanoid'
21import Fastify , { type FastifyReply , type FastifyRequest } from 'fastify'
32import cors from '@fastify/cors'
4- import { McpServer } from '@modelcontextprotocol/sdk/server/mcp.js'
5- import { isInitializeRequest } from '@modelcontextprotocol/sdk/types.js'
63import { StreamableHTTPServerTransport } from '@modelcontextprotocol/sdk/server/streamableHttp.js'
74import { SSEServerTransport } from '@modelcontextprotocol/sdk/server/sse.js'
5+ import { isInitializeRequest } from '@modelcontextprotocol/sdk/types.js'
6+ import { generateSessionId } from '@/utils'
7+ import type { McpServer } from '@modelcontextprotocol/sdk/server/mcp.js'
88import type { OptionsType } from '@/types'
99
1010export async function webServer ( server : McpServer , options : OptionsType ) {
@@ -26,7 +26,7 @@ export async function webServer(server: McpServer, options: OptionsType) {
2626 transport = transports . streamable [ sessionId ]
2727 } else if ( ! sessionId && isInitializeRequest ( request . body ) ) {
2828 transport = new StreamableHTTPServerTransport ( {
29- sessionIdGenerator : ( ) => nanoid ( ) ,
29+ sessionIdGenerator : ( ) => generateSessionId ( ) ,
3030 onsessioninitialized : sessionId => {
3131 transports . streamable [ sessionId ] = transport
3232 } ,
Original file line number Diff line number Diff line change 1+ import { nanoid } from 'nanoid'
12import type { ArgumentsCamelCase } from 'yargs'
23import type { OptionsType } from '@/types'
34
5+ export function generateSessionId ( ) {
6+ return nanoid ( )
7+ }
8+
49export function getOptions (
510 argv : ArgumentsCamelCase ,
611 pkg : {
You can’t perform that action at this time.
0 commit comments