package com.earth2me.essentials;

import java.io.File;
import java.util.HashSet;
import java.util.Set;
import org.bukkit.entity.Player;


public class EssentialsTimer implements Runnable, IConf
{
	private final IEssentials ess;
	private final Set<User> allUsers = new HashSet<User>(); 
	
	EssentialsTimer(IEssentials ess)
	{
		this.ess = ess;
		File userdir = new File(ess.getDataFolder(), "userdata");
		if (!userdir.exists()) {
			return;
		}
		for (String string : userdir.list())
		{
			if (!string.endsWith(".yml")) {
				continue;
			}
			String name = string.substring(0, string.length()-4);
			User u = ess.getUser(new OfflinePlayer(name, ess));
			allUsers.add(u);
		}
	}

	public void run()
	{
		long currentTime = System.currentTimeMillis();
		for (Player player : ess.getServer().getOnlinePlayers())
		{
			User u = ess.getUser(player);
			allUsers.add(u);
			u.setLastActivity(currentTime);
		}
		
		for (User user: allUsers) {
			if (user.getBanTimeout() > 0 && user.getBanTimeout() < currentTime) {
				user.setBanTimeout(0);
				ess.getBans().unbanByName(user.getName());
			}
			if (user.getMuteTimeout() > 0 && user.getMuteTimeout() < currentTime && user.isMuted()) {
				user.setMuteTimeout(0);
				user.sendMessage(Util.i18n("canTalkAgain"));
				user.setMuted(false);
			}
			if (user.getJailTimeout() > 0 && user.getJailTimeout() < currentTime && user.isJailed()) {
				user.setJailTimeout(0);
				user.setJailed(false);
				user.sendMessage(Util.i18n("haveBeenReleased"));
				user.setJail(null);
				try
				{
					user.getTeleport().back();
				}
				catch (Exception ex)
				{
				}
			}
			
			if (user.getLastActivity() < currentTime && user.getLastActivity() > user.getLastLogout()) {
				user.setLastLogout(user.getLastActivity());
			}
		}
	}

	public void reloadConfig()
	{
		for (User user : allUsers)
		{
			user.reloadConfig();
		}
	}
}