diff --git a/API/src/main/java/io/github/jwdeveloper/tiktok/data/events/TikTokDisconnectedEvent.java b/API/src/main/java/io/github/jwdeveloper/tiktok/data/events/TikTokDisconnectedEvent.java index 2f57358..715ca04 100644 --- a/API/src/main/java/io/github/jwdeveloper/tiktok/data/events/TikTokDisconnectedEvent.java +++ b/API/src/main/java/io/github/jwdeveloper/tiktok/data/events/TikTokDisconnectedEvent.java @@ -30,6 +30,8 @@ import lombok.Getter; @Getter @EventMeta(eventType = EventType.Control) public class TikTokDisconnectedEvent extends TikTokLiveClientEvent { + public static int UNKNOWN_CLOSE_CODE = -1; + /** Valid CloseFrame code or -1 for unknown */ private final int code; private final String reason; @@ -38,4 +40,12 @@ public class TikTokDisconnectedEvent extends TikTokLiveClientEvent { this.code = code; this.reason = reason.isBlank() ? "None" : reason; } + + public TikTokDisconnectedEvent(String reason) { + this(UNKNOWN_CLOSE_CODE, reason); + } + + public boolean isUnknownCloseCode() { + return this.code == UNKNOWN_CLOSE_CODE; + } } \ No newline at end of file diff --git a/Client/src/main/java/io/github/jwdeveloper/tiktok/TikTokLiveClient.java b/Client/src/main/java/io/github/jwdeveloper/tiktok/TikTokLiveClient.java index 193d451..e06102f 100644 --- a/Client/src/main/java/io/github/jwdeveloper/tiktok/TikTokLiveClient.java +++ b/Client/src/main/java/io/github/jwdeveloper/tiktok/TikTokLiveClient.java @@ -86,7 +86,7 @@ public class TikTokLiveClient implements LiveClient } catch (TikTokLiveException e) { setState(ConnectionState.DISCONNECTED); tikTokEventHandler.publish(this, new TikTokErrorEvent(e)); - tikTokEventHandler.publish(this, new TikTokDisconnectedEvent(-1, "Exception: " + e.getMessage())); + tikTokEventHandler.publish(this, new TikTokDisconnectedEvent("Exception: " + e.getMessage())); if (e instanceof TikTokLiveOfflineHostException && clientSettings.isRetryOnConnectionFailure()) { try { diff --git a/Client/src/main/java/io/github/jwdeveloper/tiktok/websocket/TikTokWebSocketOfflineClient.java b/Client/src/main/java/io/github/jwdeveloper/tiktok/websocket/TikTokWebSocketOfflineClient.java index b9c96d3..f7cbdc8 100644 --- a/Client/src/main/java/io/github/jwdeveloper/tiktok/websocket/TikTokWebSocketOfflineClient.java +++ b/Client/src/main/java/io/github/jwdeveloper/tiktok/websocket/TikTokWebSocketOfflineClient.java @@ -46,7 +46,7 @@ public class TikTokWebSocketOfflineClient implements LiveSocketClient { @Override public void stop(int type) { if (liveClient != null) - handler.publish(liveClient, new TikTokDisconnectedEvent(-1, "Stopping")); + handler.publish(liveClient, new TikTokDisconnectedEvent("Stopping")); } @Override