/* ************************************************************************** */
/*                                                                            */
/*                                                        :::      ::::::::   */
/*   Clusterizer.cpp                                    :+:      :+:    :+:   */
/*                                                    +:+ +:+         +:+     */
/*   By: tomoron <tomoron@student.42angouleme.fr>   +#+  +:+       +#+        */
/*                                                +#+#+#+#+#+   +#+           */
/*   Created: 2025/02/20 18:24:39 by tomoron           #+#    #+#             */
/*   Updated: 2025/03/18 17:06:57 by tomoron          ###   ########.fr       */
/*                                                                            */
/* ************************************************************************** */

#include "RT.hpp"

Clusterizer::Clusterizer(Arguments &args, Renderer *renderer)
{
	_isActive = 1;
	_isServer = 0;
	_error = 0;
	_serverSocket = 0;
	_serverFd = 0;
	_pollfds = 0;
	_currentJob = 0;
	_sceneName = args.getSceneName();
	_renderer = renderer;

	if(args.getBoolean("server"))
	{
		_isServer = 1;
		initServer(*args.getString("server"));
	}
	else if(args.getBoolean("client"))
	{
		_isServer = 0;
		initClient(*args.getString("client"));
	}
	else
		_isActive = 0;
}

Clusterizer::~Clusterizer(void)
{
	if(_serverSocket)
		close(_serverSocket);
	if(_serverFd)
		close(_serverFd);
	if(_pollfds)
		delete[] _pollfds;
	abortJobs();
	for(auto it = _clients.begin(); it != _clients.end(); it++)
	{
		std::cout << "closing fd " << it->first << std::endl;
		close(it->first);
	}
	if(_clients.size())
		updateServer();
	if(_currentJob)
		delete _currentJob;
	
}

void Clusterizer::update(Scene &scene, Window &win, std::vector<GLuint> &textures, ShaderProgram &denoisingProgram, std::vector<Buffer *> &buffers)
{
	if(!_isActive)
		return ;
	if(_isServer)
		updateServer();
	else
		updateClient(scene, win, textures, denoisingProgram, buffers);
}

bool Clusterizer::getError(void)
{
	return(_error);
}

bool Clusterizer::isServer(void)
{
	return(_isServer);
}

bool Clusterizer::hasJobs(void)
{
	return(_jobs[WAITING].size() || _jobs[IN_PROGRESS].size());
}