using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.IO;
using System.Linq;
using System.Net;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using System.Windows.Forms;
using SiMay.Sockets;
using SiMay.Sockets.Delegate;
using SiMay.Sockets.Tcp;
using SiMay.Sockets.Tcp.Client;
using SiMay.Sockets.Tcp.Server;
using SiMay.Sockets.Tcp.Session;
using SiMay.Sockets.Tcp.TcpConfiguration;

namespace SiMaySocketTestApp
{
    public partial class Form1 : Form
    {
        public Form1()
        {
            InitializeComponent();
        }
        TcpSocketSaeaClientAgent client;
        TcpSocketSaeaServer server;
        private void Form1_Load(object sender, EventArgs e)
        {
            //模式说明
            //Full模式:仅接收发送数据（高性能的数据接收模型，可启用TcpKeepAlive选项）注：数据压缩丶AppKeepAlive选项在Full模式下启用无效
            //Pack模式:自动处理分包（高性能的数据接收模型，自动处理分包，可启用数据压缩丶应用层心跳包丶TcpKeepAlive选项）


            //设置在Socket初始化后无法修改
            TcpSocketSaeaClientConfiguration clientConfig = new TcpSocketSaeaClientConfiguration();
            clientConfig.KeepAlive = false;
            clientConfig.AppKeepAlive = true;
            client = TcpSocketsFactory.CreateClientAgent(TcpSocketSaeaSessionType.Packet, clientConfig, Client_CompletetionNotify);



            TcpSocketSaeaServerConfiguration serverConfig = new TcpSocketSaeaServerConfiguration();
            serverConfig.KeepAlive = false;
            serverConfig.AppKeepAlive = true;
            server = TcpSocketsFactory.CreateServerAgent(TcpSocketSaeaSessionType.Packet, serverConfig, Server_CompletetionNotify);
        }

        private void Server_CompletetionNotify(TcpSocketCompletionNotify e, TcpSocketSaeaSession session)
        {
            this.Invoke(new Action(() =>
            {
                switch (e)
                {
                    case TcpSocketCompletionNotify.OnConnected:

                        //session初始化完成连接的事件
                        //调用session.SendAsync();对session发送消息
                        //调用session.Close(true)断开session连接，并通知断开事件
                        //可在session.AppTokens中绑定应用对象，以便在其他异步事件中调用

                        this.listBox1.Items.Add("successful client connection");

                        break;
                    case TcpSocketCompletionNotify.OnSend:

                        //session发送数据通知事件

                        //session.SendTransferredBytes == 以发送数据长度

                        break;
                    case TcpSocketCompletionNotify.OnDataReceiveing:

                        //session数据接收通知事件

                        //session.ReceiveBytesTransferred == 本次接收数据长度
                        //Packet模式下 session.CompletedBuffer.Length == 完整数据包长度

                        //this.listBox1.Items.Add("len:" + session.CompletedBuffer.Length + " msg:" + Encoding.UTF8.GetString(session.CompletedBuffer, 0, session.ReceiveBytesTransferred));


                        break;
                    case TcpSocketCompletionNotify.OnDataReceived:
                        if (session.CompletedBuffer.Length != 15)
                            throw new Exception();


                        session.SendAsync(session.CompletedBuffer);


                        //Packet模式session自动处理分包的完成事件

                        //var pack = session.CompletedBuffer;//完整数据包
                        break;
                    case TcpSocketCompletionNotify.OnClosed:

                        //session断开通知事件

                        this.listBox1.Items.Add("server :client offline");
                        break;
                }
            }));


        }

        private void Client_CompletetionNotify(TcpSocketCompletionNotify e, TcpSocketSaeaSession session)
        {
            this.Invoke(new Action(() =>
            {
                switch (e)
                {
                    case TcpSocketCompletionNotify.OnConnected:
                        break;
                    case TcpSocketCompletionNotify.OnDataReceiveing:
                        //this.listBox1.Items.Add("len:" + session.CompletedBuffer.Length + " msg:" + Encoding.UTF8.GetString(session.CompletedBuffer, 0, session.ReceiveBytesTransferred));
                        break;
                    case TcpSocketCompletionNotify.OnDataReceived:
                        if (session.CompletedBuffer.Length != 15)
                            throw new Exception();
                        Console.WriteLine(session.CompletedBuffer.Length + ":" + Encoding.UTF8.GetString(session.CompletedBuffer, 0, session.CompletedBuffer.Length));
                        session.SendAsync(session.CompletedBuffer);
                        //this.listBox1.Items.Add(session.CompletedBuffer.Length);
                        break;
                    case TcpSocketCompletionNotify.OnClosed:
                        var xx = session.AppTokens;
                        this.listBox1.Items.Add("client disconnect");
                        break;
                }
            }));

        }

        private void button1_Click(object sender, EventArgs e)
        {
            //对服务器发起连接
            client.ConnectToServer(new IPEndPoint(IPAddress.Parse("94.191.115.121"), 5211));
        }

        private void button2_Click(object sender, EventArgs e)
        {
            //断开所有连接，并通知断开事件
            client.DisconnectAll(true);
        }

        private void button3_Click(object sender, EventArgs e)
        {
            //对所有session广播数据
            client.BroadcastAsync(Encoding.UTF8.GetBytes("服务器你好啊"));
        }

        private void button4_Click(object sender, EventArgs e)
        {
            //启动监听
            server.Listen(new IPEndPoint(IPAddress.Parse("0.0.0.0"), 5211));
            this.listBox1.Items.Add("listening...");
        }

        private void button5_Click(object sender, EventArgs e)
        {
            server.BroadcastAsync(Encoding.UTF8.GetBytes("你好鸭client"));
        }

        private void button6_Click(object sender, EventArgs e)
        {
            server.DisconnectAll(true);
        }

        private void groupBox2_Enter(object sender, EventArgs e)
        {

        }
    }
}