feat(mcp): add unix socket option for remote MCP

Author: stainless-app[bot]

packages/mcp-server/src/headers.ts

@@ -10,7 +10,7 @@ export const parseAuthHeaders = (req: IncomingMessage): Partial<ClientOptions> =
     const value = req.headers.authorization.slice(scheme.length + 1);
     switch (scheme) {
       case 'Basic':
-        const rawValue = Buffer.from(value).toString('base64');
+        const rawValue = Buffer.from(value, 'base64').toString();
         return {
           tokenId: rawValue.slice(0, rawValue.search(':')),
           tokenSecret: rawValue.slice(rawValue.search(':') + 1),

packages/mcp-server/src/http.ts

@@ -83,7 +83,7 @@ export const streamableHTTPApp = (options: McpOptions) => {
 export const launchStreamableHTTPServer = async (
   options: McpOptions,
   endpoints: Endpoint[],
-  port: number | undefined,
+  port: number | string | undefined,
 ) => {
   const app = streamableHTTPApp(options);
   const server = app.listen(port);

packages/mcp-server/src/index.ts

@@ -26,7 +26,7 @@ async function main() {
       await launchStdioServer(options, selectedTools);
       break;
     case 'http':
-      await launchStreamableHTTPServer(options, selectedTools, options.port);
+      await launchStreamableHTTPServer(options, selectedTools, options.port ?? options.socket);
       break;
   }
 }

packages/mcp-server/src/options.ts

@@ -7,6 +7,7 @@ export type CLIOptions = McpOptions & {
   list: boolean;
   transport: 'stdio' | 'http';
   port: number | undefined;
+  socket: string | undefined;
 };
 
 export type McpOptions = {
@@ -141,6 +142,10 @@ export function parseOptions(): CLIOptions {
       type: 'number',
       description: 'Port to serve on if using http transport',
     })
+    .option('socket', {
+      type: 'string',
+      description: 'Unix socket to serve on if using http transport',
+    })
     .help();
 
   for (const [command, desc] of examples()) {
@@ -262,6 +267,7 @@ export function parseOptions(): CLIOptions {
     list: argv.list || false,
     transport,
     port: argv.port,
+    socket: argv.socket,
   };
 }