Lanmikeman/Launcher
1
1
Fork 0
mirror of https://github.com/GravitLauncher/Launcher synced 2024-11-15 03:31:15 +03:00
Code Issues Projects Releases Packages Wiki Activity

[FEATURE][EXP] Возможность обрабатывать сообщения WebSocket...

Browse source
This commit is contained in:
Zaxar163 2019-09-27 19:31:09 +02:00
parent 0ff391778a
commit f89fabaf11
No known key found for this signature in database
GPG key ID: 1FE4F2E1F053831B
1 changed files with 2 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
LaunchServer/src/main/java/pro/gravit/launchserver/socket/WebSocketService.java
View file

@ -37,6 +37,7 @@
public class WebSocketService { public class WebSocketService {
public final ChannelGroup channels; public final ChannelGroup channels;
public static ProviderMap<WebSocketServerResponse> providers = new ProviderMap<>(); public static ProviderMap<WebSocketServerResponse> providers = new ProviderMap<>();
public final BiHookSet<TextWebSocketFrame, ChannelHandlerContext> packetHook = new BiHookSet<>();
public static class WebSocketRequestContext public static class WebSocketRequestContext
{ {
public WebSocketServerResponse response; public WebSocketServerResponse response;
@ -64,6 +65,7 @@ public WebSocketService(ChannelGroup channels, LaunchServer server) {
private final Gson gson; private final Gson gson;
public void process(ChannelHandlerContext ctx, TextWebSocketFrame frame, Client client, String ip) { public void process(ChannelHandlerContext ctx, TextWebSocketFrame frame, Client client, String ip) {
if (packetHook.hook(frame, ctx)) return;
String request = frame.text(); String request = frame.text();
WebSocketServerResponse response = gson.fromJson(request, WebSocketServerResponse.class); WebSocketServerResponse response = gson.fromJson(request, WebSocketServerResponse.class);
process(ctx, response, client, ip); process(ctx, response, client, ip);