Rainnny/Tether
1
0
Fork 0
Code Issues 1 Pull Requests 3 Actions Wiki Activity

debugs
All checks were successful
Deploy API / deploy (ubuntu-latest, 2.44.0) (push) Successful in 56s
Details

Browse Source
This commit is contained in:
Braydon 2024-09-10 16:04:20 -04:00
parent cd4a57a4f2
commit 2f0b6d5982
1 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
API/src/main/java/me/braydon/tether/service/websocket/WebSocket.java
View File

@ -56,22 +56,30 @@ public class WebSocket extends TextWebSocketHandler {
log.info("Active Sessions: {}", activeSessions.size());
}
for (WebSocketClient client : activeSessions.values()) {
// Disconnect users that have not been active for 15 seconds
if (client.getListeningTo() == null && ((System.currentTimeMillis() - client.getConnected()) >= TimeUnit.SECONDS.toMillis(15L))) {
String sessionId = client.getSession().getId();
System.out.println("client.getSession().getId() = " + sessionId);
// Disconnect users that have not been active for 30 seconds
if (client.getListeningTo() == null && ((System.currentTimeMillis() - client.getConnected()) >= TimeUnit.SECONDS.toMillis(30L))) {
log.info("Disconnecting session {} for being inactive", sessionId);
client.getSession().close(CloseStatus.NOT_ACCEPTABLE.withReason("Client is inactive"));
continue;
}
if (client.getListeningTo() == null) {
System.err.println("NOT LISTENING!!!");
continue;
}
// Notify the listening client of the user's status if it has changed
try {
DiscordUser user = discordService.getUserBySnowflake(client.getListeningTo()).getUser();
System.out.println("user = " + user);
if (!user.equals(client.getLastUser())) {
client.setLastUser(user);
dispatch(client.getSession(), new UserStatusPacket(user));
}
} catch (BadRequestException | ServiceUnavailableException | ResourceNotFoundException ex) {
System.err.println(ex.getLocalizedMessage());
System.err.println("STOPPED LISTENING TO USER!!!!!!!!!!!!!!");
client.setListeningTo(null);
dispatch(client.getSession(), new ErrorMessagePacket(ex.getLocalizedMessage()));
}