Labb3

.gitignore

@@ -1,2 +1,4 @@
 target/
 /.idea/
+.env
+*.iml

pom.xml

@@ -11,15 +11,22 @@
     <properties>
         <maven.compiler.release>25</maven.compiler.release>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
-        <junit.jupiter.version>6.0.0</junit.jupiter.version>
+        <junit.jupiter.version>5.9.2</junit.jupiter.version>
         <assertj.core.version>3.27.6</assertj.core.version>
         <mockito.version>5.20.0</mockito.version>
         <javafx.version>25</javafx.version>
+        <testfx.version>4.0.16-alpha</testfx.version>
     </properties>
     <dependencies>
         <dependency>
             <groupId>org.junit.jupiter</groupId>
-            <artifactId>junit-jupiter</artifactId>
+            <artifactId>junit-jupiter-api</artifactId>
+            <version>${junit.jupiter.version}</version>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.junit.jupiter</groupId>
+            <artifactId>junit-jupiter-engine</artifactId>
             <version>${junit.jupiter.version}</version>
             <scope>test</scope>
         </dependency>
@@ -35,6 +42,18 @@
             <version>${mockito.version}</version>
             <scope>test</scope>
         </dependency>
+        <dependency>
+            <groupId>org.testfx</groupId>
+            <artifactId>testfx-junit5</artifactId>
+            <version>${testfx.version}</version>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.testfx</groupId>
+            <artifactId>testfx-core</artifactId>
+            <version>${testfx.version}</version>
+            <scope>test</scope>
+        </dependency>
         <dependency>
             <groupId>org.openjfx</groupId>
             <artifactId>javafx-controls</artifactId>
@@ -45,8 +64,45 @@
             <artifactId>javafx-fxml</artifactId>
             <version>${javafx.version}</version>
         </dependency>
