2020-01-11 18:28:48 +01:00
|
|
|
package envoy.server.processors;
|
|
|
|
|
|
|
|
import java.io.IOException;
|
2020-06-20 09:57:54 +02:00
|
|
|
import java.time.LocalDateTime;
|
2020-06-11 12:06:06 +02:00
|
|
|
import java.util.logging.Logger;
|
2020-01-11 18:28:48 +01:00
|
|
|
|
2020-04-09 22:31:20 +02:00
|
|
|
import javax.persistence.EntityExistsException;
|
|
|
|
|
2020-01-11 18:28:48 +01:00
|
|
|
import envoy.data.Message;
|
2020-06-10 23:01:10 +02:00
|
|
|
import envoy.data.Message.MessageStatus;
|
2020-02-15 22:43:20 +01:00
|
|
|
import envoy.server.data.PersistenceManager;
|
2020-02-12 22:01:32 +01:00
|
|
|
import envoy.server.net.ConnectionManager;
|
2020-01-11 18:28:48 +01:00
|
|
|
import envoy.server.net.ObjectWriteProxy;
|
2020-06-11 12:06:06 +02:00
|
|
|
import envoy.util.EnvoyLog;
|
2020-01-11 18:28:48 +01:00
|
|
|
|
|
|
|
/**
|
|
|
|
* 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
|
2020-03-25 18:22:58 +01:00
|
|
|
* @author Maximilian Käfer
|
2020-01-11 18:28:48 +01:00
|
|
|
* @since Envoy Server Standalone v0.1-alpha
|
|
|
|
*/
|
|
|
|
public class MessageProcessor implements ObjectProcessor<Message> {
|
|
|
|
|
2020-06-11 12:06:06 +02:00
|
|
|
private static final Logger logger = EnvoyLog.getLogger(MessageProcessor.class);
|
|
|
|
|
2020-01-11 18:28:48 +01:00
|
|
|
@Override
|
2020-03-26 20:14:09 +01:00
|
|
|
public void process(Message message, long socketID, ObjectWriteProxy writeProxy) {
|
2020-06-14 16:40:51 +02:00
|
|
|
if (message.getStatus() != MessageStatus.WAITING) {
|
2020-06-14 16:30:46 +02:00
|
|
|
logger.warning("Received message with invalid status: " + message);
|
|
|
|
return;
|
|
|
|
}
|
2020-01-11 18:28:48 +01:00
|
|
|
message.nextStatus();
|
2020-06-23 09:08:57 +02:00
|
|
|
ConnectionManager connectionManager = ConnectionManager.getInstance();
|
2020-03-25 18:22:58 +01:00
|
|
|
|
2020-04-18 13:27:43 +02:00
|
|
|
sendToUser(connectionManager, message, writeProxy);
|
2020-04-09 22:31:20 +02:00
|
|
|
try {
|
|
|
|
PersistenceManager.getInstance().addMessage(new envoy.server.data.Message(message));
|
|
|
|
} catch (EntityExistsException e) {
|
2020-06-11 12:06:06 +02:00
|
|
|
logger.warning("Received a message with an id that already exists");
|
2020-04-09 22:31:20 +02:00
|
|
|
}
|
2020-03-25 18:22:58 +01:00
|
|
|
}
|
|
|
|
|
|
|
|
private void sendToUser(ConnectionManager connectionManager, Message message, ObjectWriteProxy writeProxy) {
|
2020-03-26 16:06:55 +01:00
|
|
|
if (connectionManager.isOnline(message.getRecipientID())) try {
|
2020-01-28 19:25:30 +01:00
|
|
|
// If recipient is online, send the message directly
|
2020-06-14 16:40:51 +02:00
|
|
|
writeProxy.write(connectionManager.getSocketID(message.getRecipientID()), message);
|
2020-01-28 19:25:30 +01:00
|
|
|
// Update the message status to RECEIVED
|
2020-06-20 09:57:54 +02:00
|
|
|
message.setReceivedDate(LocalDateTime.now());
|
2020-01-28 19:25:30 +01:00
|
|
|
message.nextStatus();
|
2020-01-11 18:28:48 +01:00
|
|
|
} catch (IOException e) {
|
2020-06-11 12:06:06 +02:00
|
|
|
logger.warning("Recipient online. Failed to send message" + message.getID());
|
2020-01-11 18:28:48 +01:00
|
|
|
e.printStackTrace();
|
|
|
|
}
|
|
|
|
}
|
2020-03-25 18:22:58 +01:00
|
|
|
|
2020-02-15 22:47:14 +01:00
|
|
|
@Override
|
|
|
|
public Class<Message> getInputClass() { return Message.class; }
|
2020-01-11 18:28:48 +01:00
|
|
|
}
|