Add table service
This commit is contained in:
		
							parent
							
								
									2bd8efd140
								
							
						
					
					
						commit
						98beea7649
					
				
							
								
								
									
										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