Feature/message input

.gitignore

@@ -1,2 +1,4 @@
 target/
 /.idea/
+.env
+package-lock.json

pom.xml

@@ -45,6 +45,22 @@
             <artifactId>javafx-fxml</artifactId>
             <version>${javafx.version}</version>
         </dependency>
+        <dependency>
+            <groupId>tools.jackson.core</groupId>
+            <artifactId>jackson-databind</artifactId>
+            <version>3.0.1</version>
+        </dependency>
+        <dependency>
+            <groupId>io.github.cdimascio</groupId>
+            <artifactId>dotenv-java</artifactId>
+            <version>3.2.0</version>
+        </dependency>
+        <dependency>
+            <groupId>org.wiremock</groupId>
+            <artifactId>wiremock</artifactId>
+            <version>4.0.0-beta.15</version>
+            <scope>test</scope>
+        </dependency>
     </dependencies>
     <build>
         <plugins>

src/main/java/com/example/HelloController.java

@@ -1,22 +1,86 @@
 package com.example;
-
+import javafx.event.ActionEvent;
 import javafx.fxml.FXML;
-import javafx.scene.control.Label;
+import javafx.geometry.Insets;
+import javafx.scene.control.*;
+import javafx.scene.layout.HBox;
 
 /**
  * Controller layer: mediates between the view (FXML) and the model.
  */
 public class HelloController {
 
-    private final HelloModel model = new HelloModel();
+    private final HelloModel model = new HelloModel(new NtfyConnectionImpl());
+    public ListView<NtfyMessageDto> messageView;
 
     @FXML
     private Label messageLabel;
 
+    @FXML
+    private TextField messageField;
+
     @FXML
     private void initialize() {
         if (messageLabel != null) {
             messageLabel.setText(model.getGreeting());
         }
+        messageView.setItems(model.getMessages());
+
+        messageView.setCellFactory(list -> new ListCell<>() {
+            private final Label messageLabel = new Label();
+            private final HBox bubble = new HBox(messageLabel);
+            {
+                bubble.setPadding(new Insets(5, 10, 5, 10));
+                bubble.setMaxWidth(200);
+                messageLabel.setWrapText(true);
+                bubble.getStyleClass().add("chat-bubble");
+            }
+
+            @Override
+            protected void updateItem(NtfyMessageDto item, boolean empty) {
+                super.updateItem(item, empty);
+                if (empty || item == null) {
+                    setGraphic(null);
+                } else {
+                    // Format tid + text
+                    java.time.LocalTime time = java.time.Instant.ofEpochSecond(item.time())
+                            .atZone(java.time.ZoneId.systemDefault())
+                            .toLocalTime();
+                    String formattedTime = time.format(java.time.format.DateTimeFormatter.ofPattern("HH:mm"));
+
+                    messageLabel.setText(formattedTime + "\n" + item.message());
+                    setGraphic(bubble);
+                }
+            }
+        });
+
+        model.messageToSendProperty().bind(messageField.textProperty());
+
+    }
+
+    public void sendMessage(ActionEvent actionEvent) {
+        String message = messageField.getText();
+        if(message == null || message.isBlank()){
+            showTemporaryAlert("You must write something before sending!");
+            return;
+        }
+
+        model.sendMessage();
+        messageField.clear();
+    }
+
+    private void showTemporaryAlert(String alertMessage) {
+        Alert alert = new Alert(Alert.AlertType.WARNING);
+        alert.setHeaderText(null);
+        alert.setContentText(alertMessage);
+        alert.initOwner(messageField.getScene().getWindow());
+
+        alert.show();
+
+        new Thread(() -> {
+            try {
+                Thread.sleep(2000);
+            } catch (InterruptedException e) {}
+        }).start();
     }
 }

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

@@ -1,5 +1,4 @@
 package com.example;
-
 import javafx.application.Application;
 import javafx.fxml.FXMLLoader;
 import javafx.scene.Parent;
