OGC3DTilesAccessParser.cpp

#include "OGC3DTilesAccessParser.h"
 
#include "Context.h"
#include "Engine.h"
 
#include <Serialization/JsonParser.h>
 
#include <Foundation/Logging/Logger.h>
 
#include <cassert>
 
namespace {
  const std::string ACCESS_FILE_NAME = "/access.json";
  Cogs::Logging::Log logger = Cogs::Logging::getLogger("OGC3DTilesAccessParser");
}
 
using namespace Cogs::Core;
 
bool
parseJSON(std::string_view json, OGC3DTilesAccessParser::TilesAccess* accessData)
{
  Document doc = parseJson(json, JsonParseFlags::None);
  accessData->type = doc["type"].GetString();
  accessData->url = doc["url"].GetString();
  accessData->attributionsJSON = "FIXME"; // FIXME: Parse this when we actually need it (2-10-2023 handegard)
  // Use the name bearerToken to avoid confusion with 'accessToken' in OGC3DTilesComponent
  accessData->bearerToken = doc["accessToken"].GetString();
 
  // FIXME: Add proper error handling here (18-10-2023 handegar)
  return true;
}
 
Cogs::Core::DataFetcherManager::FetchId
OGC3DTilesAccessParser::fetch(Context* context, const std::string& baseURL, OGC3DTilesAccessParser::FetchCallback callback)
{
  std::string url = baseURL + ACCESS_FILE_NAME;
 
  Cogs::Core::DataFetcherManager::FetchId fetchId = DataFetcherManager::fetchAsync(context, url,
    [context, callback, url](std::unique_ptr<Cogs::FileContents> data) {
      TilesAccess* accessData = nullptr;
      if (data.get()) {
        accessData = new TilesAccess;
        Memory::MemoryBuffer contentsBuff = data->take();
        std::string_view jsonStr = std::string_view(static_cast<const char*>(contentsBuff.data()), contentsBuff.size());
        bool success = parseJSON(jsonStr, accessData);
        if (!success) {
          delete accessData;
          accessData = nullptr;
        }
      }
      else {
        LOG_ERROR(logger, "Failed fetching TileAccess data from '%s'", url.c_str());
      }
 
      auto finishTask = [callback, accessData]() {
        callback(accessData);
        };
 
#if defined(EMSCRIPTEN)
      (void)context;  // Silence unused capture warning.
      // Cogs.js support - no threading
      finishTask();
#else
      context->engine->runTaskInMainThread(std::move(finishTask));
#endif
    });
 
  return fetchId;
}