fix(gateway / status rotor): fixed issues with the new gateway implem…

…entation where having an active status rotor would cause the gateway to crash after a disconnect and attempted reconnect

This was due to the status rotor attempting to send a message when it wasn't authorized to do so, since the ready event hadn't yet been received.

src/main/java/com/seailz/discordjar/DiscordJar.java

@@ -438,7 +438,7 @@ public void setStatus(@NotNull Status status) {
         JSONObject json = new JSONObject();
         json.put("d", status.compile());
         json.put("op", 3);
-        gatewayFactory.queueMessage(json);
+        gatewayFactory.queueMessageUntilReady(json);
         gatewayFactory.setStatus(status);
         this.status = status;
     }

src/main/java/com/seailz/discordjar/gateway/Gateway.java

@@ -64,6 +64,7 @@ public class Gateway {
     private ReconnectInfo resumeInfo;
     public static long lastSequenceNumber = -1;
     private boolean readyForMessages = false;
+    private boolean receivedReady = false;
     private HeartLogic heartbeatManager;
     public static Date lastHeartbeatSent = new Date();
     public static List<Long> pingHistoryMs = new ArrayList<>();
@@ -118,6 +119,7 @@ public void disconnect(@NotNull CloseStatus closeStatus) {
      * @param closeStatus The close status of the disconnect.
      */
     public void disconnectFlow(@NotNull CloseStatus closeStatus) {
+        setReceivedReady(false);
         heartbeatManager.stop(); // Stop attempting heartbeats to avoid broken pipe errors
         CloseCode closeCode = CloseCode.fromCode(closeStatus.getCode());
         readyForMessages = false;
@@ -403,6 +405,22 @@ public void queueMessage(@NotNull JSONObject payload) {
         }
     }
 
+    /**
+     * Queues a message to be sent to the gateway.
+     * <br>Messages will be sent after the READY event is received.
+     * @param payload {@link JSONObject} containing the payload to send
+     */
+    public void queueMessageUntilReady(@NotNull JSONObject payload) {
+        if (bot.isDebug()) logger.info("[Gateway] Queued message: " + payload);
+        while (receivedReady) {
+            socket.send(payload.toString());
+            if (bot.isDebug()) {
+                logger.info("[Gateway] Sent message: " + payload);
+            }
+            break;
+        }
+    }
+
     /**
      * Sends a request to the gateway to request guild members.
      * @param action {@link RequestGuildMembersAction} containing extra information about the request
@@ -506,6 +524,10 @@ private String getGatewayUrl() throws InterruptedException {
         return gatewayUrl;
     }
 
+    public void setReceivedReady(boolean receivedReady) {
+        this.receivedReady = receivedReady;
+    }
+
     /**
      * Returns resume info for the next resume attempt, or null if READY was not received yet.
      */

src/main/java/com/seailz/discordjar/gateway/events/DispatchedEvents.java

@@ -70,6 +70,7 @@ public enum DispatchedEvents {
     READY((p, g, d) -> {
         Logger.getLogger("Gateway")
                 .info("[Gateway] Ready to receive events");
+        g.setReceivedReady(true);
         return ReadyEvent.class;
     }),
     RESUMED((p, d, g) -> GatewayResumedEvent.class),