Service skeletons for nearest, trip, match

This commit is contained in:
Daniel J. Hofmann 2016-02-17 15:49:10 -08:00 committed by Patrick Niklaus
parent c59647ad2f
commit 4d20dea271
10 changed files with 225 additions and 33 deletions

View File

@ -24,6 +24,7 @@ class BaseService
virtual engine::Status RunQuery(std::vector<util::FixedPointCoordinate> coordinates,
std::string &options,
util::json::Object &json_result) = 0;
virtual unsigned GetVersion() = 0;
protected:

View File

@ -0,0 +1,35 @@
#ifndef SERVER_SERVICE_MATCH_SERVICE_HPP
#define SERVER_SERVICE_MATCH_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 MatchService final : public BaseService
{
public:
MatchService(OSRM &routing_machine) : BaseService(routing_machine) {}
engine::Status RunQuery(std::vector<util::FixedPointCoordinate> coordinates,
std::string &options,
util::json::Object &result) final override;
unsigned GetVersion() final override { return 1; }
};
}
}
}
#endif

View File

@ -0,0 +1,35 @@
#ifndef SERVER_SERVICE_NEAREST_SERVICE_HPP
#define SERVER_SERVICE_NEAREST_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 NearestService final : public BaseService
{
public:
NearestService(OSRM &routing_machine) : BaseService(routing_machine) {}
engine::Status RunQuery(std::vector<util::FixedPointCoordinate> coordinates,
std::string &options,
util::json::Object &result) final override;
unsigned GetVersion() final override { return 1; }
};
}
}
}
#endif

View File

@ -20,12 +20,13 @@ namespace service
class RouteService final : public BaseService
{
public:
RouteService(OSRM& routing_machine) : BaseService(routing_machine) {}
RouteService(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; }
engine::Status RunQuery(std::vector<util::FixedPointCoordinate> coordinates,
std::string &options,
util::json::Object &result) final override;
unsigned GetVersion() final override { return 1; }
};
}
}

View File

@ -20,12 +20,13 @@ namespace service
class TableService final : public BaseService
{
public:
TableService(OSRM& routing_machine) : BaseService(routing_machine) {}
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; }
engine::Status RunQuery(std::vector<util::FixedPointCoordinate> coordinates,
std::string &options,
util::json::Object &result) final override;
unsigned GetVersion() final override { return 1; }
};
}
}

View File

@ -0,0 +1,35 @@
#ifndef SERVER_SERVICE_TRIP_SERVICE_HPP
#define SERVER_SERVICE_TRIP_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 TripService final : public BaseService
{
public:
TripService(OSRM &routing_machine) : BaseService(routing_machine) {}
engine::Status RunQuery(std::vector<util::FixedPointCoordinate> coordinates,
std::string &options,
util::json::Object &result) final override;
unsigned GetVersion() final override { return 1; }
};
}
}
}
#endif

View File

@ -0,0 +1,26 @@
#include "server/service/match_service.hpp"
#include "engine/api/match_parameters.hpp"
#include "server/api/parameters_parser.hpp"
#include "util/json_container.hpp"
#include <boost/format.hpp>
namespace osrm
{
namespace server
{
namespace service
{
engine::Status RouteService::RunQuery(std::vector<util::FixedPointCoordinate> coordinates,
std::string &options,
util::json::Object &json_result)
{
// TODO(daniel-j-h)
return Status::Error;
}
}
}
}

View File

@ -0,0 +1,26 @@
#include "server/service/nearest_service.hpp"
#include "engine/api/nearest_parameters.hpp"
#include "server/api/parameters_parser.hpp"
#include "util/json_container.hpp"
#include <boost/format.hpp>
namespace osrm
{
namespace server
{
namespace service
{
engine::Status RouteService::RunQuery(std::vector<util::FixedPointCoordinate> coordinates,
std::string &options,
util::json::Object &json_result)
{
// TODO(daniel-j-h)
return Status::Error;
}
}
}
}

View File

@ -0,0 +1,26 @@
#include "server/service/trip_service.hpp"
#include "engine/api/trip_parameters.hpp"
#include "server/api/parameters_parser.hpp"
#include "util/json_container.hpp"
#include <boost/format.hpp>
namespace osrm
{
namespace server
{
namespace service
{
engine::Status RouteService::RunQuery(std::vector<util::FixedPointCoordinate> coordinates,
std::string &options,
util::json::Object &json_result)
{
// TODO(daniel-j-h)
return Status::Error;
}
}
}
}

View File

@ -2,6 +2,9 @@
#include "server/service/route_service.hpp"
#include "server/service/table_service.hpp"
#include "server/service/nearest_service.hpp"
#include "server/service/trip_service.hpp"
#include "server/service/match_service.hpp"
#include "server/api/parsed_url.hpp"
#include "util/json_util.hpp"
@ -11,31 +14,34 @@ namespace osrm
{
namespace server
{
ServiceHandler::ServiceHandler(osrm::EngineConfig &config) : routing_machine(config)
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);
service_map["nearest"] = util::make_unique<service::NearestService>(routing_machine);
service_map["trip"] = util::make_unique<service::TripService>(routing_machine);
service_map["match"] = util::make_unique<service::MatchService>(routing_machine);
}
engine::Status ServiceHandler::RunQuery(api::ParsedURL parsed_url, util::json::Object &result)
{
const auto &service_iter = service_map.find(parsed_url.service);
if (service_iter == service_map.end())
{
service_map["route"] = util::make_unique<service::RouteService>(routing_machine);
service_map["table"] = util::make_unique<service::TableService>(routing_machine);
result.values["code"] = "invalid-service";
result.values["message"] = "Service " + parsed_url.service + " not found!";
return engine::Status::Error;
}
auto &service = service_iter->second;
if (service->GetVersion() != parsed_url.version)
{
result.values["code"] = "invalid-version";
result.values["message"] = "Service " + parsed_url.service + " not found!";
return engine::Status::Error;
}
engine::Status ServiceHandler::RunQuery(api::ParsedURL parsed_url, util::json::Object &json_result)
{
const auto& service_iter = service_map.find(parsed_url.service);
if (service_iter == service_map.end())
{
json_result.values["code"] = "invalid-service";
json_result.values["message"] = "Service " + parsed_url.service + " not found!";
return engine::Status::Error;
}
auto &service = service_iter->second;
if (service->GetVersion() != parsed_url.version)
{
json_result.values["code"] = "invalid-version";
json_result.values["message"] = "Service " + parsed_url.service + " not found!";
return engine::Status::Error;
}
return service->RunQuery(std::move(parsed_url.coordinates), parsed_url.options, json_result);
}
return service->RunQuery(std::move(parsed_url.coordinates), parsed_url.options, result);
}
}
}