Decompiled source of AtlyssArchipelago v1.3.6
AtlyssArchipelagoWIP.dll
Decompiled a week ago
The result has been truncated due to the large size, download it to view full contents!
using System; using System.Collections; using System.Collections.Concurrent; using System.Collections.Generic; using System.Collections.ObjectModel; using System.Diagnostics; using System.IO; using System.Linq; using System.Reflection; using System.Runtime.CompilerServices; using System.Runtime.Versioning; using System.Threading.Tasks; using Archipelago.MultiClient.Net; using Archipelago.MultiClient.Net.BounceFeatures.DeathLink; using Archipelago.MultiClient.Net.Enums; using Archipelago.MultiClient.Net.Helpers; using Archipelago.MultiClient.Net.Models; using Archipelago.MultiClient.Net.Packets; using BepInEx; using BepInEx.Configuration; using BepInEx.Logging; using HarmonyLib; using Newtonsoft.Json; using Newtonsoft.Json.Linq; using UnityEngine; using UnityEngine.Events; using UnityEngine.SceneManagement; using UnityEngine.UI; [assembly: CompilationRelaxations(8)] [assembly: RuntimeCompatibility(WrapNonExceptionThrows = true)] [assembly: Debuggable(DebuggableAttribute.DebuggingModes.Default | DebuggableAttribute.DebuggingModes.DisableOptimizations | DebuggableAttribute.DebuggingModes.IgnoreSymbolStoreSequencePoints | DebuggableAttribute.DebuggingModes.EnableEditAndContinue)] [assembly: TargetFramework(".NETFramework,Version=v4.7.2", FrameworkDisplayName = ".NET Framework 4.7.2")] [assembly: AssemblyVersion("0.0.0.0")] namespace AtlyssArchipelagoWIP; [HarmonyPatch(typeof(SettingsManager), "Close_SettingsMenu")] internal class SettingsMenuClosePatch { private static void Prefix(SettingsManager __instance) { if (Object.op_Implicit((Object)(object)GameObject.Find("_SettingsManager/Canvas_SettingsMenu/_dolly_settingsMenu/_dolly_apSettingsTab"))) { AtlyssArchipelagoPlugin instance = AtlyssArchipelagoPlugin.Instance; Toggle component = GameObject.Find("_SettingsManager/Canvas_SettingsMenu/_dolly_settingsMenu/_dolly_apSettingsTab/_backdrop_gameTab/Scroll View_gameTab/Viewport_gameTab/Content_gameTab/_cell_fadeGameFeed/Toggle_fadeGameFeed").GetComponent<Toggle>(); if (component.isOn != instance.cfgDeathlink.Value) { instance.ToggleDeathLink(component.isOn); } instance.cfgDeathlink.Value = component.isOn; } } } [HarmonyPatch(typeof(SettingsManager), "Open_SettingsMenu")] internal class SettingsMenuOpenPatch { private static void Prefix(SettingsManager __instance) { //IL_0024: Unknown result type (might be due to invalid IL or missing references) //IL_0029: Unknown result type (might be due to invalid IL or missing references) //IL_0362: Unknown result type (might be due to invalid IL or missing references) //IL_0383: Unknown result type (might be due to invalid IL or missing references) //IL_03a4: Unknown result type (might be due to invalid IL or missing references) //IL_0407: Unknown result type (might be due to invalid IL or missing references) //IL_0423: Unknown result type (might be due to invalid IL or missing references) //IL_043f: Unknown result type (might be due to invalid IL or missing references) //IL_0557: Unknown result type (might be due to invalid IL or missing references) //IL_0561: Expected O, but got Unknown if (Object.op_Implicit((Object)(object)GameObject.Find("_SettingsManager/Canvas_SettingsMenu/_dolly_settingsMenu/_dolly_apSettingsTab"))) { return; } Scene sceneByName = SceneManager.GetSceneByName("01_rootScene"); if (((Scene)(ref sceneByName)).isLoaded) { bool flag = false; if (!Object.op_Implicit((Object)(object)GameObject.Find("_GameUI_MainMenu"))) { flag = true; ((Component)((Component)MainMenuManager._current).gameObject.transform.parent).gameObject.SetActive(true); } AtlyssArchipelagoPlugin instance = AtlyssArchipelagoPlugin.Instance; GameObject val = Object.Instantiate<GameObject>(GameObject.Find("_SettingsManager/Canvas_SettingsMenu/_dolly_settingsMenu/_dolly_gameSettings")); ((Object)val).name = "_dolly_apSettingsTab"; val.transform.SetParent(GameObject.Find("_SettingsManager/Canvas_SettingsMenu/_dolly_settingsMenu").transform, false); Transform val2 = val.transform.Find("_backdrop_gameTab/Scroll View_gameTab/Viewport_gameTab/Content_gameTab"); ((Component)((Component)val2).transform.Find("_header_gameSettings/Text")).GetComponent<Text>().text = "Archipelago Settings"; Transform child = ((Component)val2).transform.GetChild(1); Transform child2 = ((Component)val2).transform.GetChild(2); Transform child3 = ((Component)val2).transform.GetChild(3); Transform child4 = ((Component)val2).transform.GetChild(21); ((Component)child4).GetComponentInChildren<Text>().text = "DeathLink"; ((Component)child4).GetComponent<SettingsCell>()._setToggle = null; Object.Destroy((Object)(object)((Component)child).transform.GetChild(1)); Object.Destroy((Object)(object)((Component)child2).transform.GetChild(1)); Object.Destroy((Object)(object)((Component)child3).transform.GetChild(1)); ((Component)child).GetComponentInChildren<Text>().text = "Archipelago Server"; ((Component)child2).GetComponentInChildren<Text>().text = "Slot Name"; ((Component)child3).GetComponentInChildren<Text>().text = "Password"; ((Component)((Component)val2).transform.Find("_header_nametagSettings/Text")).GetComponent<Text>().text = "Press F5 at any time to connect!"; for (int num = val2.childCount - 3; num >= 5; num--) { GameObject gameObject = ((Component)val2.GetChild(num)).gameObject; Object.Destroy((Object)(object)gameObject); } Transform val3 = Object.Instantiate<Transform>(GameObject.Find("_GameUI_MainMenu").transform.Find("_characterSelectMenu/Canvas_characterSelect/_dolly_characterManagement/_input_@nickname")); ((Object)val3).name = "Input_apServer"; Transform val4 = Object.Instantiate<Transform>(GameObject.Find("_GameUI_MainMenu").transform.Find("_characterSelectMenu/Canvas_characterSelect/_dolly_characterManagement/_input_@nickname")); ((Object)val4).name = "Input_apSlot"; Transform val5 = Object.Instantiate<Transform>(GameObject.Find("_GameUI_MainMenu").transform.Find("_characterSelectMenu/Canvas_characterSelect/_dolly_characterManagement/_input_@nickname")); ((Object)val5).name = "Input_apPassword"; ((Component)val3).gameObject.SetActive(true); ((Component)val4).gameObject.SetActive(true); ((Component)val5).gameObject.SetActive(true); Object.Destroy((Object)(object)((Component)val3).transform.Find("_backdrop_globalNicknameTooltip")); Object.Destroy((Object)(object)((Component)val4).transform.Find("_backdrop_globalNicknameTooltip")); Object.Destroy((Object)(object)((Component)val5).transform.Find("_backdrop_globalNicknameTooltip")); ((Component)val3).transform.SetParent(((Component)child).transform, false); ((Component)val4).transform.SetParent(((Component)child2).transform, false); ((Component)val5).transform.SetParent(((Component)child3).transform, false); ((Component)val3).transform.localPosition = new Vector3(180f, 0f, 0f); ((Component)val4).transform.localPosition = new Vector3(180f, 0f, 0f); ((Component)val5).transform.localPosition = new Vector3(180f, 0f, 0f); instance.apServer = ((Component)val3).GetComponent<InputField>(); instance.apSlot = ((Component)val4).GetComponent<InputField>(); instance.apPassword = ((Component)val5).GetComponent<InputField>(); instance.apDeathlink = ((Component)((Component)child4).transform.Find("Toggle_fadeGameFeed")).gameObject.GetComponent<Toggle>(); ((Text)instance.apServer.placeholder).text = "archipelago.gg:38281"; ((Text)instance.apSlot.placeholder).text = "ATLYSSPlayer"; ((Text)instance.apPassword.placeholder).text = "supersecret"; instance.apServer.text = instance.cfgServer.Value; instance.apSlot.text = instance.cfgSlot.Value; instance.apPassword.text = instance.cfgPassword.Value; instance.apDeathlink.isOn = instance.cfgDeathlink.Value; GameObject val6 = Object.Instantiate<GameObject>(GameObject.Find("_SettingsManager/Canvas_SettingsMenu/_dolly_settingsMenu/_dolly_tabButtons/Button_gameTab")); ((Object)val6).name = "Button_apTab"; val6.GetComponentInChildren<Text>().text = "Archipelago"; GameObject val7 = GameObject.Find("_SettingsManager/Canvas_SettingsMenu/_dolly_settingsMenu/_dolly_tabButtons"); val6.transform.SetParent(val7.transform, false); ((HorizontalOrVerticalLayoutGroup)val7.GetComponent<HorizontalLayoutGroup>()).childScaleWidth = true; ((HorizontalOrVerticalLayoutGroup)val7.GetComponent<HorizontalLayoutGroup>()).childControlWidth = true; ((LayoutGroup)val7.GetComponent<HorizontalLayoutGroup>()).padding.right = 8; val7.SetActive(false); instance.ReenableSettingsTabs(); ((UnityEvent)val6.GetComponent<Button>().onClick).AddListener((UnityAction)delegate { __instance.Set_SettingMenuSelectionIndex(4); }); if (flag) { ((Component)((Component)MainMenuManager._current).gameObject.transform.parent).gameObject.SetActive(false); } } } } [HarmonyPatch(typeof(SettingsManager), "Set_SettingMenuSelectionIndex")] internal class SettingsMenuTabsPatch { private static void Postfix(SettingsManager __instance, int _index) { //IL_0006: Unknown result type (might be due to invalid IL or missing references) //IL_000b: Unknown result type (might be due to invalid IL or missing references) //IL_005f: Unknown result type (might be due to invalid IL or missing references) //IL_0080: Unknown result type (might be due to invalid IL or missing references) Scene sceneByName = SceneManager.GetSceneByName("01_rootScene"); if (((Scene)(ref sceneByName)).isLoaded) { if (_index == 4) { MenuElement component = GameObject.Find("_SettingsManager/Canvas_SettingsMenu/_dolly_settingsMenu/_dolly_apSettingsTab").GetComponent<MenuElement>(); RectTransform component2 = GameObject.Find("_SettingsManager/Canvas_SettingsMenu/_dolly_settingsMenu/_dolly_apSettingsTab/_backdrop_gameTab/Scroll View_gameTab/Viewport_gameTab/Content_gameTab").GetComponent<RectTransform>(); GameObject val = GameObject.Find("_SettingsManager/Canvas_SettingsMenu/_dolly_settingsMenu/_selectHighlight_tabButtons"); component.isEnabled = true; component2.anchoredPosition = Vector2.zero; val.transform.position = GameObject.Find("_SettingsManager/Canvas_SettingsMenu/_dolly_settingsMenu/_dolly_tabButtons/Button_apTab").transform.position; } else { MenuElement component3 = GameObject.Find("_SettingsManager/Canvas_SettingsMenu/_dolly_settingsMenu/_dolly_apSettingsTab").GetComponent<MenuElement>(); component3.isEnabled = false; } } } } [HarmonyPatch(typeof(Player), "Player_OnDeath")] internal class PlayerDeathPatch { private static void Postfix(Player __instance) { //IL_006b: Unknown result type (might be due to invalid IL or missing references) //IL_0071: Expected O, but got Unknown if ((Object)(object)__instance != (Object)(object)Player._mainPlayer) { return; } AtlyssArchipelagoPlugin instance = AtlyssArchipelagoPlugin.Instance; if (instance._dlService != null && instance.cfgDeathlink.Value) { if (AtlyssArchipelagoPlugin.reactingToDeathLink > 0) { AtlyssArchipelagoPlugin.reactingToDeathLink--; return; } DeathLink val = new DeathLink(__instance._nickname, __instance._nickname + " was defeated."); instance._dlService.SendDeathLink(val); } } } [HarmonyPatch(typeof(ChatBehaviour), "Send_ChatMessage")] public static class ChatBehaviourPatch { private static bool Prefix(ChatBehaviour __instance, string _message) { try { if (!string.IsNullOrEmpty(_message) && _message.StartsWith("/")) { string[] array = new string[6] { "/release", "/collect", "/hint", "/help", "/players", "/status" }; bool flag = false; string[] array2 = array; foreach (string value in array2) { if (_message.StartsWith(value, StringComparison.OrdinalIgnoreCase)) { flag = true; break; } } if (flag) { if ((Object)(object)AtlyssArchipelagoPlugin.Instance != (Object)null) { AtlyssArchipelagoPlugin.Instance.HandleArchipelagoCommand(_message); } __instance._focusedInChat = false; return false; } } return true; } catch (Exception ex) { ManualLogSource staticLogger = AtlyssArchipelagoPlugin.StaticLogger; if (staticLogger != null) { staticLogger.LogError((object)("[AtlyssAP] Chat patch error: " + ex.Message)); } return true; } } } [HarmonyPatch(typeof(GameManager), "Locate_Item")] public static class LocateItemPatch { private static ScriptableItem _fallbackDummyItem = null; private static Sprite _customAPSprite = null; private static Dictionary<string, ScriptableItem> _apItemCache = new Dictionary<string, ScriptableItem>(); private static void Postfix(string _tag, ref ScriptableItem __result) { try { if ((Object)(object)__result != (Object)null || string.IsNullOrEmpty(_tag) || !_tag.StartsWith("[AP]")) { return; } if (_apItemCache.TryGetValue(_tag, out var value)) { __result = value; return; } string text = ExtractItemName(_tag); if (string.IsNullOrEmpty(text)) { AtlyssArchipelagoPlugin.StaticLogger.LogWarning((object)("[AtlyssAP] Could not extract item name from: " + _tag)); __result = GetCustomAPItem("Unknown Item"); _apItemCache[_tag] = __result; return; } ScriptableItem val = FindRealItem(text); if ((Object)(object)val != (Object)null) { _apItemCache[_tag] = val; __result = val; AtlyssArchipelagoPlugin.StaticLogger.LogInfo((object)("[AtlyssAP] Using real item '" + val._itemName + "' icon for: " + _tag)); } else { __result = GetCustomAPItem(text); _apItemCache[_tag] = __result; AtlyssArchipelagoPlugin.StaticLogger.LogInfo((object)("[AtlyssAP] Using custom AP icon for non-ATLYSS item: " + _tag)); } } catch (Exception ex) { AtlyssArchipelagoPlugin.StaticLogger.LogError((object)("[AtlyssAP] Locate_Item patch error: " + ex.Message)); __result = GetCustomAPItem("Unknown Item"); } } public static string ExtractItemName(string apItemName) { string text = apItemName.Replace("[AP] ", ""); int num = text.LastIndexOf(" ("); if (num > 0) { return text.Substring(0, num); } return text; } private static ScriptableItem FindRealItem(string itemName) { if (!AtlyssArchipelagoPlugin.ItemNameMapping.TryGetValue(itemName, out var value)) { return null; } string text = value; int num = value.LastIndexOf('_'); if (num >= 0 && num < value.Length - 1) { text = value.Substring(num + 1); } ScriptableItem val = GameManager._current.Locate_Item(text); if ((Object)(object)val != (Object)null) { return val; } if (text.Contains(" (") && text.EndsWith(")")) { string text2 = text[..text.LastIndexOf(" (")]; val = GameManager._current.Locate_Item(text2); if ((Object)(object)val != (Object)null) { return val; } } string text3 = text.Replace(" ", ""); val = GameManager._current.Locate_Item(text3); if ((Object)(object)val != (Object)null) { return val; } return null; } private static ScriptableItem GetCustomAPItem(string itemName = "Archipelago Item") { ScriptableItem fallbackDummy = GetFallbackDummy(); if ((Object)(object)fallbackDummy != (Object)null) { ScriptableItem val = Object.Instantiate<ScriptableItem>(fallbackDummy); val._itemName = itemName; Sprite val2 = LoadCustomAPSprite(); if ((Object)(object)val2 != (Object)null) { TrySetItemIcon(val, val2); if ((Object)(object)_customAPSprite == (Object)null) { AtlyssArchipelagoPlugin.StaticLogger.LogInfo((object)"[AtlyssAP] Loaded custom Archipelago icon successfully!"); } _customAPSprite = val2; } else { AtlyssArchipelagoPlugin.StaticLogger.LogWarning((object)"[AtlyssAP] Failed to load custom icon, using base item icon"); } return val; } AtlyssArchipelagoPlugin.StaticLogger.LogError((object)"[AtlyssAP] Could not create custom AP item - no base item available"); return null; } private static Sprite LoadCustomAPSprite() { //IL_00f9: Unknown result type (might be due to invalid IL or missing references) //IL_0100: Expected O, but got Unknown //IL_0146: Unknown result type (might be due to invalid IL or missing references) //IL_0155: Unknown result type (might be due to invalid IL or missing references) if ((Object)(object)_customAPSprite != (Object)null) { return _customAPSprite; } try { Assembly executingAssembly = Assembly.GetExecutingAssembly(); string[] manifestResourceNames = executingAssembly.GetManifestResourceNames(); string text = null; string[] array = manifestResourceNames; foreach (string text2 in array) { if (text2.EndsWith("Archipelago.png-256x256_q95.png")) { text = text2; break; } } if (string.IsNullOrEmpty(text)) { AtlyssArchipelagoPlugin.StaticLogger.LogError((object)"[AtlyssAP] Could not find Archipelago.png-256x256_q95.png in embedded resources"); AtlyssArchipelagoPlugin.StaticLogger.LogError((object)("[AtlyssAP] Available resources: " + string.Join(", ", manifestResourceNames))); return null; } using Stream stream = executingAssembly.GetManifestResourceStream(text); if (stream == null) { AtlyssArchipelagoPlugin.StaticLogger.LogError((object)"[AtlyssAP] Failed to open embedded resource stream"); return null; } byte[] array2 = new byte[stream.Length]; stream.Read(array2, 0, array2.Length); Texture2D val = new Texture2D(2, 2); if (!ImageConversion.LoadImage(val, array2)) { AtlyssArchipelagoPlugin.StaticLogger.LogError((object)"[AtlyssAP] Failed to load image data into texture"); return null; } Sprite result = Sprite.Create(val, new Rect(0f, 0f, (float)((Texture)val).width, (float)((Texture)val).height), new Vector2(0.5f, 0.5f), 100f); AtlyssArchipelagoPlugin.StaticLogger.LogInfo((object)$"[AtlyssAP] Successfully loaded custom AP sprite: {((Texture)val).width}x{((Texture)val).height}"); return result; } catch (Exception ex) { AtlyssArchipelagoPlugin.StaticLogger.LogError((object)("[AtlyssAP] Error loading custom sprite: " + ex.Message)); return null; } } private static void TrySetItemIcon(ScriptableItem item, Sprite sprite) { try { string[] array = new string[6] { "_icon", "_itemIcon", "_sprite", "_itemSprite", "icon", "sprite" }; Type type = ((object)item).GetType(); string[] array2 = array; foreach (string text in array2) { FieldInfo field = type.GetField(text, BindingFlags.Instance | BindingFlags.Public | BindingFlags.NonPublic); if (field != null && field.FieldType == typeof(Sprite)) { field.SetValue(item, sprite); AtlyssArchipelagoPlugin.StaticLogger.LogInfo((object)("[AtlyssAP] Set item icon using field: " + text)); return; } } AtlyssArchipelagoPlugin.StaticLogger.LogWarning((object)"[AtlyssAP] Could not find icon field on ScriptableItem"); } catch (Exception ex) { AtlyssArchipelagoPlugin.StaticLogger.LogError((object)("[AtlyssAP] Error setting item icon: " + ex.Message)); } } private static ScriptableItem GetFallbackDummy() { if ((Object)(object)_fallbackDummyItem == (Object)null) { _fallbackDummyItem = GameManager._current.Locate_Item("Bunbag"); if ((Object)(object)_fallbackDummyItem == (Object)null) { _fallbackDummyItem = GameManager._current.Locate_Item("Wood Sword"); } if ((Object)(object)_fallbackDummyItem == (Object)null) { _fallbackDummyItem = GameManager._current.Locate_Item("Leather Top"); } } return _fallbackDummyItem; } } [HarmonyPatch(typeof(NetNPC), "Init_ShopkeepListing")] public static class ShopInventoryPatch { private static void Postfix(NetNPC __instance) { try { if (!AtlyssArchipelagoPlugin.Instance.connected || AtlyssArchipelagoPlugin.Instance._shopSanity == null || !AtlyssArchipelagoPlugin.Instance._shopSanity.IsInitialized) { return; } string name = ((Object)((Component)__instance).gameObject).name; string[] array = new string[10] { "_npc_Sally", "_npc_Skrit", "_npc_sallyWorker_frankie_01", "_npc_Ruka", "_npc_fisher", "_npc_dyeMerchant", "_npc_Tesh", "_npc_Nesh", "_npc_Cotoo", "_npc_Rikko" }; bool flag = false; string[] array2 = array; foreach (string text in array2) { if (name == text) { flag = true; break; } } if (!flag) { return; } AtlyssArchipelagoPlugin.StaticLogger.LogInfo((object)("[AtlyssAP] AP merchant shop opened: " + name + " - injecting items")); AtlyssArchipelagoPlugin.Instance._shopSanity.InjectAPShopItems(__instance); try { ShopkeepManager current = ShopkeepManager._current; if (!((Object)(object)current != (Object)null)) { return; } MethodInfo method = typeof(ShopkeepManager).GetMethod("Begin_ShopkeepListing", BindingFlags.Instance | BindingFlags.Public | BindingFlags.NonPublic); if (method != null) { ParameterInfo[] parameters = method.GetParameters(); if (parameters.Length == 1) { method.Invoke(current, new object[1] { __instance }); AtlyssArchipelagoPlugin.StaticLogger.LogInfo((object)"[AtlyssAP] Refreshed shop display via Begin_ShopkeepListing(npc)"); } else if (parameters.Length == 0) { method.Invoke(current, null); AtlyssArchipelagoPlugin.StaticLogger.LogInfo((object)"[AtlyssAP] Refreshed shop display via Begin_ShopkeepListing()"); } return; } string[] array3 = new string[6] { "Refresh_ShopListing", "Init_ShopListing", "Update_ShopListing", "Build_ShopListing", "Begin_ShopListing", "Set_ShopListing" }; string[] array4 = array3; foreach (string text2 in array4) { MethodInfo method2 = typeof(ShopkeepManager).GetMethod(text2, BindingFlags.Instance | BindingFlags.Public | BindingFlags.NonPublic); if (method2 != null) { ParameterInfo[] parameters2 = method2.GetParameters(); if (parameters2.Length == 1 && parameters2[0].ParameterType == typeof(NetNPC)) { method2.Invoke(current, new object[1] { __instance }); AtlyssArchipelagoPlugin.StaticLogger.LogInfo((object)("[AtlyssAP] Refreshed shop display via " + text2 + "(npc)")); break; } if (parameters2.Length == 0) { method2.Invoke(current, null); AtlyssArchipelagoPlugin.StaticLogger.LogInfo((object)("[AtlyssAP] Refreshed shop display via " + text2 + "()")); break; } } } } catch (Exception ex) { AtlyssArchipelagoPlugin.StaticLogger.LogWarning((object)("[AtlyssAP] Could not refresh shop display: " + ex.Message)); } } catch (Exception ex2) { AtlyssArchipelagoPlugin.StaticLogger.LogError((object)("[AtlyssAP] Shop patch error: " + ex2.Message)); AtlyssArchipelagoPlugin.StaticLogger.LogError((object)("[AtlyssAP] Stack trace: " + ex2.StackTrace)); } } } [HarmonyPatch(typeof(ShopkeepManager), "Init_PurchaseItem")] public static class ShopPurchasePatch { private static bool Prefix(ScriptableItem _scriptableItem, int _quantity, string _key, ShopListDataEntry _setEntry) { try { if (!AtlyssArchipelagoPlugin.Instance.connected) { return true; } if (AtlyssArchipelagoPlugin.Instance._shopSanity == null) { return true; } if (!AtlyssArchipelagoPlugin.Instance._shopSanity.IsInitialized) { return true; } string itemName = _setEntry._shopStruct._itemName; if (!itemName.StartsWith("[AP]")) { return true; } AtlyssArchipelagoPlugin.StaticLogger.LogInfo((object)("[AtlyssAP] Intercepting purchase of: " + itemName)); Player mainPlayer = Player._mainPlayer; if ((Object)(object)mainPlayer == (Object)null) { AtlyssArchipelagoPlugin.StaticLogger.LogError((object)"[AtlyssAP] Player not found for purchase!"); return false; } PlayerInventory component = ((Component)mainPlayer).GetComponent<PlayerInventory>(); if ((Object)(object)component == (Object)null) { AtlyssArchipelagoPlugin.StaticLogger.LogError((object)"[AtlyssAP] PlayerInventory not found!"); return false; } int num = _setEntry._shopStruct._dedicatedValue; if (_setEntry._shopStruct._useDedicatedValue) { num = _setEntry._shopStruct._dedicatedValue; } else if ((Object)(object)_scriptableItem != (Object)null) { num = _scriptableItem._vendorCost; } if (component._heldCurrency < num) { ErrorPromptTextManager.current.Init_ErrorPrompt("Not enough Crowns"); AtlyssArchipelagoPlugin.StaticLogger.LogInfo((object)"[AtlyssAP] Player cannot afford AP item"); return false; } component.Network_heldCurrency -= num; AtlyssArchipelagoPlugin.StaticLogger.LogInfo((object)$"[AtlyssAP] Deducted {num} crowns from player"); component.Play_PurchaseSound(); AtlyssArchipelagoPlugin.Instance._shopSanity.HandleAPItemPurchase(itemName, _key); return false; } catch (Exception ex) { AtlyssArchipelagoPlugin.StaticLogger.LogError((object)("[AtlyssAP] Shop purchase patch error: " + ex.Message)); return true; } } } [HarmonyPatch(typeof(FriendlyNPC_Hitbox), "OnTriggerEnter")] public static class AngelaRudePatch { private static void Postfix(FriendlyNPC_Hitbox __instance, Collider __0) { try { if ((Object)(object)AtlyssArchipelagoPlugin.Instance == (Object)null || !AtlyssArchipelagoPlugin.Instance.connected || (Object)(object)Player._mainPlayer == (Object)null || (Object)(object)((Component)__0).GetComponentInParent<Player>() != (Object)(object)Player._mainPlayer) { return; } FieldInfo fieldInfo = AccessTools.Field(typeof(FriendlyNPC_Hitbox), "_achievementTag"); if (fieldInfo == null) { return; } string text = (string)fieldInfo.GetValue(__instance); if (!(text != "ATLYSS_ACHIEVEMENT_11")) { ManualLogSource staticLogger = AtlyssArchipelagoPlugin.StaticLogger; if (staticLogger != null) { staticLogger.LogInfo((object)"[AtlyssAP] Angela 'Rude!' hitbox triggered!"); } AtlyssArchipelagoPlugin.Instance.SendCheckById(591500L); AtlyssArchipelagoPlugin.Instance.SendAPChatMessage("Found <color=yellow>Smack Dat Azz</color>!"); } } catch (Exception ex) { ManualLogSource staticLogger2 = AtlyssArchipelagoPlugin.StaticLogger; if (staticLogger2 != null) { staticLogger2.LogError((object)("[AtlyssAP] Angela patch error: " + ex.Message)); } } } } public class SpikePatch { [HarmonyPatch(typeof(File), "ReadAllText", new Type[] { typeof(string) })] public static class File_ReadAllText_Patch { private static bool Prefix(ref string path, ref string __result) { try { if (!ShouldRedirect()) { return true; } if (path.EndsWith("atl_itemBank") && !path.Contains("_ap")) { string aPMasterBankPath = ArchipelagoSpikeStorage.GetAPMasterBankPath(); if (File.Exists(aPMasterBankPath)) { __result = File.ReadAllText(aPMasterBankPath); ManualLogSource staticLogger = AtlyssArchipelagoPlugin.StaticLogger; if (staticLogger != null) { staticLogger.LogInfo((object)"[AtlyssAP] Redirected Spike load: MASTER bank -> AP MASTER bank"); } return false; } __result = "{ \"_heldItemStorage\": [] }"; return false; } if (path.Contains("atl_itemBank_") && !path.Contains("_ap_")) { string fileName = Path.GetFileName(path); for (int i = 1; i <= 7; i++) { if (!(fileName == $"atl_itemBank_{i:D2}")) { continue; } string aPBankPath = ArchipelagoSpikeStorage.GetAPBankPath(i); if (File.Exists(aPBankPath)) { __result = File.ReadAllText(aPBankPath); ManualLogSource staticLogger2 = AtlyssArchipelagoPlugin.StaticLogger; if (staticLogger2 != null) { staticLogger2.LogInfo((object)$"[AtlyssAP] Redirected Spike load: bank {i} -> AP bank {i}"); } return false; } __result = "{ \"_heldItemStorage\": [] }"; return false; } } return true; } catch (Exception ex) { ManualLogSource staticLogger3 = AtlyssArchipelagoPlugin.StaticLogger; if (staticLogger3 != null) { staticLogger3.LogError((object)("[AtlyssAP] Error in File.ReadAllText patch: " + ex.Message)); } return true; } } } [HarmonyPatch(typeof(File), "WriteAllText", new Type[] { typeof(string), typeof(string) })] public static class File_WriteAllText_Patch { private static bool Prefix(ref string path, string contents) { try { if (!ShouldRedirect()) { return true; } if (path.EndsWith("atl_itemBank") && !path.Contains("_ap")) { string aPMasterBankPath = ArchipelagoSpikeStorage.GetAPMasterBankPath(); string directoryName = Path.GetDirectoryName(aPMasterBankPath); if (!Directory.Exists(directoryName)) { Directory.CreateDirectory(directoryName); } File.WriteAllText(aPMasterBankPath, contents); ManualLogSource staticLogger = AtlyssArchipelagoPlugin.StaticLogger; if (staticLogger != null) { staticLogger.LogInfo((object)"[AtlyssAP] Redirected Spike save: MASTER bank -> AP MASTER bank"); } return false; } if (path.Contains("atl_itemBank_") && !path.Contains("_ap_")) { string fileName = Path.GetFileName(path); for (int i = 1; i <= 7; i++) { if (fileName == $"atl_itemBank_{i:D2}") { string aPBankPath = ArchipelagoSpikeStorage.GetAPBankPath(i); File.WriteAllText(aPBankPath, contents); ManualLogSource staticLogger2 = AtlyssArchipelagoPlugin.StaticLogger; if (staticLogger2 != null) { staticLogger2.LogInfo((object)$"[AtlyssAP] Redirected Spike save: bank {i} -> AP bank {i}"); } return false; } } } return true; } catch (Exception ex) { ManualLogSource staticLogger3 = AtlyssArchipelagoPlugin.StaticLogger; if (staticLogger3 != null) { staticLogger3.LogError((object)("[AtlyssAP] Error in File.WriteAllText patch: " + ex.Message)); } return true; } } } [HarmonyPatch(typeof(ItemStorageManager), "Create_StorageEntry")] public static class CreateStorageEntry_SafetyPatch { private static bool Prefix(ItemStorageManager __instance, ItemData _itemData, ScriptableItem _scriptItem, int _index, int _slotNumber) { try { FieldInfo field = typeof(ItemStorageManager).GetField("_currentStorageEntries", BindingFlags.Instance | BindingFlags.Public | BindingFlags.NonPublic); if (field != null && field.GetValue(__instance) is Array array && (_slotNumber < 0 || _slotNumber >= array.Length)) { ManualLogSource staticLogger = AtlyssArchipelagoPlugin.StaticLogger; if (staticLogger != null) { staticLogger.LogWarning((object)($"[AtlyssAP] Skipping storage entry: slot {_slotNumber} out of bounds " + $"(max {array.Length}) for item '{_itemData?._itemName}'")); } return false; } return true; } catch (Exception ex) { ManualLogSource staticLogger2 = AtlyssArchipelagoPlugin.StaticLogger; if (staticLogger2 != null) { staticLogger2.LogError((object)("[AtlyssAP] Create_StorageEntry safety check error: " + ex.Message)); } return true; } } } private static bool ShouldRedirect() { if ((Object)(object)AtlyssArchipelagoPlugin.Instance != (Object)null && AtlyssArchipelagoPlugin.Instance.connected) { return true; } if (ArchipelagoSpikeStorage.IsAPSessionActive()) { return true; } return false; } public static void InitializeAPStorage() { try { ArchipelagoSpikeStorage.SetAPSessionActive(); if (!ArchipelagoSpikeStorage.AreAPBanksInitialized()) { ArchipelagoSpikeStorage.InitializeAPBanks(); ManualLogSource staticLogger = AtlyssArchipelagoPlugin.StaticLogger; if (staticLogger != null) { staticLogger.LogInfo((object)"[AtlyssAP] Initialized AP Spike storage (separate from vanilla)"); } } else { int totalItemCount = ArchipelagoSpikeStorage.GetTotalItemCount(); ManualLogSource staticLogger2 = AtlyssArchipelagoPlugin.StaticLogger; if (staticLogger2 != null) { staticLogger2.LogInfo((object)$"[AtlyssAP] AP Spike storage loaded ({totalItemCount} items stored)"); } } } catch (Exception ex) { ManualLogSource staticLogger3 = AtlyssArchipelagoPlugin.StaticLogger; if (staticLogger3 != null) { staticLogger3.LogError((object)("[AtlyssAP] Failed to initialize AP storage: " + ex.Message)); } } } } public class ArchipelagoShopSanity { private class ShopAPItemInfo { public string ItemName; public string FromPlayer; public long LocationId; public int Price; public int SlotNumber; } private readonly AtlyssArchipelagoPlugin _plugin; private readonly ManualLogSource _logger; private static readonly long[] SHOP_LOCATION_IDS = new long[50] { 591300L, 591301L, 591302L, 591303L, 591304L, 591305L, 591306L, 591307L, 591308L, 591309L, 591310L, 591311L, 591312L, 591313L, 591314L, 591315L, 591316L, 591317L, 591318L, 591319L, 591320L, 591321L, 591322L, 591323L, 591324L, 591325L, 591326L, 591327L, 591328L, 591329L, 591330L, 591331L, 591332L, 591333L, 591334L, 591335L, 591336L, 591337L, 591338L, 591339L, 591340L, 591341L, 591342L, 591343L, 591344L, 591345L, 591346L, 591347L, 591348L, 591349L }; private static readonly Dictionary<string, (long start, long end)> MERCHANT_LOCATION_RANGES = new Dictionary<string, (long, long)> { { "Sally", (591300L, 591304L) }, { "Skrit", (591305L, 591309L) }, { "sallyWorker_frankie_01", (591310L, 591314L) }, { "Ruka", (591315L, 591319L) }, { "fisher", (591320L, 591324L) }, { "dyeMerchant", (591325L, 591329L) }, { "Tesh", (591330L, 591334L) }, { "Nesh", (591335L, 591339L) }, { "Cotoo", (591340L, 591344L) }, { "Rikko", (591345L, 591349L) } }; private static readonly int[] SHOP_PRICE_TIERS = new int[5] { 200, 400, 600, 800, 1000 }; private Dictionary<long, ShopAPItemInfo> _scoutedShopItems = new Dictionary<long, ShopAPItemInfo>(); private HashSet<long> _purchasedShopItems = new HashSet<long>(); private bool _shopItemsInitialized = false; public bool IsInitialized => _shopItemsInitialized; public ArchipelagoShopSanity(AtlyssArchipelagoPlugin plugin, ManualLogSource logger) { _plugin = plugin; _logger = logger; } public void SendLocationScouts(ArchipelagoSession session) { try { if (session == null) { _logger.LogError((object)"[AtlyssAP] Cannot scout - no session"); return; } _logger.LogInfo((object)$"[AtlyssAP] Scouting {SHOP_LOCATION_IDS.Length} shop locations..."); session.Locations.ScoutLocationsAsync(SHOP_LOCATION_IDS).ContinueWith(delegate(Task<Dictionary<long, ScoutedItemInfo>> task) { if (task.IsFaulted) { _logger.LogError((object)("[AtlyssAP] Scout failed: " + task.Exception?.GetBaseException().Message)); } else if (task.Status == TaskStatus.RanToCompletion) { ProcessScoutedLocations(session, task.Result); } }); } catch (Exception ex) { _logger.LogError((object)("[AtlyssAP] Error sending shop scouts: " + ex.Message)); } } private void ShuffleArray(int[] array) { for (int num = array.Length - 1; num > 0; num--) { int num2 = Random.Range(0, num + 1); int num3 = array[num]; array[num] = array[num2]; array[num2] = num3; } } private void ProcessScoutedLocations(ArchipelagoSession session, Dictionary<long, ScoutedItemInfo> scoutedLocations) { try { _scoutedShopItems.Clear(); _logger.LogInfo((object)$"[AtlyssAP] Processing {scoutedLocations.Count} scouted shop items"); foreach (KeyValuePair<string, (long, long)> mERCHANT_LOCATION_RANGE in MERCHANT_LOCATION_RANGES) { string key = mERCHANT_LOCATION_RANGE.Key; long item = mERCHANT_LOCATION_RANGE.Value.Item1; long item2 = mERCHANT_LOCATION_RANGE.Value.Item2; int[] array = (int[])SHOP_PRICE_TIERS.Clone(); ShuffleArray(array); int num = 0; for (long num2 = item; num2 <= item2; num2++) { if (!scoutedLocations.TryGetValue(num2, out var value)) { _logger.LogWarning((object)$"[AtlyssAP] Missing scouted data for location {num2}"); num++; continue; } string text = session.Items.GetItemName(((ItemInfo)value).ItemId, ((ItemInfo)value).ItemGame) ?? $"Item {((ItemInfo)value).ItemId}"; string text2 = session.Players.GetPlayerName(PlayerInfo.op_Implicit(value.Player)) ?? $"Player {value.Player}"; int num3 = array[num]; _scoutedShopItems[num2] = new ShopAPItemInfo { ItemName = text, FromPlayer = text2, LocationId = num2, Price = num3, SlotNumber = -1 }; _logger.LogInfo((object)$"[AtlyssAP] Scouted {key} #{num + 1}: {text} from {text2} ({num3} crowns)"); num++; } } _shopItemsInitialized = true; _logger.LogInfo((object)$"[AtlyssAP] Shop items initialized! {_scoutedShopItems.Count} items ready."); } catch (Exception ex) { _logger.LogError((object)("[AtlyssAP] Error processing scouted locations: " + ex.Message)); } } public void InjectAPShopItems(NetNPC npc) { //IL_0107: Unknown result type (might be due to invalid IL or missing references) //IL_010c: Unknown result type (might be due to invalid IL or missing references) //IL_0110: Unknown result type (might be due to invalid IL or missing references) //IL_029e: Unknown result type (might be due to invalid IL or missing references) //IL_02a3: Unknown result type (might be due to invalid IL or missing references) //IL_02ab: Unknown result type (might be due to invalid IL or missing references) //IL_02b2: Unknown result type (might be due to invalid IL or missing references) //IL_02b9: Unknown result type (might be due to invalid IL or missing references) //IL_02c1: Unknown result type (might be due to invalid IL or missing references) //IL_02c8: Unknown result type (might be due to invalid IL or missing references) //IL_02cf: Unknown result type (might be due to invalid IL or missing references) //IL_02d8: Expected O, but got Unknown //IL_02da: Unknown result type (might be due to invalid IL or missing references) //IL_034c: Unknown result type (might be due to invalid IL or missing references) //IL_034e: Unknown result type (might be due to invalid IL or missing references) //IL_036f: Unknown result type (might be due to invalid IL or missing references) try { string name = ((Object)((Component)npc).gameObject).name; _logger.LogInfo((object)("[AtlyssAP] Found NPC GameObject: '" + name + "'")); string text = null; (long, long) tuple = (0L, 0L); foreach (KeyValuePair<string, (long, long)> mERCHANT_LOCATION_RANGE in MERCHANT_LOCATION_RANGES) { if (name.Contains(mERCHANT_LOCATION_RANGE.Key)) { text = mERCHANT_LOCATION_RANGE.Key; tuple = mERCHANT_LOCATION_RANGE.Value; break; } } if (text == null) { _logger.LogWarning((object)("[AtlyssAP] Unknown merchant NPC: '" + name + "' - skipping AP injection")); return; } _logger.LogInfo((object)$"[AtlyssAP] Matched to merchant: {text} (locations {tuple.Item1}-{tuple.Item2})"); HashSet<int> hashSet = new HashSet<int>(); foreach (ShopkeepItemStruct value3 in npc._vendorItems.Values) { hashSet.Add(value3._itemData._slotNumber); } List<int> list = new List<int>(); int num = 0; while (list.Count < 5 && num < 100) { if (!hashSet.Contains(num)) { list.Add(num); } num++; } if (list.Count < 5) { _logger.LogWarning((object)$"[AtlyssAP] Only found {list.Count} available slots for {text}"); } int num2 = 0; var (num3, _) = tuple; for (; num3 <= tuple.Item2; num3++) { if (!_scoutedShopItems.TryGetValue(num3, out var value)) { _logger.LogWarning((object)$"[AtlyssAP] Missing scouted data for location {num3}"); } else if (!_purchasedShopItems.Contains(num3)) { if (num2 >= list.Count) { _logger.LogWarning((object)("[AtlyssAP] Ran out of slots for " + text)); break; } int num4 = (value.SlotNumber = list[num2]); string text2 = "[AP] " + value.ItemName + " (" + value.FromPlayer + ")"; ItemData itemData = new ItemData { _itemName = text2, _quantity = 0, _maxQuantity = 1, _slotNumber = num4, _modifierID = 0, _isEquipped = false, _isAltWeapon = false }; ShopkeepItemStruct val = default(ShopkeepItemStruct); val._itemName = text2; val._dedicatedValue = value.Price; val._useDedicatedValue = true; val._itemData = itemData; val._stockQuantity = 1; val._removeAtEmptyStock = true; val._isbuybackItem = false; val._isGambleItem = false; val._equipModifierID = 0; val._specialItemCostName = string.Empty; val._specialItemCostQuantity = 0; val._gambleValue = 0; ShopkeepItemStruct value2 = val; if (!npc._vendorItems.ContainsKey(text2)) { npc._vendorItems.Add(text2, value2); _logger.LogInfo((object)$"[AtlyssAP] Injected: {text2} in slot {num4} for {value.Price} crowns"); } num2++; } } _logger.LogInfo((object)$"[AtlyssAP] Successfully injected {num2} AP items into {text}!"); } catch (Exception ex) { _logger.LogError((object)("[AtlyssAP] Error injecting shop items: " + ex.Message)); } } public void HandleAPItemPurchase(string displayName, string key) { try { string text = LocateItemPatch.ExtractItemName(displayName); _logger.LogInfo((object)("[AtlyssAP] Looking for purchased item: " + text)); ShopAPItemInfo shopAPItemInfo = null; foreach (ShopAPItemInfo value in _scoutedShopItems.Values) { if (value.ItemName == text && !_purchasedShopItems.Contains(value.LocationId)) { shopAPItemInfo = value; break; } } if (shopAPItemInfo == null) { _logger.LogWarning((object)("[AtlyssAP] No unpurchased AP item found for: " + text + " (all copies may already be bought)")); } else if (_plugin._session != null && _plugin._session.Socket.Connected) { _plugin._session.Locations.CompleteLocationChecks(new long[1] { shopAPItemInfo.LocationId }); _purchasedShopItems.Add(shopAPItemInfo.LocationId); _plugin.SendAPChatMessage("<color=yellow>Purchased " + text + "!</color> Item sent to Spike storage!"); _logger.LogInfo((object)$"[AtlyssAP] Shop purchase completed: {displayName} (Location {shopAPItemInfo.LocationId})"); } else { _logger.LogError((object)"[AtlyssAP] Not connected to Archipelago server!"); } } catch (Exception ex) { _logger.LogError((object)("[AtlyssAP] Error handling AP purchase: " + ex.Message)); } } public void Reset() { _scoutedShopItems.Clear(); _purchasedShopItems.Clear(); _shopItemsInitialized = false; _logger.LogInfo((object)"[AtlyssAP] Shop sanity state reset"); } } public class ArchipelagoSpikeStorage { [Serializable] public class ItemBankData { public List<ItemData> _heldItemStorage = new List<ItemData>(); } private const int NUM_BANKS = 7; private const int MASTER_BANK_SLOTS = 40; private const int NUMBERED_BANK_SLOTS = 40; private static HashSet<string> _droppedItemsLogged = new HashSet<string>(); private static HashSet<string> _validatedBanks = new HashSet<string>(); private static string GetSessionMarkerPath() { string path = Path.Combine(Application.dataPath, "profileCollections"); return Path.Combine(path, "ap_session_active"); } public static bool IsAPSessionActive() { return File.Exists(GetSessionMarkerPath()); } public static void SetAPSessionActive() { try { string sessionMarkerPath = GetSessionMarkerPath(); string directoryName = Path.GetDirectoryName(sessionMarkerPath); if (!Directory.Exists(directoryName)) { Directory.CreateDirectory(directoryName); } File.WriteAllText(sessionMarkerPath, DateTime.UtcNow.ToString("o")); ManualLogSource staticLogger = AtlyssArchipelagoPlugin.StaticLogger; if (staticLogger != null) { staticLogger.LogInfo((object)"[AtlyssAP] AP session marker set (storage will persist across restarts)"); } } catch (Exception ex) { ManualLogSource staticLogger2 = AtlyssArchipelagoPlugin.StaticLogger; if (staticLogger2 != null) { staticLogger2.LogError((object)("[AtlyssAP] Failed to set session marker: " + ex.Message)); } } } public static void ClearAPSession() { try { string sessionMarkerPath = GetSessionMarkerPath(); if (File.Exists(sessionMarkerPath)) { File.Delete(sessionMarkerPath); } ClearAllAPBanks(); _droppedItemsLogged.Clear(); _validatedBanks.Clear(); ManualLogSource staticLogger = AtlyssArchipelagoPlugin.StaticLogger; if (staticLogger != null) { staticLogger.LogInfo((object)"[AtlyssAP] AP session cleared (marker removed, banks wiped)"); } } catch (Exception ex) { ManualLogSource staticLogger2 = AtlyssArchipelagoPlugin.StaticLogger; if (staticLogger2 != null) { staticLogger2.LogError((object)("[AtlyssAP] Failed to clear session: " + ex.Message)); } } } public static string GetAPMasterBankPath() { string path = Path.Combine(Application.dataPath, "profileCollections"); return Path.Combine(path, "atl_itemBank_ap"); } public static string GetAPBankPath(int bankNumber) { if (bankNumber < 1 || bankNumber > 7) { throw new ArgumentException($"Bank number must be between 1 and {7}"); } string path = Path.Combine(Application.dataPath, "profileCollections"); return Path.Combine(path, $"atl_itemBank_ap_{bankNumber:D2}"); } public static void InitializeAPBanks() { try { string aPMasterBankPath = GetAPMasterBankPath(); string directoryName = Path.GetDirectoryName(aPMasterBankPath); if (!Directory.Exists(directoryName)) { Directory.CreateDirectory(directoryName); } if (!File.Exists(aPMasterBankPath)) { ItemBankData itemBankData = new ItemBankData(); string contents = JsonConvert.SerializeObject((object)itemBankData, (Formatting)1); File.WriteAllText(aPMasterBankPath, contents); ManualLogSource staticLogger = AtlyssArchipelagoPlugin.StaticLogger; if (staticLogger != null) { staticLogger.LogInfo((object)"[AtlyssAP] Created AP master item bank"); } } for (int i = 1; i <= 7; i++) { string aPBankPath = GetAPBankPath(i); if (!File.Exists(aPBankPath)) { ItemBankData itemBankData2 = new ItemBankData(); string contents2 = JsonConvert.SerializeObject((object)itemBankData2, (Formatting)1); File.WriteAllText(aPBankPath, contents2); ManualLogSource staticLogger2 = AtlyssArchipelagoPlugin.StaticLogger; if (staticLogger2 != null) { staticLogger2.LogInfo((object)$"[AtlyssAP] Created AP item bank {i}"); } } } ManualLogSource staticLogger3 = AtlyssArchipelagoPlugin.StaticLogger; if (staticLogger3 != null) { staticLogger3.LogInfo((object)"[AtlyssAP] Archipelago item banks initialized"); } } catch (Exception ex) { ManualLogSource staticLogger4 = AtlyssArchipelagoPlugin.StaticLogger; if (staticLogger4 != null) { staticLogger4.LogError((object)("[AtlyssAP] Failed to initialize AP banks: " + ex.Message)); } } } private static bool ValidateBank(ItemBankData bank, int maxSlots) { if (bank == null || bank._heldItemStorage == null || bank._heldItemStorage.Count == 0) { return false; } bool result = false; HashSet<int> hashSet = new HashSet<int>(); foreach (ItemData item in bank._heldItemStorage) { bool flag = false; if (item._slotNumber < 0 || item._slotNumber >= maxSlots) { flag = true; } else if (hashSet.Contains(item._slotNumber)) { flag = true; } if (flag) { int i; for (i = 0; hashSet.Contains(i) && i < maxSlots; i++) { } if (i < maxSlots) { ManualLogSource staticLogger = AtlyssArchipelagoPlugin.StaticLogger; if (staticLogger != null) { staticLogger.LogWarning((object)$"[AtlyssAP] Fixing item '{item._itemName}' slot {item._slotNumber} -> {i} (was out-of-bounds or overlapping)"); } item._slotNumber = i; hashSet.Add(i); result = true; continue; } item._slotNumber = -1; result = true; if (!_droppedItemsLogged.Contains(item._itemName)) { _droppedItemsLogged.Add(item._itemName); ManualLogSource staticLogger2 = AtlyssArchipelagoPlugin.StaticLogger; if (staticLogger2 != null) { staticLogger2.LogWarning((object)("[AtlyssAP] Bank full, dropping item '" + item._itemName + "' (further drops of this item will be silent)")); } } } else { hashSet.Add(item._slotNumber); } } int num = bank._heldItemStorage.RemoveAll((ItemData item) => item._slotNumber < 0 || item._slotNumber >= maxSlots); if (num > 0) { ManualLogSource staticLogger3 = AtlyssArchipelagoPlugin.StaticLogger; if (staticLogger3 != null) { staticLogger3.LogInfo((object)$"[AtlyssAP] Removed {num} overflow item(s) from bank"); } } return result; } public static ItemBankData LoadAPBank(int bankNumber) { try { string aPBankPath = GetAPBankPath(bankNumber); if (!File.Exists(aPBankPath)) { return new ItemBankData(); } string text = File.ReadAllText(aPBankPath); ItemBankData itemBankData = JsonConvert.DeserializeObject<ItemBankData>(text); itemBankData = itemBankData ?? new ItemBankData(); if (!_validatedBanks.Contains(aPBankPath)) { if (ValidateBank(itemBankData, 40)) { SaveAPBank(bankNumber, itemBankData); ManualLogSource staticLogger = AtlyssArchipelagoPlugin.StaticLogger; if (staticLogger != null) { staticLogger.LogInfo((object)$"[AtlyssAP] Fixed slot numbers in AP bank {bankNumber}"); } } _validatedBanks.Add(aPBankPath); } return itemBankData; } catch (Exception ex) { ManualLogSource staticLogger2 = AtlyssArchipelagoPlugin.StaticLogger; if (staticLogger2 != null) { staticLogger2.LogError((object)$"[AtlyssAP] Failed to load AP bank {bankNumber}: {ex.Message}"); } return new ItemBankData(); } } public static void SaveAPBank(int bankNumber, ItemBankData data) { try { string aPBankPath = GetAPBankPath(bankNumber); string contents = JsonConvert.SerializeObject((object)data, (Formatting)1); File.WriteAllText(aPBankPath, contents); } catch (Exception ex) { ManualLogSource staticLogger = AtlyssArchipelagoPlugin.StaticLogger; if (staticLogger != null) { staticLogger.LogError((object)$"[AtlyssAP] Failed to save AP bank {bankNumber}: {ex.Message}"); } } } public static ItemBankData LoadAPMasterBank() { try { string aPMasterBankPath = GetAPMasterBankPath(); if (!File.Exists(aPMasterBankPath)) { return new ItemBankData(); } string text = File.ReadAllText(aPMasterBankPath); ItemBankData itemBankData = JsonConvert.DeserializeObject<ItemBankData>(text); itemBankData = itemBankData ?? new ItemBankData(); if (!_validatedBanks.Contains(aPMasterBankPath)) { if (ValidateBank(itemBankData, 40)) { SaveAPMasterBank(itemBankData); ManualLogSource staticLogger = AtlyssArchipelagoPlugin.StaticLogger; if (staticLogger != null) { staticLogger.LogInfo((object)"[AtlyssAP] Fixed slot numbers in AP master bank"); } } _validatedBanks.Add(aPMasterBankPath); } return itemBankData; } catch (Exception ex) { ManualLogSource staticLogger2 = AtlyssArchipelagoPlugin.StaticLogger; if (staticLogger2 != null) { staticLogger2.LogError((object)("[AtlyssAP] Failed to load AP master bank: " + ex.Message)); } return new ItemBankData(); } } public static void SaveAPMasterBank(ItemBankData data) { try { string aPMasterBankPath = GetAPMasterBankPath(); string contents = JsonConvert.SerializeObject((object)data, (Formatting)1); File.WriteAllText(aPMasterBankPath, contents); } catch (Exception ex) { ManualLogSource staticLogger = AtlyssArchipelagoPlugin.StaticLogger; if (staticLogger != null) { staticLogger.LogError((object)("[AtlyssAP] Failed to save AP master bank: " + ex.Message)); } } } public static bool AddItemToAPSpike(ItemData itemToAdd) { try { if (itemToAdd._maxQuantity > 1) { ItemBankData itemBankData = LoadAPMasterBank(); foreach (ItemData item in itemBankData._heldItemStorage) { if (!(item._itemName == itemToAdd._itemName) || item._quantity >= item._maxQuantity) { continue; } int val = item._maxQuantity - item._quantity; int num = Math.Min(val, itemToAdd._quantity); item._quantity += num; itemToAdd._quantity -= num; SaveAPMasterBank(itemBankData); if (itemToAdd._quantity == 0) { ManualLogSource staticLogger = AtlyssArchipelagoPlugin.StaticLogger; if (staticLogger != null) { staticLogger.LogInfo((object)("[AtlyssAP] Added " + itemToAdd._itemName + " to AP Spike MASTER bank (stacked)")); } return true; } } for (int i = 1; i <= 7; i++) { ItemBankData itemBankData2 = LoadAPBank(i); foreach (ItemData item2 in itemBankData2._heldItemStorage) { if (!(item2._itemName == itemToAdd._itemName) || item2._quantity >= item2._maxQuantity) { continue; } int val2 = item2._maxQuantity - item2._quantity; int num2 = Math.Min(val2, itemToAdd._quantity); item2._quantity += num2; itemToAdd._quantity -= num2; SaveAPBank(i, itemBankData2); if (itemToAdd._quantity == 0) { ManualLogSource staticLogger2 = AtlyssArchipelagoPlugin.StaticLogger; if (staticLogger2 != null) { staticLogger2.LogInfo((object)$"[AtlyssAP] Added {itemToAdd._itemName} to AP Spike bank {i} (stacked)"); } return true; } } } } ItemBankData itemBankData3 = LoadAPMasterBank(); int num3 = FindNextOpenSlot(itemBankData3, 40); if (num3 >= 0) { itemToAdd._slotNumber = num3; itemToAdd._isEquipped = false; itemBankData3._heldItemStorage.Add(itemToAdd); SaveAPMasterBank(itemBankData3); ManualLogSource staticLogger3 = AtlyssArchipelagoPlugin.StaticLogger; if (staticLogger3 != null) { staticLogger3.LogInfo((object)$"[AtlyssAP] Added {itemToAdd._itemName} to AP Spike MASTER bank slot {num3}"); } return true; } for (int j = 1; j <= 7; j++) { ItemBankData itemBankData4 = LoadAPBank(j); int num4 = FindNextOpenSlot(itemBankData4, 40); if (num4 >= 0) { itemToAdd._slotNumber = num4; itemToAdd._isEquipped = false; itemBankData4._heldItemStorage.Add(itemToAdd); SaveAPBank(j, itemBankData4); ManualLogSource staticLogger4 = AtlyssArchipelagoPlugin.StaticLogger; if (staticLogger4 != null) { staticLogger4.LogInfo((object)$"[AtlyssAP] Added {itemToAdd._itemName} to AP Spike bank {j} slot {num4}"); } return true; } } ManualLogSource staticLogger5 = AtlyssArchipelagoPlugin.StaticLogger; if (staticLogger5 != null) { staticLogger5.LogWarning((object)("[AtlyssAP] All AP Spike banks are full! Cannot add " + itemToAdd._itemName)); } return false; } catch (Exception ex) { ManualLogSource staticLogger6 = AtlyssArchipelagoPlugin.StaticLogger; if (staticLogger6 != null) { staticLogger6.LogError((object)("[AtlyssAP] Failed to add item to AP Spike: " + ex.Message)); } return false; } } private static int FindNextOpenSlot(ItemBankData bank, int maxSlots) { HashSet<int> hashSet = new HashSet<int>(); foreach (ItemData item in bank._heldItemStorage) { hashSet.Add(item._slotNumber); } int i; for (i = 0; hashSet.Contains(i); i++) { } return (i < maxSlots) ? i : (-1); } public static int GetTotalItemCount() { int num = 0; ItemBankData itemBankData = LoadAPMasterBank(); num += itemBankData._heldItemStorage.Count; for (int i = 1; i <= 7; i++) { ItemBankData itemBankData2 = LoadAPBank(i); num += itemBankData2._heldItemStorage.Count; } return num; } public static bool AreAPBanksInitialized() { if (!File.Exists(GetAPMasterBankPath())) { return false; } for (int i = 1; i <= 7; i++) { if (!File.Exists(GetAPBankPath(i))) { return false; } } return true; } public static void ClearAllAPBanks() { try { ItemBankData data = new ItemBankData(); SaveAPMasterBank(data); for (int i = 1; i <= 7; i++) { SaveAPBank(i, data); } _droppedItemsLogged.Clear(); _validatedBanks.Clear(); ManualLogSource staticLogger = AtlyssArchipelagoPlugin.StaticLogger; if (staticLogger != null) { staticLogger.LogInfo((object)"[AtlyssAP] Cleared all AP item banks (master + numbered)"); } } catch (Exception ex) { ManualLogSource staticLogger2 = AtlyssArchipelagoPlugin.StaticLogger; if (staticLogger2 != null) { staticLogger2.LogError((object)("[AtlyssAP] Failed to clear AP banks: " + ex.Message)); } } } } [BepInPlugin("com.azrael.atlyss.ap", "Atlyss Archipelago", "1.3.1")] public class AtlyssArchipelagoPlugin : BaseUnityPlugin { [CompilerGenerated] private sealed class <EnableSettingsTabs>d__90 : IEnumerator<object>, IDisposable, IEnumerator { private int <>1__state; private object <>2__current; public AtlyssArchipelagoPlugin <>4__this; object IEnumerator<object>.Current { [DebuggerHidden] get { return <>2__current; } } object IEnumerator.Current { [DebuggerHidden] get { return <>2__current; } } [DebuggerHidden] public <EnableSettingsTabs>d__90(int <>1__state) { this.<>1__state = <>1__state; } [DebuggerHidden] void IDisposable.Dispose() { <>1__state = -2; } private bool MoveNext() { //IL_0021: Unknown result type (might be due to invalid IL or missing references) //IL_002b: Expected O, but got Unknown switch (<>1__state) { default: return false; case 0: <>1__state = -1; <>2__current = (object)new WaitForEndOfFrame(); <>1__state = 1; return true; case 1: <>1__state = -1; GameObject.Find("_SettingsManager/Canvas_SettingsMenu/_dolly_settingsMenu/_dolly_tabButtons").SetActive(true); return false; } } bool IEnumerator.MoveNext() { //ILSpy generated this explicit interface implementation from .override directive in MoveNext return this.MoveNext(); } [DebuggerHidden] void IEnumerator.Reset() { throw new NotSupportedException(); } } private static Harmony _harmony; private static GameObject scriptHolder; private static PortalUnlocks portalLocker; private static readonly FieldInfo maxOnscreenMessages = AccessTools.Field(typeof(ChatBehaviour), "_maxGameLogicLines"); public ConfigEntry<string> cfgServer; public ConfigEntry<string> cfgSlot; public ConfigEntry<string> cfgPassword; public ConfigEntry<bool> cfgDeathlink; private ConfigEntry<bool> cfgAutoConnect; public InputField apServer; public InputField apSlot; public InputField apPassword; public Toggle apDeathlink; public ArchipelagoSession _session; public bool connected; private bool connecting; private Dictionary<string, object> slotData = new Dictionary<string, object>(); public DeathLinkService _dlService; public static int reactingToDeathLink; private int goalOption = 3; public bool randomPortalsEnabled = false; private int equipmentGatingOption = 0; private bool shopSanityEnabled = false; private int progressivePortalCount = 0; private ConcurrentQueue<(string itemName, string fromPlayer)> _receivedItemQueue = new ConcurrentQueue<(string, string)>(); private Dictionary<string, bool> _portalItemsReceived = new Dictionary<string, bool> { { "Outer Sanctum Portal", false }, { "Effold Terrace Portal", false }, { "Arcwood Pass Portal", false }, { "Tull Valley Portal", false }, { "Crescent Road Portal", false }, { "Catacombs Portal", false }, { "Crescent Keep Portal", false }, { "Tull Enclave Portal", false }, { "Bularr Fortress Portal", false }, { "Grove Portal", false } }; private Dictionary<string, string> _portalScenes = new Dictionary<string, string> { { "Outer Sanctum Portal", "Assets/Scenes/00_zone_forest/_zone00_outerSanctum.unity" }, { "Effold Terrace Portal", "Assets/Scenes/00_zone_forest/_zone00_effoldTerrace.unity" }, { "Arcwood Pass Portal", "Assets/Scenes/00_zone_forest/_zone00_arcwoodPass.unity" }, { "Tull Valley Portal", "Assets/Scenes/00_zone_forest/_zone00_tuulValley.unity" }, { "Crescent Road Portal", "Assets/Scenes/00_zone_forest/_zone00_crescentRoad.unity" }, { "Catacombs Portal", "Assets/Scenes/map_dungeon00_sanctumCatacombs.unity" }, { "Crescent Keep Portal", "Assets/Scenes/00_zone_forest/_zone00_crescentKeep.unity" }, { "Tull Enclave Portal", "Assets/Scenes/00_zone_forest/_zone00_tuulEnclave.unity" }, { "Bularr Fortress Portal", "Assets/Scenes/00_zone_forest/_zone00_bularFortress.unity" }, { "Grove Portal", "Assets/Scenes/map_dungeon01_crescentGrove.unity" } }; private List<string> _progressivePortalOrder = new List<string> { "Outer Sanctum Portal", "Arcwood Pass Portal", "Catacombs Portal", "Effold Terrace Portal", "Tull Valley Portal", "Crescent Road Portal", "Crescent Keep Portal", "Tull Enclave Portal", "Grove Portal", "Bularr Fortress Portal" }; public ArchipelagoShopSanity _shopSanity; private readonly HashSet<long> _reportedChecks = new HashSet<long>(); private int _lastLevel = 0; private int _previousFishingLevel = 1; private int _previousMiningLevel = 1; private HashSet<string> _completedQuests = new HashSet<string>(); private bool _questDebugLogged = false; private string currentSessionId = ""; private const string SESSION_FILE = "ap_session.json"; private const long BASE_LOCATION_ID = 591000L; private const long DEFEAT_SLIME_DIVA = 591001L; private const long DEFEAT_LORD_ZUULNERUDA = 591002L; private const long DEFEAT_GALIUS = 591003L; private const long DEFEAT_COLOSSUS = 591004L; private const long DEFEAT_LORD_KALUUZ = 591005L; private const long DEFEAT_VALDUR = 591006L; private const long REACH_LEVEL_2 = 591010L; private const long IRRITATE_ANGELA = 591500L; private static readonly Dictionary<string, long> AllQuestToLocation = new Dictionary<string, long> { { "Diva Must Die", 591001L }, { "The Voice of Zuulneruda", 591002L }, { "Gatling Galius", 591003L }, { "The Colossus", 591004L }, { "A Warm Welcome", 591030L }, { "Communing Catacombs", 591031L }, { "Dense Ingots", 591100L }, { "Ghostly Goods", 591101L }, { "Killing Tomb", 591102L }, { "Night Spirits", 591103L }, { "Ridding Slimes", 591104L }, { "Summore' Spectral Powder!", 591105L }, { "Call of Fury", 591110L }, { "Cold Shoulder", 591111L }, { "Focusin' in", 591112L }, { "Cleaning Terrace", 591115L }, { "Huntin' Hogs", 591116L }, { "Amberite Ingots", 591120L }, { "Makin' a Mekspear", 591121L }, { "Makin' More Mekspears", 591122L }, { "Purging the Undead", 591123L }, { "Rattlecage Rage", 591124L }, { "Ancient Beings", 591125L }, { "Makin' a Vile Blade", 591130L }, { "Makin' a Wizwand", 591131L }, { "Makin' More Vile Blades", 591132L }, { "Makin' More Wizwands", 591133L }, { "Sapphite Ingots", 591134L }, { "Devious Pact", 591140L }, { "Disciple of Magic", 591141L }, { "Mastery of Dexterity", 591142L }, { "Mastery of Mind", 591143L }, { "Mastery of Strength", 591144L }, { "Strength and Honor", 591145L }, { "Wicked Wizboars", 591146L }, { "Beckoning Foes", 591150L }, { "Blossom of Life", 591151L }, { "Consumed Madness", 591152L }, { "Eradicating the Undead", 591153L }, { "Makin' a Golem Chestpiece", 591154L }, { "Summore' Golem Chestpieces", 591155L }, { "Whatta' Rush!", 591156L }, { "Finding Ammagon", 591160L }, { "Reviling the Rageboars", 591161L }, { "Reviling More Rageboars", 591162L }, { "Makin' a Ragespear", 591165L }, { "Makin' More Ragespears", 591166L }, { "Purging the Grove", 591167L }, { "Searching for the Grove", 591168L }, { "Tethering Grove", 591169L }, { "Up and Over It", 591170L }, { "Makin' a Monolith Chestpiece", 591175L }, { "Summore' Monolith Chestpieces", 591176L }, { "Facing Foes", 591180L }, { "Cleansing the Grove", 591200L }, { "Spiraling In The Grove", 591201L }, { "Hell In The Grove", 591202L }, { "Makin' a Firebreath Blade", 591203L }, { "Nulversa Magica", 591204L }, { "Nulversa Viscera", 591205L }, { "Nulversa, Greenveras!", 591206L }, { "Summore' Firebreath Blades", 591207L }, { "The Gall of Galius", 591220L }, { "Makin' a Follycannon", 591240L }, { "Makin' More Follycannons", 591241L }, { "The Glyphik Booklet", 591242L } }; private static readonly Dictionary<long, string> LocationIdToName = new Dictionary<long, string> { { 591010L, "Reach Level 2" }, { 591011L, "Reach Level 4" }, { 591012L, "Reach Level 6" }, { 591013L, "Reach Level 8" }, { 591014L, "Reach Level 10" }, { 591015L, "Reach Level 12" }, { 591016L, "Reach Level 14" }, { 591017L, "Reach Level 16" }, { 591018L, "Reach Level 18" }, { 591019L, "Reach Level 20" }, { 591020L, "Reach Level 22" }, { 591021L, "Reach Level 24" }, { 591022L, "Reach Level 26" }, { 591023L, "Reach Level 28" }, { 591024L, "Reach Level 30" }, { 591025L, "Reach Level 32" }, { 591001L, "Defeat Slime Diva" }, { 591002L, "Defeat Lord Zuulneruda" }, { 591003L, "Defeat Galius" }, { 591500L, "Smack Dat Azz" } }; private static readonly Dictionary<int, long> FishingLevelLocations = new Dictionary<int, long> { { 2, 591400L }, { 3, 591401L }, { 4, 591402L }, { 5, 591403L }, { 6, 591404L }, { 7, 591405L }, { 8, 591406L }, { 9, 591407L }, { 10, 591408L } }; private static readonly Dictionary<int, long> MiningLevelLocations = new Dictionary<int, long> { { 2, 591409L }, { 3, 591410L }, { 4, 591411L }, { 5, 591412L }, { 6, 591413L }, { 7, 591414L }, { 8, 591415L }, { 9, 591416L }, { 10, 591417L } }; public static readonly Dictionary<string, string> ItemNameMapping = new Dictionary<string, string> { { "Bunbag Pack", "(lv-0) STATUSCONSUMABLE_Bunbag" }, { "Bunjar Pack", "(lv-0) STATUSCONSUMABLE_Bunjar" }, { "Bunpot Pack", "(lv-0) STATUSCONSUMABLE_Bunpot" }, { "Regen Potion Pack", "(lv-10) STATUSCONSUMABLE_Regen Potion" }, { "Regen Vial Pack", "(lv-0) STATUSCONSUMABLE_Regen Vial" }, { "Magiclove Pack", "(lv-0) STATUSCONSUMABLE_Magiclove" }, { "Magiflower Pack", "(lv-0) STATUSCONSUMABLE_Magiflower" }, { "Magileaf Pack", "(lv-0) STATUSCONSUMABLE_Magileaf" }, { "Stamstar Pack", "(lv-0) STATUSCONSUMABLE_Stamstar" }, { "Agility Potion Pack", "(lv-10) STATUSCONSUMABLE_Agility Potion" }, { "Agility Vial Pack", "(lv-0) STATUSCONSUMABLE_Agility Vial" }, { "Bolster Potion Pack", "(lv-10) STATUSCONSUMABLE_Bolster Potion" }, { "Bolster Vial Pack", "(lv-0) STATUSCONSUMABLE_Bolster Vial" }, { "Wisdom Potion Pack", "(lv-10) STATUSCONSUMABLE_Wisdom Potion" }, { "Wisdom Vial Pack", "(lv-0) STATUSCONSUMABLE_Wisdom Vial" }, { "Tome of Greater Experience", "(lv-0) STATUSCONSUMABLE_Tome of Greater Experience" }, { "Tome of Experience", "(lv-0) STATUSCONSUMABLE_Tome of Experience" }, { "Tome of Lesser Experience", "(lv-0) STATUSCONSUMABLE_Tome of Lesser Experience" }, { "Carrot Cake Pack", "(lv-0) STATUSCONSUMABLE_Carrot Cake" }, { "Minchroom Juice Pack", "(lv-0) STATUSCONSUMABLE_Minchroom Juice" }, { "Spectral Powder Pack", "(lv-0) STATUSCONSUMABLE_Spectral Powder" }, { "Geistlord Badge Pack", "TRADEITEM_Geistlord Badge" }, { "Coldgeist Badge Pack", "TRADEITEM_Coldgeist Badge" }, { "Earthcore Badge Pack", "TRADEITEM_Earthcore Badge" }, { "Windcore Badge Pack", "TRADEITEM_Windcore Badge" }, { "Iron Cluster Pack", "TRADEITEM_Iron Cluster" }, { "Copper Cluster Pack", "TRADEITEM_Copper Cluster" }, { "Mithril Cluster Pack", "TRADEITEM_Mithril Cluster" }, { "Dense Ingot Pack", "TRADEITEM_Dense Ingot" }, { "Sapphite Ingot Pack", "TRADEITEM_Sapphite Ingot" }, { "Amberite Ingot Pack", "TRADEITEM_Amberite Ingot" }, { "Soul Pearl", "TRADEITEM_Soul Pearl" }, { "Experience Bond Pack", "TRADEITEM_Experience Bond" }, { "Crypt Blade", "(lv-2) WEAPON_Crypt Blade (Sword, Strength)" }, { "Femur Club", "(lv-2) WEAPON_Femur Club (Sword, Strength)" }, { "Ironbark Sword", "(lv-2) WEAPON_Ironbark Sword (Sword, Strength)" }, { "Slimecrust Blade", "(lv-2) WEAPON_Slimecrust Blade (Sword, Strength)" }, { "Gilded Sword", "(lv-4) WEAPON_Gilded Sword (Sword, Strength)" }, { "Splitbark Club", "(lv-4) WEAPON_Splitbark Club (Sword, Strength)" }, { "Demicrypt Blade", "(lv-6) WEAPON_Demicrypt Blade (Sword, Strength)" }, { "Dense Mace", "(lv-6) WEAPON_Dense Mace (Sword, Strength)" }, { "Iron Sword", "(lv-6) WEAPON_Iron Sword (Sword, Strength)" }, { "Dawn Mace", "(lv-8) WEAPON_Dawn Mace (Sword, Strength)" }, { "Rude Blade", "(lv-8) WEAPON_Rude Blade (Sword, Strength)" }, { "Vile Blade", "(lv-8) WEAPON_Vile Blade (Sword, Strength)" }, { "Amberite Sword", "(lv-12) WEAPON_Amberite Sword (Sword, Strength)" }, { "Nethercrypt Blade", "(lv-12) WEAPON_Nethercrypt Blade (Sword, Strength)" }, { "Coldgeist Blade", "(lv-16) WEAPON_Coldgeist Blade (Sword, Strength)" }, { "Mithril Sword", "(lv-16) WEAPON_Mithril Sword (Sword, Strength)" }, { "Serrated Blade", "(lv-16) WEAPON_Serrated Blade (Sword, Strength)" }, { "Nulrok Mace", "(lv-20) WEAPON_Nulrok Mace (Sword, Strength)" }, { "Firebreath Blade", "(lv-22) WEAPON_Firebreath Blade (Sword, Strength)" }, { "Valdur Blade", "(lv-24) WEAPON_Valdur Blade (Sword, Strength)" }, { "Fier Blade", "(lv-26) WEAPON_Fier Blade (Sword, Strength)" }, { "Slimek Axehammer", "(lv-4) WEAPON_Slimek Axehammer (Hammer, Strength)" }, { "Dense Hammer", "(lv-6) WEAPON_Dense Hammer (Hammer, Strength)" }, { "Iron Axehammer", "(lv-6) WEAPON_Iron Axehammer (Hammer, Strength)" }, { "Crypt Pounder", "(lv-8) WEAPON_Crypt Pounder (Hammer, Strength)" }, { "Quake Pummeler", "(lv-18) WEAPON_Quake Pummeler (Hammer, Strength)" }, { "Mini Geist Scythe", "(lv-4) WEAPON_Mini Geist Scythe (Greatblade, Strength)" }, { "Geist Scythe", "(lv-6) WEAPON_Geist Scythe (Greatblade, Strength)" }, { "Stone Greatblade", "(lv-8) WEAPON_Stone Greatblade (Greatblade, Strength)" }, { "Amberite Warstar", "(lv-12) WEAPON_Amberite Warstar (Greatblade, Strength)" }, { "Dolkin's Axe", "(lv-12) WEAPON_Dolkin's Axe (Greatblade, Strength)" }, { "Poltergeist Scythe", "(lv-14) WEAPON_Poltergeist Scythe (Greatblade, Strength)" }, { "Coldgeist Punisher", "(lv-16) WEAPON_Coldgeist Punisher (Greatblade, Strength)" }, { "Deadwood Axe", "(lv-16) WEAPON_Deadwood Axe (Greatblade, Strength)" }, { "Mithril Greatsword", "(lv-16) WEAPON_Mithril Greatsword (Greatblade, Strength)" }, { "Deathknight Runeblade", "(lv-22) WEAPON_Deathknight Runeblade (Greatblade, Strength)" }, { "Ryzer Greataxe", "(lv-26) WEAPON_Ryzer Greataxe (Greatblade, Strength)" }, { "Dense Spear", "(lv-6) WEAPON_Dense Spear (Polearm, Strength)" }, { "Iron Spear", "(lv-6) WEAPON_Iron Spear (Polearm, Strength)" }, { "Cryptsinge Halberd", "(lv-8) WEAPON_Cryptsinge Halberd (Polearm, Strength)" }, { "Mekspear", "(lv-8) WEAPON_Mekspear (Polearm, Strength)" }, { "Amberite Halberd", "(lv-12) WEAPON_Amberite Halberd (Polearm, Strength)" }, { "Necroroyal Halberd", "(lv-12) WEAPON_Necroroyal Halberd (Polearm, Strength)" }, { "Sinner Bardiche", "(lv-12) WEAPON_Sinner Bardiche (Polearm, Strength)" }, { "Mithril Halberd", "(lv-16) WEAPON_Mithril Halberd (Polearm, Strength)" }, { "Ragespear", "(lv-16) WEAPON_Ragespear (Polearm, Strength)" }, { "Serrated Spear", "(lv-16) WEAPON_Serrated Spear (Polearm, Strength)" }, { "Sapphite Spear", "(lv-18) WEAPON_Sapphite Spear (Polearm, Strength)" }, { "Nulrok Spear", "(lv-20) WEAPON_Nulrok Spear (Polearm, Strength)" }, { "Cryotribe Spear", "(lv-22) WEAPON_Cryotribe Spear (Polearm, Strength)" }, { "Flametribe Spear", "(lv-22) WEAPON_Flametribe Spear (Polearm, Strength)" }, { "Marrow Bauble", "(lv-2) WEAPON_Marrow Bauble (Scepter, Mind)" }, { "Splitbark Scepter", "(lv-2) WEAPON_Splitbark Scepter (Scepter, Mind)" }, { "Demicrypt Bauble", "(lv-6) WEAPON_Demicrypt Bauble (Scepter, Mind)" }, { "Iron Scepter", "(lv-6) WEAPON_Iron Scepter (Scepter, Mind)" }, { "Cryo Cane", "(lv-8) WEAPON_Cryo Cane (Scepter, Mind)" }, { "Slime Diva Baton", "(lv-8) WEAPON_Slime Diva Baton (Scepter, Mind)" }, { "Pyre Cane", "(lv-12) WEAPON_Pyre Cane (Scepter, Mind)" }, { "Wizwand", "(lv-12) WEAPON_Wizwand (Scepter, Mind)" }, { "Nethercrypt Bauble", "(lv-14) WEAPON_Nethercrypt Bauble (Scepter, Mind)" }, { "Aquapetal Staff", "(lv-16) WEAPON_Aquapetal Staff (Scepter, Mind)" }, { "Flamepetal Staff", "(lv-16) WEAPON_Flamepetal Staff (Scepter, Mind)" }, { "Mithril Scepter", "(lv-16) WEAPON_Mithril Scepter (Scepter, Mind)" }, { "Sapphite Scepter", "(lv-18) WEAPON_Sapphite Scepter (Scepter, Mind)" }, { "Voalstark Wand", "(lv-24) WEAPON_Voalstark Wand (Scepter, Mind)" }, { "Cryptcall Bell", "(lv-8) WEAPON_Cryptcall Bell (Magic Bell, Mind)" }, { "Iron Bell", "(lv-8) WEAPON_Iron Bell (Magic Bell, Mind)" }, { "Coldgeist Frostcaller", "(lv-16) WEAPON_Coldgeist Frostcaller (Magic Bell, Mind)" }, { "Mithril Bell", "(lv-16) WEAPON_Mithril Bell (Magic Bell, Mind)" }, { "Colossus Tone", "(lv-18) WEAPON_Colossus Tone (Magic Bell, Mind)" }, { "Sapphite Bell", "(lv-18) WEAPON_Sapphite Bell (Magic Bell, Mind)" }, { "Slimecrust Katars", "(lv-2) WEAPON_Slimecrust Katars (Katars, Dexterity)" }, { "Cryptsinge Katars", "(lv-4) WEAPON_Cryptsinge Katars (Katars, Dexterity)" }, { "Slimek Shivs", "(lv-4) WEAPON_Slimek Shivs (Katars, Dexterity)" }, { "Deathgel Shivs", "(lv-6) WEAPON_Deathgel Shivs (Katars, Dexterity)" }, { "Dense Katars", "(lv-6) WEAPON_Dense Katars (Katars, Dexterity)" }, { "Iron Katars", "(lv-8) WEAPON_Iron Katars (Katars, Dexterity)" }, { "Runic Katars", "(lv-10) WEAPON_Runic Katars (Katars, Dexterity)" }, { "Geistlord Claws", "(lv-12) WEAPON_Geistlord Claws (Katars, Dexterity)" }, { "Hellsludge Shivs", "(lv-14) WEAPON_Hellsludge Shivs (Katars, Dexterity)" }, { "Mithril Katars", "(lv-14) WEAPON_Mithril Katars (Katars, Dexterity)" }, { "Frostbite Claws", "(lv-16) WEAPON_Frostbite Claws (Katars, Dexterity)" }, { "Serrated Knuckles", "(lv-16) WEAPON_Serrated Knuckles (Katars, Dexterity)" }, { "Rummok Bladerings", "(lv-18) WEAPON_Rummok Bladerings (Katars, Dexterity)" }, { "Sapphite Katars", "(lv-18) WEAPON_Sapphite Katars (Katars, Dexterity)" }, { "Golemfist Katars", "(lv-20) WEAPON_Golemfist Katars (Katars, Dexterity)" }, { "Crypt Bow", "(lv-2) WEAPON_Crypt Bow (Bow, Dexterity)" }, { "Demicrypt Bow", "(lv-6) WEAPON_Demicrypt Bow (Bow, Dexterity)" }, { "Iron Bow", "(lv-6) WEAPON_Iron Bow (Bow, Dexterity)" }, { "Mekspike Bow", "(lv-8) WEAPON_Mekspike Bow (Bow, Dexterity)" }, { "Menace Bow", "(lv-8) WEAPON_Menace Bow (Bow, Dexterity)" }, { "Petrified Bow", "(lv-12) WEAPON_Petrified Bow (Bow, Dexterity)" }, { "Mithril Bow", "(lv-14) WEAPON_Mithril Bow (Bow, Dexterity)" }, { "Necroroyal Bow", "(lv-14) WEAPON_Necroroyal Bow (Bow, Dexterity)" }, { "Coldgeist Bow", "(lv-16) WEAPON_Coldgeist Bow (Bow, Dexterity)" }, { "Serrated Longbow", "(lv-16) WEAPON_Serrated Longbow (Bow, Dexterity)" }, { "Torrentius Longbow", "(lv-24) WEAPON_Torrentius Longbow (Bow, Dexterity)" }, { "Amberite Boomstick", "(lv-12) WEAPON_Amberite Boomstick (Shotgun, Dexterity)" }, { "Magitek Burstgun", "(lv-20) WEAPON_Magitek Burstgun (Shotgun, Dexterity)" }, { "Follycannon", "(lv-26) WEAPON_Follycannon (Shotgun, Dexterity)" }, { "Agility Ears", "(lv-1) HELM_Agility Ears" }, { "Festive Hat", "(lv-1) HELM_Festive Hat" }, { "Fishin Hat", "(lv-1) HELM_Fishin Hat" }, { "Leather Cap", "(lv-1) HELM_Leather Cap" }, { "Newfold Halo", "(lv-1) HELM_Newfold Halo" }, { "Orefinder Hat", "(lv-1) HELM_Orefinder Hat" }, { "Spooky Hat", "(lv-1) HELM_Spooky Hat" }, { "Top Hat", "(lv-1) HELM_Top Hat" }, { "Wizard Hat", "(lv-1) HELM_Wizard Hat" }, { "Acolyte Hood", "(lv-4) HELM_Acolyte Hood" }, { "Cryptsinge Halo", "(lv-4) HELM_Cryptsinge Halo" }, { "Initiate Spectacles", "(lv-4) HELM_Initiate Spectacles" }, { "Demicrypt Halo", "(lv-6) HELM_Demicrypt Halo" }, { "Dense Helm", "(lv-6) HELM_Dense Helm" }, { "Diva Crown", "(lv-6) HELM_Diva Crown" }, { "Iron Halo", "(lv-6) HELM_Iron Halo" }, { "Necromancer Hood", "(lv-8) HELM_Necromancer Hood" }, { "Geistlord Crown", "(lv-10) HELM_Geistlord Crown" }, { "Journeyman Spectacles", "(lv-10) HELM_Journeyman Spectacles" }, { "Amberite Helm", "(lv-12) HELM_Amberite Helm" }, { "Focus Circlet", "(lv-12) HELM_Focus Circlet" }, { "Magistrate Circlet", "(lv-12) HELM_Magistrate Circlet" }, { "Rage Circlet", "(lv-12) HELM_Rage Circlet" }, { "Focusi Glasses", "(lv-14) HELM_Focusi Glasses" }, { "Nethercrypt Halo", "(lv-14) HELM_Nethercrypt Halo" }, { "Carbuncle Hat", "(lv-16) HELM_Carbuncle Hat" }, { "Geistlord Eye", "(lv-16) HELM_Geistlord Eye" }, { "Glyphgrift Halo", "(lv-16) HELM_Glyphgrift Halo" }, { "Jestercast Memory", "(lv-16) HELM_Jestercast Memory" }, { "Knightguard Halo", "(lv-16) HELM_Knightguard Halo" }, { "Mithril Halo", "(lv-16) HELM_Mithril Halo" }, { "Sapphite Mindhat", "(lv-18) HELM_Sapphite Mindhat" }, { "Dire Helm", "(lv-22) HELM_Dire Helm" }, { "Druidic Halo", "(lv-22) HELM_Druidic Halo" }, { "Guardel Helm", "(lv-22) HELM_Guardel Helm" }, { "Leathen Cap", "(lv-22) HELM_Leathen Cap" }, { "Boarus Helm", "(lv-24) HELM_Boarus Helm" }, { "Deathknight Helm", "(lv-24) HELM_Deathknight Helm" }, { "Emerock Halo", "(lv-24) HELM_Emerock Halo" }, { "Wizlad Hood", "(lv-24) HELM_Wizlad Hood" }, { "Boarus Torment", "(lv-26) HELM_Boarus Torment" }, { "Initiate Cloak", "(lv-2) CAPE_Initiate Cloak" }, { "Slimewoven Cloak", "(lv-4) CAPE_Slimewoven Cloak" }, { "Nokket Cloak", "(lv-6) CAPE_Nokket Cloak" }, { "Rugged Cloak", "(lv-6) CAPE_Rugged Cloak" }, { "Regazuul Cape", "(lv-10) CAPE_Regazuul Cape" }, { "Flux Cloak", "(lv-12) CAPE_Flux Cloak" }, { "Cozy Cloak", "(lv-14) CAPE_Cozy Cloak" }, { "Nethercrypt Cloak", "(lv-14) CAPE_Nethercrypt Cloak" }, { "Cobblerage Cloak", "(lv-16) CAPE_Cobblerage Cloak" }, { "Deathward Cape", "(lv-16) CAPE_Deathward Cape" }, { "Forlorn Cloak", "(lv-16) CAPE_Forlorn Cloak" }, { "Meshlink Cape", "(lv-16) CAPE_Meshlink Cape" }, { "Sagecaller Cape", "(lv-16) CAPE_Sagecaller Cape" }, { "Roudon Cape", "(lv-18) CAPE_Roudon Cape" }, { "Blueversa Cape", "(lv-20) CAPE_Blueversa Cape" }, { "Greenversa Cape", "(lv-20) CAPE_Greenversa Cape" }, { "Nulversa Cape", "(lv-20) CAPE_Nulversa Cape" }, { "Redversa Cape", "(lv-20) CAPE_Redversa Cape" }, { "Windgolem Cloak", "(lv-22) CAPE_Windgolem Cloak" }, { "Mekwar Drape", "(lv-24) CAPE_Mekwar Drape" }, { "Aero Top", "(lv-1) CHESTPIECE_Aero Top" }, { "Bunhost Garb", "(lv-1) CHESTPIECE_Bunhost Garb" }, { "Festive Coat", "(lv-1) CHESTPIECE_Festive Coat" }, { "Fisher Overalls", "(lv-1) CHESTPIECE_Fisher Overalls" }, { "Leather Top", "(lv-1) CHESTPIECE_Leather Top" }, { "Necro Marrow", "(lv-1) CHESTPIECE_Necro Marrow" }, { "Noble Shirt", "(lv-1) CHESTPIECE_Noble Shirt" }, { "Nutso Top", "(lv-1) CHESTPIECE_Nutso Top" }, { "Orefinder Vest", "(lv-1) CHESTPIECE_Orefinder Vest" }, { "Ritualist Garb", "(lv-1) CHESTPIECE_Ritualist Garb" }, { "Sagecloth Top", "(lv-1) CHESTPIECE_Sagecloth Top" }, { "Silken Top", "(lv-1) CHESTPIECE_Silken Top" }, { "Spooky Garment", "(lv-1) CHESTPIECE_Spooky Garment" }, { "Vampiric Coat", "(lv-1) CHESTPIECE_Vampiric Coat" }, { "Ghostly Tabard", "(lv-2) CHESTPIECE_Ghostly Tabard" }, { "Poacher Cloth", "(lv-2) CHESTPIECE_Poacher Cloth" }, { "Ragged Shirt", "(lv-2) CHESTPIECE_Ragged Shirt" }, { "Slimecrust Chest", "(lv-2) CHESTPIECE_Slimecrust Chest" }, { "Worn Robe", "(lv-2) CHESTPIECE_Worn Robe" }, { "Cryptsinge Chest", "(lv-4) CHESTPIECE_Cryptsinge Chest" }, { "Journeyman Vest", "(lv-4) CHESTPIECE_Journeyman Vest" }, { "Slimek Chest", "(lv-4) CHESTPIECE_Slimek Chest" }, { "Dense Chestpiece", "(lv-6) CHESTPIECE_Dense Chestpiece" }, { "Trodd Tunic", "(lv-6) CHESTPIECE_Trodd Tunic" }, { "Iron Chestpiece", "(lv-7) CHESTPIECE_Iron Chestpiece" }, { "Tattered Battlerobe", "(lv-8) CHESTPIECE_Tattered Battlerobe" }, { "Apprentice Robe", "(lv-10) CHESTPIECE_Apprentice Robe" }, { "Duelist Garb", "(lv-10) CHESTPIECE_Duelist Garb" }, { "Skywrill Tabard", "(lv-10) CHESTPIECE_Skywrill Tabard" }, { "Sleeper's Robe", "(lv-10) CHESTPIECE_Sleeper's Robe" }, { "Warrior Chest", "(lv-10) CHESTPIECE_Warrior Chest" }, { "Amberite Breastplate", "(lv-12) CHESTPIECE_Amberite Breastplate" }, { "Golem Chestpiece", "(lv-12) CHESTPIECE_Golem Chestpiece" }, { "Lord Breastplate", "(lv-12) CHESTPIECE_Lord Breastplate" }, { "Nethercrypt Tabard", "(lv-12) CHESTPIECE_Nethercrypt Tabard" }, { "Reapsow Garb", "(lv-12) CHESTPIECE_Reapsow Garb" }, { "Witchlock Robe", "(lv-12) CHESTPIECE_Witchlock Robe" }, { "Chainmail Guard", "(lv-14) CHESTPIECE_Chainmail Guard" }, { "Ornamented Battlerobe", "(lv-14) CHESTPIECE_Ornamented Battlerobe" }, { "Carbuncle Robe", "(lv-16) CHESTPIECE_Carbuncle Robe" }, { "Chainscale Chest", "(lv-16) CHESTPIECE_Chainscale Chest" }, { "Gemveil Raiment", "(lv-16) CHESTPIECE_Gemveil Raiment" }, { "King Breastplate", "(lv-16) CHESTPIECE_King Breastplate" }, { "Mercenary Vestment", "(lv-16) CHESTPIECE_Mercenary Vestment" }, { "Mithril Chestpiece", "(lv-16) CHESTPIECE_Mithril Chestpiece" }, { "Reaper Gi", "(lv-16) CHESTPIECE_Reaper Gi" }, { "Witchwizard Robe", "(lv-16) CHESTPIECE_Witchwizard Robe" }, { "Berserker Chestpiece", "(lv-18) CHESTPIECE_Berserker Chestpiece" }, { "Fuguefall Duster", "(lv-18) CHESTPIECE_Fuguefall Duster" }, { "Magilord Overalls", "(lv-18) CHESTPIECE_Magilord Overalls" }, { "Monolith Chestpiece", "(lv-18) CHESTPIECE_Monolith Chestpiece" }, { "Sapphite Guard", "(lv-18) CHESTPIECE_Sapphite Guard" }, { "Druidic Robe", "(lv-20) CHESTPIECE_Druidic Robe" }, { "Emerock Chestpiece", "(lv-20) CHESTPIECE_Emerock Chestpiece" }, { "Fortified Vestment", "(lv-20) CHESTPIECE_Fortified Vestment" }, { "Roudon Chestpiece", "(lv-20) CHESTPIECE_Roudon Chestpiece" }, { "Earthbind Tabard", "(lv-22) CHESTPIECE_Earthbind Tabard" }, { "Gemveil Breastplate", "(lv-22) CHESTPIECE_Gemveil Breastplate" }, { "Roudon Robe", "(lv-22) CHESTPIECE_Roudon Robe" }, { "Ruggrok Vest", "(lv-22) CHESTPIECE_Ruggrok Vest" }, { "Executioner Vestment", "(lv-24) CHESTPIECE_Executioner Vestment" }, { "Fender Garb", "(lv-24) CHESTPIECE_Fender Garb" }, { "Wizlad Robe", "(lv-24) CHESTPIECE_Wizlad Robe" }, { "Aero Pants", "(lv-1) LEGGINGS_Aero Pants" }, { "Bunhost Leggings", "(lv-1) LEGGINGS_Bunhost Leggings" }, { "Festive Trousers", "(lv-1) LEGGINGS_Festive Trousers" }, { "Leather Britches", "(lv-1) LEGGINGS_Leather Britches" }, { "Necro Caustics", "(lv-1) LEGGINGS_Necro Caustics" }, { "Noble Pants", "(lv-1) LEGGINGS_Noble Pants" }, { "Nutso Pants", "(lv-1) LEGGINGS_Nutso Pants" }, { "Orefinder Trousers", "(lv-1) LEGGINGS_Orefinder Trousers" }, { "Ritualist Straps", "(lv-1) LEGGINGS_Ritualist Straps" }, { "Sagecloth Shorts", "(lv-1) LEGGINGS_Sagecloth Shorts" }, { "Silken Loincloth", "(lv-1) LEGGINGS_Silken Loincloth" }, { "Vampiric Leggings", "(lv-1) LEGGINGS_Vampiric Leggings" }, { "Ghostly Legwraps", "(lv-2) LEGGINGS_Ghostly Legwraps" }, { "Journeyman Shorts", "(lv-2) LEGGINGS_Journeyman Shorts" }, { "Slimecrust Leggings", "(lv-2) LEGGINGS_Slimecrust Leggings" }, { "Journeyman Leggings", "(lv-4) LEGGINGS_Journeyman Leggings" }, { "Slimek Leggings", "(lv-4) LEGGINGS_Slimek Leggings" }, { "Dense Leggings", "(lv-6) LEGGINGS_Dense Leggings" }, { "Sash Leggings", "(lv-8) LEGGINGS_Sash Leggings" }, { "Warrior Leggings", "(lv-10) LEGGINGS_Warrior Leggings" }, { "Amberite Leggings", "(lv-12) LEGGINGS_Amberite Leggings" }, { "Chainmail Leggings", "(lv-12) LEGGINGS_Chainmail Leggings" }, { "Darkcloth Pants", "(lv-12) LEGGINGS_Darkcloth Pants" }, { "Lord Greaves", "(lv-12) LEGGINGS_Lord Greaves" }, { "Reapsow Pants", "(lv-12) LEGGINGS_Reapsow Pants" }, { "Witchlock Loincloth", "(lv-12) LEGGINGS_Witchlock Loincloth" }, { "King Greaves", "(lv-16) LEGGINGS_King Greaves" }, { "Mercenary Leggings", "(lv-16) LEGGINGS_Mercenary Leggings" }, { "Reaper Leggings", "(lv-16) LEGGINGS_Reaper Leggings" }, { "Stridebond Pants", "(lv-16) LEGGINGS_Stridebond Pants" }, { "Witchwizard Garterbelt", "(lv-16) LEGGINGS_Witchwizard Garterbelt" }, { "Berserker Leggings", "(lv-18) LEGGINGS_Berserker Leggings" }, { "Fuguefall Pants", "(lv-18) LEGGINGS_Fuguefall Pants" }, { "Magilord Boots", "(lv-18) LEGGINGS_Magilord Boots" }, { "Sapphite Leggings", "(lv-18) LEGGINGS_Sapphite Leggings" }, { "Jadewail Trousers", "(lv-20) LEGGINGS_Jadewail Trousers" }, { "Temrak Britches", "(lv-20) LEGGINGS_Temrak Britches" }, { "Eschek Greaves", "(lv-22) LEGGINGS_Eschek Greaves" }, { "Gemveil Leggings", "(lv-22) LEGGINGS_Gemveil Leggings" }, { "Executioner Leggings", "(lv-24) LEGGINGS_Executioner Leggings" }, { "Fender Leggings", "(lv-24) LEGGINGS_Fender Leggings" }, { "Wooden Shield", "(lv-1) SHIELD_Wooden Shield" }, { "Crypt Buckler", "(lv-4) SHIELD_Crypt Buckler" }, { "Slimek Shield", "(lv-4) SHIELD_Slimek Shield" }, { "Demicrypt Buckler", "(lv-6) SHIELD_Demicrypt Buckler" }, { "Dense Shield", "(lv-6) SHIELD_Dense Shield" }, { "Iron Shield", "(lv-6) SHIELD_Iron Shield" }, { "Iris Shield", "(lv-8) SHIELD_Iris Shield" }, { "Omen Shield", "(lv-8) SHIELD_Omen Shield" }, { "Amberite Shield", "(lv-12) SHIELD_Amberite Shield" }, { "Slabton Shield", "(lv-12) SHIELD_Slabton Shield" }, { "Mithril Shield", "(lv-14) SHIELD_Mithril Shield" }, { "Nethercrypt Shield", "(lv-14) SHIELD_Nethercrypt Shield" }, { "Rustweary Shield", "(lv-16) SHIELD_Rustweary Shield" }, { "Rustwise Shield", "(lv-16) SHIELD_Rustwise Shield" }, { "Sapphite Shield", "(lv-18) SHIELD_Sapphite Shield" }, { "Rigor Buckler", "(lv-20) SHIELD_Rigor Buckler" }, { "Daemon Shield", "(lv-22) SHIELD_Daemon Shield" }, { "Irisun Shield", "(lv-22) SHIELD_Irisun Shield" }, { "Old Ring", "(lv-1) RING_Old Ring" }, { "Ring Of Ambition", "(lv-1) RING_Ring Of Ambition" }, { "Nograd's Amulet", "(lv-2) RING_Nograd's Amulet" }, { "The One Ring", "(lv-2) RING_The One Ring" }, { "Ambersquire Ring", "(lv-6) RING_Ambersquire Ring" }, { "Emeraldfocus Ring", "(lv-6) RING_Emeraldfocus Ring" }, { "Sapphireweave Ring", "(lv-6) RING_Sapphireweave Ring" }, { "Edon's Pendant", "(lv-8) RING_Edon's Pendant" }, { "Geistlord Ring", "(lv-12) RING_Geistlord Ring" }, { "Students Ring", "(lv-12) RING_Students Ring" }, { "Pearlpond Ring", "(lv-14) RING_Pearlpond Ring" }, { "Slitherwraith Ring", "(lv-14) RING_Slitherwraith Ring" }, { "Geistlord Band", "(lv-16) RING_Geistlord Band" }, { "Jadetrout Ring", "(lv-16) RING_Jadetrout Ring" }, { "Orbos Ring", "(lv-16) RING_Orbos Ring" }, { "Valor Ring", "(lv-16) RING_Valor Ring" }, { "Earthwoken Ring", "(lv-18) RING_Earthwoken Ring" }, { "Noji Talisman", "(lv-20) RING_Noji Talisman" }, { "Valdur Effigy", "(lv-24) RING_Valdur Effigy" }, { "Glyphik Booklet", "(lv-26) RING_Glyphik Booklet" }, { "Tessellated Drive", "(lv-26) RING_Tessellated Drive" }, { "Aqua Muchroom Cap", "TRADEITEM_Aqua Muchroom Cap" }, { "Barknaught Face", "TRADEITEM_Barknaught Face" }, { "Blightwood Log", "TRADEITEM_Blightwood Log" }, { "Blightwood Stick", "TRADEITEM_Blightwood Stick" }, { "Blue Minchroom Cap", "TRADEITEM_Blue Minchroom Cap" }, { "Boomboar Gear", "TRADEITEM_Boomboar Gear" }, { "Boomboar Head", "TRADEITEM_Boomboar Head" }, { "Boomboar Pouch", "TRADEITEM_Boomboar Pouch" }, { "Burnrose", "TRADEITEM_Burnrose" }, { "Carbuncle Foot", "TRADEITEM_Carbuncle Foot" }, { "Cursed Note", "TRADEITEM_Cursed Note" }, { "Deadwood Log", "TRADEITEM_Deadwood Log" }, { "Deathgel Core", "TRADEITEM_Deathgel Core" }, { "Deathknight Gauntlet", "TRADEITEM_Deathknight Gauntlet" }, { "Demigolem Core", "TRADEITEM_Demigolem Core" }, { "Demigolem Gem", "TRADEITEM_Demigolem Gem" }, { "Diva Necklace", "TRADEITEM_Diva Necklace" }, { "Firebreath Gland", "TRADEITEM_Firebreath Gland" }, { "Fluxfern", "TRADEITEM_Fluxfern" }, { "Gale Muchroom Cap", "TRADEITEM_Gale Muchroom Cap" }, { "Geist Collar", "TRADEITEM_Geist Collar" }, { "Ghostdust", "TRADEITEM_Ghostdust" }, { "Golem Core", "TRADEITEM_Golem Core" }, { "Golem Gem", "TRADEITEM_Golem Gem" }, { "Green Lipstick", "TRADEITEM_Green Lipstick" }, { "Hellsludge Core", "TRADEITEM_Hellsludge Core" }, { "Maw Eye", "TRADEITEM_Maw Eye" }, { "Mekboar Head", "TRADEITEM_Mekboar Head" }, { "Mekboar Spear", "TRADEITEM_Mekboar Spear" }, { "Mekboar Nail", "TRADEITEM_Mekboar Nail" }, { "Mekboar Nosering", "TRADEITEM_Mekboar Nosering" }, { "Mekboar Spine", "TRADEITEM_Mekboar Spine" }, { "Monolith Core", "TRADEITEM_Monolith Core" }, { "Monolith Gem", "TRADEITEM_Monolith Gem" }, { "Mouth Bittertooth", "TRADEITEM_Mouth Bittertooth" }, { "Mouth Eye", "TRADEITEM_Mouth Eye" }, { "Rageboar Head", "TRADEITEM_Rageboar Head" }, { "Rageboar Spear", "TRADEITEM_Rageboar Spear" }, { "Red Minchroom Cap", "TRADEITEM_Red Minchroom Cap" }, { "Rock", "TRADEITEM_Rock" }, { "Slime Core", "TRADEITEM_Slime Core" }, { "Slime Diva Ears", "TRADEITEM_Slime Diva Ears" }, { "Slime Ears", "TRADEITEM_Slime Ears" }, { "Slimek Core", "TRADEITEM_Slimek Core" }, { "Slimek Ears", "TRADEITEM_Slimek Ears" }, { "Slimek Eye", "TRADEITEM_Slimek Eye" }, { "Vinethorn", "TRADEITEM_Vinethorn" }, { "Vout Antennae", "TRADEITEM_Vout Antennae" }, { "Vout Wing", "TRADEITEM_Vout Wing" }, { "Warboar Axe", "TRADEITEM_Warboar Axe" }, { "Warboar Head", "TRADEITEM_Warboar Head" }, { "Wizboar Head", "TRADEITEM_Wizboar Head" }, { "Wizboar Scepter", "TRADEITEM_Wizboar Scepter" }, { "Geistlord Nails", "TRADEITEM_Geistlord Nails" }, { "Amberite Ingot", "TRADEITEM_Amberite Ingot" }, { "Amberite Ore", "TRADEITEM_Amberite Ore" }, { "Dense Ingot", "TRADEITEM_Dense Ingot" }, { "Dense Ore", "TRADEITEM_Dense Ore" }, { "Copper Cluster", "TRADEITEM_Copper Cluster" }, { "Iron Cluster", "TRADEITEM_Iron Cluster" }, { "Mithril Cluster", "TRADEITEM_Mithril Cluster" }, { "Sapphite Ingot", "TRADEITEM_Sapphite Ingot" }, { "Sapphite Ore", "TRADEITEM_Sapphite Ore" }, { "Coal", "TRADEITEM_Coal" }, { "Big Wan", "TRADEITEM_Big Wan" }, { "Bittering Katfish", "TRADEITEM_Bittering Katfish" }, { "Bonefish", "TRADEITEM_Bonefish" }, { "Smiling Wrellfish", "TRADEITEM_Smiling Wrellfish" }, { "Squangfish", "TRADEITEM_Squangfish" }, { "Sugeel", "TRADEITEM_Sugeel" }, { "Sugshrimp", "TRADEITEM_Sugshrimp" }, { "Windtail Fish", "TRADEITEM_Windtail Fish" }, { "Old Boot", "TRADEITEM_Old Boot" }, { "Bronze Arrows", "TRADEITEM_Bronze Arrows" }, { "Agility Stone", "TRADEITEM_Agility Stone" }, { "Angela's Tear", "TRADEITEM_Angela's Tear" }, { "Epic Carrot", "TRADEITEM_Epic Carrot" }, { "Experience Bond", "TRADEITEM_Experience Bond" }, { "Flux Stone", "TRADEITEM_Flux Stone" }, { "Illusion Stone", "TRADEITEM_Illusion Stone" }, { "Might Stone", "TRADEITEM_Might Stone" }, { "Starlight Gem", "TRADEITEM_Starlight Gem" } }; public static AtlyssArchipelagoPlugin Instance { get; private set; } public static ManualLogSource StaticLogger { get; private set; } private string GetLocationName(long locationId) { if (LocationIdToName.TryGetValue(locationId, out var value)) { return value; } return $"Location {locationId}"; } private void Awake() { //IL_00fd: Unknown result type (might be due to invalid IL or missing references) //IL_0107: Expected O, but got Unknown //IL_010c: Unknown result type (might be due to invalid IL or missing references) //IL_0116: Expected O, but got Unknown Instance = this; StaticLogger = ((BaseUnityPlugin)this).Logger; cfgServer = ((BaseUnityPlugin)this).Config.Bind<string>("Connection", "Server", "localhost", "Archipelago host. You can also put host:port here."); cfgSlot = ((BaseUnityPlugin)this).Config.Bind<string>("Connection", "Slot", "Player", "Your Archipelago slot name."); cfgPassword = ((BaseUnityPlugin)this).Config.Bind<string>("Connection", "Password", "", "Room password (optional)."); cfgAutoConnect = ((BaseUnityPlugin)this).Config.Bind<bool>("Connection", "AutoConnect", false, "Auto-connect on game start."); cfgDeathlink = ((BaseUnityPlugin)this).Config.Bind<bool>("Connection", "DeathLink", false, "If DeathLink should be enabled (can be changed ingame)."); ((BaseUnityPlugin)this).Logger.LogInfo((object)"=== [AtlyssAP] Plugin loaded! Version 1.3.1 ==="); ((BaseUnityPlugin)this).Logger.LogInfo((object)"[AtlyssAP] ALL QUESTS + Commands + Item In Spike Storage + 419 ITEMS (304 Equipment) + 50 Shop Locations!"); ((BaseUnityPlugin)this).Logger.LogInfo((object)"[AtlyssAP] Press F5 to connect to Archipelago"); _harmony = new Harmony("com.azrael.atlyss.ap.harmony"); scriptHolder = new GameObject("Archipelago Script Holder"); Object.DontDestroyOnLoad((Object)(object)scriptHolder); portalLocker = scriptHolder.AddComponent<PortalUnlocks>(); _shopSanity = new ArchipelagoShopSanity(this, ((BaseUnityPlugin)this).Logger); try { _harmony.PatchAll(); ((BaseUnityPlugin)this).Logger.LogInfo((object)"[AtlyssAP] Harmony patches applied successfully"); } catch (Exception ex) { ((BaseUnityPlugin)this).Logger.LogError((object)("[AtlyssAP] Failed to apply Harmony patches: " + ex.Message)); } } private void Start() { if (cfgAutoConnect.Value) { ((BaseUnityPlugin)this).Logger.LogInfo((object)"[AtlyssAP] Auto-connecting..."); TryConnect(); } } private void OnDestroy() { Disconnect(); } private void Update() { if (Input.GetKeyDown((KeyCode)286)) { TryConnect(); } if (!connected) { return; } (string, string) result; while (_receivedItemQueue.TryDequeue(out result)) { try { SendAPChatMessage("Received <color=yellow>" + result.Item1 + "</color> from <color=#00FFFF>" + result.Item2 + "</color>!"); HandleReceivedItem(result.Item1); } catch (Exception ex) { ((BaseUnityPlugin)this).Logger.LogError((object)("[AtlyssAP] Error processing item " + result.Item1 + ": " + ex.Message)); } } PollForLevelChanges(); PollForQuestCompletions(); PollForSkillLevelChanges(); } private void PollForLevelChanges() { try { Player mainPlayer = Player._mainPlayer; if ((Object)(object)mainPlayer == (Object)null) { return; } PlayerStats component = ((Component)mainPlayer).GetComponent<PlayerStats>(); if ((Object)(object)component == (Object)null) { return; } int network_currentLevel = component.Network_currentLevel; if (network_currentLevel == _lastLevel) { return; } ((BaseUnityPlugin)this).Logger.LogInfo((object)$"[AtlyssAP] Level changed: {_lastLevel} -> {network_currentLevel}"); if (network_currentLevel >= 2 && network_currentLevel <= 32 && network_currentLevel % 2 == 0) { long num = 591010L + (long)((network_currentLevel - 2) / 2); if (!_reportedChecks.Contains(num)) { SendCheckById(num); SendAPChatMessage($"Found <color=yellow>Reach Level {network_currentLevel}</color>! " + "Sent item to another player!"); ((BaseUnityPlugin)this).Logger.LogInfo((object)$"[AtlyssAP] Reached Level {network_currentLevel} milestone!"); } } _lastLevel = network_currentLevel; } catch (Exception ex) { ((BaseUnityPlugin)this).Logger.LogError((object)("[AtlyssAP] Error polling level: " + ex.Message)); } } private void PollForSkillLevelChanges() { //IL_0040: Unknown result type (might be due to invalid IL or missing references) //IL_0045: Unknown result type (might be due to invalid IL or missing references) //IL_00d1: Unknown result type (might be due to invalid IL or missing references) //IL_0194: Unknown result type (might be due to invalid IL or missing references) try { Player mainPlayer = Player._mainPlayer; if ((Object)(object)mainPlayer == (Object)null) { return; } PlayerStats pStats = mainPlayer._pStats; if ((Object)(object)pStats == (Object)null) { return; } for (int i = 0; i < pStats._syncProfessions.Count; i++) { ProfessionStruct val = pStats._syncProfessions[i]; ScriptableProfession val2 = null; if ((Object)(object)GameManager._current != (Object)null && (Object)(object)GameManager._current._statLogics != (Object)null && i < GameManager._current._statLogics._scriptableProfessions.Length) { val2 = GameManager._current._statLogics._scriptableProfessions[i]; } if ((Object)(object)val2 == (Object)null) { continue; } if (val2._professionName == "Fishing") { int professionLvl = val._professionLvl; if (professionLvl > _previousFishingLevel) { for (int j = _previousFishingLevel + 1; j <= professionLvl; j++) { if (FishingLevelLocations.TryGetValue(j, out var value)) { SendCheckById(value); SendAPChatMessage($"Found <color=yellow>Fishing Level {j}</color>! " + "Sent item to another player!"); ((BaseUnityPlugin)this).Logger.LogInfo((object)$"[AtlyssAP] Fishing level {j} reached!"); } } _previousFishingLevel = professionLvl; } } if (!(val2._professionName == "Mining")) { continue; } int professionLvl2 = val._professionLvl; if (professionLvl2 <= _previousMiningLevel) { continue; } for (int k = _previousMiningLevel + 1; k <= professionLvl2; k++) { if (MiningLevelLocations.TryGetValue(k, out var value2)) { SendCheckById(value2); SendAPChatMessage($"Found <color=yellow>Mining Level {k}</color>! " + "Sent item to another player!"); ((BaseUnityPlugin)this).Logger.LogInfo((object)$"[AtlyssAP] Mining level {k} reached!"); } } _previousMiningLevel = professionLvl2; } } catch (Exception ex) { ((BaseUnityPlugin)this).Logger.LogError((object)("[AtlyssAP] Error checking skill levels: " + ex.Message)); } } private void PollForQuestCompletions() { try { Player mainPlayer = Player._mainPlayer; if ((Object)(object)mainPlayer == (Object)null) { return; } PlayerQuesting component = ((Component)mainPlayer).GetComponent<PlayerQuesting>(); if ((Object)(object)component == (Object)null || component._finishedQuests == null) { return; } if (!_questDebugLogged && component._finishedQuests.Count > 0) { ((BaseUnityPlugin)this).Logger.LogInfo((object)$"[AtlyssAP] DEBUG: Found {component._finishedQuests.Count} completed quests"); foreach (string key2 in component._finishedQuests.Keys) { ((BaseUnityPlugin)this).Logger.LogInfo((object)("[AtlyssAP] DEBUG: Completed quest: '" + key2 + "'")); } _questDebugLogged = true; } foreach (KeyValuePair<string, long> item in AllQuestToLocation) { string key = item.Key; long value = item.Value; if (component._finishedQuests.ContainsKey(key) && !_completedQuests.Contains(key)) { SendCheckById(value); _completedQuests.Add(key); SendAPChatMessage("Found <color=yellow>" + key + "</color>! Sent item to another player!"); ((BaseUnityPlugin)this).Logger.LogInfo((object)("[AtlyssAP] Quest completed: " + key)); if (key == "Gatling Galius") { SendAPChatMessage("<color=gold>VICTORY!</color> <color=yellow>You completed your goal!</color>"); ((BaseUnityPlugin)this).Logger.LogInfo((object)"[AtlyssAP] VICTORY! Defeated final boss Galius!"); } } } } catch (Exception ex) { ((BaseUnityPlugin)this).Logger.LogError((object)("[AtlyssAP] Error polling quests: " + ex.Message)); } } private bool IsNewSession(string sessionId) { try { string path = Path.Combine(Application.persistentDataPath, "ap_session.json"); if (!File.Exists(path)) { return true; } string text = File.ReadAllText(path); return text != sessionId; } catch { return true; } } private void SaveSessionId(string sessionId) { try { string path = Path.Combine(Application.persistentDataPath, "ap_session.json"); File.WriteAllText(path, sessionId); ((BaseUnityPlugin)this).Logger.LogInfo((object)("Saved session ID: " + sessionId)); } catch (Exception ex) { ((BaseUnityPlugin)this).Logger.LogError((object)("Failed to save session ID: " + ex.Message)); } } private void TryConnect() { //IL_069c: Unknown result type (might be due to invalid IL or missing references) //IL_06a6: Expected O, but got Unknown //IL_06b9: Unknown result type (might be due to invalid IL or missing references) //IL_06c3: Expected O, but got Unknown //IL_06d1: Unknown result type (might be due to invalid IL or missing references) //IL_06db: Expected O, but got Unknown //IL_06ee: Unknown result type (might be due to invalid IL or missing references) //IL_06f8: Expected O, but got Unknown //IL_0648: Unknown result type (might be due to invalid IL or missing references) //IL_0652: Expected O, but got Unknown //IL_05df: Unknown result type (might be due to invalid IL or missing references) //IL_05e6: Expected O, but got Unknown if (connected) { ((BaseUnityPlugin)this).Logger.LogWarning((object)"[AtlyssAP] Already connected."); return; } if (connecting) { ((BaseUnityPlugin)this).Logger.LogWarning((object)"[AtlyssAP] Connection in progress..."); return; } connecting = true; try { if ((Object)(object)apServer == (Object)nu
Newtonsoft.Json.dll
Decompiled a week ago
The result has been truncated due to the large size, download it to view full contents!
#define DEBUG using System; using System.Collections; using System.Collections.Concurrent; using System.Collections.Generic; using System.Collections.ObjectModel; using System.Collections.Specialized; using System.ComponentModel; using System.Data; using System.Data.SqlTypes; using System.Diagnostics; using System.Diagnostics.CodeAnalysis; using System.Dynamic; using System.Globalization; using System.IO; using System.Linq; using System.Linq.Expressions; using System.Numerics; using System.Reflection; using System.Reflection.Emit; using System.Resources; using System.Runtime.CompilerServices; using System.Runtime.InteropServices; using System.Runtime.Serialization; using System.Runtime.Serialization.Formatters; using System.Runtime.Versioning; using System.Security; using System.Security.Permissions; using System.Text; using System.Text.RegularExpressions; using System.Threading; using System.Threading.Tasks; using System.Xml; using System.Xml.Linq; using Microsoft.CodeAnalysis; using Newtonsoft.Json.Bson; using Newtonsoft.Json.Converters; using Newtonsoft.Json.Linq; using Newtonsoft.Json.Linq.JsonPath; using Newtonsoft.Json.Schema; using Newtonsoft.Json.Serialization; using Newtonsoft.Json.Utilities; [assembly: CompilationRelaxations(8)] [assembly: RuntimeCompatibility(WrapNonExceptionThrows = true)] [assembly: Debuggable(DebuggableAttribute.DebuggingModes.Default | DebuggableAttribute.DebuggingModes.DisableOptimizations | DebuggableAttribute.DebuggingModes.IgnoreSymbolStoreSequencePoints | DebuggableAttribute.DebuggingModes.EnableEditAndContinue)] [assembly: AllowPartiallyTrustedCallers] [assembly: InternalsVisibleTo("Newtonsoft.Json.Schema")] [assembly: InternalsVisibleTo("Newtonsoft.Json.Tests")] [assembly: InternalsVisibleTo("Newtonsoft.Json.Dynamic, PublicKey=0024000004800000940000000602000000240000525341310004000001000100cbd8d53b9d7de30f1f1278f636ec462cf9c254991291e66ebb157a885638a517887633b898ccbcf0d5c5ff7be85a6abe9e765d0ac7cd33c68dac67e7e64530e8222101109f154ab14a941c490ac155cd1d4fcba0fabb49016b4ef28593b015cab5937da31172f03f67d09edda404b88a60023f062ae71d0b2e4438b74cc11dc9")] [assembly: AssemblyTrademark("")] [assembly: ComVisible(false)] [assembly: Guid("9ca358aa-317b-4925-8ada-4a29e943a363")] [assembly: CLSCompliant(true)] [assembly: TargetFramework(".NETFramework,Version=v4.5", FrameworkDisplayName = ".NET Framework 4.5")] [assembly: AssemblyCompany("Newtonsoft")] [assembly: AssemblyConfiguration("Debug")] [assembly: AssemblyCopyright("Copyright © James Newton-King 2008")] [assembly: AssemblyDescription("Json.NET is a popular high-performance JSON framework for .NET")] [assembly: AssemblyFileVersion("11.0.1")] [assembly: AssemblyInformationalVersion("11.0.1-beta2+0eb477a285cdf06aa7bf5e103583768eba37fed6")] [assembly: AssemblyProduct("Json.NET")] [assembly: AssemblyTitle("Json.NET")] [assembly: AssemblyMetadata("RepositoryUrl", "https://github.com/ArchipelagoMW/Archipelago.MultiClient.Net.git")] [assembly: NeutralResourcesLanguage("en-US")] [assembly: AssemblyVersion("11.0.0.0")] namespace Microsoft.CodeAnalysis { [CompilerGenerated] [Microsoft.CodeAnalysis.Embedded] internal sealed class EmbeddedAttribute : Attribute { } } namespace System.Runtime.CompilerServices { [CompilerGenerated] [Microsoft.CodeAnalysis.Embedded] internal sealed class IsReadOnlyAttribute : Attribute { } [CompilerGenerated] [Microsoft.CodeAnalysis.Embedded] [AttributeUsage(AttributeTargets.Class | AttributeTargets.Property | AttributeTargets.Field | AttributeTargets.Event | AttributeTargets.Parameter | AttributeTargets.ReturnValue | AttributeTargets.GenericParameter, AllowMultiple = false, Inherited = false)] internal sealed class NullableAttribute : Attribute { public readonly byte[] NullableFlags; public NullableAttribute(byte P_0) { NullableFlags = new byte[1] { P_0 }; } public NullableAttribute(byte[] P_0) { NullableFlags = P_0; } } [CompilerGenerated] [Microsoft.CodeAnalysis.Embedded] [AttributeUsage(AttributeTargets.Class | AttributeTargets.Struct | AttributeTargets.Method | AttributeTargets.Interface | AttributeTargets.Delegate, AllowMultiple = false, Inherited = false)] internal sealed class NullableContextAttribute : Attribute { public readonly byte Flag; public NullableContextAttribute(byte P_0) { Flag = P_0; } } } namespace System.Diagnostics.CodeAnalysis { [AttributeUsage(AttributeTargets.Method | AttributeTargets.Property | AttributeTargets.Field | AttributeTargets.Parameter | AttributeTargets.ReturnValue, AllowMultiple = true)] internal sealed class NotNullAttribute : Attribute { } [AttributeUsage(AttributeTargets.Parameter, AllowMultiple = false)] internal sealed class NotNullWhenAttribute : Attribute { public bool ReturnValue { get; } public NotNullWhenAttribute(bool returnValue) { ReturnValue = returnValue; } } [AttributeUsage(AttributeTargets.Property | AttributeTargets.Field | AttributeTargets.Parameter | AttributeTargets.ReturnValue, Inherited = false)] internal sealed class MaybeNullAttribute : Attribute { } [AttributeUsage(AttributeTargets.Property | AttributeTargets.Field | AttributeTargets.Parameter, Inherited = false)] internal sealed class AllowNullAttribute : Attribute { } [AttributeUsage(AttributeTargets.Parameter, Inherited = false)] internal class DoesNotReturnIfAttribute : Attribute { public bool ParameterValue { get; } public DoesNotReturnIfAttribute(bool parameterValue) { ParameterValue = parameterValue; } } } namespace Newtonsoft.Json { public enum ConstructorHandling { Default, AllowNonPublicDefaultConstructor } public enum DateFormatHandling { IsoDateFormat, MicrosoftDateFormat } public enum DateParseHandling { None, DateTime, DateTimeOffset } public enum DateTimeZoneHandling { Local, Utc, Unspecified, RoundtripKind } public class DefaultJsonNameTable : JsonNameTable { private class Entry { internal readonly string Value; internal readonly int HashCode; internal Entry Next; internal Entry(string value, int hashCode, Entry next) { Value = value; HashCode = hashCode; Next = next; } } private static readonly int HashCodeRandomizer; private int _count; private Entry[] _entries; private int _mask = 31; static DefaultJsonNameTable() { HashCodeRandomizer = Environment.TickCount; } public DefaultJsonNameTable() { _entries = new Entry[_mask + 1]; } public override string? Get(char[] key, int start, int length) { if (length == 0) { return string.Empty; } int num = length + HashCodeRandomizer; num += (num << 7) ^ key[start]; int num2 = start + length; for (int i = start + 1; i < num2; i++) { num += (num << 7) ^ key[i]; } num -= num >> 17; num -= num >> 11; num -= num >> 5; int num3 = num & _mask; Entry[] entries = _entries; for (Entry entry = entries[num3]; entry != null; entry = entry.Next) { if (entry.HashCode == num && TextEquals(entry.Value, key, start, length)) { return entry.Value; } } return null; } public string Add(string key) { if (key == null) { throw new ArgumentNullException("key"); } int length = key.Length; if (length == 0) { return string.Empty; } int num = length + HashCodeRandomizer; for (int i = 0; i < key.Length; i++) { num += (num << 7) ^ key[i]; } num -= num >> 17; num -= num >> 11; num -= num >> 5; for (Entry entry = _entries[num & _mask]; entry != null; entry = entry.Next) { if (entry.HashCode == num && entry.Value.Equals(key, StringComparison.Ordinal)) { return entry.Value; } } return AddEntry(key, num); } private string AddEntry(string str, int hashCode) { int num = hashCode & _mask; Entry entry = new Entry(str, hashCode, _entries[num]); _entries[num] = entry; if (_count++ == _mask) { Grow(); } return entry.Value; } private void Grow() { Entry[] entries = _entries; int num = _mask * 2 + 1; Entry[] array = new Entry[num + 1]; for (int i = 0; i < entries.Length; i++) { Entry entry = entries[i]; while (entry != null) { int num2 = entry.HashCode & num; Entry next = entry.Next; entry.Next = array[num2]; array[num2] = entry; entry = next; } } _entries = array; _mask = num; } private static bool TextEquals(string str1, char[] str2, int str2Start, int str2Length) { if (str1.Length != str2Length) { return false; } for (int i = 0; i < str1.Length; i++) { if (str1[i] != str2[str2Start + i]) { return false; } } return true; } } [Flags] public enum DefaultValueHandling { Include = 0, Ignore = 1, Populate = 2, IgnoreAndPopulate = 3 } public enum FloatFormatHandling { String, Symbol, DefaultValue } public enum FloatParseHandling { Double, Decimal } public enum Formatting { None, Indented } public interface IArrayPool<T> { T[] Rent(int minimumLength); void Return(T[]? array); } public interface IJsonLineInfo { int LineNumber { get; } int LinePosition { get; } bool HasLineInfo(); } [AttributeUsage(AttributeTargets.Class | AttributeTargets.Interface, AllowMultiple = false)] public sealed class JsonArrayAttribute : JsonContainerAttribute { private bool _allowNullItems; public bool AllowNullItems { get { return _allowNullItems; } set { _allowNullItems = value; } } public JsonArrayAttribute() { } public JsonArrayAttribute(bool allowNullItems) { _allowNullItems = allowNullItems; } public JsonArrayAttribute(string id) : base(id) { } } [AttributeUsage(AttributeTargets.Constructor, AllowMultiple = false)] public sealed class JsonConstructorAttribute : Attribute { } [AttributeUsage(AttributeTargets.Class | AttributeTargets.Interface, AllowMultiple = false)] public abstract class JsonContainerAttribute : Attribute { internal bool? _isReference; internal bool? _itemIsReference; internal ReferenceLoopHandling? _itemReferenceLoopHandling; internal TypeNameHandling? _itemTypeNameHandling; private Type? _namingStrategyType; private object[]? _namingStrategyParameters; public string? Id { get; set; } public string? Title { get; set; } public string? Description { get; set; } public Type? ItemConverterType { get; set; } public object[]? ItemConverterParameters { get; set; } public Type? NamingStrategyType { get { return _namingStrategyType; } set { _namingStrategyType = value; NamingStrategyInstance = null; } } public object[]? NamingStrategyParameters { get { return _namingStrategyParameters; } set { _namingStrategyParameters = value; NamingStrategyInstance = null; } } internal NamingStrategy? NamingStrategyInstance { get; set; } public bool IsReference { get { return _isReference.GetValueOrDefault(); } set { _isReference = value; } } public bool ItemIsReference { get { return _itemIsReference.GetValueOrDefault(); } set { _itemIsReference = value; } } public ReferenceLoopHandling ItemReferenceLoopHandling { get { return _itemReferenceLoopHandling.GetValueOrDefault(); } set { _itemReferenceLoopHandling = value; } } public TypeNameHandling ItemTypeNameHandling { get { return _itemTypeNameHandling.GetValueOrDefault(); } set { _itemTypeNameHandling = value; } } protected JsonContainerAttribute() { } protected JsonContainerAttribute(string id) { Id = id; } } public static class JsonConvert { public static readonly string True = "true"; public static readonly string False = "false"; public static readonly string Null = "null"; public static readonly string Undefined = "undefined"; public static readonly string PositiveInfinity = "Infinity"; public static readonly string NegativeInfinity = "-Infinity"; public static readonly string NaN = "NaN"; public static Func<JsonSerializerSettings>? DefaultSettings { get; set; } public static string ToString(DateTime value) { return ToString(value, DateFormatHandling.IsoDateFormat, DateTimeZoneHandling.RoundtripKind); } public static string ToString(DateTime value, DateFormatHandling format, DateTimeZoneHandling timeZoneHandling) { DateTime value2 = DateTimeUtils.EnsureDateTime(value, timeZoneHandling); using StringWriter stringWriter = StringUtils.CreateStringWriter(64); stringWriter.Write('"'); DateTimeUtils.WriteDateTimeString(stringWriter, value2, format, null, CultureInfo.InvariantCulture); stringWriter.Write('"'); return stringWriter.ToString(); } public static string ToString(DateTimeOffset value) { return ToString(value, DateFormatHandling.IsoDateFormat); } public static string ToString(DateTimeOffset value, DateFormatHandling format) { using StringWriter stringWriter = StringUtils.CreateStringWriter(64); stringWriter.Write('"'); DateTimeUtils.WriteDateTimeOffsetString(stringWriter, value, format, null, CultureInfo.InvariantCulture); stringWriter.Write('"'); return stringWriter.ToString(); } public static string ToString(bool value) { return value ? True : False; } public static string ToString(char value) { return ToString(char.ToString(value)); } public static string ToString(Enum value) { return value.ToString("D"); } public static string ToString(int value) { return value.ToString(null, CultureInfo.InvariantCulture); } public static string ToString(short value) { return value.ToString(null, CultureInfo.InvariantCulture); } [CLSCompliant(false)] public static string ToString(ushort value) { return value.ToString(null, CultureInfo.InvariantCulture); } [CLSCompliant(false)] public static string ToString(uint value) { return value.ToString(null, CultureInfo.InvariantCulture); } public static string ToString(long value) { return value.ToString(null, CultureInfo.InvariantCulture); } private static string ToStringInternal(BigInteger value) { return value.ToString(null, CultureInfo.InvariantCulture); } [CLSCompliant(false)] public static string ToString(ulong value) { return value.ToString(null, CultureInfo.InvariantCulture); } public static string ToString(float value) { return EnsureDecimalPlace(value, value.ToString("R", CultureInfo.InvariantCulture)); } internal static string ToString(float value, FloatFormatHandling floatFormatHandling, char quoteChar, bool nullable) { return EnsureFloatFormat(value, EnsureDecimalPlace(value, value.ToString("R", CultureInfo.InvariantCulture)), floatFormatHandling, quoteChar, nullable); } private static string EnsureFloatFormat(double value, string text, FloatFormatHandling floatFormatHandling, char quoteChar, bool nullable) { if (floatFormatHandling == FloatFormatHandling.Symbol || (!double.IsInfinity(value) && !double.IsNaN(value))) { return text; } if (floatFormatHandling == FloatFormatHandling.DefaultValue) { return (!nullable) ? "0.0" : Null; } return quoteChar + text + quoteChar; } public static string ToString(double value) { return EnsureDecimalPlace(value, value.ToString("R", CultureInfo.InvariantCulture)); } internal static string ToString(double value, FloatFormatHandling floatFormatHandling, char quoteChar, bool nullable) { return EnsureFloatFormat(value, EnsureDecimalPlace(value, value.ToString("R", CultureInfo.InvariantCulture)), floatFormatHandling, quoteChar, nullable); } private static string EnsureDecimalPlace(double value, string text) { if (double.IsNaN(value) || double.IsInfinity(value) || text.IndexOf('.') != -1 || text.IndexOf('E') != -1 || text.IndexOf('e') != -1) { return text; } return text + ".0"; } private static string EnsureDecimalPlace(string text) { if (text.IndexOf('.') != -1) { return text; } return text + ".0"; } public static string ToString(byte value) { return value.ToString(null, CultureInfo.InvariantCulture); } [CLSCompliant(false)] public static string ToString(sbyte value) { return value.ToString(null, CultureInfo.InvariantCulture); } public static string ToString(decimal value) { return EnsureDecimalPlace(value.ToString(null, CultureInfo.InvariantCulture)); } public static string ToString(Guid value) { return ToString(value, '"'); } internal static string ToString(Guid value, char quoteChar) { string text = value.ToString("D", CultureInfo.InvariantCulture); string text2 = quoteChar.ToString(CultureInfo.InvariantCulture); return text2 + text + text2; } public static string ToString(TimeSpan value) { return ToString(value, '"'); } internal static string ToString(TimeSpan value, char quoteChar) { return ToString(value.ToString(), quoteChar); } public static string ToString(Uri? value) { if (value == null) { return Null; } return ToString(value, '"'); } internal static string ToString(Uri value, char quoteChar) { return ToString(value.OriginalString, quoteChar); } public static string ToString(string? value) { return ToString(value, '"'); } public static string ToString(string? value, char delimiter) { return ToString(value, delimiter, StringEscapeHandling.Default); } public static string ToString(string? value, char delimiter, StringEscapeHandling stringEscapeHandling) { if (delimiter != '"' && delimiter != '\'') { throw new ArgumentException("Delimiter must be a single or double quote.", "delimiter"); } return JavaScriptUtils.ToEscapedJavaScriptString(value, delimiter, appendDelimiters: true, stringEscapeHandling); } public static string ToString(object? value) { if (value == null) { return Null; } return ConvertUtils.GetTypeCode(value.GetType()) switch { PrimitiveTypeCode.String => ToString((string)value), PrimitiveTypeCode.Char => ToString((char)value), PrimitiveTypeCode.Boolean => ToString((bool)value), PrimitiveTypeCode.SByte => ToString((sbyte)value), PrimitiveTypeCode.Int16 => ToString((short)value), PrimitiveTypeCode.UInt16 => ToString((ushort)value), PrimitiveTypeCode.Int32 => ToString((int)value), PrimitiveTypeCode.Byte => ToString((byte)value), PrimitiveTypeCode.UInt32 => ToString((uint)value), PrimitiveTypeCode.Int64 => ToString((long)value), PrimitiveTypeCode.UInt64 => ToString((ulong)value), PrimitiveTypeCode.Single => ToString((float)value), PrimitiveTypeCode.Double => ToString((double)value), PrimitiveTypeCode.DateTime => ToString((DateTime)value), PrimitiveTypeCode.Decimal => ToString((decimal)value), PrimitiveTypeCode.DBNull => Null, PrimitiveTypeCode.DateTimeOffset => ToString((DateTimeOffset)value), PrimitiveTypeCode.Guid => ToString((Guid)value), PrimitiveTypeCode.Uri => ToString((Uri)value), PrimitiveTypeCode.TimeSpan => ToString((TimeSpan)value), PrimitiveTypeCode.BigInteger => ToStringInternal((BigInteger)value), _ => throw new ArgumentException("Unsupported type: {0}. Use the JsonSerializer class to get the object's JSON representation.".FormatWith(CultureInfo.InvariantCulture, value.GetType())), }; } [DebuggerStepThrough] public static string SerializeObject(object? value) { return SerializeObject(value, (Type?)null, (JsonSerializerSettings?)null); } [DebuggerStepThrough] public static string SerializeObject(object? value, Formatting formatting) { return SerializeObject(value, formatting, (JsonSerializerSettings?)null); } [DebuggerStepThrough] public static string SerializeObject(object? value, params JsonConverter[] converters) { JsonSerializerSettings settings = ((converters != null && converters.Length != 0) ? new JsonSerializerSettings { Converters = converters } : null); return SerializeObject(value, null, settings); } [DebuggerStepThrough] public static string SerializeObject(object? value, Formatting formatting, params JsonConverter[] converters) { JsonSerializerSettings settings = ((converters != null && converters.Length != 0) ? new JsonSerializerSettings { Converters = converters } : null); return SerializeObject(value, null, formatting, settings); } [DebuggerStepThrough] public static string SerializeObject(object? value, JsonSerializerSettings? settings) { return SerializeObject(value, null, settings); } [DebuggerStepThrough] public static string SerializeObject(object? value, Type? type, JsonSerializerSettings? settings) { JsonSerializer jsonSerializer = JsonSerializer.CreateDefault(settings); return SerializeObjectInternal(value, type, jsonSerializer); } [DebuggerStepThrough] public static string SerializeObject(object? value, Formatting formatting, JsonSerializerSettings? settings) { return SerializeObject(value, null, formatting, settings); } [DebuggerStepThrough] public static string SerializeObject(object? value, Type? type, Formatting formatting, JsonSerializerSettings? settings) { JsonSerializer jsonSerializer = JsonSerializer.CreateDefault(settings); jsonSerializer.Formatting = formatting; return SerializeObjectInternal(value, type, jsonSerializer); } private static string SerializeObjectInternal(object? value, Type? type, JsonSerializer jsonSerializer) { StringBuilder sb = new StringBuilder(256); StringWriter stringWriter = new StringWriter(sb, CultureInfo.InvariantCulture); using (JsonTextWriter jsonTextWriter = new JsonTextWriter(stringWriter)) { jsonTextWriter.Formatting = jsonSerializer.Formatting; jsonSerializer.Serialize(jsonTextWriter, value, type); } return stringWriter.ToString(); } [DebuggerStepThrough] public static object? DeserializeObject(string value) { return DeserializeObject(value, (Type?)null, (JsonSerializerSettings?)null); } [DebuggerStepThrough] public static object? DeserializeObject(string value, JsonSerializerSettings settings) { return DeserializeObject(value, null, settings); } [DebuggerStepThrough] public static object? DeserializeObject(string value, Type type) { return DeserializeObject(value, type, (JsonSerializerSettings?)null); } [DebuggerStepThrough] public static T? DeserializeObject<T>(string value) { return JsonConvert.DeserializeObject<T>(value, (JsonSerializerSettings?)null); } [DebuggerStepThrough] public static T? DeserializeAnonymousType<T>(string value, T anonymousTypeObject) { return DeserializeObject<T>(value); } [DebuggerStepThrough] public static T? DeserializeAnonymousType<T>(string value, T anonymousTypeObject, JsonSerializerSettings settings) { return DeserializeObject<T>(value, settings); } [DebuggerStepThrough] public static T? DeserializeObject<T>(string value, params JsonConverter[] converters) { return (T)DeserializeObject(value, typeof(T), converters); } [DebuggerStepThrough] public static T? DeserializeObject<T>(string value, JsonSerializerSettings? settings) { return (T)DeserializeObject(value, typeof(T), settings); } [DebuggerStepThrough] public static object? DeserializeObject(string value, Type type, params JsonConverter[] converters) { JsonSerializerSettings settings = ((converters != null && converters.Length != 0) ? new JsonSerializerSettings { Converters = converters } : null); return DeserializeObject(value, type, settings); } public static object? DeserializeObject(string value, Type? type, JsonSerializerSettings? settings) { ValidationUtils.ArgumentNotNull(value, "value"); JsonSerializer jsonSerializer = JsonSerializer.CreateDefault(settings); if (!jsonSerializer.IsCheckAdditionalContentSet()) { jsonSerializer.CheckAdditionalContent = true; } using JsonTextReader reader = new JsonTextReader(new StringReader(value)); return jsonSerializer.Deserialize(reader, type); } [DebuggerStepThrough] public static void PopulateObject(string value, object target) { PopulateObject(value, target, null); } public static void PopulateObject(string value, object target, JsonSerializerSettings? settings) { JsonSerializer jsonSerializer = JsonSerializer.CreateDefault(settings); using JsonReader jsonReader = new JsonTextReader(new StringReader(value)); jsonSerializer.Populate(jsonReader, target); if (settings == null || !settings.CheckAdditionalContent) { return; } while (jsonReader.Read()) { if (jsonReader.TokenType != JsonToken.Comment) { throw JsonSerializationException.Create(jsonReader, "Additional text found in JSON string after finishing deserializing object."); } } } public static string SerializeXmlNode(XmlNode? node) { return SerializeXmlNode(node, Formatting.None); } public static string SerializeXmlNode(XmlNode? node, Formatting formatting) { XmlNodeConverter xmlNodeConverter = new XmlNodeConverter(); return SerializeObject(node, formatting, xmlNodeConverter); } public static string SerializeXmlNode(XmlNode? node, Formatting formatting, bool omitRootObject) { XmlNodeConverter xmlNodeConverter = new XmlNodeConverter { OmitRootObject = omitRootObject }; return SerializeObject(node, formatting, xmlNodeConverter); } public static XmlDocument? DeserializeXmlNode(string value) { return DeserializeXmlNode(value, null); } public static XmlDocument? DeserializeXmlNode(string value, string? deserializeRootElementName) { return DeserializeXmlNode(value, deserializeRootElementName, writeArrayAttribute: false); } public static XmlDocument? DeserializeXmlNode(string value, string? deserializeRootElementName, bool writeArrayAttribute) { return DeserializeXmlNode(value, deserializeRootElementName, writeArrayAttribute, encodeSpecialCharacters: false); } public static XmlDocument? DeserializeXmlNode(string value, string? deserializeRootElementName, bool writeArrayAttribute, bool encodeSpecialCharacters) { XmlNodeConverter xmlNodeConverter = new XmlNodeConverter(); xmlNodeConverter.DeserializeRootElementName = deserializeRootElementName; xmlNodeConverter.WriteArrayAttribute = writeArrayAttribute; xmlNodeConverter.EncodeSpecialCharacters = encodeSpecialCharacters; return (XmlDocument)DeserializeObject(value, typeof(XmlDocument), xmlNodeConverter); } public static string SerializeXNode(XObject? node) { return SerializeXNode(node, Formatting.None); } public static string SerializeXNode(XObject? node, Formatting formatting) { return SerializeXNode(node, formatting, omitRootObject: false); } public static string SerializeXNode(XObject? node, Formatting formatting, bool omitRootObject) { XmlNodeConverter xmlNodeConverter = new XmlNodeConverter { OmitRootObject = omitRootObject }; return SerializeObject(node, formatting, xmlNodeConverter); } public static XDocument? DeserializeXNode(string value) { return DeserializeXNode(value, null); } public static XDocument? DeserializeXNode(string value, string? deserializeRootElementName) { return DeserializeXNode(value, deserializeRootElementName, writeArrayAttribute: false); } public static XDocument? DeserializeXNode(string value, string? deserializeRootElementName, bool writeArrayAttribute) { return DeserializeXNode(value, deserializeRootElementName, writeArrayAttribute, encodeSpecialCharacters: false); } public static XDocument? DeserializeXNode(string value, string? deserializeRootElementName, bool writeArrayAttribute, bool encodeSpecialCharacters) { //IL_0039: Unknown result type (might be due to invalid IL or missing references) //IL_003f: Expected O, but got Unknown XmlNodeConverter xmlNodeConverter = new XmlNodeConverter(); xmlNodeConverter.DeserializeRootElementName = deserializeRootElementName; xmlNodeConverter.WriteArrayAttribute = writeArrayAttribute; xmlNodeConverter.EncodeSpecialCharacters = encodeSpecialCharacters; return (XDocument)DeserializeObject(value, typeof(XDocument), xmlNodeConverter); } } public abstract class JsonConverter { public virtual bool CanRead => true; public virtual bool CanWrite => true; public abstract void WriteJson(JsonWriter writer, object? value, JsonSerializer serializer); public abstract object? ReadJson(JsonReader reader, Type objectType, object? existingValue, JsonSerializer serializer); public abstract bool CanConvert(Type objectType); } public abstract class JsonConverter<T> : JsonConverter { public sealed override void WriteJson(JsonWriter writer, object? value, JsonSerializer serializer) { if (!((value != null) ? (value is T) : ReflectionUtils.IsNullable(typeof(T)))) { throw new JsonSerializationException("Converter cannot write specified value to JSON. {0} is required.".FormatWith(CultureInfo.InvariantCulture, typeof(T))); } WriteJson(writer, (T)value, serializer); } public abstract void WriteJson(JsonWriter writer, T? value, JsonSerializer serializer); public sealed override object? ReadJson(JsonReader reader, Type objectType, object? existingValue, JsonSerializer serializer) { bool flag = existingValue == null; if (!flag && !(existingValue is T)) { throw new JsonSerializationException("Converter cannot read JSON with the specified existing value. {0} is required.".FormatWith(CultureInfo.InvariantCulture, typeof(T))); } return ReadJson(reader, objectType, flag ? default(T) : ((T)existingValue), !flag, serializer); } public abstract T? ReadJson(JsonReader reader, Type objectType, T? existingValue, bool hasExistingValue, JsonSerializer serializer); public sealed override bool CanConvert(Type objectType) { return typeof(T).IsAssignableFrom(objectType); } } [AttributeUsage(AttributeTargets.Class | AttributeTargets.Struct | AttributeTargets.Enum | AttributeTargets.Property | AttributeTargets.Field | AttributeTargets.Interface | AttributeTargets.Parameter, AllowMultiple = false)] public sealed class JsonConverterAttribute : Attribute { private readonly Type _converterType; public Type ConverterType => _converterType; public object[]? ConverterParameters { get; } public JsonConverterAttribute(Type converterType) { if (converterType == null) { throw new ArgumentNullException("converterType"); } _converterType = converterType; } public JsonConverterAttribute(Type converterType, params object[] converterParameters) : this(converterType) { ConverterParameters = converterParameters; } } public class JsonConverterCollection : Collection<JsonConverter> { } [AttributeUsage(AttributeTargets.Class | AttributeTargets.Interface, AllowMultiple = false)] public sealed class JsonDictionaryAttribute : JsonContainerAttribute { public JsonDictionaryAttribute() { } public JsonDictionaryAttribute(string id) : base(id) { } } [Serializable] public class JsonException : Exception { public JsonException() { } public JsonException(string message) : base(message) { } public JsonException(string message, Exception? innerException) : base(message, innerException) { } public JsonException(SerializationInfo info, StreamingContext context) : base(info, context) { } internal static JsonException Create(IJsonLineInfo lineInfo, string path, string message) { message = JsonPosition.FormatMessage(lineInfo, path, message); return new JsonException(message); } } [AttributeUsage(AttributeTargets.Property | AttributeTargets.Field, AllowMultiple = false)] public class JsonExtensionDataAttribute : Attribute { public bool WriteData { get; set; } public bool ReadData { get; set; } public JsonExtensionDataAttribute() { WriteData = true; ReadData = true; } } [AttributeUsage(AttributeTargets.Property | AttributeTargets.Field, AllowMultiple = false)] public sealed class JsonIgnoreAttribute : Attribute { } public abstract class JsonNameTable { public abstract string? Get(char[] key, int start, int length); } [AttributeUsage(AttributeTargets.Class | AttributeTargets.Struct | AttributeTargets.Interface, AllowMultiple = false)] public sealed class JsonObjectAttribute : JsonContainerAttribute { private MemberSerialization _memberSerialization = MemberSerialization.OptOut; internal MissingMemberHandling? _missingMemberHandling; internal Required? _itemRequired; internal NullValueHandling? _itemNullValueHandling; public MemberSerialization MemberSerialization { get { return _memberSerialization; } set { _memberSerialization = value; } } public MissingMemberHandling MissingMemberHandling { get { return _missingMemberHandling.GetValueOrDefault(); } set { _missingMemberHandling = value; } } public NullValueHandling ItemNullValueHandling { get { return _itemNullValueHandling.GetValueOrDefault(); } set { _itemNullValueHandling = value; } } public Required ItemRequired { get { return _itemRequired.GetValueOrDefault(); } set { _itemRequired = value; } } public JsonObjectAttribute() { } public JsonObjectAttribute(MemberSerialization memberSerialization) { MemberSerialization = memberSerialization; } public JsonObjectAttribute(string id) : base(id) { } } internal enum JsonContainerType { None, Object, Array, Constructor } internal struct JsonPosition { private static readonly char[] SpecialCharacters = new char[18] { '.', ' ', '\'', '/', '"', '[', ']', '(', ')', '\t', '\n', '\r', '\f', '\b', '\\', '\u0085', '\u2028', '\u2029' }; internal JsonContainerType Type; internal int Position; internal string? PropertyName; internal bool HasIndex; public JsonPosition(JsonContainerType type) { Type = type; HasIndex = TypeHasIndex(type); Position = -1; PropertyName = null; } internal int CalculateLength() { switch (Type) { case JsonContainerType.Object: return PropertyName.Length + 5; case JsonContainerType.Array: case JsonContainerType.Constructor: return MathUtils.IntLength((ulong)Position) + 2; default: throw new ArgumentOutOfRangeException("Type"); } } internal void WriteTo(StringBuilder sb, ref StringWriter? writer, ref char[]? buffer) { switch (Type) { case JsonContainerType.Object: { string propertyName = PropertyName; if (propertyName.IndexOfAny(SpecialCharacters) != -1) { sb.Append("['"); if (writer == null) { writer = new StringWriter(sb); } JavaScriptUtils.WriteEscapedJavaScriptString(writer, propertyName, '\'', appendDelimiters: false, JavaScriptUtils.SingleQuoteCharEscapeFlags, StringEscapeHandling.Default, null, ref buffer); sb.Append("']"); } else { if (sb.Length > 0) { sb.Append('.'); } sb.Append(propertyName); } break; } case JsonContainerType.Array: case JsonContainerType.Constructor: sb.Append('['); sb.Append(Position); sb.Append(']'); break; } } internal static bool TypeHasIndex(JsonContainerType type) { return type == JsonContainerType.Array || type == JsonContainerType.Constructor; } internal static string BuildPath(List<JsonPosition> positions, JsonPosition? currentPosition) { int num = 0; if (positions != null) { for (int i = 0; i < positions.Count; i++) { num += positions[i].CalculateLength(); } } if (currentPosition.HasValue) { num += currentPosition.GetValueOrDefault().CalculateLength(); } StringBuilder stringBuilder = new StringBuilder(num); StringWriter writer = null; char[] buffer = null; if (positions != null) { foreach (JsonPosition position in positions) { position.WriteTo(stringBuilder, ref writer, ref buffer); } } currentPosition?.WriteTo(stringBuilder, ref writer, ref buffer); return stringBuilder.ToString(); } internal static string FormatMessage(IJsonLineInfo? lineInfo, string path, string message) { if (!message.EndsWith(Environment.NewLine, StringComparison.Ordinal)) { message = message.Trim(); if (!StringUtils.EndsWith(message, '.')) { message += "."; } message += " "; } message += "Path '{0}'".FormatWith(CultureInfo.InvariantCulture, path); if (lineInfo != null && lineInfo.HasLineInfo()) { message += ", line {0}, position {1}".FormatWith(CultureInfo.InvariantCulture, lineInfo.LineNumber, lineInfo.LinePosition); } message += "."; return message; } } [AttributeUsage(AttributeTargets.Property | AttributeTargets.Field | AttributeTargets.Parameter, AllowMultiple = false)] public sealed class JsonPropertyAttribute : Attribute { internal NullValueHandling? _nullValueHandling; internal DefaultValueHandling? _defaultValueHandling; internal ReferenceLoopHandling? _referenceLoopHandling; internal ObjectCreationHandling? _objectCreationHandling; internal TypeNameHandling? _typeNameHandling; internal bool? _isReference; internal int? _order; internal Required? _required; internal bool? _itemIsReference; internal ReferenceLoopHandling? _itemReferenceLoopHandling; internal TypeNameHandling? _itemTypeNameHandling; public Type? ItemConverterType { get; set; } public object[]? ItemConverterParameters { get; set; } public Type? NamingStrategyType { get; set; } public object[]? NamingStrategyParameters { get; set; } public NullValueHandling NullValueHandling { get { return _nullValueHandling.GetValueOrDefault(); } set { _nullValueHandling = value; } } public DefaultValueHandling DefaultValueHandling { get { return _defaultValueHandling.GetValueOrDefault(); } set { _defaultValueHandling = value; } } public ReferenceLoopHandling ReferenceLoopHandling { get { return _referenceLoopHandling.GetValueOrDefault(); } set { _referenceLoopHandling = value; } } public ObjectCreationHandling ObjectCreationHandling { get { return _objectCreationHandling.GetValueOrDefault(); } set { _objectCreationHandling = value; } } public TypeNameHandling TypeNameHandling { get { return _typeNameHandling.GetValueOrDefault(); } set { _typeNameHandling = value; } } public bool IsReference { get { return _isReference.GetValueOrDefault(); } set { _isReference = value; } } public int Order { get { return _order.GetValueOrDefault(); } set { _order = value; } } public Required Required { get { return _required.GetValueOrDefault(); } set { _required = value; } } public string? PropertyName { get; set; } public ReferenceLoopHandling ItemReferenceLoopHandling { get { return _itemReferenceLoopHandling.GetValueOrDefault(); } set { _itemReferenceLoopHandling = value; } } public TypeNameHandling ItemTypeNameHandling { get { return _itemTypeNameHandling.GetValueOrDefault(); } set { _itemTypeNameHandling = value; } } public bool ItemIsReference { get { return _itemIsReference.GetValueOrDefault(); } set { _itemIsReference = value; } } public JsonPropertyAttribute() { } public JsonPropertyAttribute(string propertyName) { PropertyName = propertyName; } } public abstract class JsonReader : IDisposable { protected internal enum State { Start, Complete, Property, ObjectStart, Object, ArrayStart, Array, Closed, PostValue, ConstructorStart, Constructor, Error, Finished } private JsonToken _tokenType; private object? _value; internal char _quoteChar; internal State _currentState; private JsonPosition _currentPosition; private CultureInfo? _culture; private DateTimeZoneHandling _dateTimeZoneHandling; private int? _maxDepth; private bool _hasExceededMaxDepth; internal DateParseHandling _dateParseHandling; internal FloatParseHandling _floatParseHandling; private string? _dateFormatString; private List<JsonPosition>? _stack; protected State CurrentState => _currentState; public bool CloseInput { get; set; } public bool SupportMultipleContent { get; set; } public virtual char QuoteChar { get { return _quoteChar; } protected internal set { _quoteChar = value; } } public DateTimeZoneHandling DateTimeZoneHandling { get { return _dateTimeZoneHandling; } set { if (value < DateTimeZoneHandling.Local || value > DateTimeZoneHandling.RoundtripKind) { throw new ArgumentOutOfRangeException("value"); } _dateTimeZoneHandling = value; } } public DateParseHandling DateParseHandling { get { return _dateParseHandling; } set { if (value < DateParseHandling.None || value > DateParseHandling.DateTimeOffset) { throw new ArgumentOutOfRangeException("value"); } _dateParseHandling = value; } } public FloatParseHandling FloatParseHandling { get { return _floatParseHandling; } set { if (value < FloatParseHandling.Double || value > FloatParseHandling.Decimal) { throw new ArgumentOutOfRangeException("value"); } _floatParseHandling = value; } } public string? DateFormatString { get { return _dateFormatString; } set { _dateFormatString = value; } } public int? MaxDepth { get { return _maxDepth; } set { if (value <= 0) { throw new ArgumentException("Value must be positive.", "value"); } _maxDepth = value; } } public virtual JsonToken TokenType => _tokenType; public virtual object? Value => _value; public virtual Type? ValueType => _value?.GetType(); public virtual int Depth { get { int num = _stack?.Count ?? 0; if (JsonTokenUtils.IsStartToken(TokenType) || _currentPosition.Type == JsonContainerType.None) { return num; } return num + 1; } } public virtual string Path { get { if (_currentPosition.Type == JsonContainerType.None) { return string.Empty; } JsonPosition? currentPosition = ((_currentState != State.ArrayStart && _currentState != State.ConstructorStart && _currentState != State.ObjectStart) ? new JsonPosition?(_currentPosition) : null); return JsonPosition.BuildPath(_stack, currentPosition); } } public CultureInfo Culture { get { return _culture ?? CultureInfo.InvariantCulture; } set { _culture = value; } } public virtual Task<bool> ReadAsync(CancellationToken cancellationToken = default(CancellationToken)) { return cancellationToken.CancelIfRequestedAsync<bool>() ?? Read().ToAsync(); } public async Task SkipAsync(CancellationToken cancellationToken = default(CancellationToken)) { if (TokenType == JsonToken.PropertyName) { await ReadAsync(cancellationToken).ConfigureAwait(continueOnCapturedContext: false); } if (JsonTokenUtils.IsStartToken(TokenType)) { int depth = Depth; while (await ReadAsync(cancellationToken).ConfigureAwait(continueOnCapturedContext: false) && depth < Depth) { } } } internal async Task ReaderReadAndAssertAsync(CancellationToken cancellationToken) { if (!(await ReadAsync(cancellationToken).ConfigureAwait(continueOnCapturedContext: false))) { throw CreateUnexpectedEndException(); } } public virtual Task<bool?> ReadAsBooleanAsync(CancellationToken cancellationToken = default(CancellationToken)) { return cancellationToken.CancelIfRequestedAsync<bool?>() ?? Task.FromResult(ReadAsBoolean()); } public virtual Task<byte[]?> ReadAsBytesAsync(CancellationToken cancellationToken = default(CancellationToken)) { return cancellationToken.CancelIfRequestedAsync<byte[]>() ?? Task.FromResult(ReadAsBytes()); } internal async Task<byte[]?> ReadArrayIntoByteArrayAsync(CancellationToken cancellationToken) { List<byte> buffer = new List<byte>(); do { if (!(await ReadAsync(cancellationToken).ConfigureAwait(continueOnCapturedContext: false))) { SetToken(JsonToken.None); } } while (!ReadArrayElementIntoByteArrayReportDone(buffer)); byte[] d = buffer.ToArray(); SetToken(JsonToken.Bytes, d, updateIndex: false); return d; } public virtual Task<DateTime?> ReadAsDateTimeAsync(CancellationToken cancellationToken = default(CancellationToken)) { return cancellationToken.CancelIfRequestedAsync<DateTime?>() ?? Task.FromResult(ReadAsDateTime()); } public virtual Task<DateTimeOffset?> ReadAsDateTimeOffsetAsync(CancellationToken cancellationToken = default(CancellationToken)) { return cancellationToken.CancelIfRequestedAsync<DateTimeOffset?>() ?? Task.FromResult(ReadAsDateTimeOffset()); } public virtual Task<decimal?> ReadAsDecimalAsync(CancellationToken cancellationToken = default(CancellationToken)) { return cancellationToken.CancelIfRequestedAsync<decimal?>() ?? Task.FromResult(ReadAsDecimal()); } public virtual Task<double?> ReadAsDoubleAsync(CancellationToken cancellationToken = default(CancellationToken)) { return Task.FromResult(ReadAsDouble()); } public virtual Task<int?> ReadAsInt32Async(CancellationToken cancellationToken = default(CancellationToken)) { return cancellationToken.CancelIfRequestedAsync<int?>() ?? Task.FromResult(ReadAsInt32()); } public virtual Task<string?> ReadAsStringAsync(CancellationToken cancellationToken = default(CancellationToken)) { return cancellationToken.CancelIfRequestedAsync<string>() ?? Task.FromResult(ReadAsString()); } internal async Task<bool> ReadAndMoveToContentAsync(CancellationToken cancellationToken) { bool flag = await ReadAsync(cancellationToken).ConfigureAwait(continueOnCapturedContext: false); if (flag) { flag = await MoveToContentAsync(cancellationToken).ConfigureAwait(continueOnCapturedContext: false); } return flag; } internal Task<bool> MoveToContentAsync(CancellationToken cancellationToken) { JsonToken tokenType = TokenType; JsonToken jsonToken = tokenType; if (jsonToken == JsonToken.None || jsonToken == JsonToken.Comment) { return MoveToContentFromNonContentAsync(cancellationToken); } return AsyncUtils.True; } private async Task<bool> MoveToContentFromNonContentAsync(CancellationToken cancellationToken) { JsonToken jsonToken2; do { if (!(await ReadAsync(cancellationToken).ConfigureAwait(continueOnCapturedContext: false))) { return false; } JsonToken tokenType = TokenType; JsonToken jsonToken = tokenType; jsonToken2 = jsonToken; } while (jsonToken2 == JsonToken.None || jsonToken2 == JsonToken.Comment); return true; } internal JsonPosition GetPosition(int depth) { if (_stack != null && depth < _stack.Count) { return _stack[depth]; } return _currentPosition; } protected JsonReader() { _currentState = State.Start; _dateTimeZoneHandling = DateTimeZoneHandling.RoundtripKind; _dateParseHandling = DateParseHandling.DateTime; _floatParseHandling = FloatParseHandling.Double; _maxDepth = 64; CloseInput = true; } private void Push(JsonContainerType value) { UpdateScopeWithFinishedValue(); if (_currentPosition.Type == JsonContainerType.None) { _currentPosition = new JsonPosition(value); return; } if (_stack == null) { _stack = new List<JsonPosition>(); } _stack.Add(_currentPosition); _currentPosition = new JsonPosition(value); if (!_maxDepth.HasValue || !(Depth + 1 > _maxDepth) || _hasExceededMaxDepth) { return; } _hasExceededMaxDepth = true; throw JsonReaderException.Create(this, "The reader's MaxDepth of {0} has been exceeded.".FormatWith(CultureInfo.InvariantCulture, _maxDepth)); } private JsonContainerType Pop() { JsonPosition currentPosition; if (_stack != null && _stack.Count > 0) { currentPosition = _currentPosition; _currentPosition = _stack[_stack.Count - 1]; _stack.RemoveAt(_stack.Count - 1); } else { currentPosition = _currentPosition; _currentPosition = default(JsonPosition); } if (_maxDepth.HasValue && Depth <= _maxDepth) { _hasExceededMaxDepth = false; } return currentPosition.Type; } private JsonContainerType Peek() { return _currentPosition.Type; } public abstract bool Read(); public virtual int? ReadAsInt32() { JsonToken contentToken = GetContentToken(); switch (contentToken) { case JsonToken.None: case JsonToken.Null: case JsonToken.EndArray: return null; case JsonToken.Integer: case JsonToken.Float: { object value = Value; if (value is int value2) { return value2; } int num; if (value is BigInteger bigInteger) { num = (int)bigInteger; } else { try { num = Convert.ToInt32(value, CultureInfo.InvariantCulture); } catch (Exception ex) { throw JsonReaderException.Create(this, "Could not convert to integer: {0}.".FormatWith(CultureInfo.InvariantCulture, value), ex); } } SetToken(JsonToken.Integer, num, updateIndex: false); return num; } case JsonToken.String: { string s = (string)Value; return ReadInt32String(s); } default: throw JsonReaderException.Create(this, "Error reading integer. Unexpected token: {0}.".FormatWith(CultureInfo.InvariantCulture, contentToken)); } } internal int? ReadInt32String(string? s) { if (StringUtils.IsNullOrEmpty(s)) { SetToken(JsonToken.Null, null, updateIndex: false); return null; } if (int.TryParse(s, NumberStyles.Integer, Culture, out var result)) { SetToken(JsonToken.Integer, result, updateIndex: false); return result; } SetToken(JsonToken.String, s, updateIndex: false); throw JsonReaderException.Create(this, "Could not convert string to integer: {0}.".FormatWith(CultureInfo.InvariantCulture, s)); } public virtual string? ReadAsString() { JsonToken contentToken = GetContentToken(); switch (contentToken) { case JsonToken.None: case JsonToken.Null: case JsonToken.EndArray: return null; case JsonToken.String: return (string)Value; default: if (JsonTokenUtils.IsPrimitiveToken(contentToken)) { object value = Value; if (value != null) { string text = ((!(value is IFormattable formattable)) ? ((value is Uri uri) ? uri.OriginalString : value.ToString()) : formattable.ToString(null, Culture)); SetToken(JsonToken.String, text, updateIndex: false); return text; } } throw JsonReaderException.Create(this, "Error reading string. Unexpected token: {0}.".FormatWith(CultureInfo.InvariantCulture, contentToken)); } } public virtual byte[]? ReadAsBytes() { JsonToken contentToken = GetContentToken(); switch (contentToken) { case JsonToken.StartObject: { ReadIntoWrappedTypeObject(); byte[] array3 = ReadAsBytes(); ReaderReadAndAssert(); if (TokenType != JsonToken.EndObject) { throw JsonReaderException.Create(this, "Error reading bytes. Unexpected token: {0}.".FormatWith(CultureInfo.InvariantCulture, TokenType)); } SetToken(JsonToken.Bytes, array3, updateIndex: false); return array3; } case JsonToken.String: { string text = (string)Value; Guid g; byte[] array2 = ((text.Length == 0) ? CollectionUtils.ArrayEmpty<byte>() : ((!ConvertUtils.TryConvertGuid(text, out g)) ? Convert.FromBase64String(text) : g.ToByteArray())); SetToken(JsonToken.Bytes, array2, updateIndex: false); return array2; } case JsonToken.None: case JsonToken.Null: case JsonToken.EndArray: return null; case JsonToken.Bytes: if (Value is Guid guid) { byte[] array = guid.ToByteArray(); SetToken(JsonToken.Bytes, array, updateIndex: false); return array; } return (byte[])Value; case JsonToken.StartArray: return ReadArrayIntoByteArray(); default: throw JsonReaderException.Create(this, "Error reading bytes. Unexpected token: {0}.".FormatWith(CultureInfo.InvariantCulture, contentToken)); } } internal byte[] ReadArrayIntoByteArray() { List<byte> list = new List<byte>(); do { if (!Read()) { SetToken(JsonToken.None); } } while (!ReadArrayElementIntoByteArrayReportDone(list)); byte[] array = list.ToArray(); SetToken(JsonToken.Bytes, array, updateIndex: false); return array; } private bool ReadArrayElementIntoByteArrayReportDone(List<byte> buffer) { switch (TokenType) { case JsonToken.None: throw JsonReaderException.Create(this, "Unexpected end when reading bytes."); case JsonToken.Integer: buffer.Add(Convert.ToByte(Value, CultureInfo.InvariantCulture)); return false; case JsonToken.EndArray: return true; case JsonToken.Comment: return false; default: throw JsonReaderException.Create(this, "Unexpected token when reading bytes: {0}.".FormatWith(CultureInfo.InvariantCulture, TokenType)); } } public virtual double? ReadAsDouble() { JsonToken contentToken = GetContentToken(); switch (contentToken) { case JsonToken.None: case JsonToken.Null: case JsonToken.EndArray: return null; case JsonToken.Integer: case JsonToken.Float: { object value = Value; if (value is double value2) { return value2; } double num = ((!(value is BigInteger bigInteger) || 1 == 0) ? Convert.ToDouble(value, CultureInfo.InvariantCulture) : ((double)bigInteger)); SetToken(JsonToken.Float, num, updateIndex: false); return num; } case JsonToken.String: return ReadDoubleString((string)Value); default: throw JsonReaderException.Create(this, "Error reading double. Unexpected token: {0}.".FormatWith(CultureInfo.InvariantCulture, contentToken)); } } internal double? ReadDoubleString(string? s) { if (StringUtils.IsNullOrEmpty(s)) { SetToken(JsonToken.Null, null, updateIndex: false); return null; } if (double.TryParse(s, NumberStyles.Float | NumberStyles.AllowThousands, Culture, out var result)) { SetToken(JsonToken.Float, result, updateIndex: false); return result; } SetToken(JsonToken.String, s, updateIndex: false); throw JsonReaderException.Create(this, "Could not convert string to double: {0}.".FormatWith(CultureInfo.InvariantCulture, s)); } public virtual bool? ReadAsBoolean() { JsonToken contentToken = GetContentToken(); switch (contentToken) { case JsonToken.None: case JsonToken.Null: case JsonToken.EndArray: return null; case JsonToken.Integer: case JsonToken.Float: { bool flag = ((!(Value is BigInteger bigInteger) || 1 == 0) ? Convert.ToBoolean(Value, CultureInfo.InvariantCulture) : (bigInteger != 0L)); SetToken(JsonToken.Boolean, flag, updateIndex: false); return flag; } case JsonToken.String: return ReadBooleanString((string)Value); case JsonToken.Boolean: return (bool)Value; default: throw JsonReaderException.Create(this, "Error reading boolean. Unexpected token: {0}.".FormatWith(CultureInfo.InvariantCulture, contentToken)); } } internal bool? ReadBooleanString(string? s) { if (StringUtils.IsNullOrEmpty(s)) { SetToken(JsonToken.Null, null, updateIndex: false); return null; } if (bool.TryParse(s, out var result)) { SetToken(JsonToken.Boolean, result, updateIndex: false); return result; } SetToken(JsonToken.String, s, updateIndex: false); throw JsonReaderException.Create(this, "Could not convert string to boolean: {0}.".FormatWith(CultureInfo.InvariantCulture, s)); } public virtual decimal? ReadAsDecimal() { JsonToken contentToken = GetContentToken(); switch (contentToken) { case JsonToken.None: case JsonToken.Null: case JsonToken.EndArray: return null; case JsonToken.Integer: case JsonToken.Float: { object value = Value; if (value is decimal value2) { return value2; } decimal num; if (value is BigInteger bigInteger) { num = (decimal)bigInteger; } else { try { num = Convert.ToDecimal(value, CultureInfo.InvariantCulture); } catch (Exception ex) { throw JsonReaderException.Create(this, "Could not convert to decimal: {0}.".FormatWith(CultureInfo.InvariantCulture, value), ex); } } SetToken(JsonToken.Float, num, updateIndex: false); return num; } case JsonToken.String: return ReadDecimalString((string)Value); default: throw JsonReaderException.Create(this, "Error reading decimal. Unexpected token: {0}.".FormatWith(CultureInfo.InvariantCulture, contentToken)); } } internal decimal? ReadDecimalString(string? s) { if (StringUtils.IsNullOrEmpty(s)) { SetToken(JsonToken.Null, null, updateIndex: false); return null; } if (decimal.TryParse(s, NumberStyles.Number, Culture, out var result)) { SetToken(JsonToken.Float, result, updateIndex: false); return result; } if (ConvertUtils.DecimalTryParse(s.ToCharArray(), 0, s.Length, out result) == ParseResult.Success) { SetToken(JsonToken.Float, result, updateIndex: false); return result; } SetToken(JsonToken.String, s, updateIndex: false); throw JsonReaderException.Create(this, "Could not convert string to decimal: {0}.".FormatWith(CultureInfo.InvariantCulture, s)); } public virtual DateTime? ReadAsDateTime() { switch (GetContentToken()) { case JsonToken.None: case JsonToken.Null: case JsonToken.EndArray: return null; case JsonToken.Date: if (Value is DateTimeOffset dateTimeOffset) { SetToken(JsonToken.Date, dateTimeOffset.DateTime, updateIndex: false); } return (DateTime)Value; case JsonToken.String: return ReadDateTimeString((string)Value); default: throw JsonReaderException.Create(this, "Error reading date. Unexpected token: {0}.".FormatWith(CultureInfo.InvariantCulture, TokenType)); } } internal DateTime? ReadDateTimeString(string? s) { if (StringUtils.IsNullOrEmpty(s)) { SetToken(JsonToken.Null, null, updateIndex: false); return null; } if (DateTimeUtils.TryParseDateTime(s, DateTimeZoneHandling, _dateFormatString, Culture, out var dt)) { dt = DateTimeUtils.EnsureDateTime(dt, DateTimeZoneHandling); SetToken(JsonToken.Date, dt, updateIndex: false); return dt; } if (DateTime.TryParse(s, Culture, DateTimeStyles.RoundtripKind, out dt)) { dt = DateTimeUtils.EnsureDateTime(dt, DateTimeZoneHandling); SetToken(JsonToken.Date, dt, updateIndex: false); return dt; } throw JsonReaderException.Create(this, "Could not convert string to DateTime: {0}.".FormatWith(CultureInfo.InvariantCulture, s)); } public virtual DateTimeOffset? ReadAsDateTimeOffset() { JsonToken contentToken = GetContentToken(); switch (contentToken) { case JsonToken.None: case JsonToken.Null: case JsonToken.EndArray: return null; case JsonToken.Date: if (Value is DateTime dateTime) { SetToken(JsonToken.Date, new DateTimeOffset(dateTime), updateIndex: false); } return (DateTimeOffset)Value; case JsonToken.String: { string s = (string)Value; return ReadDateTimeOffsetString(s); } default: throw JsonReaderException.Create(this, "Error reading date. Unexpected token: {0}.".FormatWith(CultureInfo.InvariantCulture, contentToken)); } } internal DateTimeOffset? ReadDateTimeOffsetString(string? s) { if (StringUtils.IsNullOrEmpty(s)) { SetToken(JsonToken.Null, null, updateIndex: false); return null; } if (DateTimeUtils.TryParseDateTimeOffset(s, _dateFormatString, Culture, out var dt)) { SetToken(JsonToken.Date, dt, updateIndex: false); return dt; } if (DateTimeOffset.TryParse(s, Culture, DateTimeStyles.RoundtripKind, out dt)) { SetToken(JsonToken.Date, dt, updateIndex: false); return dt; } SetToken(JsonToken.String, s, updateIndex: false); throw JsonReaderException.Create(this, "Could not convert string to DateTimeOffset: {0}.".FormatWith(CultureInfo.InvariantCulture, s)); } internal void ReaderReadAndAssert() { if (!Read()) { throw CreateUnexpectedEndException(); } } internal JsonReaderException CreateUnexpectedEndException() { return JsonReaderException.Create(this, "Unexpected end when reading JSON."); } internal void ReadIntoWrappedTypeObject() { ReaderReadAndAssert(); if (Value != null && Value.ToString() == "$type") { ReaderReadAndAssert(); if (Value != null && Value.ToString().StartsWith("System.Byte[]", StringComparison.Ordinal)) { ReaderReadAndAssert(); if (Value.ToString() == "$value") { return; } } } throw JsonReaderException.Create(this, "Error reading bytes. Unexpected token: {0}.".FormatWith(CultureInfo.InvariantCulture, JsonToken.StartObject)); } public void Skip() { if (TokenType == JsonToken.PropertyName) { Read(); } if (JsonTokenUtils.IsStartToken(TokenType)) { int depth = Depth; while (Read() && depth < Depth) { } } } protected void SetToken(JsonToken newToken) { SetToken(newToken, null, updateIndex: true); } protected void SetToken(JsonToken newToken, object? value) { SetToken(newToken, value, updateIndex: true); } protected void SetToken(JsonToken newToken, object? value, bool updateIndex) { _tokenType = newToken; _value = value; switch (newToken) { case JsonToken.StartObject: _currentState = State.ObjectStart; Push(JsonContainerType.Object); break; case JsonToken.StartArray: _currentState = State.ArrayStart; Push(JsonContainerType.Array); break; case JsonToken.StartConstructor: _currentState = State.ConstructorStart; Push(JsonContainerType.Constructor); break; case JsonToken.EndObject: ValidateEnd(JsonToken.EndObject); break; case JsonToken.EndArray: ValidateEnd(JsonToken.EndArray); break; case JsonToken.EndConstructor: ValidateEnd(JsonToken.EndConstructor); break; case JsonToken.PropertyName: _currentState = State.Property; _currentPosition.PropertyName = (string)value; break; case JsonToken.Raw: case JsonToken.Integer: case JsonToken.Float: case JsonToken.String: case JsonToken.Boolean: case JsonToken.Null: case JsonToken.Undefined: case JsonToken.Date: case JsonToken.Bytes: SetPostValueState(updateIndex); break; case JsonToken.Comment: break; } } internal void SetPostValueState(bool updateIndex) { if (Peek() != 0 || SupportMultipleContent) { _currentState = State.PostValue; } else { SetFinished(); } if (updateIndex) { UpdateScopeWithFinishedValue(); } } private void UpdateScopeWithFinishedValue() { if (_currentPosition.HasIndex) { _currentPosition.Position++; } } private void ValidateEnd(JsonToken endToken) { JsonContainerType jsonContainerType = Pop(); if (GetTypeForCloseToken(endToken) != jsonContainerType) { throw JsonReaderException.Create(this, "JsonToken {0} is not valid for closing JsonType {1}.".FormatWith(CultureInfo.InvariantCulture, endToken, jsonContainerType)); } if (Peek() != 0 || SupportMultipleContent) { _currentState = State.PostValue; } else { SetFinished(); } } protected void SetStateBasedOnCurrent() { JsonContainerType jsonContainerType = Peek(); switch (jsonContainerType) { case JsonContainerType.Object: _currentState = State.Object; break; case JsonContainerType.Array: _currentState = State.Array; break; case JsonContainerType.Constructor: _currentState = State.Constructor; break; case JsonContainerType.None: SetFinished(); break; default: throw JsonReaderException.Create(this, "While setting the reader state back to current object an unexpected JsonType was encountered: {0}".FormatWith(CultureInfo.InvariantCulture, jsonContainerType)); } } private void SetFinished() { _currentState = ((!SupportMultipleContent) ? State.Finished : State.Start); } private JsonContainerType GetTypeForCloseToken(JsonToken token) { return token switch { JsonToken.EndObject => JsonContainerType.Object, JsonToken.EndArray => JsonContainerType.Array, JsonToken.EndConstructor => JsonContainerType.Constructor, _ => throw JsonReaderException.Create(this, "Not a valid close JsonToken: {0}".FormatWith(CultureInfo.InvariantCulture, token)), }; } void IDisposable.Dispose() { Dispose(disposing: true); GC.SuppressFinalize(this); } protected virtual void Dispose(bool disposing) { if (_currentState != State.Closed && disposing) { Close(); } } public virtual void Close() { _currentState = State.Closed; _tokenType = JsonToken.None; _value = null; } internal void ReadAndAssert() { if (!Read()) { throw JsonSerializationException.Create(this, "Unexpected end when reading JSON."); } } internal void ReadForTypeAndAssert(JsonContract? contract, bool hasConverter) { if (!ReadForType(contract, hasConverter)) { throw JsonSerializationException.Create(this, "Unexpected end when reading JSON."); } } internal bool ReadForType(JsonContract? contract, bool hasConverter) { if (hasConverter) { return Read(); } switch (contract?.InternalReadType ?? ReadType.Read) { case ReadType.Read: return ReadAndMoveToContent(); case ReadType.ReadAsInt32: ReadAsInt32(); break; case ReadType.ReadAsInt64: { bool result = ReadAndMoveToContent(); if (TokenType == JsonToken.Undefined) { throw JsonReaderException.Create(this, "An undefined token is not a valid {0}.".FormatWith(CultureInfo.InvariantCulture, contract?.UnderlyingType ?? typeof(long))); } return result; } case ReadType.ReadAsDecimal: ReadAsDecimal(); break; case ReadType.ReadAsDouble: ReadAsDouble(); break; case ReadType.ReadAsBytes: ReadAsBytes(); break; case ReadType.ReadAsBoolean: ReadAsBoolean(); break; case ReadType.ReadAsString: ReadAsString(); break; case ReadType.ReadAsDateTime: ReadAsDateTime(); break; case ReadType.ReadAsDateTimeOffset: ReadAsDateTimeOffset(); break; default: throw new ArgumentOutOfRangeException(); } return TokenType != JsonToken.None; } internal bool ReadAndMoveToContent() { return Read() && MoveToContent(); } internal bool MoveToContent() { JsonToken tokenType = TokenType; while (tokenType == JsonToken.None || tokenType == JsonToken.Comment) { if (!Read()) { return false; } tokenType = TokenType; } return true; } private JsonToken GetContentToken() { JsonToken tokenType; do { if (!Read()) { SetToken(JsonToken.None); return JsonToken.None; } tokenType = TokenType; } while (tokenType == JsonToken.Comment); return tokenType; } } [Serializable] public class JsonReaderException : JsonException { public int LineNumber { get; } public int LinePosition { get; } public string? Path { get; } public JsonReaderException() { } public JsonReaderException(string message) : base(message) { } public JsonReaderException(string message, Exception innerException) : base(message, innerException) { } public JsonReaderException(SerializationInfo info, StreamingContext context) : base(info, context) { } public JsonReaderException(string message, string path, int lineNumber, int linePosition, Exception? innerException) : base(message, innerException) { Path = path; LineNumber = lineNumber; LinePosition = linePosition; } internal static JsonReaderException Create(JsonReader reader, string message) { return Create(reader, message, null); } internal static JsonReaderException Create(JsonReader reader, string message, Exception? ex) { return Create(reader as IJsonLineInfo, reader.Path, message, ex); } internal static JsonReaderException Create(IJsonLineInfo? lineInfo, string path, string message, Exception? ex) { message = JsonPosition.FormatMessage(lineInfo, path, message); int lineNumber; int linePosition; if (lineInfo != null && lineInfo.HasLineInfo()) { lineNumber = lineInfo.LineNumber; linePosition = lineInfo.LinePosition; } else { lineNumber = 0; linePosition = 0; } return new JsonReaderException(message, path, lineNumber, linePosition, ex); } } [AttributeUsage(AttributeTargets.Property | AttributeTargets.Field, AllowMultiple = false)] public sealed class JsonRequiredAttribute : Attribute { } [Serializable] public class JsonSerializationException : JsonException { public int LineNumber { get; } public int LinePosition { get; } public string? Path { get; } public JsonSerializationException() { } public JsonSerializationException(string message) : base(message) { } public JsonSerializationException(string message, Exception innerException) : base(message, innerException) { } public JsonSerializationException(SerializationInfo info, StreamingContext context) : base(info, context) { } public JsonSerializationException(string message, string path, int lineNumber, int linePosition, Exception? innerException) : base(message, innerException) { Path = path; LineNumber = lineNumber; LinePosition = linePosition; } internal static JsonSerializationException Create(JsonReader reader, string message) { return Create(reader, message, null); } internal static JsonSerializationException Create(JsonReader reader, string message, Exception? ex) { return Create(reader as IJsonLineInfo, reader.Path, message, ex); } internal static JsonSerializationException Create(IJsonLineInfo? lineInfo, string path, string message, Exception? ex) { message = JsonPosition.FormatMessage(lineInfo, path, message); int lineNumber; int linePosition; if (lineInfo != null && lineInfo.HasLineInfo()) { lineNumber = lineInfo.LineNumber; linePosition = lineInfo.LinePosition; } else { lineNumber = 0; linePosition = 0; } return new JsonSerializationException(message, path, lineNumber, linePosition, ex); } } public class JsonSerializer { internal TypeNameHandling _typeNameHandling; internal TypeNameAssemblyFormatHandling _typeNameAssemblyFormatHandling; internal PreserveReferencesHandling _preserveReferencesHandling; internal ReferenceLoopHandling _referenceLoopHandling; internal MissingMemberHandling _missingMemberHandling; internal ObjectCreationHandling _objectCreationHandling; internal NullValueHandling _nullValueHandling; internal DefaultValueHandling _defaultValueHandling; internal ConstructorHandling _constructorHandling; internal MetadataPropertyHandling _metadataPropertyHandling; internal JsonConverterCollection? _converters; internal IContractResolver _contractResolver; internal ITraceWriter? _traceWriter; internal IEqualityComparer? _equalityComparer; internal ISerializationBinder _serializationBinder; internal StreamingContext _context; private IReferenceResolver? _referenceResolver; private Formatting? _formatting; private DateFormatHandling? _dateFormatHandling; private DateTimeZoneHandling? _dateTimeZoneHandling; private DateParseHandling? _dateParseHandling; private FloatFormatHandling? _floatFormatHandling; private FloatParseHandling? _floatParseHandling; private StringEscapeHandling? _stringEscapeHandling; private CultureInfo _culture; private int? _maxDepth; private bool _maxDepthSet; private bool? _checkAdditionalContent; private string? _dateFormatString; private bool _dateFormatStringSet; public virtual IReferenceResolver? ReferenceResolver { get { return GetReferenceResolver(); } set { if (value == null) { throw new ArgumentNullException("value", "Reference resolver cannot be null."); } _referenceResolver = value; } } [Obsolete("Binder is obsolete. Use SerializationBinder instead.")] public virtual SerializationBinder Binder { get { if (_serializationBinder is SerializationBinder result) { return result; } if (_serializationBinder is SerializationBinderAdapter serializationBinderAdapter) { return serializationBinderAdapter.SerializationBinder; } throw new InvalidOperationException("Cannot get SerializationBinder because an ISerializationBinder was previously set."); } set { if (value == null) { throw new ArgumentNullException("value", "Serialization binder cannot be null."); } _serializationBinder = (value as ISerializationBinder) ?? new SerializationBinderAdapter(value); } } public virtual ISerializationBinder SerializationBinder { get { return _serializationBinder; } set { if (value == null) { throw new ArgumentNullException("value", "Serialization binder cannot be null."); } _serializationBinder = value; } } public virtual ITraceWriter? TraceWriter { get { return _traceWriter; } set { _traceWriter = value; } } public virtual IEqualityComparer? EqualityComparer { get { return _equalityComparer; } set { _equalityComparer = value; } } public virtual TypeNameHandling TypeNameHandling { get { return _typeNameHandling; } set { if (value < TypeNameHandling.None || value > TypeNameHandling.Auto) { throw new ArgumentOutOfRangeException("value"); } _typeNameHandling = value; } } [Obsolete("TypeNameAssemblyFormat is obsolete. Use TypeNameAssemblyFormatHandling instead.")] public virtual FormatterAssemblyStyle TypeNameAssemblyFormat { get { return (FormatterAssemblyStyle)_typeNameAssemblyFormatHandling; } set { if (value < FormatterAssemblyStyle.Simple || value > FormatterAssemblyStyle.Full) { throw new ArgumentOutOfRangeException("value"); } _typeNameAssemblyFormatHandling = (TypeNameAssemblyFormatHandling)value; } } public virtual TypeNameAssemblyFormatHandling TypeNameAssemblyFormatHandling { get { return _typeNameAssemblyFormatHandling; } set { if (value < TypeNameAssemblyFormatHandling.Simple || value > TypeNameAssemblyFormatHandling.Full) { throw new ArgumentOutOfRangeException("value"); } _typeNameAssemblyFormatHandling = value; } } public virtual PreserveReferencesHandling PreserveReferencesHandling { get { return _preserveReferencesHandling; } set { if (value < PreserveReferencesHandling.None || value > PreserveReferencesHandling.All) { throw new ArgumentOutOfRangeException("value"); } _preserveReferencesHandling = value; } } public virtual ReferenceLoopHandling ReferenceLoopHandling { get { return _referenceLoopHandling; } set { if (value < ReferenceLoopHandling.Error || value > ReferenceLoopHandling.Serialize) { throw new ArgumentOutOfRangeException("value"); } _referenceLoopHandling = value; } } public virtual MissingMemberHandling MissingMemberHandling { get { return _missingMemberHandling; } set { if (value < MissingMemberHandling.Ignore || value > MissingMemberHandling.Error) { throw new ArgumentOutOfRangeException("value"); } _missingMemberHandling = value; } } public virtual NullValueHandling NullValueHandling { get { return _nullValueHandling; } set { if (value < NullValueHandling.Include || value > NullValueHandling.Ignore) { throw new ArgumentOutOfRangeException("value"); } _nullValueHandling = value; } } public virtual DefaultValueHandling DefaultValueHandling { get { return _defaultValueHandling; } set { if (value < DefaultValueHandling.Include || value > DefaultValueHandling.IgnoreAndPopulate) { throw new ArgumentOutOfRangeException("value"); } _defaultValueHandling = value; } } public virtual ObjectCreationHandling ObjectCreationHandling { get { return _objectCreationHandling; } set { if (value < ObjectCreationHandling.Auto || value > ObjectCreationHandling.Replace) { throw new ArgumentOutOfRangeException("value"); } _objectCreationHandling = value; } } public virtual ConstructorHandling ConstructorHandling { get { return _constructorHandling; } set { if (value < ConstructorHandling.Default || value > ConstructorHandling.AllowNonPublicDefaultConstructor) { throw new ArgumentOutOfRangeException("value"); } _constructorHandling = value; } } public virtual MetadataPropertyHandling MetadataPropertyHandling { get { return _metadataPropertyHandling; } set { if (value < MetadataPropertyHandling.Default || value > MetadataPropertyHandling.Ignore) { throw new ArgumentOutOfRangeException("value"); } _metadataPropertyHandling = value; } } public virtual JsonConverterCollection Converters { get { if (_converters == null) { _converters = new JsonConverterCollection(); } return _converters; } } public virtual IContractResolver ContractResolver { get { return _contractResolver; } set { _contractResolver = value ?? DefaultContractResolver.Instance; } } public virtual StreamingContext Context { get { return _context; } set { _context = value; } } public virtual Formatting Formatting { get { return _formatting.GetValueOrDefault(); } set { _formatting = value; } } public virtual DateFormatHandling DateFormatHandling { get { return _dateFormatHandling.GetValueOrDefault(); } set { _dateFormatHandling = value; } } public virtual DateTimeZoneHandling DateTimeZoneHandling { get { return _dateTimeZoneHandling ?? DateTimeZoneHandling.RoundtripKind; } set { _dateTimeZoneHandling = value; } } public virtual DateParseHandling DateParseHandling { get { return _dateParseHandling ?? DateParseHandling.DateTime; } set { _dateParseHandling = value; } } public virtual FloatParseHandling FloatParseHandling { get { return _floatParseHandling.GetValueOrDefault(); } set { _floatParseHandling = value; } } public virtual FloatFormatHandling FloatFormatHandling { get { return _floatFormatHandling.GetValueOrDefault(); } set { _floatFormatHandling = value; } } public virtual StringEscapeHandling StringEscapeHandling { get { return _stringEscapeHandling.GetValueOrDefault(); } set { _stringEscapeHandling = value; } } public virtual string DateFormatString { get { return _dateFormatString ?? "yyyy'-'MM'-'dd'T'HH':'mm':'ss.FFFFFFFK"; } set { _dateFormatString = value; _dateFormatStringSet = true; } } public virtual CultureInfo Culture { get { return _culture ?? JsonSerializerSettings.DefaultCulture; } set { _culture = value; } } public virtual int? MaxDepth { get { return _maxDepth; } set { if (value <= 0) { throw new ArgumentException("Value must be positive.", "value"); } _maxDepth = value; _maxDepthSet = true; } } public virtual bool CheckAdditionalContent { get { return _checkAdditionalContent.GetValueOrDefault(); } set { _checkAdditionalContent = value; } } public virtual event EventHandler<Newtonsoft.Json.Serialization.ErrorEventArgs>? Error; internal bool IsCheckAdditionalContentSet() { return _checkAdditionalContent.HasValue; } public JsonSerializer() { _referenceLoopHandling = ReferenceLoopHandling.Error; _missingMemberHandling = MissingMemberHandling.Ignore; _nullValueHandling = NullValueHandling.Include; _defaultValueHandling = DefaultValueHandling.Include; _objectCreationHandling = ObjectCreationHandling.Auto; _preserveReferencesHandling = PreserveReferencesHandling.None; _constructorHandling = ConstructorHandling.Default; _typeNameHandling = TypeNameHandling.None; _metadataPropertyHandling = MetadataPropertyHandling.Default; _context = JsonSerializerSettings.DefaultContext; _serializationBinder = DefaultSerializationBinder.Instance; _culture = JsonSerializerSettings.DefaultCulture; _contractResolver = DefaultContractResolver.Instance; } public static JsonSerializer Create() { return new JsonSerializer(); } public static JsonSerializer Create(JsonSerializerSettings? settings) { JsonSerializer jsonSerializer = Create(); if (settings != null) { ApplySerializerSettings(jsonSerializer, settings); } return jsonSerializer; } public static JsonSerializer CreateDefault() { JsonSerializerSettings settings = JsonConvert.DefaultSettings?.Invoke(); return Create(settings); } public static JsonSerializer CreateDefault(JsonSerializerSettings? settings) { JsonSerializer jsonSerializer = CreateDefault(); if (settings != null) { ApplySerializerSettings(jsonSerializer, settings); } return jsonSerializer; } private static void ApplySerializerSettings(JsonSerializer serializer, JsonSerializerSettings settings) { if (!CollectionUtils.IsNullOrEmpty(settings.Converters)) { for (int i = 0; i < settings.Converters.Count; i++) { serializer.Converters.Insert(i, settings.Converters[i]); } } if (settings._typeNameHandling.HasValue) { serializer.TypeNameHandling = settings.TypeNameHandling; } if (settings._metadataPropertyHandling.HasValue) { serializer.MetadataPropertyHandling = settings.MetadataPropertyHandling; } if (settings._typeNameAssemblyFormatHandling.HasValue) { serializer.TypeNameAssemblyFormatHandling = settings.TypeNameAssemblyFormatHandling; } if (settings._preserveReferencesHandling.HasValue) { serializer.PreserveReferencesHandling = settings.PreserveReferencesHandling; } if (settings._referenceLoopHandling.HasValue) { serializer.ReferenceLoopHandling = settings.ReferenceLoopHandling; } if (settings._missingMemberHandling.HasValue) { serializer.MissingMemberHandling = settings.MissingMemberHandling; } if (settings._objectCreationHandling.HasValue) { serializer.ObjectCreationHandling = settings.ObjectCreationHandling; } if (settings._nullValueHandling.HasValue) { serializer.NullValueHandling = settings.NullValueHandling; } if (settings._defaultValueHandling.HasValue) { serializer.DefaultValueHandling = settings.DefaultValueHandling; } if (settings._constructorHandling.HasValue) { serializer.ConstructorHandling = settings.ConstructorHandling; } if (settings._context.HasValue) { serializer.Context = settings.Context; } if (settings._checkAdditionalContent.HasValue) { serializer._checkAdditionalContent = settings._checkAdditionalContent; } if (settings.Error != null) { serializer.Error += settings.Error; } if (settings.ContractResolver != null) { serializer.ContractResolver = settings.ContractResolver; } if (settings.ReferenceResolverProvider != null) { serializer.ReferenceResolver = settings.ReferenceResolverProvider(); } if (settings.TraceWriter != null) { serializer.TraceWriter = settings.TraceWriter; } if (settings.EqualityComparer != null) { serializer.EqualityComparer = settings.EqualityComparer; } if (settings.SerializationBinder != null) { serializer.SerializationBinder = settings.SerializationBinder; } if (settings._formatting.HasValue) { serializer._formatting = settings._formatting; } if (settings._dateFormatHandling.HasValue) { serializer._dateFormatHandling = settings._dateFormatHandling; } if (settings._dateTimeZoneHandling.HasValue) { serializer._dateTimeZoneHandling = settings._dateTimeZoneHandling; } if (settings._dateParseHandling.HasValue) { serializer._dateParseHandling = settings._dateParseHandling; } if (settings._dateFormatStringSet) { serializer._dateFormatString = settings._dateFormatString; serializer._dateFormatStringSet = settings._dateFormatStringSet; } if (settings._floatFormatHandling.HasValue) { serializer._floatFormatHandling = settings._floatFormatHandling; } if (settings._floatParseHandling.HasValue) { serializer._floatParseHandling = settings._floatParseHandling; } if (settings._stringEscapeHandling.HasValue) { serializer._stringEscapeHandling = settings._stringEscapeHandling; } if (settings._culture != null) { serializer._culture = settings._culture; } if (settings._maxDepthSet) { serializer._maxDepth = settings._maxDepth; serializer._maxDepthSet = settings._maxDepthSet; } } [DebuggerStepThrough] public void Populate(TextReader reader, object target) { Populate(new JsonTextReader(reader), target); } [DebuggerStepThrough] public void Populate(JsonReader reader, object target) { PopulateInternal(reader, target); } internal virtual void PopulateInternal(JsonReader reader, object target) { ValidationUtils.ArgumentNotNull(reader, "reader"); ValidationUtils.ArgumentNotNull(target, "target"); SetupReader(reader, out CultureInfo previousCulture, out DateTimeZoneHandling? previousDateTimeZoneHandling, out DateParseHandling? previousDateParseHandling, out FloatParseHandling? previousFloatParseHandling, out int? previousMaxDepth, out string previousDateFormatString); TraceJsonReader traceJsonReader = ((TraceWriter != null && TraceWriter.LevelFilter >= TraceLevel.Verbose) ? CreateTraceJsonReader(reader) : null); JsonSerializerInternalReader jsonSerializerInternalReader = new JsonSerializerInternalReader(this); jsonSerializerInternalReader.Populate(traceJsonReader ?? reader, target); if (traceJsonReader != null) { TraceWriter.Trace(TraceLevel.Verbose, traceJsonReader.GetDeserializedJsonMessage(), null); } ResetReader(reader, previousCulture, previousDateTimeZoneHandling, previousDateParseHandling, previousFloatParseHandling, previousMaxDepth, previousDateFormatString); } [DebuggerStepThrough] public object? Deserialize(JsonReader reader) { return Deserialize(reader, null); } [DebuggerStepThrough] public object? Deserialize(TextReader reader, Type objectType) { return Deserialize(new JsonTextReader(reader), objectType); } [DebuggerStepThrough] public T? Deserialize<T>(JsonReader reader) { return (T)Deserialize(reader, typeof(T)); } [DebuggerStepThrough] public object? Deserialize(JsonReader reader, Type? objectType) { return DeserializeInternal(reader, objectType); } internal virtual object? DeserializeInternal(JsonReader reader, Type? objectType) { ValidationUtils.ArgumentNotNull(reader, "reader"); SetupReader(reader, out CultureInfo previousCulture, out DateTimeZoneHandling? previousDateTimeZoneHandling, out DateParseHandling? previousDateParseHandling, out FloatParseHandling? previousFloatParseHandling, out int? previousMaxDepth, out string previousDateFormatString); TraceJsonReader traceJsonReader = ((TraceWriter != null && TraceWriter.LevelFilter >= TraceLevel.Verbose) ? CreateTraceJsonReader(reader) : null); JsonSerializerInternalReader jsonSerializerInternalReader = new JsonSerializerInternalReader(this); object result = jsonSerializerInternalReader.Deserialize(traceJsonReader ?? reader, objectType, CheckAdditionalContent); if (traceJsonReader != null) { TraceWriter.Trace(TraceLevel.Verbose, traceJsonReader.GetDeserializedJsonMessage(), null); } ResetReader(reader, previousCulture, previousDateTimeZoneHandling, previousDateParseHandling, previousFloatParseHandling, previousMaxDepth, previousDateFormatString); return result; } internal void SetupReader(JsonReader reader, out CultureInfo? previousCulture, out DateTimeZoneHandling? previousDateTimeZoneHandling, out DateParseHandling? previousDateParseHandling, out FloatParseHandling? previousFloatParseHandling, out int? previousMaxDepth, out string? previousDateFormatString) { if (_culture != null && !_culture.Equals(reader.Culture)) { previousCulture = reader.Culture; reader.Culture = _culture; } else { previousCulture = null; } if (_dateTimeZoneHandling.HasValue && reader.DateTimeZoneHandling != _dateTimeZoneHandling) { previousDateTimeZoneHandling = reader.DateTimeZoneHandling; reader.DateTimeZoneHandling = _dateTimeZoneHandling.GetValueOrDefault(); } else { previousDateTimeZoneHandling = null; } if (_dateParseHandling.HasValue && reader.DateParseHandling != _dateParseHandling) { previousDateParseHandling = reader.DateParseHandling; reader.DateParseHandling = _dateParseHandling.GetValueOrDefault(); } else { previousDateParseHandling = null; } if (_floatParseHandling.HasValue && reader.FloatParseHandling != _floatParseHandling) { previousFloatParseHandling = reader.FloatParseHandling; reader.FloatParseHandling = _floatParseHandling.GetValueOrDefault(); } else { previousFloatParseHandling = null; } if (_maxDepthSet && reader.MaxDepth != _maxDepth) { previousMaxDepth = reader.MaxDepth; reader.MaxDepth = _maxDepth; } else { previousMaxDepth = null; } if (_dateFormatStringSet && reader.DateFormatString != _dateFormatString) { previousDateFormatString = reader.DateFormatString; reader.DateFormatString = _dateFormatString; } else { previousDateFormatString = null; } if (reader is JsonTextReader jsonTextReader && jsonTextReader.PropertyNameTable == null && _contractResolver is DefaultContractResolver defaultContractResolver) { jsonTextReader.PropertyNameTable = defaultContractResolver.GetNameTable(); } } private void ResetReader(JsonReader reader, CultureInfo? previousCulture, DateTimeZoneHandling? previousDateTimeZoneHandling, DateParseHandling? previousDateParseHandling, FloatParseHandling? previousFloatParseHandling, int? previousMaxDepth, string? previousDateFormatString) { if (previousCulture != null) { reader.Culture = previousCulture; } if (previousDateTimeZoneHandling.HasValue) { reader.DateTimeZoneHandling = previousDateTimeZoneHandling.GetValueOrDefault(); } if (previousDateParseHandling.HasValue) { reader.DateParseHandling = previousDateParseHandling.GetValueOrDefault(); } if (previousFloatParseHandling.HasValue) { reader.FloatParseHandling = previousFloatParseHandling.GetValueOrDefault(); } if (_maxDepthSet) { reader.MaxDepth = previousMaxDepth; } if (_dateFormatStringSet) { reader.DateFormatString = previousDateFormatString; } if (reader is JsonTextReader jsonTextReader && jsonTextReader.PropertyNameTable != null && _contractResolver is DefaultContractResolver defaultContractResolver && jsonTextReader.PropertyNameTable == defaultContractResolver.GetNameTable()) { jsonTextReader.PropertyNameTable = null; } } public void Serialize(TextWriter textWriter, object? value) { Serialize(new JsonTextWriter(textWriter), value); } public void Serialize(JsonWriter jsonWriter, object? value, Type? objectType) { SerializeInternal(jsonWriter, value, objectType); } public void Serialize(TextWriter textWriter, object? value, Type objectType) { Serialize(new JsonTextWriter(textWriter), value, objectType); } public void Serialize(JsonWriter jsonWriter, object? value) { SerializeInternal(jsonWriter, value, null); } private TraceJsonReader CreateTraceJsonReader(JsonReader reader) { TraceJsonReader traceJsonReader = new TraceJsonReader(reader); if (reader.TokenType != 0) { traceJsonReader.WriteCurrentToken(); } return traceJsonReader; } internal virtual void SerializeInternal(JsonWriter jsonWriter, object? value, Type? objectType) { ValidationUtils.ArgumentNotNull(jsonWriter, "jsonWriter"); Formatting? formatting = null; if (_formatting.HasValue && jsonWriter.Formatting != _formatting) { formatting = jsonWriter.Formatting; jsonWriter.Formatting = _formatting.GetValueOrDefault(); } DateFormatHandling? dateFormatHandling = null; if (_dateFormatHandling.HasValue && jsonWriter.DateFormatHandling != _dateFormatHandling) { dateFormatHandling = jsonWriter.DateFormatHandling; jsonWriter.DateFormatHandling = _dateFormatHandling.GetValueOrDefault(); } DateTimeZoneHandling? dateTimeZoneHandling = null; if (_dateTimeZoneHandling.HasValue && jsonWriter.DateTimeZoneHandling != _dateTimeZoneHandling) { dateTimeZoneHandling = jsonWriter.DateTimeZoneHandling; jsonWriter.DateTimeZoneHandling = _dateTimeZoneHandling.GetValueOrDefault(); } FloatFormatHandling? floatFormatHandling = null; if (_floatFormatHandling.HasValue && jsonWriter.FloatFormatHandling != _floatFormatHandling) { floatFormatHandling = jsonWriter.FloatFormatHandling; jsonWriter.FloatFormatHandling = _floatFormatHandling.GetValueOrDefault(); } StringEscapeHandling? stringEscapeHandling = null; if (_stringEscapeHandling.HasValue && jsonWriter.StringEscapeHandling != _stringEscapeHandling) { stringEscapeHandling = jsonWriter.StringEscapeHandling; jsonWriter.StringEscapeHandling = _stringEscapeHandling.GetValueOrDefault(); } CultureInfo cultureInfo = null; if (_culture != null && !_culture.Equals(jsonWriter.Culture)) { cultureInfo = jsonWriter.Culture; jsonWriter.Culture = _culture; } string dateFormatString = null; if (_dateFormatStringSet && jsonWriter.DateFormatString != _dateFormatString) { dateFormatString = jsonWriter.DateFormatString; jsonWriter.DateFormatString = _dateFormatString; } TraceJsonWriter traceJsonWriter = ((TraceWriter != null && TraceWriter.LevelFilter >= TraceLevel.Verbose) ? new TraceJsonWriter(jsonWriter) : null); JsonSerializerInternalWriter jsonSerializerInternalWriter = new JsonSerializerInternalWriter(this); jsonSerializerInternalWriter.Serialize(traceJsonWriter ?? jsonWriter, value, objectType); if (traceJsonWriter != null) { TraceWriter.Trace(TraceLevel.Verbose, traceJsonWriter.GetSerializedJsonMessage(), null); } if (formatting.HasValue) { jsonWriter.Formatting = formatting.GetValueOrDefault(); } if (dateFormatHandling.HasValue) { jsonWriter.DateFormatHandling = dateFormatHandling.GetValueOrDefault(); } if (dateTimeZoneHandling.HasValue) { jsonWriter.DateTimeZoneHandling = dateTimeZoneHandling.GetValueOrDefault(); } if (floatFormatHandling.HasValue) { jsonWriter.FloatFormatHandling = floatFormatHandling.GetValueOrDefault(); } if (stringEscapeHandling.HasValue) { jsonWriter.StringEscapeHandling = stringEscapeHandling.GetValueOrDefault(); } if (_dateFormatStringSet) { jsonWriter.DateFormatString = dateFormatString; } if (cultureInfo != null) { jsonWriter.Culture = cultureInfo; } } internal IReferenceResolver GetReferenceResolver() { if (_referenceResolver == null) { _referenceResolver = new DefaultReferenceResolver(); } return _referenceResolver; } internal JsonConverter? GetMatchingConverter(Type type) { return GetMatchingConverter(_converters, type); } internal static JsonConverter? GetMatchingConverter(IList<JsonConverter>? converters, Type objectType) { ValidationUtils.ArgumentNotNull(objectType, "objectType"); if (converters != null) { for (int i = 0; i < converters.Count; i++) { JsonConverter jsonConverter = converters[i]; if (jsonConverter.CanConvert(objectType)) { return jsonConverter; } } } return null; } internal void OnError(Newtonsoft.Json.Serialization.ErrorEventArgs e) { this.Error?.Invoke(this, e); } } public class JsonSerializerSettings { internal const ReferenceLoopHandling DefaultReferenceLoopHandling = ReferenceLoopHandling.Error; internal const MissingMemberHandling DefaultMissingMemberHandling = MissingMemberHandling.Ignore; internal const NullValueHandling DefaultNullValueHandling = NullValueHandling.Include; internal const DefaultValueHandling DefaultDefaultValueHandling = DefaultValueHandling.Include; internal const ObjectCreationHandling DefaultObjectCreationHandling = ObjectCreationHandling.Auto; internal const PreserveReferencesHandling DefaultPreserveReferencesHandling = PreserveReferencesHandling.None; internal const ConstructorHandling DefaultConstructorHandling = ConstructorHandling.Default; internal const TypeNameHandling DefaultTypeNameHandling = TypeNameHandling.None; internal const MetadataPropertyHandling DefaultMetadataPropertyHandling = MetadataPropertyHandling.Default; internal static readonly StreamingContext DefaultContext; internal const Formatting DefaultFormatting = Formatting.None; internal const DateFormatHandling DefaultDateFormatHandling = DateFormatHandling.IsoDateFormat; internal const DateTimeZoneHandling DefaultDateTimeZoneHandling = DateTimeZoneHandling.RoundtripKind; internal const DateParseHandling DefaultDateParseHandling = DateParseHandling.DateTime; internal const FloatParseHandling DefaultFloatParseHandling = FloatParseHandling.Double; internal const FloatFormatHandling DefaultFloatFormatHandling = FloatFormatHandling.String; internal const StringEscapeHandling DefaultStringEscapeHandling = StringEscapeHandling.Default; internal const TypeNameAssemblyFormatHandling DefaultTypeNameAssemblyFormatHandling = TypeNameAssemblyFormatHandling.Simple; internal static readonly CultureInfo DefaultCulture; internal const bool DefaultCheckAdditionalContent = false; internal const string DefaultDateFormatString = "yyyy'-'MM'-'dd'T'HH':'mm':'ss.FFFFFFFK"; internal const int DefaultMaxDepth = 64; internal Formatting? _formatting; internal DateFormatHandling? _dateFormatHandling; internal DateTimeZoneHandling? _dateTimeZoneHandling; internal DateParseHandling? _dateParseHandling; internal FloatFormatHandling? _floatFormatHandling; internal FloatParseHandling? _floatParseHandling; internal StringEscapeHandling? _stringEscapeHandling; internal CultureInfo? _culture; internal bool? _checkAdditionalContent; internal int? _maxDepth; internal bool _maxDepthSet; internal string? _dateFormatString; internal bool _dateFormatStringSet; internal TypeNameAssemblyFormatHandling? _typeNameAssemblyFormatHandling; internal DefaultValueHandling? _defaultValueHandling; internal PreserveReferencesHandling? _preserveReferencesHandling; internal NullValueHandling? _nullValueHandling; internal ObjectCreationHandling? _objectCreationHandling; internal MissingMemberHandling? _missingMemberHandling; internal ReferenceLoopHandling? _referenceLoopHandling; internal StreamingContext? _context; internal ConstructorHandling? _constructorHandling; internal TypeNameHandling? _typeNameHandling; internal MetadataPropertyHandling? _metadataPropertyHandling; public ReferenceLoopHandling ReferenceLoopHandling { get { return _referenceLoopHandling.GetValueOrDefault(); } set { _referenceLoopHandling = value; } } public MissingMemberHandling MissingMemberHandling { get { return _missingMemberHandling.GetValueOrDefault(); } set { _missingMemberHandling = value; } } public ObjectCreationHandling ObjectCreationHandling { get { return _objectCreationHandling.GetValueOrDefault(); } set { _objectCreationHandling = value; } } public NullValueHandling NullValueHandling { get { return _nullValueHandling.GetValueOrDefault(); } set { _nullValueHandling = value; } } public DefaultValueHandling DefaultValueHandling { get { return _defaultValueHandling.GetValueOrDefault(); } set { _defaultValueHandling = value; } } public IList<JsonConverter> Converters { get; set; } public PreserveReferencesHandling PreserveReferencesHandling { get { return _preserveReferencesHandling.GetValueOrDefault(); } set { _preserveReferencesHandling = value; } } public TypeNameHandling TypeName
Archipelago.MultiClient.Net.dll
Decompiled a week ago
The result has been truncated due to the large size, download it to view full contents!
using System; using System.Collections; using System.Collections.Concurrent; using System.Collections.Generic; using System.Collections.ObjectModel; using System.Diagnostics; using System.Globalization; using System.IO; using System.Linq; using System.Net; using System.Net.WebSockets; using System.Numerics; using System.Reflection; using System.Runtime.CompilerServices; using System.Runtime.InteropServices; using System.Runtime.Serialization; using System.Runtime.Versioning; using System.Text; using System.Threading; using System.Threading.Tasks; using Archipelago.MultiClient.Net.Colors; using Archipelago.MultiClient.Net.ConcurrentCollection; using Archipelago.MultiClient.Net.Converters; using Archipelago.MultiClient.Net.DataPackage; using Archipelago.MultiClient.Net.Enums; using Archipelago.MultiClient.Net.Exceptions; using Archipelago.MultiClient.Net.Extensions; using Archipelago.MultiClient.Net.Helpers; using Archipelago.MultiClient.Net.MessageLog.Messages; using Archipelago.MultiClient.Net.MessageLog.Parts; using Archipelago.MultiClient.Net.Models; using Archipelago.MultiClient.Net.Packets; using Newtonsoft.Json; using Newtonsoft.Json.Converters; using Newtonsoft.Json.Linq; using Newtonsoft.Json.Serialization; [assembly: CompilationRelaxations(8)] [assembly: RuntimeCompatibility(WrapNonExceptionThrows = true)] [assembly: Debuggable(DebuggableAttribute.DebuggingModes.IgnoreSymbolStoreSequencePoints)] [assembly: ComVisible(false)] [assembly: Guid("35a803ad-85ed-42e9-b1e3-c6b72096f0c1")] [assembly: InternalsVisibleTo("Archipelago.MultiClient.Net.Tests")] [assembly: InternalsVisibleTo("DynamicProxyGenAssembly2")] [assembly: TargetFramework(".NETFramework,Version=v4.5", FrameworkDisplayName = ".NET Framework 4.5")] [assembly: AssemblyCompany("Jarno Westhof, Hussein Farran, Zach Parks")] [assembly: AssemblyConfiguration("Release")] [assembly: AssemblyCopyright("Copyright © 2025")] [assembly: AssemblyDescription("A client library for use with .NET based prog-langs for interfacing with Archipelago hosts.")] [assembly: AssemblyFileVersion("6.7.0.0")] [assembly: AssemblyInformationalVersion("6.7.0+c807746b6f1774cf1afe12af819acb078b55a333")] [assembly: AssemblyProduct("Archipelago.MultiClient.Net")] [assembly: AssemblyTitle("Archipelago.MultiClient.Net")] [assembly: AssemblyMetadata("RepositoryUrl", "https://github.com/ArchipelagoMW/Archipelago.MultiClient.Net")] [assembly: AssemblyVersion("6.7.0.0")] internal interface IConcurrentHashSet<T> { bool TryAdd(T item); bool Contains(T item); void UnionWith(T[] otherSet); T[] ToArray(); ReadOnlyCollection<T> AsToReadOnlyCollection(); ReadOnlyCollection<T> AsToReadOnlyCollectionExcept(IConcurrentHashSet<T> otherSet); } public class AttemptingStringEnumConverter : StringEnumConverter { public AttemptingStringEnumConverter() { } public AttemptingStringEnumConverter(Type namingStrategyType) : base(namingStrategyType) { } public override object ReadJson(JsonReader reader, Type objectType, object existingValue, JsonSerializer serializer) { try { return ((StringEnumConverter)this).ReadJson(reader, objectType, existingValue, serializer); } catch (JsonSerializationException) { return objectType.IsValueType ? Activator.CreateInstance(objectType) : null; } } } namespace Archipelago.MultiClient.Net { [Serializable] public abstract class ArchipelagoPacketBase { [JsonIgnore] internal JObject jobject; [JsonProperty("cmd")] [JsonConverter(typeof(StringEnumConverter))] public abstract ArchipelagoPacketType PacketType { get; } public JObject ToJObject() { return jobject; } } public interface IArchipelagoSession : IArchipelagoSessionActions { IArchipelagoSocketHelper Socket { get; } IReceivedItemsHelper Items { get; } ILocationCheckHelper Locations { get; } IPlayerHelper Players { get; } IDataStorageHelper DataStorage { get; } IConnectionInfoProvider ConnectionInfo { get; } IRoomStateHelper RoomState { get; } IMessageLogHelper MessageLog { get; } IHintsHelper Hints { get; } Task<RoomInfoPacket> ConnectAsync(); Task<LoginResult> LoginAsync(string game, string name, ItemsHandlingFlags itemsHandlingFlags, Version version = null, string[] tags = null, string uuid = null, string password = null, bool requestSlotData = true); LoginResult TryConnectAndLogin(string game, string name, ItemsHandlingFlags itemsHandlingFlags, Version version = null, string[] tags = null, string uuid = null, string password = null, bool requestSlotData = true); } public class ArchipelagoSession : IArchipelagoSession, IArchipelagoSessionActions { private const int ArchipelagoConnectionTimeoutInSeconds = 4; private ConnectionInfoHelper connectionInfo; private TaskCompletionSource<LoginResult> loginResultTask = new TaskCompletionSource<LoginResult>(); private TaskCompletionSource<RoomInfoPacket> roomInfoPacketTask = new TaskCompletionSource<RoomInfoPacket>(); public IArchipelagoSocketHelper Socket { get; } public IReceivedItemsHelper Items { get; } public ILocationCheckHelper Locations { get; } public IPlayerHelper Players { get; } public IDataStorageHelper DataStorage { get; } public IConnectionInfoProvider ConnectionInfo => connectionInfo; public IRoomStateHelper RoomState { get; } public IMessageLogHelper MessageLog { get; } public IHintsHelper Hints { get; } internal ArchipelagoSession(IArchipelagoSocketHelper socket, IReceivedItemsHelper items, ILocationCheckHelper locations, IPlayerHelper players, IRoomStateHelper roomState, ConnectionInfoHelper connectionInfoHelper, IDataStorageHelper dataStorage, IMessageLogHelper messageLog, IHintsHelper createHints) { Socket = socket; Items = items; Locations = locations; Players = players; RoomState = roomState; connectionInfo = connectionInfoHelper; DataStorage = dataStorage; MessageLog = messageLog; Hints = createHints; socket.PacketReceived += Socket_PacketReceived; } private void Socket_PacketReceived(ArchipelagoPacketBase packet) { if (!(packet is ConnectedPacket) && !(packet is ConnectionRefusedPacket)) { if (packet is RoomInfoPacket result) { roomInfoPacketTask.TrySetResult(result); } } else { loginResultTask.TrySetResult(LoginResult.FromPacket(packet)); } } public Task<RoomInfoPacket> ConnectAsync() { roomInfoPacketTask = new TaskCompletionSource<RoomInfoPacket>(); Task.Factory.StartNew(delegate { try { Task task = Socket.ConnectAsync(); task.Wait(TimeSpan.FromSeconds(4.0)); if (!task.IsCompleted) { roomInfoPacketTask.TrySetCanceled(); } } catch (AggregateException) { roomInfoPacketTask.TrySetCanceled(); } }); return roomInfoPacketTask.Task; } public Task<LoginResult> LoginAsync(string game, string name, ItemsHandlingFlags itemsHandlingFlags, Version version = null, string[] tags = null, string uuid = null, string password = null, bool requestSlotData = true) { loginResultTask = new TaskCompletionSource<LoginResult>(); if (!roomInfoPacketTask.Task.IsCompleted) { loginResultTask.TrySetResult(new LoginFailure("You are not connected, run ConnectAsync() first")); return loginResultTask.Task; } connectionInfo.SetConnectionParameters(game, tags, itemsHandlingFlags, uuid); try { Socket.SendPacket(BuildConnectPacket(name, password, version, requestSlotData)); } catch (ArchipelagoSocketClosedException) { loginResultTask.TrySetResult(new LoginFailure("You are not connected, run ConnectAsync() first")); return loginResultTask.Task; } SetResultAfterTimeout(loginResultTask, 4, new LoginFailure("Connection timed out.")); return loginResultTask.Task; } private static void SetResultAfterTimeout<T>(TaskCompletionSource<T> task, int timeoutInSeconds, T result) { new CancellationTokenSource(TimeSpan.FromSeconds(timeoutInSeconds)).Token.Register(delegate { task.TrySetResult(result); }); } public LoginResult TryConnectAndLogin(string game, string name, ItemsHandlingFlags itemsHandlingFlags, Version version = null, string[] tags = null, string uuid = null, string password = null, bool requestSlotData = true) { Task<RoomInfoPacket> task = ConnectAsync(); try { task.Wait(TimeSpan.FromSeconds(4.0)); } catch (AggregateException ex) { if (ex.GetBaseException() is OperationCanceledException) { return new LoginFailure("Connection timed out."); } return new LoginFailure(ex.GetBaseException().Message); } if (!task.IsCompleted) { return new LoginFailure("Connection timed out."); } return LoginAsync(game, name, itemsHandlingFlags, version, tags, uuid, password, requestSlotData).Result; } private ConnectPacket BuildConnectPacket(string name, string password, Version version, bool requestSlotData) { return new ConnectPacket { Game = ConnectionInfo.Game, Name = name, Password = password, Tags = ConnectionInfo.Tags, Uuid = ConnectionInfo.Uuid, Version = ((version != null) ? new NetworkVersion(version) : new NetworkVersion(0, 6, 0)), ItemsHandling = ConnectionInfo.ItemsHandlingFlags, RequestSlotData = requestSlotData }; } public void Say(string message) { Socket.SendPacket(new SayPacket { Text = message }); } public void SetClientState(ArchipelagoClientState state) { Socket.SendPacket(new StatusUpdatePacket { Status = state }); } public void SetGoalAchieved() { SetClientState(ArchipelagoClientState.ClientGoal); } } public interface IArchipelagoSessionActions { void Say(string message); void SetClientState(ArchipelagoClientState state); void SetGoalAchieved(); } public static class ArchipelagoSessionFactory { public static ArchipelagoSession CreateSession(Uri uri) { ArchipelagoSocketHelper socket = new ArchipelagoSocketHelper(uri); DataPackageCache cache = new DataPackageCache(socket); ConnectionInfoHelper connectionInfoHelper = new ConnectionInfoHelper(socket); PlayerHelper playerHelper = new PlayerHelper(socket, connectionInfoHelper); ItemInfoResolver itemInfoResolver = new ItemInfoResolver(cache, connectionInfoHelper); LocationCheckHelper locationCheckHelper = new LocationCheckHelper(socket, itemInfoResolver, connectionInfoHelper, playerHelper); ReceivedItemsHelper items = new ReceivedItemsHelper(socket, locationCheckHelper, itemInfoResolver, connectionInfoHelper, playerHelper); RoomStateHelper roomStateHelper = new RoomStateHelper(socket, locationCheckHelper); DataStorageHelper dataStorageHelper = new DataStorageHelper(socket, connectionInfoHelper); MessageLogHelper messageLog = new MessageLogHelper(socket, itemInfoResolver, playerHelper, connectionInfoHelper); HintsHelper createHints = new HintsHelper(socket, playerHelper, locationCheckHelper, roomStateHelper, dataStorageHelper); return new ArchipelagoSession(socket, items, locationCheckHelper, playerHelper, roomStateHelper, connectionInfoHelper, dataStorageHelper, messageLog, createHints); } public static ArchipelagoSession CreateSession(string hostname, int port = 38281) { return CreateSession(ParseUri(hostname, port)); } internal static Uri ParseUri(string hostname, int port) { string text = hostname; if (!text.StartsWith("ws://") && !text.StartsWith("wss://")) { text = "unspecified://" + text; } if (!text.Substring(text.IndexOf("://", StringComparison.Ordinal) + 3).Contains(":")) { text += $":{port}"; } if (text.EndsWith(":")) { text += port; } return new Uri(text); } } public abstract class LoginResult { public abstract bool Successful { get; } public static LoginResult FromPacket(ArchipelagoPacketBase packet) { if (!(packet is ConnectedPacket connectedPacket)) { if (packet is ConnectionRefusedPacket connectionRefusedPacket) { return new LoginFailure(connectionRefusedPacket); } throw new ArgumentOutOfRangeException("packet", "packet is not a connection result packet"); } return new LoginSuccessful(connectedPacket); } } public class LoginSuccessful : LoginResult { public override bool Successful => true; public int Team { get; } public int Slot { get; } public Dictionary<string, object> SlotData { get; } public LoginSuccessful(ConnectedPacket connectedPacket) { Team = connectedPacket.Team; Slot = connectedPacket.Slot; SlotData = connectedPacket.SlotData; } } public class LoginFailure : LoginResult { public override bool Successful => false; public ConnectionRefusedError[] ErrorCodes { get; } public string[] Errors { get; } public LoginFailure(ConnectionRefusedPacket connectionRefusedPacket) { if (connectionRefusedPacket.Errors != null) { ErrorCodes = connectionRefusedPacket.Errors.ToArray(); Errors = ErrorCodes.Select(GetErrorMessage).ToArray(); } else { ErrorCodes = new ConnectionRefusedError[0]; Errors = new string[0]; } } public LoginFailure(string message) { ErrorCodes = new ConnectionRefusedError[0]; Errors = new string[1] { message }; } private static string GetErrorMessage(ConnectionRefusedError errorCode) { return errorCode switch { ConnectionRefusedError.InvalidSlot => "The slot name did not match any slot on the server.", ConnectionRefusedError.InvalidGame => "The slot is set to a different game on the server.", ConnectionRefusedError.SlotAlreadyTaken => "The slot already has a connection with a different uuid established.", ConnectionRefusedError.IncompatibleVersion => "The client and server version mismatch.", ConnectionRefusedError.InvalidPassword => "The password is invalid.", ConnectionRefusedError.InvalidItemsHandling => "The item handling flags provided are invalid.", _ => $"Unknown error: {errorCode}.", }; } } internal class TwoWayLookup<TA, TB> : IEnumerable<KeyValuePair<TB, TA>>, IEnumerable { private readonly Dictionary<TA, TB> aToB = new Dictionary<TA, TB>(); private readonly Dictionary<TB, TA> bToA = new Dictionary<TB, TA>(); public TA this[TB b] => bToA[b]; public TB this[TA a] => aToB[a]; public void Add(TA a, TB b) { aToB[a] = b; bToA[b] = a; } public void Add(TB b, TA a) { Add(a, b); } public bool TryGetValue(TA a, out TB b) { return aToB.TryGetValue(a, out b); } public bool TryGetValue(TB b, out TA a) { return bToA.TryGetValue(b, out a); } public IEnumerator<KeyValuePair<TB, TA>> GetEnumerator() { return bToA.GetEnumerator(); } IEnumerator IEnumerable.GetEnumerator() { return GetEnumerator(); } } } namespace Archipelago.MultiClient.Net.Packets { public class BouncedPacket : BouncePacket { public override ArchipelagoPacketType PacketType => ArchipelagoPacketType.Bounced; } public class BouncePacket : ArchipelagoPacketBase { public override ArchipelagoPacketType PacketType => ArchipelagoPacketType.Bounce; [JsonProperty("games")] public List<string> Games { get; set; } = new List<string>(); [JsonProperty("slots")] public List<int> Slots { get; set; } = new List<int>(); [JsonProperty("tags")] public List<string> Tags { get; set; } = new List<string>(); [JsonProperty("data")] public Dictionary<string, JToken> Data { get; set; } } public class ConnectedPacket : ArchipelagoPacketBase { public override ArchipelagoPacketType PacketType => ArchipelagoPacketType.Connected; [JsonProperty("team")] public int Team { get; set; } [JsonProperty("slot")] public int Slot { get; set; } [JsonProperty("players")] public NetworkPlayer[] Players { get; set; } [JsonProperty("missing_locations")] public long[] MissingChecks { get; set; } [JsonProperty("checked_locations")] public long[] LocationsChecked { get; set; } [JsonProperty("slot_data")] public Dictionary<string, object> SlotData { get; set; } [JsonProperty("slot_info")] public Dictionary<int, NetworkSlot> SlotInfo { get; set; } [JsonProperty("hint_points")] public int? HintPoints { get; set; } } public class ConnectionRefusedPacket : ArchipelagoPacketBase { public override ArchipelagoPacketType PacketType => ArchipelagoPacketType.ConnectionRefused; [JsonProperty("errors", ItemConverterType = typeof(AttemptingStringEnumConverter))] public ConnectionRefusedError[] Errors { get; set; } } public class ConnectPacket : ArchipelagoPacketBase { public override ArchipelagoPacketType PacketType => ArchipelagoPacketType.Connect; [JsonProperty("password")] public string Password { get; set; } [JsonProperty("game")] public string Game { get; set; } [JsonProperty("name")] public string Name { get; set; } [JsonProperty("uuid")] public string Uuid { get; set; } [JsonProperty("version")] public NetworkVersion Version { get; set; } [JsonProperty("tags")] public string[] Tags { get; set; } [JsonProperty("items_handling")] public ItemsHandlingFlags ItemsHandling { get; set; } [JsonProperty("slot_data")] public bool RequestSlotData { get; set; } } public class ConnectUpdatePacket : ArchipelagoPacketBase { public override ArchipelagoPacketType PacketType => ArchipelagoPacketType.ConnectUpdate; [JsonProperty("tags")] public string[] Tags { get; set; } [JsonProperty("items_handling")] public ItemsHandlingFlags? ItemsHandling { get; set; } } public class CreateHintsPacket : ArchipelagoPacketBase { public override ArchipelagoPacketType PacketType => ArchipelagoPacketType.CreateHints; [JsonProperty("locations")] public long[] Locations { get; set; } [JsonProperty("player")] public int Player { get; set; } [JsonProperty("status")] public HintStatus Status { get; set; } } public class DataPackagePacket : ArchipelagoPacketBase { public override ArchipelagoPacketType PacketType => ArchipelagoPacketType.DataPackage; [JsonProperty("data")] public Archipelago.MultiClient.Net.Models.DataPackage DataPackage { get; set; } } public class GetDataPackagePacket : ArchipelagoPacketBase { public override ArchipelagoPacketType PacketType => ArchipelagoPacketType.GetDataPackage; [JsonProperty("games")] public string[] Games { get; set; } } public class GetPacket : ArchipelagoPacketBase { public override ArchipelagoPacketType PacketType => ArchipelagoPacketType.Get; [JsonProperty("keys")] public string[] Keys { get; set; } } public class InvalidPacketPacket : ArchipelagoPacketBase { public override ArchipelagoPacketType PacketType => ArchipelagoPacketType.InvalidPacket; [JsonProperty("type")] public InvalidPacketErrorType ErrorType { get; set; } [JsonProperty("text")] public string ErrorText { get; set; } [JsonProperty("original_cmd")] public ArchipelagoPacketType OriginalCmd { get; set; } } public class LocationChecksPacket : ArchipelagoPacketBase { public override ArchipelagoPacketType PacketType => ArchipelagoPacketType.LocationChecks; [JsonProperty("locations")] public long[] Locations { get; set; } } public class LocationInfoPacket : ArchipelagoPacketBase { public override ArchipelagoPacketType PacketType => ArchipelagoPacketType.LocationInfo; [JsonProperty("locations")] public NetworkItem[] Locations { get; set; } } public class LocationScoutsPacket : ArchipelagoPacketBase { public override ArchipelagoPacketType PacketType => ArchipelagoPacketType.LocationScouts; [JsonProperty("locations")] public long[] Locations { get; set; } [JsonProperty("create_as_hint")] public int CreateAsHint { get; set; } } public class PrintJsonPacket : ArchipelagoPacketBase { public override ArchipelagoPacketType PacketType => ArchipelagoPacketType.PrintJSON; [JsonProperty("data")] public JsonMessagePart[] Data { get; set; } [JsonProperty("type")] [JsonConverter(typeof(AttemptingStringEnumConverter))] public JsonMessageType? MessageType { get; set; } } public class ItemPrintJsonPacket : PrintJsonPacket { [JsonProperty("receiving")] public int ReceivingPlayer { get; set; } [JsonProperty("item")] public NetworkItem Item { get; set; } } public class ItemCheatPrintJsonPacket : PrintJsonPacket { [JsonProperty("receiving")] public int ReceivingPlayer { get; set; } [JsonProperty("item")] public NetworkItem Item { get; set; } [JsonProperty("team")] public int Team { get; set; } } public class HintPrintJsonPacket : PrintJsonPacket { [JsonProperty("receiving")] public int ReceivingPlayer { get; set; } [JsonProperty("item")] public NetworkItem Item { get; set; } [JsonProperty("found")] public bool? Found { get; set; } } public class JoinPrintJsonPacket : PrintJsonPacket { [JsonProperty("team")] public int Team { get; set; } [JsonProperty("slot")] public int Slot { get; set; } [JsonProperty("tags")] public string[] Tags { get; set; } } public class LeavePrintJsonPacket : PrintJsonPacket { [JsonProperty("team")] public int Team { get; set; } [JsonProperty("slot")] public int Slot { get; set; } } public class ChatPrintJsonPacket : PrintJsonPacket { [JsonProperty("team")] public int Team { get; set; } [JsonProperty("slot")] public int Slot { get; set; } [JsonProperty("message")] public string Message { get; set; } } public class ServerChatPrintJsonPacket : PrintJsonPacket { [JsonProperty("message")] public string Message { get; set; } } public class TutorialPrintJsonPacket : PrintJsonPacket { } public class TagsChangedPrintJsonPacket : PrintJsonPacket { [JsonProperty("team")] public int Team { get; set; } [JsonProperty("slot")] public int Slot { get; set; } [JsonProperty("tags")] public string[] Tags { get; set; } } public class CommandResultPrintJsonPacket : PrintJsonPacket { } public class AdminCommandResultPrintJsonPacket : PrintJsonPacket { } public class GoalPrintJsonPacket : PrintJsonPacket { [JsonProperty("team")] public int Team { get; set; } [JsonProperty("slot")] public int Slot { get; set; } } public class ReleasePrintJsonPacket : PrintJsonPacket { [JsonProperty("team")] public int Team { get; set; } [JsonProperty("slot")] public int Slot { get; set; } } public class CollectPrintJsonPacket : PrintJsonPacket { [JsonProperty("team")] public int Team { get; set; } [JsonProperty("slot")] public int Slot { get; set; } } public class CountdownPrintJsonPacket : PrintJsonPacket { [JsonProperty("countdown")] public int RemainingSeconds { get; set; } } public class ReceivedItemsPacket : ArchipelagoPacketBase { public override ArchipelagoPacketType PacketType => ArchipelagoPacketType.ReceivedItems; [JsonProperty("index")] public int Index { get; set; } [JsonProperty("items")] public NetworkItem[] Items { get; set; } } public class RetrievedPacket : ArchipelagoPacketBase { public override ArchipelagoPacketType PacketType => ArchipelagoPacketType.Retrieved; [JsonProperty("keys")] public Dictionary<string, JToken> Data { get; set; } } public class RoomInfoPacket : ArchipelagoPacketBase { public override ArchipelagoPacketType PacketType => ArchipelagoPacketType.RoomInfo; [JsonProperty("version")] public NetworkVersion Version { get; set; } [JsonProperty("generator_version")] public NetworkVersion GeneratorVersion { get; set; } [JsonProperty("tags")] public string[] Tags { get; set; } [JsonProperty("password")] public bool Password { get; set; } [JsonProperty("permissions")] public Dictionary<string, Permissions> Permissions { get; set; } [JsonProperty("hint_cost")] public int HintCostPercentage { get; set; } [JsonProperty("location_check_points")] public int LocationCheckPoints { get; set; } [JsonProperty("players")] public NetworkPlayer[] Players { get; set; } [JsonProperty("games")] public string[] Games { get; set; } [JsonProperty("datapackage_checksums")] public Dictionary<string, string> DataPackageChecksums { get; set; } [JsonProperty("seed_name")] public string SeedName { get; set; } [JsonProperty("time")] public double Timestamp { get; set; } } public class RoomUpdatePacket : ArchipelagoPacketBase { public override ArchipelagoPacketType PacketType => ArchipelagoPacketType.RoomUpdate; [JsonProperty("tags")] public string[] Tags { get; set; } [JsonProperty("password")] public bool? Password { get; set; } [JsonProperty("permissions")] public Dictionary<string, Permissions> Permissions { get; set; } = new Dictionary<string, Permissions>(); [JsonProperty("hint_cost")] public int? HintCostPercentage { get; set; } [JsonProperty("location_check_points")] public int? LocationCheckPoints { get; set; } [JsonProperty("players")] public NetworkPlayer[] Players { get; set; } [JsonProperty("hint_points")] public int? HintPoints { get; set; } [JsonProperty("checked_locations")] public long[] CheckedLocations { get; set; } } public class SayPacket : ArchipelagoPacketBase { public override ArchipelagoPacketType PacketType => ArchipelagoPacketType.Say; [JsonProperty("text")] public string Text { get; set; } } public class SetNotifyPacket : ArchipelagoPacketBase { public override ArchipelagoPacketType PacketType => ArchipelagoPacketType.SetNotify; [JsonProperty("keys")] public string[] Keys { get; set; } } public class SetPacket : ArchipelagoPacketBase { public override ArchipelagoPacketType PacketType => ArchipelagoPacketType.Set; [JsonProperty("key")] public string Key { get; set; } [JsonProperty("default")] public JToken DefaultValue { get; set; } [JsonProperty("operations")] public OperationSpecification[] Operations { get; set; } [JsonProperty("want_reply")] public bool WantReply { get; set; } [JsonExtensionData] public Dictionary<string, JToken> AdditionalArguments { get; set; } [OnDeserialized] internal void OnDeserializedMethod(StreamingContext context) { AdditionalArguments?.Remove("cmd"); } } public class SetReplyPacket : SetPacket { public override ArchipelagoPacketType PacketType => ArchipelagoPacketType.SetReply; [JsonProperty("value")] public JToken Value { get; set; } [JsonProperty("original_value")] public JToken OriginalValue { get; set; } } public class StatusUpdatePacket : ArchipelagoPacketBase { public override ArchipelagoPacketType PacketType => ArchipelagoPacketType.StatusUpdate; [JsonProperty("status")] public ArchipelagoClientState Status { get; set; } } public class SyncPacket : ArchipelagoPacketBase { public override ArchipelagoPacketType PacketType => ArchipelagoPacketType.Sync; } internal class UnknownPacket : ArchipelagoPacketBase { public override ArchipelagoPacketType PacketType => ArchipelagoPacketType.Unknown; } public class UpdateHintPacket : ArchipelagoPacketBase { public override ArchipelagoPacketType PacketType => ArchipelagoPacketType.UpdateHint; [JsonProperty("player")] public int Player { get; set; } [JsonProperty("location")] public long Location { get; set; } [JsonProperty("status")] public HintStatus Status { get; set; } } } namespace Archipelago.MultiClient.Net.Models { public struct Color : IEquatable<Color> { public static Color Red = new Color(byte.MaxValue, 0, 0); public static Color Green = new Color(0, 128, 0); public static Color Yellow = new Color(byte.MaxValue, byte.MaxValue, 0); public static Color Blue = new Color(0, 0, byte.MaxValue); public static Color Magenta = new Color(byte.MaxValue, 0, byte.MaxValue); public static Color Cyan = new Color(0, byte.MaxValue, byte.MaxValue); public static Color Black = new Color(0, 0, 0); public static Color White = new Color(byte.MaxValue, byte.MaxValue, byte.MaxValue); public static Color SlateBlue = new Color(106, 90, 205); public static Color Salmon = new Color(250, 128, 114); public static Color Plum = new Color(221, 160, 221); public byte R { get; set; } public byte G { get; set; } public byte B { get; set; } public Color(byte r, byte g, byte b) { R = r; G = g; B = b; } public override bool Equals(object obj) { if (obj is Color color && R == color.R && G == color.G) { return B == color.B; } return false; } public bool Equals(Color other) { if (R == other.R && G == other.G) { return B == other.B; } return false; } public override int GetHashCode() { return ((-1520100960 * -1521134295 + R.GetHashCode()) * -1521134295 + G.GetHashCode()) * -1521134295 + B.GetHashCode(); } public static bool operator ==(Color left, Color right) { return left.Equals(right); } public static bool operator !=(Color left, Color right) { return !(left == right); } } public class DataPackage { [JsonProperty("games")] public Dictionary<string, GameData> Games { get; set; } = new Dictionary<string, GameData>(); } public class DataStorageElement { internal DataStorageElementContext Context; internal List<OperationSpecification> Operations = new List<OperationSpecification>(0); internal DataStorageHelper.DataStorageUpdatedHandler Callbacks; internal Dictionary<string, JToken> AdditionalArguments = new Dictionary<string, JToken>(0); private JToken cachedValue; public event DataStorageHelper.DataStorageUpdatedHandler OnValueChanged { add { Context.AddHandler(Context.Key, value); } remove { Context.RemoveHandler(Context.Key, value); } } internal DataStorageElement(DataStorageElementContext context) { Context = context; } internal DataStorageElement(OperationType operationType, JToken value) { Operations = new List<OperationSpecification>(1) { new OperationSpecification { OperationType = operationType, Value = value } }; } internal DataStorageElement(DataStorageElement source, OperationType operationType, JToken value) : this(source.Context) { Operations = source.Operations.ToList(); Callbacks = source.Callbacks; AdditionalArguments = source.AdditionalArguments; Operations.Add(new OperationSpecification { OperationType = operationType, Value = value }); } internal DataStorageElement(DataStorageElement source, Callback callback) : this(source.Context) { Operations = source.Operations.ToList(); Callbacks = source.Callbacks; AdditionalArguments = source.AdditionalArguments; Callbacks = (DataStorageHelper.DataStorageUpdatedHandler)Delegate.Combine(Callbacks, callback.Method); } internal DataStorageElement(DataStorageElement source, AdditionalArgument additionalArgument) : this(source.Context) { Operations = source.Operations.ToList(); Callbacks = source.Callbacks; AdditionalArguments = source.AdditionalArguments; AdditionalArguments[additionalArgument.Key] = additionalArgument.Value; } public static DataStorageElement operator ++(DataStorageElement a) { return new DataStorageElement(a, OperationType.Add, JToken.op_Implicit(1)); } public static DataStorageElement operator --(DataStorageElement a) { return new DataStorageElement(a, OperationType.Add, JToken.op_Implicit(-1)); } public static DataStorageElement operator +(DataStorageElement a, int b) { return new DataStorageElement(a, OperationType.Add, JToken.op_Implicit(b)); } public static DataStorageElement operator +(DataStorageElement a, long b) { return new DataStorageElement(a, OperationType.Add, JToken.op_Implicit(b)); } public static DataStorageElement operator +(DataStorageElement a, float b) { return new DataStorageElement(a, OperationType.Add, JToken.op_Implicit(b)); } public static DataStorageElement operator +(DataStorageElement a, double b) { return new DataStorageElement(a, OperationType.Add, JToken.op_Implicit(b)); } public static DataStorageElement operator +(DataStorageElement a, decimal b) { return new DataStorageElement(a, OperationType.Add, JToken.op_Implicit(b)); } public static DataStorageElement operator +(DataStorageElement a, string b) { return new DataStorageElement(a, OperationType.Add, JToken.op_Implicit(b)); } public static DataStorageElement operator +(DataStorageElement a, JToken b) { return new DataStorageElement(a, OperationType.Add, b); } public static DataStorageElement operator +(DataStorageElement a, IEnumerable b) { return new DataStorageElement(a, OperationType.Add, (JToken)(object)JArray.FromObject((object)b)); } public static DataStorageElement operator +(DataStorageElement a, OperationSpecification s) { return new DataStorageElement(a, s.OperationType, s.Value); } public static DataStorageElement operator +(DataStorageElement a, Callback c) { return new DataStorageElement(a, c); } public static DataStorageElement operator +(DataStorageElement a, AdditionalArgument arg) { return new DataStorageElement(a, arg); } public static DataStorageElement operator *(DataStorageElement a, int b) { return new DataStorageElement(a, OperationType.Mul, JToken.op_Implicit(b)); } public static DataStorageElement operator *(DataStorageElement a, long b) { return new DataStorageElement(a, OperationType.Mul, JToken.op_Implicit(b)); } public static DataStorageElement operator *(DataStorageElement a, float b) { return new DataStorageElement(a, OperationType.Mul, JToken.op_Implicit(b)); } public static DataStorageElement operator *(DataStorageElement a, double b) { return new DataStorageElement(a, OperationType.Mul, JToken.op_Implicit(b)); } public static DataStorageElement operator *(DataStorageElement a, decimal b) { return new DataStorageElement(a, OperationType.Mul, JToken.op_Implicit(b)); } public static DataStorageElement operator %(DataStorageElement a, int b) { return new DataStorageElement(a, OperationType.Mod, JToken.op_Implicit(b)); } public static DataStorageElement operator %(DataStorageElement a, long b) { return new DataStorageElement(a, OperationType.Mod, JToken.op_Implicit(b)); } public static DataStorageElement operator %(DataStorageElement a, float b) { return new DataStorageElement(a, OperationType.Mod, JToken.op_Implicit(b)); } public static DataStorageElement operator %(DataStorageElement a, double b) { return new DataStorageElement(a, OperationType.Mod, JToken.op_Implicit(b)); } public static DataStorageElement operator %(DataStorageElement a, decimal b) { return new DataStorageElement(a, OperationType.Mod, JToken.op_Implicit(b)); } public static DataStorageElement operator ^(DataStorageElement a, int b) { return new DataStorageElement(a, OperationType.Pow, JToken.op_Implicit(b)); } public static DataStorageElement operator ^(DataStorageElement a, long b) { return new DataStorageElement(a, OperationType.Pow, JToken.op_Implicit(b)); } public static DataStorageElement operator ^(DataStorageElement a, float b) { return new DataStorageElement(a, OperationType.Pow, JToken.op_Implicit(b)); } public static DataStorageElement operator ^(DataStorageElement a, double b) { return new DataStorageElement(a, OperationType.Pow, JToken.op_Implicit(b)); } public static DataStorageElement operator ^(DataStorageElement a, decimal b) { return new DataStorageElement(a, OperationType.Pow, JToken.op_Implicit(b)); } public static DataStorageElement operator -(DataStorageElement a, int b) { return new DataStorageElement(a, OperationType.Add, JToken.FromObject((object)(-b))); } public static DataStorageElement operator -(DataStorageElement a, long b) { return new DataStorageElement(a, OperationType.Add, JToken.FromObject((object)(-b))); } public static DataStorageElement operator -(DataStorageElement a, float b) { return new DataStorageElement(a, OperationType.Add, JToken.FromObject((object)(0f - b))); } public static DataStorageElement operator -(DataStorageElement a, double b) { return new DataStorageElement(a, OperationType.Add, JToken.FromObject((object)(0.0 - b))); } public static DataStorageElement operator -(DataStorageElement a, decimal b) { return new DataStorageElement(a, OperationType.Add, JToken.FromObject((object)(-b))); } public static DataStorageElement operator /(DataStorageElement a, int b) { return new DataStorageElement(a, OperationType.Mul, JToken.FromObject((object)(1m / (decimal)b))); } public static DataStorageElement operator /(DataStorageElement a, long b) { return new DataStorageElement(a, OperationType.Mul, JToken.FromObject((object)(1m / (decimal)b))); } public static DataStorageElement operator /(DataStorageElement a, float b) { return new DataStorageElement(a, OperationType.Mul, JToken.FromObject((object)(1.0 / (double)b))); } public static DataStorageElement operator /(DataStorageElement a, double b) { return new DataStorageElement(a, OperationType.Mul, JToken.FromObject((object)(1.0 / b))); } public static DataStorageElement operator /(DataStorageElement a, decimal b) { return new DataStorageElement(a, OperationType.Mul, JToken.FromObject((object)(1m / b))); } public static implicit operator DataStorageElement(bool b) { return new DataStorageElement(OperationType.Replace, JToken.op_Implicit(b)); } public static implicit operator DataStorageElement(int i) { return new DataStorageElement(OperationType.Replace, JToken.op_Implicit(i)); } public static implicit operator DataStorageElement(long l) { return new DataStorageElement(OperationType.Replace, JToken.op_Implicit(l)); } public static implicit operator DataStorageElement(decimal m) { return new DataStorageElement(OperationType.Replace, JToken.op_Implicit(m)); } public static implicit operator DataStorageElement(double d) { return new DataStorageElement(OperationType.Replace, JToken.op_Implicit(d)); } public static implicit operator DataStorageElement(float f) { return new DataStorageElement(OperationType.Replace, JToken.op_Implicit(f)); } public static implicit operator DataStorageElement(string s) { if (s != null) { return new DataStorageElement(OperationType.Replace, JToken.op_Implicit(s)); } return new DataStorageElement(OperationType.Replace, (JToken)(object)JValue.CreateNull()); } public static implicit operator DataStorageElement(JToken o) { return new DataStorageElement(OperationType.Replace, o); } public static implicit operator DataStorageElement(Array a) { return new DataStorageElement(OperationType.Replace, (JToken)(object)JArray.FromObject((object)a)); } public static implicit operator DataStorageElement(List<bool> l) { return new DataStorageElement(OperationType.Replace, (JToken)(object)JArray.FromObject((object)l)); } public static implicit operator DataStorageElement(List<int> l) { return new DataStorageElement(OperationType.Replace, (JToken)(object)JArray.FromObject((object)l)); } public static implicit operator DataStorageElement(List<long> l) { return new DataStorageElement(OperationType.Replace, (JToken)(object)JArray.FromObject((object)l)); } public static implicit operator DataStorageElement(List<decimal> l) { return new DataStorageElement(OperationType.Replace, (JToken)(object)JArray.FromObject((object)l)); } public static implicit operator DataStorageElement(List<double> l) { return new DataStorageElement(OperationType.Replace, (JToken)(object)JArray.FromObject((object)l)); } public static implicit operator DataStorageElement(List<float> l) { return new DataStorageElement(OperationType.Replace, (JToken)(object)JArray.FromObject((object)l)); } public static implicit operator DataStorageElement(List<string> l) { return new DataStorageElement(OperationType.Replace, (JToken)(object)JArray.FromObject((object)l)); } public static implicit operator DataStorageElement(List<object> l) { return new DataStorageElement(OperationType.Replace, (JToken)(object)JArray.FromObject((object)l)); } public static implicit operator bool(DataStorageElement e) { return RetrieveAndReturnBoolValue<bool>(e); } public static implicit operator bool?(DataStorageElement e) { return RetrieveAndReturnBoolValue<bool?>(e); } public static implicit operator int(DataStorageElement e) { return RetrieveAndReturnDecimalValue<int>(e); } public static implicit operator int?(DataStorageElement e) { return RetrieveAndReturnDecimalValue<int?>(e); } public static implicit operator long(DataStorageElement e) { return RetrieveAndReturnDecimalValue<long>(e); } public static implicit operator long?(DataStorageElement e) { return RetrieveAndReturnDecimalValue<long?>(e); } public static implicit operator float(DataStorageElement e) { return RetrieveAndReturnDecimalValue<float>(e); } public static implicit operator float?(DataStorageElement e) { return RetrieveAndReturnDecimalValue<float?>(e); } public static implicit operator double(DataStorageElement e) { return RetrieveAndReturnDecimalValue<double>(e); } public static implicit operator double?(DataStorageElement e) { return RetrieveAndReturnDecimalValue<double?>(e); } public static implicit operator decimal(DataStorageElement e) { return RetrieveAndReturnDecimalValue<decimal>(e); } public static implicit operator decimal?(DataStorageElement e) { return RetrieveAndReturnDecimalValue<decimal?>(e); } public static implicit operator string(DataStorageElement e) { return RetrieveAndReturnStringValue(e); } public static implicit operator bool[](DataStorageElement e) { return RetrieveAndReturnArrayValue<bool[]>(e); } public static implicit operator int[](DataStorageElement e) { return RetrieveAndReturnArrayValue<int[]>(e); } public static implicit operator long[](DataStorageElement e) { return RetrieveAndReturnArrayValue<long[]>(e); } public static implicit operator decimal[](DataStorageElement e) { return RetrieveAndReturnArrayValue<decimal[]>(e); } public static implicit operator double[](DataStorageElement e) { return RetrieveAndReturnArrayValue<double[]>(e); } public static implicit operator float[](DataStorageElement e) { return RetrieveAndReturnArrayValue<float[]>(e); } public static implicit operator string[](DataStorageElement e) { return RetrieveAndReturnArrayValue<string[]>(e); } public static implicit operator object[](DataStorageElement e) { return RetrieveAndReturnArrayValue<object[]>(e); } public static implicit operator List<bool>(DataStorageElement e) { return RetrieveAndReturnArrayValue<List<bool>>(e); } public static implicit operator List<int>(DataStorageElement e) { return RetrieveAndReturnArrayValue<List<int>>(e); } public static implicit operator List<long>(DataStorageElement e) { return RetrieveAndReturnArrayValue<List<long>>(e); } public static implicit operator List<decimal>(DataStorageElement e) { return RetrieveAndReturnArrayValue<List<decimal>>(e); } public static implicit operator List<double>(DataStorageElement e) { return RetrieveAndReturnArrayValue<List<double>>(e); } public static implicit operator List<float>(DataStorageElement e) { return RetrieveAndReturnArrayValue<List<float>>(e); } public static implicit operator List<string>(DataStorageElement e) { return RetrieveAndReturnArrayValue<List<string>>(e); } public static implicit operator List<object>(DataStorageElement e) { return RetrieveAndReturnArrayValue<List<object>>(e); } public static implicit operator Array(DataStorageElement e) { return RetrieveAndReturnArrayValue<Array>(e); } public static implicit operator JArray(DataStorageElement e) { return RetrieveAndReturnArrayValue<JArray>(e); } public static implicit operator JToken(DataStorageElement e) { return e.Context.GetData(e.Context.Key); } public static DataStorageElement operator +(DataStorageElement a, BigInteger b) { return new DataStorageElement(a, OperationType.Add, JToken.Parse(b.ToString())); } public static DataStorageElement operator *(DataStorageElement a, BigInteger b) { return new DataStorageElement(a, OperationType.Mul, JToken.Parse(b.ToString())); } public static DataStorageElement operator %(DataStorageElement a, BigInteger b) { return new DataStorageElement(a, OperationType.Mod, JToken.Parse(b.ToString())); } public static DataStorageElement operator ^(DataStorageElement a, BigInteger b) { return new DataStorageElement(a, OperationType.Pow, JToken.Parse(b.ToString())); } public static DataStorageElement operator -(DataStorageElement a, BigInteger b) { return new DataStorageElement(a, OperationType.Add, JToken.Parse((-b).ToString())); } public static DataStorageElement operator /(DataStorageElement a, BigInteger b) { throw new InvalidOperationException("DataStorage[Key] / BigInterger is not supported, due to loss of precision when using integer division"); } public static implicit operator DataStorageElement(BigInteger bi) { return new DataStorageElement(OperationType.Replace, JToken.Parse(bi.ToString())); } public static implicit operator BigInteger(DataStorageElement e) { return RetrieveAndReturnBigIntegerValue<BigInteger>(e); } public static implicit operator BigInteger?(DataStorageElement e) { return RetrieveAndReturnBigIntegerValue<BigInteger?>(e); } private static T RetrieveAndReturnBigIntegerValue<T>(DataStorageElement e) { if (e.cachedValue != null) { if (!BigInteger.TryParse(((object)e.cachedValue).ToString(), out var result)) { return default(T); } return (T)Convert.ChangeType(result, IsNullable<T>() ? Nullable.GetUnderlyingType(typeof(T)) : typeof(T)); } BigInteger result2; BigInteger? bigInteger = (BigInteger.TryParse(((object)e.Context.GetData(e.Context.Key)).ToString(), out result2) ? new BigInteger?(result2) : null); if (!bigInteger.HasValue && !IsNullable<T>()) { bigInteger = Activator.CreateInstance<BigInteger>(); } foreach (OperationSpecification operation in e.Operations) { if (operation.OperationType == OperationType.Floor || operation.OperationType == OperationType.Ceil) { continue; } if (!BigInteger.TryParse(((object)operation.Value).ToString(), NumberStyles.AllowLeadingSign, null, out var result3)) { throw new InvalidOperationException($"DataStorage[Key] cannot be converted to BigInterger as its value its not an integer number, value: {operation.Value}"); } switch (operation.OperationType) { case OperationType.Replace: bigInteger = result3; break; case OperationType.Add: bigInteger += result3; break; case OperationType.Mul: bigInteger *= result3; break; case OperationType.Mod: bigInteger %= result3; break; case OperationType.Pow: bigInteger = BigInteger.Pow(bigInteger.Value, (int)operation.Value); break; case OperationType.Max: { BigInteger value = result3; BigInteger? bigInteger2 = bigInteger; if (value > bigInteger2) { bigInteger = result3; } break; } case OperationType.Min: { BigInteger value = result3; BigInteger? bigInteger2 = bigInteger; if (value < bigInteger2) { bigInteger = result3; } break; } case OperationType.Xor: bigInteger ^= result3; break; case OperationType.Or: bigInteger |= result3; break; case OperationType.And: bigInteger &= result3; break; case OperationType.LeftShift: bigInteger <<= (int)operation.Value; break; case OperationType.RightShift: bigInteger >>= (int)operation.Value; break; } } e.cachedValue = JToken.Parse(bigInteger.ToString()); if (!bigInteger.HasValue) { return default(T); } return (T)Convert.ChangeType(bigInteger.Value, IsNullable<T>() ? Nullable.GetUnderlyingType(typeof(T)) : typeof(T)); } public void Initialize(JToken value) { Context.Initialize(Context.Key, value); } public void Initialize(IEnumerable value) { Context.Initialize(Context.Key, (JToken)(object)JArray.FromObject((object)value)); } public Task<T> GetAsync<T>() { return GetAsync().ContinueWith((Task<JToken> r) => r.Result.ToObject<T>()); } public Task<JToken> GetAsync() { return Context.GetAsync(Context.Key); } private static T RetrieveAndReturnArrayValue<T>(DataStorageElement e) { //IL_000e: Unknown result type (might be due to invalid IL or missing references) //IL_003d: Unknown result type (might be due to invalid IL or missing references) //IL_0073: Unknown result type (might be due to invalid IL or missing references) //IL_0079: Invalid comparison between Unknown and I4 //IL_00ab: Unknown result type (might be due to invalid IL or missing references) //IL_00b1: Invalid comparison between Unknown and I4 //IL_00d8: Unknown result type (might be due to invalid IL or missing references) if (e.cachedValue != null) { return ((JToken)(JArray)e.cachedValue).ToObject<T>(); } JArray val = (JArray)(((object)e.Context.GetData(e.Context.Key).ToObject<JArray>()) ?? ((object)new JArray())); foreach (OperationSpecification operation in e.Operations) { switch (operation.OperationType) { case OperationType.Add: if ((int)operation.Value.Type != 2) { throw new InvalidOperationException($"Cannot perform operation {OperationType.Add} on Array value, with a non Array value: {operation.Value}"); } ((JContainer)val).Merge((object)operation.Value); break; case OperationType.Replace: if ((int)operation.Value.Type != 2) { throw new InvalidOperationException($"Cannot replace Array value, with a non Array value: {operation.Value}"); } val = (JArray)(((object)operation.Value.ToObject<JArray>()) ?? ((object)new JArray())); break; default: throw new InvalidOperationException($"Cannot perform operation {operation.OperationType} on Array value"); } } e.cachedValue = (JToken)(object)val; return ((JToken)val).ToObject<T>(); } private static string RetrieveAndReturnStringValue(DataStorageElement e) { //IL_0031: Unknown result type (might be due to invalid IL or missing references) //IL_0038: Invalid comparison between Unknown and I4 //IL_009e: Unknown result type (might be due to invalid IL or missing references) //IL_00a4: Invalid comparison between Unknown and I4 if (e.cachedValue != null) { return (string)e.cachedValue; } JToken val = e.Context.GetData(e.Context.Key); string text = (((int)val.Type == 10) ? null : ((object)val).ToString()); foreach (OperationSpecification operation in e.Operations) { switch (operation.OperationType) { case OperationType.Add: text += (string)operation.Value; break; case OperationType.Mul: if ((int)operation.Value.Type != 6) { throw new InvalidOperationException($"Cannot perform operation {OperationType.Mul} on string value, with a non interger value: {operation.Value}"); } text = string.Concat(Enumerable.Repeat(text, (int)operation.Value)); break; case OperationType.Replace: text = (string)operation.Value; break; default: throw new InvalidOperationException($"Cannot perform operation {operation.OperationType} on string value"); } } if (text == null) { e.cachedValue = (JToken)(object)JValue.CreateNull(); } else { e.cachedValue = JToken.op_Implicit(text); } return (string)e.cachedValue; } private static T RetrieveAndReturnBoolValue<T>(DataStorageElement e) { if (e.cachedValue != null) { return e.cachedValue.ToObject<T>(); } bool? flag = e.Context.GetData(e.Context.Key).ToObject<bool?>() ?? ((bool?)Activator.CreateInstance(typeof(T))); foreach (OperationSpecification operation in e.Operations) { if (operation.OperationType == OperationType.Replace) { flag = (bool?)operation.Value; continue; } throw new InvalidOperationException($"Cannot perform operation {operation.OperationType} on boolean value"); } e.cachedValue = JToken.op_Implicit(flag); if (!flag.HasValue) { return default(T); } return (T)Convert.ChangeType(flag.Value, IsNullable<T>() ? Nullable.GetUnderlyingType(typeof(T)) : typeof(T)); } private static T RetrieveAndReturnDecimalValue<T>(DataStorageElement e) { if (e.cachedValue != null) { return e.cachedValue.ToObject<T>(); } decimal? num = e.Context.GetData(e.Context.Key).ToObject<decimal?>(); if (!num.HasValue && !IsNullable<T>()) { num = Activator.CreateInstance<decimal>(); } foreach (OperationSpecification operation in e.Operations) { switch (operation.OperationType) { case OperationType.Replace: num = (decimal)operation.Value; break; case OperationType.Add: num += (decimal?)(decimal)operation.Value; break; case OperationType.Mul: num *= (decimal?)(decimal)operation.Value; break; case OperationType.Mod: num %= (decimal?)(decimal)operation.Value; break; case OperationType.Pow: num = (decimal)Math.Pow((double)num.Value, (double)operation.Value); break; case OperationType.Max: num = Math.Max(num.Value, (decimal)operation.Value); break; case OperationType.Min: num = Math.Min(num.Value, (decimal)operation.Value); break; case OperationType.Xor: num = (long)num.Value ^ (long)operation.Value; break; case OperationType.Or: num = (long)num.Value | (long)operation.Value; break; case OperationType.And: num = (long)num.Value & (long)operation.Value; break; case OperationType.LeftShift: num = (long)num.Value << (int)operation.Value; break; case OperationType.RightShift: num = (long)num.Value >> (int)operation.Value; break; case OperationType.Floor: num = Math.Floor(num.Value); break; case OperationType.Ceil: num = Math.Ceiling(num.Value); break; } } e.cachedValue = JToken.op_Implicit(num); if (!num.HasValue) { return default(T); } return (T)Convert.ChangeType(num.Value, IsNullable<T>() ? Nullable.GetUnderlyingType(typeof(T)) : typeof(T)); } private static bool IsNullable<T>() { if (typeof(T).IsGenericType) { return typeof(T).GetGenericTypeDefinition() == typeof(Nullable<>).GetGenericTypeDefinition(); } return false; } public T To<T>() { if (Operations.Count != 0) { throw new InvalidOperationException("DataStorageElement.To<T>() cannot be used together with other operations on the DataStorageElement"); } return Context.GetData(Context.Key).ToObject<T>(); } public override string ToString() { return (Context?.ToString() ?? "(null)") + ", (" + ListOperations() + ")"; } private string ListOperations() { if (Operations != null) { return string.Join(", ", Operations.Select((OperationSpecification o) => o.ToString()).ToArray()); } return "none"; } } internal class DataStorageElementContext { internal string Key { get; set; } internal Action<string, DataStorageHelper.DataStorageUpdatedHandler> AddHandler { get; set; } internal Action<string, DataStorageHelper.DataStorageUpdatedHandler> RemoveHandler { get; set; } internal Func<string, JToken> GetData { get; set; } internal Action<string, JToken> Initialize { get; set; } internal Func<string, Task<JToken>> GetAsync { get; set; } public override string ToString() { return "Key: " + Key; } } public class GameData { [JsonProperty("location_name_to_id")] public Dictionary<string, long> LocationLookup { get; set; } = new Dictionary<string, long>(); [JsonProperty("item_name_to_id")] public Dictionary<string, long> ItemLookup { get; set; } = new Dictionary<string, long>(); [Obsolete("use Checksum instead")] [JsonProperty("version")] public int Version { get; set; } [JsonProperty("checksum")] public string Checksum { get; set; } } public class Hint { [JsonProperty("receiving_player")] public int ReceivingPlayer { get; set; } [JsonProperty("finding_player")] public int FindingPlayer { get; set; } [JsonProperty("item")] public long ItemId { get; set; } [JsonProperty("location")] public long LocationId { get; set; } [JsonProperty("item_flags")] public ItemFlags ItemFlags { get; set; } [JsonProperty("found")] public bool Found { get; set; } [JsonProperty("entrance")] public string Entrance { get; set; } [JsonProperty("status")] public HintStatus Status { get; set; } } public class ItemInfo { private readonly IItemInfoResolver itemInfoResolver; public long ItemId { get; } public long LocationId { get; } public PlayerInfo Player { get; } public ItemFlags Flags { get; } public string ItemName => itemInfoResolver.GetItemName(ItemId, ItemGame); public string ItemDisplayName => ItemName ?? $"Item: {ItemId}"; public string LocationName => itemInfoResolver.GetLocationName(LocationId, LocationGame); public string LocationDisplayName => LocationName ?? $"Location: {LocationId}"; public string ItemGame { get; } public string LocationGame { get; } public ItemInfo(NetworkItem item, string receiverGame, string senderGame, IItemInfoResolver itemInfoResolver, PlayerInfo player) { this.itemInfoResolver = itemInfoResolver; ItemGame = receiverGame; LocationGame = senderGame; ItemId = item.Item; LocationId = item.Location; Flags = item.Flags; Player = player; } public SerializableItemInfo ToSerializable() { return new SerializableItemInfo { IsScout = (GetType() == typeof(ScoutedItemInfo)), ItemId = ItemId, LocationId = LocationId, PlayerSlot = Player, Player = Player, Flags = Flags, ItemGame = ItemGame, ItemName = ItemName, LocationGame = LocationGame, LocationName = LocationName }; } } public class ScoutedItemInfo : ItemInfo { public new PlayerInfo Player => base.Player; public bool IsReceiverRelatedToActivePlayer { get; } public ScoutedItemInfo(NetworkItem item, string receiverGame, string senderGame, IItemInfoResolver itemInfoResolver, IPlayerHelper players, PlayerInfo player) : base(item, receiverGame, senderGame, itemInfoResolver, player) { IsReceiverRelatedToActivePlayer = (players.ActivePlayer ?? new PlayerInfo()).IsRelatedTo(player); } } public class JsonMessagePart { [JsonProperty("type")] [JsonConverter(typeof(AttemptingStringEnumConverter), new object[] { typeof(SnakeCaseNamingStrategy) })] public JsonMessagePartType? Type { get; set; } [JsonProperty("color")] [JsonConverter(typeof(AttemptingStringEnumConverter), new object[] { typeof(SnakeCaseNamingStrategy) })] public JsonMessagePartColor? Color { get; set; } [JsonProperty("text")] public string Text { get; set; } [JsonProperty("player")] public int? Player { get; set; } [JsonProperty("flags")] public ItemFlags? Flags { get; set; } [JsonProperty("hint_status")] public HintStatus? HintStatus { get; set; } } public struct NetworkItem { [JsonProperty("item")] public long Item { get; set; } [JsonProperty("location")] public long Location { get; set; } [JsonProperty("player")] public int Player { get; set; } [JsonProperty("flags")] public ItemFlags Flags { get; set; } } public struct NetworkPlayer { [JsonProperty("team")] public int Team { get; set; } [JsonProperty("slot")] public int Slot { get; set; } [JsonProperty("alias")] public string Alias { get; set; } [JsonProperty("name")] public string Name { get; set; } } public struct NetworkSlot { [JsonProperty("name")] public string Name { get; set; } [JsonProperty("game")] public string Game { get; set; } [JsonProperty("type")] public SlotType Type { get; set; } [JsonProperty("group_members")] public int[] GroupMembers { get; set; } } public class NetworkVersion { [JsonProperty("major")] public int Major { get; set; } [JsonProperty("minor")] public int Minor { get; set; } [JsonProperty("build")] public int Build { get; set; } [JsonProperty("class")] public string Class => "Version"; public NetworkVersion() { } public NetworkVersion(int major, int minor, int build) { Major = major; Minor = minor; Build = build; } public NetworkVersion(Version version) { Major = version.Major; Minor = version.Minor; Build = version.Build; } public Version ToVersion() { return new Version(Major, Minor, Build); } } public class OperationSpecification { [JsonProperty("operation")] [JsonConverter(typeof(AttemptingStringEnumConverter), new object[] { typeof(SnakeCaseNamingStrategy) })] public OperationType OperationType; [JsonProperty("value")] public JToken Value { get; set; } public override string ToString() { return $"{OperationType}: {Value}"; } } public static class Operation { public static OperationSpecification Min(int i) { return new OperationSpecification { OperationType = OperationType.Min, Value = JToken.op_Implicit(i) }; } public static OperationSpecification Min(long i) { return new OperationSpecification { OperationType = OperationType.Min, Value = JToken.op_Implicit(i) }; } public static OperationSpecification Min(float i) { return new OperationSpecification { OperationType = OperationType.Min, Value = JToken.op_Implicit(i) }; } public static OperationSpecification Min(double i) { return new OperationSpecification { OperationType = OperationType.Min, Value = JToken.op_Implicit(i) }; } public static OperationSpecification Min(decimal i) { return new OperationSpecification { OperationType = OperationType.Min, Value = JToken.op_Implicit(i) }; } public static OperationSpecification Min(JToken i) { return new OperationSpecification { OperationType = OperationType.Min, Value = i }; } public static OperationSpecification Min(BigInteger i) { return new OperationSpecification { OperationType = OperationType.Min, Value = JToken.Parse(i.ToString()) }; } public static OperationSpecification Max(int i) { return new OperationSpecification { OperationType = OperationType.Max, Value = JToken.op_Implicit(i) }; } public static OperationSpecification Max(long i) { return new OperationSpecification { OperationType = OperationType.Max, Value = JToken.op_Implicit(i) }; } public static OperationSpecification Max(float i) { return new OperationSpecification { OperationType = OperationType.Max, Value = JToken.op_Implicit(i) }; } public static OperationSpecification Max(double i) { return new OperationSpecification { OperationType = OperationType.Max, Value = JToken.op_Implicit(i) }; } public static OperationSpecification Max(decimal i) { return new OperationSpecification { OperationType = OperationType.Max, Value = JToken.op_Implicit(i) }; } public static OperationSpecification Max(JToken i) { return new OperationSpecification { OperationType = OperationType.Max, Value = i }; } public static OperationSpecification Max(BigInteger i) { return new OperationSpecification { OperationType = OperationType.Max, Value = JToken.Parse(i.ToString()) }; } public static OperationSpecification Remove(JToken value) { return new OperationSpecification { OperationType = OperationType.Remove, Value = value }; } public static OperationSpecification Pop(int value) { return new OperationSpecification { OperationType = OperationType.Pop, Value = JToken.op_Implicit(value) }; } public static OperationSpecification Pop(JToken value) { return new OperationSpecification { OperationType = OperationType.Pop, Value = value }; } public static OperationSpecification Update(IDictionary dictionary) { return new OperationSpecification { OperationType = OperationType.Update, Value = (JToken)(object)JObject.FromObject((object)dictionary) }; } public static OperationSpecification Floor() { return new OperationSpecification { OperationType = OperationType.Floor, Value = null }; } public static OperationSpecification Ceiling() { return new OperationSpecification { OperationType = OperationType.Ceil, Value = null }; } } public static class Bitwise { public static OperationSpecification Xor(long i) { return new OperationSpecification { OperationType = OperationType.Xor, Value = JToken.op_Implicit(i) }; } public static OperationSpecification Xor(BigInteger i) { return new OperationSpecification { OperationType = OperationType.Xor, Value = JToken.Parse(i.ToString()) }; } public static OperationSpecification Or(long i) { return new OperationSpecification { OperationType = OperationType.Or, Value = JToken.op_Implicit(i) }; } public static OperationSpecification Or(BigInteger i) { return new OperationSpecification { OperationType = OperationType.Or, Value = JToken.Parse(i.ToString()) }; } public static OperationSpecification And(long i) { return new OperationSpecification { OperationType = OperationType.And, Value = JToken.op_Implicit(i) }; } public static OperationSpecification And(BigInteger i) { return new OperationSpecification { OperationType = OperationType.And, Value = JToken.Parse(i.ToString()) }; } public static OperationSpecification LeftShift(long i) { return new OperationSpecification { OperationType = OperationType.LeftShift, Value = JToken.op_Implicit(i) }; } public static OperationSpecification RightShift(long i) { return new OperationSpecification { OperationType = OperationType.RightShift, Value = JToken.op_Implicit(i) }; } } public class Callback { internal DataStorageHelper.DataStorageUpdatedHandler Method { get; set; } private Callback() { } public static Callback Add(DataStorageHelper.DataStorageUpdatedHandler callback) { return new Callback { Method = callback }; } } public class AdditionalArgument { internal string Key { get; set; } internal JToken Value { get; set; } private AdditionalArgument() { } public static AdditionalArgument Add(string name, JToken value) { return new AdditionalArgument { Key = name, Value = value }; } } public class MinimalSerializableItemInfo { public long ItemId { get; set; } public long LocationId { get; set; } public int PlayerSlot { get; set; } public ItemFlags Flags { get; set; } public string ItemGame { get; set; } public string LocationGame { get; set; } } public class SerializableItemInfo : MinimalSerializableItemInfo { public bool IsScout { get; set; } public PlayerInfo Player { get; set; } public string ItemName { get; set; } public string LocationName { get; set; } [JsonIgnore] public string ItemDisplayName => ItemName ?? $"Item: {base.ItemId}"; [JsonIgnore] public string LocationDisplayName => LocationName ?? $"Location: {base.LocationId}"; public string ToJson(bool full = false) { //IL_005d: Unknown result type (might be due to invalid IL or missing references) //IL_0062: Unknown result type (might be due to invalid IL or missing references) //IL_0069: Unknown result type (might be due to invalid IL or missing references) //IL_0071: Expected O, but got Unknown MinimalSerializableItemInfo minimalSerializableItemInfo = this; if (!full) { minimalSerializableItemInfo = new MinimalSerializableItemInfo { ItemId = base.ItemId, LocationId = base.LocationId, PlayerSlot = base.PlayerSlot, Flags = base.Flags }; if (IsScout) { minimalSerializableItemInfo.ItemGame = base.ItemGame; } else { minimalSerializableItemInfo.LocationGame = base.LocationGame; } } JsonSerializerSettings val = new JsonSerializerSettings { NullValueHandling = (NullValueHandling)1, Formatting = (Formatting)0 }; return JsonConvert.SerializeObject((object)minimalSerializableItemInfo, val); } public static SerializableItemInfo FromJson(string json, IArchipelagoSession session = null) { //IL_003c: Unknown result type (might be due to invalid IL or missing references) //IL_0041: Unknown result type (might be due to invalid IL or missing references) //IL_0050: Expected O, but got Unknown ItemInfoStreamingContext additional = ((session != null) ? new ItemInfoStreamingContext { Items = session.Items, Locations = session.Locations, PlayerHelper = session.Players, ConnectionInfo = session.ConnectionInfo } : null); JsonSerializerSettings val = new JsonSerializerSettings { Context = new StreamingContext(StreamingContextStates.Other, additional) }; return JsonConvert.DeserializeObject<SerializableItemInfo>(json, val); } [OnDeserialized] internal void OnDeserializedMethod(StreamingContext streamingContext) { if (base.ItemGame == null && base.LocationGame != null) { IsScout = false; } else if (base.ItemGame != null && base.LocationGame == null) { IsScout = true; } if (streamingContext.Context is ItemInfoStreamingContext itemInfoStreamingContext) { if (IsScout && base.LocationGame == null) { base.LocationGame = itemInfoStreamingContext.ConnectionInfo.Game; } else if (!IsScout && base.ItemGame == null) { base.ItemGame = itemInfoStreamingContext.ConnectionInfo.Game; } if (ItemName == null) { ItemName = itemInfoStreamingContext.Items.GetItemName(base.ItemId, base.ItemGame); } if (LocationName == null) { LocationName = itemInfoStreamingContext.Locations.GetLocationNameFromId(base.LocationId, base.LocationGame); } if (Player == null) { Player = itemInfoStreamingContext.PlayerHelper.GetPlayerInfo(base.PlayerSlot); } } } } internal class ItemInfoStreamingContext { public IReceivedItemsHelper Items { get; set; } public ILocationCheckHelper Locations { get; set; } public IPlayerHelper PlayerHelper { get; set; } public IConnectionInfoProvider ConnectionInfo { get; set; } } } namespace Archipelago.MultiClient.Net.MessageLog.Parts { public class EntranceMessagePart : MessagePart { internal EntranceMessagePart(JsonMessagePart messagePart) : base(MessagePartType.Entrance, messagePart, Archipelago.MultiClient.Net.Colors.PaletteColor.Blue) { base.Text = messagePart.Text; } } public class HintStatusMessagePart : MessagePart { internal HintStatusMessagePart(JsonMessagePart messagePart) : base(MessagePartType.HintStatus, messagePart) { base.Text = messagePart.Text; if (messagePart.HintStatus.HasValue) { base.PaletteColor = ColorUtils.GetColor(messagePart.HintStatus.Value); } } } public class ItemMessagePart : MessagePart { public ItemFlags Flags { get; } public long ItemId { get; } public int Player { get; } internal ItemMessagePart(IPlayerHelper players, IItemInfoResolver items, JsonMessagePart part) : base(MessagePartType.Item, part) { Flags = part.Flags.GetValueOrDefault(); base.PaletteColor = ColorUtils.GetColor(Flags); Player = part.Player.GetValueOrDefault(); string game = (players.GetPlayerInfo(Player) ?? new PlayerInfo()).Game; JsonMessagePartType? type = part.Type; if (type.HasValue) { switch (type.GetValueOrDefault()) { case JsonMessagePartType.ItemId: ItemId = long.Parse(part.Text); base.Text = items.GetItemName(ItemId, game) ?? $"Item: {ItemId}"; break; case JsonMessagePartType.ItemName: ItemId = 0L; base.Text = part.Text; break; } } } } public class LocationMessagePart : MessagePart { public long LocationId { get; } public int Player { get; } internal LocationMessagePart(IPlayerHelper players, IItemInfoResolver itemInfoResolver, JsonMessagePart part) : base(MessagePartType.Location, part, Archipelago.MultiClient.Net.Colors.PaletteColor.Green) { Player = part.Player.GetValueOrDefault(); string game = (players.GetPlayerInfo(Player) ?? new PlayerInfo()).Game; JsonMessagePartType? type = part.Type; if (type.HasValue) { switch (type.GetValueOrDefault()) { case JsonMessagePartType.LocationId: LocationId = long.Parse(part.Text); base.Text = itemInfoResolver.GetLocationName(LocationId, game) ?? $"Location: {LocationId}"; break; case JsonMessagePartType.LocationName: LocationId = itemInfoResolver.GetLocationId(part.Text, game); base.Text = part.Text; break; } } } } public class MessagePart { public string Text { get; internal set; } public MessagePartType Type { get; internal set; } public Color Color => GetColor(BuiltInPalettes.Dark); public PaletteColor? PaletteColor { get; protected set; } public bool IsBackgroundColor { get; internal set; } internal MessagePart(MessagePartType type, JsonMessagePart messagePart, PaletteColor? color = null) { Type = type; Text = messagePart.Text; if (color.HasValue) { PaletteColor = color.Value; } else if (messagePart.Color.HasValue) { PaletteColor = ColorUtils.GetColor(messagePart.Color.Value); IsBackgroundColor = messagePart.Color.Value >= JsonMessagePartColor.BlackBg; } else { PaletteColor = null; } } public T GetColor<T>(Palette<T> palette) { return palette[PaletteColor]; } public override string ToString() { return Text; } } public enum MessagePartType { Text, Player, Item, Location, Entrance, HintStatus } public class PlayerMessagePart : MessagePart { public bool IsActivePlayer { get; } public int SlotId { get; } internal PlayerMessagePart(IPlayerHelper players, IConnectionInfoProvider connectionInfo, JsonMessagePart part) : base(MessagePartType.Player, part) { switch (part.Type) { case JsonMessagePartType.PlayerId: SlotId = int.Parse(part.Text); IsActivePlayer = SlotId == connectionInfo.Slot; base.Text = players.GetPlayerAlias(SlotId) ?? $"Player {SlotId}"; break; case JsonMessagePartType.PlayerName: SlotId = 0; IsActivePlayer = false; base.Text = part.Text; break; } base.PaletteColor = (IsActivePlayer ? Archipelago.MultiClient.Net.Colors.PaletteColor.Magenta : Archipelago.MultiClient.Net.Colors.PaletteColor.Yellow); } } } namespace Archipelago.MultiClient.Net.MessageLog.Messages { public class AdminCommandResultLogMessage : LogMessage { internal AdminCommandResultLogMessage(MessagePart[] parts) : base(parts) { } } public class ChatLogMessage : PlayerSpecificLogMessage { public string Message { get; } internal ChatLogMessage(MessagePart[] parts, IPlayerHelper players, int team, int slot, string message) : base(parts, players, team, slot) { Message = message; } } public class CollectLogMessage : PlayerSpecificLogMessage { internal CollectLogMessage(MessagePart[] parts, IPlayerHelper players, int team, int slot) : base(parts, players, team, slot) { } } public class CommandResultLogMessage : LogMessage { internal CommandResultLogMessage(MessagePart[] parts) : base(parts) { } } public class CountdownLogMessage : LogMessage { public int RemainingSeconds { get; } internal CountdownLogMessage(MessagePart[] parts, int remainingSeconds) : base(parts) { RemainingSeconds = remainingSeconds; } } public class GoalLogMessage : PlayerSpecificLogMessage { internal GoalLogMessage(MessagePart[] parts, IPlayerHelper players, int team, int slot) : base(parts, players, team, slot) { } } public class HintItemSendLogMessage : ItemSendLogMessage { public bool IsFound { get; } internal HintItemSendLogMessage(MessagePart[] parts, IPlayerHelper players, int receiver, int sender, NetworkItem item, bool found, IItemInfoResolver itemInfoResolver) : base(parts, players, receiver, sender, item, itemInfoResolver) { IsFound = found; } } public class ItemCheatLogMessage : ItemSendLogMessage { internal ItemCheatLogMessage(MessagePart[] parts, IPlayerHelper players, int team, int slot, NetworkItem item, IItemInfoResolver itemInfoResolver) : base(parts, players, slot, 0, item, team, itemInfoResolver) { } } public class ItemSendLogMessage : LogMessage { private PlayerInfo ActivePlayer { get; } public PlayerInfo Receiver { get; } public PlayerInfo Sender { get; } public bool IsReceiverTheActivePlayer => Receiver == ActivePlayer; public bool IsSenderTheActivePlayer => Sender == ActivePlayer; public bool IsRelatedToActivePlayer { get { if (!ActivePlayer.IsRelatedTo(Receiver)) { return ActivePlayer.IsRelatedTo(Sender); } return true; } } public ItemInfo Item { get; } internal ItemSendLogMessage(MessagePart[] parts, IPlayerHelper players, int receiver, int sender, NetworkItem item, IItemInfoResolver itemInfoResolver) : this(parts, players, receiver, sender, item, players.ActivePlayer.Team, itemInfoResolver) { } internal ItemSendLogMessage(MessagePart[] parts, IPlayerHelper players, int receiver, int sender, NetworkItem item, int team, IItemInfoResolver itemInfoResolver) : base(parts) { ActivePlayer = players.ActivePlayer ?? new PlayerInfo(); Receiver = players.GetPlayerInfo(team, receiver) ?? new PlayerInfo(); Sender = players.GetPlayerInfo(team, sender) ?? new PlayerInfo(); PlayerInfo player = players.GetPlayerInfo(team, item.Player) ?? new PlayerInfo(); Item = new ItemInfo(item, Receiver.Game, Sender.Game, itemInfoResolver, player); } } public class JoinLogMessage : PlayerSpecificLogMessage { public string[] Tags { get; } internal JoinLogMessage(MessagePart[] parts, IPlayerHelper players, int team, int slot, string[] tags) : base(parts, players, team, slot) { Tags = tags; } } public class LeaveLogMessage : PlayerSpecificLogMessage { internal LeaveLogMessage(MessagePart[] parts, IPlayerHelper players, int team, int slot) : base(parts, players, team, slot) { } } public class LogMessage { public MessagePart[] Parts { get; } internal LogMessage(MessagePart[] parts) { Parts = parts; } public override string ToString() { if (Parts.Length == 1) { return Parts[0].Text; } StringBuilder stringBuilder = new StringBuilder(); MessagePart[] parts = Parts; foreach (MessagePart messagePart in parts) { stringBuilder.Append(messagePart.Text); } return stringBuilder.ToString(); } } public abstract class PlayerSpecificLogMessage : LogMessage { private PlayerInfo ActivePlayer { get; } public PlayerInfo Player { get; } public bool IsActivePlayer => Player == ActivePlayer; public bool IsRelatedToActivePlayer => ActivePlayer.IsRelatedTo(Player); internal PlayerSpecificLogMessage(MessagePart[] parts, IPlayerHelper players, int team, int slot) : base(parts) { ActivePlayer = players.ActivePlayer ?? new PlayerInfo(); Player = players.GetPlayerInfo(team, slot) ?? new PlayerInfo(); } } public class ReleaseLogMessage : PlayerSpecificLogMessage { internal ReleaseLogMessage(MessagePart[] parts, IPlayerHelper players, int team, int slot) : base(parts, players, team, slot) { } } public class ServerChatLogMessage : LogMessage { public string Message { get; } internal ServerChatLogMessage(MessagePart[] parts, string message) : base(parts) { Message = message; } } public class TagsChangedLogMessage : PlayerSpecificLogMessage { public string[] Tags { get; } internal TagsChangedLogMessage(MessagePart[] parts, IPlayerHelper players, int team, int slot, string[] tags) : base(parts, players, team, slot) { Tags = tags; } } public class TutorialLogMessage : LogMessage { internal TutorialLogMessage(MessagePart[] parts) : base(parts) { } } } namespace Archipelago.MultiClient.Net.Helpers { public class ArchipelagoSocketHelper : BaseArchipelagoSocketHelper<ClientWebSocket>, IArchipelagoSocketHelper { public Uri Uri { get; } internal ArchipelagoSocketHelper(Uri hostUri) : base(CreateWebSocket(), 1024) { Uri = hostUri; SecurityProtocolType securityProtocolType = SecurityProtocolType.Tls13; ServicePointManager.SecurityProtocol = SecurityProtocolType.Tls12 | securityProtocolType; } private static ClientWebSocket CreateWebSocket() { return new ClientWebSocket(); } public async Task ConnectAsync() { await ConnectToProvidedUri(Uri); StartPolling(); } private async Task ConnectToProvidedUri(Uri uri) { if (uri.Scheme != "unspecified") { try { await Socket.ConnectAsync(uri, CancellationToken.None); return; } catch (Exception e) { OnError(e); throw; } } List<Exception> errors = new List<Exception>(0); try { await Socket.ConnectAsync(uri.AsWss(), CancellationToken.None); if (Socket.State == WebSocketState.Open) { return; } } catch (Exception item) { errors.Add(item); Socket = CreateWebSocket(); } try { await Socket.ConnectAsync(uri.AsWs(), CancellationToken.None); } catch (Exception item2) { errors.Add(item2); OnError(new AggregateException(errors)); throw; } } } public class BaseArchipelagoSocketHelper<T> where T : WebSocket { private static readonly ArchipelagoPacketConverter Converter = new ArchipelagoPacketConverter(); private readonly BlockingCollection<Tuple<ArchipelagoPacketBase, TaskCompletionSource<bool>>> sendQueue = new BlockingCollection<Tuple<ArchipelagoPacketBase, TaskCompletionSource<bool>>>(); internal T Socket; private readonly int bufferSize; public bool Connected { get { if (Socket.State != WebSocketState.Open) { return Socket.State == WebSocketState.CloseReceived; } return true; } } public event ArchipelagoSocketHelperDelagates.PacketReceivedHandler PacketReceived; public event ArchipelagoSocketHelperDelagates.PacketsSentHandler PacketsSent; public event ArchipelagoSocketHelperDelagates.ErrorReceivedHandler ErrorReceived; public event ArchipelagoSocketHelperDelagates.SocketClosedHandler SocketClosed; public event ArchipelagoSocketHelperDelagates.SocketOpenedHandler SocketOpened; internal BaseArchipelagoSocketHelper(T socket, int bufferSize = 1024) { Socket = socket; this.bufferSize = bufferSize; } internal void StartPolling() { if (this.SocketOpened != null) { this.SocketOpened(); } Task.Run((Func<Task?>)PollingLoop); Task.Run((Func<Task?>)SendLoop); } private async Task PollingLoop() { byte[] buffer = new byte[bufferSize]; while (Socket.State == WebSocketState.Open) { string message = null; try { message = await ReadMessageAsync(buffer); } catch (Exception e) { OnError(e); } OnMessageReceived(message); } } private async Task SendLoop() { while (Socket.State == WebSocketState.Open) { try { await HandleSendBuffer(); } catch (Exception e) { OnError(e); } await Task.Delay(20); } } private async Task<string> ReadMessageAsync(byte[] buffer) { using MemoryStream readStream = new MemoryStream(buffer.Length); WebSocketReceiveResult result; do { result = await Socket.ReceiveAsync(new ArraySegment<byte>(buffer), CancellationToken.None); if (result.MessageType == WebSocketMessageType.Close) { try { await Socket.CloseAsync(WebSocketCloseStatus.NormalClosure, string.Empty, CancellationToken.None); } catch { } OnSocketClosed(); } else { readStream.Write(buffer, 0, result.Count); } } while (!result.EndOfMessage); return Encoding.UTF8.GetString(readStream.ToArray()); } public async Task DisconnectAsync() { await Socket.CloseAsync(WebSocketCloseStatus.NormalClosure, "Closure requested by client", CancellationToken.None); OnSocketClosed(); } public void SendPacket(ArchipelagoPacketBase packet) { SendMultiplePackets(new List<ArchipelagoPacketBase> { packet }); } public void SendMultiplePackets(List<ArchipelagoPacketBase> packets) { SendMultiplePackets(packets.ToArray()); } public void SendMultiplePackets(params ArchipelagoPacketBase[] packets) { SendMultiplePacketsAsync(packets).Wait(); } public Task SendPacketAsync(ArchipelagoPacketBase packet) { return SendMultiplePacketsAsync(new List<ArchipelagoPacketBase> { packet }); } public Task SendMultiplePacketsAsync(List<ArchipelagoPacketBase> packets) { return SendMultiplePacketsAsync(packets.ToArray()); } public Task SendMultiplePacketsAsync(params ArchipelagoPacketBase[] packets) { TaskCompletionSource<bool> taskCompletionSource = new TaskCompletionSource<bool>(); foreach (ArchipelagoPacketBase item in packets) { sendQueue.Add(new Tuple<ArchipelagoPacketBase, TaskCompletionSource<bool>>(item, taskCompletionSource)); } return taskCompletionSource.Task; } private async Task HandleSendBuffer() { List<ArchipelagoPacketBase> list = new List<ArchipelagoPacketBase>(); List<TaskCompletionSource<bool>> tasks = new List<TaskCompletionSource<bool>>(); Tuple<ArchipelagoPacketBase, TaskCompletionSource<bool>> tuple = sendQueue.Take(); list.Add(tuple.Item1); tasks.Add(tuple.Item2); Tuple<ArchipelagoPacketBase, TaskCompletionSource<bool>> item; while (sendQueue.TryTake(out item)) { list.Add(item.Item1); tasks.Add(item.Item2); } if (!list.Any()) { return; } if (Socket.State != WebSocketState.Open) { throw new ArchipelagoSocketClosedException(); } ArchipelagoPacketBase[] packets = list.ToArray(); string s = JsonConvert.SerializeObject((object)packets); byte[] messageBuffer = Encoding.UTF8.GetBytes(s); int messagesCount = (int)Math.Ceiling((double)messageBuffer.Length / (double)bufferSize); for (int i = 0; i < messagesCount; i++) { int num = bufferSize * i; int num2 = bufferSize; bool endOfMessage = i + 1 == messagesCount; if (num2 * (i + 1) > messageBuffer.Length) { num2 = messageBuffer.Length - num; } await Socket.SendAsync(new ArraySegment<byte>(messageBuffer, num, num2), WebSocketMessageType.Text, endOfMessage, CancellationToken.None); } foreach (TaskCompletionSource<bool> item2 in tasks) { item2.TrySetResult(result: true); } OnPacketSend(packets); } private void OnPacketSend(ArchipelagoPacketBase[] packets) { try { if (this.PacketsSent != null) { this.PacketsSent(packets); } } catch (Exception e) { OnError(e); } } private void OnSocketClosed() { try { if (this.SocketClosed != null) { this.SocketClosed(""); } } catch (Exception e) { OnError(e); } } private void OnMessageReceived(string message) { try { if (string.IsNullOrEmpty(message) || this.PacketReceived == null) { return; } List<ArchipelagoPacketBase> list = null; try { list = JsonConvert.DeserializeObject<List<ArchipelagoPacketBase>>(message, (JsonConverter[])(object)new JsonConverter[1] { Converter }); } catch (Exception e) { OnError(e); } if (list == null) { return; } foreach (ArchipelagoPacketBase item in list) { this.PacketReceived(item); } } catch (Exception e2) { OnError(e2); } } protected void OnError(Exception e) { try { if (this.ErrorReceived != null) { this.ErrorReceived(e, e.Message); } } catch (Exception ex) { Console.Out.WriteLine("Error occured during reporting of errorOuter Errror: " + e.Message + " " + e.StackTrace + "Inner Errror: " + ex.Message + " " + ex.StackTrace); } } } public interface IConnectionInfoProvider { string Game { get; } int Team { get; } int Slot { get; } string[] Tags { get; } ItemsHandlingFlags ItemsHandlingFlags { get; } string Uuid { get; } void UpdateConnectionOptions(string[] tags); void UpdateConnectionOptions(ItemsHandlingFlags itemsHandlingFlags); void UpdateConnectionOptions(string[] tags, ItemsHandlingFlags itemsHandlingFlags); } public class ConnectionInfoHelper : IConnectionInfoProvider { private readonly IArchipelagoSocketHelper socket; public string Game { get; private set; } public int Team { get; private set; } public int Slot { get; private set; } public string[] Tags { get; internal set; } public ItemsHandlingFlags ItemsHandlingFlags { get; internal set; } public string Uuid { get; private set; } internal ConnectionInfoHelper(IArchipelagoSocketHelper socket) { this.socket = socket; Reset(); socket.PacketReceived += PacketReceived; } private void PacketReceived(ArchipelagoPacketBase packet) { if (!(packet is ConnectedPacket connectedPacket)) { if (packet is ConnectionRefusedPacket) { Reset(); } return; } Team = connectedPacket.Team; Slot = connectedPacket.Slot; if (connectedPacket.SlotInfo != null && connectedPacket.SlotInfo.ContainsKey(Slot)) { Game = connectedPacket.SlotInfo[Slot].Game; } } internal void SetConnectionParameters(string game, string[] tags, ItemsHandlingFlags itemsHandlingFlags, string uuid) { Game = game; Tags = tags ?? new string[0]; ItemsHandlingFlags = itemsHandlingFlags; Uuid = uuid ?? Guid.NewGuid().ToString(); } private void Reset() { Game = null; Team = -1; Slot = -1; Tags = new string[0]; ItemsHandlingFlags = ItemsHandlingFlags.NoItems; Uuid = null; } public void UpdateConnectionOptions(string[] tags) { UpdateConnectionOptions(tags, ItemsHandlingFlags); } public void UpdateConnectionOptions(ItemsHandlingFlags itemsHandlingFlags) { UpdateConnectionOptions(Tags, ItemsHandlingFlags); } public void UpdateConnectionOptions(string[] tags, ItemsHandlingFlags itemsHandlingFlags) { SetConnectionParameters(Game, tags, itemsHandlingFlags, Uuid); socket.SendPacket(new ConnectUpdatePacket { Tags = Tags, ItemsHandling = ItemsHandlingFlags }); } } public interface IDataStorageHelper : IDataStorageWrapper { DataStorageElement this[Scope scope, string key] { get; set; } DataStorageElement this[string key] { get; set; } } public class DataStorageHelper : IDataStorageHelper, IDataStorageWrapper { public delegate void DataStorageUpdatedHandler(JToken originalValue, JToken newValue, Dictionary<string, JToken> additionalArguments); private readonly Dictionary<string, DataStorageUpdatedHandler> onValueChangedEventHandlers = new Dictionary<string, DataStorageUpdatedHandler>(); private readonly Dictionary<Guid, DataStorageUpdatedHandler> operationSpecificCallbacks = new Dictionary<Guid, DataStorageUpdatedHandler>(); private readonly Dictionary<string, TaskCompletionSource<JToken>> asyncRetrievalTasks = new Dictionary<string, TaskCompletionSource<JToken>>(); private readonly IArchipelagoSocketHelper socket; private readonly IConnectionInfoProvider connectionInfoProvider; public DataStorageElement this[Scope scope, string key] { get { return this[AddScope(scope, key)]; } set { this[AddScope(scope, key)] = value; } } public DataStorageElement this[string key] { get { return new DataStorageElement(GetContextForKey(key)); } set { SetValue(key, value); } } internal DataStorageHelper(IArchipelagoSocketHelper socket, IConnectionInfoProvider connectionInfoProvider) { this.socket = socket; this.connectionInfoProvider = connectionInfoProvider; socket.PacketReceived += OnPacketReceived; } private void OnPacketReceived(ArchipelagoPacketBase packet) { //IL_00b3: Unknown result type (might be due to invalid IL or missing references) //IL_00b9: Invalid comparison between Unknown and I4 if (!(packet is RetrievedPacket retrievedPacket)) { if (packet is SetReplyPacket setReplyPacket) { if (setReplyPacket.AdditionalArguments != null && setReplyPacket.AdditionalArguments.ContainsKey("Reference") && (int)setReplyPacket.AdditionalArguments["Reference"].Type == 8 && ((string)setReplyPacket.AdditionalArguments["Reference"]).TryParseNGuid(out var g) && operationSpecificCallbacks.TryGetValue(g, out var value)) { value(setReplyPacket.OriginalValue, setReplyPacket.Value, setReplyPacket.AdditionalArguments); operationSpecificCallbacks.Remove(g); } if (onValueChangedEventHandlers.TryGetValue(setReplyPacket.Key, out var value2)) { value2(setReplyPacket.OriginalValue, setReplyPacket.Value, setReplyPacket.AdditionalArguments); } } return; } foreach (KeyValuePair<string, JToken> datum in retrievedPacket.Data) { if (asyncRetrievalTasks.TryGetValue(datum.Key, out var value3)) { value3.TrySetResult(datum.Value); asyncRetrievalTasks.Remove(datum.Key); } } } private Task<JToken> GetAsync(string key) { if (asyncRetrievalTasks.TryGetValue(key, out var value)) { return value.Task; } TaskCompletionSource<JToken> taskCompletionSource = new TaskCompletionSource<JToken>(); asyncRetrievalTasks[key] = taskCompletionSource; socket.SendPacketAsync(new GetPacket { Keys = new string[1] { key } }); return taskCompletionSource.Task; } private void Initialize(string key, JToken value) { socket.SendPacketAsync(new SetPacket { Key = key, DefaultValue = value, Operations = new OperationSpecification[1] { new OperationSpecification { OperationType = OperationType.Default } } }); } private JToken GetValue(string key) { Task<JToken> async = GetAsync(key); if (!async.Wait(TimeSpan.FromSeconds(2.0))) { throw new TimeoutException("Timed out retrieving data for key `" + key + "`. This may be due to an attempt to retrieve a value from the DataStorageHelper in a synchronous fashion from within a PacketReceived handler. When using the DataStorageHelper from within code which runs on the websocket thread then use the asynchronous getters. Ex: `DataStorageHelper[\"" + key + "\"].GetAsync().ContinueWith(x => {});`Be aware that DataStorageHelper calls tend to cause packet responses, so making a call from within a PacketReceived handler may cause an infinite loop."); } return async.Result; } private void SetValue(string key, DataStorageElement e) { if (key.StartsWith("_read_")) { throw new InvalidOperationException("DataStorage write operation on readonly key '" + key + "' is not allowed"); } if (e == null) { e = new DataStorageElement(OperationType.Replace, (JToken)(object)JValue.CreateNull()); } if (e.Context == null) { e.Context = GetContextForKey(key); } else if (e.Context.Key != key) { e.Operations.Insert(0, new OperationSpecification { OperationType = OperationType.Replace, Value = GetValue(e.Context.Key) }); } Dictionary<string, JToken> dictionary = e.AdditionalArguments ?? new Dictionary<string, JToken>(0); if (e.Callbacks != null) { Guid key2 = Guid.NewGuid(); operationSpecificCallbacks[key2] = e.Callbacks; dictionary["Reference"] = JToken.op_Implicit(key2.ToString("N")); socket.SendPacketAsync(new SetPacket { Key = key, Operations = e.Operations.ToArray(), WantReply = true, AdditionalArguments = dictionary }); } else { socket.SendPacketAsync(new SetPacket { Key = key, Operations = e.Operations.ToArray(), AdditionalArguments = dictionary }); } } private DataStorageElementContext GetContextForKey(string key) { return new DataStorageElementContext { Key = key, GetData = GetValue, GetAsync = GetAsync, Initialize = Initialize, AddHandler = AddHandler, RemoveHandler = RemoveHandler }; } private void AddHandler(string key, DataStorageUpdatedHandler handler) { if (onValueChangedEventHandlers.ContainsKey(key)) { Dictionary<string, DataStorageUpdatedHandler> dictionary = onValueChangedEventHandlers; dictionary[key] = (DataStorageUpdatedHandler)Delegate.Combine(dictionary[key], handler); } else { onValueChangedEventHandlers[key] = handler; } socket.SendPacketAsync(new SetNotifyPacket { Keys = new string[1] { key } }); } private void RemoveHandler(string key, DataStorageUpdatedHandler handler) { if (onValueChangedEventHandlers.ContainsKey(key)) { Dictionary<string, DataStorageUpdatedHandler> dictionary = onValueChangedEventHandlers; dictionary[key] = (DataStorageUpdatedHandler)Delegate.Remove(dictionary[key], handler); if (onValueChangedEventHandlers[key] == null) { onValueChangedEventHandlers.Remove(key); } } } private string AddScope(Scope scope, string key) { return scope switch { Scope.Global => key, Scope.Game => $"{scope}:{connectionInfoProvider.Game}:{key}", Scope.Team => $"{scope}:{connectionInfoProvider.Team}:{key}", Scope.Slot => $"{scope}:{connectionInfoProvider.Slot}:{key}", Scope.ReadOnly => "_read_" + key, _ => throw new ArgumentOutOfRangeException("scope", scope, "Invalid scope for key " + key), }; } private DataStorageElement GetHintsElement(int? slot = null, int? team = null) { return this[Scope.ReadOnly, $"hints_{team ?? connectionInfoProvider.Team}_{slot ?? connectionInfoProvider.Slot}"]; } private DataStorageElement GetSlotDataElement(int? slot = null) { return this[Scope.ReadOnly, $"slot_data_{slot ?? connectionInfoProvider.Slot}"]; } private DataStorageElement GetItemNameGroupsElement(string game = null) { return this[Scope.ReadOnly, "item_name_groups_" + (game ?? connectionInfoProvider.Game)]; } private DataStorageElement GetLocationNameGroupsElement(string game = null) { return this[Scope.ReadOnly, "location_name_groups_" + (game ?? connectionInfoProvider.Game)]; } private DataStorageElement GetClientStatusElement(int? slot = null, int? team = null) { return this[Scope.ReadOnly, $"client_status_{team ?? connectionInfoProvider.Team}_{slot ?? connectionInfoProvider.Slot}"]; } private DataStorageElement GetRaceModeElement() { return this[Scope.ReadOnly, "race_mode"]; } public Hint[] GetHints(int? slot = null, int? team = null) { return GetHintsElement(slot, team).To<Hint[]>(); } public Task<Hint[]> GetHintsAsync(int? slot = null, int? team = null) { return GetHintsElement(slot, team).GetAsync<Hint[]>(); } public void TrackHints(Action<Hint[]> onHintsUpdated, bool retrieveCurrentlyUnlockedHints = true, int? slot = null, int? team = null) { GetHintsElement(slot, team).OnValueChanged += delegate(JToken _, JToken newValue, Dictionary<string, JToken> x) { onHintsUpdated(newValue.ToObject<Hint[]>()); }; if (retrieveCurrentlyUnlockedHints) { GetHintsAsync(slot, team).ContinueWith(delegate(Task<Hint[]> t) { onHintsUpdated(t.Result); }); } } public Dictionary<string, object> GetSlotData(int? slot = null) { return GetSlotData<Dictionary<string, object>>(slot); } public T GetSlotData<T>(int? slot = null) where T : class { return GetSlotDataElement(slot).To<T>(); } public Task<Dictionary<string, object>> GetSlotDataAsync(int? slot = null) { return GetSlotDataAsync<Dictionary<string, object>>(slot); } public Task<T> GetSlotDataAsync<T>(int? slot = null) where T : class { return GetSlotDataElement(slot).GetAsync<T>(); } public Dictionary<string, string[]> GetItemNameGroups(string game = null) { return GetItemNameGroupsElement(game).To<Dictionary<string, string[]>>(); } public Task<Dictionary<string, string[]>> GetItemNameGroupsAsync(string game = null) { return GetItemNameGroupsElement(game).GetAsync<Dictionary<string, string[]>>(); } public Dictionary<string, string[]> GetLocationNameGroups(string game = null) { return GetLocationNameGroupsElement(game).To<Dictionary<string, string[]>>(); } public Task<Dictionary<string, string[]>> GetLocationNameGroupsAsync(string game = null) { return GetLocationNameGroupsElement(game).GetAsync<Dictionary<string, string[]>>(); } public ArchipelagoClientState GetClientStatus(int? slot = null, int? team = null) { return GetClientStatusElement(slot, team).To<ArchipelagoClientState?>().GetValueOrDefault(); } public Task<ArchipelagoClientState> GetClientStatusAsync(int? slot = null, int? team = null) { return GetClientStatusElement(slot, team).GetAsync<ArchipelagoClientState?>().ContinueWith((Task<ArchipelagoClientState?> r) => r.Result.GetValueOrDefault()); } public void TrackClientStatus(Action<ArchipelagoClientState> onStatusUpdated, bool retrieveCurrentClientStatus = true, int? slot = null, int? team = null) { Get
