No OneTemporary
Actions

Authored By

Unknown

Size

82 KB

Referenced Files

None

Subscribers

None

View Options

	diff --git a/lib/pleroma/web/activity_pub/object_validators/create_generic_validator.ex b/lib/pleroma/web/activity_pub/object_validators/create_generic_validator.ex
	index c9a621cb1..2395abfd4 100644
	--- a/lib/pleroma/web/activity_pub/object_validators/create_generic_validator.ex
	+++ b/lib/pleroma/web/activity_pub/object_validators/create_generic_validator.ex
	@@ -1,161 +1,161 @@
	# Pleroma: A lightweight social networking server
	# Copyright © 2017-2022 Pleroma Authors <https://pleroma.social/>
	# SPDX-License-Identifier: AGPL-3.0-only

	# Code based on CreateChatMessageValidator
	# NOTES
	# - doesn't embed, will only get the object id
	defmodule Pleroma.Web.ActivityPub.ObjectValidators.CreateGenericValidator do
	use Ecto.Schema

	alias Pleroma.EctoType.ActivityPub.ObjectValidators
	alias Pleroma.Object
	alias Pleroma.User
	alias Pleroma.Web.ActivityPub.ObjectValidators.CommonFixes
	alias Pleroma.Web.ActivityPub.ObjectValidators.CommonValidations
	alias Pleroma.Web.ActivityPub.Transmogrifier

	import Ecto.Changeset

	@primary_key false

	embedded_schema do
	quote do
	unquote do
	import Elixir.Pleroma.Web.ActivityPub.ObjectValidators.CommonFields
	message_fields()
	activity_fields()
	end
	end

	field(:expires_at, ObjectValidators.DateTime)

	# Should be moved to object, done for CommonAPI.Utils.make_context
	field(:context, :string)
	end

	def cast_data(data, meta \\ []) do
	data = fix(data, meta)

	%__MODULE__{}
	\|> changeset(data)
	end

	def cast_and_apply(data) do
	data
	\|> cast_data
	\|> apply_action(:insert)
	end

	def cast_and_validate(data, meta \\ []) do
	data
	\|> cast_data(meta)
	\|> validate_data(meta)
	end

	def changeset(struct, data) do
	struct
	\|> cast(data, __schema__(:fields))
	end

	# CommonFixes.fix_activity_addressing adapted for Create specific behavior
	defp fix_addressing(data, object) do
	%User{follower_address: follower_collection} = User.get_cached_by_ap_id(data["actor"])

	data
	\|> CommonFixes.cast_and_filter_recipients("to", follower_collection, object["to"])
	\|> CommonFixes.cast_and_filter_recipients("cc", follower_collection, object["cc"])
	\|> CommonFixes.cast_and_filter_recipients("bto", follower_collection, object["bto"])
	\|> CommonFixes.cast_and_filter_recipients("bcc", follower_collection, object["bcc"])
	\|> Transmogrifier.fix_implicit_addressing(follower_collection)
	end

	def fix(data, meta) do
	object = meta[:object_data]

	data
	\|> CommonFixes.fix_actor()
	- \|> Map.put_new("context", object["context"])
	+ \|> Map.put("context", object["context"])
	\|> fix_addressing(object)
	end

	defp validate_data(cng, meta) do
	object = meta[:object_data]

	cng
	\|> validate_required([:actor, :type, :object, :to, :cc])
	\|> validate_inclusion(:type, ["Create"])
	\|> CommonValidations.validate_actor_presence()
	\|> validate_actors_match(object)
	\|> validate_context_match(object)
	\|> validate_addressing_match(object)
	\|> validate_object_nonexistence()
	\|> validate_object_containment()
	end

	def validate_object_containment(cng) do
	actor = get_field(cng, :actor)

	cng
	\|> validate_change(:object, fn :object, object_id ->
	%URI{host: object_id_host} = URI.parse(object_id)
	%URI{host: actor_host} = URI.parse(actor)

	if object_id_host == actor_host do
	[]
	else
	[{:object, "The host of the object id doesn't match with the host of the actor"}]
	end
	end)
	end

	def validate_object_nonexistence(cng) do
	cng
	\|> validate_change(:object, fn :object, object_id ->
	if Object.get_cached_by_ap_id(object_id) do
	[{:object, "The object to create already exists"}]
	else
	[]
	end
	end)
	end

	def validate_actors_match(cng, object) do
	attributed_to = object["attributedTo"] \|\| object["actor"]

	cng
	\|> validate_change(:actor, fn :actor, actor ->
	if actor == attributed_to do
	[]
	else
	[{:actor, "Actor doesn't match with object attributedTo"}]
	end
	end)
	end

	def validate_context_match(cng, %{"context" => object_context}) do
	cng
	\|> validate_change(:context, fn :context, context ->
	if context == object_context do
	[]
	else
	[{:context, "context field not matching between Create and object (#{object_context})"}]
	end
	end)
	end

	def validate_addressing_match(cng, object) do
	[:to, :cc, :bcc, :bto]
	\|> Enum.reduce(cng, fn field, cng ->
	object_data = object[to_string(field)]

	validate_change(cng, field, fn field, data ->
	if data == object_data do
	[]
	else
	[{field, "field doesn't match with object (#{inspect(object_data)})"}]
	end
	end)
	end)
	end
	end
	diff --git a/test/fixtures/create-pleroma-reply-to-misskey-thread.json b/test/fixtures/create-pleroma-reply-to-misskey-thread.json
	new file mode 100644
	index 000000000..0c31efa76
	--- /dev/null
	+++ b/test/fixtures/create-pleroma-reply-to-misskey-thread.json
	@@ -0,0 +1,61 @@
	+{
	+ "@context": [
	+ "https://www.w3.org/ns/activitystreams",
	+ "https://p.helene.moe/schemas/litepub-0.1.jsonld",
	+ {
	+ "@language": "und"
	+ }
	+ ],
	+ "actor": "https://p.helene.moe/users/helene",
	+ "attachment": [],
	+ "attributedTo": "https://p.helene.moe/users/helene",
	+ "cc": [
	+ "https://p.helene.moe/users/helene/followers"
	+ ],
	+ "context": "https://p.helene.moe/contexts/cc324643-5583-4c3f-91d2-c6ed37db159d",
	+ "conversation": "https://p.helene.moe/contexts/cc324643-5583-4c3f-91d2-c6ed37db159d",
	+ "directMessage": false,
	+ "id": "https://p.helene.moe/activities/5f80db86-a9bb-4883-9845-fbdbd1478f3a",
	+ "object": {
	+ "actor": "https://p.helene.moe/users/helene",
	+ "attachment": [],
	+ "attributedTo": "https://p.helene.moe/users/helene",
	+ "cc": [
	+ "https://p.helene.moe/users/helene/followers"
	+ ],
	+ "content": "<span class=\"h-card\"><a class=\"u-url mention\" data-user=\"AHntpQ4T3J4OSnpgMC\" href=\"https://mk.absturztau.be/@mametsuko\" rel=\"ugc\">@<span>mametsuko</span></a></span> meow",
	+ "context": "https://p.helene.moe/contexts/cc324643-5583-4c3f-91d2-c6ed37db159d",
	+ "conversation": "https://p.helene.moe/contexts/cc324643-5583-4c3f-91d2-c6ed37db159d",
	+ "id": "https://p.helene.moe/objects/fd5910ac-d9dc-412e-8d1d-914b203296c4",
	+ "inReplyTo": "https://mk.absturztau.be/notes/93e7nm8wqg",
	+ "published": "2022-08-02T13:46:58.403996Z",
	+ "sensitive": null,
	+ "source": "@mametsuko@mk.absturztau.be meow",
	+ "summary": "",
	+ "tag": [
	+ {
	+ "href": "https://mk.absturztau.be/users/8ozbzjs3o8",
	+ "name": "@mametsuko@mk.absturztau.be",
	+ "type": "Mention"
	+ }
	+ ],
	+ "to": [
	+ "https://mk.absturztau.be/users/8ozbzjs3o8",
	+ "https://www.w3.org/ns/activitystreams#Public"
	+ ],
	+ "type": "Note"
	+ },
	+ "published": "2022-08-02T13:46:58.403883Z",
	+ "tag": [
	+ {
	+ "href": "https://mk.absturztau.be/users/8ozbzjs3o8",
	+ "name": "@mametsuko@mk.absturztau.be",
	+ "type": "Mention"
	+ }
	+ ],
	+ "to": [
	+ "https://mk.absturztau.be/users/8ozbzjs3o8",
	+ "https://www.w3.org/ns/activitystreams#Public"
	+ ],
	+ "type": "Create"
	+}
	\ No newline at end of file
	diff --git a/test/fixtures/tesla_mock/helene@p.helene.moe.json b/test/fixtures/tesla_mock/helene@p.helene.moe.json
	new file mode 100644
	index 000000000..d7444817f
	--- /dev/null
	+++ b/test/fixtures/tesla_mock/helene@p.helene.moe.json
	@@ -0,0 +1,50 @@
	+{
	+ "@context": [
	+ "https://www.w3.org/ns/activitystreams",
	+ "https://p.helene.moe/schemas/litepub-0.1.jsonld",
	+ {
	+ "@language": "und"
	+ }
	+ ],
	+ "alsoKnownAs": [],
	+ "attachment": [
	+ {
	+ "name": "Timezone",
	+ "type": "PropertyValue",
	+ "value": "UTC+2 (Paris/Berlin)"
	+ }
	+ ],
	+ "capabilities": {
	+ "acceptsChatMessages": true
	+ },
	+ "discoverable": true,
	+ "endpoints": {
	+ "oauthAuthorizationEndpoint": "https://p.helene.moe/oauth/authorize",
	+ "oauthRegistrationEndpoint": "https://p.helene.moe/api/v1/apps",
	+ "oauthTokenEndpoint": "https://p.helene.moe/oauth/token",
	+ "sharedInbox": "https://p.helene.moe/inbox",
	+ "uploadMedia": "https://p.helene.moe/api/ap/upload_media"
	+ },
	+ "featured": "https://p.helene.moe/users/helene/collections/featured",
	+ "followers": "https://p.helene.moe/users/helene/followers",
	+ "following": "https://p.helene.moe/users/helene/following",
	+ "icon": {
	+ "type": "Image",
	+ "url": "https://p.helene.moe/media/9a39209daa5a66b7ebb0547b08bf8360aa9d8d65a4ffba2603c6ffbe6aecb432.jpg"
	+ },
	+ "id": "https://p.helene.moe/users/helene",
	+ "inbox": "https://p.helene.moe/users/helene/inbox",
	+ "manuallyApprovesFollowers": false,
	+ "name": "Hélène",
	+ "outbox": "https://p.helene.moe/users/helene/outbox",
	+ "preferredUsername": "helene",
	+ "publicKey": {
	+ "id": "https://p.helene.moe/users/helene#main-key",
	+ "owner": "https://p.helene.moe/users/helene",
	+ "publicKeyPem": "-----BEGIN PUBLIC KEY-----\nMIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEAtoSBPU/VS2Kx3f6ap3zv\nZVacJsgUfaoFb3c2ii/FRh9RmRVlarq8sJXcjsQt1e0oxWaWJaIDDwyKZPt6hXae\nrY/AiGGeNu+NA+BtY7l7+9Yu67HUyT62+1qAwYHKBXX3fLOPs/YmQI0Tt0c4wKAG\nKEkiYsRizghgpzUC6jqdKV71DJkUZ8yhckCGb2fLko1ajbWEssdaP51aLsyRMyC2\nuzeWrxtD4O/HG0ea4S6y5X6hnsAHIK4Y3nnyIQ6pn4tOsl3HgqkjXE9MmZSvMCFx\nBq89TfZrVXNa2gSZdZLdbbJstzEScQWNt1p6tA6rM+e4JXYGr+rMdF3G+jV7afI2\nFQIDAQAB\n-----END PUBLIC KEY-----\n\n"
	+ },
	+ "summary": "I can speak: Français, English, Deutsch (nicht sehr gut), 日本語 (not very well)",
	+ "tag": [],
	+ "type": "Person",
	+ "url": "https://p.helene.moe/users/helene"
	+}
	\ No newline at end of file
	diff --git a/test/fixtures/tesla_mock/mametsuko@mk.absturztau.be.json b/test/fixtures/tesla_mock/mametsuko@mk.absturztau.be.json
	new file mode 100644
	index 000000000..d8c13f775
	--- /dev/null
	+++ b/test/fixtures/tesla_mock/mametsuko@mk.absturztau.be.json
	@@ -0,0 +1,65 @@
	+{
	+ "@context": [
	+ "https://www.w3.org/ns/activitystreams",
	+ "https://w3id.org/security/v1",
	+ {
	+ "manuallyApprovesFollowers": "as:manuallyApprovesFollowers",
	+ "sensitive": "as:sensitive",
	+ "Hashtag": "as:Hashtag",
	+ "quoteUrl": "as:quoteUrl",
	+ "toot": "http://joinmastodon.org/ns#",
	+ "Emoji": "toot:Emoji",
	+ "featured": "toot:featured",
	+ "discoverable": "toot:discoverable",
	+ "schema": "http://schema.org#",
	+ "PropertyValue": "schema:PropertyValue",
	+ "value": "schema:value",
	+ "misskey": "https://misskey-hub.net/ns#",
	+ "_misskey_content": "misskey:_misskey_content",
	+ "_misskey_quote": "misskey:_misskey_quote",
	+ "_misskey_reaction": "misskey:_misskey_reaction",
	+ "_misskey_votes": "misskey:_misskey_votes",
	+ "_misskey_talk": "misskey:_misskey_talk",
	+ "isCat": "misskey:isCat",
	+ "vcard": "http://www.w3.org/2006/vcard/ns#"
	+ }
	+ ],
	+ "type": "Person",
	+ "id": "https://mk.absturztau.be/users/8ozbzjs3o8",
	+ "inbox": "https://mk.absturztau.be/users/8ozbzjs3o8/inbox",
	+ "outbox": "https://mk.absturztau.be/users/8ozbzjs3o8/outbox",
	+ "followers": "https://mk.absturztau.be/users/8ozbzjs3o8/followers",
	+ "following": "https://mk.absturztau.be/users/8ozbzjs3o8/following",
	+ "featured": "https://mk.absturztau.be/users/8ozbzjs3o8/collections/featured",
	+ "sharedInbox": "https://mk.absturztau.be/inbox",
	+ "endpoints": {
	+ "sharedInbox": "https://mk.absturztau.be/inbox"
	+ },
	+ "url": "https://mk.absturztau.be/@mametsuko",
	+ "preferredUsername": "mametsuko",
	+ "name": "mametschko",
	+ "summary": "<p><span>nya, ich bin eine Brotperson</span></p>",
	+ "icon": {
	+ "type": "Image",
	+ "url": "https://mk.absturztau.be/files/webpublic-3b5594f4-fa52-4548-b4e3-c379ae2143ed",
	+ "sensitive": false,
	+ "name": null
	+ },
	+ "image": {
	+ "type": "Image",
	+ "url": "https://mk.absturztau.be/files/webpublic-0d03b03d-b14b-4916-ac3d-8a137118ec84",
	+ "sensitive": false,
	+ "name": null
	+ },
	+ "tag": [],
	+ "manuallyApprovesFollowers": true,
	+ "discoverable": false,
	+ "publicKey": {
	+ "id": "https://mk.absturztau.be/users/8ozbzjs3o8#main-key",
	+ "type": "Key",
	+ "owner": "https://mk.absturztau.be/users/8ozbzjs3o8",
	+ "publicKeyPem": "-----BEGIN PUBLIC KEY-----\nMIICIjANBgkqhkiG9w0BAQEFAAOCAg8AMIICCgKCAgEAuN/S1spBGmh8FXI1Bt16\nXB7Cc0QutBp7UPgmDNHjOfsq0zrF4g3L1UBxvrpU0XX77XPMCd9yPvGwAYURH2mv\ntIcYuE+R90VLDmBu5MTVthcG2D874eCZ2rD2YsEYmN5AjTX7QBIqCck+qDhVWkkM\nEZ6S5Ht6IJ5Of74eKffXElQI/C6QB+9uEDOmPk0jCzgI5gw7xvJqFj/DIF4kUUAu\nA89JqaFZzZlkrSrj4cr48bLN/YOmpdaHu0BKHaDSHct4+MqlixqovgdB6RboCEDw\ne4Aeav7+Q0Y9oGIvuggg0Q+nCubnVNnaPyzd817tpPVzyZmTts+DKyDuv90SX3nR\nsPaNa5Ty60eqplUk4b7X1gSvuzBJUFBxTVV84WnjwoeoydaS6rSyjCDPGLBjaByc\nFyWMMEb/zlQyhLZfBlvT7k96wRSsMszh2hDALWmgYIhq/jNwINvALJ1GKLNHHKZ4\nyz2LnxVpRm2rWrZzbvtcnSQOt3LaPSZn8Wgwv4buyHF02iuVuIamZVtKexsE1Ixl\nIi9qa3AKEc5gOzYXhRhvHaruzoCehUbb/UHC5c8Tto8L5G1xYzjLP3qj3PT9w/wM\n+k1Ra/4JhuAnVFROOoOmx9rIELLHH7juY2nhM7plGhyt1M5gysgqEloij8QzyQU2\nZK1YlAERG2XFO6br8omhcmECAwEAAQ==\n-----END PUBLIC KEY-----\n"
	+ },
	+ "isCat": true,
	+ "vcard:Address": "Vienna, Austria"
	+}
	\ No newline at end of file
	diff --git a/test/fixtures/tesla_mock/mk.absturztau.be-93e7nm8wqg.json b/test/fixtures/tesla_mock/mk.absturztau.be-93e7nm8wqg.json
	new file mode 100644
	index 000000000..1b931a9a4
	--- /dev/null
	+++ b/test/fixtures/tesla_mock/mk.absturztau.be-93e7nm8wqg.json
	@@ -0,0 +1,44 @@
	+{
	+ "@context": [
	+ "https://www.w3.org/ns/activitystreams",
	+ "https://w3id.org/security/v1",
	+ {
	+ "manuallyApprovesFollowers": "as:manuallyApprovesFollowers",
	+ "sensitive": "as:sensitive",
	+ "Hashtag": "as:Hashtag",
	+ "quoteUrl": "as:quoteUrl",
	+ "toot": "http://joinmastodon.org/ns#",
	+ "Emoji": "toot:Emoji",
	+ "featured": "toot:featured",
	+ "discoverable": "toot:discoverable",
	+ "schema": "http://schema.org#",
	+ "PropertyValue": "schema:PropertyValue",
	+ "value": "schema:value",
	+ "misskey": "https://misskey-hub.net/ns#",
	+ "_misskey_content": "misskey:_misskey_content",
	+ "_misskey_quote": "misskey:_misskey_quote",
	+ "_misskey_reaction": "misskey:_misskey_reaction",
	+ "_misskey_votes": "misskey:_misskey_votes",
	+ "_misskey_talk": "misskey:_misskey_talk",
	+ "isCat": "misskey:isCat",
	+ "vcard": "http://www.w3.org/2006/vcard/ns#"
	+ }
	+ ],
	+ "id": "https://mk.absturztau.be/notes/93e7nm8wqg",
	+ "type": "Note",
	+ "attributedTo": "https://mk.absturztau.be/users/8ozbzjs3o8",
	+ "summary": null,
	+ "content": "<p><span>meow</span></p>",
	+ "_misskey_content": "meow",
	+ "published": "2022-08-01T11:06:49.568Z",
	+ "to": [
	+ "https://www.w3.org/ns/activitystreams#Public"
	+ ],
	+ "cc": [
	+ "https://mk.absturztau.be/users/8ozbzjs3o8/followers"
	+ ],
	+ "inReplyTo": null,
	+ "attachment": [],
	+ "sensitive": false,
	+ "tag": []
	+}
	\ No newline at end of file
	diff --git a/test/fixtures/tesla_mock/p.helene.moe-AM7S6vZQmL6pI9TgPY.json b/test/fixtures/tesla_mock/p.helene.moe-AM7S6vZQmL6pI9TgPY.json
	new file mode 100644
	index 000000000..a1ef5e20b
	--- /dev/null
	+++ b/test/fixtures/tesla_mock/p.helene.moe-AM7S6vZQmL6pI9TgPY.json
	@@ -0,0 +1,36 @@
	+{
	+ "@context": [
	+ "https://www.w3.org/ns/activitystreams",
	+ "https://p.helene.moe/schemas/litepub-0.1.jsonld",
	+ {
	+ "@language": "und"
	+ }
	+ ],
	+ "actor": "https://p.helene.moe/users/helene",
	+ "attachment": [],
	+ "attributedTo": "https://p.helene.moe/users/helene",
	+ "cc": [
	+ "https://p.helene.moe/users/helene/followers"
	+ ],
	+ "content": "<span class=\"h-card\"><a class=\"u-url mention\" data-user=\"AHntpQ4T3J4OSnpgMC\" href=\"https://mk.absturztau.be/@mametsuko\" rel=\"ugc\">@<span>mametsuko</span></a></span> meow",
	+ "context": "https://p.helene.moe/contexts/cc324643-5583-4c3f-91d2-c6ed37db159d",
	+ "conversation": "https://p.helene.moe/contexts/cc324643-5583-4c3f-91d2-c6ed37db159d",
	+ "id": "https://p.helene.moe/objects/fd5910ac-d9dc-412e-8d1d-914b203296c4",
	+ "inReplyTo": "https://mk.absturztau.be/notes/93e7nm8wqg",
	+ "published": "2022-08-02T13:46:58.403996Z",
	+ "sensitive": null,
	+ "source": "@mametsuko@mk.absturztau.be meow",
	+ "summary": "",
	+ "tag": [
	+ {
	+ "href": "https://mk.absturztau.be/users/8ozbzjs3o8",
	+ "name": "@mametsuko@mk.absturztau.be",
	+ "type": "Mention"
	+ }
	+ ],
	+ "to": [
	+ "https://mk.absturztau.be/users/8ozbzjs3o8",
	+ "https://www.w3.org/ns/activitystreams#Public"
	+ ],
	+ "type": "Note"
	+}
	\ No newline at end of file
	diff --git a/test/pleroma/web/activity_pub/object_validators/create_generic_validator_test.exs b/test/pleroma/web/activity_pub/object_validators/create_generic_validator_test.exs
	index 0a5b44beb..e771260c9 100644
	--- a/test/pleroma/web/activity_pub/object_validators/create_generic_validator_test.exs
	+++ b/test/pleroma/web/activity_pub/object_validators/create_generic_validator_test.exs
	@@ -1,59 +1,62 @@
	# Pleroma: A lightweight social networking server
	# Copyright © 2017-2022 Pleroma Authors <https://pleroma.social/>
	# SPDX-License-Identifier: AGPL-3.0-only

	defmodule Pleroma.Web.ActivityPub.ObjectValidators.CreateGenericValidatorTest do
	use Pleroma.DataCase, async: true

	alias Pleroma.Web.ActivityPub.ObjectValidator
	alias Pleroma.Web.ActivityPub.ObjectValidators.CreateGenericValidator
	alias Pleroma.Web.ActivityPub.Utils

	import Pleroma.Factory

	test "a Create/Note from Roadhouse validates" do
	insert(:user, ap_id: "https://macgirvin.com/channel/mike")

	note_activity =
	"test/fixtures/roadhouse-create-activity.json"
	\|> File.read!()
	\|> Jason.decode!()

	# Build metadata
	{:ok, object_data} = ObjectValidator.cast_and_apply(note_activity["object"])
	meta = [object_data: ObjectValidator.stringify_keys(object_data)]

	- %{valid?: true} = CreateGenericValidator.cast_and_validate(note_activity, meta)
	+ assert %{valid?: true} = CreateGenericValidator.cast_and_validate(note_activity, meta)
	end

	- test "a Create/Note with mismatched context is invalid" do
	+ test "a Create/Note with mismatched context uses the Note's context" do
	user = insert(:user)

	note = %{
	"id" => Utils.generate_object_id(),
	"type" => "Note",
	"actor" => user.ap_id,
	"to" => [user.follower_address],
	"cc" => [],
	"content" => "Hello world",
	"context" => Utils.generate_context_id()
	}

	note_activity = %{
	"id" => Utils.generate_activity_id(),
	"type" => "Create",
	"actor" => note["actor"],
	"to" => note["to"],
	"cc" => note["cc"],
	"object" => note,
	"published" => DateTime.utc_now() \|> DateTime.to_iso8601(),
	"context" => Utils.generate_context_id()
	}

	# Build metadata
	{:ok, object_data} = ObjectValidator.cast_and_apply(note_activity["object"])
	meta = [object_data: ObjectValidator.stringify_keys(object_data)]

	- %{valid?: false} = CreateGenericValidator.cast_and_validate(note_activity, meta)
	+ validated = CreateGenericValidator.cast_and_validate(note_activity, meta)
	+
	+ assert validated.valid?
	+ assert {:context, note["context"]} in validated.changes
	end
	end
	diff --git a/test/pleroma/web/activity_pub/transmogrifier_test.exs b/test/pleroma/web/activity_pub/transmogrifier_test.exs
	index b254e5591..a07972895 100644
	--- a/test/pleroma/web/activity_pub/transmogrifier_test.exs
	+++ b/test/pleroma/web/activity_pub/transmogrifier_test.exs
	@@ -1,576 +1,581 @@
	# Pleroma: A lightweight social networking server
	# Copyright © 2017-2022 Pleroma Authors <https://pleroma.social/>
	# SPDX-License-Identifier: AGPL-3.0-only

	defmodule Pleroma.Web.ActivityPub.TransmogrifierTest do
	use Oban.Testing, repo: Pleroma.Repo
	use Pleroma.DataCase

	alias Pleroma.Activity
	alias Pleroma.Object
	alias Pleroma.Tests.ObanHelpers
	alias Pleroma.User
	alias Pleroma.Web.ActivityPub.Transmogrifier
	alias Pleroma.Web.ActivityPub.Utils
	alias Pleroma.Web.AdminAPI.AccountView
	alias Pleroma.Web.CommonAPI

	import Mock
	import Pleroma.Factory
	import ExUnit.CaptureLog

	setup_all do
	Tesla.Mock.mock_global(fn env -> apply(HttpRequestMock, :request, [env]) end)
	:ok
	end

	setup do: clear_config([:instance, :max_remote_account_fields])

	describe "handle_incoming" do
	test "it works for incoming unfollows with an existing follow" do
	user = insert(:user)

	follow_data =
	File.read!("test/fixtures/mastodon-follow-activity.json")
	\|> Jason.decode!()
	\|> Map.put("object", user.ap_id)

	{:ok, %Activity{data: _, local: false}} = Transmogrifier.handle_incoming(follow_data)

	data =
	File.read!("test/fixtures/mastodon-unfollow-activity.json")
	\|> Jason.decode!()
	\|> Map.put("object", follow_data)

	{:ok, %Activity{data: data, local: false}} = Transmogrifier.handle_incoming(data)

	assert data["type"] == "Undo"
	assert data["object"]["type"] == "Follow"
	assert data["object"]["object"] == user.ap_id
	assert data["actor"] == "http://mastodon.example.org/users/admin"

	refute User.following?(User.get_cached_by_ap_id(data["actor"]), user)
	end

	test "it accepts Flag activities" do
	user = insert(:user)
	other_user = insert(:user)

	{:ok, activity} = CommonAPI.post(user, %{status: "test post"})
	object = Object.normalize(activity, fetch: false)

	note_obj = %{
	"type" => "Note",
	"id" => activity.data["id"],
	"content" => "test post",
	"published" => object.data["published"],
	"actor" => AccountView.render("show.json", %{user: user, skip_visibility_check: true})
	}

	message = %{
	"@context" => "https://www.w3.org/ns/activitystreams",
	"cc" => [user.ap_id],
	"object" => [user.ap_id, activity.data["id"]],
	"type" => "Flag",
	"content" => "blocked AND reported!!!",
	"actor" => other_user.ap_id
	}

	assert {:ok, activity} = Transmogrifier.handle_incoming(message)

	assert activity.data["object"] == [user.ap_id, note_obj]
	assert activity.data["content"] == "blocked AND reported!!!"
	assert activity.data["actor"] == other_user.ap_id
	assert activity.data["cc"] == [user.ap_id]
	end

	test "it accepts Move activities" do
	old_user = insert(:user)
	new_user = insert(:user)

	message = %{
	"@context" => "https://www.w3.org/ns/activitystreams",
	"type" => "Move",
	"actor" => old_user.ap_id,
	"object" => old_user.ap_id,
	"target" => new_user.ap_id
	}

	assert :error = Transmogrifier.handle_incoming(message)

	{:ok, _new_user} = User.update_and_set_cache(new_user, %{also_known_as: [old_user.ap_id]})

	assert {:ok, %Activity{} = activity} = Transmogrifier.handle_incoming(message)
	assert activity.actor == old_user.ap_id
	assert activity.data["actor"] == old_user.ap_id
	assert activity.data["object"] == old_user.ap_id
	assert activity.data["target"] == new_user.ap_id
	assert activity.data["type"] == "Move"
	end

	- test "a reply with mismatched context is rejected" do
	- insert(:user, ap_id: "https://macgirvin.com/channel/mike")
	+ test "it fixes both the Create and object contexts in a reply" do
	+ insert(:user, ap_id: "https://mk.absturztau.be/users/8ozbzjs3o8")
	+ insert(:user, ap_id: "https://p.helene.moe/users/helene")

	- note_activity =
	- "test/fixtures/roadhouse-create-activity.json"
	+ create_activity =
	+ "test/fixtures/create-pleroma-reply-to-misskey-thread.json"
	\|> File.read!()
	\|> Jason.decode!()

	- assert {:error, _} = Transmogrifier.handle_incoming(note_activity)
	+ assert {:ok, %Activity{} = activity} = Transmogrifier.handle_incoming(create_activity)
	+
	+ object = Object.normalize(activity, fetch: false)
	+
	+ assert activity.data["context"] == object.data["context"]
	end
	end

	describe "prepare outgoing" do
	test "it inlines private announced objects" do
	user = insert(:user)

	{:ok, activity} = CommonAPI.post(user, %{status: "hey", visibility: "private"})

	{:ok, announce_activity} = CommonAPI.repeat(activity.id, user)

	{:ok, modified} = Transmogrifier.prepare_outgoing(announce_activity.data)

	assert modified["object"]["content"] == "hey"
	assert modified["object"]["actor"] == modified["object"]["attributedTo"]
	end

	test "it turns mentions into tags" do
	user = insert(:user)
	other_user = insert(:user)

	{:ok, activity} =
	CommonAPI.post(user, %{status: "hey, @#{other_user.nickname}, how are ya? #2hu"})

	with_mock Pleroma.Notification,
	get_notified_from_activity: fn _, _ -> [] end do
	{:ok, modified} = Transmogrifier.prepare_outgoing(activity.data)

	object = modified["object"]

	expected_mention = %{
	"href" => other_user.ap_id,
	"name" => "@#{other_user.nickname}",
	"type" => "Mention"
	}

	expected_tag = %{
	"href" => Pleroma.Web.Endpoint.url() <> "/tags/2hu",
	"type" => "Hashtag",
	"name" => "#2hu"
	}

	refute called(Pleroma.Notification.get_notified_from_activity(:_, :_))
	assert Enum.member?(object["tag"], expected_tag)
	assert Enum.member?(object["tag"], expected_mention)
	end
	end

	test "it adds the json-ld context and the conversation property" do
	user = insert(:user)

	{:ok, activity} = CommonAPI.post(user, %{status: "hey"})
	{:ok, modified} = Transmogrifier.prepare_outgoing(activity.data)

	assert modified["@context"] == Utils.make_json_ld_header()["@context"]

	assert modified["object"]["conversation"] == modified["context"]
	end

	test "it sets the 'attributedTo' property to the actor of the object if it doesn't have one" do
	user = insert(:user)

	{:ok, activity} = CommonAPI.post(user, %{status: "hey"})
	{:ok, modified} = Transmogrifier.prepare_outgoing(activity.data)

	assert modified["object"]["actor"] == modified["object"]["attributedTo"]
	end

	test "it strips internal hashtag data" do
	user = insert(:user)

	{:ok, activity} = CommonAPI.post(user, %{status: "#2hu"})

	expected_tag = %{
	"href" => Pleroma.Web.Endpoint.url() <> "/tags/2hu",
	"type" => "Hashtag",
	"name" => "#2hu"
	}

	{:ok, modified} = Transmogrifier.prepare_outgoing(activity.data)

	assert modified["object"]["tag"] == [expected_tag]
	end

	test "it strips internal fields" do
	user = insert(:user)

	{:ok, activity} =
	CommonAPI.post(user, %{
	status: "#2hu :firefox:",
	generator: %{type: "Application", name: "TestClient", url: "https://pleroma.social"}
	})

	# Ensure injected application data made it into the activity
	# as we don't have a Token to derive it from, otherwise it will
	# be nil and the test will pass
	assert %{
	type: "Application",
	name: "TestClient",
	url: "https://pleroma.social"
	} == activity.object.data["generator"]

	{:ok, modified} = Transmogrifier.prepare_outgoing(activity.data)

	assert length(modified["object"]["tag"]) == 2

	assert is_nil(modified["object"]["emoji"])
	assert is_nil(modified["object"]["like_count"])
	assert is_nil(modified["object"]["announcements"])
	assert is_nil(modified["object"]["announcement_count"])
	assert is_nil(modified["object"]["generator"])
	end

	test "it strips internal fields of article" do
	activity = insert(:article_activity)

	{:ok, modified} = Transmogrifier.prepare_outgoing(activity.data)

	assert length(modified["object"]["tag"]) == 2

	assert is_nil(modified["object"]["emoji"])
	assert is_nil(modified["object"]["like_count"])
	assert is_nil(modified["object"]["announcements"])
	assert is_nil(modified["object"]["announcement_count"])
	assert is_nil(modified["object"]["likes"])
	end

	test "the directMessage flag is present" do
	user = insert(:user)
	other_user = insert(:user)

	{:ok, activity} = CommonAPI.post(user, %{status: "2hu :moominmamma:"})

	{:ok, modified} = Transmogrifier.prepare_outgoing(activity.data)

	assert modified["directMessage"] == false

	{:ok, activity} = CommonAPI.post(user, %{status: "@#{other_user.nickname} :moominmamma:"})

	{:ok, modified} = Transmogrifier.prepare_outgoing(activity.data)

	assert modified["directMessage"] == false

	{:ok, activity} =
	CommonAPI.post(user, %{
	status: "@#{other_user.nickname} :moominmamma:",
	visibility: "direct"
	})

	{:ok, modified} = Transmogrifier.prepare_outgoing(activity.data)

	assert modified["directMessage"] == true
	end

	test "it strips BCC field" do
	user = insert(:user)
	{:ok, list} = Pleroma.List.create("foo", user)

	{:ok, activity} = CommonAPI.post(user, %{status: "foobar", visibility: "list:#{list.id}"})

	{:ok, modified} = Transmogrifier.prepare_outgoing(activity.data)

	assert is_nil(modified["bcc"])
	end

	test "it can handle Listen activities" do
	listen_activity = insert(:listen)

	{:ok, modified} = Transmogrifier.prepare_outgoing(listen_activity.data)

	assert modified["type"] == "Listen"

	user = insert(:user)

	{:ok, activity} = CommonAPI.listen(user, %{"title" => "lain radio episode 1"})

	{:ok, _modified} = Transmogrifier.prepare_outgoing(activity.data)
	end

	test "custom emoji urls are URI encoded" do
	# :dinosaur: filename has a space -> dino walking.gif
	user = insert(:user)

	{:ok, activity} = CommonAPI.post(user, %{status: "everybody do the dinosaur :dinosaur:"})

	{:ok, prepared} = Transmogrifier.prepare_outgoing(activity.data)

	assert length(prepared["object"]["tag"]) == 1

	url = prepared["object"]["tag"] \|> List.first() \|> Map.get("icon") \|> Map.get("url")

	assert url == "http://localhost:4001/emoji/dino%20walking.gif"
	end
	end

	describe "user upgrade" do
	test "it upgrades a user to activitypub" do
	user =
	insert(:user, %{
	nickname: "rye@niu.moe",
	local: false,
	ap_id: "https://niu.moe/users/rye",
	follower_address: User.ap_followers(%User{nickname: "rye@niu.moe"})
	})

	user_two = insert(:user)
	Pleroma.FollowingRelationship.follow(user_two, user, :follow_accept)

	{:ok, activity} = CommonAPI.post(user, %{status: "test"})
	{:ok, unrelated_activity} = CommonAPI.post(user_two, %{status: "test"})
	assert "http://localhost:4001/users/rye@niu.moe/followers" in activity.recipients

	user = User.get_cached_by_id(user.id)
	assert user.note_count == 1

	{:ok, user} = Transmogrifier.upgrade_user_from_ap_id("https://niu.moe/users/rye")
	ObanHelpers.perform_all()

	assert user.ap_enabled
	assert user.note_count == 1
	assert user.follower_address == "https://niu.moe/users/rye/followers"
	assert user.following_address == "https://niu.moe/users/rye/following"

	user = User.get_cached_by_id(user.id)
	assert user.note_count == 1

	activity = Activity.get_by_id(activity.id)
	assert user.follower_address in activity.recipients

	assert %{
	"url" => [
	%{
	"href" =>
	"https://cdn.niu.moe/accounts/avatars/000/033/323/original/fd7f8ae0b3ffedc9.jpeg"
	}
	]
	} = user.avatar

	assert %{
	"url" => [
	%{
	"href" =>
	"https://cdn.niu.moe/accounts/headers/000/033/323/original/850b3448fa5fd477.png"
	}
	]
	} = user.banner

	refute "..." in activity.recipients

	unrelated_activity = Activity.get_by_id(unrelated_activity.id)
	refute user.follower_address in unrelated_activity.recipients

	user_two = User.get_cached_by_id(user_two.id)
	assert User.following?(user_two, user)
	refute "..." in User.following(user_two)
	end
	end

	describe "actor rewriting" do
	test "it fixes the actor URL property to be a proper URI" do
	data = %{
	"url" => %{"href" => "http://example.com"}
	}

	rewritten = Transmogrifier.maybe_fix_user_object(data)
	assert rewritten["url"] == "http://example.com"
	end
	end

	describe "actor origin containment" do
	test "it rejects activities which reference objects with bogus origins" do
	data = %{
	"@context" => "https://www.w3.org/ns/activitystreams",
	"id" => "http://mastodon.example.org/users/admin/activities/1234",
	"actor" => "http://mastodon.example.org/users/admin",
	"to" => ["https://www.w3.org/ns/activitystreams#Public"],
	"object" => "https://info.pleroma.site/activity.json",
	"type" => "Announce"
	}

	assert capture_log(fn ->
	{:error, _} = Transmogrifier.handle_incoming(data)
	end) =~ "Object containment failed"
	end

	test "it rejects activities which reference objects that have an incorrect attribution (variant 1)" do
	data = %{
	"@context" => "https://www.w3.org/ns/activitystreams",
	"id" => "http://mastodon.example.org/users/admin/activities/1234",
	"actor" => "http://mastodon.example.org/users/admin",
	"to" => ["https://www.w3.org/ns/activitystreams#Public"],
	"object" => "https://info.pleroma.site/activity2.json",
	"type" => "Announce"
	}

	assert capture_log(fn ->
	{:error, _} = Transmogrifier.handle_incoming(data)
	end) =~ "Object containment failed"
	end

	test "it rejects activities which reference objects that have an incorrect attribution (variant 2)" do
	data = %{
	"@context" => "https://www.w3.org/ns/activitystreams",
	"id" => "http://mastodon.example.org/users/admin/activities/1234",
	"actor" => "http://mastodon.example.org/users/admin",
	"to" => ["https://www.w3.org/ns/activitystreams#Public"],
	"object" => "https://info.pleroma.site/activity3.json",
	"type" => "Announce"
	}

	assert capture_log(fn ->
	{:error, _} = Transmogrifier.handle_incoming(data)
	end) =~ "Object containment failed"
	end
	end

	describe "fix_explicit_addressing" do
	setup do
	user = insert(:user)
	[user: user]
	end

	test "moves non-explicitly mentioned actors to cc", %{user: user} do
	explicitly_mentioned_actors = [
	"https://pleroma.gold/users/user1",
	"https://pleroma.gold/user2"
	]

	object = %{
	"actor" => user.ap_id,
	"to" => explicitly_mentioned_actors ++ ["https://social.beepboop.ga/users/dirb"],
	"cc" => [],
	"tag" =>
	Enum.map(explicitly_mentioned_actors, fn href ->
	%{"type" => "Mention", "href" => href}
	end)
	}

	fixed_object = Transmogrifier.fix_explicit_addressing(object, user.follower_address)
	assert Enum.all?(explicitly_mentioned_actors, &(&1 in fixed_object["to"]))
	refute "https://social.beepboop.ga/users/dirb" in fixed_object["to"]
	assert "https://social.beepboop.ga/users/dirb" in fixed_object["cc"]
	end

	test "does not move actor's follower collection to cc", %{user: user} do
	object = %{
	"actor" => user.ap_id,
	"to" => [user.follower_address],
	"cc" => []
	}

	fixed_object = Transmogrifier.fix_explicit_addressing(object, user.follower_address)
	assert user.follower_address in fixed_object["to"]
	refute user.follower_address in fixed_object["cc"]
	end

	test "removes recipient's follower collection from cc", %{user: user} do
	recipient = insert(:user)

	object = %{
	"actor" => user.ap_id,
	"to" => [recipient.ap_id, "https://www.w3.org/ns/activitystreams#Public"],
	"cc" => [user.follower_address, recipient.follower_address]
	}

	fixed_object = Transmogrifier.fix_explicit_addressing(object, user.follower_address)

	assert user.follower_address in fixed_object["cc"]
	refute recipient.follower_address in fixed_object["cc"]
	refute recipient.follower_address in fixed_object["to"]
	end
	end

	describe "fix_summary/1" do
	test "returns fixed object" do
	assert Transmogrifier.fix_summary(%{"summary" => nil}) == %{"summary" => ""}
	assert Transmogrifier.fix_summary(%{"summary" => "ok"}) == %{"summary" => "ok"}
	assert Transmogrifier.fix_summary(%{}) == %{"summary" => ""}
	end
	end

	describe "fix_url/1" do
	test "fixes data for object when url is map" do
	object = %{
	"url" => %{
	"type" => "Link",
	"mimeType" => "video/mp4",
	"href" => "https://peede8d-46fb-ad81-2d4c2d1630e3-480.mp4"
	}
	}

	assert Transmogrifier.fix_url(object) == %{
	"url" => "https://peede8d-46fb-ad81-2d4c2d1630e3-480.mp4"
	}
	end

	test "returns non-modified object" do
	assert Transmogrifier.fix_url(%{"type" => "Text"}) == %{"type" => "Text"}
	end
	end

	describe "get_obj_helper/2" do
	test "returns nil when cannot normalize object" do
	assert capture_log(fn ->
	refute Transmogrifier.get_obj_helper("test-obj-id")
	end) =~ "Unsupported URI scheme"
	end

	@tag capture_log: true
	test "returns {:ok, %Object{}} for success case" do
	assert {:ok, %Object{}} =
	Transmogrifier.get_obj_helper(
	"https://mstdn.io/users/mayuutann/statuses/99568293732299394"
	)
	end
	end

	describe "fix_attachments/1" do
	test "puts dimensions into attachment url field" do
	object = %{
	"attachment" => [
	%{
	"type" => "Document",
	"name" => "Hello world",
	"url" => "https://media.example.tld/1.jpg",
	"width" => 880,
	"height" => 960,
	"mediaType" => "image/jpeg",
	"blurhash" => "eTKL26+HDjcEIBVl;ds+K6t301W.t7nit7y1E,R:v}ai4nXSt7V@of"
	}
	]
	}

	expected = %{
	"attachment" => [
	%{
	"type" => "Document",
	"name" => "Hello world",
	"url" => [
	%{
	"type" => "Link",
	"mediaType" => "image/jpeg",
	"href" => "https://media.example.tld/1.jpg",
	"width" => 880,
	"height" => 960
	}
	],
	"mediaType" => "image/jpeg",
	"blurhash" => "eTKL26+HDjcEIBVl;ds+K6t301W.t7nit7y1E,R:v}ai4nXSt7V@of"
	}
	]
	}

	assert Transmogrifier.fix_attachments(object) == expected
	end
	end
	end
	diff --git a/test/support/http_request_mock.ex b/test/support/http_request_mock.ex
	index eb844e469..c1f0f7af1 100644
	--- a/test/support/http_request_mock.ex
	+++ b/test/support/http_request_mock.ex
	@@ -1,1489 +1,1525 @@
	# Pleroma: A lightweight social networking server
	# Copyright © 2017-2022 Pleroma Authors <https://pleroma.social/>
	# SPDX-License-Identifier: AGPL-3.0-only

	defmodule HttpRequestMock do
	require Logger

	def activitypub_object_headers, do: [{"content-type", "application/activity+json"}]

	def request(
	%Tesla.Env{
	url: url,
	method: method,
	headers: headers,
	query: query,
	body: body
	} = _env
	) do
	with {:ok, res} <- apply(__MODULE__, method, [url, query, body, headers]) do
	res
	else
	error ->
	with {:error, message} <- error do
	Logger.warn(to_string(message))
	end

	{_, _r} = error
	end
	end

	# GET Requests
	#
	def get(url, query \\ [], body \\ [], headers \\ [])

	def get("https://osada.macgirvin.com/channel/mike", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/https___osada.macgirvin.com_channel_mike.json"),
	headers: activitypub_object_headers()
	}}
	end

	def get("https://shitposter.club/users/moonman", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/moonman@shitposter.club.json"),
	headers: activitypub_object_headers()
	}}
	end

	def get("https://mastodon.social/users/emelie/statuses/101849165031453009", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/status.emelie.json"),
	headers: activitypub_object_headers()
	}}
	end

	def get("https://mastodon.social/users/emelie/statuses/101849165031453404", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 404,
	body: ""
	}}
	end

	def get("https://mastodon.social/users/emelie", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/emelie.json"),
	headers: activitypub_object_headers()
	}}
	end

	def get("https://mastodon.social/users/not_found", _, _, _) do
	{:ok, %Tesla.Env{status: 404}}
	end

	def get("https://mastodon.sdf.org/users/rinpatch", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/rinpatch.json"),
	headers: activitypub_object_headers()
	}}
	end

	def get("https://mastodon.sdf.org/users/rinpatch/collections/featured", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body:
	File.read!("test/fixtures/users_mock/masto_featured.json")
	\|> String.replace("{{domain}}", "mastodon.sdf.org")
	\|> String.replace("{{nickname}}", "rinpatch"),
	headers: [{"content-type", "application/activity+json"}]
	}}
	end

	def get("https://patch.cx/objects/tesla_mock/poll_attachment", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/poll_attachment.json"),
	headers: activitypub_object_headers()
	}}
	end

	def get(
	"https://mastodon.social/.well-known/webfinger?resource=https://mastodon.social/users/emelie",
	_,
	_,
	_
	) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/webfinger_emelie.json"),
	headers: activitypub_object_headers()
	}}
	end

	def get(
	"https://osada.macgirvin.com/.well-known/webfinger?resource=acct:mike@osada.macgirvin.com",
	_,
	_,
	[{"accept", "application/xrd+xml,application/jrd+json"}]
	) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/mike@osada.macgirvin.com.json"),
	headers: [{"content-type", "application/jrd+json"}]
	}}
	end

	def get(
	"https://social.heldscal.la/.well-known/webfinger?resource=https://social.heldscal.la/user/29191",
	_,
	_,
	[{"accept", "application/xrd+xml,application/jrd+json"}]
	) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/https___social.heldscal.la_user_29191.xml")
	}}
	end

	def get(
	"https://pawoo.net/.well-known/webfinger?resource=acct:https://pawoo.net/users/pekorino",
	_,
	_,
	[{"accept", "application/xrd+xml,application/jrd+json"}]
	) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/https___pawoo.net_users_pekorino.xml")
	}}
	end

	def get(
	"https://social.stopwatchingus-heidelberg.de/.well-known/webfinger?resource=acct:https://social.stopwatchingus-heidelberg.de/user/18330",
	_,
	_,
	[{"accept", "application/xrd+xml,application/jrd+json"}]
	) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/atarifrosch_webfinger.xml")
	}}
	end

	def get(
	"https://social.heldscal.la/.well-known/webfinger?resource=nonexistant@social.heldscal.la",
	_,
	_,
	[{"accept", "application/xrd+xml,application/jrd+json"}]
	) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/nonexistant@social.heldscal.la.xml")
	}}
	end

	def get(
	"https://squeet.me/xrd/?uri=acct:lain@squeet.me",
	_,
	_,
	[{"accept", "application/xrd+xml,application/jrd+json"}]
	) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/lain_squeet.me_webfinger.xml"),
	headers: [{"content-type", "application/xrd+xml"}]
	}}
	end

	def get(
	"https://mst3k.interlinked.me/users/luciferMysticus",
	_,
	_,
	[{"accept", "application/activity+json"}]
	) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/lucifermysticus.json"),
	headers: activitypub_object_headers()
	}}
	end

	def get("https://prismo.news/@mxb", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/https___prismo.news__mxb.json"),
	headers: activitypub_object_headers()
	}}
	end

	def get(
	"https://hubzilla.example.org/channel/kaniini",
	_,
	_,
	[{"accept", "application/activity+json"}]
	) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/kaniini@hubzilla.example.org.json"),
	headers: activitypub_object_headers()
	}}
	end

	def get("https://niu.moe/users/rye", _, _, [{"accept", "application/activity+json"}]) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/rye.json"),
	headers: activitypub_object_headers()
	}}
	end

	def get("https://n1u.moe/users/rye", _, _, [{"accept", "application/activity+json"}]) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/rye.json"),
	headers: activitypub_object_headers()
	}}
	end

	def get("http://mastodon.example.org/users/admin/statuses/100787282858396771", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body:
	File.read!(
	"test/fixtures/tesla_mock/http___mastodon.example.org_users_admin_status_1234.json"
	)
	}}
	end

	def get("https://puckipedia.com/", _, _, [{"accept", "application/activity+json"}]) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/puckipedia.com.json"),
	headers: activitypub_object_headers()
	}}
	end

	def get("https://peertube.moe/accounts/7even", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/7even.json"),
	headers: activitypub_object_headers()
	}}
	end

	def get("https://peertube.stream/accounts/createurs", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/peertube/actor-person.json"),
	headers: activitypub_object_headers()
	}}
	end

	def get("https://peertube.moe/videos/watch/df5f464b-be8d-46fb-ad81-2d4c2d1630e3", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/peertube.moe-vid.json"),
	headers: activitypub_object_headers()
	}}
	end

	def get("https://framatube.org/accounts/framasoft", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/https___framatube.org_accounts_framasoft.json"),
	headers: activitypub_object_headers()
	}}
	end

	def get("https://framatube.org/videos/watch/6050732a-8a7a-43d4-a6cd-809525a1d206", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/framatube.org-video.json"),
	headers: activitypub_object_headers()
	}}
	end

	def get("https://peertube.social/accounts/craigmaloney", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/craigmaloney.json"),
	headers: activitypub_object_headers()
	}}
	end

	def get("https://peertube.social/videos/watch/278d2b7c-0f38-4aaa-afe6-9ecc0c4a34fe", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/peertube-social.json"),
	headers: activitypub_object_headers()
	}}
	end

	def get("https://mobilizon.org/events/252d5816-00a3-4a89-a66f-15bf65c33e39", _, _, [
	{"accept", "application/activity+json"}
	]) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/mobilizon.org-event.json"),
	headers: activitypub_object_headers()
	}}
	end

	def get("https://mobilizon.org/@tcit", _, _, [{"accept", "application/activity+json"}]) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/mobilizon.org-user.json"),
	headers: activitypub_object_headers()
	}}
	end

	def get("https://baptiste.gelez.xyz/@/BaptisteGelez", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/baptiste.gelex.xyz-user.json"),
	headers: activitypub_object_headers()
	}}
	end

	def get("https://baptiste.gelez.xyz/~/PlumeDevelopment/this-month-in-plume-june-2018/", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/baptiste.gelex.xyz-article.json"),
	headers: activitypub_object_headers()
	}}
	end

	def get("https://wedistribute.org/wp-json/pterotype/v1/object/85810", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/wedistribute-article.json"),
	headers: activitypub_object_headers()
	}}
	end

	def get("https://wedistribute.org/wp-json/pterotype/v1/actor/-blog", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/wedistribute-user.json"),
	headers: activitypub_object_headers()
	}}
	end

	def get("http://mastodon.example.org/users/admin", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/admin@mastdon.example.org.json"),
	headers: activitypub_object_headers()
	}}
	end

	def get("http://mastodon.example.org/users/relay", _, _, [
	{"accept", "application/activity+json"}
	]) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/relay@mastdon.example.org.json"),
	headers: activitypub_object_headers()
	}}
	end

	def get("http://mastodon.example.org/users/gargron", _, _, [
	{"accept", "application/activity+json"}
	]) do
	{:error, :nxdomain}
	end

	def get("http://osada.macgirvin.com/.well-known/host-meta", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 404,
	body: ""
	}}
	end

	def get("https://osada.macgirvin.com/.well-known/host-meta", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 404,
	body: ""
	}}
	end

	def get("http://mastodon.sdf.org/.well-known/host-meta", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/sdf.org_host_meta")
	}}
	end

	def get("https://mastodon.sdf.org/.well-known/host-meta", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/sdf.org_host_meta")
	}}
	end

	def get(
	"https://mastodon.sdf.org/.well-known/webfinger?resource=https://mastodon.sdf.org/users/snowdusk",
	_,
	_,
	_
	) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/snowdusk@sdf.org_host_meta.json")
	}}
	end

	def get("http://mstdn.jp/.well-known/host-meta", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/mstdn.jp_host_meta")
	}}
	end

	def get("https://mstdn.jp/.well-known/host-meta", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/mstdn.jp_host_meta")
	}}
	end

	def get("https://mstdn.jp/.well-known/webfinger?resource=kpherox@mstdn.jp", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/kpherox@mstdn.jp.xml")
	}}
	end

	def get("http://mamot.fr/.well-known/host-meta", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/mamot.fr_host_meta")
	}}
	end

	def get("https://mamot.fr/.well-known/host-meta", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/mamot.fr_host_meta")
	}}
	end

	def get("http://pawoo.net/.well-known/host-meta", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/pawoo.net_host_meta")
	}}
	end

	def get("https://pawoo.net/.well-known/host-meta", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/pawoo.net_host_meta")
	}}
	end

	def get(
	"https://pawoo.net/.well-known/webfinger?resource=https://pawoo.net/users/pekorino",
	_,
	_,
	_
	) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/pekorino@pawoo.net_host_meta.json"),
	headers: activitypub_object_headers()
	}}
	end

	def get("http://pleroma.soykaf.com/.well-known/host-meta", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/soykaf.com_host_meta")
	}}
	end

	def get("https://pleroma.soykaf.com/.well-known/host-meta", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/soykaf.com_host_meta")
	}}
	end

	def get("http://social.stopwatchingus-heidelberg.de/.well-known/host-meta", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/stopwatchingus-heidelberg.de_host_meta")
	}}
	end

	def get("https://social.stopwatchingus-heidelberg.de/.well-known/host-meta", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/stopwatchingus-heidelberg.de_host_meta")
	}}
	end

	def get(
	"http://mastodon.example.org/@admin/99541947525187367",
	_,
	_,
	_
	) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/mastodon-note-object.json"),
	headers: activitypub_object_headers()
	}}
	end

	def get("http://mastodon.example.org/@admin/99541947525187368", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 404,
	body: ""
	}}
	end

	def get("https://shitposter.club/notice/7369654", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/7369654.html")
	}}
	end

	def get("https://mstdn.io/users/mayuutann", _, _, [{"accept", "application/activity+json"}]) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/mayumayu.json"),
	headers: activitypub_object_headers()
	}}
	end

	def get(
	"https://mstdn.io/users/mayuutann/statuses/99568293732299394",
	_,
	_,
	[{"accept", "application/activity+json"}]
	) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/mayumayupost.json"),
	headers: activitypub_object_headers()
	}}
	end

	def get(url, _, _, [{"accept", "application/xrd+xml,application/jrd+json"}])
	when url in [
	"https://pleroma.soykaf.com/.well-known/webfinger?resource=acct:https://pleroma.soykaf.com/users/lain",
	"https://pleroma.soykaf.com/.well-known/webfinger?resource=https://pleroma.soykaf.com/users/lain"
	] do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/https___pleroma.soykaf.com_users_lain.xml")
	}}
	end

	def get(
	"https://shitposter.club/.well-known/webfinger?resource=https://shitposter.club/user/1",
	_,
	_,
	[{"accept", "application/xrd+xml,application/jrd+json"}]
	) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/https___shitposter.club_user_1.xml")
	}}
	end

	def get("https://testing.pleroma.lol/objects/b319022a-4946-44c5-9de9-34801f95507b", _, _, _) do
	{:ok, %Tesla.Env{status: 200}}
	end

	def get(
	"https://shitposter.club/.well-known/webfinger?resource=https://shitposter.club/user/5381",
	_,
	_,
	[{"accept", "application/xrd+xml,application/jrd+json"}]
	) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/spc_5381_xrd.xml")
	}}
	end

	def get("http://shitposter.club/.well-known/host-meta", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/shitposter.club_host_meta")
	}}
	end

	def get("https://shitposter.club/notice/4027863", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/7369654.html")
	}}
	end

	def get("http://social.sakamoto.gq/.well-known/host-meta", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/social.sakamoto.gq_host_meta")
	}}
	end

	def get(
	"https://social.sakamoto.gq/.well-known/webfinger?resource=https://social.sakamoto.gq/users/eal",
	_,
	_,
	[{"accept", "application/xrd+xml,application/jrd+json"}]
	) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/eal_sakamoto.xml")
	}}
	end

	def get("http://mastodon.social/.well-known/host-meta", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/mastodon.social_host_meta")
	}}
	end

	def get(
	"https://mastodon.social/.well-known/webfinger?resource=https://mastodon.social/users/lambadalambda",
	_,
	_,
	[{"accept", "application/xrd+xml,application/jrd+json"}]
	) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body:
	File.read!("test/fixtures/tesla_mock/https___mastodon.social_users_lambadalambda.xml")
	}}
	end

	def get(
	"https://mastodon.social/.well-known/webfinger?resource=acct:not_found@mastodon.social",
	_,
	_,
	[{"accept", "application/xrd+xml,application/jrd+json"}]
	) do
	{:ok, %Tesla.Env{status: 404}}
	end

	def get("http://gs.example.org/.well-known/host-meta", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/gs.example.org_host_meta")
	}}
	end

	def get(
	"http://gs.example.org/.well-known/webfinger?resource=http://gs.example.org:4040/index.php/user/1",
	_,
	_,
	[{"accept", "application/xrd+xml,application/jrd+json"}]
	) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body:
	File.read!("test/fixtures/tesla_mock/http___gs.example.org_4040_index.php_user_1.xml")
	}}
	end

	def get(
	"http://gs.example.org:4040/index.php/user/1",
	_,
	_,
	[{"accept", "application/activity+json"}]
	) do
	{:ok, %Tesla.Env{status: 406, body: ""}}
	end

	def get("http://squeet.me/.well-known/host-meta", _, _, _) do
	{:ok,
	%Tesla.Env{status: 200, body: File.read!("test/fixtures/tesla_mock/squeet.me_host_meta")}}
	end

	def get(
	"https://squeet.me/xrd?uri=lain@squeet.me",
	_,
	_,
	[{"accept", "application/xrd+xml,application/jrd+json"}]
	) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/lain_squeet.me_webfinger.xml")
	}}
	end

	def get(
	"https://social.heldscal.la/.well-known/webfinger?resource=acct:shp@social.heldscal.la",
	_,
	_,
	[{"accept", "application/xrd+xml,application/jrd+json"}]
	) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/shp@social.heldscal.la.xml"),
	headers: [{"content-type", "application/xrd+xml"}]
	}}
	end

	def get(
	"https://social.heldscal.la/.well-known/webfinger?resource=acct:invalid_content@social.heldscal.la",
	_,
	_,
	[{"accept", "application/xrd+xml,application/jrd+json"}]
	) do
	{:ok, %Tesla.Env{status: 200, body: "", headers: [{"content-type", "application/jrd+json"}]}}
	end

	def get("http://framatube.org/.well-known/host-meta", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/framatube.org_host_meta")
	}}
	end

	def get(
	"http://framatube.org/main/xrd?uri=acct:framasoft@framatube.org",
	_,
	_,
	[{"accept", "application/xrd+xml,application/jrd+json"}]
	) do
	{:ok,
	%Tesla.Env{
	status: 200,
	headers: [{"content-type", "application/jrd+json"}],
	body: File.read!("test/fixtures/tesla_mock/framasoft@framatube.org.json")
	}}
	end

	def get("http://gnusocial.de/.well-known/host-meta", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/gnusocial.de_host_meta")
	}}
	end

	def get(
	"http://gnusocial.de/main/xrd?uri=winterdienst@gnusocial.de",
	_,
	_,
	[{"accept", "application/xrd+xml,application/jrd+json"}]
	) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/winterdienst_webfinger.json"),
	headers: activitypub_object_headers()
	}}
	end

	def get("http://status.alpicola.com/.well-known/host-meta", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/status.alpicola.com_host_meta")
	}}
	end

	def get("http://macgirvin.com/.well-known/host-meta", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/macgirvin.com_host_meta")
	}}
	end

	def get("http://gerzilla.de/.well-known/host-meta", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/gerzilla.de_host_meta")
	}}
	end

	def get(
	"https://gerzilla.de/xrd/?uri=acct:kaniini@gerzilla.de",
	_,
	_,
	[{"accept", "application/xrd+xml,application/jrd+json"}]
	) do
	{:ok,
	%Tesla.Env{
	status: 200,
	headers: [{"content-type", "application/jrd+json"}],
	body: File.read!("test/fixtures/tesla_mock/kaniini@gerzilla.de.json")
	}}
	end

	def get(
	"https://social.heldscal.la/.well-known/webfinger?resource=https://social.heldscal.la/user/23211",
	_,
	_,
	_
	) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/https___social.heldscal.la_user_23211.xml")
	}}
	end

	def get("http://social.heldscal.la/.well-known/host-meta", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/social.heldscal.la_host_meta")
	}}
	end

	def get("https://social.heldscal.la/.well-known/host-meta", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/social.heldscal.la_host_meta")
	}}
	end

	def get("https://mastodon.social/users/lambadalambda", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/lambadalambda.json"),
	headers: activitypub_object_headers()
	}}
	end

	def get("https://mastodon.social/users/lambadalambda/collections/featured", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body:
	File.read!("test/fixtures/users_mock/masto_featured.json")
	\|> String.replace("{{domain}}", "mastodon.social")
	\|> String.replace("{{nickname}}", "lambadalambda"),
	headers: activitypub_object_headers()
	}}
	end

	def get("https://apfed.club/channel/indio", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/osada-user-indio.json"),
	headers: activitypub_object_headers()
	}}
	end

	def get("https://social.heldscal.la/user/23211", _, _, [{"accept", "application/activity+json"}]) do
	{:ok, Tesla.Mock.json(%{"id" => "https://social.heldscal.la/user/23211"}, status: 200)}
	end

	def get("http://example.com/ogp", _, _, _) do
	{:ok, %Tesla.Env{status: 200, body: File.read!("test/fixtures/rich_media/ogp.html")}}
	end

	def get("https://example.com/ogp", _, _, _) do
	{:ok, %Tesla.Env{status: 200, body: File.read!("test/fixtures/rich_media/ogp.html")}}
	end

	def get("https://pleroma.local/notice/9kCP7V", _, _, _) do
	{:ok, %Tesla.Env{status: 200, body: File.read!("test/fixtures/rich_media/ogp.html")}}
	end

	def get("http://localhost:4001/users/masto_closed/followers", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/users_mock/masto_closed_followers.json"),
	headers: activitypub_object_headers()
	}}
	end

	def get("http://localhost:4001/users/masto_closed/followers?page=1", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/users_mock/masto_closed_followers_page.json"),
	headers: activitypub_object_headers()
	}}
	end

	def get("http://localhost:4001/users/masto_closed/following", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/users_mock/masto_closed_following.json"),
	headers: activitypub_object_headers()
	}}
	end

	def get("http://localhost:4001/users/masto_closed/following?page=1", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/users_mock/masto_closed_following_page.json"),
	headers: activitypub_object_headers()
	}}
	end

	def get("http://localhost:8080/followers/fuser3", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/users_mock/friendica_followers.json"),
	headers: activitypub_object_headers()
	}}
	end

	def get("http://localhost:8080/following/fuser3", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/users_mock/friendica_following.json"),
	headers: activitypub_object_headers()
	}}
	end

	def get("http://localhost:4001/users/fuser2/followers", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/users_mock/pleroma_followers.json"),
	headers: activitypub_object_headers()
	}}
	end

	def get("http://localhost:4001/users/fuser2/following", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/users_mock/pleroma_following.json"),
	headers: activitypub_object_headers()
	}}
	end

	def get("http://domain-with-errors:4001/users/fuser1/followers", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 504,
	body: ""
	}}
	end

	def get("http://domain-with-errors:4001/users/fuser1/following", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 504,
	body: ""
	}}
	end

	def get("http://example.com/ogp-missing-data", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/rich_media/ogp-missing-data.html")
	}}
	end

	def get("https://example.com/ogp-missing-data", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/rich_media/ogp-missing-data.html")
	}}
	end

	def get("http://example.com/malformed", _, _, _) do
	{:ok,
	%Tesla.Env{status: 200, body: File.read!("test/fixtures/rich_media/malformed-data.html")}}
	end

	def get("http://example.com/empty", _, _, _) do
	{:ok, %Tesla.Env{status: 200, body: "hello"}}
	end

	def get("http://404.site" <> _, _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 404,
	body: ""
	}}
	end

	def get(
	"https://zetsubou.xn--q9jyb4c/.well-known/webfinger?resource=acct:lain@zetsubou.xn--q9jyb4c",
	_,
	_,
	[{"accept", "application/xrd+xml,application/jrd+json"}]
	) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/lain.xml"),
	headers: [{"content-type", "application/xrd+xml"}]
	}}
	end

	def get(
	"https://zetsubou.xn--q9jyb4c/.well-known/webfinger?resource=acct:https://zetsubou.xn--q9jyb4c/users/lain",
	_,
	_,
	[{"accept", "application/xrd+xml,application/jrd+json"}]
	) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/lain.xml"),
	headers: [{"content-type", "application/xrd+xml"}]
	}}
	end

	def get("http://zetsubou.xn--q9jyb4c/.well-known/host-meta", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/host-meta-zetsubou.xn--q9jyb4c.xml")
	}}
	end

	def get(
	"https://zetsubou.xn--q9jyb4c/.well-known/host-meta",
	_,
	_,
	_
	) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/host-meta-zetsubou.xn--q9jyb4c.xml")
	}}
	end

	def get("http://lm.kazv.moe/.well-known/host-meta", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/lm.kazv.moe_host_meta")
	}}
	end

	def get("https://lm.kazv.moe/.well-known/host-meta", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/lm.kazv.moe_host_meta")
	}}
	end

	def get(
	"https://lm.kazv.moe/.well-known/webfinger?resource=acct:mewmew@lm.kazv.moe",
	_,
	_,
	[{"accept", "application/xrd+xml,application/jrd+json"}]
	) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/https___lm.kazv.moe_users_mewmew.xml"),
	headers: [{"content-type", "application/xrd+xml"}]
	}}
	end

	def get("https://lm.kazv.moe/users/mewmew", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/mewmew@lm.kazv.moe.json"),
	headers: activitypub_object_headers()
	}}
	end

	def get("https://lm.kazv.moe/users/mewmew/collections/featured", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body:
	File.read!("test/fixtures/users_mock/masto_featured.json")
	\|> String.replace("{{domain}}", "lm.kazv.moe")
	\|> String.replace("{{nickname}}", "mewmew"),
	headers: [{"content-type", "application/activity+json"}]
	}}
	end

	def get("https://info.pleroma.site/activity.json", _, _, [
	{"accept", "application/activity+json"}
	]) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/https__info.pleroma.site_activity.json"),
	headers: activitypub_object_headers()
	}}
	end

	def get("https://info.pleroma.site/activity.json", _, _, _) do
	{:ok, %Tesla.Env{status: 404, body: ""}}
	end

	def get("https://info.pleroma.site/activity2.json", _, _, [
	{"accept", "application/activity+json"}
	]) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/https__info.pleroma.site_activity2.json"),
	headers: activitypub_object_headers()
	}}
	end

	def get("https://info.pleroma.site/activity2.json", _, _, _) do
	{:ok, %Tesla.Env{status: 404, body: ""}}
	end

	def get("https://info.pleroma.site/activity3.json", _, _, [
	{"accept", "application/activity+json"}
	]) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/https__info.pleroma.site_activity3.json"),
	headers: activitypub_object_headers()
	}}
	end

	def get("https://info.pleroma.site/activity3.json", _, _, _) do
	{:ok, %Tesla.Env{status: 404, body: ""}}
	end

	def get("https://mstdn.jp/.well-known/webfinger?resource=acct:kpherox@mstdn.jp", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/kpherox@mstdn.jp.xml"),
	headers: [{"content-type", "application/xrd+xml"}]
	}}
	end

	def get("https://10.111.10.1/notice/9kCP7V", _, _, _) do
	{:ok, %Tesla.Env{status: 200, body: ""}}
	end

	def get("https://172.16.32.40/notice/9kCP7V", _, _, _) do
	{:ok, %Tesla.Env{status: 200, body: ""}}
	end

	def get("https://192.168.10.40/notice/9kCP7V", _, _, _) do
	{:ok, %Tesla.Env{status: 200, body: ""}}
	end

	def get("https://www.patreon.com/posts/mastodon-2-9-and-28121681", _, _, _) do
	{:ok, %Tesla.Env{status: 200, body: ""}}
	end

	def get("http://mastodon.example.org/@admin/99541947525187367", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/mastodon-post-activity.json"),
	headers: activitypub_object_headers()
	}}
	end

	def get("https://info.pleroma.site/activity4.json", _, _, _) do
	{:ok, %Tesla.Env{status: 500, body: "Error occurred"}}
	end

	def get("http://example.com/rel_me/anchor", _, _, _) do
	{:ok, %Tesla.Env{status: 200, body: File.read!("test/fixtures/rel_me_anchor.html")}}
	end

	def get("http://example.com/rel_me/anchor_nofollow", _, _, _) do
	{:ok, %Tesla.Env{status: 200, body: File.read!("test/fixtures/rel_me_anchor_nofollow.html")}}
	end

	def get("http://example.com/rel_me/link", _, _, _) do
	{:ok, %Tesla.Env{status: 200, body: File.read!("test/fixtures/rel_me_link.html")}}
	end

	def get("http://example.com/rel_me/null", _, _, _) do
	{:ok, %Tesla.Env{status: 200, body: File.read!("test/fixtures/rel_me_null.html")}}
	end

	def get("https://skippers-bin.com/notes/7x9tmrp97i", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/misskey_poll_no_end_date.json"),
	headers: activitypub_object_headers()
	}}
	end

	def get("https://example.org/emoji/firedfox.png", _, _, _) do
	{:ok, %Tesla.Env{status: 200, body: File.read!("test/fixtures/image.jpg")}}
	end

	def get("https://skippers-bin.com/users/7v1w1r8ce6", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/sjw.json"),
	headers: activitypub_object_headers()
	}}
	end

	def get("https://patch.cx/users/rin", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/rin.json"),
	headers: activitypub_object_headers()
	}}
	end

	def get(
	"https://channels.tests.funkwhale.audio/federation/music/uploads/42342395-0208-4fee-a38d-259a6dae0871",
	_,
	_,
	_
	) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/funkwhale_audio.json"),
	headers: activitypub_object_headers()
	}}
	end

	def get("https://channels.tests.funkwhale.audio/federation/actors/compositions", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/funkwhale_channel.json"),
	headers: activitypub_object_headers()
	}}
	end

	def get("http://example.com/rel_me/error", _, _, _) do
	{:ok, %Tesla.Env{status: 404, body: ""}}
	end

	def get("https://relay.mastodon.host/actor", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/relay/relay.json"),
	headers: activitypub_object_headers()
	}}
	end

	def get("http://localhost:4001/", _, "", [{"accept", "text/html"}]) do
	{:ok, %Tesla.Env{status: 200, body: File.read!("test/fixtures/tesla_mock/7369654.html")}}
	end

	def get("https://osada.macgirvin.com/", _, "", [{"accept", "text/html"}]) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/https___osada.macgirvin.com.html")
	}}
	end

	def get("https://patch.cx/objects/a399c28e-c821-4820-bc3e-4afeb044c16f", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/emoji-in-summary.json"),
	headers: activitypub_object_headers()
	}}
	end

	def get("https://gleasonator.com/objects/102eb097-a18b-4cd5-abfc-f952efcb70bb", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/gleasonator-AG3RzWfwEKKrY63qj2.json"),
	headers: activitypub_object_headers()
	}}
	end

	def get("https://gleasonator.com/users/macgirvin", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/macgirvin@gleasonator.com.json"),
	headers: activitypub_object_headers()
	}}
	end

	def get("https://gleasonator.com/users/macgirvin/collections/featured", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body:
	File.read!("test/fixtures/users_mock/masto_featured.json")
	\|> String.replace("{{domain}}", "gleasonator.com")
	\|> String.replace("{{nickname}}", "macgirvin"),
	headers: activitypub_object_headers()
	}}
	end

	+ def get("https://mk.absturztau.be/users/8ozbzjs3o8", _, _, _) do
	+ {:ok,
	+ %Tesla.Env{
	+ status: 200,
	+ body: File.read!("test/fixtures/tesla_mock/mametsuko@mk.absturztau.be.json"),
	+ headers: activitypub_object_headers()
	+ }}
	+ end
	+
	+ def get("https://p.helene.moe/users/helene", _, _, _) do
	+ {:ok,
	+ %Tesla.Env{
	+ status: 200,
	+ body: File.read!("test/fixtures/tesla_mock/helene@p.helene.moe.json"),
	+ headers: activitypub_object_headers()
	+ }}
	+ end
	+
	+ def get("https://mk.absturztau.be/notes/93e7nm8wqg", _, _, _) do
	+ {:ok,
	+ %Tesla.Env{
	+ status: 200,
	+ body: File.read!("test/fixtures/tesla_mock/mk.absturztau.be-93e7nm8wqg.json"),
	+ headers: activitypub_object_headers()
	+ }}
	+ end
	+
	+ def get("https://p.helene.moe/objects/fd5910ac-d9dc-412e-8d1d-914b203296c4", _, _, _) do
	+ {:ok,
	+ %Tesla.Env{
	+ status: 200,
	+ body: File.read!("test/fixtures/tesla_mock/p.helene.moe-AM7S6vZQmL6pI9TgPY.json"),
	+ headers: activitypub_object_headers()
	+ }}
	+ end
	+
	def get(url, query, body, headers) do
	{:error,
	"Mock response not implemented for GET #{inspect(url)}, #{query}, #{inspect(body)}, #{inspect(headers)}"}
	end

	# POST Requests
	#

	def post(url, query \\ [], body \\ [], headers \\ [])

	def post("https://relay.mastodon.host/inbox", _, _, _) do
	{:ok, %Tesla.Env{status: 200, body: ""}}
	end

	def post("http://example.org/needs_refresh", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: ""
	}}
	end

	def post("http://mastodon.example.org/inbox", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: ""
	}}
	end

	def post("https://hubzilla.example.org/inbox", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: ""
	}}
	end

	def post("http://gs.example.org/index.php/main/salmon/user/1", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: ""
	}}
	end

	def post("http://200.site" <> _, _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: ""
	}}
	end

	def post("http://connrefused.site" <> _, _, _, _) do
	{:error, :connrefused}
	end

	def post("http://404.site" <> _, _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 404,
	body: ""
	}}
	end

	def post(url, query, body, headers) do
	{:error,
	"Mock response not implemented for POST #{inspect(url)}, #{query}, #{inspect(body)}, #{inspect(headers)}"}
	end

	# Most of the rich media mocks are missing HEAD requests, so we just return 404.
	@rich_media_mocks [
	"https://example.com/ogp",
	"https://example.com/ogp-missing-data",
	"https://example.com/twitter-card"
	]
	def head(url, _query, _body, _headers) when url in @rich_media_mocks do
	{:ok, %Tesla.Env{status: 404, body: ""}}
	end

	def head(url, query, body, headers) do
	{:error,
	"Mock response not implemented for HEAD #{inspect(url)}, #{query}, #{inspect(body)}, #{inspect(headers)}"}
	end
	end

File Metadata

Mime Type: text/x-diff
Expires: Fri, Oct 30, 8:19 AM (20 h, 22 m)
Storage Engine: blob
Storage Format: Raw Data
Storage Handle: 1799870
Default Alt Text: (82 KB)

No OneTemporaryActions

View Options

File Metadata

Event Timeline

No OneTemporary
Actions