Как написать telegram бота на java

Дело в том, что некоторые пользователи не имеют имя и фамилию в настройках профиля, а некоторые имеют только это. В общем, мы предусмотрели этот момент. И теперь если мы захотим написать: Привет, Илья! У нас никогда не будет: Привет, null!. Мы ведь не хотим отставать от глаза бога.

Тем, кому лень писать код, держите TelegramType:

public enum TelegramType

Двигаемся дальше, мы обработали их апдейт и теперь нам пора обработать свой апдейт, но перед этим нам нужно создать ещё свой ответ. Выглядит он не так ужасно, но ужасно 🙂

Это нам очень сильно поможет в будущем, нужно только верить.

@Data public class Answer < private SendDocument sendDocument; private SendPhoto sendPhoto; private SendVideo sendVideo; private SendVideoNote sendVideoNote; private SendSticker sendSticker; private SendAudio sendAudio; private SendVoice sendVoice; private SendMediaGroup sendMediaGroup; private SetChatPhoto setChatPhoto; private AddStickerToSet addStickerToSet; private SetStickerSetThumb setStickerSetThumb; private CreateNewStickerSet createNewStickerSet; private UploadStickerFile uploadStickerFile; private EditMessageMedia editMessageMedia; private SendAnimation sendAnimation; private BotApiMethodbotApiMethod; >

На самом деле, всё можно сделать и без этого класса, если вы собираетесь отвечать пользователю только сообщениями или коллбэками. Потому что в будущем этот класс ещё и увеличит немного кода. Я лишь стараюсь увеличить расширяемость, чтобы внедрение новой фичи делалось быстро и легко.

Теперь нам как-то нужно работать с пользователями, поэтому с помощью Spring JPA создадим сущность пользователя.

@Entity @Table(name = "users") @Getter @Setter public class User

Как вы можете заметить, у пользователя есть состояние, это поможет нам для проведения интерактивов и т.д. Также я использую у permissions тип Long, потому что обычно это:

• 0 — Default User
• 1 — Какой-нибудь VIP
• 2 — Moderator
• 3 — Admin

Это просто и удобно и лениво, но если кто-то хочет, то может заморочиться.
Вернёмся к состоянию, напишем простую сущность для состояния :

@Entity @Table(name = "state") @Getter @Setter public class State < @GeneratedValue(strategy = GenerationType.IDENTITY) @Id private Long Id; @Column(name = "value") private String stateValue; public boolean inState() < return stateValue != null; >@OneToOne(fetch = FetchType.EAGER, cascade = CascadeType.ALL) @JoinColumn private User user; >

Для чего нам нужно состояние?
К примеру, пользователь захотел пополнить баланс, и мы просим его ввести сумму пополнения. Если мы не узнаем, что прямо сейчас он вводит сумму пополнения, то будем обрабатывать его команду: 100, как обычную. В общем, нам нужно состояние.

Дальше нам нужно создать обработчик сообщений, в нашем случае они будут разные и их будет много, поэтому создадим интерфейс Handler.

@MappedSuperclass public interface Handler < // Какой тип сообщения будет обработан TelegramType getHandleType(); // Приоритет обработчика int priority(); // Условия, при которых мы воспользуемся этим обработчиком boolean condition(User user, ClassifiedUpdate update); // В этом методе, с помощью апдейта мы будем получать answer Answer getAnswer(User user, ClassifiedUpdate update); >

Обработчик выполняет функцию хранения комманд. Теперь нам нужно создать команды для обработчика. Создадим интерфейс Command.

@MappedSuperclass public interface Command < // Каким обработчиком будет пользоваться команда Class handler(); // С помощью чего мы найдём эту команду Object getFindBy(); // Ну и тут мы уже получим ответ на самом деле Answer getAnswer(ClassifiedUpdate update, User user); >

Теперь как-то надо найти команды для обработчика, поэтому создадим класс AbstractHandler.

@MappedSuperclass public abstract class AbstractHandler implements Handler < protected final MapallCommands = new HashMap<>(); // Найдём все команды для обработчика @Autowired private List commands; protected abstract HashMap createMap(); // Тут мы распихиваем команды по хэшмапе, чтобы потом было удобнее доставать :/ @PostConstruct private void init() < commands.forEach(c -> < allCommands.put(c.getFindBy(), c); if(Objects.equals(c.handler().getName(), this.getClass().getName())) < createMap().put(c.getFindBy(), c); System.out.println(c.getClass().getSimpleName() + " was added for " + this.getClass().getSimpleName()); >>); > >

