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 creates a conversation for given ap_id" do
13 assert {:ok, %Conversation{} = conversation} =
14 Conversation.create_for_ap_id("https://some_ap_id")
16 # Inserting again returns the same
17 assert {:ok, conversation_two} = Conversation.create_for_ap_id("https://some_ap_id")
18 assert conversation_two.id == conversation.id
21 test "public posts don't create conversations" do
23 {:ok, activity} = CommonAPI.post(user, %{"status" => "Hey"})
25 object = Pleroma.Object.normalize(activity)
26 context = object.data["context"]
28 conversation = Conversation.get_for_ap_id(context)
33 test "it creates or updates a conversation and participations for a given DM" do
35 jafnhar = insert(:user, local: false)
39 CommonAPI.post(har, %{"status" => "Hey @#{jafnhar.nickname}", "visibility" => "direct"})
41 object = Pleroma.Object.normalize(activity)
42 context = object.data["context"]
45 Conversation.get_for_ap_id(context)
46 |> Repo.preload(:participations)
50 assert Enum.find(conversation.participations, fn %{user_id: user_id} -> har.id == user_id end)
52 assert Enum.find(conversation.participations, fn %{user_id: user_id} ->
57 CommonAPI.post(jafnhar, %{
58 "status" => "Hey @#{har.nickname}",
59 "visibility" => "direct",
60 "in_reply_to_status_id" => activity.id
63 object = Pleroma.Object.normalize(activity)
64 context = object.data["context"]
67 Conversation.get_for_ap_id(context)
68 |> Repo.preload(:participations)
70 assert conversation_two.id == conversation.id
72 assert Enum.find(conversation_two.participations, fn %{user_id: user_id} ->
76 assert Enum.find(conversation_two.participations, fn %{user_id: user_id} ->
81 CommonAPI.post(tridi, %{
82 "status" => "Hey @#{har.nickname}",
83 "visibility" => "direct",
84 "in_reply_to_status_id" => activity.id
87 object = Pleroma.Object.normalize(activity)
88 context = object.data["context"]
91 Conversation.get_for_ap_id(context)
92 |> Repo.preload([:participations, :users])
94 assert conversation_three.id == conversation.id
96 assert Enum.find(conversation_three.participations, fn %{user_id: user_id} ->
100 assert Enum.find(conversation_three.participations, fn %{user_id: user_id} ->
101 jafnhar.id == user_id
104 assert Enum.find(conversation_three.participations, fn %{user_id: user_id} ->
108 assert Enum.find(conversation_three.users, fn %{id: user_id} ->
112 assert Enum.find(conversation_three.users, fn %{id: user_id} ->
113 jafnhar.id == user_id
116 assert Enum.find(conversation_three.users, fn %{id: user_id} ->
121 test "create_or_bump_for returns the conversation with participations" do
123 jafnhar = insert(:user, local: false)
126 CommonAPI.post(har, %{"status" => "Hey @#{jafnhar.nickname}", "visibility" => "direct"})
128 {:ok, conversation} = Conversation.create_or_bump_for(activity)
130 assert length(conversation.participations) == 2
133 CommonAPI.post(har, %{"status" => "Hey @#{jafnhar.nickname}", "visibility" => "public"})
135 assert {:error, _} = Conversation.create_or_bump_for(activity)