Пишем простого slack-бота на Java16.12.2021 13:01

Зайдите в документацию требуемого метода. 

Вам могут понадобиться не все разрешения метода. Лучше прочитать про каждое отдельно. Для нашего примера будет достаточно chat: write. Все разрешения.

    4.0.0
    
        org.springframework.boot
        spring-boot-starter-parent
        2.6.0
    
    ru.hh.example
    slack-example
    0.0.1-SNAPSHOT
    slack-example

    
        11
        1.13.0
    

    
        
            org.springframework.boot
            spring-boot-starter
        
        
            org.springframework.boot
            spring-boot-starter-web
        
        
            org.springframework.boot
            spring-boot-starter-test
            test
        

        
        
            com.slack.api
            bolt
            ${slack.bolt.version}
        
        
            com.slack.api
            bolt-servlet
            ${slack.bolt.version}
        

        
        
            com.slack.api
            bolt-socket-mode
            ${slack.bolt.version}
        
        
            org.glassfish.tyrus.bundles
            tyrus-standalone-client
            1.9
        
        
            javax.websocket
            javax.websocket-api
            1.1
        
    

    
        
            
                org.springframework.boot
                spring-boot-maven-plugin
            
        
    

package ru.hh.example.slack;

import com.slack.api.Slack;
import com.slack.api.methods.MethodsClient;
import com.slack.api.methods.SlackApiException;
import com.slack.api.methods.response.chat.ChatPostMessageResponse;
import com.slack.api.methods.response.conversations.ConversationsListResponse;
import com.slack.api.model.Conversation;
import java.io.IOException;
import java.util.Map;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import static org.springframework.http.MediaType.APPLICATION_FORM_URLENCODED_VALUE;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class SlackController {
  private static final Logger LOGGER = LoggerFactory.getLogger(SlackController.class);

  @PostMapping(path = "/", consumes = {APPLICATION_FORM_URLENCODED_VALUE})
  public String slackCommand(@RequestParam Map slackRequest) {
    LOGGER.info("slackRequest: {}", slackRequest);
    return "hello " + slackRequest.get("user_name");
  }

  @PostMapping(path = "/send-to-chat")
  public void sendMessage() throws SlackApiException, IOException {
    // https://api.slack.com/authentication/oauth-v2
    String token = "xoxb-YOUR-TOKEN";
    String channelName = "YOUR-CHANNEL-NAME";
    String message = "hello";

    var client = Slack.getInstance().methods(token);
    var channelId = findChannel(client, channelName);

    ChatPostMessageResponse chatPostMessageResponse = postMessage(client, channelId, message);
    LOGGER.info("chatPostMessageResponse.isOk() : {}", chatPostMessageResponse.isOk());
  }

  // https://api.slack.com/messaging/retrieving#finding_conversation
  private String findChannel(MethodsClient client, String channelName) throws SlackApiException, IOException {
    String nextCursor = null;
    do {
      var result = getConversationsList(client, nextCursor);
      nextCursor = result.getResponseMetadata().getNextCursor();
      for (Conversation channel : result.getChannels()) {
        if (channel.getName().equalsIgnoreCase(channelName)) {
          return channel.getId();
        }
      }
    } while (nextCursor != null);
    throw new IllegalStateException();
  }

  private ConversationsListResponse getConversationsList(MethodsClient client, String nextCursor) throws SlackApiException, IOException {
    return client.conversationsList(r -> r.cursor(nextCursor));
  }

  // https://api.slack.com/messaging/sending#publishing
  private ChatPostMessageResponse postMessage(MethodsClient client, String conversationId, String message) throws SlackApiException, IOException {
    return client.chatPostMessage(r -> r.channel(conversationId).text(message));
  }
}

В моем боте он пока не нужен, но было интересно разобраться

В меню Socket Mode

Выставить enable

Алиас для токена

Забрать токен (нужно будет подложить приложению)

Теперь нужно подписаться на ивенты. Для моего примера нужно событие app_mention

В меню Event Subscriptions

package ru.hh.example.slack;


import com.slack.api.bolt.App;
import com.slack.api.bolt.AppConfig;
import com.slack.api.bolt.socket_mode.SocketModeApp;
import com.slack.api.model.event.AppMentionEvent;

public class SocketExample {
  public static void main(String[] args) throws Exception {
        String botToken = "xoxb-YOUR-BOT-TOKEN";
        String appToken = "xapp-APPTOKEN";

    AppConfig appConfig = AppConfig.builder().singleTeamBotToken(botToken).build();
    App app = new App(appConfig);

    app.event(AppMentionEvent.class, (req, ctx) -> {
      System.out.println("HI! I received event!" + req.getEvent());
      ctx.say("I was mentioned by user with id " + req.getEvent().getUser());
      return ctx.ack();
    });

    SocketModeApp socketModeApp = new SocketModeApp(appToken, app);

// #start() method establishes a new WebSocket connection and then blocks the current thread.
// If you do not want to block this thread, use #startAsync() instead.
    socketModeApp.start();
  }
}

Нужно поменять две переменные

xoxb-YOUR-BOT-TOKEN — токен из первого раздела 

xapp-APPTOKEN — получили несколькими строками выше

Можно проверять

Схема взаимодействия через socket api

Из неочевидных особенностей — через сокет нельзя совершать любые действия. Только отвечать на событие. А все остальное нужно делать через web api

Больше примеров здесь и здесь

PS: Если не приходят определенные ивенты, возможно вы не подписались на них в разделе Event Subscriptions(я потратил какое то время, чтобы это понять))