Это конечно всё хорошо, но нам нужно собрать все обработчики в одном месте. И отправить наш ClassifiedUpdate в эту бездонную бочку. Назовём эту штуку HandlersMap, просто потому что я снова распихиваю обработчики по хэшмапе 🙂

@Component public class HandlersMap < private HashMap> hashMap = new HashMap<>(); private final List handlers; // Тут точно также находим все обработчики, просто в первом случае я использовал // @Autowired. Это немного лучше. public HandlersMap(List handlers) < this.handlers = handlers; >@PostConstruct private void init() < for(Handler handler : handlers) < if(!hashMap.containsKey(handler.getHandleType())) hashMap.put(handler.getHandleType(), new ArrayList<>()); hashMap.get(handler.getHandleType()).add(handler); > hashMap.values().forEach(h -> h.sort(new Comparator() < @Override public int compare(Handler o1, Handler o2) < return o2.priority() - o1.priority(); >>)); > public Answer execute(ClassifiedUpdate classifiedUpdate, User user) < if(!hashMap.containsKey(classifiedUpdate.getTelegramType())) return new Answer(); for (Handler handler : hashMap.get(classifiedUpdate.getTelegramType())) < if(handler.condition(user, classifiedUpdate)) return handler.getAnswer(user, classifiedUpdate); >return null; > >

Теперь нам нужна ещё прослойка в виде ClassifiedUpdateHandler’a. Там мы будем доставать пользователя из базы данных и может что-то ещё. Просто добавим его.
Класс ClassifiedUpdateHandler:

@Service public class ClassifiedUpdateHandler < private final UserService userService; private final HandlersMap commandMap; public ClassifiedUpdateHandler(UserService userService, HandlersMap commandMap) < this.userService = userService; this.commandMap = commandMap; >public Answer request(ClassifiedUpdate classifiedUpdate) < return commandMap.execute(classifiedUpdate, userService.findUserByUpdate(classifiedUpdate)); >>

Тут ничего особенного, пропустим объяснения. Намного интереснее в классе UserService.
До этого, благо, мы успели всё обработать и на 100% достать id пользователя и его имя.

@Service public class UserService < private final UserRepository userRepository; private final StateRepository stateRepository; public UserService(UserRepository userRepository, StateRepository stateRepository) < this.userRepository = userRepository; this.stateRepository = stateRepository; >public User findUserByUpdate(ClassifiedUpdate classifiedUpdate) < // Проверим, существует ли этот пользователь. if(userRepository.findByChatId(classifiedUpdate.getUserId()) != null) < User user = userRepository.findByChatId(classifiedUpdate.getUserId()); // Если мы не смогли до этого записать имя пользователя, то запишем его. if(user.getUserName() == null && classifiedUpdate.getUserName() != null) user.setUserName(classifiedUpdate.getUserName()); // Проверим менял ли пользователя имя. if(user.getUserName() != null) if (!user.getUserName().equals(classifiedUpdate.getUserName())) user.setUserName(classifiedUpdate.getUserName()); if(!user.getName().equals(classifiedUpdate.getName())) user.setName(classifiedUpdate.getName()); return user; >try < User user = new User(); user.setName(classifiedUpdate.getName()); user.setPermissions(0L); user.setChatId(classifiedUpdate.getUserId()); user.setUserName(classifiedUpdate.getUserName()); State state = new State(); state.setStateValue(null); state.setUser(user); stateRepository.save(state); user.setState(state); userRepository.save(user); return user; >catch (Exception e) < e.printStackTrace(); >return null; > > 

Всё готово, теперь пора создать наш первый Handler и Command для примера. Но для начала напишем Builder для сообщений.

public class SendMessageBuilder < private SendMessage sendMessage; public SendMessageBuilder() < this.sendMessage = new SendMessage(); >public SendMessageBuilder chatId(Long chatId) < this.sendMessage.setChatId(chatId); return this; >public SendMessageBuilder message(String message) < this.sendMessage.setText(message); return this; >public Answer build() throws Exception < if(sendMessage.getChatId() == null) throw new Exception("Id must be not null"); Answer answer = new Answer(); answer.setBotApiMethod(sendMessage); return answer; >>

Вот теперь можем написать Handler и Command.

