Stardew_Valley_Mods/GeneralMods/ModdedUtilitiesNetworking/Class1.cs

using Galaxy.Api;
using ModdedUtilitiesNetworking.Framework;
using ModdedUtilitiesNetworking.Framework.Clients;
using ModdedUtilitiesNetworking.Framework.Delegates;
using ModdedUtilitiesNetworking.Framework.Extentions;
using ModdedUtilitiesNetworking.Framework.Extentions.StrardewValleyExtentions;
using ModdedUtilitiesNetworking.Framework.Servers;
using StardewModdingAPI;
using StardewValley;
using StardewValley.Network;
using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Reflection;
using System.Runtime.Serialization.Formatters.Binary;
using System.Text;
using System.Threading.Tasks;
using ModdedUtilitiesNetworking.Framework.Features;
using static ModdedUtilitiesNetworking.Framework.Delegates.DelegateInfo;

namespace ModdedUtilitiesNetworking
{
    /*
     *When adding a new supported type... 
     * 1.Make reader and writer overload functions
     * 2.Add supported type to objectTypes list using addObjectType or addCustomObjectType
     * 
     * When adding a new supported function...
     * 1.Make sure the supported type is handled first!
     * 2.Add in a function that will accept the object data and parse the data to do what you want.
     * 3. Add funtion to possibleVoidFunctions
     * 
     * 
     * TODO:
     *  Make CustomGalaxyClient work.
     */
    public class ModCore : Mod
    {
        public static CustomMultiplayer multiplayer;

        public static IModHelper helper;
        public static IMonitor monitor;
        public static IManifest manifest;
        bool multiplayerSet;

        public static Dictionary<string, ReadWriter> objectTypes = new Dictionary<string, ReadWriter>();
        public static Dictionary<string, voidFunc> possibleVoidFunctions = new Dictionary<string, voidFunc>();

        public static string displayMessageString = "Omegasis.ModdedUtilitiesNetworking.ModCore.displayMessage";

        public override void Entry(IModHelper helper)
        {
            helper = Helper;
            monitor = Monitor;
            manifest = ModManifest;

            StardewModdingAPI.Events.SaveEvents.AfterLoad += SaveEvents_AfterLoad;
            StardewModdingAPI.Events.ControlEvents.KeyPressed += ControlEvents_KeyPressed;
            multiplayerSet = false;
            multiplayer = new CustomMultiplayer();

            possibleVoidFunctions.Add(displayMessageString, new voidFunc(displayMessage));
            possibleVoidFunctions.Add(Framework.Features.Stardew.MessageFeatures.FSTRING_SendHUDMessageWithIcon, Framework.Features.Stardew.MessageFeatures.SendHUDMessageWithIcon);
            initializeBasicTypes();

            
        }


        private void ControlEvents_KeyPressed(object sender, StardewModdingAPI.Events.EventArgsKeyPressed e)
        {
            
            /*
                if (e.KeyPressed==Microsoft.Xna.Framework.Input.Keys.K)
                {
                    //multiplayer.sendMessage(Framework.Features.Stardew.MessageFeatures.FSTRING_SendHUDMessageWithIcon, MessagesExtentions.HUDMessageIconIdentifier, new HUDMessage("My love is like fire",1),Framework.Enums.MessageTypes.messageTypes.SendToSpecific,Game1.otherFarmers.ElementAt(0).Value);
                }
            */
        }

        /// <summary>
        /// Don't change this. Sets appropriate clients and servers once the game has loaded.
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void SaveEvents_AfterLoad(object sender, EventArgs e)
        {
            if (Game1.server != null && multiplayerSet == false)
            {
                List<Server> servers = new List<Server>();
                if (Game1.server != null)
                {
                    ModCore.monitor.Log(Game1.server.GetType().ToString());
                    //var property = ModCore.helper.Reflection.GetProperty<List<Server>>(Game1.server, "servers", true);

                    Type type = Game1.server.GetType();
                    BindingFlags bindingFlags = BindingFlags.Instance | BindingFlags.NonPublic;

                    // get the field info
                    FieldInfo finfo = type.GetField("servers", bindingFlags);


                    var list = (List<Server>)finfo.GetValue(Game1.server);

                    foreach (var server in list)
                    {
                        servers.Add(server);
                    }
                }
                Game1.server.stopServer();
                Game1.server = new CustomGameServer();
                multiplayerSet = true;

                (Game1.server as CustomGameServer).startServer();

                ModCore.monitor.Log("Custom multiplayer binding success!");
            }

            if (Game1.client != null && multiplayerSet ==false )
            {
                if(Game1.client is LidgrenClient)
                {

                    BindingFlags bindingFlags = BindingFlags.Instance | BindingFlags.NonPublic;

                    // get the field info
                    FieldInfo finfo = typeof(LidgrenClient).GetField("address", bindingFlags);


                    var address = (string)finfo.GetValue(Game1.client);

                    Game1.client.disconnect(true); //Disconnect old client
                    LidgrenClient client = new CustomLidgrenClient(address);
                    Game1.client = client;
                    client.connect(); //Connect new client.
                    multiplayerSet = true;
                 
                }
                if(Game1.client is StardewValley.SDKs.GalaxyNetClient)
                {
                    BindingFlags bindingFlags = BindingFlags.Instance | BindingFlags.NonPublic;

                    // get the field info
                    FieldInfo finfo = typeof(StardewValley.SDKs.GalaxyNetClient).GetField("lobbyId", bindingFlags);
                    

                    var galaxyID = (GalaxyID)finfo.GetValue(Game1.client);

                    Game1.client.disconnect(true); //Disconnect old client
                    CustomGalaxyClient client = new CustomGalaxyClient(galaxyID);
                    Game1.client = client;
                    client.connect(); //Connect new client.
                    multiplayerSet = true;
                }
            }
        }

