ServerThread.java

package server.domain;

import server.utils.DecryptionUtils;
import server.view.ServerGUI;

import javax.security.sasl.AuthenticationException;
import java.io.*;
import java.net.Socket;
import java.util.Vector;

import static server.utils.ErrorMessage.STRING_INVALID_PASSWORD;
import static server.utils.OutputMessage.*;

class ServerThread implements Runnable {
    static Vector<PrintWriter> list = new Vector<>();

    private Socket socket;
    private PrintWriter writer;
    private ServerGUI serverGUI;
    private ServerInfo serverInfo;

    public ServerThread(Socket socket, ServerGUI serverGUI, ServerInfo serverInfo) {
        this.socket = socket;
        this.serverGUI = serverGUI;
        this.serverInfo = serverInfo;
        PrintWriter tempWriter = null;
        try {
            tempWriter = new PrintWriter(socket.getOutputStream());
        } catch (IOException e) {
            e.printStackTrace();
        }
        writer = tempWriter;
        list.add(writer);
    }

    @Override
    public void run() {
        String name = null;
        String password;
        try (InputStream inputStream = socket.getInputStream();
             InputStreamReader inputStreamReader = new InputStreamReader(inputStream);
             BufferedReader reader = new BufferedReader(inputStreamReader)) {

            name = reader.readLine();
            password = reader.readLine();

            validatePassword(name, password);
            sendAll("#" + name + STRING_LOGIN_MESSAGE.getMessage());
            addUser(name);

            while (true) {
                String message = reader.readLine();
                if (message == null)
                    break;
                sendAll("[" + name + "]" + message);
            }

        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            list.remove(writer);
            sendAll("#" + name + STRING_LOGOUT_MESSAGE.getMessage());
            try {
                socket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

    void validatePassword(String name, String password) throws AuthenticationException {
        try {
            String encryptedPassword = DecryptionUtils.decrypt(password, serverInfo.getKey());
            if (!encryptedPassword.equals(serverInfo.getPassword())) {
                sendAll("#" + name + STRING_LOGIN_ERROR_MESSAGE.getMessage());
                throw new AuthenticationException(STRING_INVALID_PASSWORD.getMessage());
            }
        } catch (Exception e) {
            e.printStackTrace();
            throw new AuthenticationException("Password validation failed.");
        }
    }

    private void sendAll(String message) {
        serverGUI.chatList(message + "\n");
        for (PrintWriter writer : list) {
            writer.println(message);
            writer.flush();
        }
    }

    private void addUser(String name) {
        serverGUI.updateUserList(name);
    }

    /*public Document toXmlDocument() {
        // Implement this method to convert ServerThread state to XML if needed
        return null;
    }*/
}