Add user presence to show as online and ingame over xbox

Author: rtm516

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

@@ -174,6 +174,7 @@ private void createSession() {
         try {
             logger.info("Setting up Xbox session...");
             sessionManager.createSession(sessionInfo);
+            sessionManager.updatePresence();
             logger.info("Created Xbox session!");
         } catch (SessionCreationException | SessionUpdateException e) {
             logger.error("Failed to create xbox session!", e);
@@ -197,6 +198,7 @@ private void tick() {
         try {
             sessionInfo.setPlayers(this.geyserApi().onlineConnections().size());
             sessionManager.updateSession(sessionInfo);
+            sessionManager.updatePresence();
         } catch (SessionUpdateException e) {
             logger.error("Failed to update session information!", e);
         }

bootstrap/geyser/src/main/resources/config.yml

@@ -8,6 +8,7 @@ remote-port: auto
 
 # The amount of time in seconds to update session information and
 # sync other data
+# Warning: This can be no lower than 20 due to xbox rate limits
 update-interval: 30
 
 # Should Xbox Live friends automatically be whitelisted

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

@@ -92,6 +92,7 @@ private static void createSession() throws SessionCreationException, SessionUpda
         logger.info("Creating session...");
 
         sessionManager.createSession(sessionInfo);
+        sessionManager.updatePresence();
 
         logger.info("Created session!");
 
@@ -104,6 +105,7 @@ private static void createSession() throws SessionCreationException, SessionUpda
 
                 // Update the session
                 sessionManager.updateSession(sessionInfo);
+                sessionManager.updatePresence();
                 logger.info("Updated session!");
             } catch (SessionUpdateException e) {
                 logger.error("Failed to update session", e);

bootstrap/standalone/src/main/resources/config.yml

@@ -1,6 +1,7 @@
 # Core session settings
 session:
   # The amount of time in seconds to update session information
+  # Warning: This can be no lower than 20 due to xbox rate limits
   update-interval: 30
 
   # Should we query the bedrock server to sync the session information

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

@@ -22,7 +22,8 @@ public class Constants {
     public static final URI RTA_WEBSOCKET = URI.create("wss://rta.xboxlive.com/connect");
     public static final URI CREATE_HANDLE = URI.create("https://sessiondirectory.xboxlive.com/handles");
 
-    public static final String PEOPLE = "https://social.xboxlive.com/users/me/people";
+    public static final String PEOPLE = "https://social.xboxlive.com/users/me/people/xuid(%s)";
+    public static final String USER_PRESENCE = "https://userpresence.xboxlive.com/users/xuid(%s)/devices/current/titles/current";
     public static final URI FOLLOWERS = URI.create("https://peoplehub.xboxlive.com/users/me/people/followers");
     public static final URI SOCIAL = URI.create("https://peoplehub.xboxlive.com/users/me/people/social");
     /**

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

@@ -358,7 +358,7 @@ public List<FollowerResponse.Person> getXboxFriends() throws XboxFriendsExceptio
      */
     public boolean addXboxFriend(String xuid) {
         HttpRequest xboxFriendRequest = HttpRequest.newBuilder()
-            .uri(URI.create(Constants.PEOPLE + "/xuid(" + xuid + ")"))
+            .uri(URI.create(Constants.PEOPLE.formatted(xuid)))
             .header("Authorization", getTokenHeader())
             .PUT(HttpRequest.BodyPublishers.noBody())
             .build();
@@ -379,7 +379,7 @@ public boolean addXboxFriend(String xuid) {
      */
     public boolean removeXboxFriend(String xuid) {
         HttpRequest xboxFriendRequest = HttpRequest.newBuilder()
-            .uri(URI.create(Constants.PEOPLE + "/xuid(" + xuid + ")"))
+            .uri(URI.create(Constants.PEOPLE.formatted(xuid)))
             .header("Authorization", getTokenHeader())
             .DELETE()
             .build();
@@ -466,4 +466,24 @@ public void dumpSession() {
 
         logger.info("Dumped session responses to 'lastSessionResponse.json' and 'currentSessionResponse.json'");
     }
+
+    public void updatePresence() {
+        HttpRequest updatePresenceRequest = HttpRequest.newBuilder()
+            .uri(URI.create(Constants.USER_PRESENCE.formatted(getXboxToken().userXUID)))
+            .header("Content-Type", "application/json")
+            .header("Authorization", getTokenHeader())
+            .header("x-xbl-contract-version", "3")
+            .POST(HttpRequest.BodyPublishers.ofString("{\"state\": \"active\"}"))
+            .build();
+
+        try {
+            HttpResponse<Void> updatePresenceResponse = httpClient.send(updatePresenceRequest, HttpResponse.BodyHandlers.discarding());
+
+            if (updatePresenceResponse.statusCode() != 200) {
+                logger.error("Failed to update presence, got status " + updatePresenceResponse.statusCode());
+            }
+        } catch (IOException | InterruptedException e) {
+            throw new RuntimeException(e);
+        }
+    }
 }