toolception
Advanced tools
@@ -68,2 +68,27 @@ import { FastifyInstance } from 'fastify'; | ||
| /** | ||
| * Closes all active sessions and clears the session map so the server is | ||
| * free to accept a new connection. Required for SDK 1.26+, which throws | ||
| * "Already connected" when `connect()` is called while a transport is | ||
| * still attached. Handles unclean client disconnects followed by re-init. | ||
| * | ||
| * The map is cleared before closing so that `onclose` handlers fired by | ||
| * `transport.close()` do not attempt double-deletion. | ||
| * | ||
| * @param sessions - The client's active session map to drain | ||
| */ | ||
| private drainExistingSessions; | ||
| /** | ||
| * Disconnects the server from its current transport so that `Protocol._transport` | ||
| * is cleared before a new connection is established. | ||
| * | ||
| * `drainExistingSessions` handles same-bundle reconnects (sessions in the map). | ||
| * This method handles the STATIC-mode cross-client case: a different client's | ||
| * bundle has an empty sessions map, but the shared server is still attached to | ||
| * the previous client's transport because `StreamableHTTPClientTransport.close()` | ||
| * does not send DELETE—it only aborts connections. | ||
| * | ||
| * @param server - The MCP server to disconnect from its current transport | ||
| */ | ||
| private disconnectServer; | ||
| /** | ||
| * @param bundle - The client bundle to clean up | ||
@@ -70,0 +95,0 @@ */ |
@@ -1,1 +0,1 @@ | ||
| {"version":3,"file":"FastifyTransport.d.ts","sourceRoot":"","sources":["../../src/http/FastifyTransport.ts"],"names":[],"mappings":"AAAA,OAAgB,EACd,KAAK,eAAe,EAGrB,MAAM,SAAS,CAAC;AAIjB,OAAO,KAAK,EAAE,kBAAkB,EAAE,MAAM,+BAA+B,CAAC;AAGxE,OAAO,KAAK,EAAE,sBAAsB,EAAE,MAAM,sCAAsC,CAAC;AAKnF,OAAO,KAAK,EACV,uBAAuB,EACvB,oBAAoB,EACpB,wBAAwB,EACzB,MAAM,iBAAiB,CAAC;AAQzB,qBAAa,gBAAgB;IAC3B,OAAO,CAAC,QAAQ,CAAC,OAAO,CAQtB;IACF,OAAO,CAAC,QAAQ,CAAC,cAAc,CAAqB;IACpD,OAAO,CAAC,QAAQ,CAAC,YAAY,CAAuB;IACpD,OAAO,CAAC,QAAQ,CAAC,sBAAsB,CAAC,CAAyB;IACjE,OAAO,CAAC,QAAQ,CAAC,WAAW,CAAC,CAAU;IACvC,OAAO,CAAC,GAAG,CAAgC;IAC3C,OAAO,CAAC,QAAQ,CAAC,YAAY,CAAC,CAAS;IAGvC,OAAO,CAAC,QAAQ,CAAC,WAAW,CASzB;gBAGD,cAAc,EAAE,kBAAkB,EAClC,YAAY,EAAE,oBAAoB,EAClC,OAAO,GAAE,uBAA4B,EACrC,YAAY,CAAC,EAAE,MAAM,EACrB,sBAAsB,CAAC,EAAE,sBAAsB,EAC/C,WAAW,CAAC,EAAE,OAAO;IAkBvB,MAAM,CAAC,OAAO;8BAQY,kBAAkB;4BACpB,oBAAoB;oBAC5B,MAAM;oBACN,MAAM;wBACF,MAAM;oBACV,OAAO;sBACL,OAAO;mBACV,eAAe;+BACH,wBAAwB,EAAE;4BAC7B,MAAM;sCACI,sBAAsB;2BACjC,OAAO;;;IAMjB,KAAK,IAAI,OAAO,CAAC,IAAI,CAAC;IA4BnC;;;OAGG;IACH,OAAO,CAAC,iBAAiB;IAIzB;;;OAGG;IACH,OAAO,CAAC,sBAAsB;IAI9B;;;OAGG;IACH,OAAO,CAAC,qBAAqB;IAI7B;;;OAGG;IACH,OAAO,CAAC,+BAA+B;IAiBvC;;;OAGG;IACH,OAAO,CAAC,uBAAuB;IAkF/B;;;OAGG;IACH,OAAO,CAAC,sBAAsB;IAgC9B;;;OAGG;IACH,OAAO,CAAC,yBAAyB;IAiDpB,IAAI,IAAI,OAAO,CAAC,IAAI,CAAC;IAYlC;;OAEG;IACH,OAAO,CAAC,aAAa;IAmBrB;;;;OAIG;IACH,OAAO,CAAC,qBAAqB;IAqC7B;;;OAGG;IACH,OAAO,CAAC,cAAc;IAYtB;;;OAGG;IACH,OAAO,CAAC,YAAY;CAYrB"} | ||
| {"version":3,"file":"FastifyTransport.d.ts","sourceRoot":"","sources":["../../src/http/FastifyTransport.ts"],"names":[],"mappings":"AAAA,OAAgB,EACd,KAAK,eAAe,EAGrB,MAAM,SAAS,CAAC;AAIjB,OAAO,KAAK,EAAE,kBAAkB,EAAE,MAAM,+BAA+B,CAAC;AAGxE,OAAO,KAAK,EAAE,sBAAsB,EAAE,MAAM,sCAAsC,CAAC;AAKnF,OAAO,KAAK,EACV,uBAAuB,EACvB,oBAAoB,EACpB,wBAAwB,EACzB,MAAM,iBAAiB,CAAC;AAQzB,qBAAa,gBAAgB;IAC3B,OAAO,CAAC,QAAQ,CAAC,OAAO,CAQtB;IACF,OAAO,CAAC,QAAQ,CAAC,cAAc,CAAqB;IACpD,OAAO,CAAC,QAAQ,CAAC,YAAY,CAAuB;IACpD,OAAO,CAAC,QAAQ,CAAC,sBAAsB,CAAC,CAAyB;IACjE,OAAO,CAAC,QAAQ,CAAC,WAAW,CAAC,CAAU;IACvC,OAAO,CAAC,GAAG,CAAgC;IAC3C,OAAO,CAAC,QAAQ,CAAC,YAAY,CAAC,CAAS;IAGvC,OAAO,CAAC,QAAQ,CAAC,WAAW,CASzB;gBAGD,cAAc,EAAE,kBAAkB,EAClC,YAAY,EAAE,oBAAoB,EAClC,OAAO,GAAE,uBAA4B,EACrC,YAAY,CAAC,EAAE,MAAM,EACrB,sBAAsB,CAAC,EAAE,sBAAsB,EAC/C,WAAW,CAAC,EAAE,OAAO;IAkBvB,MAAM,CAAC,OAAO;8BAQY,kBAAkB;4BACpB,oBAAoB;oBAC5B,MAAM;oBACN,MAAM;wBACF,MAAM;oBACV,OAAO;sBACL,OAAO;mBACV,eAAe;+BACH,wBAAwB,EAAE;4BAC7B,MAAM;sCACI,sBAAsB;2BACjC,OAAO;;;IAMjB,KAAK,IAAI,OAAO,CAAC,IAAI,CAAC;IA4BnC;;;OAGG;IACH,OAAO,CAAC,iBAAiB;IAIzB;;;OAGG;IACH,OAAO,CAAC,sBAAsB;IAI9B;;;OAGG;IACH,OAAO,CAAC,qBAAqB;IAI7B;;;OAGG;IACH,OAAO,CAAC,+BAA+B;IAiBvC;;;OAGG;IACH,OAAO,CAAC,uBAAuB;IAmF/B;;;OAGG;IACH,OAAO,CAAC,sBAAsB;IAgC9B;;;OAGG;IACH,OAAO,CAAC,yBAAyB;IA6CpB,IAAI,IAAI,OAAO,CAAC,IAAI,CAAC;IAYlC;;;;;;;;;;OAUG;YACW,qBAAqB;IAWnC;;;;;;;;;;;OAWG;YACW,gBAAgB;IAI9B;;OAEG;IACH,OAAO,CAAC,aAAa;IAarB;;;;OAIG;IACH,OAAO,CAAC,qBAAqB;IAqC7B;;;OAGG;IACH,OAAO,CAAC,cAAc;IAYtB;;;OAGG;IACH,OAAO,CAAC,YAAY;CAYrB"} |
@@ -1,1 +0,1 @@ | ||
| {"version":3,"file":"PermissionAwareFastifyTransport.d.ts","sourceRoot":"","sources":["../../src/permissions/PermissionAwareFastifyTransport.ts"],"names":[],"mappings":"AAAA,OAAgB,EACd,KAAK,eAAe,EAGrB,MAAM,SAAS,CAAC;AAIjB,OAAO,KAAK,EAAE,kBAAkB,EAAE,MAAM,+BAA+B,CAAC;AAMxE,OAAO,KAAK,EACV,oBAAoB,EACpB,qBAAqB,EACrB,sCAAsC,EACvC,MAAM,wBAAwB,CAAC;AAChC,OAAO,KAAK,EAAE,wBAAwB,EAAE,MAAM,uBAAuB,CAAC;AAQtE,qBAAa,+BAA+B;;IAC1C,OAAO,CAAC,QAAQ,CAAC,OAAO,CAQtB;IACF,OAAO,CAAC,QAAQ,CAAC,cAAc,CAAqB;IACpD,OAAO,CAAC,QAAQ,CAAC,2BAA2B,CAER;IACpC,OAAO,CAAC,GAAG,CAAgC;IAC3C,OAAO,CAAC,QAAQ,CAAC,YAAY,CAAC,CAAS;IAGvC,OAAO,CAAC,QAAQ,CAAC,WAAW,CAWzB;gBAGD,cAAc,EAAE,kBAAkB,EAClC,2BAA2B,EAAE,CAC3B,OAAO,EAAE,oBAAoB,KAC1B,OAAO,CAAC,qBAAqB,CAAC,EACnC,OAAO,GAAE,sCAA2C,EACpD,YAAY,CAAC,EAAE,MAAM;IAgBvB,MAAM,CAAC,OAAO;8BAMY,kBAAkB;2CACL,CAAC,OAAO,EAAE,oBAAoB,KAAK,OAAO,CAAC,qBAAqB,CAAC;oBACxF,MAAM;oBACN,MAAM;wBACF,MAAM;oBACV,OAAO;sBACL,OAAO;mBACV,eAAe;+BACH,wBAAwB,EAAE;4BAC7B,MAAM;;;IAMjB,KAAK,IAAI,OAAO,CAAC,IAAI,CAAC;IAoDtB,IAAI,IAAI,OAAO,CAAC,IAAI,CAAC;CA0TnC"} | ||
| {"version":3,"file":"PermissionAwareFastifyTransport.d.ts","sourceRoot":"","sources":["../../src/permissions/PermissionAwareFastifyTransport.ts"],"names":[],"mappings":"AAAA,OAAgB,EACd,KAAK,eAAe,EAGrB,MAAM,SAAS,CAAC;AAIjB,OAAO,KAAK,EAAE,kBAAkB,EAAE,MAAM,+BAA+B,CAAC;AAMxE,OAAO,KAAK,EACV,oBAAoB,EACpB,qBAAqB,EACrB,sCAAsC,EACvC,MAAM,wBAAwB,CAAC;AAChC,OAAO,KAAK,EAAE,wBAAwB,EAAE,MAAM,uBAAuB,CAAC;AAQtE,qBAAa,+BAA+B;;IAC1C,OAAO,CAAC,QAAQ,CAAC,OAAO,CAQtB;IACF,OAAO,CAAC,QAAQ,CAAC,cAAc,CAAqB;IACpD,OAAO,CAAC,QAAQ,CAAC,2BAA2B,CAER;IACpC,OAAO,CAAC,GAAG,CAAgC;IAC3C,OAAO,CAAC,QAAQ,CAAC,YAAY,CAAC,CAAS;IAGvC,OAAO,CAAC,QAAQ,CAAC,WAAW,CAWzB;gBAGD,cAAc,EAAE,kBAAkB,EAClC,2BAA2B,EAAE,CAC3B,OAAO,EAAE,oBAAoB,KAC1B,OAAO,CAAC,qBAAqB,CAAC,EACnC,OAAO,GAAE,sCAA2C,EACpD,YAAY,CAAC,EAAE,MAAM;IAgBvB,MAAM,CAAC,OAAO;8BAMY,kBAAkB;2CACL,CAAC,OAAO,EAAE,oBAAoB,KAAK,OAAO,CAAC,qBAAqB,CAAC;oBACxF,MAAM;oBACN,MAAM;wBACF,MAAM;oBACV,OAAO;sBACL,OAAO;mBACV,eAAe;+BACH,wBAAwB,EAAE;4BAC7B,MAAM;;;IAMjB,KAAK,IAAI,OAAO,CAAC,IAAI,CAAC;IAoDtB,IAAI,IAAI,OAAO,CAAC,IAAI,CAAC;CAsVnC"} |
+2
-2
| { | ||
| "name": "toolception", | ||
| "version": "0.6.2", | ||
| "version": "0.6.3", | ||
| "private": false, | ||
@@ -27,3 +27,3 @@ "type": "module", | ||
| "@fastify/cors": "^10.0.1", | ||
| "@modelcontextprotocol/sdk": "^1.0.0", | ||
| "@modelcontextprotocol/sdk": "^1.27.1", | ||
| "fastify": "^5.0.0", | ||
@@ -30,0 +30,0 @@ "zod": "^3.22.4" |
Sorry, the diff of this file is too big to display
Sorry, the diff of this file is too big to display
413884
1.52%3681
1.54%