package mineplex.serverdata;

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;

import com.google.gson.Gson;
import com.google.gson.GsonBuilder;

/**
 * Utility offers various necessary utility-based methods for use in Mineplex.ServerData.
 * @author Ty
 *
 */
public class Utility 
{

	// The Gson instance used to serialize/deserialize objects in JSON form.
	private static Gson _gson = new GsonBuilder().create();
	public static Gson getGson() { return _gson; }
	
	// Public static jedis pool for interacting with central default jedis repo.
	private static JedisPool _masterPool;
	private static JedisPool _slavePool;
	
	/**
	 * @param object - the (non-null) object to serialize
	 * @return the serialized form of {@code object}.
	 */
	public static String serialize(Object object)
	{
		return _gson.toJson(object);
	}
	
	/**
	 * @param serializedData - the serialized data to be deserialized
	 * @param type - the resulting class type of the object to be deserialized
	 * @return the deserialized form of {@code serializedData} for class {@code type}.
	 */
	public static <T> T deserialize(String serializedData, Class<T> type)
	{
		return _gson.fromJson(serializedData, type);
	}
	
	/**
	 * @param delimiter - the delimiter character used to separate the concatenated elements
	 * @param elements - the set of string elements to be concatenated and returned.
	 * @return the concatenated string of all {@code elements} separated by the {@code delimiter}.
	 */
	public static String concatenate(char delimiter, String... elements)
	{
		int length = elements.length;
		String result = length > 0 ? elements[0] : new String();
		
		for (int i = 1; i < length; i++)
		{
			result += delimiter + elements[i];
		}
		
		return result;
	}
	
	/**
	 * @return the current timestamp (in seconds) fetched from the central jedis repository
	 * for synced timestamps.
	 */
	public static long currentTimeSeconds()
	{
		long currentTime = 0;
		JedisPool pool = getPool(false);
		Jedis jedis = pool.getResource();
		
		try
		{
			currentTime = Long.parseLong(jedis.time().get(0));
		}
		finally
		{
			pool.returnResource(jedis);
		}
		
		return currentTime;
	}
	
	/**
	 * @return the current timestamp (in milliseconds) fetched from the central jedis repository
	 * for synced timestamps.
	 */
	public static long currentTimeMillis()
	{
		long currentTime = 0;
		JedisPool pool = getPool(false);
		Jedis jedis = pool.getResource();

		try
		{
			currentTime = Long.parseLong(jedis.time().get(0));
		}
		finally
		{
			pool.returnResource(jedis);
		}
		
		return currentTime * 1000;
	}
	
	/**
	 * @param connData - the connection data specifying the database to be connected to.
	 * @return a newly instantiated {@link JedisPool} connected to the provided {@link ConnectionData} repository.
	 */
	public static JedisPool generatePool(ConnectionData connData)
	{
		return new JedisPool(new JedisPoolConfig(), connData.getHost(), connData.getPort());
	}
	
	/**
	 * @param writeable - whether or not the Jedis connections returned should be writeable to.
	 * @return a globally available {@link JedisPool}
	 */
	public static JedisPool getPool(boolean writeable)
	{
		if (writeable)
		{
			if (_masterPool == null)
			{
				_masterPool = generatePool(ServerManager.DEFAULT_MASTER_CONNECTION);
			}
			
			return _masterPool;
		}
		else
		{
			if (_slavePool == null)
			{
				_slavePool = generatePool(ServerManager.DEFAULT_SLAVE_CONNECTION);
			}
			
			return _slavePool;
		}
	}
}