Loggers

.gitignore

@@ -35,3 +35,4 @@ out/
 
 ### VS Code ###
 .vscode/
+target/

pom.xml

@@ -31,6 +31,7 @@
     </properties>
     <dependencies>
         <dependency>
+
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-data-jpa</artifactId>
         </dependency>
@@ -71,6 +72,10 @@
             <artifactId>lombok</artifactId>
             <optional>true</optional>
         </dependency>
+        <dependency>
+            <groupId>org.hibernate.orm</groupId>
+            <artifactId>hibernate-envers</artifactId>
+        </dependency>
         <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-data-jpa-test</artifactId>

src/main/java/org/example/crimearchive/Entity/Golare/Golare.java

@@ -2,10 +2,11 @@
 
 
 import jakarta.persistence.*;
+import org.example.crimearchive.audit.Auditable;
 
 @Entity
 @Table(name = "golare")
-public class Golare {
+public class Golare extends Auditable {
 
     @Id
     @GeneratedValue(strategy = GenerationType.IDENTITY)

src/main/java/org/example/crimearchive/Entity/försvare/Advocat.java

@@ -1,4 +1,33 @@
 package org.example.crimearchive.Entity.försvare;
+import jakarta.persistence.*;
+import org.example.crimearchive.audit.Auditable;
+import java.time.LocalDate;
+import java.time.ZonedDateTime;
 
-public class Advocat {
+@Entity
+@Table(name = "advocat")
+public class Advocat extends Auditable {
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    private Long id;
+
+    @Column(nullable = false)
+    private String email;
+
+    @Column(nullable = false)
+    private String company;
+
+    @Column(nullable = false)
+    private String telephone;
+
+    @Column(nullable = false)
+    private String name;
+
+    private String knumber;
+
+    private LocalDate appointedTime;
+
+    private ZonedDateTime crimeTime;
+
+    // Getters and Setters if needed, or use Lombok if available
 }

src/main/java/org/example/crimearchive/Entity/Åklagare/Åklagare.java

@@ -2,10 +2,11 @@
 
 
 import jakarta.persistence.*;
+import org.example.crimearchive.audit.Auditable;
 
 @Entity
 @Table(name = "Åklagare")
-public class Åklagare {
+public class Åklagare extends Auditable {
 
     @Id
     @GeneratedValue(strategy = GenerationType.IDENTITY)

src/main/java/org/example/crimearchive/audit/Auditable.java

@@ -0,0 +1,54 @@
+package org.example.crimearchive.audit;
+
+
+import jakarta.persistence.*;
+import org.hibernate.envers.Audited;
+import org.springframework.data.annotation.*;
+import org.springframework.data.jpa.domain.support.AuditingEntityListener;
+
+import java.time.LocalDateTime;
+
+@MappedSuperclass
+@EntityListeners(AuditingEntityListener.class)
+@Audited
+public abstract class Auditable {
+
+    @CreatedBy
+    protected String createdBy;
+
+    @CreatedDate
+    protected LocalDateTime createdDate;
+
+    @LastModifiedBy
+    protected String lastModifiedBy;
+
+    @LastModifiedDate
+    protected LocalDateTime lastModifiedDate;
+
+    // Getters och Setters
+
+    public String getCreatedBy() {
+        return createdBy;
+    }
+    public void setCreatedBy(String createdBy) {
+        this.createdBy = createdBy;
+    }
+    public LocalDateTime getCreatedDate() {
+        return createdDate;
+    }
+    public void setCreatedDate(LocalDateTime createdDate) {
+        this.createdDate = createdDate;
+    }
+    public String getLastModifiedBy() {
+        return lastModifiedBy;
+    }
+    public void setLastModifiedBy(String lastModifiedBy) {
+        this.lastModifiedBy = lastModifiedBy;
+    }
+    public LocalDateTime getLastModifiedDate() {
+        return lastModifiedDate;
+    }
+    public void setLastModifiedDate(LocalDateTime lastModifiedDate) {
+        this.lastModifiedDate = lastModifiedDate;
+    }
+}

src/main/java/org/example/crimearchive/cases/CaseEventType.java

@@ -6,5 +6,6 @@ public enum CaseEventType {
     HANDLER_ASSIGNED,
     HANDLER_REMOVED,
     DOCUMENT_UPLOADED,
-    COMMENT_ADDED
+    COMMENT_ADDED,
+    ROLE_CHANGED
 }

src/main/java/org/example/crimearchive/cases/CaseLifecycleController.java

@@ -3,10 +3,12 @@
 import org.example.crimearchive.permissions.PermissionService;
 import org.example.crimearchive.polis.Account;
 import org.springframework.http.HttpStatus;
+import org.springframework.http.MediaType;
 import org.springframework.http.ResponseEntity;
 import org.springframework.security.core.annotation.AuthenticationPrincipal;
 import org.springframework.web.bind.annotation.*;
 import org.springframework.web.server.ResponseStatusException;
+import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;
 
 import java.util.List;
 
@@ -72,6 +74,13 @@ public ResponseEntity<List<CaseEventResponse>> getEvents(@PathVariable String ca
         return ResponseEntity.ok(events);
     }
 
+    @GetMapping(value = "/{caseNumber}/events/stream", produces = MediaType.TEXT_EVENT_STREAM_VALUE)
+    public SseEmitter streamEvents(@PathVariable String caseNumber,
+                                   @AuthenticationPrincipal Account user) {
+        requireAccess(caseNumber, user);
+        return lifecycleService.subscribe(caseNumber);
+    }
+
     private void requireAccess(String caseNumber, Account user) {
         if (!permissionService.canAccessCase(caseNumber, user)) {
             throw new ResponseStatusException(HttpStatus.FORBIDDEN, "Åtkomst nekad till ärende: " + caseNumber);

src/main/java/org/example/crimearchive/cases/CaseLifecycleService.java

@@ -4,8 +4,13 @@
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.web.server.ResponseStatusException;
+import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;
 
+import java.io.IOException;
+import java.util.ArrayList;
 import java.util.List;
+import java.util.concurrent.ConcurrentHashMap;
+import java.util.concurrent.CopyOnWriteArrayList;
 
 @Service
 public class CaseLifecycleService {
@@ -14,6 +19,8 @@ public class CaseLifecycleService {
     private final CaseEventRepository eventRepository;
     private final CaseCommentRepository commentRepository;
 
+    private final ConcurrentHashMap<String, CopyOnWriteArrayList<SseEmitter>> emitters = new ConcurrentHashMap<>();
+
     public CaseLifecycleService(CasesRepository casesRepository,
                                 CaseEventRepository eventRepository,
                                 CaseCommentRepository commentRepository) {
@@ -22,16 +29,25 @@ public CaseLifecycleService(CasesRepository casesRepository,
         this.commentRepository = commentRepository;
     }
 
+    public SseEmitter subscribe(String caseNumber) {
+        SseEmitter emitter = new SseEmitter(Long.MAX_VALUE);
+        emitters.computeIfAbsent(caseNumber, k -> new CopyOnWriteArrayList<>()).add(emitter);
+        emitter.onCompletion(() -> removeEmitter(caseNumber, emitter));
+        emitter.onTimeout(() -> removeEmitter(caseNumber, emitter));
+        emitter.onError(e -> removeEmitter(caseNumber, emitter));
+        return emitter;
+    }
+
     @Transactional
     public void initCase(Cases cases, String performedBy) {
         cases.setStatus(CaseStatus.OPEN);
-        eventRepository.save(new CaseEvent(cases, CaseEventType.CASE_CREATED,
+        saveAndBroadcast(new CaseEvent(cases, CaseEventType.CASE_CREATED,
                 "Ärende " + cases.getCaseNumber() + " skapades", performedBy));
     }
 
     @Transactional
     public void onHandlerAssigned(Cases cases, String handlerName, String performedBy) {
-        eventRepository.save(new CaseEvent(cases, CaseEventType.HANDLER_ASSIGNED,
+        saveAndBroadcast(new CaseEvent(cases, CaseEventType.HANDLER_ASSIGNED,
                 "Handläggare " + handlerName + " tilldelades ärendet", performedBy));
         if (cases.getStatus() == CaseStatus.OPEN) {
             updateStatus(cases, CaseStatus.ASSIGNED, performedBy);
@@ -40,7 +56,7 @@ public void onHandlerAssigned(Cases cases, String handlerName, String performedB
 
     @Transactional
     public void onHandlerRemoved(Cases cases, String handlerName, String performedBy) {
-        eventRepository.save(new CaseEvent(cases, CaseEventType.HANDLER_REMOVED,
+        saveAndBroadcast(new CaseEvent(cases, CaseEventType.HANDLER_REMOVED,
                 "Handläggare " + handlerName + " togs bort från ärendet", performedBy));
         // Only revert to OPEN from ASSIGNED — later states (IN_PROGRESS, CLOSED) are not disturbed by handler removal.
         if (cases.getAccounts().isEmpty() && cases.getStatus() == CaseStatus.ASSIGNED) {
@@ -50,10 +66,19 @@ public void onHandlerRemoved(Cases cases, String handlerName, String performedBy
 
     @Transactional
     public void onDocumentUploaded(Cases cases, String filename, String performedBy) {
-        eventRepository.save(new CaseEvent(cases, CaseEventType.DOCUMENT_UPLOADED,
+        saveAndBroadcast(new CaseEvent(cases, CaseEventType.DOCUMENT_UPLOADED,
                 "Dokument laddades upp: " + filename, performedBy));
     }
 
+    @Transactional
+    public void onRoleChanged(Long accountId, String username, List<String> oldRoles, List<String> newRoles, String performedBy) {
+        List<Cases> cases = casesRepository.findByAccountsId(accountId);
+        String description = "Roller för " + username + " ändrades från [" + String.join(", ", oldRoles) + "] till [" + String.join(", ", newRoles) + "]";
+        for (Cases c : cases) {
+            saveAndBroadcast(new CaseEvent(c, CaseEventType.ROLE_CHANGED, description, performedBy));
+        }
+    }
+
     @Transactional
     public CaseComment addComment(String caseNumber, String content, String author) {
         if (content == null || content.isBlank()) {
@@ -64,7 +89,7 @@ public CaseComment addComment(String caseNumber, String content, String author)
         }
         Cases cases = findCase(caseNumber);
         CaseComment comment = commentRepository.save(new CaseComment(cases, content, author));
-        eventRepository.save(new CaseEvent(cases, CaseEventType.COMMENT_ADDED,
+        saveAndBroadcast(new CaseEvent(cases, CaseEventType.COMMENT_ADDED,
                 author + " lade till en kommentar", author));
         return comment;
     }
@@ -93,10 +118,36 @@ public CaseStatus getStatus(String caseNumber) {
     private void updateStatus(Cases cases, CaseStatus newStatus, String performedBy) {
         CaseStatus previous = cases.getStatus();
         cases.setStatus(newStatus);
-        eventRepository.save(new CaseEvent(cases, CaseEventType.STATUS_CHANGED,
+        saveAndBroadcast(new CaseEvent(cases, CaseEventType.STATUS_CHANGED,
                 "Status ändrades från " + previous + " till " + newStatus, performedBy));
     }
 
+    private CaseEvent saveAndBroadcast(CaseEvent event) {
+        CaseEvent saved = eventRepository.save(event);
+        broadcast(event.getCaseEntity().getCaseNumber(), saved);
+        return saved;
+    }
+
+    private void broadcast(String caseNumber, CaseEvent event) {
+        CopyOnWriteArrayList<SseEmitter> list = emitters.get(caseNumber);
+        if (list == null || list.isEmpty()) return;
+        CaseEventResponse dto = CaseEventResponse.from(event);
+        List<SseEmitter> dead = new ArrayList<>();
+        for (SseEmitter emitter : list) {
+            try {
+                emitter.send(SseEmitter.event().name("case-event").data(dto));
+            } catch (IOException e) {
+                dead.add(emitter);
+            }
+        }
+        list.removeAll(dead);
+    }
+
+    private void removeEmitter(String caseNumber, SseEmitter emitter) {
+        CopyOnWriteArrayList<SseEmitter> list = emitters.get(caseNumber);
+        if (list != null) list.remove(emitter);
+    }
+
     private Cases findCase(String caseNumber) {
         return casesRepository.findFirstByCaseNumber(caseNumber)
                 .orElseThrow(() -> new ResponseStatusException(HttpStatus.NOT_FOUND,

src/main/java/org/example/crimearchive/cases/Cases.java

@@ -1,7 +1,8 @@
 package org.example.crimearchive.cases;
 
 import jakarta.persistence.*;
-import org.example.crimearchive.DTO.CreateReport;
+import org.example.crimearchive.audit.Auditable;
+import org.example.crimearchive.dto.CreateReport;
 import org.example.crimearchive.polis.Account;
 import org.example.crimearchive.reports.Report;
 
@@ -12,7 +13,7 @@
 import java.util.UUID;
 
 @Entity
-public class Cases {
+public class Cases extends Auditable {
     @Id
     @GeneratedValue(strategy = GenerationType.IDENTITY)
     private Long Id;

src/main/java/org/example/crimearchive/config/AuditConfig.java

@@ -0,0 +1,27 @@
+package org.example.crimearchive.config;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.domain.AuditorAware;
+import org.springframework.data.jpa.repository.config.EnableJpaAuditing;
+import org.springframework.security.core.Authentication;
+import org.springframework.security.core.context.SecurityContextHolder;
+
+import java.util.Optional;
+
+@Configuration
+@EnableJpaAuditing(auditorAwareRef = "auditorProvider")
+public class AuditConfig {
+
+    @Bean
+    public AuditorAware<String> auditorProvider() {
+        return () -> {
+            Authentication authentication = SecurityContextHolder.getContext().getAuthentication();
+            if (authentication == null || !authentication.isAuthenticated()) {
+                return Optional.of("SYSTEM");
+            }
+            return Optional.of(authentication.getName());
+        };
+    }
+}
+

src/main/java/org/example/crimearchive/config/S3Config.java

@@ -73,4 +73,4 @@ public ApplicationRunner createBucket(S3Client s3Client) {
             }
         };
     }
-}
+}

src/main/java/org/example/crimearchive/controllers/AccountsController.java

@@ -1,8 +1,8 @@
 package org.example.crimearchive.controllers;
 
 import jakarta.validation.Valid;
-import org.example.crimearchive.DTO.Polis.DTOCreatePolis;
-import org.example.crimearchive.DTO.Polis.DTOUpdatePolis;
+import org.example.crimearchive.dto.police.DTOCreatePolis;
+import org.example.crimearchive.dto.police.DTOUpdatePolis;
 import org.example.crimearchive.exceptions.PasswordValidationException;
 import org.example.crimearchive.polis.Account;
 import org.example.crimearchive.polis.UserService;

src/main/java/org/example/crimearchive/controllers/HomeController.java

@@ -1,7 +1,7 @@
 package org.example.crimearchive.controllers;
 
 import jakarta.validation.Valid;
-import org.example.crimearchive.DTO.CreateReport;
+import org.example.crimearchive.dto.CreateReport;
 import org.example.crimearchive.cases.CaseService;
 import org.example.crimearchive.cases.CasesRepository;
 import org.example.crimearchive.evidence.EvidenceFileService;

src/main/java/org/example/crimearchive/controllers/ProfileController.java

@@ -1,7 +1,7 @@
 package org.example.crimearchive.controllers;
 
 import jakarta.validation.Valid;
-import org.example.crimearchive.DTO.Polis.DTOUpdateProfile;
+import org.example.crimearchive.dto.police.DTOUpdateProfile;
 import org.example.crimearchive.cases.CaseLifecycleService;
 import org.example.crimearchive.cases.CaseService;
 import org.example.crimearchive.cases.CaseStatus;

src/main/java/org/example/crimearchive/DTO/CreateReport.java → src/main/java/org/example/crimearchive/dto/CreateReport.java

@@ -1,4 +1,4 @@
-package org.example.crimearchive.DTO;
+package org.example.crimearchive.dto;
 
 import jakarta.validation.constraints.NotBlank;
 import org.example.crimearchive.validations.ValidCasenumber;