Add dumpsession command

Author: rtm516

bootstrap/geyser/src/main/java/com/rtm516/mcxboxbroadcast/bootstrap/geyser/MCXboxBroadcastExtension.java

@@ -74,6 +74,20 @@ public void onCommandDefine(GeyserDefineCommandsEvent event) {
                 createSession();
             })
             .build());
+
+        event.register(Command.builder(this)
+            .source(CommandSource.class)
+            .name("dumpsession")
+            .description("Dump the current session to json files.")
+            .executor((source, command, args) -> {
+                if (!source.isConsole()) {
+                    source.sendMessage("This command can only be ran from the console.");
+                    return;
+                }
+
+                sessionManager.dumpSession();
+            })
+            .build());
     }
 
     @Subscribe

bootstrap/standalone/src/main/java/com/rtm516/mcxboxbroadcast/bootstrap/standalone/StandaloneLoggerImpl.java

@@ -53,6 +53,7 @@ protected void runCommand(String command) {
             switch (commandNode) {
                 case "exit" -> System.exit(0);
                 case "restart" -> StandaloneMain.restart();
+                case "dumpsession" -> StandaloneMain.sessionManager.dumpSession();
                 default -> logger.warn("Unknown command: {}", commandNode);
             }
         } catch (Exception e) {

bootstrap/standalone/src/main/java/com/rtm516/mcxboxbroadcast/bootstrap/standalone/StandaloneMain.java

@@ -26,10 +26,11 @@
 public class StandaloneMain {
     private static StandaloneConfig config;
     private static StandaloneLoggerImpl logger;
-    private static SessionManager sessionManager;
     private static SessionInfo sessionInfo;
     private static ScheduledExecutorService scheduledThreadPool;
 
+    public static SessionManager sessionManager;
+
     public static void main(String[] args) throws Exception {
         logger = new StandaloneLoggerImpl(LoggerFactory.getLogger(StandaloneMain.class));
 

core/src/main/java/com/rtm516/mcxboxbroadcast/core/SessionManager.java

@@ -10,6 +10,7 @@
 import com.rtm516.mcxboxbroadcast.core.models.XboxTokenInfo;
 
 import java.io.File;
+import java.io.FileWriter;
 import java.io.IOException;
 import java.net.URI;
 import java.net.http.HttpClient;
@@ -30,10 +31,13 @@ public class SessionManager {
     private final XboxTokenManager xboxTokenManager;
     private final HttpClient httpClient;
     private final Logger logger;
+    private final String cache;
 
     private RtaWebsocketClient rtaWebsocket;
     private ExpandedSessionInfo sessionInfo;
 
+    private String lastSessionResponse;
+
     /**
      * Create an instance of SessionManager using default values
      */
@@ -63,6 +67,7 @@ public SessionManager(String cache, Logger logger) {
             .build();
 
         this.logger = logger;
+        this.cache = cache;
 
         this.liveTokenManager = new LiveTokenManager(cache, httpClient, logger);
         this.xboxTokenManager = new XboxTokenManager(cache, httpClient, logger);
@@ -239,8 +244,10 @@ private void updateSession() throws SessionUpdateException {
             throw new SessionUpdateException(e.getMessage());
         }
 
+        lastSessionResponse = createSessionResponse.body();
+
         if (createSessionResponse.statusCode() != 200 && createSessionResponse.statusCode() != 201) {
-            logger.debug("Got session response: " + createSessionResponse.body());
+            logger.debug("Got session response: " + lastSessionResponse);
             throw new SessionUpdateException("Unable to update session information, got status " + createSessionResponse.statusCode() + " trying to update");
         }
     }
@@ -424,4 +431,35 @@ public void stopSession() {
         rtaWebsocket.close();
         this.sessionInfo.setSessionId(null);
     }
+
+    public void dumpSession() {
+        logger.info("Dumping current and last session responses");
+        try {
+            FileWriter file = new FileWriter(this.cache + "/lastSessionResponse.json");
+            file.write(lastSessionResponse);
+            file.close();
+        } catch (IOException e) {
+            logger.error("Error dumping last session: " + e.getMessage());
+        }
+
+        HttpRequest createSessionRequest = HttpRequest.newBuilder()
+                .uri(URI.create(Constants.CREATE_SESSION + this.sessionInfo.getSessionId()))
+                .header("Content-Type", "application/json")
+                .header("Authorization", getTokenHeader())
+                .header("x-xbl-contract-version", "107")
+                .GET()
+                .build();
+
+        try {
+            HttpResponse<String> createSessionResponse = httpClient.send(createSessionRequest, HttpResponse.BodyHandlers.ofString());
+
+            FileWriter file = new FileWriter(this.cache + "/currentSessionResponse.json");
+            file.write(createSessionResponse.body());
+            file.close();
+        } catch (IOException | InterruptedException e) {
+            logger.error("Error dumping current session: " + e.getMessage());
+        }
+
+        logger.info("Dumped session responses to 'lastSessionResponse.json' and 'currentSessionResponse.json'");
+    }
 }