No OneTemporary
Actions

Size

27 KB

Referenced Files

None

Subscribers

None

View Options

	diff --git a/lib/pleroma/activity/pruner.ex b/lib/pleroma/activity/pruner.ex
	index 7f561ebae..54a40b534 100644
	--- a/lib/pleroma/activity/pruner.ex
	+++ b/lib/pleroma/activity/pruner.ex
	@@ -1,52 +1,61 @@
	defmodule Pleroma.Activity.Pruner do
	@moduledoc """
	Prunes activities from the database.
	"""
	@cutoff 30

	alias Pleroma.Activity
	alias Pleroma.Repo
	import Ecto.Query

	def prune_deletes do
	before_time = cutoff()

	from(a in Activity,
	where: fragment("?->>'type' = ?", a.data, "Delete") and a.inserted_at < ^before_time
	)
	\|> Repo.delete_all(timeout: :infinity)
	end

	def prune_undos do
	before_time = cutoff()

	from(a in Activity,
	where: fragment("?->>'type' = ?", a.data, "Undo") and a.inserted_at < ^before_time
	)
	\|> Repo.delete_all(timeout: :infinity)
	end

	+ def prune_updates do
	+ before_time = cutoff()
	+
	+ from(a in Activity,
	+ where: fragment("?->>'type' = ?", a.data, "Update") and a.inserted_at < ^before_time
	+ )
	+ \|> Repo.delete_all(timeout: :infinity)
	+ end
	+
	def prune_removes do
	before_time = cutoff()

	from(a in Activity,
	where: fragment("?->>'type' = ?", a.data, "Remove") and a.inserted_at < ^before_time
	)
	\|> Repo.delete_all(timeout: :infinity)
	end

	def prune_stale_follow_requests do
	before_time = cutoff()

	from(a in Activity,
	where:
	fragment("?->>'type' = ?", a.data, "Follow") and a.inserted_at < ^before_time and
	fragment("?->>'state' = ?", a.data, "reject")
	)
	\|> Repo.delete_all(timeout: :infinity)
	end

	defp cutoff do
	DateTime.utc_now() \|> Timex.shift(days: -@cutoff)
	end
	end
	diff --git a/lib/pleroma/workers/cron/database_prune_worker.ex b/lib/pleroma/workers/cron/database_prune_worker.ex
	index 58995c69a..ced4b27b7 100644
	--- a/lib/pleroma/workers/cron/database_prune_worker.ex
	+++ b/lib/pleroma/workers/cron/database_prune_worker.ex
	@@ -1,35 +1,38 @@
	defmodule Pleroma.Workers.Cron.PruneDatabaseWorker do
	@moduledoc """
	The worker to prune old data from the database.
	"""
	require Logger
	use Oban.Worker, queue: "database_prune"

	alias Pleroma.Activity.Pruner, as: ActivityPruner
	alias Pleroma.Object.Pruner, as: ObjectPruner

	@impl Oban.Worker
	def perform(_job) do
	Logger.info("Pruning old data from the database")

	Logger.info("Pruning old deletes")
	ActivityPruner.prune_deletes()

	Logger.info("Pruning old follow requests")
	ActivityPruner.prune_stale_follow_requests()

	Logger.info("Pruning old undos")
	ActivityPruner.prune_undos()

	+ Logger.info("Pruning old updates")
	+ ActivityPruner.prune_updates()
	+
	Logger.info("Pruning old removes")
	ActivityPruner.prune_removes()

	Logger.info("Pruning old tombstone delivery entries")
	ObjectPruner.prune_tombstoned_deliveries()

	Logger.info("Pruning old tombstones")
	ObjectPruner.prune_tombstones()

	:ok
	end
	end
	diff --git a/test/pleroma/activity/pruner_test.exs b/test/pleroma/activity/pruner_test.exs
	index e8d4b30aa..26db60c1c 100644
	--- a/test/pleroma/activity/pruner_test.exs
	+++ b/test/pleroma/activity/pruner_test.exs
	@@ -1,63 +1,93 @@
	defmodule Pleroma.Activity.PrunerTest do
	use Pleroma.DataCase, async: true

	alias Pleroma.Activity
	alias Pleroma.Activity.Pruner

	import Pleroma.Factory

	- describe "prune_deletes" do
	- test "it prunes old delete objects" do
	+ describe "prune_transient_activities" do
	+ test "it prunes old transient activities" do
	user = insert(:user)
	+ old_time = DateTime.utc_now() \|> DateTime.add(-31 * 24, :hour)

	new_delete = insert(:delete_activity, type: "Delete", user: user)

	old_delete =
	insert(:delete_activity,
	- type: "Delete",
	user: user,
	- inserted_at: DateTime.utc_now() \|> DateTime.add(-31 * 24, :hour)
	+ inserted_at: old_time
	)

	+ new_update = insert(:update_activity, type: "Update", user: user)
	+
	+ old_update =
	+ insert(:update_activity,
	+ type: "Update",
	+ user: user,
	+ inserted_at: old_time
	+ )
	+
	+ new_undo = insert(:undo_activity)
	+
	+ old_undo = insert(:undo_activity, inserted_at: old_time)
	+
	+ new_remove = insert(:remove_activity)
	+
	+ old_remove = insert(:remove_activity, inserted_at: old_time)
	+
	Pruner.prune_deletes()
	+ Pruner.prune_updates()
	+ Pruner.prune_undos()
	+ Pruner.prune_removes()
	+
	assert Activity.get_by_id(new_delete.id)
	refute Activity.get_by_id(old_delete.id)
	+
	+ assert Activity.get_by_id(new_update.id)
	+ refute Activity.get_by_id(old_update.id)
	+
	+ assert Activity.get_by_id(new_undo.id)
	+ refute Activity.get_by_id(old_undo.id)
	+
	+ assert Activity.get_by_id(new_remove.id)
	+ refute Activity.get_by_id(old_remove.id)
	end
	end

	describe "prune_stale_follow_requests" do
	test "it prunes old follow requests" do
	follower = insert(:user)
	followee = insert(:user)

	new_follow_request =
	insert(
	:follow_activity,
	follower: follower,
	followed: followee,
	state: "reject"
	)

	old_not_rejected_request =
	insert(:follow_activity,
	follower: follower,
	followed: followee,
	state: "pending",
	inserted_at: DateTime.utc_now() \|> DateTime.add(-31 * 24, :hour)
	)

	old_follow_request =
	insert(:follow_activity,
	follower: follower,
	followed: followee,
	inserted_at: DateTime.utc_now() \|> DateTime.add(-31 * 24, :hour),
	state: "reject"
	)

	Pruner.prune_stale_follow_requests()
	assert Activity.get_by_id(new_follow_request.id)
	assert Activity.get_by_id(old_not_rejected_request.id)
	refute Activity.get_by_id(old_follow_request.id)
	end
	end
	end
	diff --git a/test/support/factory.ex b/test/support/factory.ex
	index 42c940c52..e21b8fc1e 100644
	--- a/test/support/factory.ex
	+++ b/test/support/factory.ex
	@@ -1,730 +1,779 @@
	# Pleroma: A lightweight social networking server
	# Copyright © 2017-2021 Pleroma Authors <https://pleroma.social/>
	# SPDX-License-Identifier: AGPL-3.0-only

	defmodule Pleroma.Factory do
	use ExMachina.Ecto, repo: Pleroma.Repo

	require Pleroma.Constants

	alias Pleroma.Object
	alias Pleroma.User
	+ alias Pleroma.Web.ActivityPub.UserView

	@rsa_keys [
	"test/fixtures/rsa_keys/key_1.pem",
	"test/fixtures/rsa_keys/key_2.pem",
	"test/fixtures/rsa_keys/key_3.pem",
	"test/fixtures/rsa_keys/key_4.pem",
	"test/fixtures/rsa_keys/key_5.pem"
	]
	\|> Enum.map(&File.read!/1)

	def participation_factory do
	conversation = insert(:conversation)
	user = insert(:user)

	%Pleroma.Conversation.Participation{
	conversation: conversation,
	user: user,
	read: false
	}
	end

	def conversation_factory do
	%Pleroma.Conversation{
	ap_id: sequence(:ap_id, &"https://some_conversation/#{&1}")
	}
	end

	def instance_factory(attrs \\ %{}) do
	%Pleroma.Instances.Instance{
	host: attrs[:domain] \|\| "example.com",
	nodeinfo: %{version: "2.0", openRegistrations: true},
	unreachable_since: nil
	}
	\|> Map.merge(attrs)
	end

	def user_factory(attrs \\ %{}) do
	pem = Enum.random(@rsa_keys)
	# Argon2.hash_pwd_salt("test")
	# it really eats CPU time, so we use a precomputed hash
	password_hash =
	"$argon2id$v=19$m=65536,t=8,p=2$FEAarFuiOsROO24NHIHMYw$oxdaz2fTPpuU+dYCl60FsqE65T1Tjy6lGikKfmql4xo"

	user = %User{
	name: sequence(:name, &"Test テスト User #{&1}"),
	email: sequence(:email, &"user#{&1}@example.com"),
	nickname: sequence(:nickname, &"nick#{&1}"),
	password_hash: password_hash,
	bio: sequence(:bio, &"Tester Number #{&1}"),
	is_discoverable: true,
	last_digest_emailed_at: NaiveDateTime.utc_now(),
	last_refreshed_at: NaiveDateTime.utc_now(),
	notification_settings: %Pleroma.User.NotificationSetting{},
	multi_factor_authentication_settings: %Pleroma.MFA.Settings{},
	ap_enabled: true,
	keys: pem
	}

	urls =
	if attrs[:local] == false do
	base_domain = attrs[:domain] \|\| Enum.random(["domain1.com", "domain2.com", "domain3.com"])

	ap_id = "https://#{base_domain}/users/#{user.nickname}"

	%{
	ap_id: ap_id,
	follower_address: ap_id <> "/followers",
	following_address: ap_id <> "/following",
	featured_address: ap_id <> "/collections/featured"
	}
	else
	%{
	ap_id: User.ap_id(user),
	follower_address: User.ap_followers(user),
	following_address: User.ap_following(user),
	featured_address: User.ap_featured_collection(user)
	}
	end

	attrs = Map.delete(attrs, :domain)

	user
	\|> Map.put(:raw_bio, user.bio)
	\|> Map.merge(urls)
	\|> merge_attributes(attrs)
	end

	def user_relationship_factory(attrs \\ %{}) do
	source = attrs[:source] \|\| insert(:user)
	target = attrs[:target] \|\| insert(:user)
	relationship_type = attrs[:relationship_type] \|\| :block

	%Pleroma.UserRelationship{
	source_id: source.id,
	target_id: target.id,
	relationship_type: relationship_type
	}
	end

	def note_factory(attrs \\ %{}) do
	text = sequence(:text, &"This is :moominmamma: note #{&1}")

	user = attrs[:user] \|\| insert(:user)

	data = %{
	"type" => "Note",
	"content" => text,
	"source" => text,
	"id" => Pleroma.Web.ActivityPub.Utils.generate_object_id(),
	"actor" => user.ap_id,
	"to" => ["https://www.w3.org/ns/activitystreams#Public"],
	"published" => DateTime.utc_now() \|> DateTime.to_iso8601(),
	"likes" => [],
	"like_count" => 0,
	"context" => "2hu",
	"summary" => "2hu",
	"tag" => ["2hu"],
	"emoji" => %{
	"2hu" => "corndog.png"
	}
	}

	%Pleroma.Object{
	data: merge_attributes(data, Map.get(attrs, :data, %{}))
	}
	end

	def attachment_factory(attrs \\ %{}) do
	user = attrs[:user] \|\| insert(:user)

	data =
	attachment_data(user.ap_id, nil)
	\|> Map.put("id", Pleroma.Web.ActivityPub.Utils.generate_object_id())

	%Pleroma.Object{
	data: merge_attributes(data, Map.get(attrs, :data, %{}))
	}
	end

	def attachment_note_factory(attrs \\ %{}) do
	user = attrs[:user] \|\| insert(:user)
	{length, attrs} = Map.pop(attrs, :length, 1)

	data = %{
	"attachment" =>
	Stream.repeatedly(fn -> attachment_data(user.ap_id, attrs[:href]) end)
	\|> Enum.take(length)
	}

	build(:note, Map.put(attrs, :data, data))
	end

	defp attachment_data(ap_id, href) do
	href = href \|\| sequence(:href, &"#{Pleroma.Web.Endpoint.url()}/media/#{&1}.jpg")

	%{
	"url" => [
	%{
	"href" => href,
	"type" => "Link",
	"mediaType" => "image/jpeg"
	}
	],
	"name" => "some name",
	"type" => "Document",
	"actor" => ap_id,
	"mediaType" => "image/jpeg"
	}
	end

	def followers_only_note_factory(attrs \\ %{}) do
	%Pleroma.Object{data: data} = note_factory(attrs)
	%Pleroma.Object{data: Map.merge(data, %{"to" => [data["actor"] <> "/followers"]})}
	end

	def audio_factory(attrs \\ %{}) do
	text = sequence(:text, &"lain radio episode #{&1}")

	user = attrs[:user] \|\| insert(:user)

	data = %{
	"type" => "Audio",
	"id" => Pleroma.Web.ActivityPub.Utils.generate_object_id(),
	"artist" => "lain",
	"title" => text,
	"album" => "lain radio",
	"to" => ["https://www.w3.org/ns/activitystreams#Public"],
	"published" => DateTime.utc_now() \|> DateTime.to_iso8601(),
	"actor" => user.ap_id,
	"length" => 180_000
	}

	%Pleroma.Object{
	data: merge_attributes(data, Map.get(attrs, :data, %{}))
	}
	end

	def listen_factory do
	audio = insert(:audio)

	data = %{
	"id" => Pleroma.Web.ActivityPub.Utils.generate_activity_id(),
	"type" => "Listen",
	"actor" => audio.data["actor"],
	"to" => audio.data["to"],
	"object" => audio.data,
	"published" => audio.data["published"]
	}

	%Pleroma.Activity{
	data: data,
	actor: data["actor"],
	recipients: data["to"]
	}
	end

	def direct_note_factory do
	user2 = insert(:user)

	%Pleroma.Object{data: data} = note_factory()
	%Pleroma.Object{data: Map.merge(data, %{"to" => [user2.ap_id]})}
	end

	def article_factory do
	%Pleroma.Object{data: data} = note_factory()
	%Pleroma.Object{data: Map.merge(data, %{"type" => "Article"})}
	end

	def tombstone_factory(attrs) do
	data = %{
	"type" => "Tombstone",
	"id" => Pleroma.Web.ActivityPub.Utils.generate_object_id(),
	"formerType" => "Note",
	"deleted" => DateTime.utc_now() \|> DateTime.to_iso8601()
	}

	%Pleroma.Object{
	data: data
	}
	\|> merge_attributes(attrs)
	end

	def question_factory(attrs \\ %{}) do
	user = attrs[:user] \|\| insert(:user)

	data = %{
	"id" => Pleroma.Web.ActivityPub.Utils.generate_object_id(),
	"type" => "Question",
	"actor" => user.ap_id,
	"attributedTo" => user.ap_id,
	"attachment" => [],
	"to" => ["https://www.w3.org/ns/activitystreams#Public"],
	"cc" => [user.follower_address],
	"context" => Pleroma.Web.ActivityPub.Utils.generate_context_id(),
	"closed" => DateTime.utc_now() \|> DateTime.add(86_400) \|> DateTime.to_iso8601(),
	"oneOf" => [
	%{
	"type" => "Note",
	"name" => "chocolate",
	"replies" => %{"totalItems" => 0, "type" => "Collection"}
	},
	%{
	"type" => "Note",
	"name" => "vanilla",
	"replies" => %{"totalItems" => 0, "type" => "Collection"}
	}
	]
	}

	%Pleroma.Object{
	data: merge_attributes(data, Map.get(attrs, :data, %{}))
	}
	end

	def direct_note_activity_factory do
	dm = insert(:direct_note)

	data = %{
	"id" => Pleroma.Web.ActivityPub.Utils.generate_activity_id(),
	"type" => "Create",
	"actor" => dm.data["actor"],
	"to" => dm.data["to"],
	"object" => dm.data,
	"published" => DateTime.utc_now() \|> DateTime.to_iso8601(),
	"context" => dm.data["context"]
	}

	%Pleroma.Activity{
	data: data,
	actor: data["actor"],
	recipients: data["to"]
	}
	end

	def add_activity_factory(attrs \\ %{}) do
	featured_collection_activity(attrs, "Add")
	end

	- def remove_activity_factor(attrs \\ %{}) do
	+ def remove_activity_factory(attrs \\ %{}) do
	featured_collection_activity(attrs, "Remove")
	end

	defp featured_collection_activity(attrs, type) do
	user = attrs[:user] \|\| insert(:user)
	note = attrs[:note] \|\| insert(:note, user: user)

	data_attrs =
	attrs
	\|> Map.get(:data_attrs, %{})
	\|> Map.put(:type, type)

	attrs = Map.drop(attrs, [:user, :note, :data_attrs])

	data =
	%{
	"id" => Pleroma.Web.ActivityPub.Utils.generate_activity_id(),
	"target" => user.featured_address,
	"object" => note.data["object"],
	"actor" => note.data["actor"],
	- "type" => "Add",
	+ "type" => type,
	"to" => [Pleroma.Constants.as_public()],
	"cc" => [user.follower_address]
	}
	\|> Map.merge(data_attrs)

	%Pleroma.Activity{
	data: data,
	actor: data["actor"],
	recipients: data["to"]
	}
	\|> Map.merge(attrs)
	end

	def followers_only_note_activity_factory(attrs \\ %{}) do
	user = attrs[:user] \|\| insert(:user)
	note = insert(:followers_only_note, user: user)

	data_attrs = attrs[:data_attrs] \|\| %{}
	attrs = Map.drop(attrs, [:user, :note, :data_attrs])

	data =
	%{
	"id" => Pleroma.Web.ActivityPub.Utils.generate_activity_id(),
	"type" => "Create",
	"actor" => note.data["actor"],
	"to" => note.data["to"],
	"object" => note.data,
	"published" => DateTime.utc_now() \|> DateTime.to_iso8601(),
	"context" => note.data["context"]
	}
	\|> Map.merge(data_attrs)

	%Pleroma.Activity{
	data: data,
	actor: data["actor"],
	recipients: data["to"]
	}
	\|> Map.merge(attrs)
	end

	def note_activity_factory(attrs \\ %{}) do
	user = attrs[:user] \|\| insert(:user)
	note = attrs[:note] \|\| insert(:note, user: user)

	data_attrs = attrs[:data_attrs] \|\| %{}
	attrs = Map.drop(attrs, [:user, :note, :data_attrs])

	data =
	%{
	"id" => Pleroma.Web.ActivityPub.Utils.generate_activity_id(),
	"type" => "Create",
	"actor" => note.data["actor"],
	"to" => note.data["to"],
	"object" => note.data["id"],
	"published" => DateTime.utc_now() \|> DateTime.to_iso8601(),
	"context" => note.data["context"]
	}
	\|> Map.merge(data_attrs)

	%Pleroma.Activity{
	data: data,
	actor: data["actor"],
	recipients: data["to"]
	}
	\|> Map.merge(attrs)
	end

	def article_activity_factory do
	article = insert(:article)

	data = %{
	"id" => Pleroma.Web.ActivityPub.Utils.generate_activity_id(),
	"type" => "Create",
	"actor" => article.data["actor"],
	"to" => article.data["to"],
	"object" => article.data,
	"published" => DateTime.utc_now() \|> DateTime.to_iso8601(),
	"context" => article.data["context"]
	}

	%Pleroma.Activity{
	data: data,
	actor: data["actor"],
	recipients: data["to"]
	}
	end

	def announce_activity_factory(attrs \\ %{}) do
	note_activity = attrs[:note_activity] \|\| insert(:note_activity)
	user = attrs[:user] \|\| insert(:user)

	data = %{
	"type" => "Announce",
	"actor" => note_activity.actor,
	"object" => note_activity.data["id"],
	"to" => [user.follower_address, note_activity.data["actor"]],
	"cc" => ["https://www.w3.org/ns/activitystreams#Public"],
	"context" => note_activity.data["context"]
	}

	%Pleroma.Activity{
	data: data,
	actor: user.ap_id,
	recipients: data["to"]
	}
	end

	def like_activity_factory(attrs \\ %{}) do
	note_activity = attrs[:note_activity] \|\| insert(:note_activity)
	object = Object.normalize(note_activity, fetch: false)
	user = insert(:user)

	data =
	%{
	"id" => Pleroma.Web.ActivityPub.Utils.generate_activity_id(),
	"actor" => user.ap_id,
	"type" => "Like",
	"object" => object.data["id"],
	"published_at" => DateTime.utc_now() \|> DateTime.to_iso8601()
	}
	\|> Map.merge(attrs[:data_attrs] \|\| %{})

	%Pleroma.Activity{
	data: data
	}
	end

	def follow_activity_factory(attrs \\ %{}) do
	follower = attrs[:follower] \|\| insert(:user)
	followed = attrs[:followed] \|\| insert(:user)

	data = %{
	"id" => Pleroma.Web.ActivityPub.Utils.generate_activity_id(),
	"actor" => follower.ap_id,
	"type" => "Follow",
	"object" => followed.ap_id,
	"state" => attrs[:state] \|\| "pending",
	"published_at" => DateTime.utc_now() \|> DateTime.to_iso8601()
	}

	%Pleroma.Activity{
	data: data,
	actor: follower.ap_id
	}
	\|> Map.merge(attrs)
	end

	def report_activity_factory(attrs \\ %{}) do
	user = attrs[:user] \|\| insert(:user)
	activity = attrs[:activity] \|\| insert(:note_activity)
	state = attrs[:state] \|\| "open"

	data = %{
	"id" => Pleroma.Web.ActivityPub.Utils.generate_activity_id(),
	"actor" => user.ap_id,
	"type" => "Flag",
	"object" => [activity.actor, activity.data["id"]],
	"published" => DateTime.utc_now() \|> DateTime.to_iso8601(),
	"to" => [],
	"cc" => [activity.actor],
	"context" => activity.data["context"],
	"state" => state
	}

	%Pleroma.Activity{
	data: data,
	actor: data["actor"],
	recipients: data["to"] ++ data["cc"]
	}
	end

	def question_activity_factory(attrs \\ %{}) do
	user = attrs[:user] \|\| insert(:user)
	question = attrs[:question] \|\| insert(:question, user: user)

	data_attrs = attrs[:data_attrs] \|\| %{}
	attrs = Map.drop(attrs, [:user, :question, :data_attrs])

	data =
	%{
	"id" => Pleroma.Web.ActivityPub.Utils.generate_activity_id(),
	"type" => "Create",
	"actor" => question.data["actor"],
	"to" => question.data["to"],
	"object" => question.data["id"],
	"published" => DateTime.utc_now() \|> DateTime.to_iso8601(),
	"context" => question.data["context"]
	}
	\|> Map.merge(data_attrs)

	%Pleroma.Activity{
	data: data,
	actor: data["actor"],
	recipients: data["to"]
	}
	\|> Map.merge(attrs)
	end

	def delete_activity_factory(attrs \\ %{}) do
	user = attrs[:user] \|\| insert(:user)
	note_activity = attrs[:note_activity] \|\| insert(:note_activity, user: user)

	data_attrs = attrs[:data_attrs] \|\| %{}
	attrs = Map.drop(attrs, [:user, :data_attrs])

	data =
	%{
	"id" => Pleroma.Web.ActivityPub.Utils.generate_activity_id(),
	"type" => "Delete",
	"actor" => note_activity.data["actor"],
	"to" => note_activity.data["to"],
	"object" => note_activity.data["id"],
	"published" => DateTime.utc_now() \|> DateTime.to_iso8601(),
	"context" => note_activity.data["context"]
	}
	\|> Map.merge(data_attrs)

	%Pleroma.Activity{
	data: data,
	actor: data["actor"],
	recipients: data["to"]
	}
	\|> Map.merge(attrs)
	end

	+ def undo_activity_factory(attrs \\ %{}) do
	+ like_activity = attrs[:like_activity] \|\| insert(:like_activity)
	+ attrs = Map.drop(attrs, [:like_activity])
	+
	+ data =
	+ %{
	+ "id" => Pleroma.Web.ActivityPub.Utils.generate_activity_id(),
	+ "type" => "Undo",
	+ "actor" => like_activity.data["actor"],
	+ "to" => like_activity.data["to"],
	+ "object" => like_activity.data["id"],
	+ "published" => DateTime.utc_now() \|> DateTime.to_iso8601(),
	+ "context" => like_activity.data["context"]
	+ }
	+
	+ %Pleroma.Activity{
	+ data: data,
	+ actor: data["actor"],
	+ recipients: data["to"]
	+ }
	+ \|> Map.merge(attrs)
	+ end
	+
	+ def update_activity_factory(attrs \\ %{}) do
	+ user = attrs[:user] \|\| insert(:user, nickname: "testuser")
	+ attrs = Map.drop(attrs, [:user])
	+
	+ user_data =
	+ UserView.render("user.json", %{user: user})
	+ \|> Map.merge(%{"name" => "new display name"})
	+
	+ data = %{
	+ "type" => "Update",
	+ "to" => [
	+ user_data["followers"],
	+ "https://www.w3.org/ns/activitystreams#Public"
	+ ],
	+ "actor" => user_data["id"],
	+ "object" => user_data
	+ }
	+
	+ %Pleroma.Activity{
	+ actor: user_data["id"],
	+ data: data
	+ }
	+ \|> Map.merge(attrs)
	+ end
	+
	def oauth_app_factory do
	%Pleroma.Web.OAuth.App{
	client_name: sequence(:client_name, &"Some client #{&1}"),
	redirect_uris: "https://example.com/callback",
	scopes: ["read", "write", "follow", "push"],
	website: "https://example.com",
	client_id: Ecto.UUID.generate(),
	client_secret: "aaa;/&bbb"
	}
	end

	def oauth_token_factory(attrs \\ %{}) do
	scopes = Map.get(attrs, :scopes, ["read"])
	oauth_app = Map.get_lazy(attrs, :app, fn -> insert(:oauth_app, scopes: scopes) end)
	user = Map.get_lazy(attrs, :user, fn -> build(:user) end)

	valid_until =
	Map.get(attrs, :valid_until, NaiveDateTime.add(NaiveDateTime.utc_now(), 60 * 10))

	%Pleroma.Web.OAuth.Token{
	token: :crypto.strong_rand_bytes(32) \|> Base.url_encode64(),
	refresh_token: :crypto.strong_rand_bytes(32) \|> Base.url_encode64(),
	scopes: scopes,
	user: user,
	app: oauth_app,
	valid_until: valid_until
	}
	end

	def oauth_admin_token_factory(attrs \\ %{}) do
	user = Map.get_lazy(attrs, :user, fn -> build(:user, is_admin: true) end)

	scopes =
	attrs
	\|> Map.get(:scopes, ["admin"])
	\|> Kernel.++(["admin"])
	\|> Enum.uniq()

	attrs = Map.merge(attrs, %{user: user, scopes: scopes})
	oauth_token_factory(attrs)
	end

	def oauth_authorization_factory do
	%Pleroma.Web.OAuth.Authorization{
	token: :crypto.strong_rand_bytes(32) \|> Base.url_encode64(padding: false),
	scopes: ["read", "write", "follow", "push"],
	valid_until: NaiveDateTime.add(NaiveDateTime.utc_now(), 60 * 10),
	user: build(:user),
	app: build(:oauth_app)
	}
	end

	def push_subscription_factory do
	%Pleroma.Web.Push.Subscription{
	user: build(:user),
	token: build(:oauth_token),
	endpoint: "https://example.com/example/1234",
	key_auth: "8eDyX_uCN0XRhSbY5hs7Hg==",
	key_p256dh:
	"BCIWgsnyXDv1VkhqL2P7YRBvdeuDnlwAPT2guNhdIoW3IP7GmHh1SMKPLxRf7x8vJy6ZFK3ol2ohgn_-0yP7QQA=",
	data: %{}
	}
	end

	def notification_factory do
	%Pleroma.Notification{
	user: build(:user)
	}
	end

	def scheduled_activity_factory do
	%Pleroma.ScheduledActivity{
	user: build(:user),
	scheduled_at: NaiveDateTime.add(NaiveDateTime.utc_now(), :timer.minutes(60), :millisecond),
	params: build(:note) \|> Map.from_struct() \|> Map.get(:data)
	}
	end

	def registration_factory do
	user = insert(:user)

	%Pleroma.Registration{
	user: user,
	provider: "twitter",
	uid: "171799000",
	info: %{
	"name" => "John Doe",
	"email" => "john@doe.com",
	"nickname" => "johndoe",
	"description" => "My bio"
	}
	}
	end

	def config_factory(attrs \\ %{}) do
	%Pleroma.ConfigDB{
	key: sequence(:key, &String.to_atom("some_key_#{&1}")),
	group: :pleroma,
	value:
	sequence(
	:value,
	&%{another_key: "#{&1}somevalue", another: "#{&1}somevalue"}
	)
	}
	\|> merge_attributes(attrs)
	end

	def marker_factory do
	%Pleroma.Marker{
	user: build(:user),
	timeline: "notifications",
	lock_version: 0,
	last_read_id: "1"
	}
	end

	def mfa_token_factory do
	%Pleroma.MFA.Token{
	token: :crypto.strong_rand_bytes(32) \|> Base.url_encode64(padding: false),
	authorization: build(:oauth_authorization),
	valid_until: NaiveDateTime.add(NaiveDateTime.utc_now(), 60 * 10),
	user: build(:user)
	}
	end

	def filter_factory do
	%Pleroma.Filter{
	user: build(:user),
	filter_id: sequence(:filter_id, & &1),
	phrase: "cofe",
	context: ["home"]
	}
	end

	def announcement_factory(params \\ %{}) do
	data = Map.get(params, :data, %{})

	{_, params} = Map.pop(params, :data)

	%Pleroma.Announcement{
	data: Map.merge(%{"content" => "test announcement", "all_day" => false}, data)
	}
	\|> Map.merge(params)
	\|> Pleroma.Announcement.add_rendered_properties()
	end

	def frontend_setting_profile_factory(params \\ %{}) do
	%Pleroma.Akkoma.FrontendSettingsProfile{
	user: build(:user),
	frontend_name: "akkoma-fe",
	profile_name: "default",
	settings: %{"test" => "test"},
	version: 1
	}
	\|> Map.merge(params)
	end

	def delivery_factory(params \\ %{}) do
	object = Map.get(params, :object, build(:note))
	user = Map.get(params, :user, build(:user))

	%Pleroma.Delivery{
	object: object,
	user: user
	}
	end

	def hashtag_factory(params \\ %{}) do
	%Pleroma.Hashtag{
	name: "test #{sequence(:hashtag_name, & &1)}"
	}
	\|> Map.merge(params)
	end
	end

File Metadata

Mime Type: text/x-diff
Expires: Sat, Jul 18, 5:58 PM (1 d, 2 h)
Storage Engine: blob
Storage Format: Raw Data
Storage Handle: 1695109
Default Alt Text: (27 KB)

No OneTemporaryActions

View Options

File Metadata

Event Timeline

No OneTemporary
Actions