using SuperSocket;
using SuperSocket.Channel;
using SuperSocket.Server;
using System.Text;

namespace IStation.Server
{
    /// <summary>
    /// Session会话
    /// </summary>
    internal class MySession : AppSession
    {
        /// <summary>
        /// 会话名称
        /// </summary>
        public string SessionName { get; set; }


        /// <summary>
        /// 是否连接
        /// </summary>
        public bool IsConnected
        {
            get
            {
                return this.State == SessionState.Connected;
            }
        }

        /// <summary>
        /// 关闭事件
        /// </summary>
        public event Action SessionClosedEvent;

        protected override ValueTask OnSessionConnectedAsync()
        {
            LogHelper.Info(this.RemoteEndPoint.ToString() + "连接成功！");
            return base.OnSessionConnectedAsync();
        }

        protected override ValueTask OnSessionClosedAsync(CloseEventArgs e)
        {
            this.SessionClosedEvent?.Invoke();
            LogHelper.Info($"{this.SessionName},Socket连接关闭，关闭原因：{e.Reason}");
            return base.OnSessionClosedAsync(e);
        }

        /// <summary>
        /// 发送文本
        /// </summary>
        public async void Send(string message)
        {
            var bts = Encoding.UTF8.GetBytes(message);
            var memory = new ReadOnlyMemory<byte>(bts);
            await ((IAppSession)this).SendAsync(memory);
        }

        /// <summary>
        /// 发送字节
        /// </summary>
        public async void Send(byte[] data)
        {
            var memory = new ReadOnlyMemory<byte>(data);
            await ((IAppSession)this).SendAsync(memory);
        }

        /// <summary>
        /// 发送字节
        /// </summary>
        public void Send(byte[] data, int offset, int length)
        {
            var bts = new byte[length];
            Buffer.BlockCopy(data, offset, bts, 0, length);
            Send(bts);
        }

        /// <summary>
        /// 关闭
        /// </summary>
        public async void Close(string reason)
        {
            LogHelper.Info($"{this.SessionName} 准备关闭会话，原因:{reason}");
            await base.CloseAsync();
        }


    }
}