Feature 2868/pull slack kudos in

.github/workflows/gradle-build-production.yml

@@ -89,6 +89,7 @@ jobs:
             --set-env-vars "SLACK_BOT_TOKEN=${{ secrets.SLACK_BOT_TOKEN }}" \
             --set-env-vars "SLACK_PULSE_SIGNING_SECRET=${{ secrets.SLACK_PULSE_SIGNING_SECRET }}" \
             --set-env-vars "SLACK_PULSE_BOT_TOKEN=${{ secrets.SLACK_PULSE_BOT_TOKEN }}" \
+            --set-env-vars "SLACK_KUDOS_CHANNEL_ID=${{ secrets.SLACK_KUDOS_CHANNEL_ID }}" \
             --platform "managed" \
             --max-instances 8 \
             --allow-unauthenticated

.github/workflows/gradle-deploy-develop.yml

@@ -113,6 +113,7 @@ jobs:
             --set-env-vars "SLACK_WEBHOOK_URL=${{ secrets.SLACK_WEBHOOK_URL }}" \
             --set-env-vars "SLACK_BOT_TOKEN=${{ secrets.SLACK_BOT_TOKEN }}" \
             --set-env-vars "SLACK_SIGNING_SECRET=${{ secrets.SLACK_PULSE_SIGNING_SECRET }}" \
+            --set-env-vars "SLACK_KUDOS_CHANNEL_ID=${{ secrets.SLACK_KUDOS_CHANNEL_ID }}" \
             --platform "managed" \
             --max-instances 2 \
             --allow-unauthenticated

.github/workflows/gradle-deploy-native-develop.yml

@@ -113,6 +113,7 @@ jobs:
             --set-env-vars "SLACK_BOT_TOKEN=${{ secrets.SLACK_BOT_TOKEN }}" \
             --set-env-vars "SLACK_PULSE_SIGNING_SECRET=${{ secrets.SLACK_PULSE_SIGNING_SECRET }}" \
             --set-env-vars "SLACK_PULSE_BOT_TOKEN=${{ secrets.SLACK_PULSE_BOT_TOKEN }}" \
+            --set-env-vars "SLACK_KUDOS_CHANNEL_ID=${{ secrets.SLACK_KUDOS_CHANNEL_ID }}" \
             --platform "managed" \
             --max-instances 2 \
             --allow-unauthenticated

server/src/main/java/com/objectcomputing/checkins/configuration/CheckInsConfiguration.java

@@ -82,6 +82,9 @@ public static class SlackConfig {
 
             @NotBlank
             private String signingSecret;
+
+            @NotBlank
+            private String kudosChannel;
         }
     }
 }

server/src/main/java/com/objectcomputing/checkins/notifications/social_media/SlackSender.java