+        <dependency>
+            <groupId>org.openjfx</groupId>
+            <artifactId>javafx-base</artifactId>
+            <version>${javafx.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>com.fasterxml.jackson.core</groupId>
+            <artifactId>jackson-databind</artifactId>
+            <version>2.17.0</version>
+        </dependency>
+        <dependency>
+            <groupId>io.github.cdimascio</groupId>
+            <artifactId>dotenv-java</artifactId>
+            <version>3.1.0</version>
+        </dependency>
+        <dependency>
+            <groupId>org.jetbrains</groupId>
+            <artifactId>annotations</artifactId>
+            <version>24.0.1</version>
+        </dependency>
+        <dependency>
+            <groupId>org.testng</groupId>
+            <artifactId>testng</artifactId>
+            <version>RELEASE</version>
+            <scope>compile</scope>
+        </dependency>
     </dependencies>
     <build>
+        <resources>
+            <resource>
+                <directory>src/main/resources</directory>
+                <includes>
+                    <include>**/*.fxml</include>
+                    <include>**/*.css</include>
+                    <include>**/*.jpg</include>
+                    <include>**/*.png</include>
+                </includes>
+            </resource>
+        </resources>
         <plugins>
             <plugin>
                 <groupId>org.openjfx</groupId>
@@ -63,6 +119,17 @@
                     <noManPages>true</noManPages>
                 </configuration>
             </plugin>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-surefire-plugin</artifactId>
+                <version>3.2.5</version>
+                <configuration>
+                    <includes>
+                        <include>**/*Test.java</include>
+                        <include>**/*IT.java</include>
+                    </includes>
+                </configuration>
+            </plugin>
         </plugins>
     </build>
 </project>

src/main/java/com/example/ChatNetworkClient.java

@@ -0,0 +1,19 @@
+package com.example;
+
+import java.io.Closeable;
+import java.io.IOException;
+import java.util.function.Consumer;
+
+public interface ChatNetworkClient {
+    void send(String baseUrl, NtfyMessage message) throws Exception;
+
+    //Returnerar mitt egna Subscription-interface
+    Subscription subscribe(String baseUrl, String topic, Consumer<NtfyMessage> messageHandler);
+
+    //Inner interface för Subscription
+    interface Subscription extends Closeable {
+        @Override
+        void close() throws IOException;
+        boolean isOpen();
+    }
+}

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

@@ -1,22 +1,155 @@
 package com.example;
 
+import javafx.beans.binding.Bindings;
 import javafx.fxml.FXML;
 import javafx.scene.control.Label;
+import javafx.scene.control.ListView;
+import javafx.scene.control.TextField;
+import javafx.scene.control.Button;
+
+import java.io.IOException;
+import java.util.UUID;
 
 /**
  * Controller layer: mediates between the view (FXML) and the model.
  */
 public class HelloController {
 
-    private final HelloModel model = new HelloModel();
+    private final HelloModel model;
+    private final ChatNetworkClient httpClient;  // Abstraktion (Dependency Inversion)
+    private final String hostName;
+    private ChatNetworkClient.Subscription subscription;
+    private long subscriptionStartTime;
 
-    @FXML
-    private Label messageLabel;
+    @FXML private Label messageLabel;
+
+    //Nya FXML-komponenter:
+    @FXML private ListView<NtfyMessage> messageListView;     //Visar meddelanden från HelloModel
+    @FXML private TextField messageTextField;               //Används för att skriva nya meddelanden
+    @FXML private Button sendButton;                       //Används för att skicka meddelanden
+    @FXML private Label connectionStatusLabel;            // Status för anslutning
+
+    //Konstruktor för Dependency Injection
+    public HelloController(HelloModel model, ChatNetworkClient httpClient, String hostName) {
+        this.model = model;
+        this.httpClient = httpClient;
+        this.hostName = hostName;
+    }
 
     @FXML
     private void initialize() {
         if (messageLabel != null) {
             messageLabel.setText(model.getGreeting());
         }
+        //Binder listView till meddelandelistan i modellen
+        messageListView.setItems(model.getMessages());
+
+        //Binder anslutningsstatus till etiketten
+        connectionStatusLabel.textProperty().bind(
+                Bindings.when(model.connectedProperty())
+                        .then("Ansluten: ja")
+                        .otherwise("Ansluten: nej")
+        );
+    }
+
+    @FXML
+    private void sendMessage() {
+        String messageText = messageTextField.getText();
+        if (!messageText.isEmpty()) {
+            try {
+                NtfyMessage message = createMessage(messageText);
+                httpClient.send(hostName, message);
+                messageTextField.clear();
+            } catch (Exception e) {
+                handleSendError(e);
+            }
+        }
+    }
+
+    private NtfyMessage createMessage(String text) {
+        return new NtfyMessage(
+                UUID.randomUUID().toString(),
+                System.currentTimeMillis(),
+                "message",
+                "mytopic",
+                text
+        );
+    }
+
+    private void handleSendError(Exception e) {
+        System.err.println("Fel vid sändning: " + e.getMessage());
+    }
+
+
+    @FXML
+    private void subscribeToTopic() {
+        unsubscribeFromCurrentTopic();      // Stäng den gamla prenumerationen
+        model.getMessages().clear();       // Rensa gamla meddelanden
+        startNewSubscription();           // Starta ny prenumeration
+        model.setConnected(true);        // Uppdatera anslutningsstatus
+    }
+
+    private void unsubscribeFromCurrentTopic() {
+        if (subscription != null) {
+            try {
+                subscription.close();
+            } catch (IOException e) {
+                System.err.println("Kunde inte stänga gammal prenumeration: " + e.getMessage());
+            }
+        }
+    }
+
+    private void startNewSubscription() {
+        subscriptionStartTime = System.currentTimeMillis();  // Spara starttiden
+        subscription = httpClient.subscribe(
+                hostName,
+                "mytopic",
+                this::handleIncomingMessage
+        );
+    }
+
+    private void handleIncomingMessage(NtfyMessage message) {
+        System.out.println("Mottaget meddelande: " + message.id() + ", tid: " + message.time());
+        long messageTimeSeconds = message.time();
+        long currentTimeSeconds = System.currentTimeMillis() / 1000;
+
+        // Hoppa över gamla meddelanden
+        if (messageTimeSeconds < (subscriptionStartTime / 1000)) {
+            System.out.println("Hoppar över (gammalt meddelande).");
+            return;
+        }
+
+        // Hoppa över dubbletter
+        if (isDuplicateMessage(message)) {
+            System.out.println("Hoppar över (dublett).");
+            return;
+        }
+
+        // Lägg till meddelandet i modellen
+        System.out.println("Lägger till i modellen: " + message.message());
+        model.addMessage(message);
+    }
+
+    private boolean isDuplicateMessage(NtfyMessage message) {
+        return model.getMessages().stream()
+                .anyMatch(existingMessage -> existingMessage.id().equals(message.id()));
+    }
+
+
+    @FXML
+    private void unsubscribeFromTopic() {
+        if (subscription != null) {
+            closeSubscription();
+            model.setConnected(false);
+            subscription = null;  // Rensa referensen
+        }
+    }
+
+    private void closeSubscription() {
+        try {
+            subscription.close();
+        } catch (IOException e) {
+            System.err.println("Fel vid avprenumeration: " + e.getMessage());
+        }
     }
 }

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

@@ -1,19 +1,48 @@
 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.stage.Stage;
 
+import java.util.Objects;
+
 public class HelloFX extends Application {
 
     @Override
     public void start(Stage stage) throws Exception {
-        FXMLLoader fxmlLoader = new FXMLLoader(HelloFX.class.getResource("hello-view.fxml"));
+        Dotenv dotenv = Dotenv.load(); //Ladda .env-filen
+
+        String hostName = dotenv.get("HOST_NAME");
+
+        //Validering (valfritt)
+        if (hostName == null) {
+            throw new IllegalStateException(
+                    "Kunde inte läsa HOST_NAME från .env-filen. " +
+                    "Kontrollera att filen finns i projektets rotmapp!"
+            );
+        }
+
+        System.out.println("Ansluter till ntfy på:  " + hostName); //Debug-logg
+
+        HelloModel model = new HelloModel();
+        ChatNetworkClient httpClient = new NtfyHttpClient();
+
+        FXMLLoader fxmlLoader = new FXMLLoader(
+                HelloFX.class.getResource("/com/example/hello-view.fxml")
+        );
+        fxmlLoader.setControllerFactory(c -> new HelloController(model, httpClient, hostName));
+
         Parent root = fxmlLoader.load();
         Scene scene = new Scene(root, 640, 480);
-        stage.setTitle("Hello MVC");
+
+        scene.getStylesheets().add(
+                Objects.requireNonNull(getClass().getResource("/com/example/styles.css")).toExternalForm()
+        );
+
+        stage.setTitle("Chat App");
         stage.setScene(scene);
         stage.show();
     }