Cat chat

.gitignore

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

pom.xml

@@ -17,12 +17,29 @@
         <javafx.version>25</javafx.version>
     </properties>
     <dependencies>
+
+        <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.junit.jupiter</groupId>
             <artifactId>junit-jupiter</artifactId>
             <version>${junit.jupiter.version}</version>
             <scope>test</scope>
         </dependency>
+        <dependency>
+            <groupId>org.wiremock</groupId>
+            <artifactId>wiremock</artifactId>
+            <version>4.0.0-beta.15</version>
+            <scope>test</scope>
+        </dependency>
         <dependency>
             <groupId>org.assertj</groupId>
             <artifactId>assertj-core</artifactId>
@@ -45,6 +62,12 @@
             <artifactId>javafx-fxml</artifactId>
             <version>${javafx.version}</version>
         </dependency>
+        <dependency>
+            <groupId>org.awaitility</groupId>
+            <artifactId>awaitility</artifactId>
+            <version>4.3.0</version>
+            <scope>test</scope>
+        </dependency>
     </dependencies>
     <build>
         <plugins>
@@ -63,6 +86,15 @@
                     <noManPages>true</noManPages>
                 </configuration>
             </plugin>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-compiler-plugin</artifactId>
+                <configuration>
+                    <source>25</source>
+                    <target>25</target>
+                    <compilerArgs>--enable-preview</compilerArgs>
+                </configuration>
+            </plugin>
         </plugins>
     </build>
 </project>

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

@@ -1,22 +1,148 @@
 package com.example;
 
+import javafx.application.Platform;
+import javafx.collections.ListChangeListener;
 import javafx.fxml.FXML;
