1 # Pleroma: A lightweight social networking server
2 # Copyright © 2017-2019 Pleroma Authors <https://pleroma.social/>
3 # SPDX-License-Identifier: AGPL-3.0-only
5 defmodule Pleroma.Conversation.ParticipationTest do
8 alias Pleroma.Conversation.Participation
9 alias Pleroma.Web.CommonAPI
11 test "getting a participation will also preload things" do
13 other_user = insert(:user)
16 CommonAPI.post(user, %{"status" => "Hey @#{other_user.nickname}.", "visibility" => "direct"})
18 [participation] = Participation.for_user(user)
20 participation = Participation.get(participation.id, preload: [:conversation])
22 assert %Pleroma.Conversation{} = participation.conversation
25 test "for a new conversation, it sets the recipents of the participation" do
27 other_user = insert(:user)
28 third_user = insert(:user)
31 CommonAPI.post(user, %{"status" => "Hey @#{other_user.nickname}.", "visibility" => "direct"})
33 [participation] = Participation.for_user(user)
34 participation = Pleroma.Repo.preload(participation, :recipients)
36 assert length(participation.recipients) == 2
37 assert user in participation.recipients
38 assert other_user in participation.recipients
40 # Mentioning another user in the same conversation will not add a new recipients.
43 CommonAPI.post(user, %{
44 "in_reply_to_status_id" => activity.id,
45 "status" => "Hey @#{third_user.nickname}.",
46 "visibility" => "direct"
49 [participation] = Participation.for_user(user)
50 participation = Pleroma.Repo.preload(participation, :recipients)
52 assert length(participation.recipients) == 2
55 test "it creates a participation for a conversation and a user" do
57 conversation = insert(:conversation)
59 {:ok, %Participation{} = participation} =
60 Participation.create_for_user_and_conversation(user, conversation)
62 assert participation.user_id == user.id
63 assert participation.conversation_id == conversation.id
66 # Creating again returns the same participation
67 {:ok, %Participation{} = participation_two} =
68 Participation.create_for_user_and_conversation(user, conversation)
70 assert participation.id == participation_two.id
71 refute participation.updated_at == participation_two.updated_at
74 test "recreating an existing participations sets it to unread" do
75 participation = insert(:participation, %{read: true})
77 {:ok, participation} =
78 Participation.create_for_user_and_conversation(
80 participation.conversation
83 refute participation.read
86 test "it marks a participation as read" do
87 participation = insert(:participation, %{read: false})
88 {:ok, participation} = Participation.mark_as_read(participation)
90 assert participation.read
93 test "it marks a participation as unread" do
94 participation = insert(:participation, %{read: true})
95 {:ok, participation} = Participation.mark_as_unread(participation)
97 refute participation.read
100 test "gets all the participations for a user, ordered by updated at descending" do
102 {:ok, activity_one} = CommonAPI.post(user, %{"status" => "x", "visibility" => "direct"})
104 {:ok, activity_two} = CommonAPI.post(user, %{"status" => "x", "visibility" => "direct"})
107 {:ok, activity_three} =
108 CommonAPI.post(user, %{
110 "visibility" => "direct",
111 "in_reply_to_status_id" => activity_one.id
114 assert [participation_one, participation_two] = Participation.for_user(user)
116 object2 = Pleroma.Object.normalize(activity_two)
117 object3 = Pleroma.Object.normalize(activity_three)
119 user = Repo.get(Pleroma.User, user.id)
121 assert participation_one.conversation.ap_id == object3.data["context"]
122 assert participation_two.conversation.ap_id == object2.data["context"]
123 assert participation_one.conversation.users == [user]
126 assert [participation_one] = Participation.for_user(user, %{"limit" => 1})
128 assert participation_one.conversation.ap_id == object3.data["context"]
130 # With last_activity_id
131 assert [participation_one] =
132 Participation.for_user_with_last_activity_id(user, %{"limit" => 1})
134 assert participation_one.last_activity_id == activity_three.id
137 test "Doesn't die when the conversation gets empty" do
140 {:ok, activity} = CommonAPI.post(user, %{"status" => ".", "visibility" => "direct"})
141 [participation] = Participation.for_user_with_last_activity_id(user)
143 assert participation.last_activity_id == activity.id
145 {:ok, _} = CommonAPI.delete(activity.id, user)
147 [] = Participation.for_user_with_last_activity_id(user)
150 test "it sets recipients, always keeping the owner of the participation even when not explicitly set" do
152 other_user = insert(:user)
154 {:ok, _activity} = CommonAPI.post(user, %{"status" => ".", "visibility" => "direct"})
155 [participation] = Participation.for_user_with_last_activity_id(user)
157 participation = Repo.preload(participation, :recipients)
159 assert participation.recipients |> length() == 1
160 assert user in participation.recipients
162 {:ok, participation} = Participation.set_recipients(participation, [other_user.id])
164 assert participation.recipients |> length() == 2
165 assert user in participation.recipients
166 assert other_user in participation.recipients