using HPSocketCS;
using iWareCc.Properties;
using iWareCommon.Utils;
using System;
namespace iWareCc.Util
{
    /// <summary>
    /// Socket帮助抽象类，该类实现Socket的连接，关闭基本功能
    /// </summary>
    public abstract class SocketServer
    {

        public TcpServer Server;//socket连接服务端
        private string Ip;//需要连接的服务器IP
        private ushort Port;//需要连接的服务器端口
        /// <summary>
        /// 记录socket是否开启
        /// </summary>
        public bool IsServerStarted = false;

        /// <summary>
        /// 记录客户端是否连上
        /// </summary>
        public bool IsClientOn = false;


        public SocketServer(TcpServer server, string ip, string port)
        {
            this.Server = server;
            this.Ip = ip;
            this.Port = ushort.Parse(port);

            //绑定事件
            //绑定监听地址前触发
            Server.OnPrepareListen += new TcpServerEvent.OnPrepareListenEventHandler(OnPrepareListen);
            //客户端连接请求被接受后触发
            Server.OnAccept += new TcpServerEvent.OnAcceptEventHandler(OnAccept);
            //发送消息后触发
            Server.OnSend += new TcpServerEvent.OnSendEventHandler(OnSend);
            //收到消息后触发
            Server.OnReceive += new TcpServerEvent.OnReceiveEventHandler(OnReceive);
            //连接关闭后触发（服务端的连接通常是多个，只要某一个连接关闭了都会触发）
            Server.OnClose += new TcpServerEvent.OnCloseEventHandler(OnClose);
            //组件停止后触发
            Server.OnShutdown += new TcpServerEvent.OnShutdownEventHandler(OnShutdown);
        }

        /// <summary>
        /// 开启socket服务
        /// </summary>
        /// <returns>是否连接成功</returns>
        public bool ServerStart()
        {
            Server.IpAddress = Ip;
            Server.Port = Port;
            return Server.Start();
        }


        /// <summary>
        /// 关闭socket连接
        /// </summary>
        /// <returns>是否断开成功</returns>
        public bool Close()
        {
            return Server.Stop();
        }

        /// <summary>
        /// 发送
        /// </summary>
        /// <param name="bytes"></param>
        /// <returns></returns>
        public bool Send(IntPtr clientId, byte[] bytes)
        {
            return Server.Send(clientId, bytes, bytes.Length);
        }

        /// <summary>
        /// 获取IP
        /// </summary>
        /// <returns></returns>
        public string GetIp()
        {
            return Ip;
        }

        /// <summary>
        /// 获取端口
        /// </summary>
        /// <returns></returns>
        public string GetPort()
        {
            return Port.ToString();
        }

        /// <summary>
        /// 有Client连接上
        /// </summary>
        /// <param name="connId"></param>
        /// <param name="pClient"></param>
        /// <returns></returns>
        protected abstract HandleResult OnAccept(IntPtr connId, IntPtr pClient);

        /// <summary>
        /// 发送信息时执行
        /// </summary>
        /// <param name="connId"></param>
        /// <param name="bytes"></param>
        /// <returns></returns>
        protected abstract HandleResult OnSend(IntPtr connId, byte[] bytes);


        /// <summary>
        /// 服务器接收到信息
        /// </summary>
        /// <param name="connId"></param>
        /// <param name="bytes"></param>
        /// <returns></returns>
        protected abstract HandleResult OnReceive(IntPtr connId, byte[] bytes);


        /// <summary>
        /// Server关闭时执行
        /// </summary>
        /// <param name="connId"></param>
        /// <param name="enOperation"></param>
        /// <param name="errorCode"></param>
        /// <returns></returns>
        protected abstract HandleResult OnClose(IntPtr connId, SocketOperation enOperation, int errorCode);

        /// <summary>
        /// 服务关闭
        /// </summary>
        /// <returns></returns>
        protected abstract HandleResult OnShutdown();


        /// <summary>
        /// 服务监听
        /// </summary>
        /// <param name="soListen"></param>
        /// <returns></returns>
        protected abstract HandleResult OnPrepareListen(IntPtr soListen);
    }
}