#include "Test.h"

Test::Test() {
    socket.Init(CTL::IPV6,CTL::UDP);
}

void Test::test() {
    auto list = CTL::Socket::GetLocalIP(CTL::IPV6);
    bool F = socket.Bind(list[0].c_str(),8080);
    if (F) {
        CTL::Thread th(&Test::udp_socket,this);
        th.Start();
    }
    // bool F = socket.Connect(list[0].c_str(), 8080);
    // if (F) {
    //     auto clientinfo = socket.GetLocalHost();
    //     CC::Println(clientinfo.IPAddress.c_str());
    //     CC::Println(clientinfo.Port);
    //     CTL::Thread th(&Test::client_socket,this,socket);
    //     th.Start();
    // }
    // bool F = socket.Bind(list[0].c_str(),8080);
    // if (F) {
    //     bool F = socket.Listen();
    //     if (F) {
    //         thread.SetThread(&Test::test_socket,this);
    //         thread.Start();
    //     }
    // }
}

void Test::test_socket() {
    while (thread.Sign()) {
        auto sock = socket.Accept();
        CTL::Thread th(&Test::client_socket,this,sock);
        th.Start();
    }
}

void Test::client_socket(CTL::Socket& socket) {
    while (true) {
        char buffer[1024] = {};
        auto length = socket.RecvData(buffer,sizeof(buffer));
        if (length > 0) {
            // auto clientinfo = socket.GetClientHost();
            // CC::Println(clientinfo.IPAddress.c_str());
            // CC::Println(clientinfo.Port);
            CC::Println(buffer);
            socket.Send(buffer);
        }
        else {
            break;
        }
    }
}

void Test::udp_socket() {
    while (true) {
        char buffer[1024] = {};
        CCHostInfo client_info{};
        auto length = socket.UDPRecvData(buffer,sizeof(buffer),&client_info);
        if (length > 0) {
            CC::Println(client_info.IPAddress.c_str());
            CC::Println(client_info.Port);
            CC::Println(buffer);
            socket.UDPSend(buffer,client_info.IPAddress.c_str(),client_info.Port);
        }
        else {
            break;
        }
    }
}