chore: update realtime WS event names to prefixed format (#357)

Author: Copilot

crowdin/src/main/java/com/crowdin/platform/realtimeupdate/EchoWebSocketListener.kt

@@ -162,7 +162,7 @@ internal class EchoWebSocketListener(
         mappingValue: String,
     ) {
         try {
-            val updateEvent = "$UPDATE_DRAFT:${project.wsHash}:${project.id}:${user.id}:$languageCode:$mappingValue"
+            val updateEvent = "$UPDATE_DRAFT:${project.wsHash}:pr{${project.id}}:us{${user.id}}:$languageCode:tr{$mappingValue}"
             dataManager.getTicket(updateEvent)?.let {
                 webSocket.send(getSubscribeEventJson(updateEvent, it))
             }
@@ -171,7 +171,7 @@ internal class EchoWebSocketListener(
         }
 
         try {
-            val suggestionEvent = "$TOP_SUGGESTION:${project.wsHash}:${project.id}:$languageCode:$mappingValue"
+            val suggestionEvent = "$TOP_SUGGESTION:${project.wsHash}:pr{${project.id}}:$languageCode:tr{$mappingValue}"
             dataManager.getTicket(suggestionEvent)?.let {
                 webSocket.send(getSubscribeEventJson(suggestionEvent, it))
             }
@@ -197,7 +197,7 @@ internal class EchoWebSocketListener(
             val eventData = eventResponse.data
 
             if (event.contains(UPDATE_DRAFT) || event.contains(TOP_SUGGESTION)) {
-                val mappingId = event.split(":").last()
+                val mappingId = extractMappingId(event)
                 for (mutableEntry in dataHolderMap) {
                     val textMetaData = mutableEntry.value
                     if (textMetaData.mappingValue == mappingId) {
@@ -249,6 +249,15 @@ internal class EchoWebSocketListener(
 
     private fun parseResponse(response: String): EventResponse = Gson().fromJson(response, EventResponse::class.java)
 
+    private fun extractMappingId(event: String): String {
+        val lastSegment = event.split(":").last()
+        return if (lastSegment.startsWith("tr{") && lastSegment.endsWith("}")) {
+            lastSegment.removePrefix("tr{").removeSuffix("}")
+        } else {
+            lastSegment
+        }
+    }
+
     private fun output(message: String) {
         Log.d(EchoWebSocketListener::class.java.simpleName, message)
     }

crowdin/src/test/java/com/crowdin/platform/EchoWebSocketListenerTest.kt

@@ -11,8 +11,54 @@ import org.junit.Test
 import org.mockito.Mockito.mock
 import org.mockito.Mockito.spy
 import org.mockito.Mockito.verify
+import org.mockito.Mockito.`when`
 
 class EchoWebSocketListenerTest {
+    @Test
+    fun subscribeView_shouldUseUpdatedEventNames() {
+        // Given
+        val mockMappingData = spy(LanguageData::class.java)
+        val mockDistributionData = mock(DistributionInfoResponse.DistributionData::class.java)
+        val mockDataManager = mock(DataManager::class.java)
+        val mockViewTransformerManager = spy(ViewTransformerManager::class.java)
+        val mockWebSocket = mock(WebSocket::class.java)
+        val listener =
+            EchoWebSocketListener(
+                mockDataManager,
+                mockMappingData,
+                mockDistributionData,
+                mockViewTransformerManager,
+                null,
+                "en",
+            )
+        val project = DistributionInfoResponse.DistributionData.ProjectData("1", "wsHash")
+        val user = DistributionInfoResponse.DistributionData.UserData("2")
+        val expectedUpdateEvent = "update-draft:wsHash:pr{1}:us{2}:en:tr{3}"
+        val expectedSuggestionEvent = "top-suggestion:wsHash:pr{1}:en:tr{3}"
+
+        `when`(mockDataManager.getTicket(expectedUpdateEvent)).thenReturn("update-ticket")
+        `when`(mockDataManager.getTicket(expectedSuggestionEvent)).thenReturn("suggestion-ticket")
+
+        val subscribeViewMethod =
+            EchoWebSocketListener::class.java.getDeclaredMethod(
+                "subscribeView",
+                WebSocket::class.java,
+                DistributionInfoResponse.DistributionData.ProjectData::class.java,
+                DistributionInfoResponse.DistributionData.UserData::class.java,
+                String::class.java,
+            )
+        subscribeViewMethod.isAccessible = true
+
+        // When
+        subscribeViewMethod.invoke(listener, mockWebSocket, project, user, "3")
+
+        // Then
+        verify(mockDataManager).getTicket(expectedUpdateEvent)
+        verify(mockDataManager).getTicket(expectedSuggestionEvent)
+        verify(mockWebSocket).send("{\"action\":\"subscribe\", \"event\":\"$expectedUpdateEvent\", \"ticket\": \"update-ticket\"}")
+        verify(mockWebSocket).send("{\"action\":\"subscribe\", \"event\":\"$expectedSuggestionEvent\", \"ticket\": \"suggestion-ticket\"}")
+    }
+
     @Test
     fun whenOnOpen_shouldRegisterViewChangeListener() {
         // Given