mailersend.ex

defmodule Webhoox.Adapter.Mailersend do
  @moduledoc """
  Mailersend Adapter
  Note: Must set up custom parser to set raw_body:
  - https://stackoverflow.com/questions/41510957/read-the-raw-body-from-a-plug-connection-after-parsers-in-elixir
  - https://hexdocs.pm/plug/Plug.Parsers.html#module-custom-body-reader
  """
  import Webhoox.Authentication
  import Webhoox.Utility.Parser

  @behaviour Webhoox.Adapter

  def handle_webhook(conn, handler, opts) do
    signing_secret = Keyword.fetch!(opts, :signing_secret)

    case valid_signature?(:base16, conn, signing_secret, "signature") do
      true ->
        conn.body_params
        |> normalize_params()
        |> handler.process()

        {:ok, conn}

      _ ->
        {:error, conn}
    end
  end

  @doc """
  Handle Mailersend v1 webhook type
  """
  def normalize_params(
        email = %{
          "created_at" => timestamp,
          "data" => %{
            "email" => %{
              "from" => sender,
              "message" => %{
                "id" => message_id
              },
              "recipient" => %{
                "email" => to
              },
              "subject" => subject
            }
          },
          "type" => event
        }
      ) do
    %Webhoox.Webhook.Email{
      message_id: message_id,
      event: event,
      sender: sender,
      to: parse_email_recipients(to),
      from: parse_email_address(sender),
      subject: subject,
      timestamp: parse_timestamp(timestamp),
      raw_params: email
    }
  end

  def normalize_params(
        email = %{
          "created_at" => timestamp,
          "data" => %{
            "from" => %{"email" => sender},
            "html" => html,
            "text" => text,
            "id" => message_id,
            "subject" => subject,
            "recipients" => %{
              "to" => %{"raw" => to}
            }
          },
          "type" => event
        }
      ) do
    %Webhoox.Webhook.Email{
      message_id: message_id,
      event: event,
      sender: sender,
      to: parse_email_recipients(to),
      from: parse_email_address(sender),
      subject: subject,
      html: html,
      text: text,
      timestamp: parse_timestamp(timestamp),
      raw_params: email
    }
  end

  def normalize_params(_), do: nil
end