No OneTemporary
Actions

Size

60 KB

Referenced Files

None

Subscribers

None

View Options

	diff --git a/changelog.d/rich_media.fix b/changelog.d/rich_media.fix
	new file mode 100644
	index 000000000..08f119550
	--- /dev/null
	+++ b/changelog.d/rich_media.fix
	@@ -0,0 +1 @@
	+Rich Media Preview cache eviction when the activity is updated.
	diff --git a/lib/pleroma/activity/html.ex b/lib/pleroma/activity/html.ex
	index 706b2d36c..ba284b4d5 100644
	--- a/lib/pleroma/activity/html.ex
	+++ b/lib/pleroma/activity/html.ex
	@@ -1,81 +1,81 @@
	# Pleroma: A lightweight social networking server
	# Copyright © 2017-2022 Pleroma Authors <https://pleroma.social/>
	# SPDX-License-Identifier: AGPL-3.0-only

	defmodule Pleroma.Activity.HTML do
	alias Pleroma.HTML
	alias Pleroma.Object

	@cachex Pleroma.Config.get([:cachex, :provider], Cachex)

	# We store a list of cache keys related to an activity in a
	# separate cache, scrubber_management_cache. It has the same
	# size as scrubber_cache (see application.ex). Every time we add
	# a cache to scrubber_cache, we update scrubber_management_cache.
	#
	# The most recent write of a certain key in the management cache
	# is the same as the most recent write of any record related to that
	# key in the main cache.
	# Assuming LRW ( https://hexdocs.pm/cachex/Cachex.Policy.LRW.html ),
	# this means when the management cache is evicted by cachex, all
	# related records in the main cache will also have been evicted.

	defp get_cache_keys_for(activity_id) do
	with {:ok, list} when is_list(list) <- @cachex.get(:scrubber_management_cache, activity_id) do
	list
	else
	_ -> []
	end
	end

	- defp add_cache_key_for(activity_id, additional_key) do
	+ def add_cache_key_for(activity_id, additional_key) do
	current = get_cache_keys_for(activity_id)

	unless additional_key in current do
	@cachex.put(:scrubber_management_cache, activity_id, [additional_key \| current])
	end
	end

	def invalidate_cache_for(activity_id) do
	keys = get_cache_keys_for(activity_id)
	Enum.map(keys, &@cachex.del(:scrubber_cache, &1))
	@cachex.del(:scrubber_management_cache, activity_id)
	end

	def get_cached_scrubbed_html_for_activity(
	content,
	scrubbers,
	activity,
	key \\ "",
	callback \\ fn x -> x end
	) do
	key = "#{key}#{generate_scrubber_signature(scrubbers)}\|#{activity.id}"

	@cachex.fetch!(:scrubber_cache, key, fn _key ->
	object = Object.normalize(activity, fetch: false)

	add_cache_key_for(activity.id, key)
	HTML.ensure_scrubbed_html(content, scrubbers, object.data["fake"] \|\| false, callback)
	end)
	end

	def get_cached_stripped_html_for_activity(content, activity, key) do
	get_cached_scrubbed_html_for_activity(
	content,
	FastSanitize.Sanitizer.StripTags,
	activity,
	key,
	&HtmlEntities.decode/1
	)
	end

	defp generate_scrubber_signature(scrubber) when is_atom(scrubber) do
	generate_scrubber_signature([scrubber])
	end

	defp generate_scrubber_signature(scrubbers) do
	Enum.reduce(scrubbers, "", fn scrubber, signature ->
	"#{signature}#{to_string(scrubber)}"
	end)
	end
	end
	diff --git a/lib/pleroma/html.ex b/lib/pleroma/html.ex
	index 5bf735c4f..84ff2f129 100644
	--- a/lib/pleroma/html.ex
	+++ b/lib/pleroma/html.ex
	@@ -1,93 +1,84 @@
	# Pleroma: A lightweight social networking server
	# Copyright © 2017-2022 Pleroma Authors <https://pleroma.social/>
	# SPDX-License-Identifier: AGPL-3.0-only

	defmodule Pleroma.HTML do
	# Scrubbers are compiled on boot so they can be configured in OTP releases
	# @on_load :compile_scrubbers

	- @cachex Pleroma.Config.get([:cachex, :provider], Cachex)
	-
	def compile_scrubbers do
	dir = Path.join(:code.priv_dir(:pleroma), "scrubbers")

	dir
	\|> Pleroma.Utils.compile_dir()
	\|> case do
	{:error, _errors, _warnings} ->
	raise "Compiling scrubbers failed"

	{:ok, _modules, _warnings} ->
	:ok
	end
	end

	defp get_scrubbers(scrubber) when is_atom(scrubber), do: [scrubber]
	defp get_scrubbers(scrubbers) when is_list(scrubbers), do: scrubbers
	defp get_scrubbers(_), do: [Pleroma.HTML.Scrubber.Default]

	def get_scrubbers do
	Pleroma.Config.get([:markup, :scrub_policy])
	\|> get_scrubbers
	end

	def filter_tags(html, nil) do
	filter_tags(html, get_scrubbers())
	end

	def filter_tags(html, scrubbers) when is_list(scrubbers) do
	Enum.reduce(scrubbers, html, fn scrubber, html ->
	filter_tags(html, scrubber)
	end)
	end

	def filter_tags(html, scrubber) do
	{:ok, content} = FastSanitize.Sanitizer.scrub(html, scrubber)
	content
	end

	def filter_tags(html), do: filter_tags(html, nil)
	def strip_tags(html), do: filter_tags(html, FastSanitize.Sanitizer.StripTags)

	def ensure_scrubbed_html(
	content,
	scrubbers,
	fake,
	callback
	) do
	content =
	content
	\|> filter_tags(scrubbers)
	\|> callback.()

	if fake do
	{:ignore, content}
	else
	{:commit, content}
	end
	end

	- def extract_first_external_url_from_object(%{data: %{"content" => content}} = object)
	+ @spec extract_first_external_url_from_object(Pleroma.Object.t()) ::
	+ {:ok, String.t()} \| {:error, :no_content}
	+ def extract_first_external_url_from_object(%{data: %{"content" => content}})
	when is_binary(content) do
	- unless object.data["fake"] do
	- key = "URL\|#{object.id}"
	+ url =
	+ content
	+ \|> Floki.parse_fragment!()
	+ \|> Floki.find("a:not(.mention,.hashtag,.attachment,[rel~=\"tag\"])")
	+ \|> Enum.take(1)
	+ \|> Floki.attribute("href")
	+ \|> Enum.at(0)

	- @cachex.fetch!(:scrubber_cache, key, fn _key ->
	- {:commit, {:ok, extract_first_external_url(content)}}
	- end)
	- else
	- {:ok, extract_first_external_url(content)}
	- end
	+ {:ok, url}
	end

	def extract_first_external_url_from_object(_), do: {:error, :no_content}
	-
	- def extract_first_external_url(content) do
	- content
	- \|> Floki.parse_fragment!()
	- \|> Floki.find("a:not(.mention,.hashtag,.attachment,[rel~=\"tag\"])")
	- \|> Enum.take(1)
	- \|> Floki.attribute("href")
	- \|> Enum.at(0)
	- end
	end
	diff --git a/lib/pleroma/web/rich_media/helpers.ex b/lib/pleroma/web/rich_media/helpers.ex
	index 61000bb9b..ee12a9dfb 100644
	--- a/lib/pleroma/web/rich_media/helpers.ex
	+++ b/lib/pleroma/web/rich_media/helpers.ex
	@@ -1,131 +1,150 @@
	# Pleroma: A lightweight social networking server
	# Copyright © 2017-2022 Pleroma Authors <https://pleroma.social/>
	# SPDX-License-Identifier: AGPL-3.0-only

	defmodule Pleroma.Web.RichMedia.Helpers do
	alias Pleroma.Activity
	alias Pleroma.HTML
	alias Pleroma.Object
	alias Pleroma.Web.RichMedia.Parser

	+ @cachex Pleroma.Config.get([:cachex, :provider], Cachex)
	+
	@config_impl Application.compile_env(:pleroma, [__MODULE__, :config_impl], Pleroma.Config)

	@options [
	pool: :media,
	max_body: 2_000_000,
	recv_timeout: 2_000
	]

	@spec validate_page_url(URI.t() \| binary()) :: :ok \| :error
	defp validate_page_url(page_url) when is_binary(page_url) do
	validate_tld = @config_impl.get([Pleroma.Formatter, :validate_tld])

	page_url
	\|> Linkify.Parser.url?(validate_tld: validate_tld)
	\|> parse_uri(page_url)
	end

	defp validate_page_url(%URI{host: host, scheme: "https", authority: authority})
	when is_binary(authority) do
	cond do
	host in @config_impl.get([:rich_media, :ignore_hosts], []) ->
	:error

	get_tld(host) in @config_impl.get([:rich_media, :ignore_tld], []) ->
	:error

	true ->
	:ok
	end
	end

	defp validate_page_url(_), do: :error

	defp parse_uri(true, url) do
	url
	\|> URI.parse()
	\|> validate_page_url
	end

	defp parse_uri(_, _), do: :error

	defp get_tld(host) do
	host
	\|> String.split(".")
	\|> Enum.reverse()
	\|> hd
	end

	def fetch_data_for_object(object) do
	with true <- @config_impl.get([:rich_media, :enabled]),
	{:ok, page_url} <-
	HTML.extract_first_external_url_from_object(object),
	:ok <- validate_page_url(page_url),
	{:ok, rich_media} <- Parser.parse(page_url) do
	%{page_url: page_url, rich_media: rich_media}
	else
	_ -> %{}
	end
	end

	def fetch_data_for_activity(%Activity{data: %{"type" => "Create"}} = activity) do
	with true <- @config_impl.get([:rich_media, :enabled]),
	%Object{} = object <- Object.normalize(activity, fetch: false) do
	- fetch_data_for_object(object)
	+ if object.data["fake"] do
	+ fetch_data_for_object(object)
	+ else
	+ key = "URL\|#{activity.id}"
	+
	+ @cachex.fetch!(:scrubber_cache, key, fn _ ->
	+ result = fetch_data_for_object(object)
	+
	+ cond do
	+ match?(%{page_url: _, rich_media: _}, result) ->
	+ Activity.HTML.add_cache_key_for(activity.id, key)
	+ {:commit, result}
	+
	+ true ->
	+ {:ignore, %{}}
	+ end
	+ end)
	+ end
	else
	_ -> %{}
	end
	end

	def fetch_data_for_activity(_), do: %{}

	def rich_media_get(url) do
	headers = [{"user-agent", Pleroma.Application.user_agent() <> "; Bot"}]

	head_check =
	case Pleroma.HTTP.head(url, headers, @options) do
	# If the HEAD request didn't reach the server for whatever reason,
	# we assume the GET that comes right after won't either
	{:error, _} = e ->
	e

	{:ok, %Tesla.Env{status: 200, headers: headers}} ->
	with :ok <- check_content_type(headers),
	:ok <- check_content_length(headers),
	do: :ok

	_ ->
	:ok
	end

	with :ok <- head_check, do: Pleroma.HTTP.get(url, headers, @options)
	end

	defp check_content_type(headers) do
	case List.keyfind(headers, "content-type", 0) do
	{_, content_type} ->
	case Plug.Conn.Utils.media_type(content_type) do
	{:ok, "text", "html", _} -> :ok
	_ -> {:error, {:content_type, content_type}}
	end

	_ ->
	:ok
	end
	end

	@max_body @options[:max_body]
	defp check_content_length(headers) do
	case List.keyfind(headers, "content-length", 0) do
	{_, maybe_content_length} ->
	case Integer.parse(maybe_content_length) do
	{content_length, ""} when content_length <= @max_body -> :ok
	{_, ""} -> {:error, :body_too_large}
	_ -> :ok
	end

	_ ->
	:ok
	end
	end
	end
	diff --git a/test/fixtures/rich_media/google.html b/test/fixtures/rich_media/google.html
	new file mode 100644
	index 000000000..c068397a5
	--- /dev/null
	+++ b/test/fixtures/rich_media/google.html
	@@ -0,0 +1,12 @@
	+<meta property="og:url" content="https://google.com">
	+<meta property="og:type" content="website">
	+<meta property="og:title" content="Google">
	+<meta property="og:description" content="Search the world's information, including webpages, images, videos and more. Google has many special features to help you find exactly what you're looking for.">
	+<meta property="og:image" content="">
	+
	+<meta name="twitter:card" content="summary_large_image">
	+<meta property="twitter:domain" content="google.com">
	+<meta property="twitter:url" content="https://google.com">
	+<meta name="twitter:title" content="Google">
	+<meta name="twitter:description" content="Search the world's information, including webpages, images, videos and more. Google has many special features to help you find exactly what you're looking for.">
	+<meta name="twitter:image" content="">
	diff --git a/test/fixtures/rich_media/yahoo.html b/test/fixtures/rich_media/yahoo.html
	new file mode 100644
	index 000000000..41d8c5cd9
	--- /dev/null
	+++ b/test/fixtures/rich_media/yahoo.html
	@@ -0,0 +1,12 @@
	+<meta property="og:url" content="https://yahoo.com">
	+<meta property="og:type" content="website">
	+<meta property="og:title" content="Yahoo \| Mail, Weather, Search, Politics, News, Finance, Sports & Videos">
	+<meta property="og:description" content="Latest news coverage, email, free stock quotes, live scores and video are just the beginning. Discover more every day at Yahoo!">
	+<meta property="og:image" content="https://s.yimg.com/cv/apiv2/social/images/yahoo_default_logo.png">
	+
	+<meta name="twitter:card" content="summary_large_image">
	+<meta property="twitter:domain" content="yahoo.com">
	+<meta property="twitter:url" content="https://yahoo.com">
	+<meta name="twitter:title" content="Yahoo \| Mail, Weather, Search, Politics, News, Finance, Sports & Videos">
	+<meta name="twitter:description" content="Latest news coverage, email, free stock quotes, live scores and video are just the beginning. Discover more every day at Yahoo!">
	+<meta name="twitter:image" content="https://s.yimg.com/cv/apiv2/social/images/yahoo_default_logo.png">
	diff --git a/test/pleroma/web/rich_media/helpers_test.exs b/test/pleroma/web/rich_media/helpers_test.exs
	index 3ef5705ce..8f6713ef8 100644
	--- a/test/pleroma/web/rich_media/helpers_test.exs
	+++ b/test/pleroma/web/rich_media/helpers_test.exs
	@@ -1,111 +1,139 @@
	# Pleroma: A lightweight social networking server
	# Copyright © 2017-2022 Pleroma Authors <https://pleroma.social/>
	# SPDX-License-Identifier: AGPL-3.0-only

	defmodule Pleroma.Web.RichMedia.HelpersTest do
	use Pleroma.DataCase, async: true

	alias Pleroma.StaticStubbedConfigMock, as: ConfigMock
	alias Pleroma.Web.CommonAPI
	alias Pleroma.Web.RichMedia.Helpers

	import Mox
	import Pleroma.Factory
	import Tesla.Mock

	setup do
	mock(fn env -> apply(HttpRequestMock, :request, [env]) end)

	ConfigMock
	\|> stub(:get, fn
	[:rich_media, :enabled] -> false
	path -> Pleroma.Test.StaticConfig.get(path)
	end)
	\|> stub(:get, fn
	path, default -> Pleroma.Test.StaticConfig.get(path, default)
	end)

	:ok
	end

	test "refuses to crawl incomplete URLs" do
	user = insert(:user)

	{:ok, activity} =
	CommonAPI.post(user, %{
	status: "[test](example.com/ogp)",
	content_type: "text/markdown"
	})

	ConfigMock
	\|> stub(:get, fn
	[:rich_media, :enabled] -> true
	path -> Pleroma.Test.StaticConfig.get(path)
	end)

	assert %{} == Pleroma.Web.RichMedia.Helpers.fetch_data_for_activity(activity)
	end

	test "refuses to crawl malformed URLs" do
	user = insert(:user)

	{:ok, activity} =
	CommonAPI.post(user, %{
	status: "[test](example.com[]/ogp)",
	content_type: "text/markdown"
	})

	ConfigMock
	\|> stub(:get, fn
	[:rich_media, :enabled] -> true
	path -> Pleroma.Test.StaticConfig.get(path)
	end)

	assert %{} == Pleroma.Web.RichMedia.Helpers.fetch_data_for_activity(activity)
	end

	test "crawls valid, complete URLs" do
	user = insert(:user)

	{:ok, activity} =
	CommonAPI.post(user, %{
	status: "[test](https://example.com/ogp)",
	content_type: "text/markdown"
	})

	ConfigMock
	\|> stub(:get, fn
	[:rich_media, :enabled] -> true
	path -> Pleroma.Test.StaticConfig.get(path)
	end)

	assert %{page_url: "https://example.com/ogp", rich_media: _} =
	Pleroma.Web.RichMedia.Helpers.fetch_data_for_activity(activity)
	end

	+ test "recrawls URLs on updates" do
	+ original_url = "https://google.com/"
	+ updated_url = "https://yahoo.com/"
	+
	+ Pleroma.StaticStubbedConfigMock
	+ \|> stub(:get, fn
	+ [:rich_media, :enabled] -> true
	+ path -> Pleroma.Test.StaticConfig.get(path)
	+ end)
	+
	+ user = insert(:user)
	+ {:ok, activity} = CommonAPI.post(user, %{status: "I like this site #{original_url}"})
	+
	+ assert match?(
	+ %{page_url: ^original_url, rich_media: _},
	+ Pleroma.Web.RichMedia.Helpers.fetch_data_for_activity(activity)
	+ )
	+
	+ {:ok, _} = CommonAPI.update(user, activity, %{status: "I like this site #{updated_url}"})
	+
	+ activity = Pleroma.Activity.get_by_id(activity.id)
	+
	+ assert match?(
	+ %{page_url: ^updated_url, rich_media: _},
	+ Pleroma.Web.RichMedia.Helpers.fetch_data_for_activity(activity)
	+ )
	+ end
	+
	# This does not seem to work. The urls are being fetched.
	@tag skip: true
	test "refuses to crawl URLs of private network from posts" do
	user = insert(:user)

	{:ok, activity} =
	CommonAPI.post(user, %{status: "http://127.0.0.1:4000/notice/9kCP7VNyPJXFOXDrgO"})

	{:ok, activity2} = CommonAPI.post(user, %{status: "https://10.111.10.1/notice/9kCP7V"})
	{:ok, activity3} = CommonAPI.post(user, %{status: "https://172.16.32.40/notice/9kCP7V"})
	{:ok, activity4} = CommonAPI.post(user, %{status: "https://192.168.10.40/notice/9kCP7V"})
	{:ok, activity5} = CommonAPI.post(user, %{status: "https://pleroma.local/notice/9kCP7V"})

	ConfigMock
	\|> stub(:get, fn
	[:rich_media, :enabled] -> true
	path -> Pleroma.Test.StaticConfig.get(path)
	end)

	assert %{} = Helpers.fetch_data_for_activity(activity)
	assert %{} = Helpers.fetch_data_for_activity(activity2)
	assert %{} = Helpers.fetch_data_for_activity(activity3)
	assert %{} = Helpers.fetch_data_for_activity(activity4)
	assert %{} = Helpers.fetch_data_for_activity(activity5)
	end
	end
	diff --git a/test/support/http_request_mock.ex b/test/support/http_request_mock.ex
	index f76128312..b220fd051 100644
	--- a/test/support/http_request_mock.ex
	+++ b/test/support/http_request_mock.ex
	@@ -1,1552 +1,1562 @@
	# 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.warning(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=nonexistent@social.heldscal.la",
	_,
	_,
	[{"accept", "application/xrd+xml,application/jrd+json"}]
	) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/nonexistent@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("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("https://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("https://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(
	"https://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("https://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("https://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("https://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://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://misskey.io/users/83ssedkv53", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/aimu@misskey.io.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://mk.absturztau.be/notes/93e7nm8wqg/activity", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/mk.absturztau.be-93e7nm8wqg-activity.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("https://misskey.io/notes/8vs6wxufd0", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/misskey.io_8vs6wxufd0.json"),
	headers: activitypub_object_headers()
	}}
	end

	+ def get("https://google.com/", _, _, _) do
	+ {:ok, %Tesla.Env{status: 200, body: File.read!("test/fixtures/rich_media/google.html")}}
	+ end
	+
	+ def get("https://yahoo.com/", _, _, _) do
	+ {:ok, %Tesla.Env{status: 200, body: File.read!("test/fixtures/rich_media/yahoo.html")}}
	+ 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"
	+ "https://example.com/twitter-card",
	+ "https://google.com/",
	+ "https://yahoo.com/"
	]
	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: Sat, Aug 8, 7:00 PM (1 d, 18 h)
Storage Engine: blob
Storage Format: Raw Data
Storage Handle: 1723869
Default Alt Text: (60 KB)

No OneTemporaryActions

View Options

File Metadata

Event Timeline

No OneTemporary
Actions