Method Execute

src/commands/cmd_script.cc:66–108

  }

  Status Execute([[maybe_unused]] engine::Context &ctx, Server *srv, [[maybe_unused]] Connection *conn,
                 std::string *output) override {
    // There's a little tricky here since the script command was the write type
    // command but some subcommands like `exists` were readonly, so we want to allow
    // executing on slave here. Maybe we should find other way to do this.
    if (srv->IsSlave() && subcommand_ != "exists") {
      return {Status::RedisReadOnly, "You can't write against a read only slave"};
    }

    if (args_.size() == 2 && subcommand_ == "flush") {
      auto s = srv->ScriptFlush();
      if (!s) {
        ERROR("Failed to flush scripts: {}", s.Msg());
        return s;
      }
      s = srv->Propagate(engine::kPropagateScriptCommand, args_);
      if (!s) {
        ERROR("Failed to propagate script command: {}", s.Msg());
        return s;
      }
      *output = redis::RESP_OK;
    } else if (args_.size() >= 3 && subcommand_ == "exists") {
      *output = redis::MultiLen(args_.size() - 2);
      for (size_t j = 2; j < args_.size(); j++) {
        if (srv->ScriptExists(args_[j]).IsOK()) {
          *output += redis::Integer(1);
        } else {
          *output += redis::Integer(0);
        }
      }
    } else if (args_.size() == 3 && subcommand_ == "load") {
      std::string sha;
      auto s = lua::CreateFunction(srv, args_[2], &sha, conn->Owner()->Lua(), true);
      if (!s.IsOK()) {
        return s;
      }

      *output = redis::BulkString(sha);
    } else {
      return {Status::NotOK, "Unknown SCRIPT subcommand or wrong number of arguments"};
    }
    return Status::OK();
  }

 private:
  std::string subcommand_;