import { EventStore } from '@modelcontextprotocol/sdk/server/streamableHttp.js'; import { JSONRPCMessage } from '@modelcontextprotocol/sdk/types.js'; /** * Copyright 2025 © BeeAI a Series of LF Projects, LLC * SPDX-License-Identifier: Apache-2.0 */ /** * Simple in-memory implementation of the EventStore interface for resumability * This is primarily intended for examples and testing, not for production use * where a persistent storage solution would be more appropriate. */ declare class InMemoryEventStore implements EventStore { private events; /** * Generates a unique event ID for a given stream ID */ private generateEventId; /** * Extracts the stream ID from an event ID */ private getStreamIdFromEventId; /** * Stores an event with a generated event ID * Implements EventStore.storeEvent */ storeEvent(streamId: string, message: JSONRPCMessage): Promise; /** * Replays events that occurred after a specific event ID * Implements EventStore.replayEventsAfter */ replayEventsAfter(lastEventId: string, { send }: { send: (eventId: string, message: JSONRPCMessage) => Promise; }): Promise; } export { InMemoryEventStore };