@Component public class CommandHandler extends AbstractHandler < private HashMaphashMap = new HashMap<>(); @Override protected HashMap createMap() < return hashMap; >@Override public TelegramType getHandleType() < return TelegramType.Command; >@Override public int priority() < return 1; >@Override public boolean condition(User user, ClassifiedUpdate update) < return hashMap.containsKey(update.getCommandName()); >@Override public Answer getAnswer(User user, ClassifiedUpdate update) < return hashMap.get(update.getCommandName()).getAnswer(update, user); >>

@Component public class StartCommand implements Command < @Override public Class handler() < return CommandHandler.class; >@Override public Object getFindBy() < return "/start"; >@SneakyThrows @Override public Answer getAnswer(ClassifiedUpdate update, User user) < return new SendMessageBuilder().chatId(user.getChatId()).message("Hello!").build(); >>

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

Код я писал очень давно, поэтому что-то возможно уже нужно обновить, просто решил опубликовать свои наработки в открытый доступ.

В итоге должен получиться простой и расширяемый бот.

Если эта статья вам понравиться, то можно всё допилить и получить невероятно мощную штуку для написания телеграмм ботов, к примеру, выкатить свои аннотации и т.д.

Спасибо за внимание!

• telegram
• telegram bot
• telegram bots

Пример использования Java-библиотеки для создания Telegram-бота

Каждый разработчик (и не только), который использует Telegram в повседневной жизни, хотя бы раз задумывался о том, каково это — создать своего бота, на сколько это сложно и какой язык программирования лучше использовать.

На все эти вопросы могу дать самый простой (и, наверно, самый правильный) ответ: все зависит от вас самих, ваших знаний и намерений.

… Но в этой небольшой статье, я покажу, как можно создать своего бота на языке Java и что это довольно интересно и несложно.

Мы будем использовать библиотеку для работы с Telegram Bots API и ее расширение, позволяющее создавать свои команды (‘ /custom_cmd ‘) и обрабатывать их простым способом.

Задачей бота будет являться регистрация пользователя и отправка сообщения от указанного им имени другим пользователям бота.

Создание нового проекта и подготовка

1. Добавление зависимостей в проект

Создадим новый maven-проект и отредактируем pom.xml , добавив в него необходимые зависимости:

