DeferredNameResolution.cpp

#include "DeferredNameResolution.h"
 
#include "EntityStore.h"
#include "Context.h"
#include "Services.h"
#include "Types.h"
 
#include "Foundation/Logging/Logger.h"
#include "Foundation/Reflection/TypeDatabase.h"
 
using namespace Cogs::Core;
 
namespace
{
  Cogs::Logging::Log logger = Cogs::Logging::getLogger("DeferredNameResolution");
}
 
DeferredNameResolution::DeferredNameResolution(Context* context)
  : context(context)
{
  context->services->addFrameCallback([&] { update(); });
}
 
void DeferredNameResolution::update()
{
  if (!rescan) return;
  rescan = false;
 
  for (auto it = scheduled.begin(); it != scheduled.end();) {
    auto comp = it->component.resolve();
    if (!comp) {
      LOG_DEBUG(logger, "Component of entity reference '%s' is dead.", it->name.c_str());
      it = scheduled.erase(it);
    } else if (comp->getGeneration() != it->component.generation) {
      LOG_DEBUG(logger, "Component handle from entity reference '%s' no longer valid.", it->name.c_str());
      it = scheduled.erase(it);
    } else {
      //auto entityPtr = context->store->findEntity(it->name, comp->getContainer());
      auto entityPtr = context->store->findEntity(it->name);
      if (entityPtr) {
        LOG_DEBUG(logger, "Found entity '%s', updating reference.", it->name.c_str());
 
        if (it->index < 0) {
          if (it->field->getTypeId() == Reflection::TypeDatabase::getType<EntityPtr>().getTypeId()) {
            *(it->field->getPtr<EntityPtr>(comp)) = std::move(entityPtr);
          } else if (it->field->getTypeId() == Reflection::TypeDatabase::getType<WeakEntityPtr>().getTypeId()) {
            *(it->field->getPtr<WeakEntityPtr>(comp)) = std::move(entityPtr);
          } else {
            LOG_ERROR(logger, "Entity reference to '%s' has unhandled type %d.", it->name.c_str(), (int)it->field->getTypeId());
          }
          comp->setChanged();
        } else {
          if (it->field->getTypeId() == Reflection::TypeDatabase::getType<std::vector<EntityPtr>>().getTypeId()) {
            auto * ptr = it->field->getPtr<std::vector<EntityPtr>>(comp);
 
            if (static_cast<int64_t>(ptr->size()) <= it->index) ptr->resize(it->index + 1);
 
            (*ptr)[it->index] = std::move(entityPtr);
          } else if (it->field->getTypeId() == Reflection::TypeDatabase::getType<std::vector<WeakEntityPtr>>().getTypeId()) {
            auto * ptr = it->field->getPtr<std::vector<WeakEntityPtr>>(comp);
 
            if (static_cast<int64_t>(ptr->size()) <= it->index) ptr->resize(it->index + 1);
 
            (*ptr)[it->index] = std::move(entityPtr);
          } else {
            LOG_ERROR(logger, "Entity reference to '%s' has unhandled type %d.", it->name.c_str(), (int)it->field->getTypeId());
          }
          comp->setChanged();
        }
        it = scheduled.erase(it);
      } else {
        it++;
      }
    }
  }
}