path: root/lib/lsg/telegram_room.ex

defmodule LSG.TelegramRoom do
  require Logger
  @behaviour Telegram.ChatBot
  alias Telegram.Api

  @impl Telegram.ChatBot
  def init(id) do
    token = Keyword.get(Application.get_env(:lsg, :telegram, []), :key)
    {:ok, chat} = Api.request(token, "getChat", chat_id: id)
    Logger.debug("Starting ChatBot for room #{id} \"#{chat["title"]}\"")
    [net, chan] = String.split(chat["title"], "/", parts: 2)
    case IRC.Connection.get_network(net, chan) do
      %IRC.Connection{} ->
        :global.register_name({__MODULE__, net, chan}, self())
        {:ok, _} = Registry.register(IRC.PubSub, "#{net}/#{chan}:message", plugin: __MODULE__)
        {:ok, _} = Registry.register(IRC.PubSub, "#{net}/#{chan}:triggers", plugin: __MODULE__)
      err ->
        Logger.warn("Did not found telegram match for #{id} \"#{chat["title"]}\"")
    end
    {:ok, %{id: id, net: net, chan: chan}}
  end

  def handle_update(%{"message" => %{"from" => %{"id" => user_id}, "text" => text}}, _token, state) do
    account = IRC.Account.find_meta_account("telegram-id", user_id)
    connection = IRC.Connection.get_network(state.net)
    IRC.PuppetConnection.send_message(account, connection, state.chan, text)
    {:ok, state}
  end

  def handle_update(update, token, state) do
    {:ok, state}
  end

  def handle_info({:irc, _, %IRC.Message{sender: %{nick: nick}, text: text}}, state) do
    LSG.Telegram.send_message(state.id, "<#{nick}> #{text}")
    {:ok, state}
  end

  def handle_info({:raw, lines}, state) when is_list(lines) do
    formatted = for l <- lines, into: <<>>, do: l <> "\n"
    LSG.Telegram.send_message(state.id, formatted)
    {:ok, state}
  end

  def handle_info({:raw, line}, state) do
    handle_info({:raw, [line]}, state)
  end

  def handle_info(info, state) do
    {:ok, state}
  end

end