import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.FileReader;
import java.io.FileWriter;
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.io.PrintWriter;
import java.net.Socket;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.Scanner;
/**
 *
 * @author GRUPO SC055
 *Pedro Neves fc46430
 *João Anastácio fc43284
 *Ricardo Calçado fc46382
 */
public class ServerThread extends Thread {

	private final String Rep = "Repositorio" + File.separator + "server" + File.separator;
	private final String usersFile = Rep + "usersFile.txt";
	private Socket socket = null;

	ServerThread(Socket inSoc) {
		socket = inSoc;

	}
	/**
	 * Metodo que vai correr a thread e efetuar todas as
	 * operacoes do utilizador
	 */
	public void run() {
		try {
			ObjectOutputStream outStream = new ObjectOutputStream(socket.getOutputStream());
			ObjectInputStream inStream = new ObjectInputStream(socket.getInputStream());

			String user = (String) inStream.readObject();
			String pass = (String) inStream.readObject();

			outStream.writeObject(autenticar(user, pass));
			File dir = new File(Rep + user);
			File userId = new File(Rep + user + File.separator + "vaiSeguir.txt");
			File userId2 = new File(Rep + user + File.separator + "seguidoPor.txt");
			dir.mkdir();
			userId.createNewFile();
			userId2.createNewFile();
			String str = "";
			while ((str = (String) inStream.readObject()) != "Q") {

				switch (str) {

				case "-a":
					String fileName = (String) inStream.readObject();
					File temp = new File(Rep + user + File.separator + fileName);

					if (temp.exists()) {
						System.out.println("Ficheiro existente no servidor");
					} else {
						receiveFile(inStream, user, fileName);
						receiveFile(inStream, user, fileName + "-comments.txt");
						receiveFile(inStream, user, fileName + "-likes.txt");
					}
					break;
				case "-l":
					String who = (String) inStream.readObject();
					File dir5 = new File(Rep + who + File.separator);
					dir5.mkdir();
					File[] files = dir5.listFiles();
					File[] filesimg = new File[files.length];
					int count = 0;
					for (File file : files) {
						if (file.toString().endsWith(".png")) {
							filesimg[count] = file;
							count++;
						}

					}
					outStream.writeObject(Integer.toString(count));
					for (int i = 0; i < count; i++) {
						outStream.writeObject(filesimg[i].toString());

						outStream.writeObject(new SimpleDateFormat("dd-MM-yyyy HH-mm-ss")
								.format(new Date(new File(filesimg[i].toString()).lastModified())));
					}

					outStream.flush();

					break;
				case "-i":
					String who2 = (String) inStream.readObject();
					String namephoto = (String) inStream.readObject();
					BufferedReader bufread4 = new BufferedReader(
							new FileReader(Rep + who2 + File.separator + namephoto + "-comments.txt"));
					BufferedReader bufread5 = new BufferedReader(
							new FileReader(Rep + who2 + File.separator + namephoto + "-likes.txt"));
					int likes = 0;
					int dislikes = 0;
					String readlikes = null;
					while ((readlikes = bufread5.readLine()) != null) {
						if (readlikes.equals("+"))
							likes++;
						if (readlikes.equals("-"))
							dislikes++;
					}

					String line;
					String[] temps = new String[2048];
					int count5 = 0;
					while ((line = bufread4.readLine()) != null) {

						temps[count5] = line;
						count5++;
					}
					outStream.writeObject(Integer.toString(count5));

					for (int i = 0; i < count5; i++) {
						outStream.writeObject(temps[i]);

					}
					outStream.writeObject(Integer.toString(likes));
					outStream.writeObject(Integer.toString(dislikes));
					break;

				case "-g":
					String who1 = (String) inStream.readObject();
					File dir51 = new File(Rep + who1 + File.separator);
					dir51.mkdir();
					File[] files1 = dir51.listFiles();
					File[] filesimg1 = new File[files1.length];
					int count1 = 0;
					for (File file : files1) {
						if (file.toString().contains((".png"))) {
							filesimg1[count1] = file;
							count1++;
						}
					}
					outStream.writeObject(Integer.toString(count1));
					for (int i = 0; i < count1; i++) {
						outStream.writeObject(filesimg1[i].getName().toString());
						sendFile(outStream, who1, filesimg1[i].getName());

					}
					outStream.flush();
					break;
				case "-c":
					String co = (String) inStream.readObject();
					String[] comet = new String[Integer.parseInt(co)];
					for (int i = 0; i < comet.length - 1; i++) {
						comet[i] = (String) inStream.readObject();
					}
					String name4 = (String) inStream.readObject();
					String nomeFoto4 = (String) inStream.readObject();
					BufferedWriter bufwrite4 = new BufferedWriter(
							new FileWriter(Rep + name4 + File.separator + nomeFoto4 + "-comments.txt", true));
					for (int i = 0; i < comet.length - 1; i++) {
						bufwrite4.write(comet[i] + " ");
					}
					bufwrite4.write(" --by: " + user);
					bufwrite4.newLine();
					bufwrite4.flush();
					bufwrite4.close();
					break;
				case "-L":
					String name3 = (String) inStream.readObject();
					String nomeFoto3 = (String) inStream.readObject();
					BufferedWriter bufwrite3 = new BufferedWriter(
							new FileWriter(Rep + name3 + File.separator + nomeFoto3 + "-likes.txt", true));
					bufwrite3.write("+");
					bufwrite3.newLine();
					bufwrite3.flush();
					bufwrite3.close();
					break;

				case "-D":
					String name2 = (String) inStream.readObject();
					String nomeFoto = (String) inStream.readObject();
					BufferedWriter bufwrite2 = new BufferedWriter(
							new FileWriter(Rep + name2 + File.separator + nomeFoto + "-likes.txt", true));
					bufwrite2.write("-");
					bufwrite2.newLine();
					bufwrite2.flush();
					bufwrite2.close();
					break;
				case "-f":
					String name = (String) inStream.readObject();
					BufferedWriter bufwrite = new BufferedWriter(
							new FileWriter(Rep + user + File.separator + "seguidoPor.txt", true));
					bufwrite.write(name);
					bufwrite.newLine();
					bufwrite.flush();
					bufwrite.close();
					break;
				case "-r":
					String name1 = (String) inStream.readObject();
					String line1 = (String) inStream.readObject();
					removeLineFromFile("seguidoPor.txt", user, name1);
					break;

				}
			}

		} catch (IOException | ClassNotFoundException e) {
			e.printStackTrace();
		}

	}
	/**
	 * Metodo que serve para autenticar um user consoante a sua password
	 * @param user user a ser autenticado
	 * @param pass pass do user
	 * @return true se a pass for igual a registada, false caso contrario
	 * @throws IOException
	 * @throws ClassNotFoundException
	 */
	private boolean autenticar(String user, String pass) throws IOException, ClassNotFoundException {

		File users = new File(usersFile);
		if (users.exists()) {

			BufferedReader autUser = new BufferedReader(new FileReader(users));
			String line = null;

			while ((line = autUser.readLine()) != null) {
				String[] userPass = line.split(":");
				if (userPass[0].equals(user)) {
					if (userPass[1].equals(pass)) {
						System.out.println(user + " Autenticated.");
						autUser.close();
						return true;
					} else {
						System.out.println("Wrong Password.");
						autUser.close();
						return false;
					}
				}
			}
			autUser.close();
		}
		BufferedWriter regUser = new BufferedWriter(new FileWriter(usersFile, true));
		regUser.write(user + ":" + pass);
		regUser.newLine();
		regUser.flush();
		regUser.close();
		System.out.println("User Registration sucessful");

		return true;

	}
	/**
	 * Metodo que vai remover uma linha de um ficheiro
	 * @param file ficheiro em que a linha vai ser removida
	 * @param user user a quem pertence o ficheiro a ser alterado
	 * @param lineToRemove linha a ser removida
	 */
	private void receiveFile(ObjectInputStream in, String user, String filename)
			throws IOException, ClassNotFoundException {
		int lbuffer = 1024;
		byte[] buffer = new byte[lbuffer];
		Integer sz = (Integer) in.readObject();
		FileOutputStream fos = new FileOutputStream(Rep + user + File.separator + filename);

		int count = -1;
		while ((sz > 0) && (count = in.read(buffer, 0, lbuffer)) > 0) {
			fos.write(buffer, 0, count);
			sz -= count;
		}
		fos.close();
	}
	/**
	 * Metodo que serve para enviar um ficheiro
	 * @param out stream na qual vai ser enviada o ficheiro
	 * @param user user que vai enviar o ficheiro
	 * @param filename ficheiro a ser enviado
	 * @throws IOException
	 */
	protected void sendFile(ObjectOutputStream out, String user, String filename) throws IOException {
		int lbuffer = 1024;
		byte[] buffer = new byte[lbuffer];
		File fs = new File(Rep + user + File.separator + filename);
		Integer size = new Integer((int) fs.length());
		out.writeObject(size);

		FileInputStream f = new FileInputStream(fs);
		int count = -1;
		while ((count = f.read(buffer, 0, lbuffer)) > 0) {
			out.write(buffer, 0, count);
			out.flush();
		}
		f.close();

	}
	/**
	 * Remove linha de um ficheiro
	 * @param file a alterar
	 * @param user dono do ficheiro
	 * @param lineToRemove linha a remover
	 */
	private void removeLineFromFile(String file, String user, String lineToRemove) {
		try {

			File inFile = new File(Rep + user + File.separator + file);
			/*
			 * if (!inFile.isFile()) {
			 * System.out.println("Parameter is not an existing file"); return; }
			 */
			// Construct the new file that will later be renamed to the original filename.
			File tempFile = new File(inFile.getAbsolutePath() + ".tmp");

			BufferedReader br = new BufferedReader(new FileReader(Rep + user + File.separator + file));
			PrintWriter pw = new PrintWriter(new FileWriter(tempFile));

			String line = null;

			// Read from the original file and write to the new
			// unless content matches data to be removed.
			while ((line = br.readLine()) != null) {
				if (!line.trim().equals(lineToRemove)) {
					pw.println(line);
					pw.flush();
				}
			}
			pw.close();
			br.close();

			// Delete the original file
			if (!inFile.delete()) {
				System.out.println("Could not delete file");
				return;
			}

			// Rename the new file to the filename the original file had.
			if (!tempFile.renameTo(inFile))
				System.out.println("Could not rename file");

		} catch (FileNotFoundException ex) {
			ex.printStackTrace();
		} catch (IOException ex) {
			ex.printStackTrace();
		}
	}
}