4e385396ad
(if they were not already)... Additionally renamed some methods named `...Id()` to `...ID()`
43 lines
1.7 KiB
Java
Executable File
43 lines
1.7 KiB
Java
Executable File
package envoy.server.processors;
|
|
|
|
import java.io.IOException;
|
|
|
|
import envoy.data.Message.MessageStatus;
|
|
import envoy.event.MessageStatusChangeEvent;
|
|
import envoy.exception.EnvoyException;
|
|
import envoy.server.data.PersistenceManager;
|
|
import envoy.server.net.ConnectionManager;
|
|
import envoy.server.net.ObjectWriteProxy;
|
|
|
|
/**
|
|
* Project: <strong>envoy-server-standalone</strong><br>
|
|
* File: <strong>MessageStatusChangeProcessor.java</strong><br>
|
|
* Created: <strong>10 Jan 2020</strong><br>
|
|
*
|
|
* @author Leon Hofmeister
|
|
* @since Envoy Server Standalone v0.1-alpha
|
|
*/
|
|
public class MessageStatusChangeProcessor implements ObjectProcessor<MessageStatusChangeEvent> {
|
|
|
|
private final PersistenceManager persistenceManager = PersistenceManager.getInstance();
|
|
private final ConnectionManager connectionManager = ConnectionManager.getInstance();
|
|
|
|
@Override
|
|
public void process(MessageStatusChangeEvent input, long socketID, ObjectWriteProxy writeProxy) throws IOException {
|
|
// Any other status than READ is not supposed to be sent to the server
|
|
if (input.get() != MessageStatus.READ) throw new IOException(new EnvoyException("Message " + input + " has an invalid status"));
|
|
|
|
envoy.server.data.Message msg = persistenceManager.getMessageByID(input.getID());
|
|
msg.setStatus(input.get());
|
|
msg.setReadDate(input.getDate());
|
|
persistenceManager.updateMessage(msg);
|
|
|
|
// Notifies the sender of the message about the status-update to READ
|
|
final long senderId = msg.getSender().getID();
|
|
if (connectionManager.isOnline(senderId)) writeProxy.write(connectionManager.getSocketId(senderId), input);
|
|
}
|
|
|
|
@Override
|
|
public Class<MessageStatusChangeEvent> getInputClass() { return MessageStatusChangeEvent.class; }
|
|
}
|