meMCP - Memory-Enhanced Model Context Protocol

Implementation Reference

• src/tools/modules/MemoryStreamingTools.js:117-135 (registration)

  Registers the 'memory_stream_pause' tool with input schema requiring streamId and delegates to handleStreamPause handler.

  registerStreamPauseTool(server) {
    server.registerTool(
      'memory_stream_pause',
      'Pause an active streaming query',
      {
        type: 'object',
        properties: {
          streamId: {
            type: 'string',
            description: 'The stream ID to pause',
          },
        },
        required: ['streamId'],
      },
      async (args) => {
        return await this.handleStreamPause(args);
      }
    );
  }

• src/tools/modules/MemoryStreamingTools.js:287-317 (handler)

  Tool handler that calls StreamingManager.pauseStream(streamId) and formats the success/error response.

  async handleStreamPause(args) {
    try {
      const result = await this.streamingManager.pauseStream(args.streamId);
      
      return {
        content: [
          {
            type: 'text',
            text: JSON.stringify({
              success: true,
              streamId: args.streamId,
              status: result.status,
              message: 'Stream paused successfully',
            }),
          },
        ],
      };
    } catch (error) {
      return {
        content: [
          {
            type: 'text',
            text: JSON.stringify({
              success: false,
              error: error.message,
            }),
          },
        ],
        isError: true,
      };
    }

• src/streaming/StreamingManager.js:167-188 (helper)

  Core pause logic: validates stream exists and is active, sets status to 'paused', records pause time, returns status.

  async pauseStream(streamId) {
    const stream = this.activeStreams.get(streamId);
    if (!stream) {
      throw new Error(`Stream ${streamId} not found`);
    }
  
    if (stream.status !== 'active') {
      throw new Error(`Stream ${streamId} is not active`);
    }
  
    stream.status = 'paused';
    stream.pausedAt = Date.now();
  
    return {
      streamId,
      status: 'paused',
      progress: {
        current: stream.currentIndex,
        total: stream.totalFacts,
      },
    };
  }