feat: export createServer and add ping interval to SSE

Author: zhensherlock

.changeset/three-phones-go.md

@@ -0,0 +1,5 @@
+---
+'create-mcp-kit': patch
+---
+
+feat: export createServer and add ping interval to SSE

packages/create-mcp-kit/template/server-js/src/services/index.js.hbs

@@ -9,7 +9,7 @@ import { stdioServer } from './stdio.js'
 import { webServer } from './web.js'
 {{/if}}
 
-const createServer = options => {
+export const createServer = options => {
   const server = new McpServer({
     name: options.name,
     version: options.version,

packages/create-mcp-kit/template/server-js/src/services/web.js.hbs

@@ -6,6 +6,7 @@ import { StreamableHTTPServerTransport } from '@modelcontextprotocol/sdk/server/
   {{/if}}
   {{#if (includes transports 'sse')}}
 import { SSEServerTransport } from '@modelcontextprotocol/sdk/server/sse.js'
+import { createServer } from '@/services'
   {{/if}}
   {{#if (includes transports 'streamable')}}
 import { generateSessionId } from '@/utils'
@@ -81,10 +82,16 @@ export async function webServer(server, options) {
     const transport = new SSEServerTransport('/messages', res)
     transports.sse[transport.sessionId] = transport
 
+    const interval = setInterval(() => {
+      res.raw.write(`event: ping\ndata: {"time":"${new Date().toISOString()}"}\n\n`)
+    }, 15000)
+
     res.on('close', () => {
       delete transports.sse[transport.sessionId]
+      clearInterval(interval)
     })
 
+    const server = createServer(options)
     await server.connect(transport)
   })
 

packages/create-mcp-kit/template/server-ts/src/services/index.ts.hbs

@@ -10,7 +10,7 @@ import { webServer } from './web'
 {{/if}}
 import type { OptionsType } from '@/types'
 
-const createServer = (options: OptionsType) => {
+export const createServer = (options: OptionsType) => {
   const server = new McpServer({
     name: options.name,
     version: options.version,

packages/create-mcp-kit/template/server-ts/src/services/web.ts.hbs

@@ -6,6 +6,7 @@ import { StreamableHTTPServerTransport } from '@modelcontextprotocol/sdk/server/
   {{/if}}
   {{#if (includes transports 'sse')}}
 import { SSEServerTransport } from '@modelcontextprotocol/sdk/server/sse.js'
+import { createServer } from '@/services'
   {{/if}}
   {{#if (includes transports 'streamable')}}
 import { generateSessionId } from '@/utils'
@@ -83,10 +84,16 @@ export async function webServer(server: McpServer, options: OptionsType) {
     const transport = new SSEServerTransport('/messages', res)
     transports.sse[transport.sessionId] = transport
 
+    const interval = setInterval(() => {
+      res.raw.write(`event: ping\ndata: {"time":"${new Date().toISOString()}"}\n\n`)
+    }, 15000)
+
     res.on('close', () => {
       delete transports.sse[transport.sessionId]
+      clearInterval(interval)
     })
 
+    const server = createServer(options)
     await server.connect(transport)
   })