#include "Runtime/CMemoryCardSys.hpp"

#include "Runtime/CCRC32.hpp"
#include "Runtime/CGameState.hpp"
#include "Runtime/CSimplePool.hpp"
#include "Runtime/GameGlobalObjects.hpp"
#include "Runtime/Graphics/CTexture.hpp"
#include "Runtime/GuiSys/CStringTable.hpp"
#include "ConsoleVariables/CVar.hpp"
#include "ConsoleVariables/CVarManager.hpp"

namespace metaforce {
namespace {
using ECardResult = kabufuda::ECardResult;

static std::string g_CardImagePaths[2] = {};
static kabufuda::Card g_CardStates[2] = {kabufuda::Card{"GM8E", "01"}, kabufuda::Card{"GM8E", "01"}};
// static kabufuda::ECardResult g_OpResults[2] = {};
CVar* mc_dolphinAPath = nullptr;
CVar* mc_dolphinBPath = nullptr;
} // namespace
CSaveWorldIntermediate::CSaveWorldIntermediate(CAssetId mlvl, CAssetId savw) : x0_mlvlId(mlvl), x8_savwId(savw) {
  if (!savw.IsValid())
    x2c_dummyWorld = std::make_unique<CDummyWorld>(mlvl, false);
  else
    x34_saveWorld = g_SimplePool->GetObj(SObjectTag{FOURCC('SAVW'), savw});
}

bool CSaveWorldIntermediate::InitializePump() {
  if (x2c_dummyWorld) {
    CDummyWorld& wld = *x2c_dummyWorld;
    if (!wld.ICheckWorldComplete())
      return false;

    x4_strgId = wld.IGetStringTableAssetId();
    x8_savwId = wld.IGetSaveWorldAssetId();
    const u32 areaCount = wld.IGetAreaCount();

    xc_areaIds.reserve(areaCount);
    for (u32 i = 0; i < areaCount; ++i) {
      const IGameArea* area = wld.IGetAreaAlways(i);
      xc_areaIds.emplace_back(area->IGetAreaSaveId());
    }

    CAssetId mlvlId = wld.IGetWorldAssetId();
    CWorldState& mlvlState = g_GameState->StateForWorld(mlvlId);
    x1c_defaultLayerStates = mlvlState.GetLayerState()->x0_areaLayers;

    x34_saveWorld = g_SimplePool->GetObj(SObjectTag{FOURCC('SAVW'), x8_savwId});
    x2c_dummyWorld.reset();
  } else {
    if (!x34_saveWorld)
      return true;
    if (x34_saveWorld.IsLoaded() && x34_saveWorld.GetObj())
      return true;
  }

  return false;
}

bool CMemoryCardSys::HasSaveWorldMemory(CAssetId wldId) const {
  auto existingSearch = std::find_if(xc_memoryWorlds.cbegin(), xc_memoryWorlds.cend(),
                                     [&](const auto& wld) { return wld.first == wldId; });
  return existingSearch != xc_memoryWorlds.cend();
}

const CSaveWorldMemory& CMemoryCardSys::GetSaveWorldMemory(CAssetId wldId) const {
  auto existingSearch = std::find_if(xc_memoryWorlds.cbegin(), xc_memoryWorlds.cend(),
                                     [&](const auto& wld) { return wld.first == wldId; });
  return existingSearch->second;
}

CMemoryCardSys::CMemoryCardSys() {
  mc_dolphinAPath = CVarManager::instance()->findOrMakeCVar(
      "memcard.PathA"sv, "Path to the memory card image for SlotA"sv, ""sv,
      (CVar::EFlags::Archive | CVar::EFlags::System | CVar::EFlags::ModifyRestart));
  mc_dolphinBPath = CVarManager::instance()->findOrMakeCVar(
      "memcard.PathB"sv, "Path to the memory card image for SlotB"sv, ""sv,
      (CVar::EFlags::Archive | CVar::EFlags::System | CVar::EFlags::ModifyRestart));
  x0_hints = g_SimplePool->GetObj("HINT_Hints");
  xc_memoryWorlds.reserve(16);
  x1c_worldInter.emplace();
  x1c_worldInter->reserve(16);

  std::vector<CAssetId> orderedMLVLs;
  orderedMLVLs.reserve(16);
  g_ResFactory->EnumerateNamedResources([&](std::string_view name, const SObjectTag& tag) -> bool {
    if (tag.type == FOURCC('MLVL'))
      orderedMLVLs.emplace_back(tag.id);
    return true;
  });
  std::sort(orderedMLVLs.begin(), orderedMLVLs.end());

  for (const auto& mlvl : orderedMLVLs) {
    if (!HasSaveWorldMemory(mlvl)) {
      xc_memoryWorlds.emplace_back(mlvl, CSaveWorldMemory{});
      x1c_worldInter->emplace_back(mlvl, CAssetId{});
    }
  }

  x30_scanCategoryCounts.resize(6);
}

bool CMemoryCardSys::InitializePump() {
  if (!x1c_worldInter) {
    for (const auto& world : xc_memoryWorlds) {
      const CSaveWorldMemory& wld = world.second;
      if (!wld.GetWorldName())
        continue;
      if (!wld.GetWorldName().IsLoaded() || !wld.GetWorldName().GetObj())
        return false;
    }

    return !(!x0_hints.IsLoaded() || !x0_hints.GetObj());
  }

  bool done = true;
  for (CSaveWorldIntermediate& world : *x1c_worldInter) {
    if (world.InitializePump()) {
      if (!world.x34_saveWorld)
        continue;

      auto existingSearch = std::find_if(xc_memoryWorlds.begin(), xc_memoryWorlds.end(),
                                         [&](const auto& test) { return test.first == world.x0_mlvlId; });
      CSaveWorldMemory& wldMemOut = existingSearch->second;
      wldMemOut.x4_savwId = world.x8_savwId;
      wldMemOut.x0_strgId = world.x4_strgId;
      wldMemOut.xc_areaIds = world.xc_areaIds;
      wldMemOut.x1c_defaultLayerStates = world.x1c_defaultLayerStates;

      CWorldSaveGameInfo& savw = *world.x34_saveWorld;
      wldMemOut.x8_areaCount = savw.GetAreaCount();

      x20_scanStates.reserve(x20_scanStates.size() + savw.GetScans().size());
      for (const CWorldSaveGameInfo::SScanState& scan : savw.GetScans()) {
        const auto scanStateIter = std::find_if(x20_scanStates.cbegin(), x20_scanStates.cend(), [&](const auto& test) {
          return test.first == scan.x0_id && test.second == scan.x4_category;
        });
        if (scanStateIter == x20_scanStates.cend()) {
          x20_scanStates.emplace_back(scan.x0_id, scan.x4_category);
          ++x30_scanCategoryCounts[int(scan.x4_category)];
        }
      }

      wldMemOut.x3c_saveWorld = std::move(world.x34_saveWorld);
      wldMemOut.x2c_worldName = g_SimplePool->GetObj(SObjectTag{FOURCC('STRG'), wldMemOut.x0_strgId});
    } else
      done = false;
  }

  if (done) {
    std::sort(x20_scanStates.begin(), x20_scanStates.end(),
              [&](const auto& a, const auto& b) { return a.first < b.first; });
    x1c_worldInter = std::nullopt;
  }

  return false;
}

std::pair<CAssetId, TAreaId> CMemoryCardSys::GetAreaAndWorldIdForSaveId(s32 saveId) const {
  for (const auto& [mlvl, saveWorld] : xc_memoryWorlds) {
    for (TAreaId areaId = 0; areaId < saveWorld.xc_areaIds.size(); ++areaId) {
      if (saveWorld.xc_areaIds[areaId] == saveId) {
        return {mlvl, areaId};
      }
    }
  }

  return {{}, kInvalidAreaId};
}

void CMemoryCardSys::CCardFileInfo::LockBannerToken(CAssetId bannerTxtr, CSimplePool& sp) {
  x3c_bannerTex = bannerTxtr;
  x40_bannerTok.emplace(sp.GetObj({FOURCC('TXTR'), bannerTxtr}));
}

CMemoryCardSys::CCardFileInfo::Icon::Icon(CAssetId id, kabufuda::EAnimationSpeed speed, CSimplePool& sp)
: x0_id(id), x4_speed(speed), x8_tex(sp.GetObj({FOURCC('TXTR'), id})) {}

void CMemoryCardSys::CCardFileInfo::LockIconToken(CAssetId iconTxtr, kabufuda::EAnimationSpeed speed, CSimplePool& sp) {
  x50_iconToks.emplace_back(iconTxtr, speed, sp);
}

u32 CMemoryCardSys::CCardFileInfo::CalculateBannerDataSize() const {
  u32 ret = 68;
  if (x3c_bannerTex.IsValid()) {
    if ((*x40_bannerTok)->GetTextureFormat() == ETexelFormat::RGB5A3) {
      ret = 6212;
    } else {
      ret = 3652;
    }
  }

  bool paletteTex = false;
  for (const Icon& icon : x50_iconToks) {
    if (icon.x8_tex->GetTextureFormat() == ETexelFormat::RGB5A3) {
      ret += 2048;
    } else {
      ret += 1024;
      paletteTex = true;
    }
  }

  if (paletteTex) {
    ret += 512;
  }

  return ret;
}

u32 CMemoryCardSys::CCardFileInfo::CalculateTotalDataSize() const {
  return (CalculateBannerDataSize() + xf4_saveBuffer.size() + 8191) & ~8191;
}

void CMemoryCardSys::CCardFileInfo::BuildCardBuffer() {
  u32 bannerSz = CalculateBannerDataSize();
  x104_cardBuffer.resize((bannerSz + xf4_saveBuffer.size() + 8191) & ~8191);

  {
    CMemoryStreamOut w(x104_cardBuffer.data(), x104_cardBuffer.size(), CMemoryStreamOut::EOwnerShip::NotOwned);
    w.WriteLong(0);
    char comment[64];
    std::memset(comment, 0, std::size(comment));
    std::strncpy(comment, x28_comment.data(), std::size(comment) - 1);
    w.Put(reinterpret_cast<const u8*>(comment), 64);
    WriteBannerData(w);
    WriteIconData(w);
  }
  memmove(x104_cardBuffer.data() + bannerSz, xf4_saveBuffer.data(), xf4_saveBuffer.size());
  reinterpret_cast<u32&>(*x104_cardBuffer.data()) =
      CBasics::SwapBytes(CCRC32::Calculate(x104_cardBuffer.data() + 4, x104_cardBuffer.size() - 4));

  xf4_saveBuffer.clear();
}

void CMemoryCardSys::CCardFileInfo::WriteBannerData(COutputStream& out) const {
  if (x3c_bannerTex.IsValid()) {
    const TLockedToken<CTexture>& tex = *x40_bannerTok;
    const auto format = tex->GetTextureFormat();
    const auto* texels = tex->GetConstBitMapData(0);
    if (format == ETexelFormat::RGB5A3) {
      out.Put(texels, 6144);
    } else {
      out.Put(texels, 3072);
    }
    if (format == ETexelFormat::C8) {
      out.Put(reinterpret_cast<const u8*>(tex->GetPalette()->GetPaletteData()), 512);
    }
  }
}

void CMemoryCardSys::CCardFileInfo::WriteIconData(COutputStream& out) const {
  const u8* palette = nullptr;
  for (const Icon& icon : x50_iconToks) {
    const auto format = icon.x8_tex->GetTextureFormat();
    const auto* texels = icon.x8_tex->GetConstBitMapData(0);
    if (format == ETexelFormat::RGB5A3) {
      out.Put(texels, 2048);
    } else {
      out.Put(texels, 1024);
    }
    if (format == ETexelFormat::C8) {
      palette = reinterpret_cast<const u8*>(icon.x8_tex->GetPalette()->GetPaletteData());
    }
  }
  if (palette != nullptr) {
    out.Put(palette, 512);
  }
}

ECardResult CMemoryCardSys::CCardFileInfo::PumpCardTransfer() {
  if (x0_status == EStatus::Standby)
    return ECardResult::READY;
  else if (x0_status == EStatus::Transferring) {
    ECardResult result = CMemoryCardSys::GetResultCode(GetCardPort());
    if (result != ECardResult::BUSY)
      x104_cardBuffer.clear();
    if (result != ECardResult::READY)
      return result;
    x0_status = EStatus::Done;
    kabufuda::CardStat stat = {};
    result = GetStatus(stat);
    if (result != ECardResult::READY)
      return result;
    result = CMemoryCardSys::SetStatus(m_handle.slot, m_handle.getFileNo(), stat);
    if (result != ECardResult::READY)
      return result;
    return ECardResult::BUSY;
  } else {
    ECardResult result = CMemoryCardSys::GetResultCode(GetCardPort());
    if (result == ECardResult::READY)
      x0_status = EStatus::Standby;
    return result;
  }
}

ECardResult CMemoryCardSys::CCardFileInfo::GetStatus(kabufuda::CardStat& stat) const {
  ECardResult result = CMemoryCardSys::GetStatus(m_handle.slot, m_handle.getFileNo(), stat);
  if (result != ECardResult::READY) {
    return result;
  }

  stat.SetCommentAddr(4);
  stat.SetIconAddr(68);

  kabufuda::EImageFormat bannerFmt;
  if (x3c_bannerTex.IsValid()) {
    if ((*x40_bannerTok)->GetTextureFormat() == ETexelFormat::RGB5A3) {
      bannerFmt = kabufuda::EImageFormat::RGB5A3;
    } else {
      bannerFmt = kabufuda::EImageFormat::C8;
    }
  } else {
    bannerFmt = kabufuda::EImageFormat::None;
  }
  stat.SetBannerFormat(bannerFmt);

  int idx = 0;
  for (const Icon& icon : x50_iconToks) {
    stat.SetIconFormat(icon.x8_tex->GetTextureFormat() == ETexelFormat::RGB5A3 ? kabufuda::EImageFormat::RGB5A3
                                                                               : kabufuda::EImageFormat::C8,
                       idx);
    stat.SetIconSpeed(icon.x4_speed, idx);
    ++idx;
  }
  if (idx < 8) {
    stat.SetIconFormat(kabufuda::EImageFormat::None, idx);
    stat.SetIconSpeed(kabufuda::EAnimationSpeed::End, idx);
  }

  return ECardResult::READY;
}

ECardResult CMemoryCardSys::CCardFileInfo::CreateFile() {
  return CMemoryCardSys::CreateFile(m_handle.slot, x18_fileName.c_str(), CalculateTotalDataSize(), m_handle);
}

ECardResult CMemoryCardSys::CCardFileInfo::WriteFile() {
  BuildCardBuffer();
  // DCStoreRange(x104_cardBuffer.data(), x104_cardBuffer.size());
  x0_status = EStatus::Transferring;
  return CMemoryCardSys::WriteFile(m_handle, x104_cardBuffer.data(), x104_cardBuffer.size(), 0);
}

ECardResult CMemoryCardSys::CCardFileInfo::CloseFile() { return CMemoryCardSys::CloseFile(m_handle); }
std::string CMemoryCardSys::_GetDolphinCardPath(kabufuda::ECardSlot slot) {
  return g_CardImagePaths[static_cast<u32>(slot)];
}

void CMemoryCardSys::_ResolveDolphinCardPath(const CVar* cv, kabufuda::ECardSlot slot) {
  if (cv != nullptr && cv->toLiteral().empty()) {
    g_CardImagePaths[int(slot)] = ResolveDolphinCardPath(slot);
  } else if (cv != nullptr) {
    g_CardImagePaths[int(slot)] = cv->toLiteral();
  }
}

kabufuda::ProbeResults CMemoryCardSys::CardProbe(kabufuda::ECardSlot port) {
  _ResolveDolphinCardPath(mc_dolphinAPath, kabufuda::ECardSlot::SlotA);
  _ResolveDolphinCardPath(mc_dolphinBPath, kabufuda::ECardSlot::SlotB);

  kabufuda::ProbeResults res = kabufuda::Card::probeCardFile(g_CardImagePaths[int(port)]);
  // g_OpResults[int(port)] = res.x0_error;
  return res;
}

ECardResult CMemoryCardSys::MountCard(kabufuda::ECardSlot port) {
  kabufuda::Card& card = g_CardStates[int(port)];
  if (!card.open(g_CardImagePaths[int(port)]))
    return ECardResult::NOCARD;
  ECardResult result = card.getError();
  // g_OpResults[int(port)] = result;
  if (result == ECardResult::READY)
    return ECardResult::READY;
  return result;
}

ECardResult CMemoryCardSys::UnmountCard(kabufuda::ECardSlot port) {
  kabufuda::Card& card = g_CardStates[int(port)];
  if (CardResult err = card.getError()) {
    // g_OpResults[int(port)] = err;
    return err;
  }
  card.commit();
  // g_OpResults[int(port)] = ECardResult::READY;
  return ECardResult::READY;
}

ECardResult CMemoryCardSys::CheckCard(kabufuda::ECardSlot port) {
  kabufuda::Card& card = g_CardStates[int(port)];
  ECardResult result = card.getError();
  // g_OpResults[int(port)] = result;
  return result;
}

ECardResult CMemoryCardSys::CreateFile(kabufuda::ECardSlot port, const char* name, u32 size, CardFileHandle& info) {
  kabufuda::Card& card = g_CardStates[int(port)];
  if (CardResult err = card.getError()) {
    // g_OpResults[int(port)] = err;
    return err;
  }
  info.slot = port;
  ECardResult result = card.createFile(name, size, info.handle);
  // g_OpResults[int(port)] = result;
  return result;
}

ECardResult CMemoryCardSys::OpenFile(kabufuda::ECardSlot port, const char* name, CardFileHandle& info) {
  kabufuda::Card& card = g_CardStates[int(port)];
  if (CardResult err = card.getError()) {
    // g_OpResults[int(port)] = err;
    return err;
  }
  info.slot = port;
  ECardResult result = card.openFile(name, info.handle);
  // g_OpResults[int(port)] = result;
  return result;
}

ECardResult CMemoryCardSys::FastOpenFile(kabufuda::ECardSlot port, int fileNo, CardFileHandle& info) {
  kabufuda::Card& card = g_CardStates[int(port)];
  if (CardResult err = card.getError()) {
    // g_OpResults[int(port)] = err;
    return err;
  }
  info.slot = port;
  ECardResult result = card.openFile(fileNo, info.handle);
  // g_OpResults[int(port)] = result;
  return result;
}

ECardResult CMemoryCardSys::CloseFile(CardFileHandle& info) {
  kabufuda::Card& card = g_CardStates[int(info.slot)];
  if (CardResult err = card.getError()) {
    // g_OpResults[int(info.slot)] = err;
    return err;
  }
  card.closeFile(info.handle);
  return ECardResult::READY;
}

ECardResult CMemoryCardSys::ReadFile(CardFileHandle& info, void* buf, s32 length, s32 offset) {
  kabufuda::Card& card = g_CardStates[int(info.slot)];
  if (CardResult err = card.getError()) {
    // g_OpResults[int(info.slot)] = err;
    return err;
  }
  card.seek(info.handle, offset, kabufuda::SeekOrigin::Begin);
  card.asyncRead(info.handle, buf, length);
  // g_OpResults[int(info.slot)] = ECardResult::READY;
  return ECardResult::READY;
}

ECardResult CMemoryCardSys::WriteFile(CardFileHandle& info, const void* buf, s32 length, s32 offset) {
  kabufuda::Card& card = g_CardStates[int(info.slot)];
  if (CardResult err = card.getError()) {
    // g_OpResults[int(info.slot)] = err;
    return err;
  }
  card.seek(info.handle, offset, kabufuda::SeekOrigin::Begin);
  card.asyncWrite(info.handle, buf, length);
  // g_OpResults[int(info.slot)] = ECardResult::READY;
  return ECardResult::READY;
}

ECardResult CMemoryCardSys::GetNumFreeBytes(kabufuda::ECardSlot port, s32& freeBytes, s32& freeFiles) {
  kabufuda::Card& card = g_CardStates[int(port)];
  if (CardResult err = card.getError()) {
    // g_OpResults[int(port)] = err;
    return err;
  }
  card.getFreeBlocks(freeBytes, freeFiles);
  // g_OpResults[int(port)] = ECardResult::READY;
  return ECardResult::READY;
}

ECardResult CMemoryCardSys::GetSerialNo(kabufuda::ECardSlot port, u64& serialOut) {
  kabufuda::Card& card = g_CardStates[int(port)];
  if (CardResult err = card.getError()) {
    // g_OpResults[int(port)] = err;
    return err;
  }
  card.getSerial(serialOut);
  // g_OpResults[int(port)] = ECardResult::READY;
  return ECardResult::READY;
}

ECardResult CMemoryCardSys::GetResultCode(kabufuda::ECardSlot port) {
  kabufuda::Card& card = g_CardStates[int(port)];
  return card.getError();
}

ECardResult CMemoryCardSys::GetStatus(kabufuda::ECardSlot port, int fileNo, CardStat& statOut) {
  kabufuda::Card& card = g_CardStates[int(port)];
  if (CardResult err = card.getError()) {
    // g_OpResults[int(port)] = err;
    return err;
  }
  ECardResult result = card.getStatus(fileNo, statOut);
  // g_OpResults[int(port)] = result;
  return result;
}

ECardResult CMemoryCardSys::SetStatus(kabufuda::ECardSlot port, int fileNo, const CardStat& stat) {
  kabufuda::Card& card = g_CardStates[int(port)];
  if (CardResult err = card.getError()) {
    // g_OpResults[int(port)] = err;
    return err;
  }
  ECardResult result = card.setStatus(fileNo, stat);
  // g_OpResults[int(port)] = result;
  return result;
}

ECardResult CMemoryCardSys::DeleteFile(kabufuda::ECardSlot port, const char* name) {
  kabufuda::Card& card = g_CardStates[int(port)];
  if (CardResult err = card.getError()) {
    // g_OpResults[int(port)] = err;
    return err;
  }
  ECardResult result = card.deleteFile(name);
  // g_OpResults[int(port)] = result;
  return result;
}

ECardResult CMemoryCardSys::FastDeleteFile(kabufuda::ECardSlot port, int fileNo) {
  kabufuda::Card& card = g_CardStates[int(port)];
  if (CardResult err = card.getError()) {
    // g_OpResults[int(port)] = err;
    return err;
  }
  ECardResult result = card.deleteFile(fileNo);
  // g_OpResults[int(port)] = result;
  return result;
}

ECardResult CMemoryCardSys::Rename(kabufuda::ECardSlot port, const char* oldName, const char* newName) {
  kabufuda::Card& card = g_CardStates[int(port)];
  if (CardResult err = card.getError()) {
    // g_OpResults[int(port)] = err;
    return err;
  }
  ECardResult result = card.renameFile(oldName, newName);
  // g_OpResults[int(port)] = result;
  return result;
}

ECardResult CMemoryCardSys::FormatCard(kabufuda::ECardSlot port) {
  kabufuda::Card& card = g_CardStates[int(port)];
  card.format(port);
  if (CardResult err = card.getError()) {
    // g_OpResults[int(port)] = err;
    return err;
  }
  // g_OpResults[int(port)] = ECardResult::READY;
  return ECardResult::READY;
}

void CMemoryCardSys::CommitToDisk(kabufuda::ECardSlot port) {
  kabufuda::Card& card = g_CardStates[int(port)];
  card.commit();
}

bool CMemoryCardSys::CreateDolphinCard(kabufuda::ECardSlot slot) {
  std::string path = _CreateDolphinCard(slot, slot == kabufuda::ECardSlot::SlotA ? mc_dolphinAPath->hasDefaultValue()
                                                                                 : mc_dolphinBPath->hasDefaultValue());
  if (CardProbe(slot).x0_error != ECardResult::READY) {
    return false;
  }

  MountCard(slot);
  FormatCard(slot);
  kabufuda::Card& card = g_CardStates[int(slot)];
  card.waitForCompletion();
  return true;
}

void CMemoryCardSys::_ResetCVar(kabufuda::ECardSlot slot) {
  switch (slot) {
  case kabufuda::ECardSlot::SlotA:
    mc_dolphinAPath->fromLiteral("");
    break;
  case kabufuda::ECardSlot::SlotB:
    mc_dolphinBPath->fromLiteral("");
    break;
  }
}
void CMemoryCardSys::Shutdown() {
  UnmountCard(kabufuda::ECardSlot::SlotA);
  UnmountCard(kabufuda::ECardSlot::SlotB);
}

} // namespace metaforce