-import javafx.scene.control.Label;
+import javafx.geometry.Pos;
+import javafx.scene.control.*;
+import javafx.scene.layout.HBox;
+import javafx.scene.layout.VBox;
 
 /**
  * Controller layer: mediates between the view (FXML) and the model.
+ * Handles updates of the chat-window.
  */
 public class HelloController {
 
-    private final HelloModel model = new HelloModel();
+    //En model skapas som i bakgrunden är en lista och håller koll på meddelanden
+    private final HelloModel model = new HelloModel(new NtfyConnectionImpl());
 
+    //@FXML kopplingar
     @FXML
-    private Label messageLabel;
+    private Button connectToServer;
 
+    @FXML
+    private Button disconnectFromServer;
+
+    //Kopplar ett textfält från FXML där användaren skriver ett meddelande
+    @FXML
+    private TextField messageInput;
+
+    //Kopplar en knapp från FXML som klickas på för att skicka meddelandet
+    @FXML
+    private Button sendButton;
+
+
+    //Ytan för alla meddelanden som visas
+    @FXML
+    private ListView<NtfyMessageDto> chatBox;
+
+    //Metoden körs automatiskt när appen startar
     @FXML
     private void initialize() {
-        if (messageLabel != null) {
-            messageLabel.setText(model.getGreeting());
+        //todo: Initialisera uppkopplingsknapparna för server-anslutning
+        //todo: metod för nätverksuppkoppling?
+
+        //Sätter ursprungstillståndet (default) för skicka-knappen
+
+        updateSendButtonState();
+
+        //Lägger till en lyssnare för att uppdatera knappen vid inmatning av text
+        messageInput.textProperty().addListener((observable, oldValue, newValue) -> updateSendButtonState());
+
+        //Om användaren trycker på Enter eller klickar med musen -> skicka meddelandet
+        messageInput.setOnAction((event) -> sendMessageToModel());
+        sendButton.setOnAction(event -> sendMessageToModel());
+
+        disconnectFromServer.setOnAction(event -> setDisconnectFromServer());
+        connectToServer.setOnAction(event -> setConnectToServer());
+
+        disconnectFromServer.setDisable(true);
+
+        //model.receiveMessage();
+        //Styr hur varje meddelande ska visas i chatboxen
+        chatBox.setCellFactory(listView -> new ListCell<>() {
+            @Override
+            protected void updateItem(NtfyMessageDto item, boolean empty) {
+                super.updateItem(item, empty);
+                //Kräver en null check då JavaFX återanvänder cellerna
+               if (item == null || empty) {
+                   setText(null);
+                   setGraphic(null);
+            }
+            else{
+                //Skapar en label med meddelande-texten och sätter en stil från css
+                   Label label = new Label(item.message());
+                    label.getStyleClass().add("message-bubble");
+
+                    String time = item.formattedTime();
+                    Label labelTime = new Label(time);
+                    labelTime.getStyleClass().add("time-stamp");
+
+                    //Layout
+                   VBox messageBox = new VBox(label, labelTime);
+                   messageBox.setSpacing(2);
+
+                   //Vänster eller höger i ListView
+                   HBox hbox = new HBox(messageBox);
+                   hbox.setMaxWidth(chatBox.getWidth()-20);
+
+                   String messagePosition = item.message();
+                   if (messagePosition != null && messagePosition.startsWith("User:")) {
+                       hbox.setAlignment(javafx.geometry.Pos.CENTER_RIGHT);
+                       label.getStyleClass().add("outgoing-message");
+                   } else {
+                       hbox.setAlignment(javafx.geometry.Pos.CENTER_LEFT);
+                       label.getStyleClass().add("incoming-message");
+                   }
+                    setGraphic(hbox);
+                }
+            }
+        });
+        //Kopplar Listan i view med ObservableList i HelloModel
+        chatBox.setItems(model.getMessages());
+        //Flyttar Platform.runlater till controller på grund av runtimeexeption när tester körs, även för en mer solid MVC
+        model.getMessages().addListener((ListChangeListener<NtfyMessageDto>) changes -> {
+            chatBox.refresh();
+        });
+    }
+
+    private void sendMessageToModel() {
+        String outgoingMessage = messageInput.getText().trim();
+        //Kontrollerar om text-fältet är tomt
+        if (!outgoingMessage.isEmpty()) {
+            model.sendMessage("User: " + outgoingMessage);
+            //tömmer sedan fältet där text matas in(prompt-meddelande visas igen)
+            messageInput.clear();
         }
     }
-}
+
+    private void updateSendButtonState() {
+        // Kollar om texten, efter att ha tagit bort ledande/efterföljande mellanslag, är tom.
+        boolean isTextPresent = !messageInput.getText().trim().isEmpty();
+
+        //Nytt villkor för button för att ej kunna skicka meddelanden till servern om ej connectad
+        boolean isConnected = !disconnectFromServer.isDisabled();
+
+        // Sätt disable till TRUE om det INTE finns text.
+        sendButton.setDisable(!isTextPresent || !isConnected);
+    }
+
+    //Starta prenumeration via model och uppdaterar button
+    public void setConnectToServer() {
+        if(disconnectFromServer.isDisable()) {
+            model.receiveMessage();
+            connectToServer.setDisable(true);
+            disconnectFromServer.setDisable(false);
+            updateSendButtonState();
+        }
+    }
+
+    //Stoppar prenumerationen och uppdaterar button
+    public void setDisconnectFromServer() {
+        model.stopSubscription();
+        connectToServer.setDisable(false);
+        disconnectFromServer.setDisable(true);
+        updateSendButtonState();
+    }
+}

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

@@ -1,19 +1,24 @@
 package com.example;
 
+import io.github.cdimascio.dotenv.Dotenv;
 import javafx.application.Application;
 import javafx.fxml.FXMLLoader;
 import javafx.scene.Parent;
 import javafx.scene.Scene;
