119 lines
3.8 KiB
Java
119 lines
3.8 KiB
Java
package envoy.client.net;
|
|
|
|
import java.io.IOException;
|
|
import java.util.logging.Level;
|
|
import java.util.logging.Logger;
|
|
|
|
import envoy.client.data.Cache;
|
|
import envoy.client.data.Context;
|
|
import envoy.client.data.LocalDB;
|
|
import envoy.data.Message;
|
|
import envoy.event.MessageStatusChange;
|
|
import envoy.util.EnvoyLog;
|
|
|
|
/**
|
|
* Implements methods to send {@link Message}s and
|
|
* {@link MessageStatusChange}s to the server or cache them inside a
|
|
* {@link LocalDB} depending on the online status.
|
|
* <p>
|
|
* Project: <strong>envoy-client</strong><br>
|
|
* File: <strong>WriteProxy.java</strong><br>
|
|
* Created: <strong>6 Feb 2020</strong><br>
|
|
*
|
|
* @author Kai S. K. Engelbart
|
|
* @since Envoy Client v0.3-alpha
|
|
*/
|
|
public final class WriteProxy {
|
|
|
|
private final Client client = Context.getInstance().getClient();
|
|
private final LocalDB localDB = Context.getInstance().getLocalDB();
|
|
|
|
private static final Logger logger = EnvoyLog.getLogger(WriteProxy.class);
|
|
|
|
/**
|
|
* Initializes a write proxy using a client and a local database. The
|
|
* corresponding cache processors are injected into the caches.
|
|
*
|
|
* @since Envoy Client v0.3-alpha
|
|
*/
|
|
public WriteProxy() {
|
|
|
|
// Initialize cache processors for messages and message status change events
|
|
localDB.getCacheMap().get(Message.class).setProcessor(msg -> {
|
|
try {
|
|
logger.log(Level.FINER, "Sending cached " + msg);
|
|
client.sendMessage(msg);
|
|
} catch (final IOException e) {
|
|
logger.log(Level.SEVERE, "Could not send cached message: ", e);
|
|
}
|
|
});
|
|
localDB.getCacheMap().get(MessageStatusChange.class).setProcessor(evt -> {
|
|
logger.log(Level.FINER, "Sending cached " + evt);
|
|
try {
|
|
client.sendEvent(evt);
|
|
} catch (final IOException e) {
|
|
logger.log(Level.SEVERE, "Could not send cached message status change event: ", e);
|
|
}
|
|
});
|
|
}
|
|
|
|
/**
|
|
* Sends cached {@link Message}s and {@link MessageStatusChange}s to the
|
|
* server.
|
|
*
|
|
* @since Envoy Client v0.3-alpha
|
|
*/
|
|
public void flushCache() {
|
|
|
|
// supplying default values if not initialized - for some reason these
|
|
// processors can be not defined...
|
|
final var messageCache = localDB.getCacheMap().get(Message.class);
|
|
if (messageCache.getProcessor() == null) messageCache.setProcessor(msg -> {
|
|
try {
|
|
logger.log(Level.FINER, "Sending cached " + msg);
|
|
client.sendMessage(msg);
|
|
} catch (final IOException e) {
|
|
logger.log(Level.SEVERE, "Could not send cached message: ", e);
|
|
}
|
|
});
|
|
final var messageStatusCache = localDB.getCacheMap().get(MessageStatusChange.class);
|
|
if (messageStatusCache.getProcessor() == null) messageStatusCache.setProcessor(evt -> {
|
|
logger.log(Level.FINER, "Sending cached " + evt);
|
|
try {
|
|
client.sendEvent(evt);
|
|
} catch (final IOException e) {
|
|
logger.log(Level.SEVERE, "Could not send cached message status change event: ", e);
|
|
}
|
|
});
|
|
|
|
// sending these solely local objects to the server
|
|
localDB.getCacheMap().getMap().values().forEach(Cache::relay);
|
|
}
|
|
|
|
/**
|
|
* Delivers a message to the server if online. Otherwise the message is cached
|
|
* inside the local database.
|
|
*
|
|
* @param message the message to send
|
|
* @throws IOException if the message could not be sent
|
|
* @since Envoy Client v0.3-alpha
|
|
*/
|
|
public void writeMessage(Message message) throws IOException {
|
|
if (client.isOnline()) client.sendMessage(message);
|
|
else localDB.getCacheMap().getApplicable(Message.class).accept(message);
|
|
}
|
|
|
|
/**
|
|
* Delivers a message status change event to the server if online. Otherwise the
|
|
* event is cached inside the local database.
|
|
*
|
|
* @param evt the event to send
|
|
* @throws IOException if the event could not be sent
|
|
* @since Envoy Client v0.3-alpha
|
|
*/
|
|
public void writeMessageStatusChange(MessageStatusChange evt) throws IOException {
|
|
if (client.isOnline()) client.sendEvent(evt);
|
|
else localDB.getCacheMap().getApplicable(MessageStatusChange.class).accept(evt);
|
|
}
|
|
}
|