path: root/mapperx/src/main.cpp

#include <tinyxml2.h>
#include <atomic>
#include <boost/algorithm/string/predicate.hpp>
#include <boost/container/flat_map.hpp>
#include <boost/container/flat_set.hpp>
#include <chrono>
#include <iomanip>
#include <iostream>
#include <sdbusplus/asio/connection.hpp>
#include <sdbusplus/asio/object_server.hpp>

// interface map type is the underlying datastructure the mapper uses.
// The 3 levels of map are
// object paths
//   connection names
//      interface names
using interface_map_type = boost::container::flat_map<
    std::string, boost::container::flat_map<
                     std::string, boost::container::flat_set<std::string>>>;

struct InProgressIntrospect
{
    std::string process_name;
    std::chrono::time_point<std::chrono::steady_clock> process_start_time;
    std::shared_ptr<std::chrono::time_point<std::chrono::steady_clock>>
        global_start_time;
};

struct cmp_str
{
    bool operator()(const char* a, const char* b) const
    {
        return std::strcmp(a, b) < 0;
    }
};

static const boost::container::flat_set<const char*, cmp_str>
    ignored_interfaces{"org.freedesktop.DBus.Introspectable",
                       "org.freedesktop.DBus.Peer",
                       "org.freedesktop.DBus.Properties"};

inline bool should_scan_dbus_interface(const std::string& process_name)
{
    return boost::starts_with(process_name, "xyz.openbmc_project.") ||
           boost::starts_with(process_name, "org.openbmc.") ||
           boost::starts_with(process_name, "com.intel.");
}

void do_introspect(sdbusplus::asio::connection* system_bus,
                   std::shared_ptr<InProgressIntrospect> transaction,
                   interface_map_type& interface_map, std::string path)
{
    system_bus->async_method_call(
        [&, transaction, path, system_bus](const boost::system::error_code ec,
                                           const std::string& introspect_xml) {
            if (ec)
            {
                std::cerr << "Introspect call failed with error: "
                          << ec.message()
                          << " on process: " << transaction->process_name
                          << " path: " << path << "\n";
            }
            else
            {
                tinyxml2::XMLDocument doc;

                doc.Parse(introspect_xml.c_str());
                tinyxml2::XMLNode* pRoot = doc.FirstChildElement("node");
                if (pRoot == nullptr)
                {
                    std::cerr << "XML document did not contain any data\n";
                }
                else
                {
                    tinyxml2::XMLElement* pElement =
                        pRoot->FirstChildElement("node");
                    while (pElement != nullptr)
                    {
                        std::string child_path = pElement->Attribute("name");
                        if (child_path.empty())
                        {
                            continue;
                        }
                        else
                        {
                            std::string parent_path(path);
                            if (parent_path == "/")
                            {
                                parent_path.clear();
                            }
                            do_introspect(system_bus, transaction,
                                          interface_map,
                                          parent_path + "/" + child_path);
                        }
                        pElement = pElement->NextSiblingElement("node");
                    }

                    pElement = pRoot->FirstChildElement("interface");
                    while (pElement != nullptr)
                    {
                        std::string iface_name = pElement->Attribute("name");
                        if (iface_name.empty())
                        {
                            continue;
                        }
                        else
                        {
                            if (ignored_interfaces.find(iface_name.c_str()) ==
                                ignored_interfaces.end())
                            {
                                interface_map[path][transaction->process_name]
                                    .emplace(iface_name);
                            }
                            if (iface_name ==
                                "xyz.openbmc_project.Associations")
                            {
                                // get association
                            }
                        }
                        pElement = pElement->NextSiblingElement("interface");
                    }
                }
            }
            // if we're the last outstanding caller for this process
            if (transaction.use_count() == 1)
            {
                // TODO(ed) This signal doesn't get exposed properly in the
                // introspect right now.  Find out how to register signals in
                // sdbusplus
                sdbusplus::message::message m = system_bus->new_signal(
                    "/xyz/openbmc_project/object_mapper",
                    "xyz.openbmc_project.ObjectMapper.Private",
                    "IntrospectionComplete");
                m.append(transaction->process_name);
                system_bus->call_noreply(m);
                std::chrono::duration<float> diff =
                    std::chrono::steady_clock::now() -
                    *transaction->global_start_time;
                std::cout << std::setw(40) << transaction->process_name
                          << " scan took " << diff.count() << " seconds\n";

                // If we're the last outstanding caller globally, calculate the
                // time it took
                if (transaction->global_start_time.use_count() == 1)
                {
                    diff = std::chrono::steady_clock::now() -
                           *transaction->global_start_time;
                    std::cout << "Total scan took " << diff.count()
                              << " seconds to complete\n";
                }
            }
        },
        transaction->process_name, path, "org.freedesktop.DBus.Introspectable",
        "Introspect");
}

