using System.Collections.Generic;

namespace AxiReplay
{
    public class NetReplay
    {
        /// <summary>
        /// 客户端当前帧
        /// </summary>
        public int mCurrClientFrameIdx = int.MinValue;
        /// <summary>
        /// 服务器远端当前帧
        /// </summary>
        public int mRemoteFrameIdx { get; private set; }
        /// <summary>
        /// Remote 2 Client Frame Gap
        /// </summary>
        public int mDiffFrameCount => mRemoteFrameIdx - mCurrClientFrameIdx;
        /// <summary>
        /// 网络数据队列
        /// </summary>
        Queue<ReplayStep> mNetReplayQueue = new Queue<ReplayStep>();
        /// <summary>
        /// 当前数据
        /// </summary>
        ReplayStep mCurrReplay;
        /// <summary>
        /// 下一个数据数据
        /// </summary>
        ReplayStep mNextReplay;

        bool bNetInit = false;
        public NetReplay()
        {
            ResetData();
        }
        public void ResetData()
        {
            mNetReplayQueue.Clear();
            mCurrReplay = default(ReplayStep);
            mCurrReplay.FrameStartID = int.MinValue;
            bNetInit = false;
        }
        public void InData(ReplayStep inputData, int ServerFrameIdx)
        {
            mNetReplayQueue.Enqueue(inputData);
            mRemoteFrameIdx = inputData.FrameStartID;
            if (!bNetInit)
            {
                bNetInit = true;
                mNextReplay = mNetReplayQueue.Dequeue();
            }
        }
        public bool TryGetNextFrame(out ReplayStep data, out int frameDiff, out bool inputDiff)
        {
            if (!bNetInit)
            {
                data = default(ReplayStep);
                frameDiff = default;
                inputDiff = false;
                return false;
            }
            TakeFrame(1, out data, out frameDiff, out inputDiff);
            return frameDiff > 0;
        }

        public bool TryGetNextFrame(int targetFrame, out ReplayStep data, out int frameDiff, out bool inputDiff)
        {
            if (!bNetInit)
            {
                data = default(ReplayStep);
                frameDiff = default;
                inputDiff = false;
                return false;
            }
            return TakeFrameToTargetFrame(targetFrame, out data, out frameDiff, out inputDiff);
        }

        void TakeFrame(int addFrame, out ReplayStep data, out int bFrameDiff, out bool inputDiff)
        {
            int targetFrame = mCurrClientFrameIdx + addFrame;
            TakeFrameToTargetFrame(targetFrame, out data, out bFrameDiff, out inputDiff);
        }

        bool TakeFrameToTargetFrame(int targetFrame, out ReplayStep data, out int bFrameDiff, out bool inputDiff)
        {
            bool result;
            inputDiff = false;
            if (targetFrame == mNextReplay.FrameStartID && targetFrame <= mRemoteFrameIdx && mNetReplayQueue.Count > 0)
            {
                //当前帧追加
                mCurrClientFrameIdx = targetFrame;
                ulong oldInput = mCurrReplay.InPut;
                mCurrReplay = mNextReplay;
                if (oldInput != mCurrReplay.InPut)
                    inputDiff = true;
                mNextReplay = mNetReplayQueue.Dequeue();
                result = true;
            }
            else
                result = false;

            bFrameDiff = mRemoteFrameIdx - mCurrClientFrameIdx;
            data = mCurrReplay;

            return result;
        }
    }
}