Merge pull request #90 from supercorp-ai/rollback-to-v3.2-1

Rollback code to v3.2.0 for upcoming v3.4 release

Author: Nedomas

README.md

@@ -28,8 +28,6 @@ npx -y supergateway --stdio "uvx mcp-server-git"
 - **`--logLevel debug | info | none`**: Controls logging level (default: `info`). Use `debug` for more verbose logs, `none` to suppress all logs.
 - **`--cors`**: Enable CORS (stdio→SSE or stdio→WS mode). Use `--cors` with no values to allow all origins, or supply one or more allowed origins (e.g. `--cors "http://example.com"` or `--cors "/example\\.com$/"` for regex matching).
 - **`--healthEndpoint /healthz`**: Register one or more endpoints (stdio→SSE or stdio→WS mode; can be used multiple times) that respond with `"ok"`
-- **`--minConcurrency 1`**: Minimum concurrency for stdio server (stdio→SSE; default: `1`).
-- **`--maxConcurrency 10`**: Max concurrency for stdio server (stdio→SSE; default: `1`).
 
 ## stdio → SSE
 
@@ -297,9 +295,6 @@ Supergateway emphasizes modularity:
 
 ## Contributors
 
-- [@rsonghuster](https://github.com/rsonghuster)
-- [@zxypro1](https://github.com/zxypro1)
-- [@nicojahn](https://github.com/nicojahn)
 - [@griffinqiu](https://github.com/griffinqiu)
 - [@folkvir](https://github.com/folkvir)
 - [@wizizm](https://github.com/wizizm)

package-lock.json

@@ -1,6 +1,6 @@
 {
   "name": "supergateway",
-  "version": "3.3.0",
+  "version": "3.2.0",
   "description": "Run MCP stdio servers over SSE, Streamable HTTP or visa versa",
   "repository": {
     "type": "git",

package.json

@@ -9,7 +9,6 @@ import { Logger } from '../types.js'
 import { getVersion } from '../lib/getVersion.js'
 import { onSignals } from '../lib/onSignals.js'
 import { serializeCorsOrigin } from '../lib/serializeCorsOrigin.js'
-import { StdioChildProcessPool } from '../lib/stdioProcessPool.js'
 
 export interface StdioToSseArgs {
   stdioCmd: string
@@ -21,8 +20,6 @@ export interface StdioToSseArgs {
   corsOrigin: CorsOptions['origin']
   healthEndpoints: string[]
   headers: Record<string, string>
-  minConcurrency: number
-  maxConcurrency: number
 }
 
 const setResponseHeaders = ({
@@ -47,8 +44,6 @@ export async function stdioToSse(args: StdioToSseArgs) {
     corsOrigin,
     healthEndpoints,
     headers,
-    minConcurrency,
-    maxConcurrency,
   } = args
 
   logger.info(
@@ -68,20 +63,20 @@ export async function stdioToSse(args: StdioToSseArgs) {
   logger.info(
     `  - Health endpoints: ${healthEndpoints.length ? healthEndpoints.join(', ') : '(none)'}`,
   )
-  if (minConcurrency > 1 || maxConcurrency > 1) {
-    logger.info(`  - minConcurrency: ${minConcurrency}`)
-    logger.info(`  - maxConcurrency: ${maxConcurrency}`)
-  }
 
   onSignals({ logger })
 
-  const pool = new StdioChildProcessPool({
-    stdioCmd,
-    minConcurrency,
-    maxConcurrency,
-    logger,
+  const child: ChildProcessWithoutNullStreams = spawn(stdioCmd, { shell: true })
+  child.on('exit', (code, signal) => {
+    logger.error(`Child exited: code=${code}, signal=${signal}`)
+    process.exit(code ?? 1)
   })
 
+  const server = new Server(
+    { name: 'supergateway', version: getVersion() },
+    { capabilities: {} },
+  )
+
   const sessions: Record<
     string,
     { transport: SSEServerTransport; response: express.Response }
@@ -116,20 +111,7 @@ export async function stdioToSse(args: StdioToSseArgs) {
       headers,
     })
 
-    let child: ChildProcessWithoutNullStreams
-    try {
-      child = await pool.acquire()
-    } catch (err) {
-      logger.error('Failed to acquire child process:', err)
-      res.status(503).send('Service unavailable')
-      return
-    }
-
     const sseTransport = new SSEServerTransport(`${baseUrl}${messagePath}`, res)
-    const server = new Server(
-      { name: 'supergateway', version: getVersion() },
-      { capabilities: {} },
-    )
     await server.connect(sseTransport)
 
     const sessionId = sseTransport.sessionId
@@ -152,37 +134,9 @@ export async function stdioToSse(args: StdioToSseArgs) {
       delete sessions[sessionId]
     }
 
-    let buffer = ''
-    const onStdoutData = (chunk: Buffer) => {
-      buffer += chunk.toString('utf8')
-      const lines = buffer.split(/\r?\n/)
-      buffer = lines.pop() ?? ''
-      lines.forEach((line) => {
-        if (!line.trim()) return
-        try {
-          const jsonMsg = JSON.parse(line)
-          logger.info(`Child → SSE (session ${sessionId}):`, jsonMsg)
-          sseTransport.send(jsonMsg)
-        } catch (err) {
-          logger.error(`Child non-JSON (session ${sessionId}): ${line}`, err)
-        }
-      })
-    }
-    child.stdout.on('data', onStdoutData)
-    const onExit = (code: number | null, signal: NodeJS.Signals | null) => {
-      logger.error(
-        `Child process exited (session ${sessionId}): code=${code}, signal=${signal}`,
-      )
-      server.close()
-    }
-    child.on('exit', onExit)
-
     req.on('close', () => {
       logger.info(`Client disconnected (session ${sessionId})`)
-      server.close()
-      child.stdout.off('data', onStdoutData)
-      child.off('exit', onExit)
-      pool.release(child)
+      delete sessions[sessionId]
     })
   })
 
@@ -213,4 +167,32 @@ export async function stdioToSse(args: StdioToSseArgs) {
     logger.info(`SSE endpoint: http://localhost:${port}${ssePath}`)
     logger.info(`POST messages: http://localhost:${port}${messagePath}`)
   })
+
+  let buffer = ''
+  child.stdout.on('data', (chunk: Buffer) => {
+    buffer += chunk.toString('utf8')
+    const lines = buffer.split(/\r?\n/)
+    buffer = lines.pop() ?? ''
+    lines.forEach((line) => {
+      if (!line.trim()) return
+      try {
+        const jsonMsg = JSON.parse(line)
+        logger.info('Child → SSE:', jsonMsg)
+        for (const [sid, session] of Object.entries(sessions)) {
+          try {
+            session.transport.send(jsonMsg)
+          } catch (err) {
+            logger.error(`Failed to send to session ${sid}:`, err)
+            delete sessions[sid]
+          }
+        }
+      } catch {
+        logger.error(`Child non-JSON: ${line}`)
+      }
+    })
+  })
+
+  child.stderr.on('data', (chunk: Buffer) => {
+    logger.error(`Child stderr: ${chunk.toString('utf8')}`)
+  })
 }

src/gateways/stdioToSse.ts

@@ -123,18 +123,6 @@ async function main() {
       description:
         'Session timeout in milliseconds. Only supported for stateful stdio→StreamableHttp. If not set, the session will only be deleted when client transport explicitly terminates the session.',
     })
-    .option('minConcurrency', {
-      type: 'number',
-      default: 1,
-      description:
-        'Minimum number of concurrent processes (stdio→SSE). Default is 1.',
-    })
-    .option('maxConcurrency', {
-      type: 'number',
-      default: 1,
-      description:
-        'Maximum number of concurrent processes (stdio→SSE). Default is 1.',
-    })
     .help()
     .parseSync()
 
@@ -185,8 +173,6 @@ async function main() {
             argv,
             logger,
           }),
-          minConcurrency: argv.minConcurrency,
-          maxConcurrency: argv.maxConcurrency,
         })
       } else if (argv.outputTransport === 'ws') {
         await stdioToWs({

src/index.ts

@@ -8,7 +8,7 @@ import { SSEClientTransport } from '@modelcontextprotocol/sdk/client/sse.js'
 
 const BASE_URL = 'http://localhost:11001'
 const SSE_PATH = '/sse'
-const CONCURRENCY = 100
+const CONCURRENCY = 1
 
 function makeLimiter(maxConcurrency: number) {
   let active = 0