aboutsummaryrefslogtreecommitdiff
path: root/test/conversation_test.exs
diff options
context:
space:
mode:
authorrinpatch <rinpatch@sdf.org>2020-11-12 12:34:48 +0000
committerrinpatch <rinpatch@sdf.org>2020-11-12 12:34:48 +0000
commit1172844ed18d94d84724dc6f11c6e9f72e0ba6ec (patch)
tree7d48a259e08856ab6db0eba255f20c0c19410463 /test/conversation_test.exs
parenta0f5e8b27edbe2224d9c2c3997ad5b8ea484244b (diff)
parentb4c6b262d6dc12362f0014a864e8aed6c727c39c (diff)
downloadpleroma-2.2.0.tar.gz
Merge branch 'release/2.2.0' into 'stable'v2.2.0
Release/2.2.0 See merge request pleroma/secteam/pleroma!19
Diffstat (limited to 'test/conversation_test.exs')
-rw-r--r--test/conversation_test.exs199
1 files changed, 0 insertions, 199 deletions
diff --git a/test/conversation_test.exs b/test/conversation_test.exs
deleted file mode 100644
index 359aa6840..000000000
--- a/test/conversation_test.exs
+++ /dev/null
@@ -1,199 +0,0 @@
-# Pleroma: A lightweight social networking server
-# Copyright © 2017-2020 Pleroma Authors <https://pleroma.social/>
-# SPDX-License-Identifier: AGPL-3.0-only
-
-defmodule Pleroma.ConversationTest do
- use Pleroma.DataCase
- alias Pleroma.Activity
- alias Pleroma.Conversation
- alias Pleroma.Object
- alias Pleroma.Web.CommonAPI
-
- import Pleroma.Factory
-
- setup_all do: clear_config([:instance, :federating], true)
-
- test "it goes through old direct conversations" do
- user = insert(:user)
- other_user = insert(:user)
-
- {:ok, _activity} =
- CommonAPI.post(user, %{visibility: "direct", status: "hey @#{other_user.nickname}"})
-
- Pleroma.Tests.ObanHelpers.perform_all()
-
- Repo.delete_all(Conversation)
- Repo.delete_all(Conversation.Participation)
-
- refute Repo.one(Conversation)
-
- Conversation.bump_for_all_activities()
-
- assert Repo.one(Conversation)
- [participation, _p2] = Repo.all(Conversation.Participation)
-
- assert participation.read
- end
-
- test "it creates a conversation for given ap_id" do
- assert {:ok, %Conversation{} = conversation} =
- Conversation.create_for_ap_id("https://some_ap_id")
-
- # Inserting again returns the same
- assert {:ok, conversation_two} = Conversation.create_for_ap_id("https://some_ap_id")
- assert conversation_two.id == conversation.id
- end
-
- test "public posts don't create conversations" do
- user = insert(:user)
- {:ok, activity} = CommonAPI.post(user, %{status: "Hey"})
-
- object = Pleroma.Object.normalize(activity)
- context = object.data["context"]
-
- conversation = Conversation.get_for_ap_id(context)
-
- refute conversation
- end
-
- test "it creates or updates a conversation and participations for a given DM" do
- har = insert(:user)
- jafnhar = insert(:user, local: false)
- tridi = insert(:user)
-
- {:ok, activity} =
- CommonAPI.post(har, %{status: "Hey @#{jafnhar.nickname}", visibility: "direct"})
-
- object = Pleroma.Object.normalize(activity)
- context = object.data["context"]
-
- conversation =
- Conversation.get_for_ap_id(context)
- |> Repo.preload(:participations)
-
- assert conversation
-
- assert Enum.find(conversation.participations, fn %{user_id: user_id} -> har.id == user_id end)
-
- assert Enum.find(conversation.participations, fn %{user_id: user_id} ->
- jafnhar.id == user_id
- end)
-
- {:ok, activity} =
- CommonAPI.post(jafnhar, %{
- status: "Hey @#{har.nickname}",
- visibility: "direct",
- in_reply_to_status_id: activity.id
- })
-
- object = Pleroma.Object.normalize(activity)
- context = object.data["context"]
-
- conversation_two =
- Conversation.get_for_ap_id(context)
- |> Repo.preload(:participations)
-
- assert conversation_two.id == conversation.id
-
- assert Enum.find(conversation_two.participations, fn %{user_id: user_id} ->
- har.id == user_id
- end)
-
- assert Enum.find(conversation_two.participations, fn %{user_id: user_id} ->
- jafnhar.id == user_id
- end)
-
- {:ok, activity} =
- CommonAPI.post(tridi, %{
- status: "Hey @#{har.nickname}",
- visibility: "direct",
- in_reply_to_status_id: activity.id
- })
-
- object = Pleroma.Object.normalize(activity)
- context = object.data["context"]
-
- conversation_three =
- Conversation.get_for_ap_id(context)
- |> Repo.preload([:participations, :users])
-
- assert conversation_three.id == conversation.id
-
- assert Enum.find(conversation_three.participations, fn %{user_id: user_id} ->
- har.id == user_id
- end)
-
- assert Enum.find(conversation_three.participations, fn %{user_id: user_id} ->
- jafnhar.id == user_id
- end)
-
- assert Enum.find(conversation_three.participations, fn %{user_id: user_id} ->
- tridi.id == user_id
- end)
-
- assert Enum.find(conversation_three.users, fn %{id: user_id} ->
- har.id == user_id
- end)
-
- assert Enum.find(conversation_three.users, fn %{id: user_id} ->
- jafnhar.id == user_id
- end)
-
- assert Enum.find(conversation_three.users, fn %{id: user_id} ->
- tridi.id == user_id
- end)
- end
-
- test "create_or_bump_for returns the conversation with participations" do
- har = insert(:user)
- jafnhar = insert(:user, local: false)
-
- {:ok, activity} =
- CommonAPI.post(har, %{status: "Hey @#{jafnhar.nickname}", visibility: "direct"})
-
- {:ok, conversation} = Conversation.create_or_bump_for(activity)
-
- assert length(conversation.participations) == 2
-
- {:ok, activity} =
- CommonAPI.post(har, %{status: "Hey @#{jafnhar.nickname}", visibility: "public"})
-
- assert {:error, _} = Conversation.create_or_bump_for(activity)
- end
-
- test "create_or_bump_for does not normalize objects before checking the activity type" do
- note = insert(:note)
- note_id = note.data["id"]
- Repo.delete(note)
- refute Object.get_by_ap_id(note_id)
-
- Tesla.Mock.mock(fn env ->
- case env.url do
- ^note_id ->
- # TODO: add attributedTo and tag to the note factory
- body =
- note.data
- |> Map.put("attributedTo", note.data["actor"])
- |> Map.put("tag", [])
- |> Jason.encode!()
-
- %Tesla.Env{status: 200, body: body}
- end
- end)
-
- undo = %Activity{
- id: "fake",
- data: %{
- "id" => Pleroma.Web.ActivityPub.Utils.generate_activity_id(),
- "actor" => note.data["actor"],
- "to" => [note.data["actor"]],
- "object" => note_id,
- "type" => "Undo"
- }
- }
-
- Conversation.create_or_bump_for(undo)
-
- refute Object.get_by_ap_id(note_id)
- end
-end