diff options
Diffstat (limited to 'platform/default/src/mbgl/storage/asset_file_source.cpp')
-rw-r--r-- | platform/default/src/mbgl/storage/asset_file_source.cpp | 81 |
1 files changed, 81 insertions, 0 deletions
diff --git a/platform/default/src/mbgl/storage/asset_file_source.cpp b/platform/default/src/mbgl/storage/asset_file_source.cpp new file mode 100644 index 0000000000..7988654ae5 --- /dev/null +++ b/platform/default/src/mbgl/storage/asset_file_source.cpp @@ -0,0 +1,81 @@ +#include <mbgl/storage/asset_file_source.hpp> +#include <mbgl/storage/file_source_request.hpp> +#include <mbgl/storage/response.hpp> +#include <mbgl/util/string.hpp> +#include <mbgl/util/thread.hpp> +#include <mbgl/util/url.hpp> +#include <mbgl/util/util.hpp> +#include <mbgl/util/io.hpp> + +#include <sys/types.h> +#include <sys/stat.h> + +namespace { + +const std::string assetProtocol = "asset://"; + +} // namespace + +namespace mbgl { + +class AssetFileSource::Impl { +public: + Impl(ActorRef<Impl>, std::string root_) + : root(std::move(root_)) { + } + + void request(const std::string& url, ActorRef<FileSourceRequest> req) { + Response response; + + if (!acceptsURL(url)) { + response.error = std::make_unique<Response::Error>(Response::Error::Reason::Other, + "Invalid asset URL"); + req.invoke(&FileSourceRequest::setResponse, response); + return; + } + + // Cut off the protocol and prefix with path. + const auto path = root + "/" + mbgl::util::percentDecode(url.substr(assetProtocol.size())); + struct stat buf; + int result = stat(path.c_str(), &buf); + + if (result == 0 && (S_IFDIR & buf.st_mode)) { + response.error = std::make_unique<Response::Error>(Response::Error::Reason::NotFound); + } else if (result == -1 && errno == ENOENT) { + response.error = std::make_unique<Response::Error>(Response::Error::Reason::NotFound); + } else { + try { + response.data = std::make_shared<std::string>(util::read_file(path)); + } catch (...) { + response.error = std::make_unique<Response::Error>( + Response::Error::Reason::Other, + util::toString(std::current_exception())); + } + } + + req.invoke(&FileSourceRequest::setResponse, response); + } + +private: + std::string root; +}; + +AssetFileSource::AssetFileSource(const std::string& root) + : impl(std::make_unique<util::Thread<Impl>>("AssetFileSource", root)) { +} + +AssetFileSource::~AssetFileSource() = default; + +std::unique_ptr<AsyncRequest> AssetFileSource::request(const Resource& resource, Callback callback) { + auto req = std::make_unique<FileSourceRequest>(std::move(callback)); + + impl->actor().invoke(&Impl::request, resource.url, req->actor()); + + return std::move(req); +} + +bool AssetFileSource::acceptsURL(const std::string& url) { + return 0 == url.rfind(assetProtocol, 0); +} + +} // namespace mbgl |