docs: ref InMemoryEventStore

Author: punkpeye

README.md

@@ -84,7 +84,7 @@ Starts a proxy that listens on a `port` and `endpoint`, and sends messages to th
 
 ```ts
 import { Server } from "@modelcontextprotocol/sdk/server/index.js";
-import { startHTTPStreamServer } from "mcp-proxy";
+import { startHTTPStreamServer, InMemoryEventStore } from "mcp-proxy";
 
 const { close } = await startHTTPStreamServer({
   port: 8080,

eslint.config.js

@@ -1,3 +1,10 @@
 import perfectionist from "eslint-plugin-perfectionist";
 
-export default [perfectionist.configs["recommended-alphabetical"]];
+export default [
+  perfectionist.configs["recommended-alphabetical"],
+  {
+    ignores: [
+      '**/dist/'
+    ],
+  },
+];

src/inMemoryEventStore.ts renamed to src/InMemoryEventStore.ts

@@ -1,8 +1,11 @@
+/**
+ * This is a copy of the InMemoryEventStore from the typescript-sdk
+ * https://github.com/modelcontextprotocol/typescript-sdk/blob/main/src/inMemoryEventStore.ts
+ */
+
 import type { JSONRPCMessage } from "@modelcontextprotocol/sdk/types.js";
 import type { EventStore } from "@modelcontextprotocol/sdk/server/streamableHttp.js";
 
-// copied from https://github.com/modelcontextprotocol/typescript-sdk
-
 /**
  * Simple in-memory implementation of the EventStore interface for resumability
  * This is primarily intended for examples and testing, not for production use

src/bin/mcp-proxy.ts

@@ -11,7 +11,7 @@ import util from "node:util";
 import { startSSEServer } from "../startSSEServer.js";
 import { startHTTPStreamServer } from "../startHTTPStreamServer.js";
 import { proxyServer } from "../proxyServer.js";
-import { InMemoryEventStore } from "../inMemoryEventStore.js";
+import { InMemoryEventStore } from "../InMemoryEventStore.js";
 
 util.inspect.defaultOptions.depth = 8;
 

src/index.ts

@@ -1,4 +1,5 @@
-export { tapTransport } from "./tapTransport.js";
+export { InMemoryEventStore } from "./InMemoryEventStore.js";
 export { proxyServer } from "./proxyServer.js";
-export { startSSEServer } from "./startSSEServer.js";
 export { startHTTPStreamServer } from "./startHTTPStreamServer.js";
+export { startSSEServer } from "./startSSEServer.js";
+export { tapTransport } from "./tapTransport.js";

src/startHTTPStreamServer.ts

@@ -6,7 +6,7 @@ import { randomUUID } from "node:crypto";
 import http from "http";
 import { Server } from "@modelcontextprotocol/sdk/server/index.js";
 import { isInitializeRequest } from "@modelcontextprotocol/sdk/types.js";
-import { InMemoryEventStore } from "./inMemoryEventStore.js";
+import { InMemoryEventStore } from "./InMemoryEventStore.js";
 
 export type SSEServer = {
   close: () => Promise<void>;