55 lines
1.8 KiB
Java
Executable File
55 lines
1.8 KiB
Java
Executable File
package envoy.server.processors;
|
|
|
|
import java.io.IOException;
|
|
|
|
import envoy.data.IDGenerator;
|
|
import envoy.event.IDGeneratorRequest;
|
|
import envoy.server.data.ConfigItem;
|
|
import envoy.server.data.PersistenceManager;
|
|
import envoy.server.net.ObjectWriteProxy;
|
|
|
|
/**
|
|
* Project: <strong>envoy-server-standalone</strong><br>
|
|
* File: <strong>IDGeneratorRequestProcessor.java</strong><br>
|
|
* Created: <strong>28 Jan 2020</strong><br>
|
|
*
|
|
* @author Kai S. K. Engelbart
|
|
* @author Maximilian Käfer
|
|
* @since Envoy Server Standalone v0.1-alpha
|
|
*/
|
|
public class IDGeneratorRequestProcessor implements ObjectProcessor<IDGeneratorRequest> {
|
|
|
|
private static final long ID_RANGE = 200;
|
|
|
|
@Override
|
|
public Class<IDGeneratorRequest> getInputClass() { return IDGeneratorRequest.class; }
|
|
|
|
@Override
|
|
public void process(IDGeneratorRequest input, long socketId, ObjectWriteProxy writeProxy) throws IOException {
|
|
System.out.println("Received id generation request.");
|
|
var generator = createIDGenerator();
|
|
|
|
System.out.println("Sending new id generator " + generator);
|
|
writeProxy.write(socketId, generator);
|
|
}
|
|
|
|
/**
|
|
* @return a new IDGenerator
|
|
* @since Envoy Server Standalone v0.1-beta
|
|
*/
|
|
public static IDGenerator createIDGenerator() { return createIDGenerator(ID_RANGE); }
|
|
|
|
/**
|
|
* @param range of IDs used by the new IDGenerator
|
|
* @return a new IDGenerator with a specific range of IDs
|
|
* @since Envoy Server Standalone v0.1-beta
|
|
*/
|
|
public static IDGenerator createIDGenerator(long range) {
|
|
ConfigItem currentId = PersistenceManager.getInstance().getConfigItemById("currentMessageId");
|
|
IDGenerator generator = new IDGenerator(Integer.parseInt(currentId.getValue()), range);
|
|
currentId.setValue(String.valueOf(Integer.parseInt(currentId.getValue()) + range));
|
|
PersistenceManager.getInstance().updateConfigItem(currentId);
|
|
return generator;
|
|
}
|
|
}
|