OffBroadway.Telegram

An Off-Broadway producer for Telegram Bot API long polling

This package provides:

• OffBroadway.Telegram.Producer - Broadway producer that polls updates from Telegram getUpdates long polling endpoint and feeds them through Broadway pipeline
• OffBroadway.Telegram.TelegramClient - A generic behaviour to implement Telegram client
• OffBroadway.Telegram.NadiaClient - Default Telegram client based on Nadia package

Why

Telegram bots have two ways of getting updates: long polling or web hook. While setting up a web hook is preferable way for production it is very common to use long polling in development environment or for smaller bots. Setting up a worker for long polling is not hard but consists mostly of boilerplate code.

But hey, we can use Broadway for this!

Installation

Add off_broadway_telegram and Nadia to your list of dependencies in mix.exs :

def deps do
  [
    {:broadway_telegram, "~> 0.1.0"},
    {:nadia, "~> 0.7.0"}
  ]
end

Example

All you need to do is define a pipeline like this:

defmodule BroadwayTelegramExample do
  use Broadway

  def start_link(_opts) do
    Broadway.start_link(__MODULE__,
      name: __MODULE__,
      producer: [
        module: {OffBroadway.Telegram.Producer, []},
        concurrency: 1
      ],
      processors: [
        default: [concurrency: 2]
      ]
    )
  end

  @impl Broadway
  def handle_message(
        _processor,
        %Broadway.Message{
          data: %Nadia.Model.Update{
            message: %Nadia.Model.Message{text: text, chat: %Nadia.Model.Chat{id: chat_id}}
          }
        } = message,
        _context
      ) do
    {:ok, _} = Nadia.send_message(chat_id, text)

    message
  end
end

Everything else is up to your creativity!

Caveats

Worth noting that Telegram getUpdates is not a proper pubsub like Google PubSub or SQS! This means:

1. this producer is illegal
2. you don't want to run more than one producer process per bot
3. there is no ack/nack and therefore no built-in retry mechanism