git.squeep.com Git - akkoma/blob - test/conversation_test.exs

   1 # Pleroma: A lightweight social networking server
   2 # Copyright © 2017-2019 Pleroma Authors <https://pleroma.social/>
   3 # SPDX-License-Identifier: AGPL-3.0-only
   4
   5 defmodule Pleroma.ConversationTest do
   6   use Pleroma.DataCase
   7   alias Pleroma.Conversation
   8   alias Pleroma.Web.CommonAPI
   9
  10   import Pleroma.Factory
  11
  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")
  15
  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
  19   end
  20
  21   test "public posts don't create conversations" do
  22     user = insert(:user)
  23     {:ok, activity} = CommonAPI.post(user, %{"status" => "Hey"})
  24
  25     object = Pleroma.Object.normalize(activity)
  26     context = object.data["context"]
  27
  28     conversation = Conversation.get_for_ap_id(context)
  29
  30     refute conversation
  31   end
  32
  33   test "it creates or updates a conversation and participations for a given DM" do
  34     har = insert(:user)
  35     jafnhar = insert(:user, local: false)
  36     tridi = insert(:user)
  37
  38     {:ok, activity} =
  39       CommonAPI.post(har, %{"status" => "Hey @#{jafnhar.nickname}", "visibility" => "direct"})
  40
  41     object = Pleroma.Object.normalize(activity)
  42     context = object.data["context"]
  43
  44     conversation =
  45       Conversation.get_for_ap_id(context)
  46       |> Repo.preload(:participations)
  47
  48     assert conversation
  49
  50     assert Enum.find(conversation.participations, fn %{user_id: user_id} -> har.id == user_id end)
  51
  52     assert Enum.find(conversation.participations, fn %{user_id: user_id} ->
  53              jafnhar.id == user_id
  54            end)
  55
  56     {:ok, activity} =
  57       CommonAPI.post(jafnhar, %{
  58         "status" => "Hey @#{har.nickname}",
  59         "visibility" => "direct",
  60         "in_reply_to_status_id" => activity.id
  61       })
  62
  63     object = Pleroma.Object.normalize(activity)
  64     context = object.data["context"]
  65
  66     conversation_two =
  67       Conversation.get_for_ap_id(context)
  68       |> Repo.preload(:participations)
  69
  70     assert conversation_two.id == conversation.id
  71
  72     assert Enum.find(conversation_two.participations, fn %{user_id: user_id} ->
  73              har.id == user_id
  74            end)
  75
  76     assert Enum.find(conversation_two.participations, fn %{user_id: user_id} ->
  77              jafnhar.id == user_id
  78            end)
  79
  80     {:ok, activity} =
  81       CommonAPI.post(tridi, %{
  82         "status" => "Hey @#{har.nickname}",
  83         "visibility" => "direct",
  84         "in_reply_to_status_id" => activity.id
  85       })
  86
  87     object = Pleroma.Object.normalize(activity)
  88     context = object.data["context"]
  89
  90     conversation_three =
  91       Conversation.get_for_ap_id(context)
  92       |> Repo.preload([:participations, :users])
  93
  94     assert conversation_three.id == conversation.id
  95
  96     assert Enum.find(conversation_three.participations, fn %{user_id: user_id} ->
  97              har.id == user_id
  98            end)
  99
 100     assert Enum.find(conversation_three.participations, fn %{user_id: user_id} ->
 101              jafnhar.id == user_id
 102            end)
 103
 104     assert Enum.find(conversation_three.participations, fn %{user_id: user_id} ->
 105              tridi.id == user_id
 106            end)
 107
 108     assert Enum.find(conversation_three.users, fn %{id: user_id} ->
 109              har.id == user_id
 110            end)
 111
 112     assert Enum.find(conversation_three.users, fn %{id: user_id} ->
 113              jafnhar.id == user_id
 114            end)
 115
 116     assert Enum.find(conversation_three.users, fn %{id: user_id} ->
 117              tridi.id == user_id
 118            end)
 119   end
 120
 121   test "create_or_bump_for returns the conversation with participations" do
 122     har = insert(:user)
 123     jafnhar = insert(:user, local: false)
 124
 125     {:ok, activity} =
 126       CommonAPI.post(har, %{"status" => "Hey @#{jafnhar.nickname}", "visibility" => "direct"})
 127
 128     {:ok, conversation} = Conversation.create_or_bump_for(activity)
 129
 130     assert length(conversation.participations) == 2
 131
 132     {:ok, activity} =
 133       CommonAPI.post(har, %{"status" => "Hey @#{jafnhar.nickname}", "visibility" => "public"})
 134
 135     assert {:error, _} = Conversation.create_or_bump_for(activity)
 136   end
 137 end