package server.model.players;

import java.util.ArrayList;

import server.Server;

/**
 * @author Sanity
 */

public class PlayerSaving implements Runnable {

	private ArrayList<Integer> requests = new ArrayList<Integer>();
	private Thread thread;
	private static PlayerSaving singleton;
	private static long lastGroupSave;
	private static final int SAVE_TIMER = 300000;

	public static PlayerSaving getSingleton() {
		return singleton;
	}

	public static void initialize() {
		singleton = new PlayerSaving();
		singleton.thread = new Thread(singleton);
		singleton.thread.start();
	}

	public synchronized void run() {
		while(true) {
			saveAllPlayers();
			try {
				thread.sleep(300000);
			} catch (Exception e) {
				e.printStackTrace();
			}
		}
	}

	public synchronized void requestSave(int i) {
		if (!requests.contains(i)) {
			requests.add(i);
			notify();
		}
	}

	public void saveAllPlayers() {
		lastGroupSave = System.currentTimeMillis();
		//requests.clear();
		long start = lastGroupSave;
		for (Player p : PlayerHandler.players) {
			if (p != null)
				PlayerSave.saveGame((Client)p);
			if (System.currentTimeMillis() - start >= (Server.getSleepTimer() - 5)) {
				System.out.println("Aborted all saving to prevent lag.");
				return;
			}
		}
		System.out.println("Saved every player's file.");
	}

	public void saveRequests() {
		int totalSave = 0;
		for (int id : requests) {
			if (PlayerHandler.players[id] != null) {
				Client c = (Client)PlayerHandler.players[id];
				PlayerSave.saveGame((Client)PlayerHandler.players[id]);
				totalSave++;
			}
		}
		System.out.println("Saved a total of: " + totalSave + " player files.");
		requests.clear();
	}

	public static boolean saveRequired() {
		return System.currentTimeMillis() - lastGroupSave > SAVE_TIMER;
	}
}