Function getServer

src/examples/server/simpleSseServer.ts:19–79

()

// Create an MCP server instance
const getServer = () => {
    const server = new McpServer(
        {
            name: 'simple-sse-server',
            version: '1.0.0'
        },
        { capabilities: { logging: {} } }
    );

    server.registerTool(
        'start-notification-stream',
        {
            description: 'Starts sending periodic notifications',
            inputSchema: {
                interval: z.number().describe('Interval in milliseconds between notifications').default(1000),
                count: z.number().describe('Number of notifications to send').default(10)
            }
        },
        async ({ interval, count }, extra): Promise<CallToolResult> => {
            const sleep = (ms: number) => new Promise(resolve => setTimeout(resolve, ms));
            let counter = 0;

            // Send the initial notification
            await server.sendLoggingMessage(
                {
                    level: 'info',
                    data: `Starting notification stream with ${count} messages every ${interval}ms`
                },
                extra.sessionId
            );

            // Send periodic notifications
            while (counter < count) {
                counter++;
                await sleep(interval);

                try {
                    await server.sendLoggingMessage(
                        {
                            level: 'info',
                            data: `Notification #${counter} at ${new Date().toISOString()}`
                        },
                        extra.sessionId
                    );
                } catch (error) {
                    console.error('Error sending notification:', error);
                }
            }

            return {
                content: [
                    {
                        type: 'text',
                        text: `Completed sending ${count} notifications every ${interval}ms`
                    }
                ]
            };
        }