feat(typing): expose API for typing indicators (#8)

vincejv · Nov 3, 2022 · dc2059b · dc2059b
1 parent c281af3
commit dc2059b
Show file tree

Hide file tree

Showing 3 changed files with 32 additions and 0 deletions.
diff --git a/fpi-msgr-api-core/src/main/java/com/abavilla/fpi/msgr/controller/MsgrReqResource.java b/fpi-msgr-api-core/src/main/java/com/abavilla/fpi/msgr/controller/MsgrReqResource.java
@@ -21,6 +21,7 @@
 import javax.ws.rs.HeaderParam;
 import javax.ws.rs.POST;
 import javax.ws.rs.Path;
+import javax.ws.rs.PathParam;
 
 import com.abavilla.fpi.fw.controller.AbsBaseResource;
 import com.abavilla.fpi.fw.dto.IDto;
@@ -33,6 +34,7 @@
 import com.abavilla.fpi.msgr.ext.dto.MsgrMsgReqDto;
 import com.abavilla.fpi.msgr.service.MsgrReqSvc;
 import io.smallrye.mutiny.Uni;
+import org.apache.commons.lang3.BooleanUtils;
 import org.jboss.resteasy.reactive.RestResponse;
 import org.jboss.resteasy.reactive.server.ServerExceptionMapper;
 
@@ -51,6 +53,21 @@ public Uni<RespDto<MsgrReqReply>> sendMsg(
     });
   }
 
+  @POST
+  @Path("typing/{recipient}/{isTyping}")
+  public Uni<RespDto<MsgrReqReply>> toggleTyping(
+    @PathParam("recipient") String recipient,
+    @PathParam("isTyping") String isTypingParam) {
+    boolean isTyping = BooleanUtils.toBoolean(isTypingParam);
+    return service.toggleTyping(recipient, isTyping).map(svcResp -> {
+      var resp = new RespDto<MsgrReqReply>();
+      resp.setResp(svcResp);
+      resp.setTimestamp(DateUtil.nowAsStr());
+      resp.setStatus("%s typing indicator for %s".formatted(isTyping ? "Activated" : "Deactivated", recipient));
+      return resp;
+    });
+  }
+
   /**
    * {@inheritDoc}
    */

diff --git a/fpi-msgr-api-core/src/main/java/com/abavilla/fpi/msgr/service/MsgrReqSvc.java b/fpi-msgr-api-core/src/main/java/com/abavilla/fpi/msgr/service/MsgrReqSvc.java
@@ -76,4 +76,10 @@ public Uni<MsgrReqReply> postMsg(MsgrMsgReqDto msgReq, String appSource) {
       });
   }
 
+  public Uni<MsgrReqReply> toggleTyping(String recipient, boolean isTyping) {
+    return metaMsgrApiSvc.sendTypingIndicator(recipient, isTyping)
+      .onFailure().recoverWithUni(ex-> Uni.createFrom().failure(
+        new FPISvcEx("Failed to update typing status", ex)));
+  }
+
 }
diff --git a/fpi-msgr-api-lib/src/main/java/com/abavilla/fpi/msgr/ext/rest/MsgrReqApi.java b/fpi-msgr-api-lib/src/main/java/com/abavilla/fpi/msgr/ext/rest/MsgrReqApi.java
@@ -20,6 +20,9 @@
 
 import javax.ws.rs.Consumes;
 import javax.ws.rs.HeaderParam;
+import javax.ws.rs.POST;
+import javax.ws.rs.Path;
+import javax.ws.rs.PathParam;
 import javax.ws.rs.Produces;
 import javax.ws.rs.core.MediaType;
 
@@ -38,7 +41,13 @@
 @RegisterProvider(value = ApiRepoExHandler.class)
 public interface MsgrReqApi extends IApi {
 
+  @POST
   Uni<RespDto<MsgrReqReply>> sendMsg(
     MsgrMsgReqDto msgReq, @HeaderParam("X-FPI-System") String fpiSystem);
 
+  @POST
+  @Path("typing/{recipient}/{isTyping}")
+  Uni<RespDto<MsgrReqReply>> toggleTyping(
+    @PathParam("recipient") String recipient, @PathParam("isTyping") Boolean isTypingParam);
+
 }