session_coordinator.cc

Go to the documentation of this file.

#include "session_coordinator.h"
#include <absl/status/status.h>
#include <absl/status/statusor.h>
#include "util/i18n/tr.h"
 
#include <algorithm>
#include <cstdint>
#include <cstdio>
#include <cstring>
#include <filesystem>
#include <memory>
#include <stdexcept>
#include <string>
#include <utility>
 
#include "absl/strings/str_format.h"
#include "app/editor/dungeon/dungeon_editor_v2.h"
#include "app/editor/editor_manager.h"
#include "app/editor/events/core_events.h"
#include "app/editor/overworld/overworld_editor.h"
#include "app/editor/session_types.h"
#include "app/editor/system/editor_registry.h"
#include "app/gfx/util/palette_manager.h"
#include "app/gui/canvas/item_context_menu.h"
#include "app/gui/core/icons.h"
#include "app/gui/core/style_guard.h"
#include "app/gui/core/theme_manager.h"
#include "app/gui/core/ui_helpers.h"
#include "app/gui/widgets/themed_widgets.h"
#include "core/color.h"
#include "editor/editor.h"
#include "editor/system/session/user_settings.h"
#include "editor/ui/toast_manager.h"
#include "imgui/imgui.h"
#include "util/log.h"
#include "zelda3/game_data.h"
 
