1 # Pleroma: A lightweight social networking server
2 # Copyright © 2017-2020 Pleroma Authors <https://pleroma.social/>
3 # SPDX-License-Identifier: AGPL-3.0-only
5 defmodule Mix.Tasks.Pleroma.UserTest do
9 alias Pleroma.Tests.ObanHelpers
11 alias Pleroma.Web.CommonAPI
12 alias Pleroma.Web.OAuth.Authorization
13 alias Pleroma.Web.OAuth.Token
16 use Oban.Testing, repo: Pleroma.Repo
18 import ExUnit.CaptureIO
20 import Pleroma.Factory
23 Mix.shell(Mix.Shell.Process)
26 Mix.shell(Mix.Shell.IO)
32 describe "running new" do
33 test "user is created" do
34 # just get random data
35 unsaved = build(:user)
37 # prepare to answer yes
38 send(self(), {:mix_shell_input, :yes?, true})
40 Mix.Tasks.Pleroma.User.run([
54 assert_received {:mix_shell, :info, [message]}
55 assert message =~ "user will be created"
57 assert_received {:mix_shell, :yes?, [message]}
58 assert message =~ "Continue"
60 assert_received {:mix_shell, :info, [message]}
61 assert message =~ "created"
63 user = User.get_cached_by_nickname(unsaved.nickname)
64 assert user.name == unsaved.name
65 assert user.email == unsaved.email
66 assert user.bio == unsaved.bio
67 assert user.is_moderator
71 test "user is not created" do
72 unsaved = build(:user)
74 # prepare to answer no
75 send(self(), {:mix_shell_input, :yes?, false})
77 Mix.Tasks.Pleroma.User.run(["new", unsaved.nickname, unsaved.email])
79 assert_received {:mix_shell, :info, [message]}
80 assert message =~ "user will be created"
82 assert_received {:mix_shell, :yes?, [message]}
83 assert message =~ "Continue"
85 assert_received {:mix_shell, :info, [message]}
86 assert message =~ "will not be created"
88 refute User.get_cached_by_nickname(unsaved.nickname)
92 describe "running rm" do
93 test "user is deleted" do
96 with_mock Pleroma.Web.Federator,
97 publish: fn _ -> nil end do
98 Mix.Tasks.Pleroma.User.run(["rm", user.nickname])
99 ObanHelpers.perform_all()
101 assert_received {:mix_shell, :info, [message]}
102 assert message =~ " deleted"
103 assert %{deactivated: true} = User.get_by_nickname(user.nickname)
105 assert called(Pleroma.Web.Federator.publish(:_))
109 test "a remote user's create activity is deleted when the object has been pruned" do
112 {:ok, post} = CommonAPI.post(user, %{status: "uguu"})
113 object = Object.normalize(post)
116 with_mock Pleroma.Web.Federator,
117 publish: fn _ -> nil end do
118 Mix.Tasks.Pleroma.User.run(["rm", user.nickname])
119 ObanHelpers.perform_all()
121 assert_received {:mix_shell, :info, [message]}
122 assert message =~ " deleted"
123 assert %{deactivated: true} = User.get_by_nickname(user.nickname)
125 assert called(Pleroma.Web.Federator.publish(:_))
128 refute Activity.get_by_id(post.id)
131 test "no user to delete" do
132 Mix.Tasks.Pleroma.User.run(["rm", "nonexistent"])
134 assert_received {:mix_shell, :error, [message]}
135 assert message =~ "No local user"
139 describe "running toggle_activated" do
140 test "user is deactivated" do
143 Mix.Tasks.Pleroma.User.run(["toggle_activated", user.nickname])
145 assert_received {:mix_shell, :info, [message]}
146 assert message =~ " deactivated"
148 user = User.get_cached_by_nickname(user.nickname)
149 assert user.deactivated
152 test "user is activated" do
153 user = insert(:user, deactivated: true)
155 Mix.Tasks.Pleroma.User.run(["toggle_activated", user.nickname])
157 assert_received {:mix_shell, :info, [message]}
158 assert message =~ " activated"
160 user = User.get_cached_by_nickname(user.nickname)
161 refute user.deactivated
164 test "no user to toggle" do
165 Mix.Tasks.Pleroma.User.run(["toggle_activated", "nonexistent"])
167 assert_received {:mix_shell, :error, [message]}
168 assert message =~ "No user"
172 describe "running unsubscribe" do
173 test "user is unsubscribed" do
174 followed = insert(:user)
176 User.follow(user, followed, :follow_accept)
178 Mix.Tasks.Pleroma.User.run(["unsubscribe", user.nickname])
180 assert_received {:mix_shell, :info, [message]}
181 assert message =~ "Deactivating"
183 assert_received {:mix_shell, :info, [message]}
184 assert message =~ "Unsubscribing"
186 # Note that the task has delay :timer.sleep(500)
187 assert_received {:mix_shell, :info, [message]}
188 assert message =~ "Successfully unsubscribed"
190 user = User.get_cached_by_nickname(user.nickname)
191 assert Enum.empty?(User.get_friends(user))
192 assert user.deactivated
195 test "no user to unsubscribe" do
196 Mix.Tasks.Pleroma.User.run(["unsubscribe", "nonexistent"])
198 assert_received {:mix_shell, :error, [message]}
199 assert message =~ "No user"
203 describe "running set" do
204 test "All statuses set" do
207 Mix.Tasks.Pleroma.User.run(["set", user.nickname, "--moderator", "--admin", "--locked"])
209 assert_received {:mix_shell, :info, [message]}
210 assert message =~ ~r/Moderator status .* true/
212 assert_received {:mix_shell, :info, [message]}
213 assert message =~ ~r/Locked status .* true/
215 assert_received {:mix_shell, :info, [message]}
216 assert message =~ ~r/Admin status .* true/
218 user = User.get_cached_by_nickname(user.nickname)
219 assert user.is_moderator
224 test "All statuses unset" do
225 user = insert(:user, locked: true, is_moderator: true, is_admin: true)
227 Mix.Tasks.Pleroma.User.run([
235 assert_received {:mix_shell, :info, [message]}
236 assert message =~ ~r/Moderator status .* false/
238 assert_received {:mix_shell, :info, [message]}
239 assert message =~ ~r/Locked status .* false/
241 assert_received {:mix_shell, :info, [message]}
242 assert message =~ ~r/Admin status .* false/
244 user = User.get_cached_by_nickname(user.nickname)
245 refute user.is_moderator
250 test "no user to set status" do
251 Mix.Tasks.Pleroma.User.run(["set", "nonexistent", "--moderator"])
253 assert_received {:mix_shell, :error, [message]}
254 assert message =~ "No local user"
258 describe "running reset_password" do
259 test "password reset token is generated" do
262 assert capture_io(fn ->
263 Mix.Tasks.Pleroma.User.run(["reset_password", user.nickname])
266 assert_received {:mix_shell, :info, [message]}
267 assert message =~ "Generated"
270 test "no user to reset password" do
271 Mix.Tasks.Pleroma.User.run(["reset_password", "nonexistent"])
273 assert_received {:mix_shell, :error, [message]}
274 assert message =~ "No local user"
278 describe "running invite" do
279 test "invite token is generated" do
280 assert capture_io(fn ->
281 Mix.Tasks.Pleroma.User.run(["invite"])
284 assert_received {:mix_shell, :info, [message]}
285 assert message =~ "Generated user invite token one time"
288 test "token is generated with expires_at" do
289 assert capture_io(fn ->
290 Mix.Tasks.Pleroma.User.run([
293 Date.to_string(Date.utc_today())
297 assert_received {:mix_shell, :info, [message]}
298 assert message =~ "Generated user invite token date limited"
301 test "token is generated with max use" do
302 assert capture_io(fn ->
303 Mix.Tasks.Pleroma.User.run([
310 assert_received {:mix_shell, :info, [message]}
311 assert message =~ "Generated user invite token reusable"
314 test "token is generated with max use and expires date" do
315 assert capture_io(fn ->
316 Mix.Tasks.Pleroma.User.run([
321 Date.to_string(Date.utc_today())
325 assert_received {:mix_shell, :info, [message]}
326 assert message =~ "Generated user invite token reusable date limited"
330 describe "running invites" do
331 test "invites are listed" do
332 {:ok, invite} = Pleroma.UserInviteToken.create_invite()
335 Pleroma.UserInviteToken.create_invite(%{expires_at: Date.utc_today(), max_use: 15})
337 # assert capture_io(fn ->
338 Mix.Tasks.Pleroma.User.run([
344 assert_received {:mix_shell, :info, [message]}
345 assert_received {:mix_shell, :info, [message2]}
346 assert_received {:mix_shell, :info, [message3]}
347 assert message =~ "Invites list:"
348 assert message2 =~ invite.invite_type
349 assert message3 =~ invite2.invite_type
353 describe "running revoke_invite" do
354 test "invite is revoked" do
355 {:ok, invite} = Pleroma.UserInviteToken.create_invite(%{expires_at: Date.utc_today()})
357 assert capture_io(fn ->
358 Mix.Tasks.Pleroma.User.run([
364 assert_received {:mix_shell, :info, [message]}
365 assert message =~ "Invite for token #{invite.token} was revoked."
368 test "it prints an error message when invite is not exist" do
369 Mix.Tasks.Pleroma.User.run(["revoke_invite", "foo"])
371 assert_received {:mix_shell, :error, [message]}
372 assert message =~ "No invite found"
376 describe "running delete_activities" do
377 test "activities are deleted" do
378 %{nickname: nickname} = insert(:user)
380 assert :ok == Mix.Tasks.Pleroma.User.run(["delete_activities", nickname])
381 assert_received {:mix_shell, :info, [message]}
382 assert message == "User #{nickname} statuses deleted."
385 test "it prints an error message when user is not exist" do
386 Mix.Tasks.Pleroma.User.run(["delete_activities", "foo"])
388 assert_received {:mix_shell, :error, [message]}
389 assert message =~ "No local user"
393 describe "running toggle_confirmed" do
394 test "user is confirmed" do
395 %{id: id, nickname: nickname} = insert(:user, confirmation_pending: false)
397 assert :ok = Mix.Tasks.Pleroma.User.run(["toggle_confirmed", nickname])
398 assert_received {:mix_shell, :info, [message]}
399 assert message == "#{nickname} needs confirmation."
401 user = Repo.get(User, id)
402 assert user.confirmation_pending
403 assert user.confirmation_token
406 test "user is not confirmed" do
407 %{id: id, nickname: nickname} =
408 insert(:user, confirmation_pending: true, confirmation_token: "some token")
410 assert :ok = Mix.Tasks.Pleroma.User.run(["toggle_confirmed", nickname])
411 assert_received {:mix_shell, :info, [message]}
412 assert message == "#{nickname} doesn't need confirmation."
414 user = Repo.get(User, id)
415 refute user.confirmation_pending
416 refute user.confirmation_token
419 test "it prints an error message when user is not exist" do
420 Mix.Tasks.Pleroma.User.run(["toggle_confirmed", "foo"])
422 assert_received {:mix_shell, :error, [message]}
423 assert message =~ "No local user"
428 test "it returns users matching" do
430 moon = insert(:user, nickname: "moon", name: "fediverse expert moon")
431 moot = insert(:user, nickname: "moot")
432 kawen = insert(:user, nickname: "kawen", name: "fediverse expert moon")
434 {:ok, user} = User.follow(user, kawen)
436 assert [moon.id, kawen.id] == User.Search.search("moon") |> Enum.map(& &1.id)
437 res = User.search("moo") |> Enum.map(& &1.id)
438 assert moon.id in res
439 assert moot.id in res
440 assert kawen.id in res
441 assert [moon.id, kawen.id] == User.Search.search("moon fediverse") |> Enum.map(& &1.id)
443 assert [kawen.id, moon.id] ==
444 User.Search.search("moon fediverse", for_user: user) |> Enum.map(& &1.id)
448 describe "signing out" do
449 test "it deletes all user's tokens and authorizations" do
451 insert(:oauth_token, user: user)
452 insert(:oauth_authorization, user: user)
454 assert Repo.get_by(Token, user_id: user.id)
455 assert Repo.get_by(Authorization, user_id: user.id)
457 :ok = Mix.Tasks.Pleroma.User.run(["sign_out", user.nickname])
459 refute Repo.get_by(Token, user_id: user.id)
460 refute Repo.get_by(Authorization, user_id: user.id)
463 test "it prints an error message when user is not exist" do
464 Mix.Tasks.Pleroma.User.run(["sign_out", "foo"])
466 assert_received {:mix_shell, :error, [message]}
467 assert message =~ "No local user"
471 describe "tagging" do
472 test "it add tags to a user" do
475 :ok = Mix.Tasks.Pleroma.User.run(["tag", user.nickname, "pleroma"])
477 user = User.get_cached_by_nickname(user.nickname)
478 assert "pleroma" in user.tags
481 test "it prints an error message when user is not exist" do
482 Mix.Tasks.Pleroma.User.run(["tag", "foo"])
484 assert_received {:mix_shell, :error, [message]}
485 assert message =~ "Could not change user tags"
489 describe "untagging" do
490 test "it deletes tags from a user" do
491 user = insert(:user, tags: ["pleroma"])
492 assert "pleroma" in user.tags
494 :ok = Mix.Tasks.Pleroma.User.run(["untag", user.nickname, "pleroma"])
496 user = User.get_cached_by_nickname(user.nickname)
497 assert Enum.empty?(user.tags)
500 test "it prints an error message when user is not exist" do
501 Mix.Tasks.Pleroma.User.run(["untag", "foo"])
503 assert_received {:mix_shell, :error, [message]}
504 assert message =~ "Could not change user tags"