Method Run

example/redis_c++/redis_server.cpp:174–194

    explicit AuthCommandHandler(RedisServiceImpl* rsimpl)
        : _rsimpl(rsimpl) {}
    brpc::RedisCommandHandlerResult Run(brpc::RedisConnContext* ctx, 
                                        const std::vector<butil::StringPiece>& args,
                                        brpc::RedisReply* output,
                                        bool /*flush_batched*/) override {
        if (args.size() != 3ul) {
            output->FormatError("Expect 2 args for 'auth', actually %lu", args.size()-1);
            return brpc::REDIS_CMD_HANDLED;
        }
        
        const std::string db_name(args[1].data(), args[1].size());
        const std::string password(args[2].data(), args[2].size());
        
        if (_rsimpl->Auth(db_name, password)) {
            output->SetStatus("OK");
            auto auth_session = new AuthSession(db_name, password);
            ctx->reset_session(auth_session);
        } else {
            output->FormatError("Invalid password for database '%s'", db_name.c_str());
        }
        return brpc::REDIS_CMD_HANDLED;
    }

private:
    RedisServiceImpl* _rsimpl;