get_query_parser.hpp

#pragma once
#include <ossia/detail/small_vector.hpp>
#include <ossia/detail/string_map.hpp>
#include <ossia/network/exceptions.hpp>
#include <ossia/network/oscquery/detail/html_writer.hpp>
#include <ossia/network/oscquery/detail/json_writer.hpp>
#include <ossia/network/oscquery/detail/outbound_visitor.hpp>
#include <ossia/network/oscquery/oscquery_client.hpp>
#include <ossia/network/oscquery/oscquery_server.hpp>
 
namespace ossia
{
namespace net
{
struct parameter_data;
}
namespace oscquery
{
 
class get_query_answerer
{
public:
  template <typename OscqueryProtocol>
  static json_writer::string_t handle_listen(
      OscqueryProtocol& proto, const oscquery_server_protocol::connection_handler& hdl,
      ossia::net::node_base& node, std::string_view path, const std::string& listen_text)
  {
    // First we find for a corresponding client
    auto clt = proto.find_client(hdl);
 
    if(clt)
    {
      // Then we enable / disable listening
      if(listen_text == detail::text_true())
      {
        clt->start_listen(std::string(path), node.get_parameter());
        return {};
      }
      else if(listen_text == detail::text_false())
      {
        clt->stop_listen(std::string(path));
        return {};
      }
      else
      {
        throw bad_request_error{"Wrong arguments to listen query: " + listen_text};
        return {};
      }
    }
    else
    {
      throw bad_request_error{"Client not found"};
      return {};
    }
  }
 
  template <typename OscqueryProtocol>
  auto operator()(
      OscqueryProtocol& proto, const oscquery_server_protocol::connection_handler& hdl)
  {
    return [&proto, &hdl](
               std::string_view path,
               string_map<std::string>&& parameters) -> ossia::net::server_reply {
      // Here we handle the url elements relative to oscquery
      if(parameters.size() == 0)
      {
        auto& root = proto.get_device().get_root_node();
        if(path == "/")
        {
          return oscquery::json_writer::query_namespace(root);
        }
        else
        {
          auto node = ossia::net::find_node(root, path);
          if(node)
            return oscquery::json_writer::query_namespace(*node);
          else
            throw node_not_found_error{std::string(path)};
        }
      }
      else
      {
        auto host_it = parameters.find("HOST_INFO");
        if(host_it == parameters.end())
        {
          auto node = ossia::net::find_node(proto.get_device().get_root_node(), path);
          // First check if we have the path
          if(!node)
            throw node_not_found_error{std::string(path)};
 
          // LISTEN
          auto listen_it = parameters.find(detail::listen());
          if(listen_it != parameters.end())
          {
            return handle_listen(proto, hdl, *node, path, listen_it->second);
          }
 
          // HTML
          auto html_it = parameters.find("HTML");
          if(html_it != parameters.end())
          {
            return static_html_builder{}.build_tree(*node);
          }
 
          // ADD_NODE
          auto add_instance_it = parameters.find(detail::add_node());
          if(add_instance_it != parameters.end())
          {
            proto.add_node(path, std::move(parameters));
            return {};
          }
 
          // REMOVE_NODE
          auto rm_instance_it = parameters.find(detail::remove_node());
          if(rm_instance_it != parameters.end())
          {
            // Value is the child to remove
            proto.remove_node(path, rm_instance_it->second);
            return {};
          }
 
          // RENAME_NODE
          auto rn_instance_it = parameters.find(detail::rename_node());
          if(rn_instance_it != parameters.end())
          {
            // Value is the child to remove
            proto.rename_node(path, rn_instance_it->second);
            return {};
          }
 
          // All the value-less parameters
          ossia::small_vector<std::string, 5> attributes;
          for(const auto& elt : parameters)
          {
            if(elt.second.empty())
            {
              attributes.push_back(elt.first);
            }
          }
 
          if(!attributes.empty())
          {
            return oscquery::json_writer::query_attributes(*node, attributes);
          }
        }
        else
        {
          websocketpp::connection<websocketpp::config::asio>& sockets
              = *proto.m_websocketServer->impl().get_con_from_hdl(hdl);
          auto& socket = sockets.get_socket();
 
          std::string local_client_ip = socket.local_endpoint().address().to_string();
 
          auto transports = [&]() -> std::vector<ossia::net::osc_server_configuration> {
            if constexpr(requires { proto.get_osc_port(); })
            {
              ossia::net::udp_server_configuration conf;
              conf.bind = "0.0.0.0";
              conf.port = proto.get_osc_port();
              return {conf};
            }
            else
            {
              return proto.get_transports();
            }
          };
 
          return oscquery::json_writer::query_host_info(
              proto.get_device().get_name(), transports(), local_client_ip,
              proto.get_ws_port());
        }
      }
      return {};
    };
  }
};
}
}