Add table service
This commit is contained in:
		
							parent
							
								
									fda8f6ecef
								
							
						
					
					
						commit
						944947962b
					
				
							
								
								
									
										34
									
								
								include/server/service/table_service.hpp
									
									
									
									
									
										Normal file
									
								
							
							
						
						
									
										34
									
								
								include/server/service/table_service.hpp
									
									
									
									
									
										Normal file
									
								
							@ -0,0 +1,34 @@
 | 
			
		||||
#ifndef SERVER_SERVICE_TABLE_SERVICE_HPP
 | 
			
		||||
#define SERVER_SERVICE_TABLE_SERVICE_HPP
 | 
			
		||||
 | 
			
		||||
#include "server/service/base_service.hpp"
 | 
			
		||||
 | 
			
		||||
#include "engine/status.hpp"
 | 
			
		||||
#include "util/coordinate.hpp"
 | 
			
		||||
#include "osrm/osrm.hpp"
 | 
			
		||||
 | 
			
		||||
#include <string>
 | 
			
		||||
#include <vector>
 | 
			
		||||
 | 
			
		||||
namespace osrm
 | 
			
		||||
{
 | 
			
		||||
namespace server
 | 
			
		||||
{
 | 
			
		||||
namespace service
 | 
			
		||||
{
 | 
			
		||||
 | 
			
		||||
class TableService final : public BaseService
 | 
			
		||||
{
 | 
			
		||||
  public:
 | 
			
		||||
    TableService(OSRM& routing_machine) : BaseService(routing_machine) {}
 | 
			
		||||
 | 
			
		||||
    virtual engine::Status RunQuery(std::vector<util::FixedPointCoordinate> coordinates,
 | 
			
		||||
                                    std::string &options,
 | 
			
		||||
                                    util::json::Object &json_result) final override;
 | 
			
		||||
    virtual unsigned GetVersion() final override { return 1; }
 | 
			
		||||
};
 | 
			
		||||
}
 | 
			
		||||
}
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
#endif
 | 
			
		||||
							
								
								
									
										82
									
								
								src/server/service/table_service.cpp
									
									
									
									
									
										Normal file
									
								
							
							
						
						
									
										82
									
								
								src/server/service/table_service.cpp
									
									
									
									
									
										Normal file
									
								
							@ -0,0 +1,82 @@
 | 
			
		||||
#include "server/service/table_service.hpp"
 | 
			
		||||
 | 
			
		||||
#include "engine/api/route_parameters.hpp"
 | 
			
		||||
#include "server/api/parameters_parser.hpp"
 | 
			
		||||
 | 
			
		||||
#include "util/json_container.hpp"
 | 
			
		||||
 | 
			
		||||
#include <boost/format.hpp>
 | 
			
		||||
 | 
			
		||||
namespace osrm
 | 
			
		||||
{
 | 
			
		||||
namespace server
 | 
			
		||||
{
 | 
			
		||||
namespace service
 | 
			
		||||
{
 | 
			
		||||
 | 
			
		||||
namespace {
 | 
			
		||||
 | 
			
		||||
const constexpr char PARAMETER_SIZE_MISMATCH_MSG[] = "Number of elements in %1% size %2% does not match coordinate size %3%";
 | 
			
		||||
 | 
			
		||||
template<typename ParamT>
 | 
			
		||||
bool constrainParamSize(const char* msg_template, const char* name, const ParamT& param, const std::size_t target_size, std::string& help)
 | 
			
		||||
{
 | 
			
		||||
    if (param.size() > 0 && param.size() != target_size)
 | 
			
		||||
    {
 | 
			
		||||
        help = (boost::format(msg_template) % name % param.size() % target_size).str();
 | 
			
		||||
        return true;
 | 
			
		||||
    }
 | 
			
		||||
    return false;
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
std::string getWrongOptionHelp(const engine::api::TableParameters& parameters)
 | 
			
		||||
{
 | 
			
		||||
    std::string help;
 | 
			
		||||
 | 
			
		||||
    const auto coord_size = parameters.coordinates.size();
 | 
			
		||||
 | 
			
		||||
    const bool param_size_mismatch = constrainParamSize(PARAMETER_SIZE_MISMATCH_MSG, "hints", parameters.hints, coord_size, help)
 | 
			
		||||
     || constrainParamSize(PARAMETER_SIZE_MISMATCH_MSG, "bearings", parameters.bearings, coord_size, help)
 | 
			
		||||
     || constrainParamSize(PARAMETER_SIZE_MISMATCH_MSG, "radiuses", parameters.radiuses, coord_size, help);
 | 
			
		||||
 | 
			
		||||
    if (!param_size_mismatch && parameters.coordinates.size() < 2)
 | 
			
		||||
    {
 | 
			
		||||
        help = "Number of coordinates needs to be at least two.";
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    return help;
 | 
			
		||||
}
 | 
			
		||||
} // anon. ns
 | 
			
		||||
 | 
			
		||||
engine::Status TableService::RunQuery(std::vector<util::FixedPointCoordinate> coordinates,
 | 
			
		||||
                                      std::string &options,
 | 
			
		||||
                                      util::json::Object &json_result)
 | 
			
		||||
{
 | 
			
		||||
 | 
			
		||||
    auto options_iterator = options.begin();
 | 
			
		||||
    auto parameters = api::parseParameters<engine::api::TableParameters>(options_iterator, options.end());
 | 
			
		||||
    if (!parameters || options_iterator != options.end())
 | 
			
		||||
    {
 | 
			
		||||
        const auto position = std::distance(options.begin(), options_iterator);
 | 
			
		||||
        json_result.values["code"] = "invalid-options";
 | 
			
		||||
        json_result.values["message"] =
 | 
			
		||||
            "Options string malformed close to position " + std::to_string(position);
 | 
			
		||||
        return engine::Status::Error;
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    BOOST_ASSERT(parameters);
 | 
			
		||||
    parameters->coordinates = std::move(coordinates);
 | 
			
		||||
 | 
			
		||||
    if (!parameters->IsValid())
 | 
			
		||||
    {
 | 
			
		||||
        json_result.values["code"] = "invalid-options";
 | 
			
		||||
        json_result.values["message"] = getWrongOptionHelp(*parameters);
 | 
			
		||||
        return engine::Status::Error;
 | 
			
		||||
    }
 | 
			
		||||
    BOOST_ASSERT(parameters->IsValid());
 | 
			
		||||
 | 
			
		||||
    return BaseService::routing_machine.Table(*parameters, json_result);
 | 
			
		||||
}
 | 
			
		||||
}
 | 
			
		||||
}
 | 
			
		||||
}
 | 
			
		||||
@ -1,6 +1,7 @@
 | 
			
		||||
#include "server/service_handler.hpp"
 | 
			
		||||
 | 
			
		||||
#include "server/service/route_service.hpp"
 | 
			
		||||
#include "server/service/table_service.hpp"
 | 
			
		||||
 | 
			
		||||
#include "server/api/parsed_url.hpp"
 | 
			
		||||
#include "util/json_util.hpp"
 | 
			
		||||
@ -13,6 +14,7 @@ namespace server
 | 
			
		||||
    ServiceHandler::ServiceHandler(osrm::EngineConfig &config) : routing_machine(config)
 | 
			
		||||
    {
 | 
			
		||||
        service_map["route"] = util::make_unique<service::RouteService>(routing_machine);
 | 
			
		||||
        service_map["table"] = util::make_unique<service::TableService>(routing_machine);
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    engine::Status ServiceHandler::RunQuery(api::ParsedURL parsed_url, util::json::Object &json_result)
 | 
			
		||||
 | 
			
		||||
		Loading…
	
		Reference in New Issue
	
	Block a user