Start sending and receiving items

1 files changed, 109 insertions, 1 deletions

@@ -1,12 +1,21 @@
-using Archipelago.MultiClient.Net;
+using AnodyneSharp.Entities;
+using AnodyneSharp.Registry;
+using Archipelago.MultiClient.Net;
 using Archipelago.MultiClient.Net.Enums;
+using Archipelago.MultiClient.Net.Models;
+using Archipelago.MultiClient.Net.Packets;
 using System;
+using System.Collections.Generic;
+using System.Linq;
 
 namespace AnodyneArchipelago
 {
     internal class ArchipelagoManager
     {
         private static ArchipelagoSession _session;
+        private static int _itemIndex = 0;
+
+        private static readonly Queue<NetworkItem> _itemsToCollect = new();
 
         public static void Connect(string url, string slotName, string password)
         {
@@ -38,6 +47,105 @@ namespace AnodyneArchipelago
 
                 return;
             }
+
+            _itemIndex = 0;
+            _itemsToCollect.Clear();
+        }
+
+        public static void Disconnect()
+        {
+            if (_session == null)
+            {
+                return;
+            }
+
+            _session.Socket.DisconnectAsync();
+            _session = null;
+        }
+
+        public static void SendLocation(string location)
+        {
+            if (_session == null)
+            {
+                Plugin.Instance.Log.LogError("Attempted to send location while disconnected");
+                return;
+            }
+
+            _session.Locations.CompleteLocationChecks(_session.Locations.GetLocationIdFromName("Anodyne", location));
+        }
+
+        public static void Update()
+        {
+            if (_session == null)
+            {
+                // We're not connected.
+                return;
+            }
+
+            if (_session.Items.AllItemsReceived.Count > _itemIndex)
+            {
+                for (int i = _itemIndex; i < _session.Items.AllItemsReceived.Count; i++)
+                {
+                    string itemKey = $"ArchipelagoItem-{i}";
+                    if (GlobalState.events.GetEvent(itemKey) != 0)
+                    {
+                        continue;
+                    }
+
+                    GlobalState.events.SetEvent(itemKey, 1);
+
+                    NetworkItem item = _session.Items.AllItemsReceived[i];
+                    _itemsToCollect.Enqueue(item);
+                }
+            }
+
+            if (_itemsToCollect.Count > 0)
+            {
+                NetworkItem item = _itemsToCollect.Dequeue();
+                HandleItem(item);
+            }
+        }
+
+        private static string GetMapNameForDungeon(string dungeon)
+        {
+            switch (dungeon)
+            {
+                case "Temple of the Seeing One": return "BEDROOM";
+                case "Apartment": return "APARTMENT";
+                case "Mountain Cavern": return "CROWD";
+                case "Hotel": return "HOTEL";
+                case "Red Grotto": return "REDCAVE";
+                case "Circus": return "CIRCUS";
+                default: return "STREET";
+            }
+        }
+
+        private static void HandleItem(NetworkItem item)
+        {
+            string itemName = _session.Items.GetItemName(item.Item);
+
+            if (itemName.StartsWith("Small Key"))
+            {
+                string dungeonName = itemName.Substring(11);
+                dungeonName = dungeonName.Substring(0, dungeonName.Length - 1);
+
+                string mapName = GetMapNameForDungeon(dungeonName);
+                GlobalState.inventory.AddMapKey(mapName, 1);
+            } else if (itemName == "Green Key")
+            {
+                GlobalState.inventory.BigKeyStatus[0] = true;
+            }
+            else if (itemName == "Blue Key")
+            {
+                GlobalState.inventory.BigKeyStatus[2] = true;
+            }
+            else if (itemName == "Red Key")
+            {
+                GlobalState.inventory.BigKeyStatus[1] = true;
+            } else if (itemName == "Jump Shoes")
+            {
+                GlobalState.inventory.CanJump = true;
+            }
         }
     }
 }