@@ -13,7 +12,8 @@ public void start(Stage stage) throws Exception {
         FXMLLoader fxmlLoader = new FXMLLoader(HelloFX.class.getResource("hello-view.fxml"));
         Parent root = fxmlLoader.load();
         Scene scene = new Scene(root, 640, 480);
-        stage.setTitle("Hello MVC");
+        scene.getStylesheets().add(getClass().getResource("style.css").toExternalForm());
+        stage.setTitle("Chatt Client");
         stage.setScene(scene);
         stage.show();
     }

src/main/java/com/example/HelloModel.java

@@ -1,15 +1,55 @@
 package com.example;
+import javafx.application.Platform;
+import javafx.beans.property.SimpleStringProperty;
+import javafx.beans.property.StringProperty;
+import javafx.collections.FXCollections;
+import javafx.collections.ObservableList;
+
 
 /**
  * Model layer: encapsulates application data and business logic.
  */
 public class HelloModel {
+
+     private final NtfyConnection connection;
+
+     private final ObservableList<NtfyMessageDto> messages = FXCollections.observableArrayList();
+     private final StringProperty messageToSend = new SimpleStringProperty();
+
+     public HelloModel(NtfyConnection connection) {
+         this.connection = connection;
+         receiveMessage();
+     }
+
+    public ObservableList<NtfyMessageDto> getMessages() {
+         return messages;
+    }
+
+    public String getMessageToSend() {
+         return messageToSend.get();
+    }
+
+    public StringProperty messageToSendProperty() {
+         return messageToSend;
+    }
+
+    public void setMessageToSend(String message) {
+         messageToSend.set(message);
+    }
+
     /**
      * Returns a greeting based on the current Java and JavaFX versions.
      */
     public String getGreeting() {
-        String javaVersion = System.getProperty("java.version");
-        String javafxVersion = System.getProperty("javafx.version");
-        return "Hello, JavaFX " + javafxVersion + ", running on Java " + javaVersion + ".";
+        return "Chat Client by Adam";
+    }
+
+    public void sendMessage() {
+        connection.send(messageToSend.get());
+
+    }
+
+    public void receiveMessage() {
+        connection.receive(m->Platform.runLater(()->messages.add(m)));
     }
 }

src/main/java/com/example/ManyParameters.java

@@ -0,0 +1,17 @@
+package com.example;
+
+public class ManyParameters {
+
+    public ManyParameters(String computerName, int timeout, String method, int size, byte[] data){
+
+    }
+
+    static void main(){
+        ManyParametersBuilder builder = new ManyParametersBuilder();
+        builder
+                .setComputerName("localhost") // Fluent API
+                .setTimeout(10)
+                .setSize(0)
+                .createManyParameters();
+    }
+}

src/main/java/com/example/ManyParametersBuilder.java

@@ -0,0 +1,38 @@
+package com.example;
+
+public class ManyParametersBuilder {
+    private String computerName;
+    private int timeout = 0;
+    private String method;
+    private int size = 0;
+    private byte[] data = null;
+
+    public ManyParametersBuilder setComputerName(String computerName) {
+        this.computerName = computerName;
+        return this;
+    }
+
+    public ManyParametersBuilder setTimeout(int timeout) {
+        this.timeout = timeout;
+        return this;
+    }
+
+    public ManyParametersBuilder setMethod(String method) {
+        this.method = method;
+        return this;
+    }
+
+    public ManyParametersBuilder setSize(int size) {
+        this.size = size;
+        return this;
+    }
+
+    public ManyParametersBuilder setData(byte[] data) {
+        this.data = data;
+        return this;
+    }
+
+    public ManyParameters createManyParameters() {
+        return new ManyParameters(computerName, timeout, method, size, data);
+    }
+}

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

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

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

