Process the response from users prompt asking to post kudos in Check-Ins.

Author: ocielliottc

server/src/main/java/com/objectcomputing/checkins/services/memberprofile/currentuser/CurrentUserServicesImpl.java

@@ -57,7 +57,7 @@ public boolean hasRole(RoleType role) {
 
     @Override
     public boolean hasPermission(Permission permission) {
-        MemberProfile currentUser = getCurrentUser();
+        MemberProfile currentUser = getCurrentUserImpl();
         if (currentUser == null) {
             return false;
         }
@@ -72,16 +72,23 @@ public boolean isAdmin() {
         return hasRole(RoleType.ADMIN);
     }
 
-    public MemberProfile getCurrentUser() {
+    private MemberProfile getCurrentUserImpl() {
         if (securityService != null) {
             Optional<Authentication> auth = securityService.getAuthentication();
             if (auth.isPresent() && auth.get().getAttributes().get("email") != null) {
                 String workEmail = auth.get().getAttributes().get("email").toString();
                 return memberProfileRepo.findByWorkEmail(workEmail).orElse(null);
             }
         }
+        return null;
+    }
 
-        throw new NotFoundException("No active members in the system");
+    public MemberProfile getCurrentUser() {
+        MemberProfile profile = getCurrentUserImpl();
+        if (profile == null) {
+            throw new NotFoundException("No active members in the system");
+        }
+        return profile;
     }
 
     private MemberProfile saveNewUser(String firstName, String lastName, String workEmail) {

server/src/main/java/com/objectcomputing/checkins/services/slack/SlackSubmissionHandler.java

@@ -2,6 +2,7 @@
 
 import com.objectcomputing.checkins.services.slack.pulseresponse.PulseSlackCommand;
 import com.objectcomputing.checkins.services.slack.pulseresponse.SlackPulseResponseConverter;
+import com.objectcomputing.checkins.services.slack.kudos.SlackKudosResponseHandler;
 
 import com.objectcomputing.checkins.util.form.FormUrlEncodedDecoder;
 import com.objectcomputing.checkins.services.pulseresponse.PulseResponse;
@@ -23,19 +24,24 @@
 
 @Singleton
 public class SlackSubmissionHandler {
+    private final String typeKey = "type";
+
     private final PulseResponseService pulseResponseServices;
     private final SlackSignatureVerifier slackSignatureVerifier;
     private final PulseSlackCommand pulseSlackCommand;
     private final SlackPulseResponseConverter slackPulseResponseConverter;
+    private final SlackKudosResponseHandler slackKudosResponseHandler;
 
     public SlackSubmissionHandler(PulseResponseService pulseResponseServices,
                                   SlackSignatureVerifier slackSignatureVerifier,
                                   PulseSlackCommand pulseSlackCommand,
-                                  SlackPulseResponseConverter slackPulseResponseConverter) {
+                                  SlackPulseResponseConverter slackPulseResponseConverter,
+                                  SlackKudosResponseHandler slackKudosResponseHandler) {
         this.pulseResponseServices = pulseResponseServices;
         this.slackSignatureVerifier = slackSignatureVerifier;
         this.pulseSlackCommand = pulseSlackCommand;
         this.slackPulseResponseConverter = slackPulseResponseConverter;
+        this.slackKudosResponseHandler = slackKudosResponseHandler;
     }
 
     public HttpResponse commandResponse(String signature,
@@ -85,6 +91,8 @@ public HttpResponse externalResponse(String signature,
                                              new TypeReference<>() {});
                     if (isPulseSubmission(map)) {
                         return completePulse(map);
+                    } else if (isKudosSubmission(map)) {
+                        return completeKudos(map);
                     }
                 } catch(JsonProcessingException ex) {
                     // Fall through to the bottom...
@@ -98,7 +106,6 @@ public HttpResponse externalResponse(String signature,
     }
 
     private boolean isPulseSubmission(Map<String, Object> map) {
-        final String typeKey = "type";
         if (map.containsKey(typeKey)) {
             final String type = (String)map.get(typeKey);
             if (type.equals("view_submission")) {
@@ -147,4 +154,24 @@ private HttpResponse completePulse(Map<String, Object> map) {
         }
         return HttpResponse.ok();
     }
+
+    private boolean isKudosSubmission(Map<String, Object> map) {
+        if (map.containsKey(typeKey)) {
+            final String type = (String)map.get(typeKey);
+            if (type.equals("block_actions")) {
+                final String actionKey = "actions";
+                return map.containsKey(actionKey);
+            }
+        }
+        return false;
+    }
+
+    private HttpResponse completeKudos(Map<String, Object> map) {
+        if (slackKudosResponseHandler.handle(map)) {
+            return HttpResponse.ok();
+        } else {
+            // Something was wrong and we were not able to handle this.
+            return HttpResponse.unprocessableEntity();
+        }
+    }
 }

server/src/main/java/com/objectcomputing/checkins/services/slack/kudos/KudosChannelReader.java

@@ -31,7 +31,7 @@ public class KudosChannelReader {
     @Inject
     private SlackKudosCreator slackKudosCreator;
 
-    @Scheduled(fixedDelay = "1m")
+    @Scheduled(fixedDelay = "10m")
     public void readChannel() {
         if (lastImport == null) {
             lastImport = LocalDateTime.now();

server/src/main/java/com/objectcomputing/checkins/services/slack/kudos/SlackKudosResponseHandler.java

@@ -11,6 +11,7 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import java.util.Map;
 import java.util.UUID;
 import java.util.List;
 import java.util.ArrayList;
@@ -29,7 +30,38 @@ public class SlackKudosResponseHandler {
     @Inject
     private MemberProfileServices memberProfileServices;
 
-    public void store(UUID automatedKudosId) {
+    public boolean handle(Map<String, Object> map) {
+        try {
+            // Get the blocks out of the message so that we can grab the
+            // automated kudos id.
+            Map<String, Object> message =
+                                    (Map<String, Object>)map.get("message");
+            List<Object> blocks = (List<Object>)message.get("blocks");
+            if (blocks.size() > 0) {
+                Map<String, Object> first = (Map<String, Object>)blocks.get(0);
+                String id = (String)first.get("block_id");
+                UUID uuid = UUID.fromString(id);
+
+                List<Object> actions = (List<Object>)map.get("actions");
+                if (actions.size() > 0) {
+                    Map<String, Object> entry =
+                                            (Map<String, Object>)actions.get(0);
+                    String actionId = (String)entry.get("action_id");
+                    if (actionId.equals("yes_button")) {
+                        store(uuid);
+                    } else {
+                        automatedKudosRepository.deleteById(uuid);
+                    }
+                    return true;
+                }
+            }
+        } catch (Exception ex) {
+            LOG.error("SlackKudosResponseHandler.handle: " + ex.toString());
+        }
+        return false;
+    }
+
+    private void store(UUID automatedKudosId) {
         Optional<AutomatedKudos> found =
             automatedKudosRepository.findById(automatedKudosId);
         if (found.isPresent()) {
@@ -49,8 +81,4 @@ public void store(UUID automatedKudosId) {
                       automatedKudosId.toString());
         }
     }
-
-    public void remove(UUID automatedKudosId) {
-        automatedKudosRepository.deleteById(automatedKudosId);
-    }
 }