Michal
/
jNetServer
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

pridano zapisovani logu kdy je ping zapnut nebo vypnut u editovaneho objektu

NettyPing
Michal 2025-02-14 20:26:41 +01:00
parent f409ec2c08
commit 5cf173d60b
1 changed files with 36 additions and 24 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

60
src/jnet/server/ServerMessageParser.java
View File

@ -56,7 +56,7 @@ public class ServerMessageParser {
int platform = Integer.parseInt(userData[2]); int platform = Integer.parseInt(userData[2]);
User u = Database.getUserInfo(username); User u = Database.getUserInfo(username);
if (PasswordHashing.verify(password, u.getPassword())) { if (PasswordHashing.verify(password, u.getPassword())) {
LogFile.printInfo("User: " + username + " logged in (" + ((InetSocketAddress) currentClient.remoteAddress()).getAddress().getHostName() + ")"); LogFile.printInfo("User: " + username + " logged in (" + ((InetSocketAddress) currentClient.remoteAddress()).getAddress().getHostName() + ")");
// odeslat informaci uzivateli o jeho uspesnem prihlaseni // odeslat informaci uzivateli o jeho uspesnem prihlaseni
@ -108,12 +108,12 @@ public class ServerMessageParser {
LogFile.printInfo("Authorization failed (ser: " + username + " )"); LogFile.printInfo("Authorization failed (ser: " + username + " )");
} }
break; break;
case Message.RESTART: case Message.RESTART:
LogFile.printInfo("Prijat pozadavek na restart serveru"); LogFile.printInfo("Prijat pozadavek na restart serveru");
Server.restartServer(); Server.restartServer();
break; break;
case Message.UPTIME: case Message.UPTIME:
long uptime = ManagementFactory.getRuntimeMXBean().getUptime(); long uptime = ManagementFactory.getRuntimeMXBean().getUptime();
send(Message.UPTIME, uptime); send(Message.UPTIME, uptime);
@ -166,14 +166,14 @@ public class ServerMessageParser {
for (Map map : Server.maps) { for (Map map : Server.maps) {
for (MapObject object : map.getObjects()) { for (MapObject object : map.getObjects()) {
if (object.getId() == (int) msg.getMsg()) { if (object.getId() == (int) msg.getMsg()) {
// odebere z databaze // odebere z databaze
Database.removeObject(object.getId()); Database.removeObject(object.getId());
// odesle informaci o odebrani objektu klientum // odesle informaci o odebrani objektu klientum
sendAll(new Message(Message.REMOVE_OBJECT, object.getId())); sendAll(new Message(Message.REMOVE_OBJECT, object.getId()));
// odebere ze seznamu // odebere ze seznamu
map.getObjects().remove(object); map.getObjects().remove(object);
break; break;
} }
} }
} }
break; break;
@ -214,15 +214,15 @@ public class ServerMessageParser {
for (Map mapa : Server.maps) { for (Map mapa : Server.maps) {
for (MapObject object : mapa.getObjects()) { for (MapObject object : mapa.getObjects()) {
if (object.getId() == data[0]) { if (object.getId() == data[0]) {
// zmenit pozici // zmenit pozici
object.setX(data[1]); object.setX(data[1]);
object.setY(data[2]); object.setY(data[2]);
// zapsat zmenu do databaze // zapsat zmenu do databaze
Database.objectMove(data[0], data[1], data[2]); Database.objectMove(data[0], data[1], data[2]);
// preposlat zmenu klientum // preposlat zmenu klientum
sendAll(new Message(Message.UPDATE_OBJECT, object)); sendAll(new Message(Message.UPDATE_OBJECT, object));
break; break;
} }
} }
} }
break; break;
@ -234,12 +234,24 @@ public class ServerMessageParser {
for (Map m : Server.maps) { for (Map m : Server.maps) {
for (int i = 0; i < m.getObjects().size(); i++) { for (int i = 0; i < m.getObjects().size(); i++) {
if (m.getObjects().get(i).getId() == mo_u.getId()) { if (m.getObjects().get(i).getId() == mo_u.getId()) {
m.getObjects().set(i, mo_u); // pokud je object vypnuty a dřív nebyl prida log
break; if (!mo_u.isActive() && m.getObjects().get(i).isActive()) {
} Event event_disable = Database.addEvent(mo_u.getId(), "Ping vypnut", Event.TYPE_PING_OFF);
sendAll(new Message(Message.EVENT_NEW, event_disable));
}
// pokud je object zapnutý a dřív nebyl prida log
if (mo_u.isActive() && !m.getObjects().get(i).isActive()) {
Event event_disable = Database.addEvent(mo_u.getId(), "Ping zapnut", Event.TYPE_PING_OFF);
sendAll(new Message(Message.EVENT_NEW, event_disable));
}
// zmeni objekt v seznamu
m.getObjects().set(i, mo_u);
break;
}
} }
} }
// preposlat zmenu klientum // preposlat zmenu klientum
sendAll(new Message(Message.UPDATE_OBJECT, mo_u)); sendAll(new Message(Message.UPDATE_OBJECT, mo_u));
break; break;