fix: make dms work

This commit is contained in:
surtur 2021-02-06 12:40:14 +01:00
parent d07667d313
commit b74d0418dc
Signed by: wanderer
GPG Key ID: 19CE1EC1D9E0486D

View File

@ -26,11 +26,12 @@ class ActiveHandlers {
}
}
synchronized void senddm(SocketHandler sender, String message) {
String[] whofor = message.split(" ");
String[] whofor_split = message.split(" ");
String whofor = whofor_split[3].replaceFirst("@","");
System.err.println("dbgpls");
System.err.println(whofor);
for (SocketHandler handler:activeHandlersSet) {
if (handler.clientID == whofor[3]) {
if (handler.clientID.equals(whofor)) {
if (!handler.messages.offer(message)) {
System.err.printf("Client %s message queue is full, dropping the message!\n", handler.clientID);
}
@ -152,11 +153,14 @@ class SocketHandler {
while ((request=reader.readLine())!=null) {
request = commandzpls(request);
System.out.println(request);
switch (request.substring(0,3)){
case "|DM| ":
String[] req_kind = request.split(" ");
switch (req_kind[0]){
case "|DM|":
activeHandlers.senddm(SocketHandler.this,request);
break;
default:
activeHandlers.sendMessageToAll(SocketHandler.this,request);
break;
}
}
inputFinished=true;