refactor(webeditor): replace the websocket client with reverb and http rpc

Author: dnlblasco

pom.xml

@@ -30,7 +30,7 @@
         <fastinv.version>3.1.2</fastinv.version>
         <jetbrains-annotations.version>26.1.0</jetbrains-annotations.version>
         <gson.version>2.14.0</gson.version>
-        <java-websocket.version>1.6.0</java-websocket.version>
+        <pusher-client.version>2.4.4</pusher-client.version>
         <hikaricp.version>7.1.0</hikaricp.version>
         <mysql-connector.version>26.7.0</mysql-connector.version>
         <itemsadder-api.version>4.0.10</itemsadder-api.version>
@@ -175,11 +175,12 @@
             <version>${fastinv.version}</version>
         </dependency>
 
-        <!-- Java-WebSocket, client connection to the web editor -->
+        <!-- Pusher protocol client, subscribes to the web editor's Reverb channel.
+             Pulls Java-WebSocket in transitively, which is why that relocation stays. -->
         <dependency>
-            <groupId>org.java-websocket</groupId>
-            <artifactId>Java-WebSocket</artifactId>
-            <version>${java-websocket.version}</version>
+            <groupId>com.pusher</groupId>
+            <artifactId>pusher-java-client</artifactId>
+            <version>${pusher-client.version}</version>
         </dependency>
 
         <!-- MySQL sync -->
@@ -323,6 +324,7 @@
                                 <includes>
                                     <include>net.wesjd:anvilgui</include>
                                     <include>fr.mrmicky:fastinv</include>
+                                    <include>com.pusher:pusher-java-client</include>
                                     <include>org.java-websocket:Java-WebSocket</include>
                                     <include>com.zaxxer:HikariCP</include>
                                     <include>com.mysql:mysql-connector-j</include>
@@ -345,6 +347,10 @@
                                     <pattern>org.java_websocket</pattern>
                                     <shadedPattern>net.blueva.menu.libraries.websocket</shadedPattern>
                                 </relocation>
+                                <relocation>
+                                    <pattern>com.pusher</pattern>
+                                    <shadedPattern>net.blueva.menu.libraries.pusher</shadedPattern>
+                                </relocation>
                             </relocations>
                             <filters>
                                 <filter>

src/main/java/net/blueva/menu/Main.java

@@ -18,7 +18,7 @@
 import net.blueva.menu.managers.java.MenuManager;
 import net.blueva.menu.sync.MenuSyncService;
 import net.blueva.menu.webeditor.WebEditorManager;
-import net.blueva.menu.webeditor.WebEditorManager.WebEditorEnvironment;
+import net.blueva.menu.webeditor.WebEditorEnvironment;
 import net.kyori.adventure.platform.bukkit.BukkitAudiences;
 import org.bukkit.Bukkit;
 import org.bukkit.ChatColor;

src/main/java/net/blueva/menu/common/dto/SessionDTO.java

@@ -0,0 +1,40 @@
+package net.blueva.menu.webeditor;
+
+import com.google.gson.JsonObject;
+
+/**
+ * Reverb connection details, handed to the plugin when it registers and
+ * refreshed on every heartbeat.
+ *
+ * @param key          public application key of the Pusher protocol
+ * @param host         host serving the WebSocket endpoint
+ * @param port         port serving the WebSocket endpoint
+ * @param useTls       whether the endpoint is served over TLS
+ * @param authEndpoint URL that authorises subscriptions to private channels
+ */
+public record RealtimeSettings(String key, String host, int port, boolean useTls, String authEndpoint) {
+
+    public static RealtimeSettings fromJson(JsonObject json) {
+        if (json == null || !json.has("key") || json.get("key").isJsonNull()) {
+            return null;
+        }
+
+        String scheme = json.has("scheme") && !json.get("scheme").isJsonNull()
+            ? json.get("scheme").getAsString()
+            : "https";
+
+        return new RealtimeSettings(
+            json.get("key").getAsString(),
+            json.has("host") && !json.get("host").isJsonNull() ? json.get("host").getAsString() : null,
+            json.has("port") && !json.get("port").isJsonNull() ? json.get("port").getAsInt() : 443,
+            "https".equalsIgnoreCase(scheme),
+            json.has("authEndpoint") && !json.get("authEndpoint").isJsonNull()
+                ? json.get("authEndpoint").getAsString()
+                : null
+        );
+    }
+
+    public boolean isUsable() {
+        return key != null && !key.isBlank() && host != null && !host.isBlank() && authEndpoint != null;
+    }
+}