#include "ap_state.h" #define HAS_STD_FILESYSTEM #define _WEBSOCKETPP_CPP11_STRICT_ #pragma comment(lib, "crypt32") #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include "game_data.h" #include "logger.h" #include "tracker_frame.h" #include "tracker_state.h" constexpr int AP_MAJOR = 0; constexpr int AP_MINOR = 4; constexpr int AP_REVISION = 0; constexpr const char* CERT_STORE_PATH = "cacert.pem"; constexpr int ITEM_HANDLING = 7; // <- all namespace { struct APState { std::unique_ptr apclient; bool initialized = false; TrackerFrame* tracker_frame = nullptr; bool client_active = false; std::mutex client_mutex; bool connected = false; bool has_connection_result = false; std::string data_storage_prefix; std::list tracked_data_storage_keys; std::string victory_data_storage_key; std::map inventory; std::set checked_locations; std::map data_storage; DoorShuffleMode door_shuffle_mode = kNO_DOORS; bool color_shuffle = false; bool painting_shuffle = false; int mastery_requirement = 21; int level_2_requirement = 223; LocationChecks location_checks = kNORMAL_LOCATIONS; VictoryCondition victory_condition = kTHE_END; bool early_color_hallways = false; std::map painting_mapping; void Connect(std::string server, std::string player, std::string password) { if (!initialized) { TrackerLog("Initializing APState..."); std::thread([this]() { for (;;) { { std::lock_guard client_guard(client_mutex); if (apclient) { apclient->poll(); } } std::this_thread::sleep_for(std::chrono::milliseconds(100)); } }).detach(); for (int panel_id : GD_GetAchievementPanels()) { tracked_data_storage_keys.push_back( "Achievement|" + GD_GetPanel(panel_id).achievement_name); } for (const MapArea& map_area : GD_GetMapAreas()) { for (const Location& location : map_area.locations) { tracked_data_storage_keys.push_back( "Hunt|" + std::to_string(location.ap_location_id)); } } initialized = true; } tracker_frame->SetStatusMessage("Connecting to Archipelago server...."); TrackerLog("Connecting to Archipelago server (" + server + ")..."); { TrackerLog("Destroying old AP client..."); std::lock_guard client_guard(client_mutex); if (apclient) { DestroyClient(); } std::string cert_store = ""; if (std::filesystem::exists(CERT_STORE_PATH)) { cert_store = CERT_STORE_PATH; } apclient = std::make_unique(ap_get_uuid(""), "Lingo", server, cert_store); } inventory.clear(); checked_locations.clear(); data_storage.clear(); victory_data_storage_key.clear(); door_shuffle_mode = kNO_DOORS; color_shuffle = false; painting_shuffle = false; painting_mapping.clear(); mastery_requirement = 21; level_2_requirement = 223; location_checks = kNORMAL_LOCATIONS; victory_condition = kTHE_END; early_color_hallways = false; connected = false; has_connection_result = false; apclient->set_room_info_handler([this, player, password]() { inventory.clear(); TrackerLog("Connected to Archipelago server. Authenticating as " + player + (password.empty() ? " without password" : " with password " + password)); tracker_frame->SetStatusMessage( "Connected to Archipelago server. Authenticating..."); apclient->ConnectSlot(player, password, ITEM_HANDLING, {"Tracker"}, {AP_MAJOR, AP_MINOR, AP_REVISION}); }); apclient->set_location_checked_handler( [this](const std::list& locations) { for (const int64_t location_id : locations) { checked_locations.insert(location_id); TrackerLog("Location: " + std::to_string(location
name: "Plaza Entrance"
ports {
  name: "PLAZA"
  path: "Components/Warps/worldport4"
  orientation: "north"
}
int timeout = 5000; // 5 seconds int interval = 100; int remaining_loops = timeout / interval; while (!has_connection_result) { if (interval == 0) { connected = false; has_connection_result = true; DestroyClient(); tracker_frame->SetStatusMessage("Disconnected from Archipelago."); TrackerLog("Timeout while connecting to Archipelago server."); wxMessageBox("Timeout while connecting to Archipelago server.", "Connection failed", wxOK | wxICON_ERROR); } std::this_thread::sleep_for(std::chrono::milliseconds(100)); interval--; } if (connected) { RefreshTracker(); } else { client_active = false; } } bool HasCheckedGameLocation(int location_id) { return checked_locations.count(location_id); } bool HasCheckedHuntPanel(int location_id) { std::string key = data_storage_prefix + "Hunt|" + std::to_string(location_id); return data_storage.count(key) && std::any_cast(data_storage.at(key)); } bool HasItem(int item_id, int quantity) { return inventory.count(item_id) && inventory.at(item_id) >= quantity; } bool HasAchievement(const std::string& name) { std::string key = data_storage_prefix + "Achievement|" + name; return data_storage.count(key) && std::any_cast(data_storage.at(key)); } void RefreshTracker() { TrackerLog("Refreshing display..."); RecalculateReachability(); tracker_frame->UpdateIndicators(); } int64_t GetItemId(const std::string& item_name) { int64_t ap_id = apclient->get_item_id(item_name); if (ap_id == APClient::INVALID_NAME_ID) { TrackerLog("Could not find AP item ID for " + item_name); } return ap_id; } bool HasReachedGoal() { return data_storage.count(victory_data_storage_key) && std::any_cast(data_storage.at(victory_data_storage_key)) == 30; // CLIENT_GOAL } void DestroyClient() { client_active = false; apclient->reset(); apclient.reset(); } }; APState& GetState() { static APState* instance = new APState(); return *instance; } } // namespace void AP_SetTrackerFrame(TrackerFrame* arg) { GetState().tracker_frame = arg; } void AP_Connect(std::string server, std::string player, std::string password) { GetState().Connect(server, player, password); } bool AP_HasCheckedGameLocation(int location_id) { return GetState().HasCheckedGameLocation(location_id); } bool AP_HasCheckedHuntPanel(int location_id) { return GetState().HasCheckedHuntPanel(location_id); } bool AP_HasItem(int item_id, int quantity) { return GetState().HasItem(item_id, quantity); } DoorShuffleMode AP_GetDoorShuffleMode() { return GetState().door_shuffle_mode; } bool AP_IsColorShuffle() { return GetState().color_shuffle; } bool AP_IsPaintingShuffle() { return GetState().painting_shuffle; } const std::map AP_GetPaintingMapping() { return GetState().painting_mapping; } int AP_GetMasteryRequirement() { return GetState().mastery_requirement; } int AP_GetLevel2Requirement() { return GetState().level_2_requirement; } bool AP_IsLocationVisible(int classification) { switch (GetState().location_checks) { case kNORMAL_LOCATIONS: return classification & kLOCATION_NORMAL; case kREDUCED_LOCATIONS: return classification & kLOCATION_REDUCED; case kPANELSANITY: return classification & kLOCATION_INSANITY; default: return false; } } VictoryCondition AP_GetVictoryCondition() { return GetState().victory_condition; } bool AP_HasAchievement(const std::string& achievement_name) { return GetState().HasAchievement(achievement_name); } bool AP_HasEarlyColorHallways() { return GetState().early_color_hallways; } bool AP_HasReachedGoal() { return GetState().HasReachedGoal(); }