#pragma once #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include namespace DB { /// Позволяет проверить соответствие адреса шаблону. class IAddressPattern { public: virtual bool contains(const Poco::Net::IPAddress & addr) const = 0; virtual ~IAddressPattern() {} static Poco::Net::IPAddress toIPv6(const Poco::Net::IPAddress addr) { if (addr.family() == Poco::Net::IPAddress::IPv6) return addr; return Poco::Net::IPAddress("::FFFF:" + addr.toString()); } }; /// IP-адрес или маска подсети. Например, 213.180.204.3 или 10.0.0.1/8 или 2a02:6b8::3 или 2a02:6b8::3/64. class IPAddressPattern : public IAddressPattern { private: /// Адрес маски. Всегда переводится в IPv6. Poco::Net::IPAddress mask_address; /// Количество бит в маске. UInt8 prefix_bits; public: explicit IPAddressPattern(const String & str) { const char * pos = strchr(str.c_str(), '/'); if (nullptr == pos) { construct(Poco::Net::IPAddress(str)); } else { String addr(str, 0, pos - str.c_str()); UInt8 prefix_bits_ = parse(pos + 1); construct(Poco::Net::IPAddress(addr), prefix_bits_); } } bool contains(const Poco::Net::IPAddress & addr) const { return prefixBitsEquals(reinterpret_cast(toIPv6(addr).addr()), reinterpret_cast(mask_address.addr()), prefix_bits); } private: void construct(const Poco::Net::IPAddress & mask_address_) { mask_address = toIPv6(mask_address_); prefix_bits = 128; } void construct(const Poco::Net::IPAddress & mask_address_, UInt8 prefix_bits_) { mask_address = toIPv6(mask_address_); prefix_bits = mask_address_.family() == Poco::Net::IPAddress::IPv4 ? prefix_bits_ + 96 : prefix_bits_; } static bool prefixBitsEquals(const char * lhs, const char * rhs, UInt8 prefix_bits) { UInt8 prefix_bytes = prefix_bits / 8; UInt8 remaining_bits = prefix_bits % 8; return 0 == memcmp(lhs, rhs, prefix_bytes) && (remaining_bits % 8 == 0 || (lhs[prefix_bytes] >> (8 - remaining_bits)) == (rhs[prefix_bytes] >> (8 - remaining_bits))); } }; /// Проверяет соответствие адреса одному из адресов хоста. class HostExactPattern : public IAddressPattern { private: String host; static bool containsImpl(const String & host, const Poco::Net::IPAddress & addr) { Poco::Net::IPAddress addr_v6 = toIPv6(addr); /// Резолвим вручную, потому что в Poco не используется флаг AI_ALL, а он важен. addrinfo * ai = nullptr; addrinfo hints; memset(&hints, 0, sizeof(hints)); hints.ai_family = AF_UNSPEC; hints.ai_flags |= AI_V4MAPPED | AI_ALL; int ret = getaddrinfo(host.c_str(), nullptr, &hints, &ai); if (0 != ret) throw Exception("Cannot getaddrinfo: " + std::string(gai_strerror(ret)), ErrorCodes::DNS_ERROR); try { for (; ai != nullptr; ai = ai->ai_next) { if (ai->ai_addrlen && ai->ai_addr) { if (ai->ai_family == AF_INET6) { if (addr_v6 == Poco::Net::IPAddress( &reinterpret_cast(ai->ai_addr)->sin6_addr, sizeof(in6_addr), reinterpret_cast(ai->ai_addr)->sin6_scope_id)) { return true; } } else if (ai->ai_family == AF_INET) { if (addr_v6 == toIPv6(Poco::Net::IPAddress( &reinterpret_cast(ai->ai_addr)->sin_addr, sizeof(in_addr)))) { return true; } } } } } catch (...) { freeaddrinfo(ai); throw; } freeaddrinfo(ai); return false; } public: HostExactPattern(const String & host_) : host(host_) {} bool contains(const Poco::Net::IPAddress & addr) const { static SimpleCache cache; return cache(host, addr); } }; /// Проверяет соответствие PTR-записи для адреса регекспу (и дополнительно проверяет, что PTR-запись резолвится обратно в адрес клиента). class HostRegexpPattern : public IAddressPattern { private: Poco::RegularExpression host_regexp; static String getDomain(const Poco::Net::IPAddress & addr) { Poco::Net::SocketAddress sock_addr(addr, 0); /// Резолвим вручную, потому что в Poco нет такой функциональности. char domain[1024]; int gai_errno = getnameinfo(sock_addr.addr(), sock_addr.length(), domain, sizeof(domain), nullptr, 0, NI_NAMEREQD); if (0 != gai_errno) throw Exception("Cannot getnameinfo: " + std::string(gai_strerror(gai_errno)), ErrorCodes::DNS_ERROR); return domain; } public: HostRegexpPattern(const String & host_regexp_) : host_regexp(host_regexp_) {} bool contains(const Poco::Net::IPAddress & addr) const { static SimpleCache cache; String domain = cache(addr); Poco::RegularExpression::Match match; if (host_regexp.match(domain, match) && HostExactPattern(domain).contains(addr)) return true; return false; } }; class AddressPatterns { private: typedef std::vector> Container; Container patterns; public: bool contains(const Poco::Net::IPAddress & addr) const { for (size_t i = 0, size = patterns.size(); i < size; ++i) { /// если хост не резолвится, то пропустим его и попробуем другой try { if (patterns[i]->contains(addr)) return true; } catch (const DB::Exception & e) { LOG_WARNING(&Logger::get("AddressPatterns"), "Failed to check if pattern contains address " << addr.toString() << ". " << e.displayText() << ", code = " << e.code()); if (e.code() == ErrorCodes::DNS_ERROR) { continue; } else throw; } } return false; } void addFromConfig(const String & config_elem, Poco::Util::AbstractConfiguration & config) { Poco::Util::AbstractConfiguration::Keys config_keys; config.keys(config_elem, config_keys); for (Poco::Util::AbstractConfiguration::Keys::const_iterator it = config_keys.begin(); it != config_keys.end(); ++it) { Container::value_type pattern; String value = config.getString(config_elem + "." + *it); if (0 == it->compare(0, strlen("ip"), "ip")) pattern.reset(new IPAddressPattern(value)); else if (0 == it->compare(0, strlen("host_regexp"), "host_regexp")) pattern.reset(new HostRegexpPattern(value)); else if (0 == it->compare(0, strlen("host"), "host")) pattern.reset(new HostExactPattern(value)); else throw Exception("Unknown address pattern type: " + *it, ErrorCodes::UNKNOWN_ADDRESS_PATTERN_TYPE); patterns.emplace_back(std::move(pattern)); } } }; /** Пользователь и ACL. */ struct User { String name; /// Требуемый пароль. Может храниться либо в открытом виде, либо в виде SHA256. String password; String password_sha256_hex; String profile; String quota; AddressPatterns addresses; /// Список разрешённых баз данных. using DatabaseSet = std::unordered_set; DatabaseSet databases; User(const String & name_, const String & config_elem, Poco::Util::AbstractConfiguration & config) : name(name_) { bool has_password = config.has(config_elem + ".password"); bool has_password_sha256_hex = config.has(config_elem + ".password_sha256_hex"); if (has_password && has_password_sha256_hex) throw Exception("Both fields 'password' and 'password_sha256_hex' are specified for user " + name + ". Must be only one of them.", ErrorCodes::BAD_ARGUMENTS); if (!has_password && !has_password_sha256_hex) throw Exception("Either 'password' or 'password_sha256_hex' must be specified for user " + name + ".", ErrorCodes::BAD_ARGUMENTS); if (has_password) password = config.getString(config_elem + ".password"); if (has_password_sha256_hex) { password_sha256_hex = Poco::toLower(config.getString(config_elem + ".password_sha256_hex")); if (password_sha256_hex.size() != 64) throw Exception("password_sha256_hex for user " + name + " has length " + toString(password_sha256_hex.size()) + " but must be exactly 64 symbols.", ErrorCodes::BAD_ARGUMENTS); } profile = config.getString(config_elem + ".profile"); quota = config.getString(config_elem + ".quota"); addresses.addFromConfig(config_elem + ".networks", config); /// Заполнить список разрешённых баз данных. const auto config_sub_elem = config_elem + ".allow_databases"; if (config.has(config_sub_elem)) { Poco::Util::AbstractConfiguration::Keys config_keys; config.keys(config_sub_elem, config_keys); databases.reserve(config_keys.size()); for (const auto & key : config_keys) { const auto database_name = config.getString(config_sub_elem + "." + key); databases.insert(database_name); } } } /// Для вставки в контейнер. User() {} }; /// Известные пользователи. class Users { private: typedef std::map Container; Container cont; public: void loadFromConfig(Poco::Util::AbstractConfiguration & config) { cont.clear(); Poco::Util::AbstractConfiguration::Keys config_keys; config.keys("users", config_keys); for (Poco::Util::AbstractConfiguration::Keys::const_iterator it = config_keys.begin(); it != config_keys.end(); ++it) cont[*it] = User(*it, "users." + *it, config); } const User & get(const String & name, const String & password, const Poco::Net::IPAddress & address) const { Container::const_iterator it = cont.find(name); if (cont.end() == it) throw Exception("Unknown user " + name, ErrorCodes::UNKNOWN_USER); if (!it->second.addresses.contains(address)) throw Exception("User " + name + " is not allowed to connect from address " + address.toString(), ErrorCodes::IP_ADDRESS_NOT_ALLOWED); auto on_wrong_password = [&]() { if (password.empty()) throw Exception("Password required for user " + name, ErrorCodes::REQUIRED_PASSWORD); else throw Exception("Wrong password for user " + name, ErrorCodes::WRONG_PASSWORD); }; if (!it->second.password_sha256_hex.empty()) { unsigned char hash[32]; SHA256_CTX ctx; SHA256_Init(&ctx); SHA256_Update(&ctx, reinterpret_cast(password.data()), password.size()); SHA256_Final(hash, &ctx); String hash_hex; { WriteBufferFromString buf(hash_hex); HexWriteBuffer hex_buf(buf); hex_buf.write(reinterpret_cast(hash), sizeof(hash)); } Poco::toLowerInPlace(hash_hex); if (hash_hex != it->second.password_sha256_hex) on_wrong_password(); } else if (password != it->second.password) { on_wrong_password(); } return it->second; } /// Проверить, имеет ли заданный клиент доступ к заданной базе данных. bool isAllowedDatabase(const std::string & user_name, const std::string & database_name) const { auto it = cont.find(user_name); if (it == cont.end()) throw Exception("Unknown user " + user_name, ErrorCodes::UNKNOWN_USER); const auto & user = it->second; return user.databases.empty() || user.databases.count(database_name); } }; }