logic.ex

defmodule QuotesBot.Polling.Logic do
  alias QuotesBot.Config
  alias QuotesBot.Bot.Server, as: ReplyServer
  alias Nadia.Model.Update
  @telegram_api Config.telegram_api

  @spec poll(integer()) :: integer()
  def poll(offset) do
    offset
    |> updates
    |> send_replies
  end

  @spec updates(integer()) :: [Update.t]
  defp updates(offset) do
    try do
      case @telegram_api.get_updates([offset: offset]) do
        {:ok, new_updates} -> new_updates
        _                  -> []
      end
    catch
      []
    end
  end

  @spec send_replies([Update.t]) :: integer()
  defp send_replies(updates) do
    updates
    |> Enum.reduce(0, fn(%Update{update_id: update_id} = update, _acc)->
      ReplyServer.reply(update)

      update_id
    end)
  end
end