82 lines
3.1 KiB
Java
Executable File
82 lines
3.1 KiB
Java
Executable File
package envoy.server.processors;
|
|
|
|
import java.io.IOException;
|
|
import java.util.Date;
|
|
|
|
import envoy.data.Message;
|
|
import envoy.data.Message.MessageStatus;
|
|
import envoy.data.MessageBuilder;
|
|
import envoy.event.MessageStatusChangeEvent;
|
|
import envoy.server.data.Contact;
|
|
import envoy.server.data.PersistenceManager;
|
|
import envoy.server.net.ConnectionManager;
|
|
import envoy.server.net.ObjectWriteProxy;
|
|
|
|
/**
|
|
* This {@link ObjectProcessor} handles incoming {@link Message}s.<br>
|
|
* <br>
|
|
* Project: <strong>envoy-server-standalone</strong><br>
|
|
* File: <strong>MessageProcessor.java</strong><br>
|
|
* Created: <strong>30.12.2019</strong><br>
|
|
*
|
|
* @author Kai S. K. Engelbart
|
|
* @author Maximilian Käfer
|
|
* @since Envoy Server Standalone v0.1-alpha
|
|
*/
|
|
public class MessageProcessor implements ObjectProcessor<Message> {
|
|
|
|
@Override
|
|
public void process(Message message, long socketID, ObjectWriteProxy writeProxy) {
|
|
message.nextStatus();
|
|
ConnectionManager connectionManager = ConnectionManager.getInstance();
|
|
Contact recipient = PersistenceManager.getInstance().getContactByID(message.getID());
|
|
|
|
if (recipient instanceof envoy.server.data.User) {
|
|
System.out.println("The received message is a direct message.");
|
|
sendToUser(connectionManager, message, writeProxy);
|
|
// Sending a messageStatusChangeEvent to the sender
|
|
try {
|
|
writeProxy.write(socketID, new MessageStatusChangeEvent(message));
|
|
} catch (IOException e) {
|
|
System.err.println("Could not send messageStatusChangeEvent to the sender of this message with ID: " + message.getID());
|
|
e.printStackTrace();
|
|
}
|
|
} else {
|
|
System.out.println("The received message is a group message.");
|
|
final var members = PersistenceManager.getInstance().getGroupByID(message.getRecipientID()).getContacts();
|
|
final var generator = IDGeneratorRequestProcessor.createIDGenerator(members.size());
|
|
members.forEach(user -> {
|
|
envoy.data.Message returnMessage = new MessageBuilder(message.getRecipientID(), user.getID(), generator)
|
|
.setDate(message.getCreationDate())
|
|
.setText(message.getText())
|
|
.setAttachment(message.getAttachment())
|
|
.setStatus(MessageStatus.SENT)
|
|
.setForwarded(message.isForwarded())
|
|
.build();
|
|
sendToUser(connectionManager, returnMessage, writeProxy);
|
|
|
|
// TODO Handle messageStatusChangeEvent because we have many recipients and
|
|
// copies of the original message. (Not at this location)
|
|
});
|
|
}
|
|
PersistenceManager.getInstance().addMessage(new envoy.server.data.Message(message));
|
|
}
|
|
|
|
private void sendToUser(ConnectionManager connectionManager, Message message, ObjectWriteProxy writeProxy) {
|
|
if (connectionManager.isOnline(message.getRecipientID())) try {
|
|
// If recipient is online, send the message directly
|
|
writeProxy.write(connectionManager.getSocketId(message.getRecipientID()), message);
|
|
// Update the message status to RECEIVED
|
|
message.setReceivedDate(new Date());
|
|
message.nextStatus();
|
|
|
|
} catch (IOException e) {
|
|
System.err.println("Recipient online. Failed to send message" + message.getID());
|
|
e.printStackTrace();
|
|
}
|
|
}
|
|
|
|
@Override
|
|
public Class<Message> getInputClass() { return Message.class; }
|
|
}
|