+import javafx.scene.image.Image;
 import javafx.stage.Stage;
 
 public class HelloFX extends Application {
 
     @Override
     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 scene = new Scene(root, 540, 650);
+        stage.setTitle("CatCode Messenger");
+        stage.getIcons().add(new Image(getClass().getResourceAsStream("/coolCat.png")));
+
         stage.setScene(scene);
         stage.show();
     }

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

@@ -1,15 +1,86 @@
 package com.example;
 
+import io.github.cdimascio.dotenv.Dotenv;
+import javafx.application.Platform;
+import javafx.beans.property.SimpleStringProperty;
+import javafx.beans.property.StringProperty;
+import javafx.collections.FXCollections;
+import javafx.collections.ObservableList;
+
+import java.io.IOException;
+
+
 /**
  * Model layer: encapsulates application data and business logic.
  */
 public class HelloModel {
     /**
-     * Returns a greeting based on the current Java and JavaFX versions.
+     * Handles and returns a list of messages observed by JavaFX
+     * Stores, changes and returns data.
      */
-    public String getGreeting() {
-        String javaVersion = System.getProperty("java.version");
-        String javafxVersion = System.getProperty("javafx.version");
-        return "Hello, JavaFX " + javafxVersion + ", running on Java " + javaVersion + ".";
+
+    //Lista som håller alla meddelanden
+    //FXCollections.observableArrayList() = Nyckel som gör listan ändrings-bar och uppdaterar GUIt
+    private final ObservableList<NtfyMessageDto> messages = FXCollections.observableArrayList();
+
+//Kopplar upp till nätverket , används för att skicka och ta emot meddelanden
+    private final NtfyConnection connection;
+    //Innehåller meddelandet som ska skickas, kopplat till GUI via SimpleStringProperty
+    private final StringProperty messageToSend = new SimpleStringProperty();
+    //Fält för att kunna styra anslutningen
+    private Subscription subscription = null;
+
+    //Konstruktorn tar emot nätverkskoppling, antingen ett test via spy eller en riktig via impl
+    public HelloModel(NtfyConnection connection) {
+
+        this.connection = connection;
+        //subscription = receiveMessage(); //subscription startar automatiskt när modellen skapas
+    }
+
+    //getter från private, används av controller för att koppla til ListView
+    public ObservableList<NtfyMessageDto> getMessages() {
+        return messages;
+    }
+    //test
+    public String getMessageToSend() {
+        return messageToSend.get();
+    }
+//Getter från private för meddelandet som ska skickas
+    public StringProperty messageToSendProperty() {
+        return messageToSend;
+    }
+//Sätter meddelande för tester
+    public void setMessageToSend(String message) {
+        messageToSend.set(message);
+    }
+
+    //Sätter meddelandet till inkommande parameter från test, eller controller (connection skickar till nätverket)
+    public void sendMessage(String message) {
+
+        messageToSend.set(message);
+        connection.send(messageToSend.get());
+
+    }
+
+    //Startar en prenumeration på inkommande meddelnaden,
+    //Returnerar ett Subscription-objekt så den kan stoppas
+    public Subscription receiveMessage() {
+if(subscription != null && subscription.isOpen()) {
+    return this.subscription;
+}
+    return subscription = connection.receive(messages::add);
+
+
+    }
+
+    public void stopSubscription() {
+        if (subscription != null && subscription.isOpen())
+            try{
+            subscription.close();
+        } catch(IOException e) {
+                System.out.println("Error closing subscription" + e.getMessage());
+            }
     }
 }
+
+

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

@@ -0,0 +1,17 @@
+package com.example;
+
+
+import java.nio.file.Path;
+import java.util.function.Consumer;
+
+public interface NtfyConnection {
+
+    //Skicka ett meddelande till servern
+    boolean send(String message);
+
+    boolean sendFile(Path file, String messageWithFile);
+
+    //Startar en prenumeration och tar emot en consumer som ska köras varje gång ett meddelande kommer
+   Subscription receive(Consumer<NtfyMessageDto> consumer);
+
+}