chuuuut

ChatApp/app/src/main/java/client/ClientGuiController.java

@@ -53,7 +53,7 @@ public class ClientGuiController implements ClientListener {
 
     @FXML
     public void initialize() throws SocketException {
-        client = new Client(new InetSocketAddress("localhost", 6665), this, UsernameSingleton.getInstance().getUsername());
+        client = new Client(new InetSocketAddress("192.168.163.131", 6665), this, UsernameSingleton.getInstance().getUsername());
         Platform.runLater(() -> {
             Stage stage = (Stage) vueContainer.getScene().getWindow();
             stage.setResizable(true); // Fixed a bug that made the close button disappear under my Wayland setup (don't know if it's the same for x11)
@@ -71,9 +71,7 @@ public class ClientGuiController implements ClientListener {
      * Request the list of rooms from the server every second.
      */
     private void requestRoomsRegularly() {
-        Timeline timeline = new Timeline(new KeyFrame(Duration.seconds(1), event -> {
-            client.RequestRoomList();
-        }));
+        Timeline timeline = new Timeline(new KeyFrame(Duration.seconds(10), event -> client.RequestRoomList()));
         timeline.setCycleCount(Timeline.INDEFINITE);
         timeline.play();
     }
@@ -130,7 +128,7 @@ public class ClientGuiController implements ClientListener {
             String timeString = formatter.format(time);
             Text chatterText = new Text(chatter + ": ");
             chatterText.setStyle("-fx-fill: black; -fx-font-weight: bold;");
-            TextFlow messageText = formatMessage(chatter, untagged);
+            TextFlow messageText = formatMessage(untagged);
             TextFlow wholeMessage = new TextFlow(chatterText, messageText);
             Text timeText = new Text("  " + timeString);
             timeText.setStyle("-fx-fill: gray; -fx-font-size: 10px;");
@@ -151,7 +149,7 @@ public class ClientGuiController implements ClientListener {
         Pattern pattern = Pattern.compile("\u001B\\[44;30m(.*?)\u001B\\[49;39m");
         Matcher matcher = pattern.matcher(message);
 
-        StringBuffer result = new StringBuffer();
+        StringBuilder result = new StringBuilder();
         while (matcher.find()) {
             String taggedName = matcher.group(1);
             matcher.appendReplacement(result, taggedName);
@@ -220,11 +218,10 @@ public class ClientGuiController implements ClientListener {
 
     /**
      * Colorize the message according to the color codes.
-     * @param chatter the name of the person who sent the message
      * @param content the content of the message
      * @return the formatted message
      */
-    private TextFlow formatMessage(String chatter, String content) {
+    private TextFlow formatMessage(String content) {
         TextFlow textFlow = new TextFlow();
         // Evil regex : match every sequence starting with a color code ending with the next color code
         Pattern pattern = Pattern.compile("&([rbgyn])([^&]*)");
@@ -271,4 +268,16 @@ public class ClientGuiController implements ClientListener {
     public void handleActualRoom(String roomName) {
 
     }
+
+    public void createRoom() {
+        TextInputDialog dialog = new TextInputDialog();
+        dialog.setTitle("Create a room");
+        dialog.setHeaderText("Enter the name of the room");
+        dialog.setContentText("Room name:");
+        Optional<String> result = dialog.showAndWait();
+        result.ifPresent(name -> {
+            client.SendCreateRoom(name);
+            createChatEnv(name);
+        });
+    }
 }

ChatApp/app/src/main/java/network/PacketPool.java

@@ -24,7 +24,7 @@ public class PacketPool {
 
 	private static int MAX_SEND_TRY = 50;
 	private static long SEND_DELAY = 10;
-	private static long RETRY_INTERVAL = SEND_DELAY * 2;
+	private static long RETRY_INTERVAL = 100;
 	private static float PACKET_LOSS_PROBABILITY = 0.1f;
 
 	private static record ReliablePacketAddress(ReliablePacket packet, InetSocketAddress address) {
@@ -71,6 +71,7 @@ public class PacketPool {
 
 	/**
 	 * Set the recieve sequence number
+	 * 
 	 * @param address
 	 * @param newValue
 	 */
@@ -80,6 +81,7 @@ public class PacketPool {
 
 	/**
 	 * Try to add the address into memory
+	 * 
 	 * @param address
 	 */
 	private void tryAddContext(InetSocketAddress address) {
@@ -88,6 +90,7 @@ public class PacketPool {
 
 	/**
 	 * Construct a PacketPool
+	 * 
 	 * @param socket
 	 */
 	public PacketPool(Socket socket) {
@@ -114,6 +117,7 @@ public class PacketPool {
 
 	/**
 	 * Send a packet to the socket
+	 * 
 	 * @param packet
 	 * @param address
 	 * @throws IOException
@@ -122,13 +126,17 @@ public class PacketPool {
 		var packetsSentTries = this.addressContexts.get(address).packetsSentTries;
 
 		new Thread(() -> {
+			// try {
+			// Thread.sleep(SEND_DELAY);
+			// if (Math.random() > PACKET_LOSS_PROBABILITY)
 			try {
-				Thread.sleep(SEND_DELAY);
-				if (Math.random() > PACKET_LOSS_PROBABILITY)
-					this.socket.sendPacket(packet, address);
-			} catch (InterruptedException | IOException e) {
+				this.socket.sendPacket(packet, address);
+			} catch (IOException e) {
 				// e.printStackTrace();
 			}
+			// } catch (InterruptedException | IOException e) {
+			// // e.printStackTrace();
+			// }
 		}).start();
 
 		if (packet.getPacket() instanceof AcknowlegdementPacket)
@@ -143,7 +151,9 @@ public class PacketPool {
 	}
 
 	/**
-	 * Send a packet to socket and try to resend if an acknowlegment was not recieved
+	 * Send a packet to socket and try to resend if an acknowlegment was not
+	 * recieved
+	 * 
 	 * @param packet
 	 * @param address
 	 * @throws IOException
@@ -163,6 +173,7 @@ public class PacketPool {
 
 	/**
 	 * Send a packet (and encapsulate it)
+	 * 
 	 * @param packet
 	 * @param address
 	 * @throws IOException
@@ -175,6 +186,7 @@ public class PacketPool {
 
 	/**
 	 * Try to resend a packet
+	 * 
 	 * @param reliablePacketAddress
 	 */
 	private void tryResend(ReliablePacketAddress reliablePacketAddress) {
@@ -212,7 +224,6 @@ public class PacketPool {
 			ctx.sendThreads.remove(Thread.currentThread());
 	}
 
-
 	/**
 	 * @param address
 	 * @return The smallest sequence number recieved
@@ -227,7 +238,9 @@ public class PacketPool {
 	}
 
 	/**
-	 * Move packets in buffer to the packet recieved queue to be processed by the app
+	 * Move packets in buffer to the packet recieved queue to be processed by the
+	 * app
+	 * 
 	 * @param address
 	 * @return the sequence number of the last packet that was added to the queue
 	 */
@@ -251,6 +264,7 @@ public class PacketPool {
 
 	/**
 	 * Process packet when recieved
+	 * 
 	 * @param packet
 	 * @param address
 	 * @throws IOException
@@ -311,6 +325,7 @@ public class PacketPool {
 
 	/**
 	 * Closes the connexion
+	 * 
 	 * @param adress
 	 */
 	private void close(InetSocketAddress adress) {
@@ -321,6 +336,7 @@ public class PacketPool {
 
 	/**
 	 * Stop the threads of the connexion
+	 * 
 	 * @param adressContext
 	 */
 	private void close(AdressContext adressContext) {

ChatApp/app/src/main/resources/client/clientVue.fxml

@@ -26,10 +26,17 @@
     </top>
     <left>
         <ScrollPane prefWidth="200.0" fitToWidth="true">
-            <VBox spacing="10.0" alignment="CENTER" VBox.vgrow="ALWAYS">
-                <Label text="Rooms" styleClass="rooms-label"/>
-                <VBox fx:id="roomList" styleClass="rooms-list" spacing="5.0" VBox.vgrow="ALWAYS" alignment="CENTER"/>
-            </VBox>
+            <BorderPane>
+                <center>
+                    <VBox spacing="10.0" alignment="CENTER" VBox.vgrow="ALWAYS">
+                        <Label text="Rooms" styleClass="rooms-label"/>
+                        <VBox fx:id="roomList" styleClass="rooms-list" spacing="5.0" VBox.vgrow="ALWAYS" alignment="CENTER"/>
+                    </VBox>
+                </center>
+                <bottom>
+                    <Button text="Create room" onAction="#createRoom" />
+                </bottom>
+            </BorderPane>
         </ScrollPane>
     </left>
     <center>