////////////////////////////////////////////////////////////////////////////////
//    Scorched3D (c) 2000-2011, 2025, 2026
//
//    This file is part of Scorched3D.
//
//    Scorched3D is free software; you can redistribute it and/or modify
//    it under the terms of the GNU General Public License as published by
//    the Free Software Foundation; either version 2 of the License, or
//    (at your option) any later version.
//
//    Scorched3D is distributed in the hope that it will be useful,
//    but WITHOUT ANY WARRANTY; without even the implied warranty of
//    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
//    GNU General Public License for more details.
//
//    You should have received a copy of the GNU General Public License along
//    with this program; if not, write to the Free Software Foundation, Inc.,
//    51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
////////////////////////////////////////////////////////////////////////////////

#include <common/OptionsScorched.hpp>
#include <common/Logger.hpp>
#include <common/Defines.hpp>
#include <server/ServerTimedMessage.hpp>
#include <server/ServerChannelManager.hpp>
#include <server/ServerCommon.hpp>
#include <server/ScorchedServer.hpp>
#include <engine/GameState.hpp>
#include <XML/XMLFile.hpp>
#include <time.h>

ServerTimedMessage::ServerTimedMessage() :
	lastCheckTime_(0),
	lastReadTime_(0)
{}

ServerTimedMessage::~ServerTimedMessage()
{}

void ServerTimedMessage::simulate()
{
#ifndef S3D_SERVER
	return;
#else

	//if (ScorchedServer::instance()->getGameState().getState() ==
	//	ServerState::ServerStateTooFewPlayers) return;

	time_t currentTime = time( nullptr );
	if (currentTime > lastCheckTime_ + 5)
	{
		lastCheckTime_ = currentTime;

		load();
		checkEntries(currentTime);
	}
#endif
}

void ServerTimedMessage::checkEntries(time_t currentTime)
{
	std::list<TimedMessageEntry>::iterator itor;
	for (itor = entries_.begin();
		itor != entries_.end();
		++itor)
	{
		TimedMessageEntry &entry = (*itor);
		if (entry.lastTime + (time_t) entry.timeInterval < currentTime)
		{
			entry.lastTime = currentTime;
			
			LangString message = entry.messages.front();
			ChannelText textMessage("announce", message);
			ScorchedServer::instance()->getServerChannelManager().sendText(textMessage, false);
			entry.messages.pop_front();
			entry.messages.push_back(message);
		}
	}
}

bool ServerTimedMessage::load()
{
	std::string filename = S3D::getSettingsFile(
		S3D::formatStringBuffer(
			"messages-%i.xml",
			ScorchedServer::instance()->getOptionsGame().getPortNo()
		)
	);
	if (!S3D::fileExists(filename)) return true;

	time_t fileTime = S3D::fileModTime(filename);
	if (fileTime == lastReadTime_) return true;

	XMLFile file;
	if (!file.readFile(filename))
	{
		Logger::log(
			S3D::formatStringBuffer(
				"Failed to parse user file \"%s\"\n%s",
				filename.c_str(),
				file.getParserError()
			)
		);
		return false;
	}

	Logger::log( S3D::formatStringBuffer( "Refreshing message list %s", filename.c_str() ) );
	lastReadTime_ = fileTime;
	entries_.clear();
	if (!file.getRootNode()) return true; // Empty File

	std::list<XMLNode *>::iterator childrenItor;
	std::list<XMLNode *> &children = file.getRootNode()->getChildren();
	for (childrenItor = children.begin();
		 childrenItor != children.end();
		++childrenItor)
	{
		XMLNode *currentNode = (*childrenItor);

		std::string text;
		TimedMessageEntry entry;
		if (!currentNode->getNamedChild("repeattime", entry.timeInterval)) return false;
		while (currentNode->getNamedChild("text", text, false))
		{
			entry.messages.push_back(LANG_STRING(text));
		}
		entries_.push_back(entry);
	}
	return true;
}
