package com.luxoft.bankapp.server;

import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.ServerSocket;
import java.net.Socket;

import com.luxoft.bankapp.exception.ClientExistsException;
import com.luxoft.bankapp.model.Bank;
import com.luxoft.bankapp.model.Client;
import com.luxoft.bankapp.service.BankApplication;

public class ServerThread implements Runnable {
	private ServerSocket socket;
	private Socket clientSocket;
	private ObjectOutputStream out;
	private ObjectInputStream in;
	ClientDAOImp cdi;
	BankOfficeDAOImp bdi;
	Bank ingBank = new Bank("ING");
	BankServerThreaded bst = new BankServerThreaded();
	
	public ServerThread(Socket clientSocket) {
		this.clientSocket = clientSocket;
	}

	public void run() {

		BankApplication bankApp = new BankApplication();
		for (Client c : bankApp.initialize().values()) {
			try {
				ingBank.addClient(c);
			} catch (ClientExistsException e) {
				e.printStackTrace();
			}
		}
		try {
			System.out.println("Server: Connected to "
					+ clientSocket.getInetAddress().getHostName());
			out = new ObjectOutputStream(clientSocket.getOutputStream());
			in = new ObjectInputStream(clientSocket.getInputStream());
			out.flush();

			String serverMessage, userMessage;
			userMessage = (String) in.readObject();
			System.out.println("Server: User Type :" + userMessage.toString());
			if (userMessage.toString().equalsIgnoreCase("Client")) {	//Client User logic
				cdi = new ClientDAOImp(ingBank);
				serverMessage = cdi.execute(userMessage);
				out.writeObject(serverMessage);

				while (userMessage != null
						&& !(userMessage.toString().equalsIgnoreCase("exit"))) {
					userMessage = (String) in.readObject();
					System.out.println("Client: " + userMessage.toString());
					out.writeObject(cdi.execute(userMessage.toString()));
					out.flush();
				}
			} else if (userMessage.toString().equalsIgnoreCase("Office")) { //Office User logic
				bdi = new BankOfficeDAOImp(ingBank);
				serverMessage = bdi.execute(userMessage);
				out.writeObject(serverMessage);
				out.flush();
				while (userMessage != null
						&& !(userMessage.toString().equalsIgnoreCase("exit"))) {
					userMessage = (String) in.readObject();
					System.out.println("Office: " + userMessage.toString());
					out.writeObject(bdi.execute(userMessage.toString()));
					out.flush();
				}
			} else {
				System.out.println("Unknown user");
			}
			bst.getClientCounter().getAndDecrement(); //Decrementing Client counter after disconnect
		} catch (IOException e) {
			e.printStackTrace();
		} catch (ClassNotFoundException e) {
			e.printStackTrace();
		} finally {
			try {
				out.close();
				in.close();
				socket.close();
				System.out.println("Connections closed");
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
	}

}