using HPSocketCS;
using System.Runtime.InteropServices;
namespace iWareCc.Util
{
    /// <summary>
    /// Socket帮助抽象类，该类实现Socket的连接，关闭基本功能
    /// </summary>
    public abstract class SocketClient
    {
        /// <summary>
        /// socket连接客户端
        /// </summary>
        public TcpClient Client;

        /// <summary>
        /// 需要连接的服务器IP
        /// </summary>
        private string Ip;

        /// <summary>
        /// 需要连接的服务器端口
        /// </summary>
        private ushort Port;

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


        public SocketClient(TcpClient client, string ip, string port)
        {
            this.Client = client;
            this.Ip = ip;
            this.Port = ushort.Parse(port);

            //绑定client事件
            Client.OnConnect += new TcpClientEvent.OnConnectEventHandler(OnConnect);
            Client.OnSend += new TcpClientEvent.OnSendEventHandler(OnSend);
            Client.OnReceive += new TcpClientEvent.OnReceiveEventHandler(OnReceive);
            Client.OnClose += new TcpClientEvent.OnCloseEventHandler(OnClose);
        }

        /// <summary>
        /// 连接socket
        /// </summary>
        /// <returns>是否连接成功</returns>
        public bool Connect()
        {

            return Client.Connetion(Ip, Port, false);

        }


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

        /// <summary>
        /// 发送
        /// </summary>
        /// <param name="bytes"></param>
        /// <returns></returns>
        public virtual bool Send(byte[] bytes)
        {

            return Client.Send(bytes, bytes.Length);
        }


        /// <summary>
        /// 关闭socket时执行的代码
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="enOperation"></param>
        /// <param name="errorCode"></param>
        /// <returns></returns>
        protected abstract HandleResult OnClose(TcpClient sender, SocketOperation enOperation, int errorCode);

        /// <summary>
        /// 接收到报文时执行的代码
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="bytes">接收到的字符串</param>
        /// <returns></returns>
        protected abstract HandleResult OnReceive(TcpClient sender, byte[] bytes);

        /// <summary>
        /// 发送报文时执行的代码
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="bytes"></param>
        /// <returns></returns>
        protected abstract HandleResult OnSend(TcpClient sender, byte[] bytes);


        /// <summary>
        /// 连接客户端时执行的代码
        /// </summary>
        /// <param name="sender"></param>
        /// <returns></returns>
        protected abstract HandleResult OnConnect(TcpClient sender);

    }
}