Ntfy

.gitignore

@@ -1,2 +1,3 @@
 target/
 /.idea/
+.env

pom.xml

@@ -17,6 +17,27 @@
         <javafx.version>25</javafx.version>
     </properties>
     <dependencies>
+        <dependency>
+            <groupId>org.openjfx</groupId>
+            <artifactId>javafx-controls</artifactId>
+            <version>${javafx.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.openjfx</groupId>
+            <artifactId>javafx-fxml</artifactId>
+            <version>${javafx.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>io.github.cdimascio</groupId>
+            <artifactId>dotenv-java</artifactId>
+            <version>3.2.0</version>
+        </dependency>
+        <dependency>
+            <groupId>tools.jackson.core</groupId>
+            <artifactId>jackson-databind</artifactId>
+            <version>3.0.1</version>
+        </dependency>
+
         <dependency>
             <groupId>org.junit.jupiter</groupId>
             <artifactId>junit-jupiter</artifactId>
@@ -36,14 +57,28 @@
             <scope>test</scope>
         </dependency>
         <dependency>
-            <groupId>org.openjfx</groupId>
-            <artifactId>javafx-controls</artifactId>
-            <version>${javafx.version}</version>
+            <groupId>org.wiremock</groupId>
+            <artifactId>wiremock</artifactId>
+            <version>4.0.0-beta.15</version>
+            <scope>test</scope>
         </dependency>
         <dependency>
-            <groupId>org.openjfx</groupId>
-            <artifactId>javafx-fxml</artifactId>
-            <version>${javafx.version}</version>
+            <groupId>org.awaitility</groupId>
+            <artifactId>awaitility</artifactId>
+            <version>4.3.0</version>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.testfx</groupId>
+            <artifactId>testfx-junit5</artifactId>
+            <version>4.0.16-alpha</version>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.slf4j</groupId>
+            <artifactId>slf4j-simple</artifactId>
+            <version>2.0.12</version>
+            <scope>test</scope>
         </dependency>
     </dependencies>
     <build>
@@ -53,9 +88,9 @@
                 <artifactId>javafx-maven-plugin</artifactId>
                 <version>0.0.8</version>
                 <configuration>
-                    <mainClass>com.example.HelloFX</mainClass>
+                    <mainClass>com.example.ChatApplication</mainClass>
                     <options>
-                    <option>--enable-native-access=javafx.graphics</option>
+                        <option>--enable-native-access=javafx.graphics</option>
                     </options>
                     <launcher>javafx</launcher>
                     <stripDebug>true</stripDebug>
@@ -65,4 +100,4 @@
             </plugin>
         </plugins>
     </build>
-</project>
+</project>

src/main/java/com/example/ChatApplication.java

@@ -0,0 +1,36 @@
+package com.example;
+
+import javafx.application.Application;
+import javafx.fxml.FXMLLoader;
+import javafx.scene.Parent;
+import javafx.scene.Scene;
+import javafx.stage.Stage;
+
+import java.io.IOException;
+
+public class ChatApplication extends Application {
+
+    @Override
+    public void start(Stage stage) throws IOException {
+
+        NtfyConnection ntfyService = new NtfyConnectionImpl();
+        ChatModel model = new ChatModel(ntfyService);
+
+        model.startReceiving();
+
+        FXMLLoader fxmlLoader = new FXMLLoader(
+                ChatApplication.class.getResource("chat-view.fxml"));
+
+        ChatController controller = new ChatController(model);
+        fxmlLoader.setController(controller);
+
+        Scene scene = new Scene(fxmlLoader.load(), 600, 400);
+        stage.setTitle("JavaFX Ntfy Chat App");
+        stage.setScene(scene);
+        stage.show();
+    }
+
+    public static void main(String[] args) {
+        launch();
+    }
+}

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

@@ -0,0 +1,67 @@
+package com.example;
+
+import io.github.cdimascio.dotenv.Dotenv;
+import javafx.fxml.FXML;
+import javafx.scene.control.Button;
+import javafx.scene.control.Label;
+import javafx.scene.control.ListView;
+import javafx.scene.control.TextField;
+
+import java.time.Instant;
+import java.time.ZoneId;
+import java.time.format.DateTimeFormatter;
+import java.util.Objects;
+
+
+public class ChatController {
+
+    @FXML private ListView<ChatMessage> messageListView;
+    @FXML private TextField inputTextField;
+    @FXML private Button sendButton;
+
+    private final ChatModel model;
+
+    private final DateTimeFormatter timeFormatter =
+            DateTimeFormatter.ofPattern("HH:mm:ss").withZone(ZoneId.systemDefault());
+
+
+    public ChatController(ChatModel model) {
+        this.model = model;
+    }
+
+    @FXML
+    public void initialize() {
+        messageListView.setItems(model.getMessages());
+
+        messageListView.setCellFactory(lv -> new javafx.scene.control.ListCell<ChatMessage>() {
+            @Override
+            protected void updateItem(ChatMessage msg, boolean empty) {
+                super.updateItem(msg, empty);
+                if (empty || msg == null) {
+                    setText(null);
+                } else {
+                    String formattedTime = timeFormatter.format(Instant.ofEpochSecond(msg.timestamp()));
+                    setText("[" + formattedTime + "] " + msg.content());
+                }
+            }
+        });
+
+
+        inputTextField.setOnAction(event -> sendMessageAction());
+        sendButton.setOnAction(event -> sendMessageAction());
+    }
+
+
+    private void sendMessageAction() {
+        String message = inputTextField.getText().trim();
+        if (!message.isEmpty()) {
+
+            model.sendMessage(message);
+
+
+            inputTextField.clear();
+        }
+    }
+
+
+}

src/main/java/com/example/ChatMessage.java

@@ -0,0 +1,4 @@
+package com.example;
+
+public record ChatMessage(String content, long timestamp) {
+}

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

@@ -0,0 +1,31 @@
+package com.example;
+
+
+import javafx.application.Platform;
+import javafx.collections.FXCollections;
+import javafx.collections.ObservableList;
+
+public class ChatModel {
+    private final ObservableList<ChatMessage> messages = FXCollections.observableArrayList();
+
+    private final NtfyConnection ntfyConnection;
+
+    public ChatModel(NtfyConnection ntfyConnection) {
+        this.ntfyConnection = ntfyConnection;
+    }
+    public ObservableList<ChatMessage> getMessages() {
+        return messages;
+    }
+
+    public void sendMessage(String text) {
+        ntfyConnection.send(text);
+    }
+
+    public void startReceiving() {
+        ntfyConnection.receive(ntfyDto -> {
+            ChatMessage chatMsg = new ChatMessage(ntfyDto.message(), ntfyDto.time());
+
+            messages.add(chatMsg);
+        });
+    }
+}

src/main/java/com/example/NtfyConnection.java

@@ -0,0 +1,9 @@
+package com.example;
+
+import java.util.concurrent.CompletableFuture;
+import java.util.function.Consumer;
+
+public interface NtfyConnection {
+    CompletableFuture<Void> send(String message);
+    void receive(Consumer<NtfyMessageDto> messageHandler);
+}

src/main/java/com/example/NtfyConnectionImpl.java

@@ -0,0 +1,83 @@
+package com.example;
+
+import io.github.cdimascio.dotenv.Dotenv;
+import tools.jackson.databind.ObjectMapper;
+
+import java.net.URI;
+import java.net.http.HttpClient;
+import java.net.http.HttpRequest;
+import java.net.http.HttpResponse;
+import java.util.concurrent.CompletableFuture;
+import java.util.function.Consumer;
+
+public class NtfyConnectionImpl implements NtfyConnection {
+
+    private final HttpClient http = HttpClient.newHttpClient();
+    private final String hostName;
+    private final ObjectMapper mapper = new ObjectMapper();
+
+    public NtfyConnectionImpl() {
+        String loadedHostName = null;
+        try {
+            Dotenv dotenv = Dotenv.load();
+            loadedHostName = dotenv.get("HOST_NAME");
+        } catch (Exception e) {
+            System.err.println("WARNING: Could not load .env file for HOST_NAME. Using fallback.");
+        }
+
+        this.hostName = (loadedHostName != null)
+                ? loadedHostName
+                : "http://localhost:8080";
+
+        if (this.hostName.equals("http://localhost:8080")) {
+            System.out.println("DEBUG: NtfyConnectionImpl running in test/fallback mode.");
+        }
+    }
+
+    public NtfyConnectionImpl(String hostName) {
+        this.hostName = hostName;
+    }
+
+    @Override
+    public CompletableFuture<Void> send(String message) {
+        HttpRequest httpRequest = HttpRequest.newBuilder()
+                .POST(HttpRequest.BodyPublishers.ofString(message))
+                .uri(URI.create(hostName + "/mytopic"))
+                .build();
+
+        return http.sendAsync(httpRequest, HttpResponse.BodyHandlers.discarding())
+                .thenAccept(response -> {
+                    if (response.statusCode() >= 200 && response.statusCode() < 300) {
+                        System.out.println("Message sent successfully.");
+                    } else {
+                        System.err.println("Error while sending: " + response.statusCode());
+                    }
+                })
+                .exceptionally(e -> {
+                    System.err.println("Network issue: " + e.getMessage());
+                    return null;
+                });
+    }
+
+    @Override
+    public void receive(Consumer<NtfyMessageDto> messageHandler) {
+        HttpRequest httpRequest = HttpRequest.newBuilder()
+                .GET()
+                .uri(URI.create(hostName + "/mytopic/json"))
+                .build();
+
+        http.sendAsync(httpRequest, HttpResponse.BodyHandlers.ofLines())
+                .thenAccept(response -> response.body()
+                        .map(s -> {
+                            try {
+                                return mapper.readValue(s, NtfyMessageDto.class);
+                            } catch (Exception e) {
+                                System.err.println("Failed to parse message: " + e.getMessage());
+                                return null;
+                            }
+                        })
+                        .filter(messageDto -> messageDto != null && messageDto.event().equals("message"))
+                        .peek(System.out::println)
+                        .forEach(messageHandler));
+    }
+}