Packages

messenger_bot

0.8.0
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 webhooks callback.ex
Raw

lib/messenger_bot/webhooks/callback.ex 

defmodule MessengerBot.Webhook.Callback do

  @moduledoc """

  MessengerBot webhook for all callbacks

  """



  alias EventBus.Model.Event



  @spec process(integer(), String.t) :: {:ok, String.t}

  def process(app_id, payload) do

    webhook_payload = Poison.decode!(payload)

    transaction_id = UUID.uuid1()



    for entry <- webhook_payload["entry"] do

      process_entry(transaction_id, {app_id, entry})

    end

    {:ok, "ok"}

  end



  defp process_entry(transaction_id, {app_id, entry}) do

    time = entry["time"]

    page_id = entry["id"]



    for messaging <- entry["messaging"] do

      process_messaging(transaction_id, {app_id, page_id, time, messaging})

    end

  end



  defp process_messaging(transaction_id, {app_id, page_id, time, messaging}) do

    topic = fetch_topic(messaging)

    payload = %{app_id: app_id, messaging: messaging, page_id: page_id,

      time: time}

    event = %Event{id: UUID.uuid1(), topic: topic, data: payload,

      transaction_id: transaction_id, occurred_at: time}

    EventBus.notify(event)

  end



  defp fetch_topic(%{"delivery" => _}),

    do: :mb_delivery_received

  defp fetch_topic(%{"read" => _}),

    do: :mb_read_received

  defp fetch_topic(%{"message" => %{"is_echo" => true}}),

    do: :mb_message_echo_received

  defp fetch_topic(%{"message" => %{"attachments" => _}}),

    do: :mb_message_attachments_received

  defp fetch_topic(%{"message" => %{"quick_reply" => _}}),

    do: :mb_message_quick_reply_received

  defp fetch_topic(%{"message" => _}),

    do: :mb_message_received

  defp fetch_topic(%{"optin" => _}),

    do: :mb_optin_received

  defp fetch_topic(%{"postback" => _}),

    do: :mb_postback_received

  defp fetch_topic(%{"referral" => _}),

    do: :mb_referral_received

  defp fetch_topic(%{"payment" => _}),

    do: :mb_payment_received

  defp fetch_topic(%{"checkout_update" => _}),

    do: :mb_checkout_update_received

  defp fetch_topic(%{"pre_checkout" => _}),

    do: :mb_pre_checkout_received

  defp fetch_topic(%{"account_linking" => _}),

    do: :mb_account_linking_received

  defp fetch_topic(%{"policy_enforcement" => _}),

    do: :mb_policy_enforcement_received

  defp fetch_topic(%{"policy-enforcement" => _}),

    do: :mb_policy_enforcement_received

  defp fetch_topic(%{"app_roles" => _}),

    do: :mb_app_roles_received

  defp fetch_topic(%{"standby" => _}),

    do: :mb_standby_received

  defp fetch_topic(%{"pass_thread_control" => _}),

    do: :mb_pass_thread_control_received

  defp fetch_topic(%{"take_thread_control" => _}),

    do: :mb_take_thread_control_received

  defp fetch_topic(_),

    do: :mb_na_received

end