added handler for GetEntityHistorySummaryRequest

src/main/java/edu/stanford/protege/webprotegeeventshistory/uiHistoryConcern/dto/EntityChange.java

@@ -0,0 +1,16 @@
+package edu.stanford.protege.webprotegeeventshistory.uiHistoryConcern.dto;
+
+import edu.stanford.protege.webprotege.common.UserId;
+
+import java.time.LocalDateTime;
+
+public record EntityChange(String changeSummary,
+                           UserId userId,
+                           LocalDateTime dateTime) {
+
+    public static EntityChange create(String changeSummary,
+                                      UserId userId,
+                                      LocalDateTime dateTime){
+        return new EntityChange(changeSummary,userId,dateTime);
+    }
+}

src/main/java/edu/stanford/protege/webprotegeeventshistory/uiHistoryConcern/dto/EntityHistorySummary.java

@@ -0,0 +1,9 @@
+package edu.stanford.protege.webprotegeeventshistory.uiHistoryConcern.dto;
+
+import java.util.List;
+
+public record EntityHistorySummary(List<EntityChange> changes) {
+    public static EntityHistorySummary create(List<EntityChange> changes) {
+        return new EntityHistorySummary(changes);
+    }
+}

src/main/java/edu/stanford/protege/webprotegeeventshistory/uiHistoryConcern/handlers/GetEntityHistorySummaryCommandHandler.java

@@ -0,0 +1,38 @@
+package edu.stanford.protege.webprotegeeventshistory.uiHistoryConcern.handlers;
+
+import edu.stanford.protege.webprotege.common.ProjectId;
+import edu.stanford.protege.webprotege.ipc.*;
+import edu.stanford.protege.webprotegeeventshistory.uiHistoryConcern.dto.EntityHistorySummary;
+import edu.stanford.protege.webprotegeeventshistory.uiHistoryConcern.services.NewRevisionsEventService;
+import org.springframework.stereotype.Component;
+import reactor.core.publisher.Mono;
+
+import javax.annotation.Nonnull;
+
+@Component
+public class GetEntityHistorySummaryCommandHandler implements CommandHandler<GetEntityHistorySummaryRequest, GetEntityHistorySummaryResponse> {
+
+    private final NewRevisionsEventService service;
+
+    public GetEntityHistorySummaryCommandHandler(NewRevisionsEventService service) {
+        this.service = service;
+    }
+
+
+    @Nonnull
+    @Override
+    public String getChannelName() {
+        return GetEntityHistorySummaryRequest.CHANNEL;
+    }
+
+    @Override
+    public Class<GetEntityHistorySummaryRequest> getRequestClass() {
+        return GetEntityHistorySummaryRequest.class;
+    }
+
+    @Override
+    public Mono<GetEntityHistorySummaryResponse> handleRequest(GetEntityHistorySummaryRequest request, ExecutionContext executionContext) {
+        EntityHistorySummary entityHistorySummary = service.getEntityHistorySummary(ProjectId.valueOf(request.projectId()), request.entityIri());
+        return Mono.just(GetEntityHistorySummaryResponse.create(entityHistorySummary));
+    }
+}

src/main/java/edu/stanford/protege/webprotegeeventshistory/uiHistoryConcern/handlers/GetEntityHistorySummaryRequest.java

@@ -0,0 +1,23 @@
+package edu.stanford.protege.webprotegeeventshistory.uiHistoryConcern.handlers;
+
+import com.fasterxml.jackson.annotation.*;
+import edu.stanford.protege.webprotege.common.Request;
+
+@JsonTypeName(GetEntityHistorySummaryRequest.CHANNEL)
+public record GetEntityHistorySummaryRequest(
+        @JsonProperty("projectId") String projectId,
+        @JsonProperty("entityIri") String entityIri
+) implements Request<GetEntityHistorySummaryResponse> {
+
+    public static final String CHANNEL = "webprotege.history.GetEntityHistorySummary";
+
+    public static GetEntityHistorySummaryRequest create(String projectId,
+                                                        String entityIri) {
+        return new GetEntityHistorySummaryRequest(projectId, entityIri);
+    }
+
+    @Override
+    public String getChannel() {
+        return CHANNEL;
+    }
+}

src/main/java/edu/stanford/protege/webprotegeeventshistory/uiHistoryConcern/handlers/GetEntityHistorySummaryResponse.java

