Redis MCP

Instructions

Implementation Reference

• src/services/mcpService.ts:1143-1155 (handler)

  The main handler function for the zset_add MCP tool. Ensures Redis connection and calls the underlying RedisService.zadd method, returning the result as MCP content.

  private async handleZsetAdd(args: any) {
    this.ensureRedisConnection();
    const result = await this.redisService!.zadd(args.key, args.members);
    
    return {
      content: [
        {
          type: 'text',
          text: JSON.stringify(result, null, 2)
        }
      ]
    };
  }

• src/services/mcpService.ts:411-442 (schema)

  Input schema definition for the zset_add tool, specifying key (string) and members (single object {member: string, score: number} or array thereof).

  inputSchema: {
    type: 'object',
    properties: {
      key: { type: 'string', description: '有序集合键名' },
      members: {
        oneOf: [
          {
            type: 'object',
            properties: {
              member: { type: 'string', description: '成员' },
              score: { type: 'number', description: '分数' }
            },
            required: ['member', 'score'],
            description: '单个成员'
          },
          {
            type: 'array',
            items: {
              type: 'object',
              properties: {
                member: { type: 'string', description: '成员' },
                score: { type: 'number', description: '分数' }
              },
              required: ['member', 'score']
            },
            description: '成员数组'
          }
        ],
        description: '要添加的成员或成员数组'
      }
    },
    required: ['key', 'members']

• src/services/mcpService.ts:678-679 (registration)

  Registration in the tool dispatcher switch statement within CallToolRequestHandler, routing calls to the zset_add handler.

  case 'zset_add':
    return await this.handleZsetAdd(args);

• src/services/redisService.ts:422-436 (helper)

  Helper method in RedisService that implements the ZADD Redis command, converting MCP parameters to redis client zAdd format and handling single/array inputs.

  async zadd(key: string, members: RedisSortedSetMember | RedisSortedSetMember[]): Promise<RedisOperationResult<number>> {
    return this.executeCommand(async () => {
      if (!this.client) throw new Error('Redis client not initialized');
      
      if (Array.isArray(members)) {
        const args: Array<{ score: number, value: string }> = members.map(m => ({
          score: m.score,
          value: m.member
        }));
        return await this.client.zAdd(key, args);
      } else {
        return await this.client.zAdd(key, { score: members.score, value: members.member });
      }
    });
  }