ArpwatchRequestHandler.cpp

Go to the documentation of this file.

#include <cassert>
#include <stdexcept>
 
#include <asiolink/io_address.h>
#include <dhcp/hwaddr.h>
 
#include <hiredis/hiredis.h>
 
#include "ArpwatchRequestHandler.hpp"
#include "XmlRpcServer.hpp"
#include "util/HiredisAdapter.hpp"
 
namespace
{
inline std::string get_ip2mac_key(std::string_view suffix)
{
    return "ip2mac-" + std::string{suffix};
}
 
inline std::string sanitize_ip_address_string(const std::string& ip_str)
{
    const isc::asiolink::IOAddress ip_addr{ip_str};
    return ip_addr.toText();
}
 
inline std::string sanitize_mac_address_string(const std::string& mac_str)
{
    const auto mac = isc::dhcp::HWAddr::fromText(mac_str);
    return mac.toText(false);
}
} // namespace
 
namespace aai
{
void ArpwatchRequestHandler::register_method_handlers(XmlRpcServer& xmlrpc_server)
{
    xmlrpc_server.register_method_handler(
      RpcMethodName::RESOLVE_IP_TO_MAC,
      [this](const std::string& ip) { return resolve_ip_to_mac(ip); });
}
 
std::optional<std::string> ArpwatchRequestHandler::resolve_ip_to_mac(std::string_view ip)
{
    const std::string redis_key = get_ip2mac_key(sanitize_ip_address_string(std::string{ip}));
    const auto redis_reply = redis.get(redis_key);
    assert(redis_reply);
 
    if (redis_reply->type == REDIS_REPLY_NIL) {
        return {};
    }
    if (redis_reply->type != REDIS_REPLY_STRING) {
        throw std::runtime_error("Unexpected Redis reply type");
    }
 
    assert(redis_reply->str);
    return {redis_reply->str};
}
} // namespace aai