@@ -0,0 +1,16 @@
+package edu.stanford.protege.webprotegeeventshistory.uiHistoryConcern.handlers;
+
+import com.fasterxml.jackson.annotation.*;
+import edu.stanford.protege.webprotege.common.Response;
+import edu.stanford.protege.webprotegeeventshistory.uiHistoryConcern.dto.EntityHistorySummary;
+
+import static edu.stanford.protege.webprotegeeventshistory.uiHistoryConcern.handlers.GetEntityHistorySummaryRequest.CHANNEL;
+
+@JsonTypeName(CHANNEL)
+public record GetEntityHistorySummaryResponse(
+        @JsonProperty("entityHistorySummary") EntityHistorySummary entityHistorySummary
+) implements Response {
+    public static GetEntityHistorySummaryResponse create(EntityHistorySummary entityHistorySummary) {
+        return new GetEntityHistorySummaryResponse(entityHistorySummary);
+    }
+}

src/main/java/edu/stanford/protege/webprotegeeventshistory/uiHistoryConcern/repositories/RevisionsEventRepository.java

@@ -1,5 +1,6 @@
 package edu.stanford.protege.webprotegeeventshistory.uiHistoryConcern.repositories;
 
+import edu.stanford.protege.webprotege.common.ProjectId;
 import edu.stanford.protege.webprotegeeventshistory.uiHistoryConcern.events.RevisionsEvent;
 import org.springframework.data.mongodb.repository.*;
 
@@ -8,4 +9,7 @@
 public interface RevisionsEventRepository extends MongoRepository<RevisionsEvent, String> {
     @Query("{ 'projectId.id': ?0, 'timestamp': { $gt: ?1 } }")
     List<RevisionsEvent> findByProjectIdAndTimestampAfter(String projectId, long timestamp);
+
+    List<RevisionsEvent> findByProjectIdAndWhoficEntityIriOrderByTimestampDesc(ProjectId projectId, String whoficEntityIri);
+
 }

src/main/java/edu/stanford/protege/webprotegeeventshistory/uiHistoryConcern/services/NewRevisionsEventService.java

@@ -2,7 +2,7 @@
 
 import edu.stanford.protege.webprotege.change.ProjectChange;
 import edu.stanford.protege.webprotege.common.*;
-import edu.stanford.protege.webprotegeeventshistory.uiHistoryConcern.dto.ChangedEntities;
+import edu.stanford.protege.webprotegeeventshistory.uiHistoryConcern.dto.*;
 import edu.stanford.protege.webprotegeeventshistory.uiHistoryConcern.events.NewRevisionsEvent;
 import org.semanticweb.owlapi.model.OWLEntity;
 
@@ -16,4 +16,6 @@ public interface NewRevisionsEventService {
     Page<ProjectChange> fetchPaginatedProjectChanges(ProjectId projectId, Optional<OWLEntity> subject, int pageNumber, int pageSize);
 
     ChangedEntities getChangedEntitiesAfterTimestamp(ProjectId projectId, Timestamp timestamp);
+
+    EntityHistorySummary getEntityHistorySummary(ProjectId projectId, String entityIri);
 }

src/main/java/edu/stanford/protege/webprotegeeventshistory/uiHistoryConcern/services/NewRevisionsEventServiceImpl.java

@@ -14,6 +14,7 @@
 import org.springframework.transaction.annotation.Transactional;
 
 import java.sql.Timestamp;
+import java.time.*;
 import java.util.*;
 import java.util.stream.Collectors;
 
@@ -99,4 +100,20 @@ private static List<String> groupByChangeType(List<RevisionsEvent> revisionsEven
                 .distinct()
                 .collect(Collectors.toList());
     }
+
+    @Override
+    public EntityHistorySummary getEntityHistorySummary(ProjectId projectId, String entityIri) {
+        List<RevisionsEvent> revisionsForEntity = repository.findByProjectIdAndWhoficEntityIriOrderByTimestampDesc(projectId, entityIri);
+        List<EntityChange> entityChanges = revisionsForEntity.stream()
+                .map(revisionEvent -> {
+                            ProjectChange projectChange = projectChangeMapper.mapProjectChangeDocumentToProjectChange(revisionEvent.projectChange());
+                            Instant instant = Instant.ofEpochMilli(projectChange.getTimestamp());
+                            LocalDateTime localDateTime = LocalDateTime.ofInstant(instant, ZoneId.of("UTC"));
+                            return EntityChange.create(projectChange.getSummary(), projectChange.getAuthor(), localDateTime);
+                        }
+                ).toList();
+
+
+        return EntityHistorySummary.create(entityChanges);
+    }
 }