import javax.swing.*;
import java.awt.*;
import java.awt.event.*;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.InetAddress;
import java.net.ServerSocket;
import java.net.Socket;
public class MessageClient extends JFrame implements ActionListener {
private Container content;
private JLabel usernameLabel;
private JTextField username;
private JButton join;
private JButton connect;
private JTextField chat;
private JTextPane messages;
private JScrollPane messageBoard;
private JTextField messageBar;
private JButton send;
private boolean openSession;
private InetAddress ip = InetAddress.getByName("schming.webredirect.org");
private int listenPort;
private Socket socket;
public MessageClient() throws Exception{
super("Message client"); //set up window and content pane
content = new Container();
this.setContentPane(content);
this.setSize(720,720);
this.setResizable(false);
this.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
usernameLabel = new JLabel("Username:"); //set up all the GUI components
usernameLabel.setSize(100,30);
usernameLabel.setLocation(60,10);
content.add(usernameLabel);
username = new JTextField();
username.setSize(400,30);
username.setLocation(135,10);
content.add(username);
connect = new JButton();
connect.setText("Connect");
connect.setSize(100,30);
connect.setLocation(560,10);
connect.addActionListener(this);
connect.setActionCommand("toggleConnect");
content.add(connect);
chat = new JTextField();
chat.setSize(475,30);
chat.setLocation(60,50);
chat.setEnabled(false);
content.add(chat);
join = new JButton();
join.setText("Join");
join.setSize(100,30);
join.setLocation(560,50);
join.addActionListener(this);
join.setActionCommand("toggleJoin");
join.setEnabled(false);
content.add(join);
messages = new JTextPane();
messages.setEditable(false);
messageBoard = new JScrollPane(messages);
messageBoard.setSize(600,500);
messageBoard.setLocation(60, 110);
content.add(messageBoard);
messageBar = new JTextField();
messageBar.setSize(475,30);
messageBar.setLocation(60,625);
messageBar.setEnabled(false);
content.add(messageBar);
send = new JButton();
send.setText("Send");
send.setSize(100,30);
send.setLocation(560,625);
send.addActionListener(this);
send.setActionCommand("send");
send.setEnabled(false);
content.add(send);
this.addWindowListener(new WindowAdapter(){ //add code to run on closing
@Override
public void windowClosing(WindowEvent e) { //if there is still an active session, send a request to end it to the server
if (openSession){
try {
String response = sendRequest("close/" + listenPort);
System.out.println(response);
socket.close();
} catch (Exception ex){
throw new RuntimeException(ex);
}
}
}
});
openSession = false; //initialise a flag as to whether or not there is an open session
listenPort = 1025; //find the first open port
boolean free = false;
while (!free){
try{
ServerSocket test = new ServerSocket(listenPort);
test.close();
free = true;
} catch (Exception e){
listenPort++;
}
}
}
public String sendRequest(String request) throws Exception{ //method to send a request to the server
socket = new Socket(ip, 2001);
PrintWriter sender = new PrintWriter(socket.getOutputStream());
sender.println(request);
sender.flush();
BufferedReader listener = new BufferedReader(new InputStreamReader(socket.getInputStream()));
String response = listener.readLine();
socket.close();
return response;
}
public void actionPerformed(ActionEvent e){ //code to handle all button presses
try {
String text = messages.getText();
if (e.getActionCommand().equals("toggleConnect")) { //if it is the connect button
if (connect.getText().equals("Connect")) { //if we are currently unconnected
if (username.getText().equals("") || username.getText().contains("/")){ //check if the username is invalid, if so inform the user
messages.setText(text + "Invalid username\n");
} else { //else, send a request, print the response, enable/disable all relevant buttons and toggle the button to disconnect
String response = sendRequest("open/" + listenPort + "/" + username.getText());
messages.setText(text + response + "\n");
chat.setEnabled(true);
join.setEnabled(true);
username.setEnabled(false);
connect.setText("Disconnect");
}
}
else { //else we are connected, so send a disconnect request, enable/disable all relevant buttons and toggle the button to connect
String response = sendRequest("close/" + listenPort);
messages.setText(text + response + "\n");
chat.setEnabled(false);
join.setEnabled(false);
messageBar.setEnabled(false);
send.setEnabled(false);
username.setEnabled(true);
chat.setText("");
messageBar.setText("");
join.setText("Join");
connect.setText("Connect");
}
} else if (e.getActionCommand().equals("toggleJoin")) { //same as previous but for joining a chat
if (join.getText().equals("Join")) {
if (chat.getText().equals("") || chat.getText().equals("NotInAChat") || username.getText().contains("/")){
messages.setText(text + "Invalid chat name\n");
} else {
String response = sendRequest("join/" + listenPort + "/" + chat.getText());
messages.setText(text + response + "\n");
messageBar.setEnabled(true);
send.setEnabled(true);
chat.setEnabled(false);
join.setText("Leave");
openSession = true;
}
}
else {
String response = sendRequest("leave/" + listenPort);
messages.setText(text + response + "\n");
messageBar.setEnabled(false);
send.setEnabled(false);
chat.setEnabled(true);
messageBar.setText("");
join.setText("Join");
openSession = false;
}
} else if (e.getActionCommand().equals("send")) { //if it is the send button, check if the message is valid, if so send a request, else inform the user it is invalid
if (messageBar.getText().contains("/")) {
messages.setText(text + "Message contains banned characters\n");
} else {
sendRequest("message/" + listenPort + "/" + messageBar.getText());
}
}
} catch (Exception ex){
throw new RuntimeException(ex);
}
}
public JTextPane getMessages(){ //getter for the message text pane
return messages;
}
public int getListenPort(){ //getter for the listen port number
return listenPort;
}
public static void main(String[] args) throws Exception {
MessageClient window = new MessageClient(); //open a new window and a server socket o listen for responses
ServerSocket listenSocket = new ServerSocket(window.getListenPort());
window.show();
while (true){ //continuously listen for the next response, printing it when it comes through
Socket socket = listenSocket.accept();
BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
String message = reader.readLine();
socket.close();
String messages = window.getMessages().getText();
messages += message + "\n";
window.getMessages().setText(messages);
}
}
}