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

Format code [skip actions]

Browse Source
This commit is contained in:
github-actions
2023-05-15 07:39:29 +00:00
parent 8ecb890fbe
commit 44003f4ee6
8 changed files with 91 additions and 114 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -1,5 +1,7 @@
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;
@@ -12,13 +14,10 @@ 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 static emu.grasscutter.config.Configuration.DISPATCH_INFO;
import javax.annotation.Nullable;
public interface DispatchUtils {
/** HTTP client used for dispatch queries. */
@@ -136,8 +135,9 @@ public interface DispatchUtils {
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)));
server.registerCallback(
PacketIds.GmTalkRsp,
packet -> future.complete(IDispatcher.decode(packet, Response.class)));
// Broadcast the request.
server.sendMessage(PacketIds.GmTalkReq, request);
@@ -146,8 +146,10 @@ public interface DispatchUtils {
// 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();
yield Response.builder()
.status(400)
.message("No response received from any server.")
.build();
}
}
case HYBRID, GAME_ONLY -> switch (action) {