/*
    * 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.IOException;
  import java.net.Socket;
  import java.util.List;
  import java.util.zip.GZIPOutputStream;
  
  import triptracker.core.Coordinate;
  import triptracker.core.Route;
  import triptracker.core.User;
  
  /***
   * Handler for map clients. 
   */
  public class MapHandler extends ClientHandler implements CoordListener {
  	GPSHandler handler = null;
  	/***
  	 * Sets up socket streams for communication with a map client and creates
  	 * the message reader thread for message processing. 
  	 * 
  	 * @param server main server instance
  	 * @param socket client communication socket
  	 * @param user client user data
  	 * @throws IOException on connection failure
  	 */
  	public MapHandler(Server server, Socket socket, User user) throws IOException {
  		super(server, socket, user);
  	}
  
  	/***
  	 * TODO (harald) Not finished yet!!! The method making sure everything is
  	 * being shutdown before the handler deletes itself.
  	 */	
  	@Override
  	protected void stopHandler() {
  //		System.out.println("Removing mapHandler from gpsHandler. " + handler);
  		if (handler != null)
  			handler.removeCoordListener(this);
  		server.removeMapHandler(this);
  	}
  
  	/***
  	 * {@inheritDoc}
  	 */
  	@Override
  	protected boolean messageHandler(String message) {
  		String[] msg = message.split(DELIMITER,-1);
  
  		try {
  			switch (Integer.parseInt(msg[0])) {
  			case QUIT:
  				log("Exiting thread and closing connection.");
  				stopHandler();
  				return false;
  			case USERS_GET:
  				 // For getting all users in database.
  				getUsers();
  				break;
  			case USER_GET:
  				User user = db.getUser(Integer.parseInt(msg[1]));
  				sendMessage(out, USER_GET, user.getUserId(),
  						user.getUsername());
  				log("Sent user: " + user.getUserId() + " to client");
  				
  //				out.println(USER_GET + ";" + user.getUserId() + ";" + user.getUsername());
  				break;
  			case VIEW_ROUTES:
  				viewRoutes((msg[1]));
  				break;
  			case ROUTE_GET:
  				// For getting complete route.
  				getRoute(Integer.parseInt(msg[1]));
  				break;
  			case REALTIME:
  				StringBuilder routeString = new StringBuilder();
  
  				for (GPSHandler gpsHandler : server.getGPSHandlers()) {
  					Route route = gpsHandler.getActiveRoute();
 					if (route != null) {
 						makeMsg(DELIMITER, routeString, route.getRouteId(),
 								route.getUserId(), route.getDescription(),
 								route.isActive(), route.getLastUpdateString(), route.getVisible());
 					} else { 
 						log("Realtime routes = null");
 					}
 				}
 				log("Sending realtime routes.");
 				sendMessage(out, VIEW_ROUTES, routeString);
 				break;
 			default:
 				// Invalid/unsupported message.
 				log("Invalid message: " + message);
 				server.invalidMessage(this, message);
 				break;
 			}
 		} catch (NumberFormatException num) {
 			log("Invalid indata from client: " + num);
 			server.invalidMessage(this, message);
 		} 
 		return true;
 	}
 	
 	/***
 	 * Sends newly recieved coordinate to mapClient.
 	 */
 	public void coordinateUpdate(Coordinate coord) {
 		sendMessage(out, COORD_ADD, route.getRouteId(), coord.getY(),
 				coord.getX(), coord.getDateString());
 		log("New coordinate sent to client");
 	}
 	
 	public void coordinateBufferUpdate(String[] coords) {
 		StringBuilder bufferString = new StringBuilder();
 		
 		makeMsg(DELIMITER, bufferString, route.getRouteId());
 		
 		for (int i = 0; i < coords.length; i += 3) {
 			double latitude = Double.parseDouble(coords[i]);
 			double longitude = Double.parseDouble(coords[i + 1]);
 			String time = coords[i + 2];
 			
 			makeMsg(DELIMITER, bufferString, latitude, longitude,
 					time);
 //			coordinateUpdate(coord);
 		}
 		
 		sendMessage(out, COORD_BUFFER_ADD, bufferString);
 		log("Sent buffered coordinates to client, size: " + coords.length);
 	}
 	
 	/***
 	 * Will stop the logging of a tracker.
 	 */
 	public void stopLogging(GPSHandler gpsHandler) {
 		sendMessage(out, REALTIME, false);// gpsHandler.getRoute().");
 //		if (handler != null)
 //			handler.removeCoordListener(this);
 		// TODO Implement method
 	}
 	
 	/***
 	 * Signals that tracking will start
 	 */
 	public void startLogging(GPSHandler gpsHandler) {
 		sendMessage(out, REALTIME, true);// gpsHandler.getRoute().");
 //		if (handler != null)
 //			handler.removeCoordListener(this);
 		// TODO Implement method
 	}
 	
 	/***
 	 * Sends a list of users to client.
 	 */
 	protected void getUsers() {
 		List<User> users = db.getUserList();
 		StringBuilder userString = new StringBuilder();
 		
 		for (User user : users) {
 			makeMsg(DELIMITER, userString, user.getUserId(),
 					user.getUsername());
 		}
 		log("Sending user list: " + userString.toString());
 		sendMessage(out, USERS_GET, userString.toString());
 	}
 	
 	/***
 	 * For recieving a complete route from database.
 	 * Will allso check if route is beeing plotted realtime, and start listening to route
 	 */
 	protected void getRoute(int routeId) {
 
 //		BufferedWriter gzipOutBuffer = new BufferedWriter(
 //				new OutputStreamWriter(new GZIPOutputStream(output)));
 		
 		route = new Route(routeId);
 		
 		handler = server.getGPSHandler(route);
 		if (handler != null)
 			handler.addCoordListener(this);
 //		else {
 //			sendMessage(out, SET_ROUTE, "Route not beeing tracked");
 //		}
 		log("Is tracking route: " + route.getRouteId());
 		
 		List<Coordinate> coords = db.getCoordinates(routeId);
 		
 		StringBuilder routeString = new StringBuilder();
 		for (Coordinate coord : coords) {
 			makeMsg(DELIMITER, routeString, coord.getY(), coord.getX(),
 					coord.getDateString());
 		}
 		
 		// TODO Legg til siste koordinat, aktiv
 		if (routeString.toString().trim().length() == 0)
 			sendMessage(ROUTE_GET, routeId);
 		else
 			sendMessage(ROUTE_GET, routeId, routeString);
 		
 //		sendMessage(out, ROUTE_GET, routeId);
 //		GZIPOutputStream zipout;
 //		try {
 //			zipout = new GZIPOutputStream(out);
 //			zipout.write(routeString.toString().getBytes());
 //		} catch (IOException e) {
 //			// TODO Auto-generated catch block
 //			e.printStackTrace();
 //		}
 
 //		System.out.println("Sent zipped route");
 		
 		log("Sent route " + routeId + " to " + user);
 	}
 }