@@ -0,0 +1,62 @@
+package com.example;
+import io.github.cdimascio.dotenv.Dotenv;
+import tools.jackson.databind.ObjectMapper;
+import java.io.IOException;
+import java.net.URI;
+import java.net.http.HttpClient;
+import java.net.http.HttpRequest;
+import java.net.http.HttpResponse;
+import java.util.Objects;
+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();
+
+    NtfyConnectionImpl(){
+        Dotenv dotenv = Dotenv.load();
+        hostName = Objects.requireNonNull(dotenv.get("HOST_NAME"));
+    }
+
+    public NtfyConnectionImpl(String hostName){
+        this.hostName = hostName;
+    }
+
+    @Override
+    public boolean send(String message) {
+                HttpRequest httpRequest = HttpRequest.newBuilder()
+                .POST(HttpRequest.BodyPublishers.ofString(message))
+                .uri(URI.create(hostName + "/mytopic"))
+                .build();
+        try {
+            // TODO: handle long blocking send requests to not freeze the JavaFX thread
+            // 1. Use thread send message?
+            // 2. Use async?
+            var response = http.send(httpRequest, HttpResponse.BodyHandlers.ofString());
+            return true;
+        } catch (IOException e) {
+            System.out.println("Error sending message");
+        } catch (InterruptedException e) {
+            System.out.println("Interrupted sending message");
+        }
+        return false;
+    }
+
+    @Override
+    public void receive(Consumer<NtfyMessageDto> messageHandler) {
+        HttpRequest httpRequest = HttpRequest.newBuilder()
+                .GET()
+                .uri(URI.create(hostName + "/mytopic/json?since=wBuD2KGEaAe0"))
+                .build();
+
+        http.sendAsync(httpRequest, HttpResponse.BodyHandlers.ofLines())
+                .thenAccept(response -> response.body()
+                        .map(s->
+                                mapper.readValue(s, NtfyMessageDto.class))
+                        .filter(message -> message.event().equals("message"))
+                        .peek(System.out::println)
+                        .forEach(messageHandler));
+    }
+}

src/main/java/com/example/NtfyMessageDto.java

@@ -0,0 +1,6 @@
+package com.example;
+
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+
+@JsonIgnoreProperties(ignoreUnknown = true)
+public record NtfyMessageDto(String id, long time, String event, String topic, String message) {}

src/main/java/com/example/Singelton.java

@@ -0,0 +1,13 @@
+package com.example;
+
+public class Singelton {
+    private final static Singelton instance = new Singelton();
+
+    private Singelton() {
+
+    }
+
+    public static Singelton getInstance() {
+        return instance;
+    }
+}

src/main/java/module-info.java

@@ -1,6 +1,10 @@
 module hellofx {
     requires javafx.controls;
     requires javafx.fxml;
+    requires io.github.cdimascio.dotenv.java;
+    requires java.net.http;
+    requires tools.jackson.databind;
+    requires javafx.graphics;
 
     opens com.example to javafx.fxml;
     exports com.example;

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

@@ -1,9 +1,22 @@
 <?xml version="1.0" encoding="UTF-8"?>
-<?import javafx.scene.layout.StackPane?>
-<?import javafx.scene.control.Label?>
-
-<StackPane xmlns="http://javafx.com/javafx" xmlns:fx="http://javafx.com/fxml" fx:controller="com.example.HelloController">
-    <children>
-        <Label fx:id="messageLabel" text="Hello, JavaFX!" />
-    </children>
-</StackPane>
+
+<?import javafx.scene.control.*?>
+<?import javafx.scene.layout.*?>
+
+<?import javafx.geometry.Insets?>
+<VBox alignment="CENTER" stylesheets="@style.css" xmlns="http://javafx.com/javafx/17.0.12" xmlns:fx="http://javafx.com/fxml/1" fx:controller="com.example.HelloController">
+
+    <Label fx:id="messageLabel" text="Adams Chat Client" />
+    <ListView fx:id="messageView" />
+
+
+    <HBox alignment="CENTER_RIGHT" spacing="5" prefHeight="40" maxWidth="600">
+        <VBox.margin>
+            <Insets top="10" left="10" right="10" bottom="10" />
+        </VBox.margin>
+
+        <TextField fx:id="messageField" prefHeight="40" promptText="Write something here.." HBox.hgrow="ALWAYS" />
+        <Button onAction="#sendMessage" prefHeight="40" prefWidth="80" text="Send" />
+    </HBox>
+
+</VBox>