these-days-backend/src/main/java/in/ocsf/these/days/app/messaging/ChatHelper.java

package in.ocsf.these.days.app.messaging;/* kpmy 20.02.2017 */

import com.pengrad.telegrambot.Callback;
import com.pengrad.telegrambot.TelegramBot;
import com.pengrad.telegrambot.TelegramBotAdapter;
import com.pengrad.telegrambot.model.request.ParseMode;
import com.pengrad.telegrambot.request.SendMessage;
import com.pengrad.telegrambot.response.SendResponse;
import org.apache.log4j.Logger;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;

import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
import java.util.Optional;

@Service
public class ChatHelper {

    private final Logger log = Logger.getLogger(getClass());

    @Value("${these-days.bot.token}")
    private String token;

    @Async
    public void sendSimpleTextMessage(Long chatId, String text) {
        //Keyboard keyboard = new ReplyKeyboardMarkup(new String[][]{{"пырвет"}});
        sendMessage(new SendMessage(chatId, text).parseMode(ParseMode.Markdown));
    }

    public Optional<SendResponse> sendMessage(SendMessage request) {
        TelegramBot bot = TelegramBotAdapter.build(token);
        List<SendResponse> responseList = new ArrayList<>();
        bot.execute(request, new Callback<SendMessage, SendResponse>() {
            @Override
            public void onResponse(SendMessage request, SendResponse response) {
                responseList.add(response);
            }

            @Override
            public void onFailure(SendMessage request, IOException e) {
                e.printStackTrace();
            }
        });
        return !responseList.isEmpty() ? Optional.of(responseList.get(0)) : Optional.empty();
    }
}