@@ -0,0 +1,124 @@
+package com.objectcomputing.checkins.notifications.social_media;
+
+import com.objectcomputing.checkins.configuration.CheckInsConfiguration;
+
+import com.slack.api.Slack;
+import com.slack.api.methods.MethodsClient;
+import com.slack.api.methods.request.chat.ChatPostMessageRequest;
+import com.slack.api.methods.response.chat.ChatPostMessageResponse;
+import com.slack.api.methods.request.chat.ChatDeleteRequest;
+import com.slack.api.methods.response.chat.ChatDeleteResponse;
+import com.slack.api.methods.request.conversations.ConversationsOpenRequest;
+import com.slack.api.methods.response.conversations.ConversationsOpenResponse;
+
+import jakarta.inject.Singleton;
+import jakarta.inject.Inject;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.util.List;
+
+@Singleton
+public class SlackSender {
+    private static final Logger LOG = LoggerFactory.getLogger(SlackSender.class);
+
+    @Inject
+    private CheckInsConfiguration configuration;
+
+    public boolean send(List<String> userIds, String slackBlocks) {
+        // See if we have a token.
+        String token = configuration.getApplication()
+                                    .getSlack().getBotToken();
+        if (token != null && !slackBlocks.isEmpty()) {
+            MethodsClient client = Slack.getInstance().methods(token);
+
+            try {
+                ConversationsOpenResponse openResponse =
+                    client.conversationsOpen(ConversationsOpenRequest.builder()
+                        .users(userIds)
+                        .returnIm(true)
+                        .build());
+                if (!openResponse.isOk()) {
+                    LOG.error("Unable to open the conversation");
+                    return false;
+                }
+
+                return send(openResponse.getChannel().getId(), slackBlocks);
+            } catch(Exception ex) {
+                LOG.error("SlackSender.send: " + ex.toString());
+                return false;
+            }
+        } else {
+            LOG.error("Missing token or missing slack blocks");
+            return false;
+        }
+    }
+
+    public boolean send(String channelId, String slackBlocks) {
+        // See if we have a token.
+        String token = configuration.getApplication()
+                                    .getSlack().getBotToken();
+        if (token != null && !slackBlocks.isEmpty()) {
+            MethodsClient client = Slack.getInstance().methods(token);
+
+            try {
+                ChatPostMessageRequest request = ChatPostMessageRequest
+                    .builder()
+                    .channel(channelId)
+                    .blocksAsString(slackBlocks)
+                    .build();
+
+                // Send it to Slack
+                ChatPostMessageResponse response = client.chatPostMessage(request);
+
+                if (!response.isOk()) {
+                    LOG.error("Unable to send the chat message: " +
+                              response.getError());
+                }
+
+                return response.isOk();
+            } catch(Exception ex) {
+                LOG.error("SlackSender.send: " + ex.toString());
+                return false;
+            }
+        } else {
+            LOG.error("Missing token or missing slack blocks");
+            return false;
+        }
+    }
+
+    public boolean delete(String channel, String ts) {
+        // See if we have a token.
+        String token = configuration.getApplication()
+                                    .getSlack().getBotToken();
+        if (token != null) {
+            MethodsClient client = Slack.getInstance().methods(token);
+
+            try {
+                ChatDeleteRequest request = ChatDeleteRequest
+                        .builder()
+                        .channel(channel)
+                        .ts(ts)
+                        .build();
+
+                // Send it to Slack
+                ChatDeleteResponse response = client.chatDelete(request);
+
+                if (!response.isOk()) {
+                    LOG.error("Unable to delete the chat message: " +
+                              response.getError());
+                }
+
+                return response.isOk();
+            } catch(Exception ex) {
+                LOG.error("SlackSender.delete: " + ex.toString());
+                return false;
+            }
+        } else {
+            LOG.error("Missing token or missing slack blocks");
+            return false;
+        }
+    }
+}
+

server/src/main/java/com/objectcomputing/checkins/services/kudos/KudosConverter.java

@@ -1,6 +1,6 @@
 package com.objectcomputing.checkins.services.kudos;
 
-import com.objectcomputing.checkins.notifications.social_media.SlackSearch;
+import com.objectcomputing.checkins.services.slack.SlackSearch;
 import com.objectcomputing.checkins.services.kudos.kudos_recipient.KudosRecipientServices;
 import com.objectcomputing.checkins.services.kudos.kudos_recipient.KudosRecipient;
 import com.objectcomputing.checkins.services.memberprofile.MemberProfileServices;
@@ -22,10 +22,6 @@
 
 @Singleton
 public class KudosConverter {
-    private record InternalBlock(
-      List<LayoutBlock> blocks
-    ) {}
-
     private final MemberProfileServices memberProfileServices;
     private final KudosRecipientServices kudosRecipientServices;
     private final SlackSearch slackSearch;
@@ -61,9 +57,8 @@ public String toSlackBlock(Kudos kudos) {
             .elements(content).build();
         RichTextBlock richTextBlock = RichTextBlock.builder()
             .elements(List.of(element)).build();
-        InternalBlock block = new InternalBlock(List.of(richTextBlock));
         Gson mapper = GsonFactory.createSnakeCase();
-        return mapper.toJson(block);
+        return mapper.toJson(List.of(richTextBlock));
     }
 
     private RichTextSectionElement.TextStyle boldItalic() {

server/src/main/java/com/objectcomputing/checkins/services/kudos/KudosServices.java

@@ -13,6 +13,8 @@ public interface KudosServices {
 
     Kudos approve(Kudos kudos);
 
+    Kudos savePreapproved(KudosCreateDTO kudos);
+
     List<KudosResponseDTO> getRecent();
 
     KudosResponseDTO getById(UUID id);