git.squeep.com Git - akkoma/blob - lib/pleroma/emails/user_email.ex

   1 # Pleroma: A lightweight social networking server
   2 # Copyright © 2017-2019 Pleroma Authors <https://pleroma.social/>
   3 # SPDX-License-Identifier: AGPL-3.0-only
   4
   5 defmodule Pleroma.Emails.UserEmail do
   6   @moduledoc "User emails"
   7
   8   use Phoenix.Swoosh, view: Pleroma.Web.EmailView, layout: {Pleroma.Web.LayoutView, :email}
   9
  10   alias Pleroma.Web.Endpoint
  11   alias Pleroma.Web.Router
  12
  13   defp instance_config, do: Pleroma.Config.get(:instance)
  14
  15   defp instance_name, do: instance_config()[:name]
  16
  17   defp sender do
  18     email = Keyword.get(instance_config(), :notify_email, instance_config()[:email])
  19     {instance_name(), email}
  20   end
  21
  22   defp recipient(email, nil), do: email
  23   defp recipient(email, name), do: {name, email}
  24   defp recipient(%Pleroma.User{} = user), do: recipient(user.email, user.name)
  25
  26   def password_reset_email(user, password_reset_token) when is_binary(password_reset_token) do
  27     password_reset_url =
  28       Router.Helpers.util_url(
  29         Endpoint,
  30         :show_password_reset,
  31         password_reset_token
  32       )
  33
  34     html_body = """
  35     <h3>Reset your password at #{instance_name()}</h3>
  36     <p>Someone has requested password change for your account at #{instance_name()}.</p>
  37     <p>If it was you, visit the following link to proceed: <a href="#{password_reset_url}">reset password</a>.</p>
  38     <p>If it was someone else, nothing to worry about: your data is secure and your password has not been changed.</p>
  39     """
  40
  41     new()
  42     |> to(recipient(user))
  43     |> from(sender())
  44     |> subject("Password reset")
  45     |> html_body(html_body)
  46   end
  47
  48   def user_invitation_email(
  49         user,
  50         %Pleroma.UserInviteToken{} = user_invite_token,
  51         to_email,
  52         to_name \\ nil
  53       ) do
  54     registration_url =
  55       Router.Helpers.redirect_url(
  56         Endpoint,
  57         :registration_page,
  58         user_invite_token.token
  59       )
  60
  61     html_body = """
  62     <h3>You are invited to #{instance_name()}</h3>
  63     <p>#{user.name} invites you to join #{instance_name()}, an instance of Pleroma federated social networking platform.</p>
  64     <p>Click the following link to register: <a href="#{registration_url}">accept invitation</a>.</p>
  65     """
  66
  67     new()
  68     |> to(recipient(to_email, to_name))
  69     |> from(sender())
  70     |> subject("Invitation to #{instance_name()}")
  71     |> html_body(html_body)
  72   end
  73
  74   def account_confirmation_email(user) do
  75     confirmation_url =
  76       Router.Helpers.confirm_email_url(
  77         Endpoint,
  78         :confirm_email,
  79         user.id,
  80         to_string(user.info.confirmation_token)
  81       )
  82
  83     html_body = """
  84     <h3>Welcome to #{instance_name()}!</h3>
  85     <p>Email confirmation is required to activate the account.</p>
  86     <p>Click the following link to proceed: <a href="#{confirmation_url}">activate your account</a>.</p>
  87     """
  88
  89     new()
  90     |> to(recipient(user))
  91     |> from(sender())
  92     |> subject("#{instance_name()} account confirmation")
  93     |> html_body(html_body)
  94   end
  95
  96   @doc """
  97   Email used in digest email notifications
  98   Includes Mentions and New Followers data
  99   If there are no mentions (even when new followers exist), the function will return nil
 100   """
 101   @spec digest_email(Pleroma.User.t()) :: Swoosh.Email.t() | nil
 102   def digest_email(user) do
 103     new_notifications =
 104       Pleroma.Notification.for_user_since(user, user.last_digest_emailed_at)
 105       |> Enum.reduce(%{followers: [], mentions: []}, fn
 106         %{activity: %{data: %{"type" => "Create"}, actor: actor} = activity} = notification,
 107         acc ->
 108           new_mention = %{
 109             data: notification,
 110             object: Pleroma.Object.normalize(activity),
 111             from: Pleroma.User.get_by_ap_id(actor)
 112           }
 113
 114           %{acc | mentions: [new_mention | acc.mentions]}
 115
 116         %{activity: %{data: %{"type" => "Follow"}, actor: actor} = activity} = notification,
 117         acc ->
 118           new_follower = %{
 119             data: notification,
 120             object: Pleroma.Object.normalize(activity),
 121             from: Pleroma.User.get_by_ap_id(actor)
 122           }
 123
 124           %{acc | followers: [new_follower | acc.followers]}
 125
 126         _, acc ->
 127           acc
 128       end)
 129
 130     with [_ | _] = mentions <- new_notifications.mentions do
 131       html_data = %{
 132         instance: instance_name(),
 133         user: user,
 134         mentions: mentions,
 135         followers: new_notifications.followers,
 136         unsubscribe_link: unsubscribe_url(user, "digest")
 137       }
 138
 139       new()
 140       |> to(recipient(user))
 141       |> from(sender())
 142       |> subject("Your digest from #{instance_name()}")
 143       |> render_body("digest.html", html_data)
 144     else
 145       _ ->
 146         nil
 147     end
 148   end
 149
 150   @doc """
 151   Generate unsubscribe link for given user and notifications type.
 152   The link contains JWT token with the data, and subscription can be modified without
 153   authorization.
 154   """
 155   @spec unsubscribe_url(Pleroma.User.t(), String.t()) :: String.t()
 156   def unsubscribe_url(user, notifications_type) do
 157     token =
 158       %{"sub" => user.id, "act" => %{"unsubscribe" => notifications_type}, "exp" => false}
 159       |> Pleroma.JWT.generate_and_sign!()
 160       |> Base.encode64()
 161
 162     Router.Helpers.subscription_url(Pleroma.Web.Endpoint, :unsubscribe, token)
 163   end
 164 end