setup

pom.xml

@@ -45,24 +45,41 @@
             <artifactId>javafx-fxml</artifactId>
             <version>${javafx.version}</version>
         </dependency>
+
+
     </dependencies>
     <build>
         <plugins>
+
+            <!-- Compiler plugin: tells Maven to use Java 25 -->
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-compiler-plugin</artifactId>
+                <version>3.11.0</version>
+                <configuration>
+                    <source>25</source>
+                    <target>25</target>
+                    <release>25</release>
+                </configuration>
+            </plugin>
+
+            <!-- JavaFX plugin -->
             <plugin>
                 <groupId>org.openjfx</groupId>
                 <artifactId>javafx-maven-plugin</artifactId>
                 <version>0.0.8</version>
                 <configuration>
                     <mainClass>com.example.HelloFX</mainClass>
                     <options>
-                    <option>--enable-native-access=javafx.graphics</option>
+                        <option>--enable-native-access=javafx.graphics</option>
                     </options>
                     <launcher>javafx</launcher>
                     <stripDebug>true</stripDebug>
                     <noHeaderFiles>true</noHeaderFiles>
                     <noManPages>true</noManPages>
                 </configuration>
             </plugin>
+
         </plugins>
     </build>
 </project>

src/main/java/com/example/ChatController.java

@@ -0,0 +1,42 @@
+package com.example;
+
+import javafx.fxml.FXML;
+import javafx.scene.control.ListView;
+import javafx.scene.control.TextField;
+import javafx.application.Platform;
+
+public class ChatController {
+
+    @FXML
+    private ListView<String> messagesList;
+
+    @FXML
+    private TextField inputField;
+
+    private final ChatModel model = new ChatModel();
+
+
+    @FXML
+    private void onSend() {
+        String message = inputField.getText().trim();
+        if (!message.isEmpty()) {
+            messagesList.getItems().add("Me: " + message);
+            model.sendMessage(message);
+            inputField.clear();
+        }
+    }
+
+
+    @FXML
+    private void initialize(){
+        model.subscribe(msg -> {
+            Platform.runLater(() -> messagesList.getItems().add("Friend: " + msg));
+        });
+    }
+
+
+
+
+
+
+}

src/main/java/com/example/ChatModel.java

