diff --git a/pom.xml b/pom.xml index b3a15d5..ab29cb7 100644 --- a/pom.xml +++ b/pom.xml @@ -58,10 +58,6 @@ ${junit-jupiter.version} test - - io.netty - netty-tcnative-boringssl-static - org.slf4j diff --git a/src/main/java/cx/lehmann/gemini/gemini/MainVerticle.java b/src/main/java/cx/lehmann/gemini/gemini/MainVerticle.java index 87dc1a9..46a3f06 100644 --- a/src/main/java/cx/lehmann/gemini/gemini/MainVerticle.java +++ b/src/main/java/cx/lehmann/gemini/gemini/MainVerticle.java @@ -126,8 +126,8 @@ public class MainVerticle extends AbstractVerticle { String quotedMessage=decodedMessage.replace("\n", "\n "); for (NetSocket socket:clients) { - socket.write(clientHash+":"+quotedMessage+"\n"); - } + socket.write(clientHash+":"+quotedMessage+"\n"); + } } } catch (SSLPeerUnverifiedException | CertificateEncodingException | NoSuchAlgorithmException ex) { // ex.printStackTrace(); @@ -136,12 +136,23 @@ public class MainVerticle extends AbstractVerticle { conn.close(); } else { System.out.println("conn2"); + for (NetSocket socket:clients) { + socket.write("one client connected. count is "+(clients.size()+1)+"\n"); + } clients.add(conn); conn.write("20 text/gemini\r\n"); conn.write("to post messages, go to\n"); conn.write("=> post post page\n"); conn.write("preferably in a new window\n"); + conn.write("currently "+clients.size()+" reading clients are connected\n"); conn.write("chat start\n"); + conn.closeHandler(v -> { + System.out.println("a client closed"); + clients.remove(conn); + for (NetSocket socket:clients) { + socket.write("one client disconnected. count is "+clients.size()+"\n"); + } + }); } } }