Merge pull request #25 from PM2-IT21bWIN-ruiz-mach-krea/Class_Message
Class Message
This commit is contained in:
commit
9eb352c0fe
|
@ -19,7 +19,6 @@ import java.util.regex.Pattern;
|
||||||
import static ch.zhaw.pm2.multichat.client.ClientConnectionHandler.State.*;
|
import static ch.zhaw.pm2.multichat.client.ClientConnectionHandler.State.*;
|
||||||
|
|
||||||
public class ChatWindowController {
|
public class ChatWindowController {
|
||||||
private final Pattern messagePattern = Pattern.compile( "^(?:@(\\w*))?\\s*(.*)$" );
|
|
||||||
private ClientConnectionHandler connectionHandler;
|
private ClientConnectionHandler connectionHandler;
|
||||||
private ClientMessageList messages;
|
private ClientMessageList messages;
|
||||||
|
|
||||||
|
@ -41,7 +40,10 @@ public class ChatWindowController {
|
||||||
serverAddressField.setText(NetworkHandler.DEFAULT_ADDRESS.getCanonicalHostName());
|
serverAddressField.setText(NetworkHandler.DEFAULT_ADDRESS.getCanonicalHostName());
|
||||||
serverPortField.setText(String.valueOf(NetworkHandler.DEFAULT_PORT));
|
serverPortField.setText(String.valueOf(NetworkHandler.DEFAULT_PORT));
|
||||||
stateChanged(NEW);
|
stateChanged(NEW);
|
||||||
messages = new ClientMessageList(this);
|
}
|
||||||
|
|
||||||
|
public void setMessages(ClientMessageList messages) {
|
||||||
|
this.messages = messages;
|
||||||
}
|
}
|
||||||
|
|
||||||
private void applicationClose() {
|
private void applicationClose() {
|
||||||
|
@ -59,46 +61,40 @@ public class ChatWindowController {
|
||||||
|
|
||||||
private void connect() {
|
private void connect() {
|
||||||
try {
|
try {
|
||||||
messages = new ClientMessageList(this); // clear message list
|
messages.clear(); // clear message list
|
||||||
|
redrawMessageList();
|
||||||
startConnectionHandler();
|
startConnectionHandler();
|
||||||
connectionHandler.connect();
|
connectionHandler.connect();
|
||||||
} catch(ChatProtocolException | IOException e) {
|
} catch(ChatProtocolException | IOException e) {
|
||||||
writeError(e.getMessage());
|
addError(e.getMessage());
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
private void disconnect() {
|
private void disconnect() {
|
||||||
if (connectionHandler == null) {
|
if (connectionHandler == null) {
|
||||||
writeError("No connection handler");
|
addError("No connection handler");
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
try {
|
try {
|
||||||
connectionHandler.disconnect();
|
connectionHandler.disconnect();
|
||||||
} catch (ChatProtocolException e) {
|
} catch (ChatProtocolException e) {
|
||||||
writeError(e.getMessage());
|
addError(e.getMessage());
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@FXML
|
@FXML
|
||||||
private void message() {
|
private void message() {
|
||||||
if (connectionHandler == null) {
|
|
||||||
writeError("No connection handler");
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
String messageString = messageField.getText().strip();
|
String messageString = messageField.getText().strip();
|
||||||
messageField.clear();
|
|
||||||
Matcher matcher = messagePattern.matcher(messageString);
|
|
||||||
if (matcher.find()) {
|
|
||||||
String receiver = matcher.group(1);
|
|
||||||
String message = matcher.group(2);
|
|
||||||
if (receiver == null || receiver.isBlank()) receiver = ClientConnectionHandler.USER_ALL;
|
|
||||||
try {
|
try {
|
||||||
connectionHandler.message(receiver, message);
|
if (connectionHandler == null) {
|
||||||
} catch (ChatProtocolException e) {
|
addError("No connection handler");
|
||||||
writeError(e.getMessage());
|
} else if (!connectionHandler.message(messageString)) {
|
||||||
}
|
addError("Not a valid message format.");
|
||||||
} else {
|
} else {
|
||||||
writeError("Not a valid message format.");
|
messageField.clear();
|
||||||
|
}
|
||||||
|
} catch (ChatProtocolException e) {
|
||||||
|
addError(e.getMessage());
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -170,42 +166,25 @@ public class ChatWindowController {
|
||||||
}
|
}
|
||||||
|
|
||||||
public void addMessage(String sender, String receiver, String message) {
|
public void addMessage(String sender, String receiver, String message) {
|
||||||
messages.addMessage(ClientMessageList.MessageType.MESSAGE, sender, receiver, message);
|
messages.addMessage(new Message(Message.MessageType.MESSAGE, sender, receiver, message));
|
||||||
this.redrawMessageList();
|
this.redrawMessageList();
|
||||||
}
|
}
|
||||||
|
|
||||||
public void addInfo(String message) {
|
public void addInfo(String message) {
|
||||||
messages.addMessage(ClientMessageList.MessageType.INFO, null, null, message);
|
messages.addMessage(new Message(Message.MessageType.INFO, null, null, message));
|
||||||
this.redrawMessageList();
|
this.redrawMessageList();
|
||||||
}
|
}
|
||||||
|
|
||||||
public void addError(String message) {
|
public void addError(String message) {
|
||||||
messages.addMessage(ClientMessageList.MessageType.ERROR, null, null, message);
|
messages.addMessage(new Message(Message.MessageType.ERROR, null, null, message));
|
||||||
this.redrawMessageList();
|
this.redrawMessageList();
|
||||||
}
|
}
|
||||||
|
|
||||||
public void clearMessageArea() {
|
|
||||||
this.messageArea.clear();
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
private void redrawMessageList() {
|
private void redrawMessageList() {
|
||||||
Platform.runLater(() -> messages.writeFilteredMessages(filterValue.getText().strip()));
|
this.messageArea.clear();
|
||||||
|
Platform.runLater(() -> this.messageArea.setText(messages.getFilteredMessages(filterValue.getText().strip())));
|
||||||
}
|
}
|
||||||
|
|
||||||
public void writeError(String message) {
|
|
||||||
this.messageArea.appendText(String.format("[ERROR] %s\n", message));
|
|
||||||
}
|
|
||||||
|
|
||||||
public void writeInfo(String message) {
|
|
||||||
this.messageArea.appendText(String.format("[INFO] %s\n", message));
|
|
||||||
}
|
|
||||||
|
|
||||||
public void writeMessage(String sender, String reciever, String message) {
|
|
||||||
this.messageArea.appendText(String.format("[%s -> %s] %s\n", sender, reciever, message));
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
class WindowCloseHandler implements EventHandler<WindowEvent> {
|
class WindowCloseHandler implements EventHandler<WindowEvent> {
|
||||||
public void handle(WindowEvent event) {
|
public void handle(WindowEvent event) {
|
||||||
applicationClose();
|
applicationClose();
|
||||||
|
@ -213,7 +192,4 @@ public class ChatWindowController {
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
|
@ -7,6 +7,8 @@ import java.io.EOFException;
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.net.SocketException;
|
import java.net.SocketException;
|
||||||
import java.util.Scanner;
|
import java.util.Scanner;
|
||||||
|
import java.util.regex.Matcher;
|
||||||
|
import java.util.regex.Pattern;
|
||||||
|
|
||||||
import static ch.zhaw.pm2.multichat.client.ClientConnectionHandler.State.*;
|
import static ch.zhaw.pm2.multichat.client.ClientConnectionHandler.State.*;
|
||||||
|
|
||||||
|
@ -24,6 +26,8 @@ public class ClientConnectionHandler implements Runnable {
|
||||||
public static final String USER_NONE = "";
|
public static final String USER_NONE = "";
|
||||||
public static final String USER_ALL = "*";
|
public static final String USER_ALL = "*";
|
||||||
|
|
||||||
|
private final Pattern messagePattern = Pattern.compile( "^(?:@(\\w*))?\\s*(.*)$" );
|
||||||
|
|
||||||
private String userName = USER_NONE;
|
private String userName = USER_NONE;
|
||||||
private State state = NEW;
|
private State state = NEW;
|
||||||
|
|
||||||
|
@ -194,9 +198,22 @@ public class ClientConnectionHandler implements Runnable {
|
||||||
this.setState(CONFIRM_DISCONNECT);
|
this.setState(CONFIRM_DISCONNECT);
|
||||||
}
|
}
|
||||||
|
|
||||||
public void message(String receiver, String message) throws ChatProtocolException {
|
public boolean message(String messageString) throws ChatProtocolException {
|
||||||
if (state != CONNECTED) throw new ChatProtocolException("Illegal state for message: " + state);
|
if (state != CONNECTED) throw new ChatProtocolException("Illegal state for message: " + state);
|
||||||
|
|
||||||
|
Matcher matcher = messagePattern.matcher(messageString);
|
||||||
|
if (matcher.find()) {
|
||||||
|
String receiver = matcher.group(1);
|
||||||
|
String message = matcher.group(2);
|
||||||
|
if(message.length() < 1){
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
if (receiver == null || receiver.isBlank()) receiver = ClientConnectionHandler.USER_ALL;
|
||||||
this.sendData(userName, receiver, DATA_TYPE_MESSAGE,message);
|
this.sendData(userName, receiver, DATA_TYPE_MESSAGE,message);
|
||||||
|
return true;
|
||||||
|
} else {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
|
@ -2,50 +2,34 @@ package ch.zhaw.pm2.multichat.client;
|
||||||
|
|
||||||
import java.util.ArrayList;
|
import java.util.ArrayList;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
import java.util.Objects;
|
|
||||||
|
|
||||||
public class ClientMessageList {
|
public class ClientMessageList {
|
||||||
private final List<MessageType> typeList = new ArrayList<>();
|
private List<Message> messages = new ArrayList<>();
|
||||||
private final List<String> senderList = new ArrayList<>();
|
|
||||||
private final List<String> receiverList = new ArrayList<>();
|
|
||||||
private final List<String> messageList = new ArrayList<>();
|
|
||||||
private final ChatWindowController gui;
|
|
||||||
|
|
||||||
public ClientMessageList(ChatWindowController gui) {
|
|
||||||
this.gui = gui;
|
public void addMessage(Message message) {
|
||||||
|
messages.add(message);
|
||||||
}
|
}
|
||||||
|
|
||||||
public void addMessage(MessageType type, String sender, String receiver, String message) {
|
public String getFilteredMessages(String filter) {
|
||||||
typeList.add(type);
|
StringBuilder result = new StringBuilder();
|
||||||
senderList.add(sender);
|
|
||||||
receiverList.add(receiver);
|
|
||||||
messageList.add(message);
|
|
||||||
}
|
|
||||||
|
|
||||||
public void writeFilteredMessages(String filter) {
|
|
||||||
boolean showAll = filter == null || filter.isBlank();
|
boolean showAll = filter == null || filter.isBlank();
|
||||||
gui.clearMessageArea();
|
for(Message message : messages) {
|
||||||
for(int i=0; i<senderList.size(); i++) {
|
if(showAll || message.matchesFilter(filter))
|
||||||
String sender = Objects.requireNonNullElse(senderList.get(i),"");
|
|
||||||
String receiver = Objects.requireNonNullElse(receiverList.get(i),"");
|
|
||||||
String message = Objects.requireNonNull(messageList.get(i), "");
|
|
||||||
if(showAll ||
|
|
||||||
sender.contains(filter) ||
|
|
||||||
receiver.contains(filter) ||
|
|
||||||
message.contains(filter))
|
|
||||||
{
|
{
|
||||||
switch (typeList.get(i)) {
|
switch (message.getType()) {
|
||||||
case MESSAGE: gui.writeMessage(senderList.get(i), receiverList.get(i), messageList.get(i)); break;
|
case MESSAGE -> result.append(String.format("[%s -> %s] %s\n", message.getSender(), message.getReceiver(), message.getText()));
|
||||||
case ERROR: gui.writeError(messageList.get(i)); break;
|
case ERROR -> result.append(String.format("[ERROR] %s\n", message.getText()));
|
||||||
case INFO: gui.writeInfo(messageList.get(i)); break;
|
case INFO -> result.append(String.format("[INFO] %s\n", message.getText()));
|
||||||
default: gui.writeError("Unexpected message type: " + typeList.get(i));
|
default -> result.append(String.format("[ERROR] %s\n", "Unexpected message type: " + message.getType()));
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
return result.toString();
|
||||||
}
|
}
|
||||||
|
|
||||||
public enum MessageType {
|
public void clear() {
|
||||||
INFO, MESSAGE, ERROR;
|
messages = new ArrayList<>();
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
|
@ -7,6 +7,7 @@ import javafx.scene.layout.Pane;
|
||||||
import javafx.stage.Stage;
|
import javafx.stage.Stage;
|
||||||
|
|
||||||
public class ClientUI extends Application {
|
public class ClientUI extends Application {
|
||||||
|
private ClientMessageList clientMessageList = new ClientMessageList();
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void start(Stage primaryStage) {
|
public void start(Stage primaryStage) {
|
||||||
|
@ -17,6 +18,10 @@ public class ClientUI extends Application {
|
||||||
try {
|
try {
|
||||||
FXMLLoader loader = new FXMLLoader(getClass().getResource("ChatWindow.fxml"));
|
FXMLLoader loader = new FXMLLoader(getClass().getResource("ChatWindow.fxml"));
|
||||||
Pane rootPane = loader.load();
|
Pane rootPane = loader.load();
|
||||||
|
|
||||||
|
ChatWindowController chatWindowController = loader.getController();
|
||||||
|
chatWindowController.setMessages(clientMessageList);
|
||||||
|
|
||||||
// fill in scene and stage setup
|
// fill in scene and stage setup
|
||||||
Scene scene = new Scene(rootPane);
|
Scene scene = new Scene(rootPane);
|
||||||
//scene.getStylesheets().add(getClass().getResource("application.css").toExternalForm());
|
//scene.getStylesheets().add(getClass().getResource("application.css").toExternalForm());
|
||||||
|
|
|
@ -0,0 +1,71 @@
|
||||||
|
package ch.zhaw.pm2.multichat.client;
|
||||||
|
|
||||||
|
/**
|
||||||
|
A Message object represents one Message of a client. Can be stored in ClientMessageList.
|
||||||
|
*/
|
||||||
|
public class Message {
|
||||||
|
private MessageType type;
|
||||||
|
private String sender;
|
||||||
|
private String receiver;
|
||||||
|
private String text;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Constructor of Message. Needs all Information about a Message to save them.
|
||||||
|
* @param type Message (if it's a message typed by a user), Error or Information (if it is generated automatically, in this case sender and reciever will be null)
|
||||||
|
* @param sender The User who has sent the message.
|
||||||
|
* @param receiver The User who should recieve the message.
|
||||||
|
* @param text The Text of the message.
|
||||||
|
*/
|
||||||
|
public Message(MessageType type, String sender, String receiver, String text) {
|
||||||
|
this.type = type;
|
||||||
|
this.sender = sender;
|
||||||
|
this.receiver = receiver;
|
||||||
|
this.text = text;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Checks if the Filter String is contained in one of the datafields sender, receiver or text
|
||||||
|
* @param filter The Filter String
|
||||||
|
* @return true if it the Filter String is contained in a datafield.
|
||||||
|
*/
|
||||||
|
public boolean matchesFilter(String filter){
|
||||||
|
return (sender != null && sender.contains(filter)) ||
|
||||||
|
(receiver != null && receiver.contains(filter)) ||
|
||||||
|
(text != null && text.contains(filter));
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @return The type of the message.
|
||||||
|
*/
|
||||||
|
public MessageType getType() {
|
||||||
|
return type;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @return The User who has sent the Message.
|
||||||
|
*/
|
||||||
|
public String getSender() {
|
||||||
|
return sender;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @return The Reciever who recieves the Message.
|
||||||
|
*/
|
||||||
|
public String getReceiver() {
|
||||||
|
return receiver;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @return The Text of the Message.
|
||||||
|
*/
|
||||||
|
public String getText() {
|
||||||
|
return text;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Enummeration of Message Types.
|
||||||
|
*/
|
||||||
|
public enum MessageType {
|
||||||
|
INFO, MESSAGE, ERROR;
|
||||||
|
}
|
||||||
|
}
|
Loading…
Reference in New Issue