@@ -0,0 +1,117 @@
+package com.example;
+
+import javafx.application.Platform;
+
+import java.io.BufferedReader;
+import java.io.InputStreamReader;
+import java.net.URI;
+import java.net.http.HttpClient;
+import java.net.http.HttpRequest;
+import java.net.http.HttpResponse;
+import java.util.Collections;
+import java.util.Set;
+import java.util.UUID;
+import java.util.concurrent.ConcurrentHashMap;
+import java.util.function.Consumer;
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
+
+public class ChatModel {
+
+    private final String sendUrl;
+    private final String subscribeUrl;
+    private final String clientId;
+    private final Set<String> sentMessages = Collections.newSetFromMap(new ConcurrentHashMap<>());
+
+    public ChatModel() {
+        String topic = System.getenv().getOrDefault("NTFY_TOPIC", "https://ntfy.sh/newchatroom3");
+
+        sendUrl = topic;
+        subscribeUrl = topic + "/sse";
+        clientId = UUID.randomUUID().toString();
+    }
+
+    public void sendMessage(String message) {
+        sentMessages.add(message);
+
+        new Thread(() -> {
+            try { Thread.sleep(5000); } catch (Exception ignored) {}
+            sentMessages.remove(message);
+        }).start();
+
+        HttpClient client = HttpClient.newHttpClient();
+
+        HttpRequest request = HttpRequest.newBuilder()
+                .uri(URI.create(sendUrl))
+                .header("Content-Type", "application/json")
+                .header("X-Client-ID", clientId)
+                .header("Title", "Friend: ")
+                .POST(HttpRequest.BodyPublishers.ofString(message))
+                .build();
+
+        client.sendAsync(request, HttpResponse.BodyHandlers.ofString())
+                .thenAccept(response -> System.out.println("Sent, status=" + response.statusCode()))
+                .exceptionally(e -> { e.printStackTrace(); return null; });
+    }
+
+
+    public void subscribe(Consumer<String> onMessageReceived) {
+        HttpClient client = HttpClient.newHttpClient();
+        HttpRequest request = HttpRequest.newBuilder()
+                .uri(URI.create(subscribeUrl))
+                .header("Accept", "text/event-stream")
+                .build();
+
+        client.sendAsync(request, HttpResponse.BodyHandlers.ofInputStream())
+                .thenAccept(response -> {
+                    try (BufferedReader reader = new BufferedReader(new InputStreamReader(response.body()))) {
+                        String line;
+                        boolean firstMessageSkipped = false;
+                        while ((line = reader.readLine()) != null) {
+                            if (line.startsWith("data:")) {
+                                if (!firstMessageSkipped) {
+                                    firstMessageSkipped = true;
+                                    continue;
+                                }
+
+                                String raw = line.substring(5).trim();
+                                String msg = parseMessage(raw);
+
+                                if (msg != null && !sentMessages.contains(msg)) {
+                                    Platform.runLater(() -> onMessageReceived.accept(msg));
+                                }
+                            }
+                        }
+                    } catch (Exception e) {
+                        e.printStackTrace();
+                    }
+                })
+                .exceptionally(e -> { e.printStackTrace(); return null; });
+    }
+
+    private String parseMessage(String data) {
+        try {
+            Matcher eventMatcher = Pattern.compile("\"event\"\\s*:\\s*\"(.*?)\"").matcher(data);
+            if (eventMatcher.find()) {
+                String event = eventMatcher.group(1);
+
+                if (!"message".equals(event)) {
+                    return null;
+                }
+            }
+
+            Matcher msgMatcher = Pattern.compile("\"message\"\\s*:\\s*\"(.*?)\"").matcher(data);
+            if (msgMatcher.find()) {
+                return msgMatcher.group(1).replace("\\\"", "\"");
+            }
+        } catch (Exception ignored) {}
+
+        return null;
+    }
+
+
+
+}
+
+
+

src/main/java/com/example/HelloFX.java

@@ -10,10 +10,10 @@ public class HelloFX extends Application {
 
     @Override
     public void start(Stage stage) throws Exception {
-        FXMLLoader fxmlLoader = new FXMLLoader(HelloFX.class.getResource("hello-view.fxml"));
+        FXMLLoader fxmlLoader = new FXMLLoader(HelloFX.class.getResource("chat-view.fxml"));
         Parent root = fxmlLoader.load();
         Scene scene = new Scene(root, 640, 480);
-        stage.setTitle("Hello MVC");
+        stage.setTitle("Chat App");
         stage.setScene(scene);
         stage.show();
     }

src/main/java/module-info.java

@@ -1,6 +1,8 @@
 module hellofx {
     requires javafx.controls;
     requires javafx.fxml;
+    requires java.net.http;
+
 
     opens com.example to javafx.fxml;
     exports com.example;

src/main/resources/com/example/chat-view.fxml

@@ -0,0 +1,24 @@
+<?xml version="1.0" encoding="UTF-8"?>
+
+<?import javafx.scene.layout.BorderPane?>
+<?import javafx.scene.control.ListView?>
+<?import javafx.scene.control.TextField?>
+<?import javafx.scene.control.Button?>
+<?import javafx.scene.layout.HBox?>
+
+<BorderPane xmlns="http://javafx.com/javafx"
+            xmlns:fx="http://javafx.com/fxml"
+            fx:controller="com.example.ChatController">
+
+    <center>
+        <ListView fx:id="messagesList"/>
+    </center>
+
+    <bottom>
+        <HBox spacing="8" style="-fx-padding: 10;">
+            <TextField fx:id="inputField" HBox.hgrow="ALWAYS"/>
+            <Button text="Send" onAction="#onSend"/>
+        </HBox>
+    </bottom>
+
+</BorderPane>