HTTPRasterSource.cpp

#include "HTTPRasterSource.h"
 
#include "../Bridge/TerrainProviderFunctions.h"
 
#include "Desktop/HTTP/BasicAuth.h"
#include "Desktop/HTTP/HTTPDataFetcher.h"
 
#include "Context.h"
#include "Services/Services.h"
 
#include "Foundation/Logging/Logger.h"
 
namespace
{
  using namespace Cogs::Core;
  Cogs::Logging::Log logger = Cogs::Logging::getLogger("HTTPRasterSource");
}
 
Cogs::Core::TerrainProvider::HTTPRasterSource::HTTPRasterSource(Context* context)
  : BaseRasterSource(context)
  , httpDataFetcher(context)
{
}
 
bool Cogs::Core::TerrainProvider::HTTPRasterSource::init(const HTTPConfig& conf, std::unique_ptr<ICache>&& icache)
{
  baseUrl = conf.baseUrl;
  if (baseUrl == NoString) {
    LOG_ERROR(logger, "No Base URL set");
    return false;
  }
  username = conf.username;
  password = conf.password;
 
  if (password != NoString && password != NoString) {
    Cogs::Desktop::BasicAuth::Configuration authConfig = {
      Strings::get(baseUrl).to_string(),
      Strings::get(username).to_string(),
      Strings::get(password).to_string()
    };
    httpDataFetcher.addAuthProvider(std::make_shared<Cogs::Desktop::BasicAuth>(std::move(authConfig)));
  }
 
  return BaseRasterSource::init(conf, std::move(icache));
}
 
void Cogs::Core::TerrainProvider::HTTPRasterSource::getConfig(HTTPConfig& conf) const
{
  BaseRasterSource::getConfig(conf);
  conf.baseUrl = baseUrl;
  conf.username = username;
  conf.password = password;
}
 
void Cogs::Core::TerrainProvider::HTTPRasterSource::requestTile(Request* req)
{
  std::string url;
  if (createFetchTileUrl(url, req->id)) {
 
    auto fetchCb = [this, req, url](Cogs::FileContents::Ptr&& contents) {
      if (!contents) {
        std::string debugLog = "URL: " + url;
        debugLog.append("\n\nSuccess: false" \
                        "\n\nNo Content");
        addTileFailure(req, debugLog);
        return;
      }
 
      MimeType kind = parseMimeType(contents->mimeTypeHash);
      Memory::MemoryBuffer contentsBuff = contents->take();
 
 
      if (kind == MimeType::XML || kind == MimeType::None) {
        std::string debugLog = "URL: " + url;
        debugLog.append("\n\nSuccess: false");
 
        if (kind == MimeType::XML) {
          debugLog.append("\n\nContent Type: ");
          debugLog.append(Strings::getC(mimeTypeString(kind)));
          debugLog.append("\n\nContent:\n");
          debugLog.append(static_cast<const char*>(contentsBuff.data()), contentsBuff.size());
        }
 
        addTileFailure(req, debugLog);
        return;
      }
 
      std::string debugLog;
      if (emitDebugLog) {
        debugLog.append("URL: ");
        debugLog.append(url);
        debugLog.append("\n\nSuccess: true");
        debugLog.append("\n\nContent Type: ");
        debugLog.append(Strings::getC(mimeTypeString(kind)));
        debugLog.append("\n\nContent:\n");
        debugLog.append(static_cast<const char*>(contentsBuff.data()), contentsBuff.size());
      }
 
      addTile(contentsBuff, kind, req, debugLog);
    };
 
    httpDataFetcher.fetchAsync(url, fetchCb, 0, 0, 0, Cogs::FileContentsHints::None);
  }
}