Packages

messenger_bot

0.5.2
1.3.0 1.2.0 retired 1.1.0 retired 1.0.0 retired 1.0.0-rc.8 retired 1.0.0-rc.7 retired 1.0.0-rc.6 retired 1.0.0-rc.5 retired 1.0.0-rc.4 retired 1.0.0-rc.3 retired 1.0.0-rc.2 retired 1.0.0-rc.1 retired 1.0.0-beta9 retired 1.0.0-beta8 retired 1.0.0-beta7 retired 1.0.0-beta6 retired 1.0.0-beta5 retired 1.0.0-beta4 retired 1.0.0-beta3 retired 1.0.0-beta2 retired 1.0.0-beta10 retired 1.0.0-beta1 retired 0.9.2 retired 0.9.1 retired 0.9.0 retired 0.8.2 retired 0.8.1 retired 0.8.0 retired 0.7.3 retired 0.7.2 retired 0.7.1 retired 0.7.0 retired 0.6.0 retired 0.5.2 retired 0.5.1 retired 0.5.0 retired 0.4.0 retired 0.3.0 retired 0.2.1 retired 0.2.0 retired 0.1.0 retired

Unofficial Facebook Messenger Platform chatbot client and webhook handler

Retired package: Deprecated
HexDocs

Current section

Files

Jump to
Readme
41 Versions
5 Dependencies
Dependants
Files
Activity
messenger_bot lib messenger_bot services message.ex
Raw

lib/messenger_bot/services/message.ex 

defmodule MessengerBot.Service.Message do

  @moduledoc """

  Facebook Messenger 'Message' API

  """



  alias MessengerBot.Client

  alias MessengerBot.Config

  alias MessengerBot.Payload.MessageRequest

  alias EventBus.Model.Event



  @path "/messages"



  @doc """

  Deliver request to facebook api

  """

  @spec deliver(String.t, MessageRequest.t) :: {:ok, Map.t} | {:error, Map.t}

  def deliver(page_id, %MessageRequest{} = request, transaction_id \\ nil) do

    transaction_id = if transaction_id, do: transaction_id, else: UUID.uuid1()

    page_token = Config.page_token(page_id)

    url = Client.url(@path, page_token)

    case Client.post(url, request) do

      %HTTPoison.Response{} = response ->

        process_response(transaction_id, page_id, request, response)

      {:error, err} ->

        report(:failed, transaction_id, page_id, request, %{"error" => err})

        {:error, err}

    end

  end



  defp process_response(transaction_id, page_id, request, response) do

    body = Poison.decode!(response.body)

    case body do

      %{"error" => _} ->

        report(:failed, transaction_id, page_id, request, body)

      _ ->

        report(:succeeded, transaction_id, page_id, request, body)

    end

  end



  defp report(status, transaction_id, page_id, request, response_body) do

    event = %Event{id: UUID.uuid1(), topic: :"mb_message_sent_#{status}",

      data: {page_id, request, response_body}, transaction_id: transaction_id}

    EventBus.notify(event)

  end

end