original code
This commit is contained in:
parent
9f2ad2d73a
commit
1cbe4aa462
|
@ -9,7 +9,3 @@
|
|||
# Maven
|
||||
log/
|
||||
target/
|
||||
dependency-reduced-pom.xml
|
||||
|
||||
# Java
|
||||
*.jar
|
||||
|
|
2
pom.xml
2
pom.xml
|
@ -143,7 +143,7 @@
|
|||
<dependency>
|
||||
<groupId>org.mongodb</groupId>
|
||||
<artifactId>mongodb-driver-async</artifactId>
|
||||
<version>3.2.2</version>
|
||||
<version>3.12.11</version>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>fr.javatic.mongo</groupId>
|
||||
|
|
|
@ -25,7 +25,7 @@ public final class POSTServerGroups implements Handler<RoutingContext> {
|
|||
String image = requestBody.getString("image");
|
||||
|
||||
ServerGroup serverGroup = new ServerGroup(id, image);
|
||||
SyncUtils.<Void>runBlocking(v -> serverGroup.insert(v));
|
||||
SyncUtils.<Void>runBlocking(serverGroup::insert);
|
||||
|
||||
if (requestBody.containsKey("addedBy")) {
|
||||
AuditLog.log(UuidUtils.parseUuid(requestBody.getString("addedBy")), requestBody.getString("addedByIp"), ctx, AuditLogActionType.SERVER_GROUP_CREATE, ImmutableMap.of("serverGroupId", id), (ignored, error) -> {
|
||||
|
|
|
@ -48,6 +48,7 @@ public final class POSTServersHeartbeat implements Handler<RoutingContext> {
|
|||
|
||||
Server actorServer = Server.findById(actor.getName());
|
||||
JsonObject requestBody = ctx.getBodyAsJson();
|
||||
System.out.println("body: " + requestBody);
|
||||
JsonObject players = requestBody.getJsonObject("players");
|
||||
Map<UUID, String> playerNames = extractPlayerNames(players);
|
||||
Map<UUID, String> playerIps = extractPlayerIps(players);
|
||||
|
@ -67,6 +68,7 @@ public final class POSTServersHeartbeat implements Handler<RoutingContext> {
|
|||
"events", result.result().result(3)
|
||||
));
|
||||
} else {
|
||||
result.cause().printStackTrace();
|
||||
ErrorUtils.respondInternalError(ctx, result.cause());
|
||||
}
|
||||
});
|
||||
|
@ -75,14 +77,16 @@ public final class POSTServersHeartbeat implements Handler<RoutingContext> {
|
|||
private Future<Void> createInfoResponse(Server server, double tps, Map<UUID, String> playerNames) {
|
||||
Future<Void> callback = Future.future();
|
||||
|
||||
server.receivedHeartbeat(tps, playerNames.keySet());
|
||||
server.save((ignored, error) -> {
|
||||
if (error != null) {
|
||||
callback.fail(error);
|
||||
} else {
|
||||
callback.complete();
|
||||
}
|
||||
});
|
||||
if (server != null && playerNames != null) {
|
||||
server.receivedHeartbeat(tps, playerNames.keySet());
|
||||
server.save((ignored, error) -> {
|
||||
if (error != null) {
|
||||
callback.fail(error);
|
||||
} else {
|
||||
callback.complete();
|
||||
}
|
||||
});
|
||||
}
|
||||
|
||||
return callback;
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue