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.ConversationTest do
8 alias Pleroma.Conversation
10 alias Pleroma.Web.CommonAPI
12 import Pleroma.Factory
15 config_path = [:instance, :federating]
16 initial_setting = Pleroma.Config.get(config_path)
18 Pleroma.Config.put(config_path, true)
19 on_exit(fn -> Pleroma.Config.put(config_path, initial_setting) end)
24 test "it goes through old direct conversations" do
26 other_user = insert(:user)
29 CommonAPI.post(user, %{"visibility" => "direct", "status" => "hey @#{other_user.nickname}"})
31 Pleroma.Tests.ObanHelpers.perform_all()
33 Repo.delete_all(Conversation)
34 Repo.delete_all(Conversation.Participation)
36 refute Repo.one(Conversation)
38 Conversation.bump_for_all_activities()
40 assert Repo.one(Conversation)
41 [participation, _p2] = Repo.all(Conversation.Participation)
43 assert participation.read
46 test "it creates a conversation for given ap_id" do
47 assert {:ok, %Conversation{} = conversation} =
48 Conversation.create_for_ap_id("https://some_ap_id")
50 # Inserting again returns the same
51 assert {:ok, conversation_two} = Conversation.create_for_ap_id("https://some_ap_id")
52 assert conversation_two.id == conversation.id
55 test "public posts don't create conversations" do
57 {:ok, activity} = CommonAPI.post(user, %{"status" => "Hey"})
59 object = Pleroma.Object.normalize(activity)
60 context = object.data["context"]
62 conversation = Conversation.get_for_ap_id(context)
67 test "it creates or updates a conversation and participations for a given DM" do
69 jafnhar = insert(:user, local: false)
73 CommonAPI.post(har, %{"status" => "Hey @#{jafnhar.nickname}", "visibility" => "direct"})
75 object = Pleroma.Object.normalize(activity)
76 context = object.data["context"]
79 Conversation.get_for_ap_id(context)
80 |> Repo.preload(:participations)
84 assert Enum.find(conversation.participations, fn %{user_id: user_id} -> har.id == user_id end)
86 assert Enum.find(conversation.participations, fn %{user_id: user_id} ->
91 CommonAPI.post(jafnhar, %{
92 "status" => "Hey @#{har.nickname}",
93 "visibility" => "direct",
94 "in_reply_to_status_id" => activity.id
97 object = Pleroma.Object.normalize(activity)
98 context = object.data["context"]
101 Conversation.get_for_ap_id(context)
102 |> Repo.preload(:participations)
104 assert conversation_two.id == conversation.id
106 assert Enum.find(conversation_two.participations, fn %{user_id: user_id} ->
110 assert Enum.find(conversation_two.participations, fn %{user_id: user_id} ->
111 jafnhar.id == user_id
115 CommonAPI.post(tridi, %{
116 "status" => "Hey @#{har.nickname}",
117 "visibility" => "direct",
118 "in_reply_to_status_id" => activity.id
121 object = Pleroma.Object.normalize(activity)
122 context = object.data["context"]
125 Conversation.get_for_ap_id(context)
126 |> Repo.preload([:participations, :users])
128 assert conversation_three.id == conversation.id
130 assert Enum.find(conversation_three.participations, fn %{user_id: user_id} ->
134 assert Enum.find(conversation_three.participations, fn %{user_id: user_id} ->
135 jafnhar.id == user_id
138 assert Enum.find(conversation_three.participations, fn %{user_id: user_id} ->
142 assert Enum.find(conversation_three.users, fn %{id: user_id} ->
146 assert Enum.find(conversation_three.users, fn %{id: user_id} ->
147 jafnhar.id == user_id
150 assert Enum.find(conversation_three.users, fn %{id: user_id} ->
155 test "create_or_bump_for returns the conversation with participations" do
157 jafnhar = insert(:user, local: false)
160 CommonAPI.post(har, %{"status" => "Hey @#{jafnhar.nickname}", "visibility" => "direct"})
162 {:ok, conversation} = Conversation.create_or_bump_for(activity)
164 assert length(conversation.participations) == 2
167 CommonAPI.post(har, %{"status" => "Hey @#{jafnhar.nickname}", "visibility" => "public"})
169 assert {:error, _} = Conversation.create_or_bump_for(activity)
172 test "create_or_bump_for does not normalize objects before checking the activity type" do
174 note_id = note.data["id"]
176 refute Object.get_by_ap_id(note_id)
178 Tesla.Mock.mock(fn env ->
181 # TODO: add attributedTo and tag to the note factory
184 |> Map.put("attributedTo", note.data["actor"])
185 |> Map.put("tag", [])
188 %Tesla.Env{status: 200, body: body}
195 "id" => Pleroma.Web.ActivityPub.Utils.generate_activity_id(),
196 "actor" => note.data["actor"],
197 "to" => [note.data["actor"]],
203 Conversation.create_or_bump_for(undo)
205 refute Object.get_by_ap_id(note_id)