namespace yaze {
namespace editor {
 
namespace {
 
std::filesystem::path NormalizeBackingFilePath(const std::string& filepath) {
  std::filesystem::path path(filepath);
  if (path.empty()) {
    return path;
  }
 
#ifndef __EMSCRIPTEN__
  std::error_code ec;
  auto absolute_path = std::filesystem::absolute(path, ec);
  if (!ec) {
    path = std::move(absolute_path);
  }
 
  ec.clear();
  auto canonical_path = std::filesystem::weakly_canonical(path, ec);
  if (!ec) {
    path = std::move(canonical_path);
  }
#endif
 
  return path.lexically_normal();
}
 
bool PathsReferToSameBackingFile(const std::string& lhs,
                                 const std::string& rhs) {
  if (lhs.empty() || rhs.empty()) {
    return false;
  }
 
#ifndef __EMSCRIPTEN__
  std::error_code ec;
  if (std::filesystem::equivalent(lhs, rhs, ec) && !ec) {
    return true;
  }
#endif
 
  return NormalizeBackingFilePath(lhs) == NormalizeBackingFilePath(rhs);
}
 
}  // namespace
 
bool SessionCoordinator::PathsReferToSameBackingFile(const std::string& lhs,
                                                     const std::string& rhs) {
  return editor::PathsReferToSameBackingFile(lhs, rhs);
}
 
SessionCoordinator::SessionCoordinator(WorkspaceWindowManager* window_manager,
                                       ToastManager* toast_manager,
                                       UserSettings* user_settings)
    : window_manager_(window_manager),
      toast_manager_(toast_manager),
      user_settings_(user_settings) {}
 
void SessionCoordinator::NotifySessionSwitched(size_t old_index,
                                               size_t new_index,
                                               RomSession* session,
                                               bool transient) {
  // Publish event to EventBus
  if (event_bus_) {
    event_bus_->Publish(
        SessionSwitchedEvent::Create(old_index, new_index, session, transient));
  }
}
 
void SessionCoordinator::NotifySessionCreated(size_t index,
                                              RomSession* session) {
  // Publish event to EventBus
  if (event_bus_) {
    event_bus_->Publish(SessionCreatedEvent::Create(index, session));
  }
}
 
void SessionCoordinator::NotifySessionClosed(size_t index) {
  // Publish event to EventBus
  if (event_bus_) {
    event_bus_->Publish(SessionClosedEvent::Create(index));
  }
}
 
void SessionCoordinator::NotifySessionRomLoaded(size_t index,
                                                RomSession* session) {
  // Publish event to EventBus
  if (event_bus_ && session) {
    event_bus_->Publish(
        RomLoadedEvent::Create(&session->rom, session->filepath, index));
  }
}
 
void SessionCoordinator::CreateNewSession() {
  if (session_count_ >= kMaxSessions) {
    ShowSessionLimitWarning();
    return;
  }
 
  // Create new empty session
  sessions_.push_back(std::make_unique<RomSession>(
      user_settings_, next_session_id_++, editor_registry_));
  UpdateSessionCount();
 
  const size_t new_session_index = sessions_.size() - 1;
 
  // Configure the new session
  if (editor_manager_) {
    auto& session = sessions_.back();
    editor_manager_->ConfigureSession(session.get());
  }
 
  LOG_INFO("SessionCoordinator", "Created new session %zu (total: %zu)",
           new_session_index, session_count_);
 
  // Notify observers
  NotifySessionCreated(new_session_index, sessions_.back().get());
  ActivateCreatedSession(new_session_index);
 
  ShowSessionOperationResult("Create Session", true);
}
 
void SessionCoordinator::DuplicateCurrentSession() {
  if (sessions_.empty())
    return;
 
  if (session_count_ >= kMaxSessions) {
    ShowSessionLimitWarning();
    return;
  }
 
  // Create new empty session (cannot actually duplicate due to non-movable
  // editors)
  // TODO: Implement proper duplication when editors become movable
  sessions_.push_back(std::make_unique<RomSession>(
      user_settings_, next_session_id_++, editor_registry_));
  UpdateSessionCount();
 
  const size_t new_session_index = sessions_.size() - 1;
 
  // Configure the new session
  if (editor_manager_) {
    auto& session = sessions_.back();
    editor_manager_->ConfigureSession(session.get());
  }
 
  LOG_INFO("SessionCoordinator", "Duplicated session %zu (total: %zu)",
           new_session_index, session_count_);
 
  // Notify observers
  NotifySessionCreated(new_session_index, sessions_.back().get());
  ActivateCreatedSession(new_session_index);
 
  ShowSessionOperationResult("Duplicate Session", true);
}
 
void SessionCoordinator::ActivateCreatedSession(size_t index) {
  if (!IsValidSessionIndex(index)) {
    return;
  }
 
  // There is no previous active index for the first session, so force the
  // normal switch notification that binds global editor/session context.
  if (sessions_.size() == 1) {
    active_session_index_ = index;
    if (window_manager_) {
      window_manager_->SetActiveSession(GetSessionId(index));
    }
    NotifySessionSwitched(index, index, sessions_[index].get(),
                          /*transient=*/false);
    return;
  }
 
  // Route activation through EditorManager when available. Besides publishing
  // the normal switch lifecycle, this preserves the existing unsaved-work
  // guard for the session being left behind.
  if (editor_manager_) {
    editor_manager_->RequestSwitchToSession(index);
  } else {
    SwitchToSession(index);
  }
}
 
void SessionCoordinator::RequestCloseCurrentSession() {
  if (editor_manager_) {
    editor_manager_->RequestCloseSession(active_session_index_);
  } else {
    CloseCurrentSession();
  }
}
 
void SessionCoordinator::CloseCurrentSession() {
  CloseSession(active_session_index_);
}
 
void SessionCoordinator::CloseSession(size_t index) {
  CloseSessionInternal(index, /*allow_closing_last=*/false);
}
 
void SessionCoordinator::CloseSessionAllowingEmpty(size_t index) {
  CloseSessionInternal(index, /*allow_closing_last=*/true);
}
 
void SessionCoordinator::CloseSessionInternal(size_t index,
                                              bool allow_closing_last) {
  if (!IsValidSessionIndex(index))
    return;
 
  if (!allow_closing_last && session_count_ <= kMinSessions) {
    // Don't allow closing the last session
    if (toast_manager_) {
      toast_manager_->Show("Cannot close the last session",
                           ToastType::kWarning);
    }
    return;
  }
 
  const size_t session_id = GetSessionId(index);
  const bool closing_active_session = index == active_session_index_;
 
  // Editors retain non-owning references to their session's workspace panels.
  // Detach those references before UnregisterSession destroys the panels.
  sessions_[index]->editors.PrepareForSessionTeardown();
 
  // Unregister cards for this stable session identity.
  if (window_manager_) {
    window_manager_->UnregisterSession(session_id);
  }
 
  // Notify observers before removal
  NotifySessionClosed(index);
 
  // Remove session (safe now with unique_ptr!)
  sessions_.erase(sessions_.begin() + index);
  UpdateSessionCount();
 
  // Adjust active session index
  if (active_session_index_ >= index && active_session_index_ > 0) {
    active_session_index_--;
  }
  if (window_manager_ && !sessions_.empty()) {
    window_manager_->SetActiveSession(GetActiveSessionId());
  }
 
  // Closing the active session can leave global editor, ROM, palette, and
  // drawer context pointing at the destroyed RomSession. Reuse the normal
  // session-switch lifecycle after the erase so every context observes the
  // surviving session.
  if (closing_active_session && !sessions_.empty()) {
    NotifySessionSwitched(index, active_session_index_,
                          sessions_[active_session_index_].get(),
                          /*transient=*/false);
  } else if (sessions_.empty()) {
    // The last session is gone: unbind every session-owned context (ROM,
    // palettes, current editor, drawers) through the normal switch path with
    // a null session.
    active_session_index_ = 0;
    NotifySessionSwitched(index, 0, nullptr, /*transient=*/false);
  }
 
  LOG_INFO("SessionCoordinator", "Closed session %zu (total: %zu)", index,
           session_count_);
 
  ShowSessionOperationResult("Close Session", true);
}
 
void SessionCoordinator::RemoveSession(size_t index) {
  CloseSession(index);
}
 
void SessionCoordinator::SwitchToSession(size_t index) {
  SwitchToSessionInternal(index, /*transient=*/false);
}
 
void SessionCoordinator::SwitchToSessionInternal(size_t index, bool transient) {
  if (!IsValidSessionIndex(index))
    return;
 
  size_t old_index = active_session_index_;
  active_session_index_ = index;
 
  if (window_manager_) {
    window_manager_->SetActiveSession(GetSessionId(index));
  }
 
  // Only notify if actually switching to a different session
  if (old_index != index) {
    NotifySessionSwitched(old_index, index, sessions_[index].get(), transient);
  }
}
 
void SessionCoordinator::ActivateSession(size_t index) {
  SwitchToSession(index);
}
 
size_t SessionCoordinator::GetActiveSessionIndex() const {
  return active_session_index_;
}
 
size_t SessionCoordinator::GetActiveSessionId() const {
  return GetSessionId(active_session_index_);
}
 
size_t SessionCoordinator::GetSessionId(size_t index) const {
  if (!IsValidSessionIndex(index)) {
    return 0;
  }
  return sessions_[index]->session_id();
}
 
void* SessionCoordinator::GetActiveSession() const {
  if (!IsValidSessionIndex(active_session_index_)) {
    return nullptr;
  }
  return sessions_[active_session_index_].get();
}
 
RomSession* SessionCoordinator::GetActiveRomSession() const {
  return static_cast<RomSession*>(GetActiveSession());
}
 
Rom* SessionCoordinator::GetCurrentRom() const {
  auto* session = GetActiveRomSession();
  return session ? &session->rom : nullptr;
}
 
zelda3::GameData* SessionCoordinator::GetCurrentGameData() const {
  auto* session = GetActiveRomSession();
  return session ? &session->game_data : nullptr;
}
 
EditorSet* SessionCoordinator::GetCurrentEditorSet() const {
  auto* session = GetActiveRomSession();
  return session ? &session->editors : nullptr;
}
 
void* SessionCoordinator::GetSession(size_t index) const {
  if (!IsValidSessionIndex(index)) {
    return nullptr;
  }
  return sessions_[index].get();
}
 
bool SessionCoordinator::HasMultipleSessions() const {
  return session_count_ > 1;
}
 
size_t SessionCoordinator::GetActiveSessionCount() const {
  return session_count_;
}
 
absl::Status SessionCoordinator::CheckBackingFileAvailable(
    const std::string& filepath,
    std::optional<size_t> excluded_session_id) const {
  if (filepath.empty()) {
    return absl::OkStatus();
  }
 
  for (const auto& session : sessions_) {
    if (!session || !session->rom.is_loaded() ||
        (excluded_session_id.has_value() &&
         session->session_id() == *excluded_session_id)) {
      continue;
    }
 
    const std::string rom_filepath = session->rom.filename();
    if (PathsReferToSameBackingFile(filepath, session->filepath) ||
        PathsReferToSameBackingFile(filepath, rom_filepath)) {
      const std::string& owner_path =
          session->filepath.empty() ? rom_filepath : session->filepath;
      return absl::AlreadyExistsError(absl::StrFormat(
          "ROM backing file '%s' is already open in session %zu ('%s')",
          filepath, session->session_id(), owner_path));
    }
  }
  return absl::OkStatus();
}
 
bool SessionCoordinator::HasDuplicateSession(
    const std::string& filepath) const {
  return !CheckBackingFileAvailable(filepath).ok();
}
 
void SessionCoordinator::DrawSessionSwitcher() {
  if (sessions_.empty())
    return;
 
  if (!show_session_switcher_)
    return;
 
  ImGui::SetNextWindowSize(ImVec2(400, 300), ImGuiCond_FirstUseEver);
  ImGui::SetNextWindowPos(ImGui::GetMainViewport()->GetCenter(),
                          ImGuiCond_Appearing, ImVec2(0.5f, 0.5f));
 
  if (!ImGui::Begin("Session Switcher", &show_session_switcher_)) {
    ImGui::End();
    return;
  }
 
  ImGui::Text(tr("%s Active Sessions (%zu)"), ICON_MD_TAB, session_count_);
  ImGui::Separator();
 
  for (size_t i = 0; i < sessions_.size(); ++i) {
    bool is_active = (i == active_session_index_);
 
    ImGui::PushID(static_cast<int>(i));
 
    // Session tab
    if (ImGui::Selectable(GetSessionDisplayName(i).c_str(), is_active)) {
      if (editor_manager_) {
        editor_manager_->RequestSwitchToSession(i);
      } else {
        SwitchToSession(i);
      }
    }
 
    // Right-click context menu
    if (ImGui::BeginPopupContextItem("SessionContextMenu")) {
      DrawSessionContextMenu(i);
      ImGui::EndPopup();
    }
 
    ImGui::PopID();
  }
 
  ImGui::Separator();
 
  // Action buttons
  if (ImGui::Button(absl::StrFormat("%s New Session", ICON_MD_ADD).c_str())) {
    CreateNewSession();
  }
 
  ImGui::SameLine();
  if (ImGui::Button(
          absl::StrFormat("%s Duplicate", ICON_MD_CONTENT_COPY).c_str())) {
    DuplicateCurrentSession();
  }
 
  ImGui::SameLine();
  if (HasMultipleSessions() &&
      ImGui::Button(absl::StrFormat("%s Close", ICON_MD_CLOSE).c_str())) {
    RequestCloseCurrentSession();
  }
 
  ImGui::End();
}
 
void SessionCoordinator::DrawSessionManager() {
  if (sessions_.empty())
    return;
 
  if (!show_session_manager_)
    return;
 
  ImGui::SetNextWindowSize(ImVec2(600, 400), ImGuiCond_FirstUseEver);
  ImGui::SetNextWindowPos(ImGui::GetMainViewport()->GetCenter(),
                          ImGuiCond_Appearing, ImVec2(0.5f, 0.5f));
 
  if (!ImGui::Begin("Session Manager", &show_session_manager_)) {
    ImGui::End();
    return;
  }
 
  // Session statistics
  ImGui::Text(tr("%s Session Statistics"), ICON_MD_ANALYTICS);
  ImGui::Separator();
 
  ImGui::Text(tr("Total Sessions: %zu"), GetTotalSessionCount());
  ImGui::Text(tr("Loaded Sessions: %zu"), GetLoadedSessionCount());
  ImGui::Text(tr("Empty Sessions: %zu"), GetEmptySessionCount());
 
  ImGui::Spacing();
 
  // Session list
  if (ImGui::BeginTable("SessionTable", 4,
                        ImGuiTableFlags_Borders | ImGuiTableFlags_RowBg |
                            ImGuiTableFlags_Resizable)) {
    ImGui::TableSetupColumn("Session", ImGuiTableColumnFlags_WidthStretch,
                            0.3f);
    ImGui::TableSetupColumn("ROM File", ImGuiTableColumnFlags_WidthStretch,
                            0.4f);
    ImGui::TableSetupColumn("Status", ImGuiTableColumnFlags_WidthStretch, 0.2f);
    ImGui::TableSetupColumn("Actions", ImGuiTableColumnFlags_WidthFixed,
                            120.0f);
    ImGui::TableHeadersRow();
 
    for (size_t i = 0; i < sessions_.size(); ++i) {
      const auto& session = sessions_[i];
      bool is_active = (i == active_session_index_);
 
      ImGui::PushID(static_cast<int>(i));
 
      ImGui::TableNextRow();
 
      // Session name
      ImGui::TableNextColumn();
      if (is_active) {
        ImGui::TextColored(gui::GetSuccessColor(), "%s %s",
                           ICON_MD_RADIO_BUTTON_CHECKED,
                           GetSessionDisplayName(i).c_str());
      } else {
        ImGui::Text("%s %s", ICON_MD_RADIO_BUTTON_UNCHECKED,
                    GetSessionDisplayName(i).c_str());
      }
 
      // ROM file
      ImGui::TableNextColumn();
      if (session->rom.is_loaded()) {
        ImGui::Text("%s", session->filepath.c_str());
      } else {
        ImGui::TextDisabled(tr("(No ROM loaded)"));
      }
 
      // Status
      ImGui::TableNextColumn();
      if (IsSessionModified(i)) {
        ImGui::TextColored(gui::GetWarningColor(), tr("Modified"));
      } else if (session->rom.is_loaded()) {
        ImGui::TextColored(gui::GetSuccessColor(), tr("Loaded"));
      } else {
        ImGui::TextColored(gui::GetWarningColor(), tr("Empty"));
      }
 
      // Actions
      ImGui::TableNextColumn();
      if (!is_active && ImGui::SmallButton(tr("Switch"))) {
        if (editor_manager_) {
          editor_manager_->RequestSwitchToSession(i);
        } else {
          SwitchToSession(i);
        }
      }
 
      ImGui::SameLine();
      if (HasMultipleSessions() && ImGui::SmallButton(tr("Close"))) {
        if (editor_manager_) {
          editor_manager_->RequestCloseSession(i);
        } else {
          CloseSession(i);
        }
      }
 
      ImGui::PopID();
    }
 
    ImGui::EndTable();
  }
 
  ImGui::End();
}
 
void SessionCoordinator::DrawSessionRenameDialog() {
  if (!show_session_rename_dialog_)
    return;
 
  ImGui::SetNextWindowSize(ImVec2(300, 150), ImGuiCond_Always);
  ImGui::SetNextWindowPos(ImGui::GetMainViewport()->GetCenter(),
                          ImGuiCond_Always, ImVec2(0.5f, 0.5f));
 
  if (!ImGui::Begin("Rename Session", &show_session_rename_dialog_)) {
    ImGui::End();
    return;
  }
 
  ImGui::Text(tr("Rename session %zu:"), session_to_rename_);
  ImGui::InputText(tr("Name"), session_rename_buffer_,
                   sizeof(session_rename_buffer_));
 
  ImGui::Spacing();
 
  if (ImGui::Button(tr("OK"))) {
    RenameSession(session_to_rename_, session_rename_buffer_);
    show_session_rename_dialog_ = false;
    session_rename_buffer_[0] = '\0';
  }
 
  ImGui::SameLine();
  if (ImGui::Button(tr("Cancel"))) {
    show_session_rename_dialog_ = false;
    session_rename_buffer_[0] = '\0';
  }
 
  ImGui::End();
}
 
void SessionCoordinator::DrawSessionTabs() {
  if (sessions_.empty())
    return;
 
  if (gui::BeginThemedTabBar("SessionTabs")) {
    for (size_t i = 0; i < sessions_.size(); ++i) {
      bool is_active = (i == active_session_index_);
      const auto& session = sessions_[i];
 
      std::string tab_name = GetSessionDisplayName(i);
      if (session->rom.is_loaded()) {
        tab_name += " ";
        tab_name += ICON_MD_CHECK_CIRCLE;
      }
      if (IsSessionModified(i)) {
        tab_name += "*";
      }
 
      if (ImGui::BeginTabItem(tab_name.c_str())) {
        if (!is_active) {
          if (editor_manager_) {
            editor_manager_->RequestSwitchToSession(i);
          } else {
            SwitchToSession(i);
          }
        }
        ImGui::EndTabItem();
      }
 
      // Right-click context menu
      if (ImGui::BeginPopupContextItem(
              absl::StrFormat("SessionTabContext_%zu", i).c_str())) {
        DrawSessionContextMenu(i);
        ImGui::EndPopup();
      }
    }
    gui::EndThemedTabBar();
  }
}
 
void SessionCoordinator::DrawSessionIndicator() {
  if (!HasMultipleSessions())
    return;
 
  const auto& theme = gui::ThemeManager::Get().GetCurrentTheme();
  ImVec4 accent_color = ConvertColorToImVec4(theme.accent);
 
  {
    gui::StyleColorGuard accent_guard(ImGuiCol_Text, accent_color);
    ImGui::Text(tr("%s Session %zu"), ICON_MD_TAB, active_session_index_);
  }
 
  if (ImGui::IsItemHovered()) {
    ImGui::SetTooltip(tr("Active Session: %s\nClick to open session switcher"),
                      GetActiveSessionDisplayName().c_str());
  }
 
  if (ImGui::IsItemClicked()) {
    ToggleSessionSwitcher();
  }
}
 
std::string SessionCoordinator::GetSessionDisplayName(size_t index) const {
  if (!IsValidSessionIndex(index)) {
    return "Invalid Session";
  }
 
  const auto& session = sessions_[index];
 
  if (!session->custom_name.empty()) {
    return session->custom_name;
  }
 
  if (session->rom.is_loaded()) {
    return absl::StrFormat(
        "Session %zu (%s)", index,
        std::filesystem::path(session->filepath).stem().string());
  }
 
  return absl::StrFormat("Session %zu (Empty)", index);
}
 
std::string SessionCoordinator::GetActiveSessionDisplayName() const {
  return GetSessionDisplayName(active_session_index_);
}
 
void SessionCoordinator::RenameSession(size_t index,
                                       const std::string& new_name) {
  if (!IsValidSessionIndex(index) || new_name.empty())
    return;
 
  sessions_[index]->custom_name = new_name;
  LOG_INFO("SessionCoordinator", "Renamed session %zu to '%s'", index,
           new_name.c_str());
}
 
std::string SessionCoordinator::GenerateUniqueEditorTitle(
    const std::string& editor_name, size_t session_index) const {
  if (sessions_.size() <= 1) {
    // Single session - use simple name
    return editor_name;
  }
 
  if (session_index >= sessions_.size()) {
    return editor_name;
  }
 
  // Multi-session - include session identifier
  const auto& session = sessions_[session_index];
  std::string session_name = session->custom_name.empty()
                                 ? session->rom.title()
                                 : session->custom_name;
 
  // Truncate long session names
  if (session_name.length() > 20) {
    session_name = session_name.substr(0, 17) + "...";
  }
 
  return absl::StrFormat("%s - %s##session_%zu", editor_name, session_name,
                         session_index);
}
 
void SessionCoordinator::SetActiveSessionIndex(size_t index) {
  SwitchToSession(index);
}
 
void SessionCoordinator::UpdateSessionCount() {
  session_count_ = sessions_.size();
}
 
// Panel coordination across sessions
void SessionCoordinator::ShowAllPanelsInActiveSession() {
  if (window_manager_) {
    window_manager_->ShowAllWindowsInSession(GetActiveSessionId());
  }
}
 
void SessionCoordinator::HideAllPanelsInActiveSession() {
  if (window_manager_) {
    window_manager_->HideAllWindowsInSession(GetActiveSessionId());
  }
}
 
void SessionCoordinator::ShowPanelsInCategory(const std::string& category) {
  if (window_manager_) {
    window_manager_->ShowAllWindowsInCategory(GetActiveSessionId(), category);
  }
}
 
void SessionCoordinator::HidePanelsInCategory(const std::string& category) {
  if (window_manager_) {
    window_manager_->HideAllWindowsInCategory(GetActiveSessionId(), category);
  }
}
 
bool SessionCoordinator::IsValidSessionIndex(size_t index) const {
  return index < sessions_.size();
}
 
void SessionCoordinator::UpdateSessions() {
  if (sessions_.empty())
    return;
 
  size_t original_session_idx = active_session_index_;
  Editor* original_editor =
      editor_manager_ ? editor_manager_->GetCurrentEditor() : nullptr;
 
  for (size_t session_idx = 0; session_idx < sessions_.size(); ++session_idx) {
    auto& session = sessions_[session_idx];
    const bool rom_loaded = session->rom.is_loaded();
    // Skip empty sessions except the active one so pre-ROM tooling (e.g.
    // Graphics prototype research) can still tick.
    if (!rom_loaded && session_idx != active_session_index_) {
      continue;
    }
 
    // Switch context
    SwitchToSessionInternal(session_idx, /*transient=*/true);
 
    for (auto editor : session->editors.active_editors_) {
      if (*editor->active()) {
        if (!rom_loaded &&
            !EditorRegistry::UpdateAllowedWithoutLoadedRom(editor->type())) {
          continue;
        }
 
        if (rom_loaded && editor->type() == EditorType::kOverworld) {
          auto& overworld_editor = static_cast<OverworldEditor&>(*editor);
          if (overworld_editor.jump_to_tab() != -1) {
            // Set the dungeon editor to the jump to tab
            session->editors.GetDungeonEditor()->add_room(
                overworld_editor.jump_to_tab());
            overworld_editor.jump_to_tab_ = -1;
          }
        }
 
        // CARD-BASED EDITORS: Don't wrap in Begin/End, they manage own windows
        bool is_card_based_editor =
            EditorManager::IsPanelBasedEditor(editor->type());
 
        if (is_card_based_editor) {
          // Panel-based editors create their own top-level windows
          // No parent wrapper needed - this allows independent docking
          if (editor_manager_) {
            editor_manager_->SetCurrentEditor(editor);
          }
 
          absl::Status status = editor->Update();
 
          // Route editor errors to toast manager
          if (!status.ok() && toast_manager_) {
            std::string editor_name =
                kEditorNames[static_cast<int>(editor->type())];
            toast_manager_->Show(
                absl::StrFormat("%s Error: %s", editor_name, status.message()),
                ToastType::kError, 8.0f);
          }
 
        } else {
          // TRADITIONAL EDITORS: Wrap in Begin/End
          std::string window_title = GenerateUniqueEditorTitle(
              kEditorNames[static_cast<int>(editor->type())], session_idx);
 
          // Set window to maximize on first open
          ImGui::SetNextWindowSize(ImGui::GetMainViewport()->WorkSize,
                                   ImGuiCond_FirstUseEver);
          ImGui::SetNextWindowPos(ImGui::GetMainViewport()->WorkPos,
                                  ImGuiCond_FirstUseEver);
 
          if (ImGui::Begin(window_title.c_str(), editor->active(),
                           ImGuiWindowFlags_None)) {  // Allow full docking
            // Temporarily switch context for this editor's update
            // (Already switched via SwitchToSession)
            if (editor_manager_) {
              editor_manager_->SetCurrentEditor(editor);
            }
 
            absl::Status status = editor->Update();
 
            // Route editor errors to toast manager
            if (!status.ok() && toast_manager_) {
              std::string editor_name =
                  kEditorNames[static_cast<int>(editor->type())];
              toast_manager_->Show(absl::StrFormat("%s Error: %s", editor_name,
                                                   status.message()),
                                   ToastType::kError, 8.0f);
            }
          }
          ImGui::End();
        }
      }
    }
  }
 
  // Restore original session context
  SwitchToSessionInternal(original_session_idx, /*transient=*/true);
  if (editor_manager_) {
    editor_manager_->SetCurrentEditor(original_editor);
  }
}
 
bool SessionCoordinator::IsSessionActive(size_t index) const {
  return index == active_session_index_;
}
 
bool SessionCoordinator::IsSessionLoaded(size_t index) const {
  return IsValidSessionIndex(index) && sessions_[index]->rom.is_loaded();
}
 
size_t SessionCoordinator::GetTotalSessionCount() const {
  return session_count_;
}
 
size_t SessionCoordinator::GetLoadedSessionCount() const {
  size_t count = 0;
  for (const auto& session : sessions_) {
    if (session->rom.is_loaded()) {
      count++;
    }
  }
  return count;
}
 
size_t SessionCoordinator::GetEmptySessionCount() const {
  return session_count_ - GetLoadedSessionCount();
}
 
absl::Status SessionCoordinator::LoadRomIntoSession(const std::string& filename,
                                                    size_t session_index) {
  if (filename.empty()) {
    return absl::InvalidArgumentError("Invalid parameters");
  }
 
  size_t target_index =
      (session_index == SIZE_MAX) ? active_session_index_ : session_index;
  if (!IsValidSessionIndex(target_index)) {
    return absl::InvalidArgumentError("Invalid session index");
  }
 
  // TODO: Implement actual ROM loading
  LOG_INFO("SessionCoordinator", "LoadRomIntoSession: %s -> session %zu",
           filename.c_str(), target_index);
 
  return absl::OkStatus();
}
 
absl::Status SessionCoordinator::SaveActiveSession(
    const std::string& filename) {
  if (!IsValidSessionIndex(active_session_index_)) {
    return absl::FailedPreconditionError("No active session");
  }
 
  // TODO: Implement actual ROM saving
  LOG_INFO("SessionCoordinator", "SaveActiveSession: session %zu",
           active_session_index_);
 
  return absl::OkStatus();
}
 
absl::Status SessionCoordinator::SaveSessionAs(size_t session_index,
                                               const std::string& filename) {
  if (!IsValidSessionIndex(session_index) || filename.empty()) {
    return absl::InvalidArgumentError("Invalid parameters");
  }
 
  // TODO: Implement actual ROM saving
  LOG_INFO("SessionCoordinator", "SaveSessionAs: session %zu -> %s",
           session_index, filename.c_str());
 
  return absl::OkStatus();
}
 
absl::StatusOr<RomSession*> SessionCoordinator::CreateSessionFromRom(
    Rom&& rom, const std::string& filepath) {
  auto path_status = CheckBackingFileAvailable(filepath);
  if (!path_status.ok()) {
    return path_status;
  }
 
  const size_t new_session_id = next_session_id_++;
  const size_t new_session_index = sessions_.size();
  sessions_.push_back(std::make_unique<RomSession>(
      std::move(rom), user_settings_, new_session_id, editor_registry_));
  auto& session = sessions_.back();
  session->filepath = filepath;
 
  UpdateSessionCount();
  // Let observers attach project/runtime context before the session becomes
  // active. This prevents a switch from briefly exposing an unbound ROM.
  NotifySessionCreated(new_session_index, session.get());
 
  if (sessions_.size() == 1) {
    active_session_index_ = new_session_index;
    if (window_manager_) {
      window_manager_->SetActiveSession(GetSessionId(new_session_index));
    }
    NotifySessionSwitched(new_session_index, new_session_index, session.get(),
                          /*transient=*/false);
  } else {
    SwitchToSession(new_session_index);
  }
 
  NotifySessionRomLoaded(new_session_index, session.get());
 
  return session.get();
}
 
absl::Status SessionCoordinator::DiscardProvisionalSession(size_t session_id) {
  auto session_it =
      std::find_if(sessions_.begin(), sessions_.end(),
                   [session_id](const std::unique_ptr<RomSession>& session) {
                     return session && session->session_id() == session_id;
                   });
  if (session_it == sessions_.end()) {
    return absl::NotFoundError(
        absl::StrFormat("Session %zu is no longer available", session_id));
  }
 
  const size_t index =
      static_cast<size_t>(std::distance(sessions_.begin(), session_it));
  const bool closing_active_session = index == active_session_index_;
  (*session_it)->editors.PrepareForSessionTeardown();
  if (window_manager_) {
    window_manager_->UnregisterSession(session_id);
  }
  NotifySessionClosed(index);
  sessions_.erase(session_it);
  UpdateSessionCount();
 
  if (sessions_.empty()) {
    active_session_index_ = 0;
    NotifySessionSwitched(index, 0, nullptr, /*transient=*/false);
  } else {
    if (active_session_index_ >= index && active_session_index_ > 0) {
      active_session_index_--;
    }
    if (window_manager_) {
      window_manager_->SetActiveSession(GetActiveSessionId());
    }
    if (closing_active_session) {
      NotifySessionSwitched(index, active_session_index_,
                            sessions_[active_session_index_].get(),
                            /*transient=*/false);
    }
  }
 
  LOG_WARN("SessionCoordinator",
           "Discarded provisional session %zu after failed open", session_id);
  return absl::OkStatus();
}
 
void SessionCoordinator::CleanupClosedSessions() {
  // Mark empty sessions as closed (except keep at least one)
  size_t loaded_count = 0;
  for (const auto& session : sessions_) {
    if (session->rom.is_loaded()) {
      loaded_count++;
    }
  }
 
  if (loaded_count > 0) {
    for (auto it = sessions_.begin(); it != sessions_.end();) {
      if (!(*it)->rom.is_loaded() && sessions_.size() > 1) {
        it = sessions_.erase(it);
      } else {
        ++it;
      }
    }
  }
 
  UpdateSessionCount();
  LOG_INFO("SessionCoordinator", "Cleaned up closed sessions (remaining: %zu)",
           session_count_);
}
 
void SessionCoordinator::ClearAllSessions() {
  if (sessions_.empty())
    return;
 
  // Editors retain non-owning references to session cards. Detach every editor
  // before unregistering any card so cross-panel callbacks cannot observe a
  // partially torn-down workspace.
  for (const auto& session : sessions_) {
    session->editors.PrepareForSessionTeardown();
  }
  if (window_manager_) {
    for (const auto& session : sessions_) {
      window_manager_->UnregisterSession(session->session_id());
    }
  }
 
  sessions_.clear();
  active_session_index_ = 0;
  UpdateSessionCount();
 
  LOG_INFO("SessionCoordinator", "Cleared all sessions");
}
 
void SessionCoordinator::FocusNextSession() {
  if (sessions_.empty())
    return;
 
  size_t next_index = (active_session_index_ + 1) % sessions_.size();
  SwitchToSession(next_index);
}
 
void SessionCoordinator::FocusPreviousSession() {
  if (sessions_.empty())
    return;
 
  size_t prev_index = (active_session_index_ == 0) ? sessions_.size() - 1
                                                   : active_session_index_ - 1;
  SwitchToSession(prev_index);
}
 
void SessionCoordinator::FocusFirstSession() {
  if (sessions_.empty())
    return;
  SwitchToSession(0);
}
 
void SessionCoordinator::FocusLastSession() {
  if (sessions_.empty())
    return;
  SwitchToSession(sessions_.size() - 1);
}
 
void SessionCoordinator::UpdateActiveSession() {
  if (!sessions_.empty() && active_session_index_ >= sessions_.size()) {
    active_session_index_ = sessions_.size() - 1;
  }
}
 
void SessionCoordinator::ValidateSessionIndex(size_t index) const {
  if (!IsValidSessionIndex(index)) {
    throw std::out_of_range(
        absl::StrFormat("Invalid session index: %zu", index));
  }
}
 
std::string SessionCoordinator::GenerateUniqueSessionName(
    const std::string& base_name) const {
  if (sessions_.empty())
    return base_name;
 
  std::string name = base_name;
  int counter = 1;
 
  while (true) {
    bool found = false;
    for (const auto& session : sessions_) {
      if (session->custom_name == name) {
        found = true;
        break;
      }
    }
 
    if (!found)
      break;
 
    name = absl::StrFormat("%s %d", base_name, counter++);
  }
 
  return name;
}
 
void SessionCoordinator::ShowSessionLimitWarning() {
  if (toast_manager_) {
    toast_manager_->Show(
        absl::StrFormat("Maximum %zu sessions allowed", kMaxSessions),
        ToastType::kWarning);
  }
}
 
void SessionCoordinator::ShowSessionOperationResult(
    const std::string& operation, bool success) {
  if (toast_manager_) {
    std::string message =
        absl::StrFormat("%s %s", operation, success ? "succeeded" : "failed");
    ToastType type = success ? ToastType::kSuccess : ToastType::kError;
    toast_manager_->Show(message, type);
  }
}
 
void SessionCoordinator::DrawSessionTab(size_t index, bool is_active) {
  if (index >= sessions_.size())
    return;
 
  const auto& session = sessions_[index];
 
  ImVec4 color = GetSessionColor(index);
  gui::StyleColorGuard tab_color_guard(ImGuiCol_Text, color);
 
  std::string tab_name = GetSessionDisplayName(index);
  if (session->rom.is_loaded()) {
    tab_name += " ";
    tab_name += ICON_MD_CHECK_CIRCLE;
  }
  if (IsSessionModified(index)) {
    tab_name += "*";
  }
 
  if (ImGui::BeginTabItem(tab_name.c_str())) {
    if (!is_active) {
      if (editor_manager_) {
        editor_manager_->RequestSwitchToSession(index);
      } else {
        SwitchToSession(index);
      }
    }
    ImGui::EndTabItem();
  }
}
 
void SessionCoordinator::DrawSessionContextMenu(size_t index) {
  std::vector<gui::MenuItemSpec> items;
  items.emplace_back("Switch to Session", ICON_MD_TAB, [this, index]() {
    if (editor_manager_) {
      editor_manager_->RequestSwitchToSession(index);
    } else {
      SwitchToSession(index);
    }
  });
  items.back().separator_after = true;
 
  items.emplace_back(
      "Rename...", ICON_MD_DRIVE_FILE_RENAME_OUTLINE, [this, index]() {
        session_to_rename_ = index;
        strncpy(session_rename_buffer_, GetSessionDisplayName(index).c_str(),
                sizeof(session_rename_buffer_) - 1);
        session_rename_buffer_[sizeof(session_rename_buffer_) - 1] = '\0';
        show_session_rename_dialog_ = true;
      });
 
  if (HasMultipleSessions()) {
    items.back().separator_after = true;
    // Closing drops the session's in-memory ROM. Confirm only when that
    // would discard unsaved changes.
    const bool modified = IsSessionModified(index);
    gui::MenuItemSpec close_item(
        modified ? "Close Session..." : "Close Session", ICON_MD_CLOSE,
        [this, index]() {
          if (editor_manager_) {
            editor_manager_->RequestCloseSession(index);
          } else {
            CloseSession(index);
          }
        });
    close_item.destructive = modified;
    close_item.requires_confirmation = modified;
    items.push_back(std::move(close_item));
  }
 
  gui::RenderMenuItems(items);
}
 
void SessionCoordinator::DrawSessionBadge(size_t index) {
  if (index >= sessions_.size())
    return;
 
  const auto& session = sessions_[index];
  ImVec4 color = GetSessionColor(index);
 
  gui::StyleColorGuard badge_guard(ImGuiCol_Text, color);
 
  if (session->rom.is_loaded()) {
    ImGui::Text("%s", ICON_MD_CHECK_CIRCLE);
  } else {
    ImGui::Text("%s", ICON_MD_RADIO_BUTTON_UNCHECKED);
  }
}
 
ImVec4 SessionCoordinator::GetSessionColor(size_t index) const {
  // Generate consistent colors for sessions
  static const ImVec4 colors[] = {
      ImVec4(0.0f, 1.0f, 0.0f, 1.0f),  // Green
      ImVec4(0.0f, 0.5f, 1.0f, 1.0f),  // Blue
      ImVec4(1.0f, 0.5f, 0.0f, 1.0f),  // Orange
      ImVec4(1.0f, 0.0f, 1.0f, 1.0f),  // Magenta
      ImVec4(1.0f, 1.0f, 0.0f, 1.0f),  // Yellow
      ImVec4(0.0f, 1.0f, 1.0f, 1.0f),  // Cyan
      ImVec4(1.0f, 0.0f, 0.0f, 1.0f),  // Red
      ImVec4(0.5f, 0.5f, 0.5f, 1.0f),  // Gray
  };
 
  return colors[index % (sizeof(colors) / sizeof(colors[0]))];
}
 
std::string SessionCoordinator::GetSessionIcon(size_t index) const {
  if (index >= sessions_.size())
    return ICON_MD_RADIO_BUTTON_UNCHECKED;
 
  const auto& session = sessions_[index];
 
  if (session->rom.is_loaded()) {
    return ICON_MD_CHECK_CIRCLE;
  } else {
    return ICON_MD_RADIO_BUTTON_UNCHECKED;
  }
}
 
bool SessionCoordinator::IsSessionEmpty(size_t index) const {
  return IsValidSessionIndex(index) && !sessions_[index]->rom.is_loaded();
}
 
bool SessionCoordinator::IsSessionClosed(size_t index) const {
  return !IsValidSessionIndex(index);
}
 
bool SessionCoordinator::IsSessionModified(size_t index) const {
  if (!IsValidSessionIndex(index)) {
    return false;
  }
 
  const auto& session = sessions_[index];
  if (session->rom.is_loaded() && session->rom.dirty()) {
    return true;
  }
 
  if (session->editors.HasPendingGraphicsChanges() ||
      session->HasPendingGfxGroupChanges()) {
    return true;
  }
 
  if (session->editors.HasPendingScreenChanges()) {
    return true;
  }
 
  if (gfx::PaletteManager::Get().HasUnsavedChanges(&session->game_data)) {
    return true;
  }
 
  if (session->project_dirty ||
      session->editors.HasPendingProjectDraftChanges() ||
      (session->project_file_editor_state.initialized &&
       session->project_file_editor_state.modified)) {
    return true;
  }
 
  if (auto* dungeon_editor = static_cast<DungeonEditorV2*>(
          session->editors.GetExistingEditor(EditorType::kDungeon))) {
    return dungeon_editor->HasPendingDungeonChanges();
  }
 
  return false;
}
 
}  // namespace editor
}  // namespace yaze