@@ -57,9 +57,7 @@ export interface McpBridgeConfig {
5757 * Start MCP bridges for all skills that declare an `mcp` field.
5858 * Each skill gets a persistent upstream connection + HTTP endpoint.
5959 */
60- export async function startMcpBridges (
61- config : McpBridgeConfig ,
62- ) : Promise < void > {
60+ export async function startMcpBridges ( config : McpBridgeConfig ) : Promise < void > {
6361 const basePort = config . basePort ?? MCP_BASE_PORT ;
6462 let portOffset = 0 ;
6563
@@ -69,10 +67,7 @@ export async function startMcpBridges(
6967 const port = basePort + portOffset ++ ;
7068 try {
7169 await startBridge ( skill , port , config . onInboxEvent ) ;
72- logger . info (
73- { skill : skill . manifest . name , port } ,
74- 'MCP bridge started' ,
75- ) ;
70+ logger . info ( { skill : skill . manifest . name , port } , 'MCP bridge started' ) ;
7671 } catch ( err ) {
7772 logger . error (
7873 { skill : skill . manifest . name , port, err } ,
@@ -94,15 +89,21 @@ export async function stopMcpBridges(): Promise<void> {
9489
9590 try {
9691 entry . httpServer . close ( ) ;
97- } catch { /* best effort */ }
92+ } catch {
93+ /* best effort */
94+ }
9895
9996 try {
10097 await entry . httpTransport . close ( ) ;
101- } catch { /* best effort */ }
98+ } catch {
99+ /* best effort */
100+ }
102101
103102 try {
104103 await entry . upstream . close ( ) ;
105- } catch { /* best effort */ }
104+ } catch {
105+ /* best effort */
106+ }
106107
107108 if ( entry . childProcess ) {
108109 entry . childProcess . kill ( 'SIGTERM' ) ;
@@ -141,9 +142,10 @@ async function startBridge(
141142 env : { ...process . env , ...env } as Record < string , string > ,
142143 } ) ;
143144
144- const upstream = new Client (
145- { name : `nonnaclaw-bridge-${ name } ` , version : '1.0.0' } ,
146- ) ;
145+ const upstream = new Client ( {
146+ name : `nonnaclaw-bridge-${ name } ` ,
147+ version : '1.0.0' ,
148+ } ) ;
147149
148150 await upstream . connect ( upstreamTransport ) ;
149151
@@ -180,7 +182,10 @@ async function startBridge(
180182 // CORS headers for container access
181183 res . setHeader ( 'Access-Control-Allow-Origin' , '*' ) ;
182184 res . setHeader ( 'Access-Control-Allow-Methods' , 'GET, POST, DELETE, OPTIONS' ) ;
183- res . setHeader ( 'Access-Control-Allow-Headers' , 'Content-Type, mcp-session-id' ) ;
185+ res . setHeader (
186+ 'Access-Control-Allow-Headers' ,
187+ 'Content-Type, mcp-session-id' ,
188+ ) ;
184189
185190 if ( req . method === 'OPTIONS' ) {
186191 res . writeHead ( 204 ) ;
@@ -296,9 +301,12 @@ function processPolledMessage(
296301 chatId : String ( msg . chat_id ?? msg . chatId ?? msg . chat_jid ?? '' ) ,
297302 content : String ( msg . content ?? msg . text ?? msg . body ?? msg . message ?? '' ) ,
298303 sender : String ( msg . sender ?? msg . from ?? msg . sender_jid ?? '' ) ,
299- senderName : String ( msg . sender_name ?? msg . senderName ?? msg . pushName ?? msg . sender_jid ?? '' ) ,
304+ senderName : String (
305+ msg . sender_name ?? msg . senderName ?? msg . pushName ?? msg . sender_jid ?? '' ,
306+ ) ,
300307 timestamp,
301- messageId : ( msg . message_id ?? msg . id ) ? String ( msg . message_id ?? msg . id ) : undefined ,
308+ messageId :
309+ ( msg . message_id ?? msg . id ) ? String ( msg . message_id ?? msg . id ) : undefined ,
302310 metadata : {
303311 isGroup : msg . is_group ?? msg . isGroup ,
304312 isBotMessage : msg . is_from_me ?? msg . isFromMe ,
0 commit comments