chore: Merge branch 'emails' into dev

Author: mydearxym

config/config.exs

@@ -66,6 +66,15 @@ config :groupher_server, :customization,
 
 config :groupher_server, GroupherServerWeb.Gettext, default_locale: "zh_CN", locales: ~w(en zh_CN)
 
+#  config email services
+config :groupher_server, :system_emails,
+  support: "coderplanets <support@group.coderplanets.com>",
+  admin: "mydearxym@qq.com"
+
+config :groupher_server, GroupherServer.Mailer,
+  adapter: Bamboo.MailgunAdapter,
+  domain: "mailer.coderplanets.com"
+
 import_config "#{Mix.env()}.exs"
 
 if File.exists?("config/#{Mix.env()}.secret.exs") do

config/dev.exs

@@ -54,3 +54,6 @@ config :groupher_server, GroupherServer.Repo,
 config :groupher_server, :github_oauth,
   client_id: System.get_env("OAUTH_GITHUB_CLIENT_ID"),
   client_secret: System.get_env("OAUTH_GITHUB_CLIENT_SECRET")
+
+#  config email services
+config :groupher_server, GroupherServer.Mailer, api_key: System.get_env("MAILER_API_KEY")

config/mock.exs

@@ -19,3 +19,6 @@ config :groupher_server, GroupherServer.Repo,
   database: "groupher_server_mock",
   hostname: "localhost",
   pool_size: 10
+
+#  config email services
+config :groupher_server, GroupherServer.Mailer, adapter: Bamboo.LocalAdapter

config/prod.exs

@@ -95,3 +95,6 @@ config :sentry,
     env: "production"
   },
   included_environments: [:prod]
+
+#  config email services
+config :groupher_server, GroupherServer.Mailer, api_key: System.get_env("MAILER_API_KEY")

config/test.exs

@@ -25,3 +25,6 @@ config :groupher_server, GroupherServer.Repo,
 config :groupher_server, :github_oauth,
   client_id: "3b4281c5e54ffd801f85",
   client_secret: "51f04dd8239b27f00a39a647ef3704de4c5ddc26"
+
+#  config email services
+config :groupher_server, GroupherServer.Mailer, adapter: Bamboo.TestAdapter

lib/groupher_server/accounts/delegates/profile.ex

@@ -10,6 +10,7 @@ defmodule GroupherServer.Accounts.Delegate.Profile do
   alias Helper.{Guardian, ORM, QueryBuilder, RadarSearch}
   alias GroupherServer.Accounts.{Achievement, GithubUser, User, Social}
   alias GroupherServer.{CMS, Repo}
+  alias GroupherServer.Email
 
   alias Ecto.Multi
 
@@ -149,7 +150,14 @@ defmodule GroupherServer.Accounts.Delegate.Profile do
     |> register_github_result
   end
 
-  defp register_github_result({:ok, %{create_user: user}}), do: gen_token(user)
+  defp register_github_result({:ok, %{create_user: create_user}}) do
+    {:ok, user} = ORM.find(User, create_user.id, preload: :github_profile)
+
+    Email.welcome(user)
+    Email.notify_admin(user, :new_register)
+
+    gen_token(user)
+  end
 
   defp register_github_result({:error, :create_user, %Ecto.Changeset{} = result, _steps}),
     do: {:error, result}

lib/groupher_server/billing/delegates/curd.ex

@@ -12,6 +12,7 @@ defmodule GroupherServer.Billing.Delegate.CURD do
   alias GroupherServer.Billing.BillRecord
   alias GroupherServer.Billing.Delegate.Actions
   alias GroupherServer.Repo
+  alias GroupherServer.Email
 
   alias Ecto.Multi
 
@@ -87,6 +88,13 @@ defmodule GroupherServer.Billing.Delegate.CURD do
       |> Map.merge(~m(user_id hash_id state)a)
       |> map_atom_value(:string)
 
-    BillRecord |> ORM.create(attrs)
+    # {:ok, record} = BillRecord |> ORM.create(attrs)
+    #  TODO: 
+    {:ok, record} = BillRecord |> ORM.create(attrs)
+    # IO.inspect(record, label: "record ->")
+    Email.notify_admin(record, :payment)
+    # {:ok, record} = BillRecord |> ORM.create(attrs, {after_success: })
+    # i email to admin
+    {:ok, record}
   end
 end

lib/groupher_server/cms/utils/loader.ex

@@ -178,7 +178,7 @@ defmodule GroupherServer.CMS.Utils.Loader do
   # NOTE: this is NOT the right solution
   # should use WINDOW function
   # see https://github.com/coderplanets/coderplanets_server/issues/16
-  def query({"posts_comments", PostComment}, %{filter: filter, unique: true}) do
+  def query({"posts_comments", PostComment}, %{filter: _filter, unique: true}) do
     PostComment
     |> join(:inner, [c], a in assoc(c, :author))
     # NOTE:  this distinct not working in production env, so the uniq logic is move to

lib/groupher_server/mailer/email.ex

@@ -0,0 +1,65 @@
+defmodule GroupherServer.Email do
+  @moduledoc """
+  the email dispatch system for Groupher
+
+  welcom_email -> send to new register
+  """
+  import Bamboo.Email
+  import Helper.Utils, only: [get_config: 2]
+
+  alias GroupherServer.Accounts.User
+  alias GroupherServer.Billing.BillRecord
+
+  alias GroupherServer.Email.Templates
+  alias GroupherServer.Mailer
+
+  @support_email get_config(:system_emails, :support)
+  @admin_email get_config(:system_emails, :admin)
+
+  def welcome(%User{email: email} = user) when not is_nil(email) do
+    base_mail()
+    |> to(email)
+    |> subject("欢迎来到 coderplanets")
+    |> html_body(Templates.Welcome.html(user))
+    |> text_body(Templates.Welcome.text())
+    |> Mailer.deliver_later()
+  end
+
+  #  user has no email log to somewhere
+  def welcome(_user) do
+    {:ok, :pass}
+  end
+
+  def notify_admin(%User{from_github: true} = user, :new_register) do
+    base_mail()
+    |> to(@admin_email)
+    |> subject("新用户(#{user.nickname})注册")
+    |> html_body(Templates.NotifyAdminRegister.html(user))
+    |> text_body(Templates.NotifyAdminRegister.text())
+    |> Mailer.deliver_later()
+  end
+
+  def notify_admin(_user, :new_register) do
+    {:ok, :pass}
+  end
+
+  def notify_admin(%BillRecord{} = record, :payment) do
+    base_mail()
+    |> to(@admin_email)
+    |> subject("打赏 #{record.amount} 元")
+    |> html_body(Templates.NotifyAdminPayment.html(record))
+    |> text_body(Templates.NotifyAdminPayment.text())
+    |> Mailer.deliver_later()
+  end
+
+  # some one comment to your post ..
+  # the author's publish content being deleted ..
+  def notify_author, do: IO.inspect("notify_author")
+  def notify_publish, do: IO.inspect("notify_publish")
+  # ...
+
+  defp base_mail do
+    new_email()
+    |> from(@support_email)
+  end
+end

lib/groupher_server/mailer/mailer.ex

@@ -0,0 +1,6 @@
+defmodule GroupherServer.Mailer do
+  @moduledoc """
+  the email staff for Groupher
+  """
+  use Bamboo.Mailer, otp_app: :groupher_server
+end