Added a test for posting a pulse response via Slack

Author: ocielliottc

server/src/test/java/com/objectcomputing/checkins/services/SlackSearchReplacement.java

@@ -0,0 +1,49 @@
+package com.objectcomputing.checkins.services;
+
+import com.objectcomputing.checkins.notifications.social_media.SlackSearch;
+import com.objectcomputing.checkins.configuration.CheckInsConfiguration;
+
+import io.micronaut.context.annotation.Replaces;
+import io.micronaut.context.annotation.Requires;
+import io.micronaut.core.util.StringUtils;
+import io.micronaut.http.HttpResponse;
+import io.micronaut.http.HttpStatus;
+
+import jakarta.inject.Singleton;
+
+import java.util.HashMap;
+import java.util.Map;
+
+@Singleton
+@Replaces(SlackSearch.class)
+@Requires(property = "replace.slacksearch", value = StringUtils.TRUE)
+public class SlackSearchReplacement extends SlackSearch {
+    public final Map<String, String> channels = new HashMap<>();
+    public final Map<String, String> users = new HashMap<>();
+
+    public SlackSearchReplacement(CheckInsConfiguration checkInsConfiguration) {
+        super(checkInsConfiguration);
+    }
+
+    @Override
+    public String findChannelId(String channelName) {
+        return channels.containsKey(channelName) ?
+                   channels.get(channelName) : null;
+    }
+
+    @Override
+    public String findUserEmail(String userId) {
+        return users.containsKey(userId) ? users.get(userId) : null;
+    }
+
+    @Override
+    public String findUserId(String userEmail) {
+        for (Map.Entry<String, String> entry : users.entrySet()) {
+            if (entry.getValue().equals(userEmail)) {
+                return entry.getKey();
+            }
+        }
+        return null;
+    }
+}
+

server/src/test/java/com/objectcomputing/checkins/services/pulseresponse/PulseResponseControllerTest.java

@@ -7,7 +7,12 @@
 import com.objectcomputing.checkins.services.fixture.RoleFixture;
 import com.objectcomputing.checkins.services.memberprofile.MemberProfile;
 import com.objectcomputing.checkins.util.Util;
+import com.objectcomputing.checkins.configuration.CheckInsConfiguration;
+import com.objectcomputing.checkins.services.SlackSearchReplacement;
+
+import io.micronaut.core.util.StringUtils;
 import io.micronaut.core.type.Argument;
+import io.micronaut.context.annotation.Property;
 import io.micronaut.http.HttpRequest;
 import io.micronaut.http.HttpResponse;
 import io.micronaut.http.HttpStatus;
@@ -27,19 +32,31 @@
 import java.util.UUID;
 import java.util.stream.Collectors;
 import java.util.stream.Stream;
+import javax.crypto.Mac;
+import javax.crypto.spec.SecretKeySpec;
+import java.nio.charset.StandardCharsets;
+import java.util.Base64;
+import java.time.Instant;
 
 import static com.objectcomputing.checkins.services.role.RoleType.Constants.ADMIN_ROLE;
 import static com.objectcomputing.checkins.services.role.RoleType.Constants.MEMBER_ROLE;
 import static org.junit.jupiter.api.Assertions.assertEquals;
 import static org.junit.jupiter.api.Assertions.assertThrows;
 import static org.junit.jupiter.api.Assertions.assertTrue;
 
+@Property(name = "replace.slacksearch", value = StringUtils.TRUE)
 class PulseResponseControllerTest extends TestContainersSuite implements MemberProfileFixture, RoleFixture, PulseResponseFixture {
 
     @Inject
     @Client("/services/pulse-responses")
     protected HttpClient client;
 
+    @Inject
+    private CheckInsConfiguration configuration;
+
+    @Inject
+    private SlackSearchReplacement slackSearch;
+
     private Map<String, MemberProfile> hierarchy;
 
     @BeforeEach
@@ -516,6 +533,50 @@ void testUpdateInvalidDatePulseResponse() {
         assertEquals(request.getPath(), href);
     }
 
+    @Test
+    void testCreateAPulseResponseFromSlack() {
+        MemberProfile memberProfile = createADefaultMemberProfile();
+        slackSearch.users.put("SLACK_ID_HI", memberProfile.getWorkEmail());
+
+        final String rawBody = "payload=%7B%22type%22%3A+%22view_submission%22%2C+%22user%22%3A+%7B%22id%22%3A+%22SLACK_ID_HI%22%7D%2C+%22view%22%3A+%7B%22id%22%3A+%22VNHU13V36%22%2C+%22type%22%3A+%22modal%22%2C+%22state%22%3A+%7B%22values%22%3A+%7B%22internalNumber%22%3A+%7B%22internalScore%22%3A+%7B%22selected_option%22%3A+%7B%22type%22%3A+%22radio_buttons%22%2C+%22value%22%3A+%224%22%7D%7D%7D%2C+%22internalText%22%3A+%7B%22internalFeelings%22%3A+%7B%22type%22%3A+%22plain_text_input%22%2C+%22value%22%3A+%22I+am+a+robot.%22%7D%7D%2C+%22externalNumber%22%3A+%7B%22externalScore%22%3A+%7B%22selected_option%22%3A+%7B%22type%22%3A+%22radio_buttons%22%2C+%22value%22%3A+%225%22%7D%7D%7D%2C+%22externalText%22%3A+%7B%22externalFeelings%22%3A+%7B%22type%22%3A+%22plain_text_input%22%2C+%22value%22%3A+%22You+are+a+robot.%22%7D%7D%7D%7D%7D%7D";
+
+        long currentTime = Instant.now().getEpochSecond();
+        String timestamp = String.valueOf(currentTime);
+
+        final HttpRequest request = HttpRequest.POST("/external", rawBody)
+        .header("Content-Type", "application/x-www-form-urlencoded")
+        .header("X-Slack-Signature", slackSignature(timestamp, rawBody))
+        .header("X-Slack-Request-Timestamp", timestamp);
+
+        final HttpResponse response = client.toBlocking().exchange(request);
+
+        assertEquals(HttpStatus.OK, response.getStatus());
+    }
+
+    private String slackSignature(String timestamp, String rawBody) {
+        String baseString = "v0:" + timestamp + ":" + rawBody;
+        String secret = configuration.getApplication()
+                                     .getPulseResponse()
+                                     .getSlack().getSigningSecret();
+
+        try {
+            // Generate HMAC SHA-256 signature
+            Mac mac = Mac.getInstance("HmacSHA256");
+            SecretKeySpec secretKeySpec = new SecretKeySpec(secret.getBytes(StandardCharsets.UTF_8), "HmacSHA256");
+            mac.init(secretKeySpec);
+            byte[] hash = mac.doFinal(baseString.getBytes(StandardCharsets.UTF_8));
+
+            // Convert hash to hex
+            StringBuilder hexString = new StringBuilder();
+            for (byte b : hash) {
+                hexString.append(String.format("%02x", b));
+            }
+            return "v0=" + hexString.toString();
+        } catch (Exception e) {
+            return null;
+        }
+    }
+
     private static PulseResponseCreateDTO createPulseResponseCreateDTO() {
         return createPulseResponseCreateDTO(UUID.randomUUID());
     }