void start_new_introspect(
    sdbusplus::asio::connection* system_bus, interface_map_type& interface_map,
    const std::string& process_name,
    std::shared_ptr<std::chrono::time_point<std::chrono::steady_clock>>
        global_start_time)
{
    auto transaction =
        std::make_shared<InProgressIntrospect>(InProgressIntrospect{
            process_name, std::chrono::steady_clock::now(), global_start_time});
    do_introspect(system_bus, transaction, interface_map, "/");
}

template <class InputIt1, class InputIt2>
bool intersect(InputIt1 first1, InputIt1 last1, InputIt2 first2, InputIt2 last2)
{
    while (first1 != last1 && first2 != last2)
    {
        if (*first1 < *first2)
        {
            ++first1;
            continue;
        }
        if (*first2 < *first1)
        {
            ++first2;
            continue;
        }
        return true;
    }
    return false;
}

int main(int argc, char** argv)
{
    boost::asio::io_service io;
    auto system_bus = std::make_shared<sdbusplus::asio::connection>(io);
    system_bus->request_name("xyz.openbmc_project.ObjectMapperX");

    interface_map_type interface_map;

    std::function<void(sdbusplus::message::message & message)>
        nameChangeHandler = [&](sdbusplus::message::message& message) {
            std::string name;
            std::string old_owner;
            std::string new_owner;

            message.read(name, old_owner, new_owner);

            if (!new_owner.empty())
            {
                auto transaction = std::make_shared<
                    std::chrono::time_point<std::chrono::steady_clock>>(
                    std::chrono::steady_clock::now());
                if (should_scan_dbus_interface(new_owner))
                {
                    // New daemon added
                    start_new_introspect(system_bus.get(), interface_map,
                                         new_owner, transaction);
                }
            }
            if (!old_owner.empty())
            {
                // Connection removed
                interface_map_type::iterator path_it = interface_map.begin();
                while (path_it != interface_map.end())
                {
                    auto connection_it = path_it->second.find(old_owner);
                    if (connection_it != path_it->second.end())
                    {
                        if (connection_it->first == old_owner)
                        {
                            path_it->second.erase(connection_it);
                            break;
                        }
                    }
                    if (path_it->second.empty())
                    {
                        // If the last connection to the object is gone, delete
                        // the top level object
                        path_it = interface_map.erase(path_it);
                        continue;
                    }
                    path_it++;
                }
            }
            else
            {
                std::cerr << "ERROR: both new path and old path are empty";
            }
        };

    sdbusplus::bus::match::match nameOwnerChanged(
        *system_bus, sdbusplus::bus::match::rules::nameOwnerChanged(),
        nameChangeHandler);

    std::function<void(sdbusplus::message::message & message)>
        interfacesAddedHandler = [&](sdbusplus::message::message& message) {
            sdbusplus::message::object_path obj_path;
            std::vector<
                std::pair<std::string,
                          std::vector<std::pair<
                              std::string, sdbusplus::message::variant<bool>>>>>
                interfaces_added;
            message.read(obj_path, interfaces_added);
            const std::string& obj_str =
                static_cast<const std::string&>(obj_path);
            auto iface_list = interface_map[obj_str];
            for (const std::pair<
                     std::string,
                     std::vector<std::pair<std::string,
                                           sdbusplus::message::variant<bool>>>>&
                     interface_pair : interfaces_added)
            {
                iface_list[interface_pair.first].emplace(message.get_sender());
            }
        };

    sdbusplus::bus::match::match interfacesAdded(
        *system_bus, sdbusplus::bus::match::rules::interfacesAdded(),
        interfacesAddedHandler);

    std::function<void(sdbusplus::message::message & message)>
        interfacesRemovedHandler = [&](sdbusplus::message::message& message) {
            sdbusplus::message::object_path obj_path;
            std::vector<std::string> interfaces_removed;
            message.read(obj_path, interfaces_removed);
            const std::string& object_path_str =
                static_cast<const std::string&>(obj_path);
            auto connection_map = interface_map.find(object_path_str);
            if (connection_map == interface_map.end())
            {
                std::cerr << "Unable to find " << object_path_str
                          << " in map\n";
                return;
            }

            const std::string sender = std::string(message.get_sender());

            for (const std::string& interface : interfaces_removed)
            {
                auto interface_set = connection_map->second.find(sender);
                if (interface_set == connection_map->second.end())
                {
                    std::cerr << "Unable to find " << sender << " in map for "
                              << interface << "\n";
                    continue;
                }

                interface_set->second.erase(interface);
                // If this was the last interface on this connection, erase the
                // connection
                if (interface_set->second.empty())
                {
                    connection_map->second.erase(interface_set);
                }
            }
            // If this was the last connection on this object path, erase the
            // object path
            if (connection_map->second.empty())
            {
                interface_map.erase(connection_map);
            }
        };

    sdbusplus::bus::match::match interfacesRemoved(
        *system_bus, sdbusplus::bus::match::rules::interfacesRemoved(),
        interfacesRemovedHandler);

    // Set up the object server, and send some objects
    auto server = sdbusplus::asio::object_server(system_bus);

    std::shared_ptr<sdbusplus::asio::dbus_interface> iface =
        server.add_interface("/xyz/openbmc_project/object_mapper",
                             "xyz.openbmc_project.ObjectMapper");

    iface->register_method(
        "GetAncestors",
        [&](const std::string& req_path, std::vector<std::string>& interfaces) {

            std::sort(interfaces.begin(), interfaces.end());

            std::vector<interface_map_type::value_type> ret;
            for (auto& object_path : interface_map)
            {
                auto& this_path = object_path.first;
                bool add = interfaces.empty();
                if (boost::starts_with(req_path, this_path))
                {
                    for (auto& interface_map : object_path.second)
                    {
                        add = intersect(interfaces.begin(), interfaces.end(),
                                        interface_map.second.begin(),
                                        interface_map.second.end());
                        if (add)
                        {
                            break;
                        }
                    }
                    if (add)
                    {
                        // THis makes a copy.  TODO(ed) make sdbusplus allow
                        // vectors of pointers so that this doesn't need to copy
                        // all strings
                        ret.emplace_back(object_path);
                    }
                }
            }

            return ret;
        });

    iface->register_method(
        "GetObject",
        [&](const std::string& path, std::vector<std::string>& interfaces) {
            std::sort(interfaces.begin(), interfaces.end());
            auto path_ref = interface_map.find(path);
            bool add = false;
            if (path_ref != interface_map.end())
            {
                add = interfaces.empty();
                for (auto& interface_map : path_ref->second)
                {
                    if (intersect(interfaces.begin(), interfaces.end(),
                                  interface_map.second.begin(),
                                  interface_map.second.end()))
                    {
                        add = true;
                        break;
                    }
                }
            }
            if (add)
            {
                return path_ref->second;
            }
            return decltype(path_ref->second){};
        });

    iface->register_method(
        "GetSubTree", [&](const std::string& req_path, int32_t depth,
                          std::vector<std::string>& interfaces) {
            std::sort(interfaces.begin(), interfaces.end());
            std::vector<interface_map_type::value_type> ret;

            for (auto& object_path : interface_map)
            {
                auto& this_path = object_path.first;
                if (boost::starts_with(this_path, req_path))
                {
                    // count the number of slashes past the search term
                    auto this_depth =
                        std::count(this_path.begin() + req_path.size(),
                                   this_path.end(), '/');
                    if (this_depth <= depth)
                    {
                        bool add = interfaces.empty();
                        for (auto& interface_map : object_path.second)
                        {
                            if (intersect(interfaces.begin(), interfaces.end(),
                                          interface_map.second.begin(),
                                          interface_map.second.end()))
                            {
                                add = true;
                                break;
                            }
                        }
                        if (add)
                        {
                            // todo(ed) this is a copy
                            ret.emplace_back(object_path);
                        }
                    }
                }
            }
            return ret;
        });
    iface->register_method(
        "GetSubTreePaths", [&](const std::string& req_path, int32_t depth,
                               const std::vector<std::string>& interfaces) {
            std::vector<std::string> ret;
            for (auto& object_path : interface_map)
            {
                auto& this_path = object_path.first;
                if (boost::starts_with(this_path, req_path))
                {
                    // count the number of slashes past the search term
                    auto this_depth =
                        std::count(this_path.begin() + req_path.size(),
                                   this_path.end(), '/');
                    if (this_depth <= depth)
                    {
                        bool add = interfaces.empty();
                        for (auto& interface_map : object_path.second)
                        {
                            if (intersect(interfaces.begin(), interfaces.end(),
                                          interface_map.second.begin(),
                                          interface_map.second.end()))
                            {
                                add = true;
                                break;
                            }
                        }
                        if (add)
                        {
                            // TODO(ed) this is a copy
                            ret.emplace_back(this_path);
                        }
                    }
                }
            }

            return ret;
        });
    iface->initialize();

    // This needs to be done after our io_service is in run, so that the match
    // creation and name reqest happen before we start introspecting.
    io.post([&]() {
        system_bus->async_method_call(
            [&](const boost::system::error_code ec,
                const std::vector<std::string>& process_names) {
                if (ec)
                {
                    std::cerr << "error getting names: " << ec << "\n";
                }
                else
                {
                    auto global_start_time = std::make_shared<
                        std::chrono::time_point<std::chrono::steady_clock>>(
                        std::chrono::steady_clock::now());

                    for (const std::string& process_name : process_names)
                    {
                        if (should_scan_dbus_interface(process_name))
                        {
                            start_new_introspect(system_bus.get(),
                                                 interface_map, process_name,
                                                 global_start_time);
                        }
                    }
                }
            },
            "org.freedesktop.DBus", "/", "org.freedesktop.DBus", "ListNames");
    });
    io.run();
}