A Gleam library for the Telegram Bot API on BEAM.
- an interface to the Telegram Bot HTTP-based APIs
telega/api - a client for the Telegram Bot API
telega/client - OTP supervision tree for all bot processes (bot actor, chat instances, polling)
- adapter to use with wisp
- long polling with automatic retry and exponential backoff
- session bot implementation
- conversation implementation (multi-message flows)
- graceful shutdown via
telega.shutdown()
If you are new to Telegram bots, read the official Introduction for Developers written by the Telegram team.
First, visit @BotFather to create a new bot. Copy the token and save it for later.
Initiate a gleam project and add telega as a dependency:
$ gleam new first_tg_bot
$ cd first_tg_bot
$ gleam add telega gleam_erlangReplace the first_tg_bot.gleam file content with the following code:
import gleam/erlang/process
import telega
import telega/reply
import telega/router
import telega/update
fn handle_text(ctx, text) {
use ctx <- telega.log_context(ctx, "echo_text")
let assert Ok(_) = reply.with_text(ctx, text)
Ok(ctx)
}
fn handle_command(ctx, command: update.Command) {
use ctx <- telega.log_context(ctx, "echo_command")
let assert Ok(_) = reply.with_text(ctx, "Command: " <> command.text)
Ok(ctx)
}
pub fn main() {
let router =
router.new("echo_bot")
|> router.on_any_text(handle_text)
|> router.on_commands(["start", "help"], handle_command)
let assert Ok(_bot) =
telega.new_for_polling(token: "BOT_TOKEN")
|> telega.with_router(router)
|> telega.init_for_polling_nil_session()
// The bot is running with a supervision tree (including polling).
process.sleep_forever()
}Replace "BOT_TOKEN" with the token you received from the BotFather. Then run the bot:
$ gleam runAnd it will echo all received text messages.
Congratulations! You just wrote a Telegram bot :)
Calling telega.init_for_polling() (or telega.init() for webhooks) starts an OTP supervision tree:
TelegaRootSupervisor (OneForOne)
├── ChatInstances (factory_supervisor, Transient children)
│ ├── ChatInstance {chat1:user1}
│ ├── ChatInstance {chat2:user2}
│ └── ...
├── Bot actor (Permanent)
└── Polling worker (Permanent) — only in polling mode
- Bot actor — dispatches incoming updates to the correct
ChatInstanceby{chat_id}:{from_id}key. - ChatInstance — one per user-chat combination; holds session state and conversation continuations. Transient restart strategy means it restarts only on abnormal exit and re-registers itself in the ETS registry automatically.
- Polling worker — long-polls the Telegram API with exponential backoff on errors.
Each telega.init* call creates an independent tree with its own ETS registry, so multiple bot instances don't conflict.
telega.shutdown(bot)Sends an OTP shutdown signal to the root supervisor, which stops children in reverse start order (polling → bot → chat factory).
Telega ships with a testing toolkit under telega/testing/ — mock clients, data factories, and a declarative conversation DSL. No real Telegram API calls needed.
import telega/testing/conversation
pub fn greeting_flow_test() {
conversation.conversation_test()
|> conversation.send("/start")
|> conversation.expect_reply_containing("Hello")
|> conversation.send("Alice")
|> conversation.expect_reply_containing("Alice")
|> conversation.run(build_router(), fn() { MySession(name: "") })
}See the full Testing guide for handler isolation, mock clients, media assertions, and more.
Progressive examples in the examples directory:
00-echo-bot— Basic echo with long polling01-commands-bot— Command handling02-session-bot— Stateful sessions03-conversation-bot— Multi-message conversations04-keyboard-bot— Inline keyboards and callbacks05-media-group-bot— Media group handling06-restaurant-booking— Full-featured application with flows and database
gleam build # Build the project
gleam test # Run the tests
gleam format # Format code
gleam shell # Run an Erlang shell