pom.xml

   4.0.0 io.example anonymizerbot 1.0-SNAPSHOT   org.apache.maven.plugins maven-compiler-plugin ```8 8       org.telegram telegrambots LATEST  org.telegram telegrambotsextensions LATEST  . 

Telegram API — библиотека для работы с Telegram Bots API, содержит в себе классы и методы для взаимодействия с сервисами Telegram и некоторые расширения этих классов.

2. Создание аккаунта для бота

Для этого нам необходимо обратиться за помощью к боту BotFather:

• найдем бота в поиске;
• выполним команду «/start»;
• выполним команду «/newbot»;
• зададим какое-нибудь имя нашему боту (должно заканчиваться на «Bot»). Я назвал его «ExampleOfAnonymizerBot».

После выполнения этих команд мы получим токен, который нам понадобится для использования Bot API. (7xxxxxxx2:Axxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx0)

Реализация

1. Модель анонимного отправителя сообщений

Данные, необходимые нам от каждого пользователя:

• User mUser — информация о пользователе Telegram;
• Chat mChat — информация о чате пользователя и бота;
• String mDisplayedName — имя, от которого пользователь будет посылать сообщения другим пользователям бота.

Anonymous.java

package io.example.anonymizerbot.model; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.telegram.telegrambots.meta.api.objects.Chat; import org.telegram.telegrambots.meta.api.objects.User; public final class Anonymous < private static final Logger LOG = LogManager.getLogger(Anonymous.class); private static final String USER_CHAT_CANNOT_BE_NULL = "User or chat cannot be null!"; private final User mUser; private final Chat mChat; private String mDisplayedName; public Anonymous(User user, Chat chat) < if (user == null || chat == null) < LOG.error(USER_CHAT_CANNOT_BE_NULL); throw new IllegalStateException(USER_CHAT_CANNOT_BE_NULL); >mUser = user; mChat = chat; > @Override public int hashCode() < return mUser.hashCode(); >@Override public boolean equals(Object obj) < return obj instanceof Anonymous && ((Anonymous) obj).getUser().equals(mUser); >public User getUser() < return mUser; >public Chat getChat() < return mChat; >public String getDisplayedName() < return mDisplayedName; >public void setDisplayedName(String displayedName) < mDisplayedName = displayedName; >>

Добавим сервис, содержащий часто используемые методы для манипулирования множеством анонимных пользователей.

AnonymousService.java

package io.example.anonymizerbot.service; import io.example.anonymizerbot.model.Anonymous; import org.telegram.telegrambots.meta.api.objects.User; import java.util.HashSet; import java.util.Objects; import java.util.Set; import java.util.stream.Stream; public final class AnonymousService < private final SetmAnonymouses; public AnonymousService() < mAnonymouses = new HashSet<>(); > public boolean setUserDisplayedName(User user, String name) < if (!isDisplayedNameTaken(name)) < mAnonymouses.stream().filter(a ->a.getUser().equals(user)).forEach(a -> a.setDisplayedName(name)); return true; > return false; > public boolean removeAnonymous(User user) < return mAnonymouses.removeIf(a ->a.getUser().equals(user)); > public boolean addAnonymous(Anonymous anonymous) < return mAnonymouses.add(anonymous); >public boolean hasAnonymous(User user) < return mAnonymouses.stream().anyMatch(a ->a.getUser().equals(user)); > public String getDisplayedName(User user) < Anonymous anonymous = mAnonymouses.stream().filter(a ->a.getUser().equals(user)).findFirst().orElse(null); if (anonymous == null) < return null; >return anonymous.getDisplayedName(); > public Stream anonymouses() < return mAnonymouses.stream(); >private boolean isDisplayedNameTaken(String name) < return mAnonymouses.stream().anyMatch(a ->Objects.equals(a.getDisplayedName(), name)); > >

2. Интерфейс бота

Любая кастомная команда должна наследоваться от BotCommand и реализовывать метод
execute(AbsSender sender, User user, Chat chat, String[] strings) , который используется для обработки команд пользователей.

После того как мы обработаем команду пользователя, мы можем послать ему ответ, используя метод execute класса AbsSender , который принимает на вход вышеупомянутый execute(AbsSender sender, User user, Chat chat, String[] strings) .

Здесь и далее чтобы не оборачивать каждый раз метод AbsSender.execute , который может выбросить исключение TelegramApiException , в try-catch , и для того чтобы не прописывать в каждой команде вывод однообразных логов, создадим класс AnonymizerCommand , а наши кастомные команды будем уже наследовать от него (обработку исключений в этом примере оставим):

AnonymizerCommand.java

package io.example.anonymizerbot.command; import io.example.anonymizerbot.logger.LogLevel; import io.example.anonymizerbot.logger.LogTemplate; import org.apache.logging.log4j.Level; import org.apache.logging.log4j.Logger; import org.apache.logging.log4j.LogManager; import org.telegram.telegrambots.extensions.bots.commandbot.commands.BotCommand; import org.telegram.telegrambots.meta.api.methods.send.SendMessage; import org.telegram.telegrambots.meta.api.objects.User; import org.telegram.telegrambots.meta.bots.AbsSender; import org.telegram.telegrambots.meta.exceptions.TelegramApiException; abstract class AnonymizerCommand extends BotCommand < final Logger log = LogManager.getLogger(getClass()); AnonymizerCommand(String commandIdentifier, String description) < super(commandIdentifier, description); >void execute(AbsSender sender, SendMessage message, User user) < try < sender.execute(message); log.log(Level.getLevel(LogLevel.SUCCESS.getValue()), LogTemplate.COMMAND_SUCCESS.getTemplate(), user.getId(), getCommandIdentifier()); >catch (TelegramApiException e) < log.error(LogTemplate.COMMAND_EXCEPTION.getTemplate(), user.getId(), getCommandIdentifier(), e); >> >

Определим команды, на которые наш бот будет реагировать:

• /start — создаст нового Anonymous без имени и добавит его в коллекцию Anonymouses ;

StartCommand.java

package io.example.anonymizerbot.command; import io.example.anonymizerbot.logger.LogLevel; import io.example.anonymizerbot.logger.LogTemplate; import io.example.anonymizerbot.model.Anonymous; import io.example.anonymizerbot.service.AnonymousService; import org.apache.logging.log4j.Level; import org.telegram.telegrambots.meta.api.methods.send.SendMessage; import org.telegram.telegrambots.meta.api.objects.Chat; import org.telegram.telegrambots.meta.api.objects.User; import org.telegram.telegrambots.meta.bots.AbsSender; public final class StartCommand extends AnonymizerCommand < private final AnonymousService mAnonymouses; // обязательно нужно вызвать конструктор суперкласса, // передав в него имя и описание команды public StartCommand(AnonymousService anonymouses) < super("start", "start using bot\n"); mAnonymouses = anonymouses; >/** * реализованный метод класса BotCommand, в котором обрабатывается команда, введенная пользователем * @param absSender - отправляет ответ пользователю * @param user - пользователь, который выполнил команду * @param chat - чат бота и пользователя * @param strings - аргументы, переданные с командой */ @Override public void execute(AbsSender absSender, User user, Chat chat, String[] strings) < log.info(LogTemplate.COMMAND_PROCESSING.getTemplate(), user.getId(), getCommandIdentifier()); StringBuilder sb = new StringBuilder(); SendMessage message = new SendMessage(); message.setChatId(chat.getId().toString()); if (mAnonymouses.addAnonymous(new Anonymous(user, chat))) < log.info("User <>is trying to execute '<>' the first time. Added to users' list.", user.getId(), getCommandIdentifier()); sb.append("Hi, ").append(user.getUserName()).append("! You've been added to bot users' list!\n") .append("Please execute command:\n'/set_name '\nwhere <displayed_name> is the name you want to use to hide your real name."); > else < log.log(Level.getLevel(LogLevel.STRANGE.getValue()), "User <>has already executed '<>'. Is he trying to do it one more time?", user.getId(), getCommandIdentifier()); sb.append("You've already started bot! You can send messages if you set your name (/set_name)."); > message.setText(sb.toString()); execute(absSender, message, user); > >

• /help — выведет пользователю информацию обо всех доступных командах (конструктор отличается от других тем, что в него необходимо передать ICommandRegistry , который содержит все кастомные команды);

HelpCommand.java

package io.example.anonymizerbot.command; import io.example.anonymizerbot.logger.LogTemplate; import org.telegram.telegrambots.extensions.bots.commandbot.commands.ICommandRegistry; import org.telegram.telegrambots.meta.api.methods.send.SendMessage; import org.telegram.telegrambots.meta.api.objects.Chat; import org.telegram.telegrambots.meta.api.objects.User; import org.telegram.telegrambots.meta.bots.AbsSender; public final class HelpCommand extends AnonymizerCommand < private final ICommandRegistry mCommandRegistry; public HelpCommand(ICommandRegistry commandRegistry) < super("help", "list all known commands\n"); mCommandRegistry = commandRegistry; >@Override public void execute(AbsSender absSender, User user, Chat chat, String[] strings) < log.info(LogTemplate.COMMAND_PROCESSING.getTemplate(), user.getId(), getCommandIdentifier()); StringBuilder helpMessageBuilder = new StringBuilder("Available commands:"); mCommandRegistry.getRegisteredCommands().forEach(cmd -> helpMessageBuilder.append(cmd.toString()).append("\n")); SendMessage helpMessage = new SendMessage(); helpMessage.setChatId(chat.getId().toString()); helpMessage.enableHtml(true); helpMessage.setText(helpMessageBuilder.toString()); execute(absSender, helpMessage, user); > >

• /set_name — задаст пользователю имя, от которого будут отправляться анонимные сообщения;

SetNameCommand.java

package io.example.anonymizerbot.command; import io.example.anonymizerbot.logger.LogLevel; import io.example.anonymizerbot.logger.LogTemplate; import io.example.anonymizerbot.service.AnonymousService; import org.apache.logging.log4j.Level; import org.telegram.telegrambots.meta.api.methods.send.SendMessage; import org.telegram.telegrambots.meta.api.objects.Chat; import org.telegram.telegrambots.meta.api.objects.User; import org.telegram.telegrambots.meta.bots.AbsSender; public final class SetNameCommand extends AnonymizerCommand < private final AnonymousService mAnonymouses; public SetNameCommand(AnonymousService anonymouses) < super("set_name", "set or change name that will be displayed with your messages\n"); mAnonymouses = anonymouses; >@Override public void execute(AbsSender absSender, User user, Chat chat, String[] strings) < log.info(LogTemplate.COMMAND_PROCESSING.getTemplate(), user.getId(), getCommandIdentifier()); SendMessage message = new SendMessage(); message.setChatId(chat.getId().toString()); if (!mAnonymouses.hasAnonymous(user)) < log.log(Level.getLevel(LogLevel.STRANGE.getValue()), "User <>is trying to execute '<>' without starting the bot!", user.getId(), getCommandIdentifier()); message.setText("Firstly you should start the bot! Execute '/start' command!"); execute(absSender, message, user); return; > String displayedName = getName(strings); if (displayedName == null) < log.log(Level.getLevel(LogLevel.STRANGE.getValue()), "User <>is trying to set empty name.", user.getId()); message.setText("You should use non-empty name!"); execute(absSender, message, user); return; > StringBuilder sb = new StringBuilder(); if (mAnonymouses.setUserDisplayedName(user, displayedName)) < if (mAnonymouses.getDisplayedName(user) == null) < log.info("User <>set a name '<>'", user.getId(), displayedName); sb.append("Your displayed name: '").append(displayedName) .append("'. Now you can send messages to bot!"); > else < log.info("User <>has changed name to '<>'", user.getId(), displayedName); sb.append("Your new displayed name: '").append(displayedName).append("'."); > > else < log.log(Level.getLevel(LogLevel.STRANGE.getValue()), "User <>is trying to set taken name '<>'", user.getId(), displayedName); sb.append("Name ").append(displayedName).append(" is already in use! Choose another name!"); > message.setText(sb.toString()); execute(absSender, message, user); > private String getName(String[] strings) < if (strings == null || strings.length == 0) < return null; >String name = String.join(" ", strings); return name.replaceAll(" ", "").isEmpty() ? null : name; > >

• /my_name — отобразит текущее имя пользователя;

MyNameCommand.java

package io.example.anonymizerbot.command; import io.example.anonymizerbot.logger.LogLevel; import io.example.anonymizerbot.logger.LogTemplate; import io.example.anonymizerbot.service.AnonymousService; import org.apache.logging.log4j.Level; import org.telegram.telegrambots.meta.api.methods.send.SendMessage; import org.telegram.telegrambots.meta.api.objects.Chat; import org.telegram.telegrambots.meta.api.objects.User; import org.telegram.telegrambots.meta.bots.AbsSender; public final class MyNameCommand extends AnonymizerCommand < private final AnonymousService mAnonymouses; public MyNameCommand(AnonymousService anonymouses) < super("my_name", "show your current name that will be displayed with your messages\n"); mAnonymouses = anonymouses; >@Override public void execute(AbsSender absSender, User user, Chat chat, String[] strings) < log.info(LogTemplate.COMMAND_PROCESSING.getTemplate(), user.getId(), getCommandIdentifier()); StringBuilder sb = new StringBuilder(); SendMessage message = new SendMessage(); message.setChatId(chat.getId().toString()); if (!mAnonymouses.hasAnonymous(user)) < sb.append("You are not in bot users' list! Send /start command!"); log.log(Level.getLevel(LogLevel.STRANGE.getValue()), "User <>is trying to execute '<>' without starting the bot.", user.getId(), getCommandIdentifier()); > else if(mAnonymouses.getDisplayedName(user) == null) < sb.append("Currently you don't have a name.\nSet it using command:\n'/set_name <displayed_name>'"); log.log(Level.getLevel(LogLevel.STRANGE.getValue()), "User <>is trying to execute '<>' without having a name.", user.getId(), getCommandIdentifier()); > else < log.info("User <>is executing '<>'. Name is '<>'.", user.getId(), getCommandIdentifier(), mAnonymouses.getDisplayedName(user)); sb.append("Your current name: ").append(mAnonymouses.getDisplayedName(user)); > message.setText(sb.toString()); execute(absSender, message, user); > >

• /stop — удалит пользователя из коллекции анонимусов.

StopCommand.java

package io.example.anonymizerbot.command; import io.example.anonymizerbot.logger.LogLevel; import io.example.anonymizerbot.logger.LogTemplate; import io.example.anonymizerbot.service.AnonymousService; import org.apache.logging.log4j.Level; import org.telegram.telegrambots.meta.api.methods.send.SendMessage; import org.telegram.telegrambots.meta.api.objects.Chat; import org.telegram.telegrambots.meta.api.objects.User; import org.telegram.telegrambots.meta.bots.AbsSender; public final class StopCommand extends AnonymizerCommand < private final AnonymousService mAnonymouses; public StopCommand(AnonymousService anonymouses) < super("stop", "remove yourself from bot users' list\n"); mAnonymouses = anonymouses; >@Override public void execute(AbsSender absSender, User user, Chat chat, String[] strings) < log.info(LogTemplate.COMMAND_PROCESSING.getTemplate(), user.getId(), getCommandIdentifier()); StringBuilder sb = new StringBuilder(); SendMessage message = new SendMessage(); message.setChatId(chat.getId().toString()); if (mAnonymouses.removeAnonymous(user)) < log.info("User <>has been removed from users list!", user.getId()); sb.append("You've been removed from bot's users list! Bye!"); > else < log.log(Level.getLevel(LogLevel.STRANGE.getValue()), "User <>is trying to execute '<>' without having executed 'start' before!", user.getId(), getCommandIdentifier()); sb.append("You were not in bot users' list. Bye!"); > message.setText(sb.toString()); execute(absSender, message, user); > >

3. Инициализация и запуск бота

Класс бота, в котором производится регистрация всех кастомных команд, обработчика сообщений-не команд и неизвестных команд.

AnonymizerBot.java

package io.example.anonymizerbot.bot; import io.example.anonymizerbot.command.*; import io.example.anonymizerbot.logger.LogLevel; import io.example.anonymizerbot.logger.LogTemplate; import io.example.anonymizerbot.model.Anonymous; import io.example.anonymizerbot.service.AnonymousService; import org.apache.logging.log4j.Level; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.telegram.telegrambots.bots.DefaultBotOptions; import org.telegram.telegrambots.extensions.bots.commandbot.TelegramLongPollingCommandBot; import org.telegram.telegrambots.meta.api.methods.send.SendMessage; import org.telegram.telegrambots.meta.api.objects.Message; import org.telegram.telegrambots.meta.api.objects.Update; import org.telegram.telegrambots.meta.api.objects.User; import org.telegram.telegrambots.meta.exceptions.TelegramApiException; import java.util.stream.Stream; public final class AnonymizerBot extends TelegramLongPollingCommandBot < private static final Logger LOG = LogManager.getLogger(AnonymizerBot.class); // имя бота, которое мы указали при создании аккаунта у BotFather // и токен, который получили в результате private static final String BOT_NAME = "AnonymizerBotExample"; private static final String BOT_TOKEN = "7xxxxxxx2:Axxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx0"; private final AnonymousService mAnonymouses; public AnonymizerBot(DefaultBotOptions botOptions) < super(botOptions, BOT_NAME); LOG.info("Initializing Anonymizer Bot. "); LOG.info("Initializing anonymouses list. "); mAnonymouses = new AnonymousService(); // регистрация всех кастомных команд LOG.info("Registering commands. "); LOG.info("Registering '/start'. "); register(new StartCommand( mAnonymouses)); LOG.info("Registering '/set_name'. "); register(new SetNameCommand(mAnonymouses)); LOG.info("Registering '/stop'. "); register(new StopCommand(mAnonymouses)); LOG.info("Registering '/my_name'. "); register(new MyNameCommand(mAnonymouses)); HelpCommand helpCommand = new HelpCommand(this); LOG.info("Registering '/help'. "); register(helpCommand); // обработка неизвестной команды LOG.info("Registering default action'. "); registerDefaultAction(((absSender, message) -> < LOG.log(Level.getLevel(LogLevel.STRANGE.getValue()), "User <>is trying to execute unknown command '<>'.", message.getFrom().getId(), message.getText()); SendMessage text = new SendMessage(); text.setChatId(message.getChatId()); text.setText(message.getText() + " command not found!"); try < absSender.execute(text); >catch (TelegramApiException e) < LOG.error("Error while replying unknown command to user <>.", message.getFrom(), e); > helpCommand.execute(absSender, message.getFrom(), message.getChat(), new String[] <>); >)); > @Override public String getBotToken() < return BOT_TOKEN; >// обработка сообщения не начинающегося с '/' @Override public void processNonCommandUpdate(Update update) < LOG.info("Processing non-command update. "); if (!update.hasMessage()) < LOG.error("Update doesn't have a body!"); throw new IllegalStateException("Update doesn't have a body!"); >Message msg = update.getMessage(); User user = msg.getFrom(); LOG.info(LogTemplate.MESSAGE_PROCESSING.getTemplate(), user.getId()); if (!canSendMessage(user, msg)) < return; >String clearMessage = msg.getText(); String messageForUsers = String.format("%s:\n%s", mAnonymouses.getDisplayedName(user), msg.getText()); SendMessage answer = new SendMessage(); // отправка ответа отправителю о том, что его сообщение получено answer.setText(clearMessage); answer.setChatId(msg.getChatId()); replyToUser(answer, user, clearMessage); // отправка сообщения всем остальным пользователям бота answer.setText(messageForUsers); Stream anonymouses = mAnonymouses.anonymouses(); anonymouses.filter(a -> !a.getUser().equals(user)) .forEach(a -> < answer.setChatId(a.getChat().getId()); sendMessageToUser(answer, a.getUser(), user); >); > // несколько проверок, чтобы можно было отправлять сообщения другим пользователям private boolean canSendMessage(User user, Message msg) < SendMessage answer = new SendMessage(); answer.setChatId(msg.getChatId()); if (!msg.hasText() || msg.getText().trim().length() == 0) < LOG.log(Level.getLevel(LogLevel.STRANGE.getValue()), "User <>is trying to send empty message!", user.getId()); answer.setText("You shouldn't send empty messages!"); replyToUser(answer, user, msg.getText()); return false; > if(!mAnonymouses.hasAnonymous(user)) < LOG.log(Level.getLevel(LogLevel.STRANGE.getValue()), "User <>is trying to send message without starting the bot!", user.getId()); answer.setText("Firstly you should start bot! Use /start command!"); replyToUser(answer, user, msg.getText()); return false; > if (mAnonymouses.getDisplayedName(user) == null) < LOG.log(Level.getLevel(LogLevel.STRANGE.getValue()), "User <>is trying to send message without setting a name!", user.getId()); answer.setText("You must set a name before sending messages.\nUse '/set_name ' command."); replyToUser(answer, user, msg.getText()); return false; > return true; > private void sendMessageToUser(SendMessage message, User receiver, User sender) < try < execute(message); LOG.log(Level.getLevel(LogLevel.SUCCESS.getValue()), LogTemplate.MESSAGE_RECEIVED.getTemplate(), receiver.getId(), sender.getId()); >catch (TelegramApiException e) < LOG.error(LogTemplate.MESSAGE_LOST.getTemplate(), receiver.getId(), sender.getId(), e); >> private void replyToUser(SendMessage message, User user, String messageText) < try < execute(message); LOG.log(Level.getLevel(LogLevel.SUCCESS.getValue()), LogTemplate.MESSAGE_SENT.getTemplate(), user.getId(), messageText); >catch (TelegramApiException e) < LOG.error(LogTemplate.MESSAGE_EXCEPTION.getTemplate(), user.getId(), e); >> >

Наконец, запуск бота:

BotInitializer.java

package io.example.anonymizerbot; import io.example.anonymizerbot.bot.AnonymizerBot; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.telegram.telegrambots.ApiContextInitializer; import org.telegram.telegrambots.bots.DefaultBotOptions; import org.telegram.telegrambots.meta.ApiContext; import org.telegram.telegrambots.meta.TelegramBotsApi; import org.telegram.telegrambots.meta.exceptions.TelegramApiRequestException; public final class BotInitializer < private static final Logger LOG = LogManager.getLogger(BotInitializer.class); private static final String PROXY_HOST = "xx.xx.xxx.xxx"; private static final int PROXY_PORT = 9999; public static void main(String[] args) < try < LOG.info("Initializing API context. "); ApiContextInitializer.init(); TelegramBotsApi botsApi = new TelegramBotsApi(); LOG.info("Configuring bot options. "); DefaultBotOptions botOptions = ApiContext.getInstance(DefaultBotOptions.class); botOptions.setProxyHost(PROXY_HOST); botOptions.setProxyPort(PROXY_PORT); botOptions.setProxyType(DefaultBotOptions.ProxyType.SOCKS4); LOG.info("Registering Anonymizer. "); botsApi.registerBot(new AnonymizerBot(botOptions)); LOG.info("Anonymizer bot is ready for work!"); >catch (TelegramApiRequestException e) < LOG.error("Error while initializing bot!", e); >> >

Вот и все! Бот готов к первым тестам.

Пример использования

В качестве примера рассмотрим следующий сценарий:

1. ‘A’ начинает работу с ботом ( /start );
2. ‘A’ пытается отправить сообщение;
3. ‘A’ пытается задать имя ( /set_name );
4. ‘A’ задает имя ( /set_name Pendalf );
5. ‘A’ посылает сообщение другим пользователям (которых нет);
6. ‘B’ начинает работу с ботом ( /start );
7. ‘B’ задает имя ( /set_name Chuck Norris );
8. ‘B’ посылает сообщение другим пользователям;
9. ‘A’ видит сообщение от ‘B’ и посылает сообщение в ответ;
10. ‘B’ видит ответ от ‘A’ и больше ему не пишет.