package chat.server;

import javax.servlet.ServletContext;

import org.apache.log4j.Logger;

import chat.module.ModuleLoader;
import chat.server.netty.NettyAcceptor;
import frame.persist.DatasuorceLoader;
import frame.persist.NamedSQLLoader;
import io.netty.util.ResourceLeakDetector;


public class ServerInstance {

	private static Logger logger;
	private static ServerInstance instance;
	private String version;
	public static ServerState state;

	static {
		logger = Logger.getLogger(ServerInstance.class);
	}
	
	public ServerInstance(ServletContext servletContext) {
		version = "1.0.0.1";
	}

	public static void startService(ServletContext servletContext) {
		try {
			instance = new ServerInstance(servletContext);
			instance.start();
		} 
		catch (Exception e) {
			logger.error(e);
			e.printStackTrace();
		}
	}

	public static void stopService() {
		try {
			if(instance != null) {
				instance.stop();
			}
			
		} catch (Exception e) {
			logger.error(e);
			e.printStackTrace();
		}
	}

	public void start() throws Exception {
		try {
			state = ServerState.Starting;
			
			//1. write info
			logger.info("server is startting...");
			logger.info("server root path is " + Configer.getPath_Application());
			
			//2. resource leak
			ResourceLeakDetector.setLevel(ResourceLeakDetector.Level.ADVANCED);
			
			//3. data source and SQL
			DatasuorceLoader.staticLoad();
			NamedSQLLoader.staticLoad();
			
			//4. schedule 
			// dbScheduler、imBusinessScheduler、callbackScheduler
			
			//5.
			ModuleLoader.load();
			
			//6、 start listener list
			NettyAcceptor.start();
			
			state = ServerState.Start;
		} 
		catch (Exception e) {
			e.printStackTrace();
		}
		finally {
			printStartUpMessage();
		}
	}

	public void stop() {
		logger.info("internal server is stopping...");

		NettyAcceptor.stop();
		
		logger.info("internal server has been stopped");
	}

	public void restart() throws Exception {
		stop();
		start();
	}

	private static String echoString(String word, int count) {
		StringBuilder result = new StringBuilder();

		for (int i = 1; i <= count; i++) {
			result.append(word);
		}

		return result.toString();
	}

	private void printStartUpMessage() {
		int length_total = 40;

		long total = Math.round((Runtime.getRuntime().totalMemory()) / (1024.0 * 1024));
		long max = Math.round((Runtime.getRuntime().maxMemory()) / (1024.0 * 1024));

		String envirenment = Configer.getString("EnvironmentName");
		System.out.println("--->>> " + envirenment + " --->>>");

		System.out.println(echoString("*", length_total + 2));
		printMessage("Total Memory:" + total + "M", length_total);
		printMessage("Max Memory:" + max + "M", length_total);
		printMessage(version, length_total);
		System.out.println(echoString("*", length_total + 2));
	}

	private void printMessage(String message, int totalLength) {
		MessagePos messagePos = new MessagePos(totalLength, message);
		System.out.println("*" + echoString(" ", messagePos.length_begin) + message + echoString(" ", messagePos.length_end) + "*");
	}

	private class MessagePos {
		private int length_begin;
		private int length_end;
		private int length_message;

		public MessagePos(int totalLength, String message) {
			length_message = message.length();
			length_begin = (totalLength - length_message) / 2;
			length_end = totalLength - length_begin - length_message;
		}
	}
	
	public static boolean isStart() {
		return ServerState.Start == state;
	}
}