meMCP - Memory-Enhanced Model Context Protocol

Implementation Reference

• src/tools/modules/MemoryQueryHandler.js:60-82 (registration)

  Registers the 'memory_bulk_process' tool on the server, defining its schema and linking to the handleBulkProcess handler.

  registerBulkProcessTool(server) {
    server.registerTool(
      'memory_bulk_process',
      'Process multiple insights or sequential thinking data at once',
      {
        type: 'object',
        properties: {
          data: {
            type: 'array',
            description: 'Array of insights or sequential thinking data to process',
          },
          context: {
            type: 'object',
            description: 'Shared context for all items being processed',
          },
        },
        required: ['data'],
      },
      async (args) => {
        return await this.handleBulkProcess(args);
      }
    );
  }

• src/tools/modules/MemoryQueryHandler.js:64-77 (schema)

  JSON schema defining the input parameters for the 'memory_bulk_process' tool: required 'data' array and optional 'context' object.

  {
    type: 'object',
    properties: {
      data: {
        type: 'array',
        description: 'Array of insights or sequential thinking data to process',
      },
      context: {
        type: 'object',
        description: 'Shared context for all items being processed',
      },
    },
    required: ['data'],
  },

• src/tools/modules/MemoryQueryHandler.js:146-175 (handler)

  Executes the core logic of the 'memory_bulk_process' tool by delegating to the injected processor's processSequentialThinking method, formatting results or handling errors.

  async handleBulkProcess(args) {
    try {
      const { data, context = {} } = args;
      
      if (!this.processor) {
        throw new Error('Sequential thinking processor not available');
      }
      
      const result = await this.processor.processSequentialThinking(data, context);
      
      return {
        content: [
          {
            type: 'text',
            text: `📦 **Bulk Processing Complete**\n\n**Processed:** ${result.processed}/${result.total} facts\n\n${result.facts.map(f => `- ${f.type}: ${f.content.substring(0, 60)}...`).join('\n')}`,
          },
        ],
      };
    } catch (error) {
      return {
        content: [
          {
            type: 'text',
            text: `Error bulk processing: ${error.message}`,
          },
        ],
        isError: true,
      };
    }
  }