Minor refactor

This commit is contained in:
simon 2018-03-11 13:34:10 -04:00
parent cbb07891fc
commit 1d780f7d9b
4 changed files with 17 additions and 18 deletions

View File

@ -9,18 +9,17 @@ import org.json.simple.parser.ParseException;
import java.util.ArrayList;
public class MessageEventDispatcher {
public class MessageDispatcher {
private ArrayList<MessageHandler> handlers = new ArrayList<>(10);
public MessageEventDispatcher() {
public MessageDispatcher() {
}
public void addHandler(MessageHandler handler) {
handlers.add(handler);
}
public void dispatch(OnlineUser user, String message) {

View File

@ -42,7 +42,7 @@ public class SocketServer extends WebSocketServer {
private SocketServerDatabase database;
private MessageEventDispatcher messageEventDispatcher = new MessageEventDispatcher();
private MessageDispatcher messageDispatcher = new MessageDispatcher();
public SocketServer(InetSocketAddress address, ServerConfiguration config) {
super(address);
@ -64,14 +64,14 @@ public class SocketServer extends WebSocketServer {
database = new SocketServerDatabase(config);
messageEventDispatcher.addHandler(new UserInfoRequestHandler());
messageEventDispatcher.addHandler(new TerrainRequestHandler());
messageEventDispatcher.addHandler(new ObjectsRequestHandler());
messageEventDispatcher.addHandler(new CodeUploadHandler());
messageEventDispatcher.addHandler(new CodeRequestHandler());
messageEventDispatcher.addHandler(new KeypressHandler());
messageEventDispatcher.addHandler(new FloppyHandler());
messageEventDispatcher.addHandler(new DebugCommandHandler());
messageDispatcher.addHandler(new UserInfoRequestHandler());
messageDispatcher.addHandler(new TerrainRequestHandler());
messageDispatcher.addHandler(new ObjectsRequestHandler());
messageDispatcher.addHandler(new CodeUploadHandler());
messageDispatcher.addHandler(new CodeRequestHandler());
messageDispatcher.addHandler(new KeypressHandler());
messageDispatcher.addHandler(new FloppyHandler());
messageDispatcher.addHandler(new DebugCommandHandler());
}
@ -95,7 +95,7 @@ public class SocketServer extends WebSocketServer {
if (onlineUser.isAuthenticated()) {
messageEventDispatcher.dispatch(onlineUser, message);
messageDispatcher.dispatch(onlineUser, message);
} else {
LogManager.LOGGER.info("(WS) Received message from unauthenticated user " + conn.getRemoteSocketAddress());

View File

@ -18,7 +18,7 @@ public class TerrainRequestHandler implements MessageHandler {
try {
world = GameServer.INSTANCE.getGameUniverse().getWorld(
Long.valueOf((long) json.get("x")).intValue(),
Long.valueOf((long) json.get("y")).intValue(), true,
Long.valueOf((long) json.get("y")).intValue(), false,
(String) json.get("dimension"));
} catch (NullPointerException e) {
LogManager.LOGGER.severe("FIXME: handle TerrainRequestHandler");

View File

@ -95,9 +95,9 @@ user_timeout=100
# ----------------------------------------------
vault_door_open_time=4
electric_box_hp=250
min_electric_box_count=3
min_electric_box_respawn_count=3
max_electric_box_respawn_count=5
electric_box_respawnTime=64
min_electric_box_count=1
min_electric_box_respawn_count=1
max_electric_box_respawn_count=4
electric_box_respawnTime=256
electric_box_damage=5
electric_box_energy_given=70