using System.Net;
using SystemX.Core.Communication;
using WebApi.Project.UniqueKeyApi.Socket.Session;

namespace WebApi.Project.UniqueKeyApi.TaskManager
{
    public class TaskSocket
    {
        public async Task Run(int socketPort = 7777)
        {
            try
            {
                await Task.Delay(1000);
                Listener _listener = new Listener();
                IPEndPoint endPoint = new IPEndPoint(IPAddress.Any, socketPort);

                _listener.Init(endPoint, () => { return SessionManager.Instance.Generate(); });

                LogXnet.WriteLine($"Address:{endPoint.Address}, Port:{socketPort}", LogXLabel.SOCKET);
                LogXnet.WriteLine($"Socket Listening Start", LogXLabel.SOCKET);
            }
            catch (Exception e)
            {
                LogXnet.WriteLine("Socket Run Failed", LogXLabel.Error);
                LogXnet.WriteLine(e);
            }
        }
    }
}