-
Notifications
You must be signed in to change notification settings - Fork 6
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Send an approved public kudos to the #kudos slack channel.
- Loading branch information
1 parent
a41349f
commit 219c330
Showing
5 changed files
with
258 additions
and
1 deletion.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
33 changes: 33 additions & 0 deletions
33
...er/src/main/java/com/objectcomputing/checkins/notifications/social_media/SlackPoster.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,33 @@ | ||
| package com.objectcomputing.checkins.notifications.social_media; | ||
|
|
||
| import io.micronaut.http.HttpRequest; | ||
| import io.micronaut.http.HttpResponse; | ||
| import io.micronaut.http.HttpStatus; | ||
| import io.micronaut.http.client.BlockingHttpClient; | ||
| import io.micronaut.http.client.HttpClient; | ||
|
|
||
| import jakarta.inject.Singleton; | ||
| import jakarta.inject.Inject; | ||
|
|
||
| import java.util.List; | ||
|
|
||
| @Singleton | ||
| public class SlackPoster { | ||
| @Inject | ||
| private HttpClient slackClient; | ||
|
|
||
| public HttpResponse post(String slackBlock) { | ||
| // See if we can have a webhook URL. | ||
| String slackWebHook = System.getenv("SLACK_WEBHOOK_URL"); | ||
| if (slackWebHook != null) { | ||
| // POST it to Slack. | ||
| BlockingHttpClient client = slackClient.toBlocking(); | ||
| HttpRequest<String> request = HttpRequest.POST(slackWebHook, | ||
| slackBlock); | ||
| return client.exchange(request); | ||
| } | ||
| return HttpResponse.status(HttpStatus.GONE, | ||
| "Slack Webhook URL is not configured"); | ||
| } | ||
| } | ||
|
|
73 changes: 73 additions & 0 deletions
73
...er/src/main/java/com/objectcomputing/checkins/notifications/social_media/SlackSearch.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,73 @@ | ||
| package com.objectcomputing.checkins.notifications.social_media; | ||
|
|
||
| import com.slack.api.model.block.LayoutBlock; | ||
| import com.slack.api.Slack; | ||
| import com.slack.api.methods.MethodsClient; | ||
| import com.slack.api.model.Conversation; | ||
| import com.slack.api.methods.SlackApiException; | ||
| import com.slack.api.methods.request.conversations.ConversationsListRequest; | ||
| import com.slack.api.methods.response.conversations.ConversationsListResponse; | ||
| import com.slack.api.methods.request.users.UsersLookupByEmailRequest; | ||
| import com.slack.api.methods.response.users.UsersLookupByEmailResponse; | ||
|
|
||
| import jakarta.inject.Singleton; | ||
| import jakarta.inject.Inject; | ||
|
|
||
| import java.util.List; | ||
| import java.io.IOException; | ||
|
|
||
| import org.slf4j.Logger; | ||
| import org.slf4j.LoggerFactory; | ||
|
|
||
| @Singleton | ||
| public class SlackSearch { | ||
| private static final Logger LOG = LoggerFactory.getLogger(SlackSearch.class); | ||
| private static final String env = "SLACK_BOT_TOKEN"; | ||
|
|
||
| public String findChannelId(String channelName) { | ||
| String token = System.getenv(env); | ||
| if (token != null) { | ||
| try { | ||
| MethodsClient client = Slack.getInstance().methods(token); | ||
| ConversationsListResponse response = client.conversationsList( | ||
| ConversationsListRequest.builder().build() | ||
| ); | ||
|
|
||
| if (response.isOk()) { | ||
| for (Conversation conversation: response.getChannels()) { | ||
| if (conversation.getName().equals(channelName)) { | ||
| return conversation.getId(); | ||
| } | ||
| } | ||
| } | ||
| } catch(IOException e) { | ||
| LOG.error("SlackSearch.findChannelId: " + e.toString()); | ||
| } catch(SlackApiException e) { | ||
| LOG.error("SlackSearch.findChannelId: " + e.toString()); | ||
| } | ||
| } | ||
| return null; | ||
| } | ||
|
|
||
| public String findUserId(String userEmail) { | ||
| String token = System.getenv(env); | ||
| if (token != null) { | ||
| try { | ||
| MethodsClient client = Slack.getInstance().methods(token); | ||
| UsersLookupByEmailResponse response = client.usersLookupByEmail( | ||
| UsersLookupByEmailRequest.builder().email(userEmail).build() | ||
| ); | ||
|
|
||
| if (response.isOk()) { | ||
| return response.getUser().getId(); | ||
| } | ||
| } catch(IOException e) { | ||
| LOG.error("SlackSearch.findUserId: " + e.toString()); | ||
| } catch(SlackApiException e) { | ||
| LOG.error("SlackSearch.findUserId: " + e.toString()); | ||
| } | ||
| } | ||
| return null; | ||
| } | ||
| } | ||
|
|
130 changes: 130 additions & 0 deletions
130
server/src/main/java/com/objectcomputing/checkins/services/kudos/KudosConverter.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,130 @@ | ||
| package com.objectcomputing.checkins.services.kudos; | ||
|
|
||
| import com.objectcomputing.checkins.notifications.social_media.SlackPoster; | ||
| import com.objectcomputing.checkins.notifications.social_media.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; | ||
| import com.objectcomputing.checkins.services.memberprofile.MemberProfileUtils; | ||
| import com.objectcomputing.checkins.services.memberprofile.MemberProfile; | ||
|
|
||
| import com.slack.api.model.block.LayoutBlock; | ||
| import com.slack.api.model.block.RichTextBlock; | ||
| import com.slack.api.model.block.element.RichTextElement; | ||
| import com.slack.api.model.block.element.RichTextSectionElement; | ||
| import com.slack.api.util.json.GsonFactory; | ||
| import com.google.gson.Gson; | ||
|
|
||
| import java.util.UUID; | ||
| import java.util.List; | ||
| import java.util.ArrayList; | ||
|
|
||
| public class KudosConverter { | ||
| private record InternalBlock( | ||
| List<LayoutBlock> blocks | ||
| ) {} | ||
|
|
||
| private final MemberProfileServices memberProfileServices; | ||
| private final KudosRecipientServices kudosRecipientServices; | ||
|
|
||
| public KudosConverter(MemberProfileServices memberProfileServices, | ||
| KudosRecipientServices kudosRecipientServices) { | ||
| this.memberProfileServices = memberProfileServices; | ||
| this.kudosRecipientServices = kudosRecipientServices; | ||
| } | ||
|
|
||
| public String toSlackBlock(Kudos kudos) { | ||
| // Build some the message text out of the Kudos data. | ||
| List<RichTextElement> content = new ArrayList<>(); | ||
|
|
||
| // Look up the channel id from Slack | ||
| String channelName = "kudos"; | ||
| SlackSearch search = new SlackSearch(); | ||
| String channelId = search.findChannelId(channelName); | ||
| if (channelId == null) { | ||
| content.add( | ||
| RichTextSectionElement.Text.builder() | ||
| .text("#" + channelName) | ||
| .style(boldItalic()) | ||
| .build() | ||
| ); | ||
| } else { | ||
| content.add( | ||
| RichTextSectionElement.Channel.builder() | ||
| .channelId(channelId) | ||
| .style(limitedBoldItalic()) | ||
| .build() | ||
| ); | ||
| } | ||
| content.add( | ||
| RichTextSectionElement.Text.builder() | ||
| .text(" from ") | ||
| .style(boldItalic()) | ||
| .build() | ||
| ); | ||
| content.add(memberAsRichText(kudos.getSenderId())); | ||
| content.addAll(recipients(kudos)); | ||
|
|
||
| content.add( | ||
| RichTextSectionElement.Text.builder() | ||
| .text("\n" + kudos.getMessage() + "\n") | ||
| .style(boldItalic()) | ||
| .build() | ||
| ); | ||
|
|
||
| // Bring it all together. | ||
| RichTextSectionElement element = RichTextSectionElement.builder() | ||
| .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); | ||
| } | ||
|
|
||
| private RichTextSectionElement.TextStyle boldItalic() { | ||
| return RichTextSectionElement.TextStyle.builder() | ||
| .bold(true).italic(true).build(); | ||
| } | ||
|
|
||
| private RichTextSectionElement.LimitedTextStyle limitedBoldItalic() { | ||
| return RichTextSectionElement.LimitedTextStyle.builder() | ||
| .bold(true).italic(true).build(); | ||
| } | ||
|
|
||
| private RichTextElement memberAsRichText(UUID memberId) { | ||
| // Look up the user name to get the user id from Slack | ||
| SlackSearch search = new SlackSearch(); | ||
| MemberProfile profile = memberProfileServices.getById(memberId); | ||
| String userId = search.findUserId(profile.getWorkEmail()); | ||
| if (userId == null) { | ||
| String name = MemberProfileUtils.getFullName(profile); | ||
| return RichTextSectionElement.Text.builder() | ||
| .text("@" + name) | ||
| .style(boldItalic()) | ||
| .build(); | ||
| } else { | ||
| return RichTextSectionElement.User.builder() | ||
| .userId(userId) | ||
| .style(limitedBoldItalic()) | ||
| .build(); | ||
| } | ||
| } | ||
|
|
||
| private List<RichTextElement> recipients(Kudos kudos) { | ||
| List<RichTextElement> list = new ArrayList<>(); | ||
| List<KudosRecipient> recipients = | ||
| kudosRecipientServices.getAllByKudosId(kudos.getId()); | ||
| String separator = " to "; | ||
| for (KudosRecipient recipient : recipients) { | ||
| list.add(RichTextSectionElement.Text.builder() | ||
| .text(separator) | ||
| .style(boldItalic()) | ||
| .build()); | ||
| list.add(memberAsRichText(recipient.getMemberId())); | ||
| separator = ", "; | ||
| } | ||
| return list; | ||
| } | ||
| } | ||
|
|
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters