git.squeep.com Git - akkoma/blob - test/web/activity_pub/transmogrifier/chat_message_test.exs

   1 # Pleroma: A lightweight social networking server
   2 # Copyright © 2017-2020 Pleroma Authors <https://pleroma.social/>
   3 # SPDX-License-Identifier: AGPL-3.0-only
   4
   5 defmodule Pleroma.Web.ActivityPub.Transmogrifier.ChatMessageTest do
   6   use Pleroma.DataCase
   7
   8   import Pleroma.Factory
   9
  10   alias Pleroma.Activity
  11   alias Pleroma.Chat
  12   alias Pleroma.Object
  13   alias Pleroma.Web.ActivityPub.Transmogrifier
  14
  15   describe "handle_incoming" do
  16     test "it rejects messages that don't contain content" do
  17       data =
  18         File.read!("test/fixtures/create-chat-message.json")
  19         |> Poison.decode!()
  20
  21       object =
  22         data["object"]
  23         |> Map.delete("content")
  24
  25       data =
  26         data
  27         |> Map.put("object", object)
  28
  29       _author =
  30         insert(:user, ap_id: data["actor"], local: false, last_refreshed_at: DateTime.utc_now())
  31
  32       _recipient =
  33         insert(:user,
  34           ap_id: List.first(data["to"]),
  35           local: true,
  36           last_refreshed_at: DateTime.utc_now()
  37         )
  38
  39       {:error, _} = Transmogrifier.handle_incoming(data)
  40     end
  41
  42     test "it rejects messages that don't concern local users" do
  43       data =
  44         File.read!("test/fixtures/create-chat-message.json")
  45         |> Poison.decode!()
  46
  47       _author =
  48         insert(:user, ap_id: data["actor"], local: false, last_refreshed_at: DateTime.utc_now())
  49
  50       _recipient =
  51         insert(:user,
  52           ap_id: List.first(data["to"]),
  53           local: false,
  54           last_refreshed_at: DateTime.utc_now()
  55         )
  56
  57       {:error, _} = Transmogrifier.handle_incoming(data)
  58     end
  59
  60     test "it rejects messages where the `to` field of activity and object don't match" do
  61       data =
  62         File.read!("test/fixtures/create-chat-message.json")
  63         |> Poison.decode!()
  64
  65       author = insert(:user, ap_id: data["actor"])
  66       _recipient = insert(:user, ap_id: List.first(data["to"]))
  67
  68       data =
  69         data
  70         |> Map.put("to", author.ap_id)
  71
  72       assert match?({:error, _}, Transmogrifier.handle_incoming(data))
  73       refute Object.get_by_ap_id(data["object"]["id"])
  74     end
  75
  76     test "it fetches the actor if they aren't in our system" do
  77       Tesla.Mock.mock(fn env -> apply(HttpRequestMock, :request, [env]) end)
  78
  79       data =
  80         File.read!("test/fixtures/create-chat-message.json")
  81         |> Poison.decode!()
  82         |> Map.put("actor", "http://mastodon.example.org/users/admin")
  83         |> put_in(["object", "actor"], "http://mastodon.example.org/users/admin")
  84
  85       _recipient = insert(:user, ap_id: List.first(data["to"]), local: true)
  86
  87       {:ok, %Activity{} = _activity} = Transmogrifier.handle_incoming(data)
  88     end
  89
  90     test "it inserts it and creates a chat" do
  91       data =
  92         File.read!("test/fixtures/create-chat-message.json")
  93         |> Poison.decode!()
  94
  95       author =
  96         insert(:user, ap_id: data["actor"], local: false, last_refreshed_at: DateTime.utc_now())
  97
  98       recipient = insert(:user, ap_id: List.first(data["to"]), local: true)
  99
 100       {:ok, %Activity{} = activity} = Transmogrifier.handle_incoming(data)
 101       assert activity.local == false
 102
 103       assert activity.actor == author.ap_id
 104       assert activity.recipients == [recipient.ap_id, author.ap_id]
 105
 106       %Object{} = object = Object.get_by_ap_id(activity.data["object"])
 107
 108       assert object
 109       assert object.data["content"] == "You expected a cute girl? Too bad. alert(&#39;XSS&#39;)"
 110       assert match?(%{"firefox" => _}, object.data["emoji"])
 111
 112       refute Chat.get(author.id, recipient.ap_id)
 113       assert Chat.get(recipient.id, author.ap_id)
 114     end
 115   end
 116 end