yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2025-09-25 17:04:54 +00:00
Code Issues Packages Projects Releases Wiki Activity

FIX #15956 - Send web socket notification on incident assignment/ack (#16086)

Browse Source 
* fix: send websocket notification on incident assignment

* style: ran java linting
This commit is contained in:
Teddy 2024-04-30 14:17:06 +02:00 committed by GitHub
parent 89b083b6f2
commit 91f930d4c4
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/TestCaseResolutionStatusRepository.java
View File

@ -40,6 +40,7 @@ import org.openmetadata.service.util.EntityUtil;
import org.openmetadata.service.util.JsonUtils; import org.openmetadata.service.util.JsonUtils;
import org.openmetadata.service.util.RestUtil; import org.openmetadata.service.util.RestUtil;
import org.openmetadata.service.util.ResultList; import org.openmetadata.service.util.ResultList;
import org.openmetadata.service.util.WebsocketNotificationHandler;
import org.openmetadata.service.util.incidentSeverityClassifier.IncidentSeverityClassifierInterface; import org.openmetadata.service.util.incidentSeverityClassifier.IncidentSeverityClassifierInterface;
public class TestCaseResolutionStatusRepository public class TestCaseResolutionStatusRepository
@ -324,6 +325,9 @@ public class TestCaseResolutionStatusRepository
.withUpdatedAt(System.currentTimeMillis()); .withUpdatedAt(System.currentTimeMillis());
FeedRepository feedRepository = Entity.getFeedRepository(); FeedRepository feedRepository = Entity.getFeedRepository();
feedRepository.create(thread); feedRepository.create(thread);
// Send WebSocket Notification
WebsocketNotificationHandler.handleTaskNotification(thread);
} }
private void patchTaskAssignee(Thread originalTask, EntityReference newAssignee, String user) { private void patchTaskAssignee(Thread originalTask, EntityReference newAssignee, String user) {
@ -334,7 +338,11 @@ public class TestCaseResolutionStatusRepository
JsonPatch patch = JsonUtils.getJsonPatch(originalTask, updatedTask); JsonPatch patch = JsonUtils.getJsonPatch(originalTask, updatedTask);
FeedRepository feedRepository = Entity.getFeedRepository(); FeedRepository feedRepository = Entity.getFeedRepository();
feedRepository.patchThread(null, originalTask.getId(), user, patch); RestUtil.PatchResponse<Thread> thread =
feedRepository.patchThread(null, originalTask.getId(), user, patch);
// Send WebSocket Notification
WebsocketNotificationHandler.handleTaskNotification(thread.entity());
} }
public void inferIncidentSeverity(TestCaseResolutionStatus incident) { public void inferIncidentSeverity(TestCaseResolutionStatus incident) {