add changeRequestId to NewRevisionsEvent for history rollback

protegeproject · Dec 11, 2024 · 458f5ca · 458f5ca
1 parent b873b8e
commit 458f5ca
Show file tree

Hide file tree

Showing 4 changed files with 10 additions and 7 deletions.
diff --git a/src/main/java/edu/stanford/protege/webprotege/project/chg/ChangeManager.java b/src/main/java/edu/stanford/protege/webprotege/project/chg/ChangeManager.java
@@ -341,7 +341,7 @@ public <R> ChangeApplicationResult<R> applyChanges(@Nonnull final UserId userId,
 
             revision.ifPresent(value -> projectRevisionRepository.save(new ProjectRevision(projectId, changeRequestId, userId, value.getRevisionNumber())));
 
-            newRevisionsEmitter.emitNewRevisionsEvent(revision);
+            newRevisionsEmitter.emitNewRevisionsEvent(revision, changeRequestId);
 
         } finally {
             changeProcesssingLock.unlock();

diff --git a/...ain/java/edu/stanford/protege/webprotege/revision/uiHistoryConcern/NewRevisionsEvent.java b/...ain/java/edu/stanford/protege/webprotege/revision/uiHistoryConcern/NewRevisionsEvent.java
@@ -11,14 +11,16 @@
 public record NewRevisionsEvent(
         EventId eventId,
         ProjectId projectId,
-        Set<ProjectChangeForEntity> changes
+        Set<ProjectChangeForEntity> changes,
+        ChangeRequestId changeRequestId
 ) implements ProjectEvent {
     public final static String CHANNEL = "webprotege.events.projects.uiHistory.NewRevisionsEvent";
 
     public static NewRevisionsEvent create(EventId eventId,
                                            ProjectId projectId,
-                                           Set<ProjectChangeForEntity> changes) {
-        return new NewRevisionsEvent(eventId, projectId, changes);
+                                           Set<ProjectChangeForEntity> changes,
+                                           ChangeRequestId changeRequestId) {
+        return new NewRevisionsEvent(eventId, projectId, changes, changeRequestId);
     }
 
     @NotNull

diff --git a/...tanford/protege/webprotege/revision/uiHistoryConcern/NewRevisionsEventEmitterService.java b/...tanford/protege/webprotege/revision/uiHistoryConcern/NewRevisionsEventEmitterService.java
@@ -1,9 +1,10 @@
 package edu.stanford.protege.webprotege.revision.uiHistoryConcern;
 
+import edu.stanford.protege.webprotege.common.ChangeRequestId;
 import edu.stanford.protege.webprotege.revision.Revision;
 
 import java.util.Optional;
 
 public interface NewRevisionsEventEmitterService {
-    void emitNewRevisionsEvent(Optional<Revision> revision);
+    void emitNewRevisionsEvent(Optional<Revision> revision, ChangeRequestId changeRequestId);
 }
diff --git a/...ord/protege/webprotege/revision/uiHistoryConcern/NewRevisionsEventEmitterServiceImpl.java b/...ord/protege/webprotege/revision/uiHistoryConcern/NewRevisionsEventEmitterServiceImpl.java
@@ -28,13 +28,13 @@ public NewRevisionsEventEmitterServiceImpl(ProjectChangesManager changesManager,
 
 
     @Override
-    public void emitNewRevisionsEvent(Optional<Revision> revision) {
+    public void emitNewRevisionsEvent(Optional<Revision> revision, ChangeRequestId changeRequestId) {
         revision.ifPresent(rev -> {
             Set<ProjectChangeForEntity> changes = changesManager.getProjectChangesForEntitiesFromRevision(rev);
             //Based on axioms in the revision we can determine if the entity was added/deleted or updated
             //e.g. for adding a new entity you have Declaration axiom
             //
-            NewRevisionsEvent revisionsEvent = NewRevisionsEvent.create(EventId.generate(), projectId, changes);
+            NewRevisionsEvent revisionsEvent = NewRevisionsEvent.create(EventId.generate(), projectId, changes, changeRequestId);
             eventDispatcher.dispatchEvent(revisionsEvent);
         });
     }