Mirror/Grasscutter
1
0
Fork 0
mirror of https://github.com/Grasscutters/Grasscutter.git synced 2025-12-17 01:15:52 +01:00
Code Issues Packages Projects Releases Wiki Activity

Separate the dispatch and game servers (pt. 3)

Browse Source 
implement handbook across servers!
This commit is contained in:
KingRainbow44
2023-05-15 03:36:40 -04:00
parent 639cbb481d
commit 8ecb890fbe
10 changed files with 391 additions and 187 deletions
Download Patch File Download Diff File Expand all files Collapse all files

52
src/main/java/emu/grasscutter/utils/DispatchUtils.java
View File

@@ -1,20 +1,24 @@
package emu.grasscutter.utils;
import static emu.grasscutter.config.Configuration.DISPATCH_INFO;
import com.google.gson.JsonObject;
import emu.grasscutter.Grasscutter;
import emu.grasscutter.auth.AuthenticationSystem.AuthenticationRequest;
import emu.grasscutter.database.DatabaseHelper;
import emu.grasscutter.game.Account;
import emu.grasscutter.game.HandbookActions;
import emu.grasscutter.server.dispatch.IDispatcher;
import emu.grasscutter.server.dispatch.PacketIds;
import emu.grasscutter.server.http.handlers.GachaHandler;
import emu.grasscutter.server.http.objects.LoginTokenRequestJson;
import emu.grasscutter.utils.objects.HandbookBody;
import emu.grasscutter.utils.objects.HandbookBody.*;
import javax.annotation.Nullable;
import java.net.http.HttpClient;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.TimeUnit;
import javax.annotation.Nullable;
import static emu.grasscutter.config.Configuration.DISPATCH_INFO;
public interface DispatchUtils {
/** HTTP client used for dispatch queries. */
@@ -112,4 +116,46 @@ public interface DispatchUtils {
}
};
}
/**
* Performs a handbook action.
*
* @param action The action.
* @param data The data.
* @return The response.
*/
static Response performHandbookAction(HandbookBody.Action action, Object data) {
return switch (Grasscutter.getRunMode()) {
case DISPATCH_ONLY -> {
// Create a request for the 'GM Talk' action.
var request = new JsonObject();
request.addProperty("action", action.name());
request.add("data", JsonUtils.toJson(data));
// Create a future for the response.
var future = new CompletableFuture<Response>();
// Listen for the response.
var server = Grasscutter.getDispatchServer();
server.registerCallback(PacketIds.GmTalkRsp, packet ->
future.complete(IDispatcher.decode(packet, Response.class)));
// Broadcast the request.
server.sendMessage(PacketIds.GmTalkReq, request);
try {
// Wait for the response.
yield future.get(5L, TimeUnit.SECONDS);
} catch (Exception ignored) {
yield Response.builder().status(400)
.message("No response received from any server.").build();
}
}
case HYBRID, GAME_ONLY -> switch (action) {
case GRANT_AVATAR -> HandbookActions.grantAvatar((GrantAvatar) data);
case GIVE_ITEM -> HandbookActions.giveItem((GiveItem) data);
case TELEPORT_TO -> HandbookActions.teleportTo((TeleportTo) data);
case SPAWN_ENTITY -> HandbookActions.spawnEntity((SpawnEntity) data);
};
};
}
}