/*
    * Trip Tracker, a real-time position tracking system for the Internet.
    * Copyright (C) 2006  Team Trip Tracker
    *
    * This program 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.
    *
   * This program 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
   */
  
  package triptracker.server;
  
  import static triptracker.core.Protocol.*;
  
  import java.io.BufferedReader;
  import java.io.IOException;
  import java.io.InputStreamReader;
  import java.io.PrintStream;
  import java.net.Socket;
  
  import triptracker.core.User;
  import triptracker.server.persistence.MySqlDB;
  import triptracker.server.persistence.Persistence;
  
  /***
   * This is for verifying the user with username and password before a special
   * thread is started for the spesific kind of task wich he has come to this
   * server to get fullfilled.
   */
  // TODO (jani) Generalize to extend ClientHandler, be single threaded.
  public class CheckThread implements Runnable {
  	private final Server server;
  	private Persistence db = new MySqlDB();
  	// TODO Add dynamic loading of persistency driver from the file
  	// "Persistence.properties" in the triptracker/server/persistence/ folder.
  
  	private final Socket socket;
  	private BufferedReader input;
  	private PrintStream output;
  
  	private String username = "xx";
  	private String password;
  	private int userId = -1;
  	private User user;
  
  	/***
  	 * Default class constructor.
  	 * 
  	 * @param server parent server instance
  	 * @param socket open socket for client communication
  	 */
  	public CheckThread(Server server, Socket socket) {
  		this.server = server;
  		this.socket = socket;
  	}
  
  	/***
  	 * Main thread entry point.
  	 * 
  	 * @see java.lang.Runnable#run()
  	 */
  	public void run() {
  		boolean shutdown = true;
  		try {
  			input = new BufferedReader(new InputStreamReader(
  					socket.getInputStream()));
  			output = new PrintStream(socket.getOutputStream(), true);
  			shutdown = messageHandler();
  		} catch (IOException e) {
  			// TODO Generalize this class to replace "null" with "this".
  			// Integrate it with ClientHandler.
  			server.socketErrorEvent(null, e); 
  			log("Client terminated with IOException: " + e); // TODO MVC this.
  		} catch (RuntimeException e) {
  			log("Client terminated with RuntimeException: " + e); // TODO MVC this.
  			e.printStackTrace();
  		} finally {
  			if (!shutdown) {
  				return;
  			}
  				
  			// Gracefully exit.
  			try {
  				socket.close();
  			} catch (IOException e) {
  				// Broadcast error to clients.
  //				server.socketErrorEvent(this, e);  // TODO Fix MVC, generalize.
  				log("Error closing client socket: " + e);
  				e.printStackTrace();
  			}
 			log("Client disconnected");
 		}
 	}
 
 	/***
 	 * Handles messages.
 	 * 
 	 * @throws IOException message handler dies on IOException
 	 */
 	private boolean messageHandler() throws IOException {
 		int type;
 		String message = input.readLine();
 		String[] msg ;
 		msg = message.split(DELIMITER);
 		
 		// Check for client type.
 		type = Integer.parseInt(msg[0]);
 		
 		try {
 			username = msg[1];
 			password = msg[2];
 		} catch (ArrayIndexOutOfBoundsException e) {
 			log("Incorrectly typed login info.");
 			throw e;  // Propagate the exception.
 		}
 
 		userId = db.authUser(username, password);
 		if (userId < 0) {
 			send(output, AUTH_FAIL);
 			log("Did not get verified!");
 			return true;
 		}
 		
 		send(output, AUTH_OK);
 		log("Verified! User: " + username + ", Pass: " + password
 				+ " Type: " + type);
 		
 		user = new User(userId, username, password);
 		
 		switch (type) {
 		case SENDCLIENT:
 			sendClientHandler();
 			break;
 		case MAPCLIENT:
 			mapClientHandler();
 			break;
 		default:
 			// TODO Generalize this class to replace "null" with "this".
 			server.invalidMessage(null, message); 
 			break;
 		}
 		
 		return false;
 	}
 	
 	/***
 	 * Creates a new GPS client handler and starts the GPS handler thread.
 	 * 
 	 * @throws IOException on socket connection error
 	 */
 	private void sendClientHandler() throws IOException {
 		GPSHandler handler = new GPSHandler(server, socket, user);
 
 		server.addGPSHandler(handler);
 		
 		handler.startHandler();
 	}
 	
 	/***
 	 * Creates a new map client handler and starts the map handler thread.
 	 * 
 	 * @throws IOException on socket connection error
 	 */
 	private void mapClientHandler() throws IOException {
 		MapHandler handler = new MapHandler(server, socket, user);
 		
 		server.addMapHandler(handler);
 		
 		handler.startHandler();
 	}
 	
 	/***
 	 * For broadcasting messages to logfile.
 	 * 
 	 * @param message
 	 */
 	protected void log(String message) {
 		server.log(username, message);
 	}
 }