/* ************************************************************************** */
/*                                                                            */
/*                                                        :::      ::::::::   */
/*   Server.cpp                                   :+:      :+:    :+:   */
/*                                                    +:+ +:+         +:+     */
/*   By: aortigos <aortigos@student.42malaga.com>    +#+  +:+       +#+        */
/*                                                +#+#+#+#+#+   +#+           */
/*   Created: 2026/04/13 22:31:44 by aortigos          #+#    #+#             */
/*   Updated: 2026/04/13 22:31:44 by aortigos         ###   ########.fr       */
/*                                                                            */
/* ************************************************************************** */

#include "Server.hpp"

//////////////////
// Constructors //
//////////////////

Server::Server()
{
	std::cout << "Server default constructor called" << std::endl;
}

Server::Server(int port) : port(port)
{
	std::cout << "Server will use port: " << port << std::endl;
}

Server::~Server()
{
	std::cout << "Server destructor called" << std::endl;
}

int Server::run()
{
	int	server_fd = socket(AF_INET, SOCK_STREAM, 0);

	sockaddr_in	addr = {};
	addr.sin_family = AF_INET;
	addr.sin_port = htons(this->port);
	addr.sin_addr.s_addr = INADDR_ANY;

	bind(server_fd, (sockaddr*)&addr, sizeof(addr));
	listen(server_fd, 1);
	std::cout << "Esperando conexion" << std::endl;

	std::vector<pollfd> fds;

	pollfd	server_pfd;
	server_pfd.fd = server_fd;
	server_pfd.events = POLLIN;
	server_pfd.revents = 0;
	fds.push_back(server_pfd);

	while (true)
	{
		poll(fds.data(), fds.size(), -1);

		for(unsigned int i = 0; i < fds.size(); i++)
		{
			if (!(fds[i].revents & POLLIN))
				continue ;

			if (fds[i].fd == server_fd)
			{
				int	client_fd = accept(server_fd, NULL, NULL);
				std::cout << "Cliente conectado (fd=" << client_fd << ")\n";

				pollfd	client_pfd;
				client_pfd.fd = client_fd;
				client_pfd.events = POLLIN;
				client_pfd.revents = 0;
				fds.push_back(client_pfd);
			} else {
				char	buf[512] = {0};
				ssize_t	n = recv(fds[i].fd, buf, sizeof(buf) - 1, 0);
				if(n <= 0)
				{
					std::cout << "Cliente (fd=" << fds[i].fd << ") desconectado\n";
					close(fds[i].fd);
					fds.erase(fds.begin() + i);
					i--;
				} else {
					std::cout << "Mensaje de fd=" << fds[i].fd << ": " << buf;
				}
			}
		}

	}

	close(client_fd);
	close(server_fd);

	return (0);

}