using ProtoBuf;
using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using Vintagestory.API.Client;
using Vintagestory.API.Common;
using Vintagestory.API.MathTools;
using Vintagestory.API.Server;
using Vintagestory.GameContent;

namespace ExpandedFoods
{
    [ProtoContract(ImplicitFields = ImplicitFields.AllPublic)]
    public class RecipeUpload
    {
        public List<string> dvalues;
        public List<string> cvalues;
    }

    [ProtoContract(ImplicitFields = ImplicitFields.AllPublic)]
    public class RecipeResponse
    {
        public string response;
    }

    public class RecipeUploadSystem : ModSystem
    {
        #region Client
        IClientNetworkChannel clientChannel;
        ICoreClientAPI clientApi;

        public override void StartClientSide(ICoreClientAPI api)
        {
            clientApi = api;

            clientChannel =
                api.Network.RegisterChannel("networkapitest")
                .RegisterMessageType(typeof(RecipeUpload))
                .RegisterMessageType(typeof(RecipeResponse))
                .SetMessageHandler<RecipeUpload>(OnServerMessage)
            ;
        }

        private void OnServerMessage(RecipeUpload networkMessage)
        {
            List<DoughRecipe> drecipes = new List<DoughRecipe>();
            List<CookingRecipe> crecipes = new List<CookingRecipe>();
            if (networkMessage.dvalues == null && networkMessage.cvalues == null)
            {
                for (int i = 0; i < networkMessage.dvalues.Count; i++)
                {
                    string drec = networkMessage.dvalues[i];
                    using (MemoryStream ms = new MemoryStream(Ascii85.Decode(drec)))
                    {
                        BinaryReader reader = new BinaryReader(ms);

                        DoughRecipe retr = new DoughRecipe();
                        retr.FromBytes(reader, clientApi.World);

                        drecipes.Add(retr);
                    }
                }

                MixingRecipeRegistry.Loaded.KneadingRecipes = drecipes;

                for (int i = 0; i < networkMessage.cvalues.Count; i++)
                {
                    string crec = networkMessage.cvalues[i];
                    using (MemoryStream ms = new MemoryStream(Ascii85.Decode(crec)))
                    {
                        BinaryReader reader = new BinaryReader(ms);

                        CookingRecipe retr = new CookingRecipe();
                        retr.FromBytes(reader, clientApi.World);

                        crecipes.Add(retr);
                    }
                }

                MixingRecipeRegistry.Loaded.MixingRecipes = crecipes;


                System.Diagnostics.Debug.WriteLine(MixingRecipeRegistry.Loaded.KneadingRecipes.Count + " kneading recipes and " + MixingRecipeRegistry.Loaded.MixingRecipes.Count + " mixing recipes loaded to client.");
            }
            else {
                System.Diagnostics.Debug.WriteLine("neading recipes and mixing recipes failed to load to client due to null values");
            }
        }

        #endregion

        #region Server
        IServerNetworkChannel serverChannel;
        ICoreServerAPI serverApi;

        public override void StartServerSide(ICoreServerAPI api)
        {
            serverApi = api;

            serverChannel =
                api.Network.RegisterChannel("networkapitest")
                .RegisterMessageType(typeof(RecipeUpload))
                .RegisterMessageType(typeof(RecipeResponse))
                .SetMessageHandler<RecipeResponse>(OnClientMessage)
            ;

            api.RegisterCommand("recipeupload", "Resync recipes", "", OnRecipeUploadCmd, Privilege.chat);
            api.Event.PlayerNowPlaying += (hmm) => { OnRecipeUploadCmd(); };
        }

        private void OnRecipeUploadCmd(IServerPlayer player = null, int groupId = 0, CmdArgs args = null)
        {
            List<string> drecipes = new List<string>();
            List<string> crecipes = new List<string>();


            foreach (DoughRecipe drec in MixingRecipeRegistry.Loaded.KneadingRecipes)
            {
                using (MemoryStream ms = new MemoryStream())
                {
                    BinaryWriter writer = new BinaryWriter(ms);

                    drec.ToBytes(writer);

                    string value = Ascii85.Encode(ms.ToArray());
                    drecipes.Add(value);
                }
            }

            foreach (CookingRecipe crec in MixingRecipeRegistry.Loaded.MixingRecipes)
            {
                using (MemoryStream ms = new MemoryStream())
                {
                    BinaryWriter writer = new BinaryWriter(ms);

                    crec.ToBytes(writer);

                    string value = Ascii85.Encode(ms.ToArray());
                    crecipes.Add(value);
                }
            }

            serverChannel.BroadcastPacket(new RecipeUpload()
            {
                dvalues = drecipes,
                cvalues = crecipes
            });
        }

        private void OnClientMessage(IPlayer fromPlayer, RecipeResponse networkMessage)
        {
            OnRecipeUploadCmd();
        }


        #endregion
    }
}