54 lines
		
	
	
	
		
			1.6 KiB
		
	
	
	
		
			Elixir
		
	
	
	
	
	
			
		
		
	
	
			54 lines
		
	
	
	
		
			1.6 KiB
		
	
	
	
		
			Elixir
		
	
	
	
	
	
| # Pleroma: A lightweight social networking server
 | |
| # Copyright © 2017-2020 Pleroma Authors <https://pleroma.social/>
 | |
| # SPDX-License-Identifier: AGPL-3.0-only
 | |
| 
 | |
| defmodule Pleroma.Workers.Cron.DigestEmailsWorkerTest do
 | |
|   use Pleroma.DataCase
 | |
| 
 | |
|   import Pleroma.Factory
 | |
| 
 | |
|   alias Pleroma.Tests.ObanHelpers
 | |
|   alias Pleroma.User
 | |
|   alias Pleroma.Web.CommonAPI
 | |
| 
 | |
|   setup do: clear_config([:email_notifications, :digest])
 | |
| 
 | |
|   setup do
 | |
|     Pleroma.Config.put([:email_notifications, :digest], %{
 | |
|       active: true,
 | |
|       inactivity_threshold: 7,
 | |
|       interval: 7
 | |
|     })
 | |
| 
 | |
|     user = insert(:user)
 | |
| 
 | |
|     date =
 | |
|       Timex.now()
 | |
|       |> Timex.shift(days: -10)
 | |
|       |> Timex.to_naive_datetime()
 | |
| 
 | |
|     user2 = insert(:user, last_digest_emailed_at: date)
 | |
|     {:ok, _} = User.switch_email_notifications(user2, "digest", true)
 | |
|     CommonAPI.post(user, %{status: "hey @#{user2.nickname}!"})
 | |
| 
 | |
|     {:ok, user2: user2}
 | |
|   end
 | |
| 
 | |
|   test "it sends digest emails", %{user2: user2} do
 | |
|     Pleroma.Workers.Cron.DigestEmailsWorker.perform(%Oban.Job{})
 | |
|     # Performing job(s) enqueued at previous step
 | |
|     ObanHelpers.perform_all()
 | |
| 
 | |
|     assert_received {:email, email}
 | |
|     assert email.to == [{user2.name, user2.email}]
 | |
|     assert email.subject == "Your digest from #{Pleroma.Config.get(:instance)[:name]}"
 | |
|   end
 | |
| 
 | |
|   test "it doesn't fail when a user has no email", %{user2: user2} do
 | |
|     {:ok, _} = user2 |> Ecto.Changeset.change(%{email: nil}) |> Pleroma.Repo.update()
 | |
| 
 | |
|     Pleroma.Workers.Cron.DigestEmailsWorker.perform(%Oban.Job{})
 | |
|     # Performing job(s) enqueued at previous step
 | |
|     ObanHelpers.perform_all()
 | |
|   end
 | |
| end
 | 
