Library for fast java telegram bot development powered by spring-boot

• Import library from spring-telegram-bot-starter Gradle:

apply plugin: 'java'

repositories {
    mavenCentral()
    maven { url "https://jitpack.io" }
}

dependencies {
    compile 'com.github.kuptservol:spring-telegram-bot-starter:1.3'
}

• Create your first bot

@MessageHandler
public class ExampleBotStarter {

    public static void main(String[] args) {
        BotPlatformStarter.start(ExampleBotStarter.class, "{set your client token received from https://telegram.me/botfather}");
    }

    @MessageMapping(text = "hi")
    public Reply sayGoodMorning(UpdateEvent updateEvent) {
        return Reply.withMessage("Good morning! Happy to see you!", updateEvent);
    }
}

• Start your bot. Service is now long pooling for new messages in chat and routes it to message handlers according your's @MessageHandler configurations.

• Spring boot autoconfiguration is fully supported - so youn can start bot as SpringBoot App

@EnableAutoConfiguration
@MessageHandler
public class ExampleBotBootAutoConfiguration {

    public static void main(String[] args) {
        SpringApplication.run(ExampleBotBootAutoConfiguration.class, format("--%s=%s", TELEGRAM_CLIENT_TOKEN, "{token}"));
    }

    @MessageMapping(text = "hi")
    public Reply sayGoodMorning(UpdateEvent updateEvent) {
        return ReplyTo.to(updateEvent).withMessage("Good morning! Happy to see you!");
    }
}

• You can create separate configuration file to hold telegram client token. The only needed at start configuration key is "telegram.client.token". Create folder config, create file application.yml in it - add line

telegram.client.token: {set your client token received from https://telegram.me/botfather}

For more about spring boot external config options : boot-features-external-config-application-property-files

Full example codes you can find here telegram-spring-bot-example

In order to handle messages you need to mark bean as @MessageHandler - this will indicate to system to look for message mappings @MessageMapping. Message handler method, annotated as @MessageMapping should receive as method parameter ru.skuptsov.telegram.bot.platform.model.UpdateEvent and return ru.skuptsov.telegram.bot.platform.client.command.Reply

@MessageMapping(text = "Hi")
    public Reply sayHi(UpdateEvent updateEvent){
        return ReplyTo.to(updateEvent).withMessage("Hi there!");
        }

UpdateEvent has original Update object received from Telegram.

MessageResponse is a response command wrapper that holds an answer to chat event and sent to telegram asynchronously, cause in most cases you don't need to wait for response message actually have been send increasing thoughput. But if you want to make some action after message was delivered - you can set some callback action.

@MessageMapping(text = "Hi")
    public Reply sayHi(UpdateEvent updateEvent){
        return ReplyTo.to(updateEvent).withMessage("Hi there!")
                .setCallback((Consumer<Message>) message -> System.out.println("Message sent"));
    }

In @MessageMapping you can handle messages to react on

• certain set of texts in message
• message text regexp match
• certain set of callback query data from users input

Annotation based example could be found here SimpleHelloBot

If you message mapping data is dynamic and you cannot use it in annotations you can implement one of interfaces

• MessageTextMessageHandler
• ConditionMessageHandler
• RegexpMessageTextHandler
• CallbackQueryDataMessageHandler with spring bean in beans scope.

@Component
public class SimpleGoodbyeBot implements MessageTextMessageHandler {

    @Override
    public Set<String> getMessageText() {
        return of("Bye", "GoodBye");
    }

    @Override
    public Reply handle(UpdateEvent updateEvent) {
        return ReplyTo.to(updateEvent).withMessage("Goodbye! See you soon!");
    }
}

Typed based example could be found here SimpleGoodbyeBot

In some situations you want to use api directly to get some additional information - you can inject ru.skuptsov.telegram.bot.platform.client.TelegramBotApi bean directly and call api methods.

@MessageHandler
public class SimpleCallApiBot {

    @Autowired
    private TelegramBotApi telegramBotApi;

    @MessageMapping(text = "/me")
    public Reply getMe(UpdateEvent updateEvent) {
        User me = telegramBotApi.getMe().get();

        return ReplyTo.to(updateEvent).withMessage("Me is : " + me.getFirstName() + " " + me.getLastName());
    }
}

Direct api call example could be found here SimpleCallApiBot

• Default message handler

If you want to specify default message handling when no one suitable mapper found for current message you can create bean that implements ru.skuptsov.telegram.bot.platform.handler.DefaultMessageHandler. By default it writes info message to logs.

• Next message id store

Telegram uses incrementing ids in messages and every pooling should request message with id > last received. By default application starts with id = 0, telegram sends only new messages and app holds it in app memory, after app restart old messages are not received. To handle this differently implement bean with interface ru.skuptsov.telegram.bot.platform.client.NextOffsetStrategy

• Updates queue

By default new unprocessed messages are stored locally in BlockingQueue and processed with thread pool reactivelly in order to prevent resource contention under high load. To change this behaviour, to perisist messages for example implement bean with interface ru.skuptsov.telegram.bot.platform.worker.saver.UpdatesWorkerRepository

Configuration options can be found in ru.skuptsov.telegram.bot.platform.config package classes with fields, annotated as @Value. You can modify default configurations setting it in application.yml.

Platform exposes application metrics via jmx.metrics:

• bot.api.client.process.error number of errors in processing
• bot.api.client.message.received number of message received overall
• bot.message.processing.{$processocClassName.methodName}.exception number of errors in client message processor
• bot.message.processing.{$processocClassName.methodName}.execution.time execution time histogram in client message processor
• bot.message.processing.{$processocClassName.methodName}.success number of successfuly processed in client message processor
• bot.message.processor.not.found number of messages that haven't been processed due to lack of processor routing
• bot.updates.worker.repository.get message repository get execution time
• bot.updates.worker.repository.save message repository save execution time