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
7 alias Pleroma.Conversation
8 alias Pleroma.Web.CommonAPI
10 import Pleroma.Factory
12 test "it goes through old direct conversations" do
14 other_user = insert(:user)
17 CommonAPI.post(user, %{"visibility" => "direct", "status" => "hey @#{other_user.nickname}"})
19 Repo.delete_all(Conversation)
20 Repo.delete_all(Conversation.Participation)
22 refute Repo.one(Conversation)
24 Conversation.bump_for_all_activities()
26 assert Repo.one(Conversation)
27 [participation, _p2] = Repo.all(Conversation.Participation)
29 assert participation.read
32 test "it creates a conversation for given ap_id" do
33 assert {:ok, %Conversation{} = conversation} =
34 Conversation.create_for_ap_id("https://some_ap_id")
36 # Inserting again returns the same
37 assert {:ok, conversation_two} = Conversation.create_for_ap_id("https://some_ap_id")
38 assert conversation_two.id == conversation.id
41 test "public posts don't create conversations" do
43 {:ok, activity} = CommonAPI.post(user, %{"status" => "Hey"})
45 object = Pleroma.Object.normalize(activity)
46 context = object.data["context"]
48 conversation = Conversation.get_for_ap_id(context)
53 test "it creates or updates a conversation and participations for a given DM" do
55 jafnhar = insert(:user, local: false)
59 CommonAPI.post(har, %{"status" => "Hey @#{jafnhar.nickname}", "visibility" => "direct"})
61 object = Pleroma.Object.normalize(activity)
62 context = object.data["context"]
65 Conversation.get_for_ap_id(context)
66 |> Repo.preload(:participations)
70 assert Enum.find(conversation.participations, fn %{user_id: user_id} -> har.id == user_id end)
72 assert Enum.find(conversation.participations, fn %{user_id: user_id} ->
77 CommonAPI.post(jafnhar, %{
78 "status" => "Hey @#{har.nickname}",
79 "visibility" => "direct",
80 "in_reply_to_status_id" => activity.id
83 object = Pleroma.Object.normalize(activity)
84 context = object.data["context"]
87 Conversation.get_for_ap_id(context)
88 |> Repo.preload(:participations)
90 assert conversation_two.id == conversation.id
92 assert Enum.find(conversation_two.participations, fn %{user_id: user_id} ->
96 assert Enum.find(conversation_two.participations, fn %{user_id: user_id} ->
101 CommonAPI.post(tridi, %{
102 "status" => "Hey @#{har.nickname}",
103 "visibility" => "direct",
104 "in_reply_to_status_id" => activity.id
107 object = Pleroma.Object.normalize(activity)
108 context = object.data["context"]
111 Conversation.get_for_ap_id(context)
112 |> Repo.preload([:participations, :users])
114 assert conversation_three.id == conversation.id
116 assert Enum.find(conversation_three.participations, fn %{user_id: user_id} ->
120 assert Enum.find(conversation_three.participations, fn %{user_id: user_id} ->
121 jafnhar.id == user_id
124 assert Enum.find(conversation_three.participations, fn %{user_id: user_id} ->
128 assert Enum.find(conversation_three.users, fn %{id: user_id} ->
132 assert Enum.find(conversation_three.users, fn %{id: user_id} ->
133 jafnhar.id == user_id
136 assert Enum.find(conversation_three.users, fn %{id: user_id} ->
141 test "create_or_bump_for returns the conversation with participations" do
143 jafnhar = insert(:user, local: false)
146 CommonAPI.post(har, %{"status" => "Hey @#{jafnhar.nickname}", "visibility" => "direct"})
148 {:ok, conversation} = Conversation.create_or_bump_for(activity)
150 assert length(conversation.participations) == 2
153 CommonAPI.post(har, %{"status" => "Hey @#{jafnhar.nickname}", "visibility" => "public"})
155 assert {:error, _} = Conversation.create_or_bump_for(activity)