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 Repo.delete_all(Conversation)
32 Repo.delete_all(Conversation.Participation)
34 refute Repo.one(Conversation)
36 Conversation.bump_for_all_activities()
38 assert Repo.one(Conversation)
39 [participation, _p2] = Repo.all(Conversation.Participation)
41 assert participation.read
44 test "it creates a conversation for given ap_id" do
45 assert {:ok, %Conversation{} = conversation} =
46 Conversation.create_for_ap_id("https://some_ap_id")
48 # Inserting again returns the same
49 assert {:ok, conversation_two} = Conversation.create_for_ap_id("https://some_ap_id")
50 assert conversation_two.id == conversation.id
53 test "public posts don't create conversations" do
55 {:ok, activity} = CommonAPI.post(user, %{"status" => "Hey"})
57 object = Pleroma.Object.normalize(activity)
58 context = object.data["context"]
60 conversation = Conversation.get_for_ap_id(context)
65 test "it creates or updates a conversation and participations for a given DM" do
67 jafnhar = insert(:user, local: false)
71 CommonAPI.post(har, %{"status" => "Hey @#{jafnhar.nickname}", "visibility" => "direct"})
73 object = Pleroma.Object.normalize(activity)
74 context = object.data["context"]
77 Conversation.get_for_ap_id(context)
78 |> Repo.preload(:participations)
82 assert Enum.find(conversation.participations, fn %{user_id: user_id} -> har.id == user_id end)
84 assert Enum.find(conversation.participations, fn %{user_id: user_id} ->
89 CommonAPI.post(jafnhar, %{
90 "status" => "Hey @#{har.nickname}",
91 "visibility" => "direct",
92 "in_reply_to_status_id" => activity.id
95 object = Pleroma.Object.normalize(activity)
96 context = object.data["context"]
99 Conversation.get_for_ap_id(context)
100 |> Repo.preload(:participations)
102 assert conversation_two.id == conversation.id
104 assert Enum.find(conversation_two.participations, fn %{user_id: user_id} ->
108 assert Enum.find(conversation_two.participations, fn %{user_id: user_id} ->
109 jafnhar.id == user_id
113 CommonAPI.post(tridi, %{
114 "status" => "Hey @#{har.nickname}",
115 "visibility" => "direct",
116 "in_reply_to_status_id" => activity.id
119 object = Pleroma.Object.normalize(activity)
120 context = object.data["context"]
123 Conversation.get_for_ap_id(context)
124 |> Repo.preload([:participations, :users])
126 assert conversation_three.id == conversation.id
128 assert Enum.find(conversation_three.participations, fn %{user_id: user_id} ->
132 assert Enum.find(conversation_three.participations, fn %{user_id: user_id} ->
133 jafnhar.id == user_id
136 assert Enum.find(conversation_three.participations, fn %{user_id: user_id} ->
140 assert Enum.find(conversation_three.users, fn %{id: user_id} ->
144 assert Enum.find(conversation_three.users, fn %{id: user_id} ->
145 jafnhar.id == user_id
148 assert Enum.find(conversation_three.users, fn %{id: user_id} ->
153 test "create_or_bump_for returns the conversation with participations" do
155 jafnhar = insert(:user, local: false)
158 CommonAPI.post(har, %{"status" => "Hey @#{jafnhar.nickname}", "visibility" => "direct"})
160 {:ok, conversation} = Conversation.create_or_bump_for(activity)
162 assert length(conversation.participations) == 2
165 CommonAPI.post(har, %{"status" => "Hey @#{jafnhar.nickname}", "visibility" => "public"})
167 assert {:error, _} = Conversation.create_or_bump_for(activity)
170 test "create_or_bump_for does not normalize objects before checking the activity type" do
172 note_id = note.data["id"]
174 refute Object.get_by_ap_id(note_id)
176 Tesla.Mock.mock(fn env ->
179 # TODO: add attributedTo and tag to the note factory
182 |> Map.put("attributedTo", note.data["actor"])
183 |> Map.put("tag", [])
186 %Tesla.Env{status: 200, body: body}
193 "id" => Pleroma.Web.ActivityPub.Utils.generate_activity_id(),
194 "actor" => note.data["actor"],
195 "to" => [note.data["actor"]],
201 Conversation.create_or_bump_for(undo)
203 refute Object.get_by_ap_id(note_id)