Function asyncForTiles

src/nodejs/node_osrm.cpp:202–266

template <typename ParameterParser, typename ServiceMemFn>
inline void asyncForTiles(const Napi::CallbackInfo &info,
                          ParameterParser argsToParams,
                          ServiceMemFn service,
                          bool requires_multiple_coordinates)
{
    auto params = argsToParams(info, requires_multiple_coordinates);
    if (!params)
        return;

    auto pluginParams = argumentsToPluginParameters(info);

    BOOST_ASSERT(params->IsValid());

    if (!info[info.Length() - 1].IsFunction())
        return ThrowTypeError(info.Env(), "last argument must be a callback function");

    auto *const self = Napi::ObjectWrap<Engine>::Unwrap(info.This().As<Napi::Object>());
    using ParamPtr = decltype(params);

    struct Worker final : Napi::AsyncWorker
    {
        Worker(std::shared_ptr<osrm::OSRM> osrm_,
               ParamPtr params_,
               ServiceMemFn service,
               Napi::Function callback,
               PluginParameters pluginParams_)
            : Napi::AsyncWorker(callback), osrm{std::move(osrm_)}, service{std::move(service)},
              params{std::move(params_)}, pluginParams{std::move(pluginParams_)}
        {
        }

        void Execute() override
        try
        {
            result = std::string();
            const auto status = ((*osrm).*(service))(*params, result);
            auto str_result = std::get<std::string>(result);
            ParseResult(status, str_result);
        }
        catch (const std::exception &e)
        {
            SetError(e.what());
        }

        void OnOK() override
        {
            Napi::HandleScope scope{Env()};

            Callback().Call({Env().Null(), render(Env(), std::get<std::string>(result))});
        }

        // Keeps the OSRM object alive even after shutdown until we're done with callback
        std::shared_ptr<osrm::OSRM> osrm;
        ServiceMemFn service;
        const ParamPtr params;
        const PluginParameters pluginParams;

        osrm::engine::api::ResultT result;