From 48d7cb7227e4ea61c1327515d9ce76fe5f3e0260 Mon Sep 17 00:00:00 2001
From: AseelHamamreh <aseel.hamamreh@hotmail.com>
Date: Sat, 15 Nov 2025 16:41:16 +0100
Subject: [PATCH 1/2] setup

---
 pom.xml                                       | 17 +++++++++++-
 src/main/java/com/example/ChatController.java | 26 +++++++++++++++++++
 src/main/java/com/example/ChatModel.java      |  9 +++++++
 src/main/java/com/example/HelloFX.java        |  2 +-
 src/main/resources/com/example/chat-view.fxml | 24 +++++++++++++++++
 5 files changed, 76 insertions(+), 2 deletions(-)
 create mode 100644 src/main/java/com/example/ChatController.java
 create mode 100644 src/main/java/com/example/ChatModel.java
 create mode 100644 src/main/resources/com/example/chat-view.fxml

diff --git a/pom.xml b/pom.xml
index c40f667e..4bf22db9 100644
--- a/pom.xml
+++ b/pom.xml
@@ -48,6 +48,20 @@
     </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>
@@ -55,7 +69,7 @@
                 <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>
@@ -63,6 +77,7 @@
                     <noManPages>true</noManPages>
                 </configuration>
             </plugin>
+
         </plugins>
     </build>
 </project>
diff --git a/src/main/java/com/example/ChatController.java b/src/main/java/com/example/ChatController.java
new file mode 100644
index 00000000..77500602
--- /dev/null
+++ b/src/main/java/com/example/ChatController.java
@@ -0,0 +1,26 @@
+package com.example;
+
+import javafx.fxml.FXML;
+import javafx.scene.control.ListView;
+import javafx.scene.control.TextField;
+
+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();
+        }
+    }
+}
diff --git a/src/main/java/com/example/ChatModel.java b/src/main/java/com/example/ChatModel.java
new file mode 100644
index 00000000..46599712
--- /dev/null
+++ b/src/main/java/com/example/ChatModel.java
@@ -0,0 +1,9 @@
+package com.example;
+
+public class ChatModel {
+
+    public void sendMessage(String message) {
+        // TODO: send POST JSON to ntfy
+        System.out.println("Sending message: " + message);
+    }
+}
diff --git a/src/main/java/com/example/HelloFX.java b/src/main/java/com/example/HelloFX.java
index 96bdc5ca..2517ef4b 100644
--- a/src/main/java/com/example/HelloFX.java
+++ b/src/main/java/com/example/HelloFX.java
@@ -10,7 +10,7 @@ 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");
diff --git a/src/main/resources/com/example/chat-view.fxml b/src/main/resources/com/example/chat-view.fxml
new file mode 100644
index 00000000..667d541b
--- /dev/null
+++ b/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>

From e2da7ee509d984e48cf934d8a20b7a037aede933 Mon Sep 17 00:00:00 2001
From: AseelHamamreh <aseel.hamamreh@hotmail.com>
Date: Sun, 16 Nov 2025 18:56:49 +0100
Subject: [PATCH 2/2] logic done

---
 pom.xml                                       |   2 +
 src/main/java/com/example/ChatController.java |  16 +++
 src/main/java/com/example/ChatModel.java      | 112 +++++++++++++++++-
 src/main/java/com/example/HelloFX.java        |   2 +-
 src/main/java/module-info.java                |   2 +
 5 files changed, 131 insertions(+), 3 deletions(-)

diff --git a/pom.xml b/pom.xml
index 4bf22db9..47427c21 100644
--- a/pom.xml
+++ b/pom.xml
@@ -45,6 +45,8 @@
             <artifactId>javafx-fxml</artifactId>
             <version>${javafx.version}</version>
         </dependency>
+
+
     </dependencies>
     <build>
         <plugins>
diff --git a/src/main/java/com/example/ChatController.java b/src/main/java/com/example/ChatController.java
index 77500602..2cc49f68 100644
--- a/src/main/java/com/example/ChatController.java
+++ b/src/main/java/com/example/ChatController.java
@@ -3,6 +3,7 @@
 import javafx.fxml.FXML;
 import javafx.scene.control.ListView;
 import javafx.scene.control.TextField;
+import javafx.application.Platform;
 
 public class ChatController {
 
@@ -14,6 +15,7 @@ public class ChatController {
 
     private final ChatModel model = new ChatModel();
 
+
     @FXML
     private void onSend() {
         String message = inputField.getText().trim();
@@ -23,4 +25,18 @@ private void onSend() {
             inputField.clear();
         }
     }
+
+
+    @FXML
+    private void initialize(){
+        model.subscribe(msg -> {
+            Platform.runLater(() -> messagesList.getItems().add("Friend: " + msg));
+        });
+    }
+
+
+
+
+
+
 }
diff --git a/src/main/java/com/example/ChatModel.java b/src/main/java/com/example/ChatModel.java
index 46599712..c1947f0c 100644
--- a/src/main/java/com/example/ChatModel.java
+++ b/src/main/java/com/example/ChatModel.java
@@ -1,9 +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) {
-        // TODO: send POST JSON to ntfy
-        System.out.println("Sending message: " + 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;
+    }
+
+
+
 }
+
+
+
diff --git a/src/main/java/com/example/HelloFX.java b/src/main/java/com/example/HelloFX.java
index 2517ef4b..be82aace 100644
--- a/src/main/java/com/example/HelloFX.java
+++ b/src/main/java/com/example/HelloFX.java
@@ -13,7 +13,7 @@ public void start(Stage stage) throws Exception {
         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();
     }
diff --git a/src/main/java/module-info.java b/src/main/java/module-info.java
index 71574a27..0a19298c 100644
--- a/src/main/java/module-info.java
+++ b/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;