webhoox

defmodule Webhoox.Adapter.Mailgun do
  @moduledoc false
  @behaviour Webhoox.Adapter

  import Webhoox.Parser

  def handle_webhook(conn, handler, opts) do
    payload = conn.body_params

    api_key = Keyword.fetch!(opts, :api_key)

    case valid_webhook_request?(payload, api_key) do
      true ->
        payload
        |> normalize_params()
        |> handler.process()

        {:ok, conn}

      _ ->
        {:error, conn}
    end
  end

  defp valid_webhook_request?(
         %{
           "signature" =>
             signature = %{
               "timestamp" => timestamp,
               "token" => token,
               "signature" => expected_signature
             }
         },
         api_key
       )
       when is_map(signature) do
    valid_signature?(timestamp, token, expected_signature, api_key)
  end

  defp valid_webhook_request?(
         %{
           "timestamp" => timestamp,
           "token" => token,
           "signature" => expected_signature
         },
         api_key
       )
       when is_binary(timestamp) do
    valid_signature?(timestamp, token, expected_signature, api_key)
  end

  defp valid_webhook_request?(_, _), do: false

  defp valid_signature?(timestamp, token, expected_signature, api_key) do
    data = timestamp <> token

    :crypto.mac(:hmac, :sha256, api_key, data)
    |> Base.encode16(case: :lower)
    |> Plug.Crypto.secure_compare(expected_signature)
  end

  @doc """
  Handle Mailgun v3 'event-data' webhook type:
  https://documentation.mailgun.com/en/latest/api-webhooks.html?highlight=webhooks#webhooks
  """
  def normalize_params(
        email = %{
          "event-data" => %{
            "envelope" => %{
              "sender" => sender
            },
            "event" => event,
            "message" => %{
              "headers" => %{
                "from" => from,
                "message-id" => message_id,
                "subject" => subject,
                "to" => to
              }
            },
            "timestamp" => timestamp
          }
        }
      ) do
    %Webhoox.Data.Email{
      message_id: message_id,
      event: event,
      sender: sender,
      to: parse_recipients(to),
      from: parse_address(from),
      subject: subject,
      timestamp: parse_timestamp(timestamp),
      raw_params: email
    }
  end

  def normalize_params(
        email = %{
          "event-data" => %{
            "event" => event,
            "message" => %{
              "headers" => %{
                "message-id" => message_id
              }
            },
            "timestamp" => timestamp
          }
        }
      ) do
    %Webhoox.Data.Email{
      message_id: message_id,
      event: event,
      timestamp: parse_timestamp(timestamp),
      raw_params: email
    }
  end

  def normalize_params(
        email = %{
          "From" => from,
          "Message-Id" => message_id,
          "Sender" => sender,
          "Subject" => subject,
          "To" => to,
          "body-html" => html,
          "body-plain" => text,
          "timestamp" => timestamp
        }
      ) do
    %Webhoox.Data.Email{
      message_id: message_id,
      sender: sender,
      to: parse_recipients(to),
      from: parse_address(from),
      subject: subject,
      html: html,
      text: text,
      timestamp: parse_timestamp(timestamp),
      raw_params: email
    }
  end

  def normalize_params(_), do: nil
end