        /// <summary>
        /// Static Debug function.
        /// </summary>
        /// <param name="param"></param>
        public static void displayMessage(object param)
        {
            DataInfo dataInfo = (DataInfo)param;
            string s = (string)dataInfo.data;
            monitor.Log(s);
        }

        /// <summary>
        /// Initialize basic supported types.
        /// </summary>
        public static void initializeBasicTypes()
        {
            addObjectType(monitor, typeof(string), new ReadWriter(new reader(GenericExtentions.ReadString), new writer(GenericExtentions.WriteString)));
            addObjectType(monitor,typeof(String), new ReadWriter(new reader(GenericExtentions.ReadString), new writer(GenericExtentions.WriteString)));
            addObjectType(monitor,typeof(List<String>), new ReadWriter(new reader(GenericExtentions.ReadStringList), new writer(GenericExtentions.WriteStringList)));
            addObjectType(monitor, typeof(DataInfo), new ReadWriter(new reader(GenericExtentions.ReadDataInfo), new writer(GenericExtentions.WriteDataInfo)));

            addObjectCustomType(monitor, MessagesExtentions.HUDMessageIconIdentifier, new ReadWriter(new reader(MessagesExtentions.ReadHUDMessageWithIcon), new writer(MessagesExtentions.WriteHUDMessageWithIcon)));
        }

        /// <summary>
        /// Safely adds types
        /// </summary>
        /// <param name="monitor"></param>
        /// <param name="t"></param>
        /// <param name="readWriter"></param>
        public static void addObjectType(IMonitor monitor,Type t, ReadWriter readWriter)
        {
            if (objectTypes.ContainsKey(t.ToString()) == false)
            {
                objectTypes.Add(t.ToString(), readWriter);
                monitor.Log("Added supported type: " + t.ToString() + " to ModdedUtilitiesNetworking.",LogLevel.Info);
            }
            else
            {
                monitor.Log("Error adding supported type: " + t.ToString() + " to ModdedUtilitiesNetworking. Type already supported!", LogLevel.Alert);
            }
        }

        /// <summary>
        /// Adds "types" using a string convention to be able to allow processing of the same class type in different ways.
        /// </summary>
        /// <param name="monitor"></param>
        /// <param name="t"></param>
        /// <param name="readWriter"></param>
        public static void addObjectCustomType(IMonitor monitor, string t, ReadWriter readWriter)
        {
            if (objectTypes.ContainsKey(t.ToString()) == false)
            {
                objectTypes.Add(t, readWriter);
                monitor.Log("Added custom supported type: " + t.ToString() + " to ModdedUtilitiesNetworking.", LogLevel.Info);
            }
            else
            {
                monitor.Log("Error custom adding supported type: " + t.ToString() + " to ModdedUtilitiesNetworking. Type already supported!", LogLevel.Alert);
            }
        }

        /// <summary>
        /// Process all possible functions that can occur.
        /// </summary>
        /// <param name="key"></param>
        /// <param name="obj"></param>
        public static void processVoidFunction(string key,object obj)
        {
            foreach(var v in possibleVoidFunctions)
            {
                if (v.Key == key) v.Value.Invoke(obj);
            }
        }

        /// <summary>
        /// Process all possible data types.
        /// </summary>
        /// <param name="msg"></param>
        /// <param name="key"></param>
        /// <returns></returns>
        public static object processTypesToRead(BinaryReader msg,string key)
        {
            foreach(var v in objectTypes)
            {
                if (v.Key == key)
                {
                    object o= v.Value.read(msg);
                    return o;
                }
            }
            monitor.Log("Error: type not found: " + key, LogLevel.Error);
            return null;
        }

        public static void processTypesToWrite(BinaryWriter msg, string key,object data)
        {
            foreach (var v in objectTypes)
            {
                if (v.Key == key)
                {
                    //ModCore.monitor.Log("PROCESS TYPES TO WRITE FUNCTION: "+v.Key + " " + data.ToString());
                    v.Value.write(msg,data);
                    return;
                }
            }
            monitor.Log("Error: type not found: " + key, LogLevel.Error);
        }
    }

 
}