norbipeti/ChatServer
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

Added TODOs and errors

Browse source
This commit is contained in:
Norbi Peti 2016-08-16 13:04:14 +02:00
parent 4b90fdf8b9
commit f997da810b
1 changed files with 19 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

25
src/io/github/norbipeti/chat/server/page/ReceiveMessageAjaxPage.java
View file

@ -2,6 +2,7 @@ package io.github.norbipeti.chat.server.page;
import java.io.IOException; import java.io.IOException;
import java.util.HashMap; import java.util.HashMap;
import java.util.Map.Entry;
import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.LogManager;
@ -25,6 +26,7 @@ public class ReceiveMessageAjaxPage extends Page {
} }
public static HashMap<User, HttpExchange> exmap = new HashMap<>(); public static HashMap<User, HttpExchange> exmap = new HashMap<>();
public static HashMap<User, Message> unsentmessages = new HashMap<>();
@Override @Override
public void handlePage(HttpExchange exchange) throws IOException { public void handlePage(HttpExchange exchange) throws IOException {
@ -47,19 +49,30 @@ public class ReceiveMessageAjaxPage extends Page {
} }
public static void sendMessageBack(Message msg, Conversation conv) throws IOException { public static void sendMessageBack(Message msg, Conversation conv) throws IOException {
for (User user : conv.getUsers()) { for (User user : conv.getUsers()) { // TODO: Load older messages when scrolling up
LogManager.getLogger().debug("User: " + user); if (unsentmessages.size() > 10)
if (exmap.containsKey(user)) { // TODO: Save new messages if not listening unsentmessages.clear();
LogManager.getLogger().debug("Exmap contains user"); if (exmap.containsKey(user)) { // TODO: Save new messages if not listening - If message count is bigger than 10, remove (the user is probably offline)
JsonObject msgobj = msg.getAsJson(); unsentmessages.put(user, msg);
for (Entry<User, Message> entry : unsentmessages.) { //TODO: Only one key allowed, fix
JsonObject msgobj = entry.getValue().getAsJson(); // TODO: Only send messages if the user's current conversation matches
try {
IOHelper.SendResponse(200, msgobj.toString(), exmap.get(user));
} catch (IOException e) { // Remove users even if an error occurs (otherwise they may not be able to send a new message due to "headers already sent")
e.printStackTrace();
}
}
JsonObject msgobj = msg.getAsJson(); // TODO: Only send messages if the user's current conversation matches
try { try {
IOHelper.SendResponse(200, msgobj.toString(), exmap.get(user)); IOHelper.SendResponse(200, msgobj.toString(), exmap.get(user));
} catch (IOException e) { // Remove users even if an error occurs (otherwise they may not be able to send a new message due to "headers already sent") } catch (IOException e) { // Remove users even if an error occurs (otherwise they may not be able to send a new message due to "headers already sent")
e.printStackTrace(); e.printStackTrace();
} }
exmap.remove(user); exmap.remove(user);
} else } else {
LogManager.getLogger().warn("User is not listening: " + user); LogManager.getLogger().warn("User is not listening: " + user);
unsentmessages.put(user, msg);
}
} }
} }
} }