using System;
using System.Collections.Generic;
using System.Linq;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading.Tasks;
using libProjectAbandonware;
using libShadSockets.Server;

namespace ProjectAbandonwareServer
{
    class Program
    {
        static Dictionary<string, Socket> Userlist = new Dictionary<string, Socket>();
        static Server server;
        static void Main(string[] args)
        {
            server = new Server("127.0.0.1", 20510);
            server.OnConnect += OnConnectServer;
            server.OnReceived += OnDataReceived;
        }

        private static void OnDataReceived(object sender, Server.DataReceivedEventArgs e)
        {
            var obj = e.Received;
            if (obj is AuthToken token)
            {
                using(var ctx = new UserContext())
                {
                    token.IsAuthentificated = ctx.Users.Where(user => user.UserName == token.Username && user.UserPass == token.Password).Count() == 1;
                    if (token.IsAuthentificated) Userlist.Add(token.Username, e.SocketReceived);
                    server.Send(e.SocketReceived, token);
                }
            }
            if(obj is Search search)
            {
                using(var ctx = new GameContext())
                {
                    search.SearchResult = ctx.Games.Where(g => g.GameName.Contains(search.SearchName)).ToList();
                    server.Send(e.SocketReceived, search);
                }
            }if(obj is NewsSearch news)
            {
                using (var ctx = new NewsContext())
                {
                    news.NewsList = ctx.Newses.Where(n => n.NewsTitle.Contains(news.NewsFilter)).ToList();
                    server.Send(e.SocketReceived, news);
                }
            }
        }

        private static void OnConnectServer(object sender, Server.ConnectEventArgs e)
        {
            Console.WriteLine("New Socket Connected !");
        }
    }
}