From 710f9919d78828acc6c451cb491c7437348dd892 Mon Sep 17 00:00:00 2001
From: Hiroki Terashima <honchikun@gmail.com>
Date: Fri, 12 Jan 2024 14:58:05 -0800
Subject: [PATCH] feat(PeerChat): IsTyping endpoint (#250)

---
 .../PeerChatTypingStatusController.java       | 47 +++++++++++++++++++
 .../data/redis/RedisMessageSubscriber.java    |  3 ++
 2 files changed, 50 insertions(+)
 create mode 100644 src/main/java/org/wise/portal/presentation/web/controllers/student/PeerChatTypingStatusController.java

diff --git a/src/main/java/org/wise/portal/presentation/web/controllers/student/PeerChatTypingStatusController.java b/src/main/java/org/wise/portal/presentation/web/controllers/student/PeerChatTypingStatusController.java
new file mode 100644
index 000000000..bf4df5760
--- /dev/null
+++ b/src/main/java/org/wise/portal/presentation/web/controllers/student/PeerChatTypingStatusController.java
@@ -0,0 +1,47 @@
+package org.wise.portal.presentation.web.controllers.student;
+
+import javax.transaction.Transactional;
+
+import org.json.JSONException;
+import org.json.JSONObject;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.messaging.handler.annotation.DestinationVariable;
+import org.springframework.messaging.handler.annotation.MessageMapping;
+import org.springframework.security.access.annotation.Secured;
+import org.springframework.security.core.Authentication;
+import org.springframework.stereotype.Controller;
+import org.wise.portal.dao.ObjectNotFoundException;
+import org.wise.portal.domain.peergroup.PeerGroup;
+import org.wise.portal.service.peergroup.PeerGroupService;
+import org.wise.portal.spring.data.redis.MessagePublisher;
+
+@Secured({ "ROLE_TEACHER", "ROLE_STUDENT" })
+@Controller
+public class PeerChatTypingStatusController extends AbstractPeerGroupWorkController {
+
+  @Autowired
+  private MessagePublisher redisPublisher;
+
+  @Autowired
+  private PeerGroupService peerGroupService;
+
+  @Transactional()
+  @MessageMapping("/api/peer-chat/{nodeId}/{componentId}/{peerGroupId}/{workgroupId}/is-typing")
+  public void sendTypingStatusToPeerGroup(Authentication auth,
+      @DestinationVariable Long peerGroupId, @DestinationVariable String nodeId,
+      @DestinationVariable String componentId, @DestinationVariable int workgroupId)
+      throws JSONException, ObjectNotFoundException {
+    PeerGroup peerGroup = peerGroupService.getById(peerGroupId);
+    if (isUserInPeerGroup(auth, peerGroup) || isUserTeacherOfPeerGroup(auth, peerGroup)) {
+      JSONObject message = new JSONObject();
+      message.put("topic", String.format("/topic/peer-group/%s/is-typing", peerGroupId));
+      message.put("type", "isTyping");
+      JSONObject body = new JSONObject();
+      body.put("nodeId", nodeId);
+      body.put("componentId", componentId);
+      body.put("workgroupId", workgroupId);
+      message.put("body", body);
+      redisPublisher.publish(message.toString());
+    }
+  }
+}
diff --git a/src/main/java/org/wise/portal/spring/data/redis/RedisMessageSubscriber.java b/src/main/java/org/wise/portal/spring/data/redis/RedisMessageSubscriber.java
index cd7fa4a5c..aba41d2bd 100644
--- a/src/main/java/org/wise/portal/spring/data/redis/RedisMessageSubscriber.java
+++ b/src/main/java/org/wise/portal/spring/data/redis/RedisMessageSubscriber.java
@@ -60,6 +60,9 @@ public void onMessage(Message message, byte[] pattern) {
       case "newWorkgroupJoinedRun":
         createAndSendWebSocketMessage("newWorkgroupJoinedRun", messageJSON);
         break;
+      case "isTyping":
+        createAndSendWebSocketMessage("isTyping", messageJSON, "body");
+        break;
       }
     } catch (JSONException e) {
       e.printStackTrace();