No OneTemporary
Actions

Authored By

Unknown

Size

103 KB

Referenced Files

None

Subscribers

None

View Options

	diff --git a/config/config.exs b/config/config.exs
	index 246712b9f..ea8869d48 100644
	--- a/config/config.exs
	+++ b/config/config.exs
	@@ -1,798 +1,802 @@
	# .i;;;;i.
	# iYcviii;vXY:
	# .YXi .i1c.
	# .YC. . in7.
	# .vc. ...... ;1c.
	# i7, .. .;1;
	# i7, .. ... .Y1i
	# ,7v .6MMM@; .YX,
	# .7;. ..IMMMMMM1 :t7.
	# .;Y. ;$MMMMMM9. :tc.
	# vY. .. .nMMM@MMU. ;1v.
	# i7i ... .#MM@M@C. .....:71i
	# it: .... $MMM@9;.,i;;;i,;tti
	# :t7. ..... 0MMMWv.,iii:::,,;St.
	# .nC. ..... IMMMQ..,::::::,.,czX.
	# .ct: ....... .ZMMMI..,:::::::,,:76Y.
	# c2: ......,i..Y$M@t..:::::::,,..inZY
	# vov ......:ii..c$MBc..,,,,,,,,,,..iI9i
	# i9Y ......iii:..7@MA,..,,,,,,,,,....;AA:
	# iIS. ......:ii::..;@MI....,............;Ez.
	# .I9. ......:i::::...8M1..................C0z.
	# .z9; ......:i::::,.. .i:...................zWX.
	# vbv ......,i::::,,. ................. :AQY
	# c6Y. .,...,::::,,..:t0@@QY. ................ :8bi
	# :6S. ..,,...,:::,,,..EMMMMMMI. ............... .;bZ,
	# :6o, .,,,,..:::,,,..i#MMMMMM#v................. YW2.
	# .n8i ..,,,,,,,::,,,,.. tMMMMM@C:.................. .1Wn
	# 7Uc. .:::,,,,,::,,,,.. i1t;,..................... .UEi
	# 7C...::::::::::::,,,,.. .................... vSi.
	# ;1;...,,::::::,......... .................. Yz:
	# v97,......... .voC.
	# izAotX7777777777777777777777777777777777777777Y7n92:
	# .;CoIIIIIUAA666666699999ZZZZZZZZZZZZZZZZZZZZ6ov.
	#
	# !!! ATTENTION !!!
	# DO NOT EDIT THIS FILE! THIS FILE CONTAINS THE DEFAULT VALUES FOR THE CON-
	# FIGURATION! EDIT YOUR SECRET FILE (either prod.secret.exs, dev.secret.exs).
	#
	# This file is responsible for configuring your application
	# and its dependencies with the aid of the Mix.Config module.
	#
	# This configuration file is loaded before any dependency and
	# is restricted to this project.
	use Mix.Config

	# General application configuration
	config :pleroma, ecto_repos: [Pleroma.Repo]

	config :pleroma, Pleroma.Repo,
	types: Pleroma.PostgresTypes,
	telemetry_event: [Pleroma.Repo.Instrumenter],
	migration_lock: nil

	config :pleroma, Pleroma.Captcha,
	enabled: true,
	seconds_valid: 300,
	method: Pleroma.Captcha.Native

	config :pleroma, Pleroma.Captcha.Kocaptcha, endpoint: "https://captcha.kotobank.ch"

	# Upload configuration
	config :pleroma, Pleroma.Upload,
	uploader: Pleroma.Uploaders.Local,
	filters: [Pleroma.Upload.Filter.Dedupe],
	link_name: false,
	proxy_remote: false,
	proxy_opts: [
	redirect_on_failure: false,
	max_body_length: 25 * 1_048_576,
	http: [
	follow_redirect: true,
	pool: :upload
	]
	],
	filename_display_max_length: 30,
	default_description: nil

	config :pleroma, Pleroma.Uploaders.Local, uploads: "uploads"

	config :pleroma, Pleroma.Uploaders.S3,
	bucket: nil,
	streaming_enabled: true,
	public_endpoint: "https://s3.amazonaws.com"

	config :pleroma, :emoji,
	shortcode_globs: ["/emoji/custom/*/.png"],
	pack_extensions: [".png", ".gif"],
	groups: [
	Custom: ["/emoji/.png", "/emoji//.png"]
	],
	default_manifest: "https://git.pleroma.social/pleroma/emoji-index/raw/master/index.json",
	shared_pack_cache_seconds_per_file: 60

	config :pleroma, :uri_schemes,
	valid_schemes: [
	"https",
	"http",
	"dat",
	"dweb",
	"gopher",
	"hyper",
	"ipfs",
	"ipns",
	"irc",
	"ircs",
	"magnet",
	"mailto",
	"mumble",
	"ssb",
	"xmpp"
	]

	websocket_config = [
	path: "/websocket",
	serializer: [
	{Phoenix.Socket.V1.JSONSerializer, "~> 1.0.0"},
	{Phoenix.Socket.V2.JSONSerializer, "~> 2.0.0"}
	],
	timeout: 60_000,
	transport_log: false,
	compress: false
	]

	# Configures the endpoint
	config :pleroma, Pleroma.Web.Endpoint,
	instrumenters: [Pleroma.Web.Endpoint.Instrumenter],
	url: [host: "localhost"],
	http: [
	ip: {127, 0, 0, 1},
	dispatch: [
	{:_,
	[
	{"/api/v1/streaming", Pleroma.Web.MastodonAPI.WebsocketHandler, []},
	{"/websocket", Phoenix.Endpoint.CowboyWebSocket,
	{Phoenix.Transports.WebSocket,
	{Pleroma.Web.Endpoint, Pleroma.Web.UserSocket, websocket_config}}},
	{:_, Phoenix.Endpoint.Cowboy2Handler, {Pleroma.Web.Endpoint, []}}
	]}
	]
	],
	protocol: "https",
	secret_key_base: "aK4Abxf29xU9TTDKre9coZPUgevcVCFQJe/5xP/7Lt4BEif6idBIbjupVbOrbKxl",
	signing_salt: "CqaoopA2",
	render_errors: [view: Pleroma.Web.ErrorView, accepts: ~w(json)],
	pubsub: [name: Pleroma.PubSub, adapter: Phoenix.PubSub.PG2],
	secure_cookie_flag: true,
	extra_cookie_attrs: [
	"SameSite=Lax"
	]

	# Configures Elixir's Logger
	config :logger, :console,
	level: :debug,
	format: "\n$time $metadata[$level] $message\n",
	metadata: [:request_id]

	config :logger, :ex_syslogger,
	level: :debug,
	ident: "pleroma",
	format: "$metadata[$level] $message",
	metadata: [:request_id]

	config :quack,
	level: :warn,
	meta: [:all],
	webhook_url: "https://hooks.slack.com/services/YOUR-KEY-HERE"

	config :mime, :types, %{
	"application/xml" => ["xml"],
	"application/xrd+xml" => ["xrd+xml"],
	"application/jrd+json" => ["jrd+json"],
	"application/activity+json" => ["activity+json"],
	"application/ld+json" => ["activity+json"]
	}

	config :tesla, adapter: Tesla.Adapter.Hackney

	# Configures http settings, upstream proxy etc.
	config :pleroma, :http,
	proxy_url: nil,
	send_user_agent: true,
	user_agent: :default,
	adapter: []

	config :pleroma, :instance,
	name: "Pleroma",
	email: "example@example.com",
	notify_email: "noreply@example.com",
	description: "Pleroma: An efficient and flexible fediverse server",
	background_image: "/images/city.jpg",
	instance_thumbnail: "/instance/thumbnail.jpeg",
	limit: 5_000,
	description_limit: 5_000,
	chat_limit: 5_000,
	remote_limit: 100_000,
	upload_limit: 16_000_000,
	avatar_upload_limit: 2_000_000,
	background_upload_limit: 4_000_000,
	banner_upload_limit: 4_000_000,
	poll_limits: %{
	max_options: 20,
	max_option_chars: 200,
	min_expiration: 0,
	max_expiration: 365 * 24 * 60 * 60
	},
	registrations_open: true,
	invites_enabled: false,
	account_activation_required: false,
	account_approval_required: false,
	federating: true,
	federation_incoming_replies_max_depth: 100,
	federation_reachability_timeout_days: 7,
	federation_publisher_modules: [
	Pleroma.Web.ActivityPub.Publisher
	],
	allow_relay: true,
	public: true,
	quarantined_instances: [],
	managed_config: true,
	static_dir: "instance/static/",
	allowed_post_formats: [
	"text/plain",
	"text/html",
	"text/markdown",
	"text/bbcode"
	],
	autofollowed_nicknames: [],
	max_pinned_statuses: 1,
	attachment_links: false,
	max_report_comment_size: 1000,
	safe_dm_mentions: false,
	healthcheck: false,
	remote_post_retention_days: 90,
	skip_thread_containment: true,
	limit_to_local_content: :unauthenticated,
	user_bio_length: 5000,
	user_name_length: 100,
	max_account_fields: 10,
	max_remote_account_fields: 20,
	account_field_name_length: 512,
	account_field_value_length: 2048,
	registration_reason_length: 500,
	external_user_synchronization: true,
	extended_nickname_format: true,
	cleanup_attachments: false,
	multi_factor_authentication: [
	totp: [
	# digits 6 or 8
	digits: 6,
	period: 30
	],
	backup_codes: [
	number: 5,
	length: 16
	]
	],
	show_reactions: true

	config :pleroma, :welcome,
	direct_message: [
	enabled: false,
	sender_nickname: nil,
	message: nil
	],
	chat_message: [
	enabled: false,
	sender_nickname: nil,
	message: nil
	],
	email: [
	enabled: false,
	sender: nil,
	subject: "Welcome to <%= instance_name %>",
	html: "Welcome to <%= instance_name %>",
	text: "Welcome to <%= instance_name %>"
	]

	config :pleroma, :feed,
	post_title: %{
	max_length: 100,
	omission: "..."
	}

	config :pleroma, :markup,
	# XXX - unfortunately, inline images must be enabled by default right now, because
	# of custom emoji. Issue #275 discusses defanging that somehow.
	allow_inline_images: true,
	allow_headings: false,
	allow_tables: false,
	allow_fonts: false,
	scrub_policy: [
	Pleroma.HTML.Scrubber.Default,
	Pleroma.HTML.Transform.MediaProxy
	]

	config :pleroma, :frontend_configurations,
	pleroma_fe: %{
	alwaysShowSubjectInput: true,
	background: "/images/city.jpg",
	collapseMessageWithSubject: false,
	disableChat: false,
	greentext: false,
	hideFilteredStatuses: false,
	hideMutedPosts: false,
	hidePostStats: false,
	hideSitename: false,
	hideUserStats: false,
	loginMethod: "password",
	logo: "/static/logo.png",
	logoMargin: ".1em",
	logoMask: true,
	minimalScopesMode: false,
	noAttachmentLinks: false,
	nsfwCensorImage: "",
	postContentType: "text/plain",
	redirectRootLogin: "/main/friends",
	redirectRootNoLogin: "/main/all",
	scopeCopy: true,
	sidebarRight: false,
	showFeaturesPanel: true,
	showInstanceSpecificPanel: false,
	subjectLineBehavior: "email",
	theme: "pleroma-dark",
	webPushNotifications: false
	},
	masto_fe: %{
	showInstanceSpecificPanel: true
	}

	config :pleroma, :assets,
	mascots: [
	pleroma_fox_tan: %{
	url: "/images/pleroma-fox-tan-smol.png",
	mime_type: "image/png"
	},
	pleroma_fox_tan_shy: %{
	url: "/images/pleroma-fox-tan-shy.png",
	mime_type: "image/png"
	}
	],
	default_mascot: :pleroma_fox_tan

	config :pleroma, :manifest,
	icons: [
	%{
	src: "/static/logo.png",
	type: "image/png"
	}
	],
	theme_color: "#282c37",
	background_color: "#191b22"

	config :pleroma, :activitypub,
	unfollow_blocked: true,
	outgoing_blocks: true,
	follow_handshake_timeout: 500,
	note_replies_output_limit: 5,
	sign_object_fetches: true,
	authorized_fetch_mode: false

	config :pleroma, :streamer,
	workers: 3,
	overflow_workers: 2

	config :pleroma, :user, deny_follow_blocked: true

	config :pleroma, :mrf_normalize_markup, scrub_policy: Pleroma.HTML.Scrubber.Default

	config :pleroma, :mrf_rejectnonpublic,
	allow_followersonly: false,
	allow_direct: false

	config :pleroma, :mrf_hellthread,
	delist_threshold: 10,
	reject_threshold: 20

	config :pleroma, :mrf_simple,
	media_removal: [],
	media_nsfw: [],
	federated_timeline_removal: [],
	report_removal: [],
	reject: [],
	followers_only: [],
	accept: [],
	avatar_removal: [],
	banner_removal: [],
	reject_deletes: []

	config :pleroma, :mrf_keyword,
	reject: [],
	federated_timeline_removal: [],
	replace: []

	config :pleroma, :mrf_subchain, match_actor: %{}

	config :pleroma, :mrf_activity_expiration, days: 365

	config :pleroma, :mrf_vocabulary,
	accept: [],
	reject: []

	# threshold of 7 days
	config :pleroma, :mrf_object_age,
	threshold: 604_800,
	actions: [:delist, :strip_followers]

	config :pleroma, :rich_media,
	enabled: true,
	ignore_hosts: [],
	ignore_tld: ["local", "localdomain", "lan"],
	parsers: [
	Pleroma.Web.RichMedia.Parsers.TwitterCard,
	Pleroma.Web.RichMedia.Parsers.OEmbed
	],
	ttl_setters: [Pleroma.Web.RichMedia.Parser.TTL.AwsSignedUrl]

	config :pleroma, :media_proxy,
	enabled: false,
	invalidation: [
	enabled: false,
	provider: Pleroma.Web.MediaProxy.Invalidation.Script
	],
	proxy_opts: [
	redirect_on_failure: false,
	max_body_length: 25 * 1_048_576,
	http: [
	follow_redirect: true,
	pool: :media
	]
	],
	whitelist: []

	config :pleroma, Pleroma.Web.MediaProxy.Invalidation.Http,
	method: :purge,
	headers: [],
	options: []

	config :pleroma, Pleroma.Web.MediaProxy.Invalidation.Script, script_path: nil

	config :pleroma, :chat, enabled: true

	config :phoenix, :format_encoders, json: Jason

	config :phoenix, :json_library, Jason

	config :phoenix, :filter_parameters, ["password", "confirm"]

	config :pleroma, :gopher,
	enabled: false,
	ip: {0, 0, 0, 0},
	port: 9999

	config :pleroma, Pleroma.Web.Metadata,
	providers: [
	Pleroma.Web.Metadata.Providers.OpenGraph,
	Pleroma.Web.Metadata.Providers.TwitterCard,
	Pleroma.Web.Metadata.Providers.RelMe,
	Pleroma.Web.Metadata.Providers.Feed
	],
	unfurl_nsfw: false

	config :pleroma, Pleroma.Web.Preload,
	providers: [
	Pleroma.Web.Preload.Providers.Instance
	]

	config :pleroma, :http_security,
	enabled: true,
	sts: false,
	sts_max_age: 31_536_000,
	ct_max_age: 2_592_000,
	referrer_policy: "same-origin"

	config :cors_plug,
	max_age: 86_400,
	methods: ["POST", "PUT", "DELETE", "GET", "PATCH", "OPTIONS"],
	expose: [
	"Link",
	"X-RateLimit-Reset",
	"X-RateLimit-Limit",
	"X-RateLimit-Remaining",
	"X-Request-Id",
	"Idempotency-Key"
	],
	credentials: true,
	headers: ["Authorization", "Content-Type", "Idempotency-Key"]

	config :pleroma, Pleroma.User,
	restricted_nicknames: [
	".well-known",
	"~",
	"about",
	"activities",
	"api",
	"auth",
	"check_password",
	"dev",
	"friend-requests",
	"inbox",
	"internal",
	"main",
	"media",
	"nodeinfo",
	"notice",
	"oauth",
	"objects",
	"ostatus_subscribe",
	"pleroma",
	"proxy",
	"push",
	"registration",
	"relay",
	"settings",
	"status",
	"tag",
	"user-search",
	"user_exists",
	"users",
	"web",
	"verify_credentials",
	"update_credentials",
	"relationships",
	"search",
	"confirmation_resend",
	"mfa"
	],
	email_blacklist: []

	config :pleroma, Oban,
	repo: Pleroma.Repo,
	log: false,
	queues: [
	activity_expiration: 10,
	federator_incoming: 50,
	federator_outgoing: 50,
	web_push: 50,
	mailer: 10,
	transmogrifier: 20,
	scheduled_activities: 10,
	background: 5,
	remote_fetcher: 2,
	attachments_cleanup: 5,
	new_users_digest: 1
	],
	plugins: [Oban.Plugins.Pruner],
	crontab: [
	{"0 0 * * *", Pleroma.Workers.Cron.ClearOauthTokenWorker},
	{"0 * * * *", Pleroma.Workers.Cron.StatsWorker},
	{"* * * * *", Pleroma.Workers.Cron.PurgeExpiredActivitiesWorker},
	{"0 0 * * 0", Pleroma.Workers.Cron.DigestEmailsWorker},
	{"0 0 * * *", Pleroma.Workers.Cron.NewUsersDigestWorker}
	]

	config :pleroma, :workers,
	retries: [
	federator_incoming: 5,
	federator_outgoing: 5
	]

	config :pleroma, Pleroma.Formatter,
	class: false,
	rel: "ugc",
	new_window: false,
	truncate: false,
	strip_prefix: false,
	extra: true,
	validate_tld: :no_scheme

	config :pleroma, :ldap,
	enabled: System.get_env("LDAP_ENABLED") == "true",
	host: System.get_env("LDAP_HOST") \|\| "localhost",
	port: String.to_integer(System.get_env("LDAP_PORT") \|\| "389"),
	ssl: System.get_env("LDAP_SSL") == "true",
	sslopts: [],
	tls: System.get_env("LDAP_TLS") == "true",
	tlsopts: [],
	base: System.get_env("LDAP_BASE") \|\| "dc=example,dc=com",
	uid: System.get_env("LDAP_UID") \|\| "cn"

	config :esshd,
	enabled: false

	oauth_consumer_strategies =
	System.get_env("OAUTH_CONSUMER_STRATEGIES")
	\|> to_string()
	\|> String.split()
	\|> Enum.map(&hd(String.split(&1, ":")))

	ueberauth_providers =
	for strategy <- oauth_consumer_strategies do
	strategy_module_name = "Elixir.Ueberauth.Strategy.#{String.capitalize(strategy)}"
	strategy_module = String.to_atom(strategy_module_name)
	{String.to_atom(strategy), {strategy_module, [callback_params: ["state"]]}}
	end

	config :ueberauth,
	Ueberauth,
	base_path: "/oauth",
	providers: ueberauth_providers

	config :pleroma,
	:auth,
	enforce_oauth_admin_scope_usage: true,
	oauth_consumer_strategies: oauth_consumer_strategies

	config :pleroma, Pleroma.Emails.Mailer, adapter: Swoosh.Adapters.Sendmail, enabled: false

	config :pleroma, Pleroma.Emails.UserEmail,
	logo: nil,
	styling: %{
	link_color: "#d8a070",
	background_color: "#2C3645",
	content_background_color: "#1B2635",
	header_color: "#d8a070",
	text_color: "#b9b9ba",
	text_muted_color: "#b9b9ba"
	}

	config :pleroma, Pleroma.Emails.NewUsersDigestEmail, enabled: false

	config :prometheus, Pleroma.Web.Endpoint.MetricsExporter, path: "/api/pleroma/app_metrics"

	config :pleroma, Pleroma.ScheduledActivity,
	daily_user_limit: 25,
	total_user_limit: 300,
	enabled: true

	config :pleroma, :email_notifications,
	digest: %{
	active: false,
	interval: 7,
	inactivity_threshold: 7
	}

	config :pleroma, :oauth2,
	token_expires_in: 600,
	issue_new_refresh_token: true,
	clean_expired_tokens: false

	config :pleroma, :database, rum_enabled: false

	config :pleroma, :env, Mix.env()

	config :http_signatures,
	adapter: Pleroma.Signature

	config :pleroma, :rate_limit,
	authentication: {60_000, 15},
	timeline: {500, 3},
	search: [{1000, 10}, {1000, 30}],
	app_account_creation: {1_800_000, 25},
	relations_actions: {10_000, 10},
	relation_id_action: {60_000, 2},
	statuses_actions: {10_000, 15},
	status_id_action: {60_000, 3},
	password_reset: {1_800_000, 5},
	account_confirmation_resend: {8_640_000, 5},
	ap_routes: {60_000, 15}

	config :pleroma, Pleroma.ActivityExpiration, enabled: true

	config :pleroma, Pleroma.Plugs.RemoteIp, enabled: true

	config :pleroma, :static_fe, enabled: false

	# Example of frontend configuration
	# This example will make us serve the primary frontend from the
	# frontends directory within your `:pleroma, :instance, static_dir`.
	# e.g., instance/static/frontends/pleroma/develop/
	#
	# With no frontend configuration, the bundled files from the `static` directory will
	# be used.
	#
	# config :pleroma, :frontends,
	# primary: %{"name" => "pleroma-fe", "ref" => "develop"},
	# admin: %{"name" => "admin-fe", "ref" => "stable"},
	# available: %{...}

	config :pleroma, :frontends,
	available: %{
	"kenoma" => %{
	"name" => "kenoma",
	"git" => "https://git.pleroma.social/lambadalambda/kenoma",
	"build_url" =>
	"https://git.pleroma.social/lambadalambda/kenoma/-/jobs/artifacts/${ref}/download?job=build",
	"ref" => "master"
	},
	"pleroma-fe" => %{
	"name" => "pleroma-fe",
	"git" => "https://git.pleroma.social/pleroma/pleroma-fe",
	"build_url" =>
	"https://git.pleroma.social/pleroma/pleroma-fe/-/jobs/artifacts/${ref}/download?job=build",
	"ref" => "develop"
	},
	"fedi-fe" => %{
	"name" => "fedi-fe",
	"git" => "https://git.pleroma.social/pleroma/fedi-fe",
	"build_url" =>
	"https://git.pleroma.social/pleroma/fedi-fe/-/jobs/artifacts/${ref}/download?job=build",
	"ref" => "master"
	},
	"admin-fe" => %{
	"name" => "admin-fe",
	"git" => "https://git.pleroma.social/pleroma/admin-fe",
	"build_url" =>
	"https://git.pleroma.social/pleroma/admin-fe/-/jobs/artifacts/${ref}/download?job=build",
	"ref" => "develop"
	},
	"soapbox-fe" => %{
	"name" => "soapbox-fe",
	"git" => "https://gitlab.com/soapbox-pub/soapbox-fe",
	"build_url" =>
	"https://gitlab.com/soapbox-pub/soapbox-fe/-/jobs/artifacts/${ref}/download?job=build-production",
	"ref" => "v1.0.0",
	"build_dir" => "static"
	}
	}

	config :pleroma, :web_cache_ttl,
	activity_pub: nil,
	activity_pub_question: 30_000

	config :pleroma, :modules, runtime_dir: "instance/modules"

	config :pleroma, configurable_from_database: false

	config :pleroma, Pleroma.Repo,
	parameters: [gin_fuzzy_search_limit: "500"],
	prepare: :unnamed

	config :pleroma, :connections_pool,
	reclaim_multiplier: 0.1,
	connection_acquisition_wait: 250,
	connection_acquisition_retries: 5,
	max_connections: 250,
	max_idle_time: 30_000,
	retry: 0,
	await_up_timeout: 5_000

	config :pleroma, :pools,
	federation: [
	size: 50,
	- max_waiting: 10
	+ max_waiting: 10,
	+ timeout: 10_000
	],
	media: [
	size: 50,
	- max_waiting: 10
	+ max_waiting: 10,
	+ timeout: 10_000
	],
	upload: [
	size: 25,
	- max_waiting: 5
	+ max_waiting: 5,
	+ timeout: 15_000
	],
	default: [
	size: 10,
	- max_waiting: 2
	+ max_waiting: 2,
	+ timeout: 5_000
	]

	config :pleroma, :hackney_pools,
	federation: [
	max_connections: 50,
	timeout: 150_000
	],
	media: [
	max_connections: 50,
	timeout: 150_000
	],
	upload: [
	max_connections: 25,
	timeout: 300_000
	]

	private_instance? = :if_instance_is_private

	config :pleroma, :restrict_unauthenticated,
	timelines: %{local: private_instance?, federated: private_instance?},
	profiles: %{local: private_instance?, remote: private_instance?},
	activities: %{local: private_instance?, remote: private_instance?}

	config :pleroma, Pleroma.Web.ApiSpec.CastAndValidate, strict: false

	config :pleroma, :mrf,
	policies: Pleroma.Web.ActivityPub.MRF.ObjectAgePolicy,
	transparency: true,
	transparency_exclusions: []

	config :tzdata, :http_client, Pleroma.HTTP.Tzdata

	config :ex_aws, http_client: Pleroma.HTTP.ExAws

	config :pleroma, :instances_favicons, enabled: false

	config :floki, :html_parser, Floki.HTMLParser.FastHtml

	config :pleroma, Pleroma.Web.Auth.Authenticator, Pleroma.Web.Auth.PleromaAuthenticator

	# Import environment specific config. This must remain at the bottom
	# of this file so it overrides the configuration defined above.
	import_config "#{Mix.env()}.exs"
	diff --git a/lib/mix/tasks/pleroma/frontend.ex b/lib/mix/tasks/pleroma/frontend.ex
	index 2adbf8d72..484af6da7 100644
	--- a/lib/mix/tasks/pleroma/frontend.ex
	+++ b/lib/mix/tasks/pleroma/frontend.ex
	@@ -1,140 +1,142 @@
	# Pleroma: A lightweight social networking server
	# Copyright © 2017-2020 Pleroma Authors <https://pleroma.social/>
	# SPDX-License-Identifier: AGPL-3.0-only

	defmodule Mix.Tasks.Pleroma.Frontend do
	use Mix.Task

	import Mix.Pleroma

	@shortdoc "Manages bundled Pleroma frontends"

	@moduledoc File.read!("docs/administration/CLI_tasks/frontend.md")

	def run(["install", "none" \| _args]) do
	shell_info("Skipping frontend installation because none was requested")
	"none"
	end

	def run(["install", frontend \| args]) do
	log_level = Logger.level()
	Logger.configure(level: :warn)
	start_pleroma()

	{options, [], []} =
	OptionParser.parse(
	args,
	strict: [
	ref: :string,
	static_dir: :string,
	build_url: :string,
	build_dir: :string,
	file: :string
	]
	)

	instance_static_dir =
	with nil <- options[:static_dir] do
	Pleroma.Config.get!([:instance, :static_dir])
	end

	cmd_frontend_info = %{
	"name" => frontend,
	"ref" => options[:ref],
	"build_url" => options[:build_url],
	"build_dir" => options[:build_dir]
	}

	config_frontend_info = Pleroma.Config.get([:frontends, :available, frontend], %{})

	frontend_info =
	Map.merge(config_frontend_info, cmd_frontend_info, fn _key, config, cmd ->
	# This only overrides things that are actually set
	cmd \|\| config
	end)

	ref = frontend_info["ref"]

	unless ref do
	raise "No ref given or configured"
	end

	dest =
	Path.join([
	instance_static_dir,
	"frontends",
	frontend,
	ref
	])

	fe_label = "#{frontend} (#{ref})"

	tmp_dir = Path.join(dest, "tmp")

	with {_, :ok} <-
	{:download_or_unzip, download_or_unzip(frontend_info, tmp_dir, options[:file])},
	shell_info("Installing #{fe_label} to #{dest}"),
	:ok <- install_frontend(frontend_info, tmp_dir, dest) do
	File.rm_rf!(tmp_dir)
	shell_info("Frontend #{fe_label} installed to #{dest}")

	Logger.configure(level: log_level)
	else
	{:download_or_unzip, _} ->
	shell_info("Could not download or unzip the frontend")

	_e ->
	shell_info("Could not install the frontend")
	end
	end

	defp download_or_unzip(frontend_info, temp_dir, file) do
	if file do
	with {:ok, zip} <- File.read(Path.expand(file)) do
	unzip(zip, temp_dir)
	end
	else
	download_build(frontend_info, temp_dir)
	end
	end

	def unzip(zip, dest) do
	with {:ok, unzipped} <- :zip.unzip(zip, [:memory]) do
	File.rm_rf!(dest)
	File.mkdir_p!(dest)

	Enum.each(unzipped, fn {filename, data} ->
	path = filename

	new_file_path = Path.join(dest, path)

	new_file_path
	\|> Path.dirname()
	\|> File.mkdir_p!()

	File.write!(new_file_path, data)
	end)

	:ok
	end
	end

	defp download_build(frontend_info, dest) do
	shell_info("Downloading pre-built bundle for #{frontend_info["name"]}")
	url = String.replace(frontend_info["build_url"], "${ref}", frontend_info["ref"])

	with {:ok, %{status: 200, body: zip_body}} <-
	- Pleroma.HTTP.get(url, [], timeout: 120_000, recv_timeout: 120_000) do
	+ Pleroma.HTTP.get(url, [],
	+ adapter: [pool: :media, timeout: 120_000, recv_timeout: 120_000]
	+ ) do
	unzip(zip_body, dest)
	else
	e -> {:error, e}
	end
	end

	defp install_frontend(frontend_info, source, dest) do
	from = frontend_info["build_dir"] \|\| "dist"
	File.mkdir_p!(dest)
	File.cp_r!(Path.join([source, from]), dest)
	:ok
	end
	end
	diff --git a/lib/pleroma/gun/connection_pool/worker.ex b/lib/pleroma/gun/connection_pool/worker.ex
	index fec9d0efa..c36332817 100644
	--- a/lib/pleroma/gun/connection_pool/worker.ex
	+++ b/lib/pleroma/gun/connection_pool/worker.ex
	@@ -1,133 +1,146 @@
	defmodule Pleroma.Gun.ConnectionPool.Worker do
	alias Pleroma.Gun
	use GenServer, restart: :temporary

	@registry Pleroma.Gun.ConnectionPool

	def start_link([key \| _] = opts) do
	GenServer.start_link(__MODULE__, opts, name: {:via, Registry, {@registry, key}})
	end

	@impl true
	def init([_key, _uri, _opts, _client_pid] = opts) do
	{:ok, nil, {:continue, {:connect, opts}}}
	end

	@impl true
	def handle_continue({:connect, [key, uri, opts, client_pid]}, _) do
	with {:ok, conn_pid} <- Gun.Conn.open(uri, opts),
	Process.link(conn_pid) do
	time = :erlang.monotonic_time(:millisecond)

	{_, _} =
	Registry.update_value(@registry, key, fn _ ->
	{conn_pid, [client_pid], 1, time}
	end)

	send(client_pid, {:conn_pid, conn_pid})

	{:noreply,
	%{key: key, timer: nil, client_monitors: %{client_pid => Process.monitor(client_pid)}},
	:hibernate}
	else
	err ->
	{:stop, {:shutdown, err}, nil}
	end
	end

	@impl true
	def handle_cast({:add_client, client_pid}, state) do
	case handle_call(:add_client, {client_pid, nil}, state) do
	{:reply, conn_pid, state, :hibernate} ->
	send(client_pid, {:conn_pid, conn_pid})
	{:noreply, state, :hibernate}
	end
	end

	@impl true
	def handle_cast({:remove_client, client_pid}, state) do
	case handle_call(:remove_client, {client_pid, nil}, state) do
	{:reply, _, state, :hibernate} ->
	{:noreply, state, :hibernate}
	end
	end

	@impl true
	def handle_call(:add_client, {client_pid, _}, %{key: key} = state) do
	time = :erlang.monotonic_time(:millisecond)

	{{conn_pid, _, _, _}, _} =
	Registry.update_value(@registry, key, fn {conn_pid, used_by, crf, last_reference} ->
	{conn_pid, [client_pid \| used_by], crf(time - last_reference, crf), time}
	end)

	state =
	if state.timer != nil do
	Process.cancel_timer(state[:timer])
	%{state \| timer: nil}
	else
	state
	end

	ref = Process.monitor(client_pid)

	state = put_in(state.client_monitors[client_pid], ref)
	{:reply, conn_pid, state, :hibernate}
	end

	@impl true
	def handle_call(:remove_client, {client_pid, _}, %{key: key} = state) do
	{{_conn_pid, used_by, _crf, _last_reference}, _} =
	Registry.update_value(@registry, key, fn {conn_pid, used_by, crf, last_reference} ->
	{conn_pid, List.delete(used_by, client_pid), crf, last_reference}
	end)

	{ref, state} = pop_in(state.client_monitors[client_pid])
	- Process.demonitor(ref)
	-
	- timer =
	- if used_by == [] do
	- max_idle = Pleroma.Config.get([:connections_pool, :max_idle_time], 30_000)
	- Process.send_after(self(), :idle_close, max_idle)
	+ # DOWN message can receive right after `remove_client` call and cause worker to terminate
	+ state =
	+ if is_nil(ref) do
	+ state
	else
	- nil
	+ Process.demonitor(ref)
	+
	+ timer =
	+ if used_by == [] do
	+ max_idle = Pleroma.Config.get([:connections_pool, :max_idle_time], 30_000)
	+ Process.send_after(self(), :idle_close, max_idle)
	+ else
	+ nil
	+ end
	+
	+ %{state \| timer: timer}
	end

	- {:reply, :ok, %{state \| timer: timer}, :hibernate}
	+ {:reply, :ok, state, :hibernate}
	end

	@impl true
	def handle_info(:idle_close, state) do
	# Gun monitors the owner process, and will close the connection automatically
	# when it's terminated
	{:stop, :normal, state}
	end

	+ @impl true
	+ def handle_info({:gun_up, _pid, _protocol}, state) do
	+ {:noreply, state, :hibernate}
	+ end
	+
	# Gracefully shutdown if the connection got closed without any streams left
	@impl true
	def handle_info({:gun_down, _pid, _protocol, _reason, []}, state) do
	{:stop, :normal, state}
	end

	- # Otherwise, shutdown with an error
	+ # Otherwise, wait for retry
	@impl true
	- def handle_info({:gun_down, _pid, _protocol, _reason, _killed_streams} = down_message, state) do
	- {:stop, {:error, down_message}, state}
	+ def handle_info({:gun_down, _pid, _protocol, _reason, _killed_streams}, state) do
	+ {:noreply, state, :hibernate}
	end

	@impl true
	def handle_info({:DOWN, _ref, :process, pid, reason}, state) do
	:telemetry.execute(
	[:pleroma, :connection_pool, :client_death],
	%{client_pid: pid, reason: reason},
	%{key: state.key}
	)

	handle_cast({:remove_client, pid}, state)
	end

	# LRFU policy: https://citeseerx.ist.psu.edu/viewdoc/summary?doi=10.1.1.55.1478
	defp crf(time_delta, prev_crf) do
	1 + :math.pow(0.5, 0.0001 * time_delta) * prev_crf
	end
	end
	diff --git a/lib/pleroma/http/adapter_helper.ex b/lib/pleroma/http/adapter_helper.ex
	index 9ec3836b0..0728cbaa2 100644
	--- a/lib/pleroma/http/adapter_helper.ex
	+++ b/lib/pleroma/http/adapter_helper.ex
	@@ -1,140 +1,125 @@
	# Pleroma: A lightweight social networking server
	# Copyright © 2017-2020 Pleroma Authors <https://pleroma.social/>
	# SPDX-License-Identifier: AGPL-3.0-only

	defmodule Pleroma.HTTP.AdapterHelper do
	@moduledoc """
	Configure Tesla.Client with default and customized adapter options.
	"""
	@defaults [pool: :federation]

	@type proxy_type() :: :socks4 \| :socks5
	@type host() :: charlist() \| :inet.ip_address()

	- alias Pleroma.Config
	alias Pleroma.HTTP.AdapterHelper
	require Logger

	@type proxy ::
	{Connection.host(), pos_integer()}
	\| {Connection.proxy_type(), Connection.host(), pos_integer()}

	@callback options(keyword(), URI.t()) :: keyword()
	@callback get_conn(URI.t(), keyword()) :: {:ok, term()} \| {:error, term()}

	@spec format_proxy(String.t() \| tuple() \| nil) :: proxy() \| nil
	def format_proxy(nil), do: nil

	def format_proxy(proxy_url) do
	case parse_proxy(proxy_url) do
	{:ok, host, port} -> {host, port}
	{:ok, type, host, port} -> {type, host, port}
	_ -> nil
	end
	end

	@spec maybe_add_proxy(keyword(), proxy() \| nil) :: keyword()
	def maybe_add_proxy(opts, nil), do: opts
	def maybe_add_proxy(opts, proxy), do: Keyword.put_new(opts, :proxy, proxy)

	@doc """
	Merge default connection & adapter options with received ones.
	"""

	@spec options(URI.t(), keyword()) :: keyword()
	def options(%URI{} = uri, opts \\ []) do
	@defaults
	- \|> put_timeout()
	\|> Keyword.merge(opts)
	\|> adapter_helper().options(uri)
	end

	- # For Hackney, this is the time a connection can stay idle in the pool.
	- # For Gun, this is the timeout to receive a message from Gun.
	- defp put_timeout(opts) do
	- {config_key, default} =
	- if adapter() == Tesla.Adapter.Gun do
	- {:pools, Config.get([:pools, :default, :timeout], 5_000)}
	- else
	- {:hackney_pools, 10_000}
	- end
	-
	- timeout = Config.get([config_key, opts[:pool], :timeout], default)
	-
	- Keyword.merge(opts, timeout: timeout)
	- end
	-
	+ @spec get_conn(URI.t(), keyword()) :: {:ok, keyword()} \| {:error, atom()}
	def get_conn(uri, opts), do: adapter_helper().get_conn(uri, opts)
	+
	defp adapter, do: Application.get_env(:tesla, :adapter)

	defp adapter_helper do
	case adapter() do
	Tesla.Adapter.Gun -> AdapterHelper.Gun
	Tesla.Adapter.Hackney -> AdapterHelper.Hackney
	_ -> AdapterHelper.Default
	end
	end

	@spec parse_proxy(String.t() \| tuple() \| nil) ::
	{:ok, host(), pos_integer()}
	\| {:ok, proxy_type(), host(), pos_integer()}
	\| {:error, atom()}
	\| nil

	def parse_proxy(nil), do: nil

	def parse_proxy(proxy) when is_binary(proxy) do
	with [host, port] <- String.split(proxy, ":"),
	{port, ""} <- Integer.parse(port) do
	{:ok, parse_host(host), port}
	else
	{_, _} ->
	Logger.warn("Parsing port failed #{inspect(proxy)}")
	{:error, :invalid_proxy_port}

	:error ->
	Logger.warn("Parsing port failed #{inspect(proxy)}")
	{:error, :invalid_proxy_port}

	_ ->
	Logger.warn("Parsing proxy failed #{inspect(proxy)}")
	{:error, :invalid_proxy}
	end
	end

	def parse_proxy(proxy) when is_tuple(proxy) do
	with {type, host, port} <- proxy do
	{:ok, type, parse_host(host), port}
	else
	_ ->
	Logger.warn("Parsing proxy failed #{inspect(proxy)}")
	{:error, :invalid_proxy}
	end
	end

	@spec parse_host(String.t() \| atom() \| charlist()) :: charlist() \| :inet.ip_address()
	def parse_host(host) when is_list(host), do: host
	def parse_host(host) when is_atom(host), do: to_charlist(host)

	def parse_host(host) when is_binary(host) do
	host = to_charlist(host)

	case :inet.parse_address(host) do
	{:error, :einval} -> host
	{:ok, ip} -> ip
	end
	end

	@spec format_host(String.t()) :: charlist()
	def format_host(host) do
	host_charlist = to_charlist(host)

	case :inet.parse_address(host_charlist) do
	{:error, :einval} ->
	:idna.encode(host_charlist)

	{:ok, _ip} ->
	host_charlist
	end
	end
	end
	diff --git a/lib/pleroma/http/adapter_helper/gun.ex b/lib/pleroma/http/adapter_helper/gun.ex
	index b4ff8306c..02e20f2d1 100644
	--- a/lib/pleroma/http/adapter_helper/gun.ex
	+++ b/lib/pleroma/http/adapter_helper/gun.ex
	@@ -1,78 +1,93 @@
	# Pleroma: A lightweight social networking server
	# Copyright © 2017-2020 Pleroma Authors <https://pleroma.social/>
	# SPDX-License-Identifier: AGPL-3.0-only

	defmodule Pleroma.HTTP.AdapterHelper.Gun do
	@behaviour Pleroma.HTTP.AdapterHelper

	+ alias Pleroma.Config
	alias Pleroma.Gun.ConnectionPool
	alias Pleroma.HTTP.AdapterHelper

	require Logger

	@defaults [
	connect_timeout: 5_000,
	domain_lookup_timeout: 5_000,
	tls_handshake_timeout: 5_000,
	- retry: 0,
	+ retry: 1,
	retry_timeout: 1000,
	await_up_timeout: 5_000
	]

	+ @type pool() :: :federation \| :upload \| :media \| :default
	+
	@spec options(keyword(), URI.t()) :: keyword()
	def options(incoming_opts \\ [], %URI{} = uri) do
	proxy =
	- Pleroma.Config.get([:http, :proxy_url])
	+ [:http, :proxy_url]
	+ \|> Config.get()
	\|> AdapterHelper.format_proxy()

	- config_opts = Pleroma.Config.get([:http, :adapter], [])
	+ config_opts = Config.get([:http, :adapter], [])

	@defaults
	\|> Keyword.merge(config_opts)
	\|> add_scheme_opts(uri)
	\|> AdapterHelper.maybe_add_proxy(proxy)
	\|> Keyword.merge(incoming_opts)
	+ \|> put_timeout()
	end

	defp add_scheme_opts(opts, %{scheme: "http"}), do: opts

	defp add_scheme_opts(opts, %{scheme: "https"}) do
	- opts
	- \|> Keyword.put(:certificates_verification, true)
	+ Keyword.put(opts, :certificates_verification, true)
	+ end
	+
	+ defp put_timeout(opts) do
	+ # this is the timeout to receive a message from Gun
	+ Keyword.put_new(opts, :timeout, pool_timeout(opts[:pool]))
	+ end
	+
	+ @spec pool_timeout(pool()) :: non_neg_integer()
	+ def pool_timeout(pool) do
	+ default = Config.get([:pools, :default, :timeout], 5_000)
	+
	+ Config.get([:pools, pool, :timeout], default)
	end

	@spec get_conn(URI.t(), keyword()) :: {:ok, keyword()} \| {:error, atom()}
	def get_conn(uri, opts) do
	case ConnectionPool.get_conn(uri, opts) do
	{:ok, conn_pid} -> {:ok, Keyword.merge(opts, conn: conn_pid, close_conn: false)}
	err -> err
	end
	end

	@prefix Pleroma.Gun.ConnectionPool
	def limiter_setup do
	- wait = Pleroma.Config.get([:connections_pool, :connection_acquisition_wait])
	- retries = Pleroma.Config.get([:connections_pool, :connection_acquisition_retries])
	+ wait = Config.get([:connections_pool, :connection_acquisition_wait])
	+ retries = Config.get([:connections_pool, :connection_acquisition_retries])

	:pools
	- \|> Pleroma.Config.get([])
	+ \|> Config.get([])
	\|> Enum.each(fn {name, opts} ->
	max_running = Keyword.get(opts, :size, 50)
	max_waiting = Keyword.get(opts, :max_waiting, 10)

	result =
	ConcurrentLimiter.new(:"#{@prefix}.#{name}", max_running, max_waiting,
	wait: wait,
	max_retries: retries
	)

	case result do
	:ok -> :ok
	{:error, :existing} -> :ok
	- e -> raise e
	end
	end)

	:ok
	end
	end
	diff --git a/lib/pleroma/http/ex_aws.ex b/lib/pleroma/http/ex_aws.ex
	index e53e64077..c3f335c73 100644
	--- a/lib/pleroma/http/ex_aws.ex
	+++ b/lib/pleroma/http/ex_aws.ex
	@@ -1,22 +1,24 @@
	# Pleroma: A lightweight social networking server
	# Copyright © 2017-2020 Pleroma Authors <https://pleroma.social/>
	# SPDX-License-Identifier: AGPL-3.0-only

	defmodule Pleroma.HTTP.ExAws do
	@moduledoc false

	@behaviour ExAws.Request.HttpClient

	alias Pleroma.HTTP

	@impl true
	def request(method, url, body \\ "", headers \\ [], http_opts \\ []) do
	+ http_opts = Keyword.put_new(http_opts, :adapter, pool: :upload)
	+
	case HTTP.request(method, url, body, headers, http_opts) do
	{:ok, env} ->
	{:ok, %{status_code: env.status, headers: env.headers, body: env.body}}

	{:error, reason} ->
	{:error, %{reason: reason}}
	end
	end
	end
	diff --git a/lib/pleroma/http/tzdata.ex b/lib/pleroma/http/tzdata.ex
	index 34bb253a7..4539ac359 100644
	--- a/lib/pleroma/http/tzdata.ex
	+++ b/lib/pleroma/http/tzdata.ex
	@@ -1,25 +1,29 @@
	# Pleroma: A lightweight social networking server
	# Copyright © 2017-2020 Pleroma Authors <https://pleroma.social/>
	# SPDX-License-Identifier: AGPL-3.0-only

	defmodule Pleroma.HTTP.Tzdata do
	@moduledoc false

	@behaviour Tzdata.HTTPClient

	alias Pleroma.HTTP

	@impl true
	def get(url, headers, options) do
	+ options = Keyword.put_new(options, :adapter, pool: :default)
	+
	with {:ok, %Tesla.Env{} = env} <- HTTP.get(url, headers, options) do
	{:ok, {env.status, env.headers, env.body}}
	end
	end

	@impl true
	def head(url, headers, options) do
	+ options = Keyword.put_new(options, :adapter, pool: :default)
	+
	with {:ok, %Tesla.Env{} = env} <- HTTP.head(url, headers, options) do
	{:ok, {env.status, env.headers}}
	end
	end
	end
	diff --git a/lib/pleroma/instances/instance.ex b/lib/pleroma/instances/instance.ex
	index a1f935232..711c42158 100644
	--- a/lib/pleroma/instances/instance.ex
	+++ b/lib/pleroma/instances/instance.ex
	@@ -1,169 +1,171 @@
	# Pleroma: A lightweight social networking server
	# Copyright © 2017-2020 Pleroma Authors <https://pleroma.social/>
	# SPDX-License-Identifier: AGPL-3.0-only

	defmodule Pleroma.Instances.Instance do
	@moduledoc "Instance."

	alias Pleroma.Instances
	alias Pleroma.Instances.Instance
	alias Pleroma.Repo

	use Ecto.Schema

	import Ecto.Query
	import Ecto.Changeset

	schema "instances" do
	field(:host, :string)
	field(:unreachable_since, :naive_datetime_usec)
	field(:favicon, :string)
	field(:favicon_updated_at, :naive_datetime)

	timestamps()
	end

	defdelegate host(url_or_host), to: Instances

	def changeset(struct, params \\ %{}) do
	struct
	\|> cast(params, [:host, :unreachable_since, :favicon, :favicon_updated_at])
	\|> validate_required([:host])
	\|> unique_constraint(:host)
	end

	def filter_reachable([]), do: %{}

	def filter_reachable(urls_or_hosts) when is_list(urls_or_hosts) do
	hosts =
	urls_or_hosts
	\|> Enum.map(&(&1 && host(&1)))
	\|> Enum.filter(&(to_string(&1) != ""))

	unreachable_since_by_host =
	Repo.all(
	from(i in Instance,
	where: i.host in ^hosts,
	select: {i.host, i.unreachable_since}
	)
	)
	\|> Map.new(& &1)

	reachability_datetime_threshold = Instances.reachability_datetime_threshold()

	for entry <- Enum.filter(urls_or_hosts, &is_binary/1) do
	host = host(entry)
	unreachable_since = unreachable_since_by_host[host]

	if !unreachable_since \|\|
	NaiveDateTime.compare(unreachable_since, reachability_datetime_threshold) == :gt do
	{entry, unreachable_since}
	end
	end
	\|> Enum.filter(& &1)
	\|> Map.new(& &1)
	end

	def reachable?(url_or_host) when is_binary(url_or_host) do
	!Repo.one(
	from(i in Instance,
	where:
	i.host == ^host(url_or_host) and
	i.unreachable_since <= ^Instances.reachability_datetime_threshold(),
	select: true
	)
	)
	end

	def reachable?(_), do: true

	def set_reachable(url_or_host) when is_binary(url_or_host) do
	with host <- host(url_or_host),
	%Instance{} = existing_record <- Repo.get_by(Instance, %{host: host}) do
	{:ok, _instance} =
	existing_record
	\|> changeset(%{unreachable_since: nil})
	\|> Repo.update()
	end
	end

	def set_reachable(_), do: {:error, nil}

	def set_unreachable(url_or_host, unreachable_since \\ nil)

	def set_unreachable(url_or_host, unreachable_since) when is_binary(url_or_host) do
	unreachable_since = parse_datetime(unreachable_since) \|\| NaiveDateTime.utc_now()
	host = host(url_or_host)
	existing_record = Repo.get_by(Instance, %{host: host})

	changes = %{unreachable_since: unreachable_since}

	cond do
	is_nil(existing_record) ->
	%Instance{}
	\|> changeset(Map.put(changes, :host, host))
	\|> Repo.insert()

	existing_record.unreachable_since &&
	NaiveDateTime.compare(existing_record.unreachable_since, unreachable_since) != :gt ->
	{:ok, existing_record}

	true ->
	existing_record
	\|> changeset(changes)
	\|> Repo.update()
	end
	end

	def set_unreachable(_, _), do: {:error, nil}

	defp parse_datetime(datetime) when is_binary(datetime) do
	NaiveDateTime.from_iso8601(datetime)
	end

	defp parse_datetime(datetime), do: datetime

	def get_or_update_favicon(%URI{host: host} = instance_uri) do
	existing_record = Repo.get_by(Instance, %{host: host})
	now = NaiveDateTime.utc_now()

	if existing_record && existing_record.favicon_updated_at &&
	NaiveDateTime.diff(now, existing_record.favicon_updated_at) < 86_400 do
	existing_record.favicon
	else
	favicon = scrape_favicon(instance_uri)

	if existing_record do
	existing_record
	\|> changeset(%{favicon: favicon, favicon_updated_at: now})
	\|> Repo.update()
	else
	%Instance{}
	\|> changeset(%{host: host, favicon: favicon, favicon_updated_at: now})
	\|> Repo.insert()
	end

	favicon
	end
	end

	defp scrape_favicon(%URI{} = instance_uri) do
	try do
	with {:ok, %Tesla.Env{body: html}} <-
	- Pleroma.HTTP.get(to_string(instance_uri), [{:Accept, "text/html"}]),
	+ Pleroma.HTTP.get(to_string(instance_uri), [{"accept", "text/html"}],
	+ adapter: [pool: :media]
	+ ),
	favicon_rel <-
	html
	\|> Floki.parse_document!()
	\|> Floki.attribute("link[rel=icon]", "href")
	\|> List.first(),
	favicon <- URI.merge(instance_uri, favicon_rel) \|> to_string(),
	true <- is_binary(favicon) do
	favicon
	else
	_ -> nil
	end
	rescue
	_ -> nil
	end
	end
	end
	diff --git a/lib/pleroma/object/fetcher.ex b/lib/pleroma/object/fetcher.ex
	index 6fdbc8efd..374d8704a 100644
	--- a/lib/pleroma/object/fetcher.ex
	+++ b/lib/pleroma/object/fetcher.ex
	@@ -1,222 +1,222 @@
	# Pleroma: A lightweight social networking server
	# Copyright © 2017-2020 Pleroma Authors <https://pleroma.social/>
	# SPDX-License-Identifier: AGPL-3.0-only

	defmodule Pleroma.Object.Fetcher do
	alias Pleroma.HTTP
	alias Pleroma.Object
	alias Pleroma.Object.Containment
	alias Pleroma.Repo
	alias Pleroma.Signature
	alias Pleroma.Web.ActivityPub.InternalFetchActor
	alias Pleroma.Web.ActivityPub.ObjectValidator
	alias Pleroma.Web.ActivityPub.Transmogrifier
	alias Pleroma.Web.Federator

	require Logger
	require Pleroma.Constants

	defp touch_changeset(changeset) do
	updated_at =
	NaiveDateTime.utc_now()
	\|> NaiveDateTime.truncate(:second)

	Ecto.Changeset.put_change(changeset, :updated_at, updated_at)
	end

	defp maybe_reinject_internal_fields(%{data: %{} = old_data}, new_data) do
	internal_fields = Map.take(old_data, Pleroma.Constants.object_internal_fields())

	Map.merge(new_data, internal_fields)
	end

	defp maybe_reinject_internal_fields(_, new_data), do: new_data

	@spec reinject_object(struct(), map()) :: {:ok, Object.t()} \| {:error, any()}
	defp reinject_object(%Object{data: %{"type" => "Question"}} = object, new_data) do
	Logger.debug("Reinjecting object #{new_data["id"]}")

	with new_data <- Transmogrifier.fix_object(new_data),
	data <- maybe_reinject_internal_fields(object, new_data),
	{:ok, data, _} <- ObjectValidator.validate(data, %{}),
	changeset <- Object.change(object, %{data: data}),
	changeset <- touch_changeset(changeset),
	{:ok, object} <- Repo.insert_or_update(changeset),
	{:ok, object} <- Object.set_cache(object) do
	{:ok, object}
	else
	e ->
	Logger.error("Error while processing object: #{inspect(e)}")
	{:error, e}
	end
	end

	defp reinject_object(%Object{} = object, new_data) do
	Logger.debug("Reinjecting object #{new_data["id"]}")

	with new_data <- Transmogrifier.fix_object(new_data),
	data <- maybe_reinject_internal_fields(object, new_data),
	changeset <- Object.change(object, %{data: data}),
	changeset <- touch_changeset(changeset),
	{:ok, object} <- Repo.insert_or_update(changeset),
	{:ok, object} <- Object.set_cache(object) do
	{:ok, object}
	else
	e ->
	Logger.error("Error while processing object: #{inspect(e)}")
	{:error, e}
	end
	end

	def refetch_object(%Object{data: %{"id" => id}} = object) do
	with {:local, false} <- {:local, Object.local?(object)},
	{:ok, new_data} <- fetch_and_contain_remote_object_from_id(id),
	{:ok, object} <- reinject_object(object, new_data) do
	{:ok, object}
	else
	{:local, true} -> {:ok, object}
	e -> {:error, e}
	end
	end

	# Note: will create a Create activity, which we need internally at the moment.
	def fetch_object_from_id(id, options \\ []) do
	with {_, nil} <- {:fetch_object, Object.get_cached_by_ap_id(id)},
	{_, true} <- {:allowed_depth, Federator.allowed_thread_distance?(options[:depth])},
	{_, {:ok, data}} <- {:fetch, fetch_and_contain_remote_object_from_id(id)},
	{_, nil} <- {:normalize, Object.normalize(data, false)},
	params <- prepare_activity_params(data),
	{_, :ok} <- {:containment, Containment.contain_origin(id, params)},
	{_, {:ok, activity}} <-
	{:transmogrifier, Transmogrifier.handle_incoming(params, options)},
	{_, _data, %Object{} = object} <-
	{:object, data, Object.normalize(activity, false)} do
	{:ok, object}
	else
	{:allowed_depth, false} ->
	{:error, "Max thread distance exceeded."}

	{:containment, _} ->
	{:error, "Object containment failed."}

	{:transmogrifier, {:error, {:reject, nil}}} ->
	{:reject, nil}

	{:transmogrifier, _} = e ->
	{:error, e}

	{:object, data, nil} ->
	reinject_object(%Object{}, data)

	{:normalize, object = %Object{}} ->
	{:ok, object}

	{:fetch_object, %Object{} = object} ->
	{:ok, object}

	{:fetch, {:error, error}} ->
	{:error, error}

	e ->
	e
	end
	end

	defp prepare_activity_params(data) do
	%{
	"type" => "Create",
	"to" => data["to"] \|\| [],
	"cc" => data["cc"] \|\| [],
	# Should we seriously keep this attributedTo thing?
	"actor" => data["actor"] \|\| data["attributedTo"],
	"object" => data
	}
	end

	def fetch_object_from_id!(id, options \\ []) do
	with {:ok, object} <- fetch_object_from_id(id, options) do
	object
	else
	{:error, %Tesla.Mock.Error{}} ->
	nil

	{:error, "Object has been deleted"} ->
	nil

	{:reject, reason} ->
	Logger.info("Rejected #{id} while fetching: #{inspect(reason)}")
	nil

	e ->
	Logger.error("Error while fetching #{id}: #{inspect(e)}")
	nil
	end
	end

	defp make_signature(id, date) do
	uri = URI.parse(id)

	signature =
	InternalFetchActor.get_actor()
	\|> Signature.sign(%{
	"(request-target)": "get #{uri.path}",
	host: uri.host,
	date: date
	})

	- [{"signature", signature}]
	+ {"signature", signature}
	end

	defp sign_fetch(headers, id, date) do
	if Pleroma.Config.get([:activitypub, :sign_object_fetches]) do
	- headers ++ make_signature(id, date)
	+ [make_signature(id, date) \| headers]
	else
	headers
	end
	end

	defp maybe_date_fetch(headers, date) do
	if Pleroma.Config.get([:activitypub, :sign_object_fetches]) do
	- headers ++ [{"date", date}]
	+ [{"date", date} \| headers]
	else
	headers
	end
	end

	def fetch_and_contain_remote_object_from_id(id) when is_binary(id) do
	Logger.debug("Fetching object #{id} via AP")

	date = Pleroma.Signature.signed_date()

	headers =
	[{"accept", "application/activity+json"}]
	\|> maybe_date_fetch(date)
	\|> sign_fetch(id, date)

	Logger.debug("Fetch headers: #{inspect(headers)}")

	with {:scheme, true} <- {:scheme, String.starts_with?(id, "http")},
	{:ok, %{body: body, status: code}} when code in 200..299 <- HTTP.get(id, headers),
	{:ok, data} <- Jason.decode(body),
	:ok <- Containment.contain_origin_from_id(id, data) do
	{:ok, data}
	else
	{:ok, %{status: code}} when code in [404, 410] ->
	{:error, "Object has been deleted"}

	{:scheme, _} ->
	{:error, "Unsupported URI scheme"}

	{:error, e} ->
	{:error, e}

	e ->
	{:error, e}
	end
	end

	def fetch_and_contain_remote_object_from_id(%{"id" => id}),
	do: fetch_and_contain_remote_object_from_id(id)

	def fetch_and_contain_remote_object_from_id(_id), do: {:error, "id must be a string"}
	end
	diff --git a/lib/pleroma/uploaders/s3.ex b/lib/pleroma/uploaders/s3.ex
	index a13ff23b6..6dbef9085 100644
	--- a/lib/pleroma/uploaders/s3.ex
	+++ b/lib/pleroma/uploaders/s3.ex
	@@ -1,90 +1,101 @@
	# Pleroma: A lightweight social networking server
	# Copyright © 2017-2020 Pleroma Authors <https://pleroma.social/>
	# SPDX-License-Identifier: AGPL-3.0-only

	defmodule Pleroma.Uploaders.S3 do
	@behaviour Pleroma.Uploaders.Uploader
	require Logger

	alias Pleroma.Config

	# The file name is re-encoded with S3's constraints here to comply with previous
	# links with less strict filenames
	@impl true
	def get_file(file) do
	config = Config.get([__MODULE__])
	bucket = Keyword.fetch!(config, :bucket)

	bucket_with_namespace =
	cond do
	truncated_namespace = Keyword.get(config, :truncated_namespace) ->
	truncated_namespace

	namespace = Keyword.get(config, :bucket_namespace) ->
	namespace <> ":" <> bucket

	true ->
	bucket
	end

	{:ok,
	{:url,
	Path.join([
	Keyword.fetch!(config, :public_endpoint),
	bucket_with_namespace,
	strict_encode(URI.decode(file))
	])}}
	end

	@impl true
	def put_file(%Pleroma.Upload{} = upload) do
	config = Config.get([__MODULE__])
	bucket = Keyword.get(config, :bucket)
	streaming = Keyword.get(config, :streaming_enabled)

	s3_name = strict_encode(upload.path)

	op =
	if streaming do
	- upload.tempfile
	- \|> ExAws.S3.Upload.stream_file()
	- \|> ExAws.S3.upload(bucket, s3_name, [
	- {:acl, :public_read},
	- {:content_type, upload.content_type}
	- ])
	+ op =
	+ upload.tempfile
	+ \|> ExAws.S3.Upload.stream_file()
	+ \|> ExAws.S3.upload(bucket, s3_name, [
	+ {:acl, :public_read},
	+ {:content_type, upload.content_type}
	+ ])
	+
	+ if Application.get_env(:tesla, :adapter) == Tesla.Adapter.Gun do
	+ # set s3 upload timeout to respect :upload pool timeout
	+ # timeout should be slightly larger, so s3 can retry upload on fail
	+ timeout = Pleroma.HTTP.AdapterHelper.Gun.pool_timeout(:upload) + 1_000
	+ opts = Keyword.put(op.opts, :timeout, timeout)
	+ Map.put(op, :opts, opts)
	+ else
	+ op
	+ end
	else
	{:ok, file_data} = File.read(upload.tempfile)

	ExAws.S3.put_object(bucket, s3_name, file_data, [
	{:acl, :public_read},
	{:content_type, upload.content_type}
	])
	end

	case ExAws.request(op) do
	{:ok, _} ->
	{:ok, {:file, s3_name}}

	error ->
	Logger.error("#{__MODULE__}: #{inspect(error)}")
	{:error, "S3 Upload failed"}
	end
	end

	@impl true
	def delete_file(file) do
	[__MODULE__, :bucket]
	\|> Config.get()
	\|> ExAws.S3.delete_object(file)
	\|> ExAws.request()
	\|> case do
	{:ok, %{status_code: 204}} -> :ok
	error -> {:error, inspect(error)}
	end
	end

	@regex Regex.compile!("[^0-9a-zA-Z!.*/'()_-]")
	def strict_encode(name) do
	String.replace(name, @regex, "-")
	end
	end
	diff --git a/lib/pleroma/web/rich_media/helpers.ex b/lib/pleroma/web/rich_media/helpers.ex
	index 6210f2c5a..2fb482b51 100644
	--- a/lib/pleroma/web/rich_media/helpers.ex
	+++ b/lib/pleroma/web/rich_media/helpers.ex
	@@ -1,101 +1,101 @@
	# Pleroma: A lightweight social networking server
	# Copyright _ 2017-2020 Pleroma Authors <https://pleroma.social/>
	# SPDX-License-Identifier: AGPL-3.0-only

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

	@rich_media_options [
	pool: :media,
	max_body: 2_000_000
	]

	@spec validate_page_url(URI.t() \| binary()) :: :ok \| :error
	defp validate_page_url(page_url) when is_binary(page_url) do
	validate_tld = Pleroma.Config.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.get([:rich_media, :ignore_hosts], []) ->
	:error

	get_tld(host) in Config.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.get([:rich_media, :enabled]),
	false <- object.data["sensitive"] \|\| false,
	{:ok, page_url} <-
	HTML.extract_first_external_url(object, object.data["content"]),
	: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.get([:rich_media, :enabled]),
	%Object{} = object <- Object.normalize(activity) do
	fetch_data_for_object(object)
	else
	_ -> %{}
	end
	end

	def fetch_data_for_activity(_), do: %{}

	def perform(:fetch, %Activity{} = activity) do
	fetch_data_for_activity(activity)
	:ok
	end

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

	options =
	if Application.get_env(:tesla, :adapter) == Tesla.Adapter.Hackney do
	Keyword.merge(@rich_media_options,
	recv_timeout: 2_000,
	with_body: true
	)
	else
	@rich_media_options
	end

	- Pleroma.HTTP.get(url, headers, options)
	+ Pleroma.HTTP.get(url, headers, adapter: options)
	end
	end
	diff --git a/lib/pleroma/web/web_finger/web_finger.ex b/lib/pleroma/web/web_finger/web_finger.ex
	index c4051e63e..6629f5356 100644
	--- a/lib/pleroma/web/web_finger/web_finger.ex
	+++ b/lib/pleroma/web/web_finger/web_finger.ex
	@@ -1,201 +1,201 @@
	# Pleroma: A lightweight social networking server
	# Copyright © 2017-2020 Pleroma Authors <https://pleroma.social/>
	# SPDX-License-Identifier: AGPL-3.0-only

	defmodule Pleroma.Web.WebFinger do
	alias Pleroma.HTTP
	alias Pleroma.User
	alias Pleroma.Web
	alias Pleroma.Web.Federator.Publisher
	alias Pleroma.Web.XML
	alias Pleroma.XmlBuilder
	require Jason
	require Logger

	def host_meta do
	base_url = Web.base_url()

	{
	:XRD,
	%{xmlns: "http://docs.oasis-open.org/ns/xri/xrd-1.0"},
	{
	:Link,
	%{
	rel: "lrdd",
	type: "application/xrd+xml",
	template: "#{base_url}/.well-known/webfinger?resource={uri}"
	}
	}
	}
	\|> XmlBuilder.to_doc()
	end

	def webfinger(resource, fmt) when fmt in ["XML", "JSON"] do
	host = Pleroma.Web.Endpoint.host()
	regex = ~r/(acct:)?(?<username>[a-z0-9A-Z_\.-]+)@#{host}/

	with %{"username" => username} <- Regex.named_captures(regex, resource),
	%User{} = user <- User.get_cached_by_nickname(username) do
	{:ok, represent_user(user, fmt)}
	else
	_e ->
	with %User{} = user <- User.get_cached_by_ap_id(resource) do
	{:ok, represent_user(user, fmt)}
	else
	_e ->
	{:error, "Couldn't find user"}
	end
	end
	end

	defp gather_links(%User{} = user) do
	[
	%{
	"rel" => "http://webfinger.net/rel/profile-page",
	"type" => "text/html",
	"href" => user.ap_id
	}
	] ++ Publisher.gather_webfinger_links(user)
	end

	def represent_user(user, "JSON") do
	{:ok, user} = User.ensure_keys_present(user)

	%{
	"subject" => "acct:#{user.nickname}@#{Pleroma.Web.Endpoint.host()}",
	"aliases" => [user.ap_id],
	"links" => gather_links(user)
	}
	end

	def represent_user(user, "XML") do
	{:ok, user} = User.ensure_keys_present(user)

	links =
	gather_links(user)
	\|> Enum.map(fn link -> {:Link, link} end)

	{
	:XRD,
	%{xmlns: "http://docs.oasis-open.org/ns/xri/xrd-1.0"},
	[
	{:Subject, "acct:#{user.nickname}@#{Pleroma.Web.Endpoint.host()}"},
	{:Alias, user.ap_id}
	] ++ links
	}
	\|> XmlBuilder.to_doc()
	end

	defp webfinger_from_xml(doc) do
	subject = XML.string_from_xpath("//Subject", doc)

	subscribe_address =
	~s{//Link[@rel="http://ostatus.org/schema/1.0/subscribe"]/@template}
	\|> XML.string_from_xpath(doc)

	ap_id =
	~s{//Link[@rel="self" and @type="application/activity+json"]/@href}
	\|> XML.string_from_xpath(doc)

	data = %{
	"subject" => subject,
	"subscribe_address" => subscribe_address,
	"ap_id" => ap_id
	}

	{:ok, data}
	end

	defp webfinger_from_json(doc) do
	data =
	Enum.reduce(doc["links"], %{"subject" => doc["subject"]}, fn link, data ->
	case {link["type"], link["rel"]} do
	{"application/activity+json", "self"} ->
	Map.put(data, "ap_id", link["href"])

	{"application/ld+json; profile=\"https://www.w3.org/ns/activitystreams\"", "self"} ->
	Map.put(data, "ap_id", link["href"])

	_ ->
	Logger.debug("Unhandled type: #{inspect(link["type"])}")
	data
	end
	end)

	{:ok, data}
	end

	def get_template_from_xml(body) do
	xpath = "//Link[@rel='lrdd']/@template"

	with doc when doc != :error <- XML.parse_document(body),
	template when template != nil <- XML.string_from_xpath(xpath, doc) do
	{:ok, template}
	end
	end

	def find_lrdd_template(domain) do
	with {:ok, %{status: status, body: body}} when status in 200..299 <-
	- HTTP.get("http://#{domain}/.well-known/host-meta", []) do
	+ HTTP.get("http://#{domain}/.well-known/host-meta") do
	get_template_from_xml(body)
	else
	_ ->
	with {:ok, %{body: body, status: status}} when status in 200..299 <-
	- HTTP.get("https://#{domain}/.well-known/host-meta", []) do
	+ HTTP.get("https://#{domain}/.well-known/host-meta") do
	get_template_from_xml(body)
	else
	e -> {:error, "Can't find LRDD template: #{inspect(e)}"}
	end
	end
	end

	defp get_address_from_domain(domain, encoded_account) when is_binary(domain) do
	case find_lrdd_template(domain) do
	{:ok, template} ->
	String.replace(template, "{uri}", encoded_account)

	_ ->
	"https://#{domain}/.well-known/webfinger?resource=#{encoded_account}"
	end
	end

	defp get_address_from_domain(_, _), do: nil

	@spec finger(String.t()) :: {:ok, map()} \| {:error, any()}
	def finger(account) do
	account = String.trim_leading(account, "@")

	domain =
	with [_name, domain] <- String.split(account, "@") do
	domain
	else
	_e ->
	URI.parse(account).host
	end

	encoded_account = URI.encode("acct:#{account}")

	with address when is_binary(address) <- get_address_from_domain(domain, encoded_account),
	response <-
	HTTP.get(
	address,
	[{"accept", "application/xrd+xml,application/jrd+json"}]
	),
	{:ok, %{status: status, body: body}} when status in 200..299 <- response do
	doc = XML.parse_document(body)

	if doc != :error do
	webfinger_from_xml(doc)
	else
	with {:ok, doc} <- Jason.decode(body) do
	webfinger_from_json(doc)
	end
	end
	else
	e ->
	Logger.debug(fn -> "Couldn't finger #{account}" end)
	Logger.debug(fn -> inspect(e) end)
	{:error, e}
	end
	end
	end
	diff --git a/test/support/http_request_mock.ex b/test/support/http_request_mock.ex
	index eeeba7880..a0ebf65d9 100644
	--- a/test/support/http_request_mock.ex
	+++ b/test/support/http_request_mock.ex
	@@ -1,1439 +1,1439 @@
	# Pleroma: A lightweight social networking server
	# Copyright © 2017-2020 Pleroma Authors <https://pleroma.social/>
	# SPDX-License-Identifier: AGPL-3.0-only

	defmodule HttpRequestMock do
	require Logger

	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")
	}}
	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")
	}}
	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")
	}}
	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")
	}}
	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")
	}}
	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")
	}}
	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")
	}}
	end

	def get("https://mastodon.social/users/emelie.atom", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/emelie.atom")
	}}
	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")
	}}
	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/users/pekorino.atom", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/https___pawoo.net_users_pekorino.atom")
	}}
	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/api/statuses/user_timeline/18330.atom",
	_,
	_,
	_
	) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/atarifrosch_feed.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://mamot.fr/users/Skruyb.atom", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/https___mamot.fr_users_Skruyb.atom")
	}}
	end

	def get(
	"https://mamot.fr/.well-known/webfinger?resource=acct:https://mamot.fr/users/Skruyb",
	_,
	_,
	[{"accept", "application/xrd+xml,application/jrd+json"}]
	) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/skruyb@mamot.fr.atom")
	}}
	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")
	}}
	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")
	}}
	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")
	}}
	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")
	}}
	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")
	}}
	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")
	}}
	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")
	}}
	end

	def get("https://peertube.moe/accounts/7even", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/7even.json")
	}}
	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")
	}}
	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")
	}}
	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")
	}}
	end

	def get("https://peertube.social/accounts/craigmaloney", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/craigmaloney.json")
	}}
	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")
	}}
	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")
	}}
	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")
	}}
	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")
	}}
	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")
	}}
	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")
	}}
	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")
	}}
	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")
	}}
	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")
	}}
	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(
	"https://mamot.fr/.well-known/webfinger?resource=https://mamot.fr/users/Skruyb",
	_,
	_,
	_
	) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/skruyb@mamot.fr.atom")
	}}
	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")
	}}
	end

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

	def get("https://zetsubou.xn--q9jyb4c/.well-known/host-meta", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/xn--q9jyb4c_host_meta")
	}}
	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")
	}}
	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")
	}}
	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")
	}}
	end

	def get("https://pleroma.soykaf.com/users/lain/feed.atom", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body:
	File.read!(
	"test/fixtures/tesla_mock/https___pleroma.soykaf.com_users_lain_feed.atom.xml"
	)
	}}
	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/api/statuses/user_timeline/1.atom", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body:
	File.read!(
	"test/fixtures/tesla_mock/https___shitposter.club_api_statuses_user_timeline_1.atom.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://shitposter.club/notice/2827873", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/https___shitposter.club_notice_2827873.json")
	}}
	end

	def get("https://shitposter.club/api/statuses/show/2827873.atom", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body:
	File.read!(
	"test/fixtures/tesla_mock/https___shitposter.club_api_statuses_show_2827873.atom.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/api/statuses/user_timeline/5381.atom", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/spc_5381.atom")
	}}
	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/api/statuses/show/7369654.atom", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/7369654.atom")
	}}
	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("https://social.sakamoto.gq/users/eal/feed.atom", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/tesla_mock/sakamoto_eal_feed.atom")
	}}
	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(
	"https://social.sakamoto.gq/objects/0ccc1a2c-66b0-4305-b23a-7f7f2b040056",
	_,
	_,
	[{"accept", "application/atom+xml"}]
	) do
	{:ok, %Tesla.Env{status: 200, body: File.read!("test/fixtures/tesla_mock/sakamoto.atom")}}
	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("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://gs.example.org/index.php/api/statuses/user_timeline/1.atom", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body:
	File.read!(
	"test/fixtures/tesla_mock/http__gs.example.org_index.php_api_statuses_user_timeline_1.atom.xml"
	)
	}}
	end

	def get("https://social.heldscal.la/api/statuses/user_timeline/29191.atom", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body:
	File.read!(
	"test/fixtures/tesla_mock/https___social.heldscal.la_api_statuses_user_timeline_29191.atom.xml"
	)
	}}
	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")
	}}
	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: ""}}
	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/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")
	}}
	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/json"}],
	body: File.read!("test/fixtures/tesla_mock/kaniini@gerzilla.de.json")
	}}
	end

	def get("https://social.heldscal.la/api/statuses/user_timeline/23211.atom", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body:
	File.read!(
	"test/fixtures/tesla_mock/https___social.heldscal.la_api_statuses_user_timeline_23211.atom.xml"
	)
	}}
	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.atom", _, _, _) do
	{:ok, %Tesla.Env{status: 200, body: File.read!("test/fixtures/lambadalambda.atom")}}
	end

	def get("https://mastodon.social/users/lambadalambda", _, _, _) do
	{:ok, %Tesla.Env{status: 200, body: File.read!("test/fixtures/lambadalambda.json")}}
	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")}}
	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")
	}}
	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")
	}}
	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")
	}}
	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")
	}}
	end

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

	def get("http://localhost:8080/following/fuser3", _, _, _) do
	{:ok,
	%Tesla.Env{
	status: 200,
	body: File.read!("test/fixtures/users_mock/friendica_following.json")
	}}
	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")
	}}
	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")
	}}
	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")
	}}
	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")
	}}
	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("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")
	}}
	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")
	}}
	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")
	}}
	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")
	}}
	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")}}
	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")
	}}
	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")}}
	end

	def get("https://patch.cx/users/rin", _, _, _) do
	{:ok, %Tesla.Env{status: 200, body: File.read!("test/fixtures/tesla_mock/rin.json")}}
	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")}}
	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")}}
	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")}}
	end

	- def get("http://localhost:4001/", _, "", Accept: "text/html") do
	+ 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
	+ 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(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
	end

File Metadata

Mime Type: text/x-diff
Expires: Fri, Oct 30, 6:02 PM (15 h, 12 m)
Storage Engine: blob
Storage Format: Raw Data
Storage Handle: 1800387
Default Alt Text: (103 KB)

No OneTemporaryActions

View Options

File Metadata

Event Timeline

No OneTemporary
Actions