1 # Pleroma: A lightweight social networking server
2 # Copyright © 2017-2021 Pleroma Authors <https://pleroma.social/>
3 # SPDX-License-Identifier: AGPL-3.0-only
5 defmodule Pleroma.Factory do
6 use ExMachina.Ecto, repo: Pleroma.Repo
8 require Pleroma.Constants
13 def participation_factory do
14 conversation = insert(:conversation)
17 %Pleroma.Conversation.Participation{
18 conversation: conversation,
24 def conversation_factory do
25 %Pleroma.Conversation{
26 ap_id: sequence(:ap_id, &"https://some_conversation/#{&1}")
30 def user_factory(attrs \\ %{}) do
32 name: sequence(:name, &"Test テスト User #{&1}"),
33 email: sequence(:email, &"user#{&1}@example.com"),
34 nickname: sequence(:nickname, &"nick#{&1}"),
35 password_hash: Pleroma.Password.Pbkdf2.hash_pwd_salt("test"),
36 bio: sequence(:bio, &"Tester Number #{&1}"),
37 is_discoverable: true,
38 last_digest_emailed_at: NaiveDateTime.utc_now(),
39 last_refreshed_at: NaiveDateTime.utc_now(),
40 notification_settings: %Pleroma.User.NotificationSetting{},
41 multi_factor_authentication_settings: %Pleroma.MFA.Settings{},
46 if attrs[:local] == false do
47 base_domain = attrs[:domain] || Enum.random(["domain1.com", "domain2.com", "domain3.com"])
49 ap_id = "https://#{base_domain}/users/#{user.nickname}"
53 follower_address: ap_id <> "/followers",
54 following_address: ap_id <> "/following",
55 featured_address: ap_id <> "/collections/featured"
59 ap_id: User.ap_id(user),
60 follower_address: User.ap_followers(user),
61 following_address: User.ap_following(user),
62 featured_address: User.ap_featured_collection(user)
66 attrs = Map.delete(attrs, :domain)
69 |> Map.put(:raw_bio, user.bio)
71 |> merge_attributes(attrs)
74 def user_relationship_factory(attrs \\ %{}) do
75 source = attrs[:source] || insert(:user)
76 target = attrs[:target] || insert(:user)
77 relationship_type = attrs[:relationship_type] || :block
79 %Pleroma.UserRelationship{
82 relationship_type: relationship_type
86 def note_factory(attrs \\ %{}) do
87 text = sequence(:text, &"This is :moominmamma: note #{&1}")
89 user = attrs[:user] || insert(:user)
95 "id" => Pleroma.Web.ActivityPub.Utils.generate_object_id(),
96 "actor" => user.ap_id,
97 "to" => ["https://www.w3.org/ns/activitystreams#Public"],
98 "published" => DateTime.utc_now() |> DateTime.to_iso8601(),
105 "2hu" => "corndog.png"
110 data: merge_attributes(data, Map.get(attrs, :data, %{}))
114 def attachment_note_factory(attrs \\ %{}) do
115 user = attrs[:user] || insert(:user)
116 {length, attrs} = Map.pop(attrs, :length, 1)
120 Stream.repeatedly(fn -> attachment_data(user.ap_id, attrs[:href]) end)
124 build(:note, Map.put(attrs, :data, data))
127 defp attachment_data(ap_id, href) do
128 href = href || sequence(:href, &"#{Pleroma.Web.Endpoint.url()}/media/#{&1}.jpg")
135 "mediaType" => "image/jpeg"
138 "name" => "some name",
139 "type" => "Document",
141 "mediaType" => "image/jpeg"
145 def audio_factory(attrs \\ %{}) do
146 text = sequence(:text, &"lain radio episode #{&1}")
148 user = attrs[:user] || insert(:user)
152 "id" => Pleroma.Web.ActivityPub.Utils.generate_object_id(),
155 "album" => "lain radio",
156 "to" => ["https://www.w3.org/ns/activitystreams#Public"],
157 "published" => DateTime.utc_now() |> DateTime.to_iso8601(),
158 "actor" => user.ap_id,
163 data: merge_attributes(data, Map.get(attrs, :data, %{}))
167 def listen_factory do
168 audio = insert(:audio)
171 "id" => Pleroma.Web.ActivityPub.Utils.generate_activity_id(),
173 "actor" => audio.data["actor"],
174 "to" => audio.data["to"],
175 "object" => audio.data,
176 "published" => audio.data["published"]
181 actor: data["actor"],
182 recipients: data["to"]
186 def direct_note_factory do
187 user2 = insert(:user)
189 %Pleroma.Object{data: data} = note_factory()
190 %Pleroma.Object{data: Map.merge(data, %{"to" => [user2.ap_id]})}
193 def article_factory do
194 %Pleroma.Object{data: data} = note_factory()
195 %Pleroma.Object{data: Map.merge(data, %{"type" => "Article"})}
198 def tombstone_factory do
200 "type" => "Tombstone",
201 "id" => Pleroma.Web.ActivityPub.Utils.generate_object_id(),
202 "formerType" => "Note",
203 "deleted" => DateTime.utc_now() |> DateTime.to_iso8601()
211 def question_factory(attrs \\ %{}) do
212 user = attrs[:user] || insert(:user)
215 "id" => Pleroma.Web.ActivityPub.Utils.generate_object_id(),
216 "type" => "Question",
217 "actor" => user.ap_id,
218 "attributedTo" => user.ap_id,
220 "to" => ["https://www.w3.org/ns/activitystreams#Public"],
221 "cc" => [user.follower_address],
222 "context" => Pleroma.Web.ActivityPub.Utils.generate_context_id(),
223 "closed" => DateTime.utc_now() |> DateTime.add(86_400) |> DateTime.to_iso8601(),
227 "name" => "chocolate",
228 "replies" => %{"totalItems" => 0, "type" => "Collection"}
233 "replies" => %{"totalItems" => 0, "type" => "Collection"}
239 data: merge_attributes(data, Map.get(attrs, :data, %{}))
243 def direct_note_activity_factory do
244 dm = insert(:direct_note)
247 "id" => Pleroma.Web.ActivityPub.Utils.generate_activity_id(),
249 "actor" => dm.data["actor"],
250 "to" => dm.data["to"],
252 "published" => DateTime.utc_now() |> DateTime.to_iso8601(),
253 "context" => dm.data["context"]
258 actor: data["actor"],
259 recipients: data["to"]
263 def add_activity_factory(attrs \\ %{}) do
264 featured_collection_activity(attrs, "Add")
267 def remove_activity_factor(attrs \\ %{}) do
268 featured_collection_activity(attrs, "Remove")
271 defp featured_collection_activity(attrs, type) do
272 user = attrs[:user] || insert(:user)
273 note = attrs[:note] || insert(:note, user: user)
277 |> Map.get(:data_attrs, %{})
278 |> Map.put(:type, type)
280 attrs = Map.drop(attrs, [:user, :note, :data_attrs])
284 "id" => Pleroma.Web.ActivityPub.Utils.generate_activity_id(),
285 "target" => user.featured_address,
286 "object" => note.data["object"],
287 "actor" => note.data["actor"],
289 "to" => [Pleroma.Constants.as_public()],
290 "cc" => [user.follower_address]
292 |> Map.merge(data_attrs)
296 actor: data["actor"],
297 recipients: data["to"]
302 def note_activity_factory(attrs \\ %{}) do
303 user = attrs[:user] || insert(:user)
304 note = attrs[:note] || insert(:note, user: user)
306 data_attrs = attrs[:data_attrs] || %{}
307 attrs = Map.drop(attrs, [:user, :note, :data_attrs])
311 "id" => Pleroma.Web.ActivityPub.Utils.generate_activity_id(),
313 "actor" => note.data["actor"],
314 "to" => note.data["to"],
315 "object" => note.data["id"],
316 "published" => DateTime.utc_now() |> DateTime.to_iso8601(),
317 "context" => note.data["context"]
319 |> Map.merge(data_attrs)
323 actor: data["actor"],
324 recipients: data["to"]
329 def article_activity_factory do
330 article = insert(:article)
333 "id" => Pleroma.Web.ActivityPub.Utils.generate_activity_id(),
335 "actor" => article.data["actor"],
336 "to" => article.data["to"],
337 "object" => article.data,
338 "published" => DateTime.utc_now() |> DateTime.to_iso8601(),
339 "context" => article.data["context"]
344 actor: data["actor"],
345 recipients: data["to"]
349 def announce_activity_factory(attrs \\ %{}) do
350 note_activity = attrs[:note_activity] || insert(:note_activity)
351 user = attrs[:user] || insert(:user)
354 "type" => "Announce",
355 "actor" => note_activity.actor,
356 "object" => note_activity.data["id"],
357 "to" => [user.follower_address, note_activity.data["actor"]],
358 "cc" => ["https://www.w3.org/ns/activitystreams#Public"],
359 "context" => note_activity.data["context"]
365 recipients: data["to"]
369 def like_activity_factory(attrs \\ %{}) do
370 note_activity = attrs[:note_activity] || insert(:note_activity)
371 object = Object.normalize(note_activity, fetch: false)
376 "id" => Pleroma.Web.ActivityPub.Utils.generate_activity_id(),
377 "actor" => user.ap_id,
379 "object" => object.data["id"],
380 "published_at" => DateTime.utc_now() |> DateTime.to_iso8601()
382 |> Map.merge(attrs[:data_attrs] || %{})
389 def follow_activity_factory do
390 follower = insert(:user)
391 followed = insert(:user)
394 "id" => Pleroma.Web.ActivityPub.Utils.generate_activity_id(),
395 "actor" => follower.ap_id,
397 "object" => followed.ap_id,
398 "published_at" => DateTime.utc_now() |> DateTime.to_iso8601()
403 actor: follower.ap_id
407 def report_activity_factory(attrs \\ %{}) do
408 user = attrs[:user] || insert(:user)
409 activity = attrs[:activity] || insert(:note_activity)
410 state = attrs[:state] || "open"
413 "id" => Pleroma.Web.ActivityPub.Utils.generate_activity_id(),
414 "actor" => user.ap_id,
416 "object" => [activity.actor, activity.data["id"]],
417 "published" => DateTime.utc_now() |> DateTime.to_iso8601(),
419 "cc" => [activity.actor],
420 "context" => activity.data["context"],
426 actor: data["actor"],
427 recipients: data["to"] ++ data["cc"]
431 def question_activity_factory(attrs \\ %{}) do
432 user = attrs[:user] || insert(:user)
433 question = attrs[:question] || insert(:question, user: user)
435 data_attrs = attrs[:data_attrs] || %{}
436 attrs = Map.drop(attrs, [:user, :question, :data_attrs])
440 "id" => Pleroma.Web.ActivityPub.Utils.generate_activity_id(),
442 "actor" => question.data["actor"],
443 "to" => question.data["to"],
444 "object" => question.data["id"],
445 "published" => DateTime.utc_now() |> DateTime.to_iso8601(),
446 "context" => question.data["context"]
448 |> Map.merge(data_attrs)
452 actor: data["actor"],
453 recipients: data["to"]
458 def oauth_app_factory do
459 %Pleroma.Web.OAuth.App{
460 client_name: sequence(:client_name, &"Some client #{&1}"),
461 redirect_uris: "https://example.com/callback",
462 scopes: ["read", "write", "follow", "push", "admin"],
463 website: "https://example.com",
464 client_id: Ecto.UUID.generate(),
465 client_secret: "aaa;/&bbb"
469 def instance_factory do
470 %Pleroma.Instances.Instance{
472 unreachable_since: nil
476 def oauth_token_factory(attrs \\ %{}) do
477 scopes = Map.get(attrs, :scopes, ["read"])
478 oauth_app = Map.get_lazy(attrs, :app, fn -> insert(:oauth_app, scopes: scopes) end)
479 user = Map.get_lazy(attrs, :user, fn -> build(:user) end)
482 Map.get(attrs, :valid_until, NaiveDateTime.add(NaiveDateTime.utc_now(), 60 * 10))
484 %Pleroma.Web.OAuth.Token{
485 token: :crypto.strong_rand_bytes(32) |> Base.url_encode64(),
486 refresh_token: :crypto.strong_rand_bytes(32) |> Base.url_encode64(),
490 valid_until: valid_until
494 def oauth_admin_token_factory(attrs \\ %{}) do
495 user = Map.get_lazy(attrs, :user, fn -> build(:user, is_admin: true) end)
499 |> Map.get(:scopes, ["admin"])
500 |> Kernel.++(["admin"])
503 attrs = Map.merge(attrs, %{user: user, scopes: scopes})
504 oauth_token_factory(attrs)
507 def oauth_authorization_factory do
508 %Pleroma.Web.OAuth.Authorization{
509 token: :crypto.strong_rand_bytes(32) |> Base.url_encode64(padding: false),
510 scopes: ["read", "write", "follow", "push"],
511 valid_until: NaiveDateTime.add(NaiveDateTime.utc_now(), 60 * 10),
513 app: build(:oauth_app)
517 def push_subscription_factory do
518 %Pleroma.Web.Push.Subscription{
520 token: build(:oauth_token),
521 endpoint: "https://example.com/example/1234",
522 key_auth: "8eDyX_uCN0XRhSbY5hs7Hg==",
524 "BCIWgsnyXDv1VkhqL2P7YRBvdeuDnlwAPT2guNhdIoW3IP7GmHh1SMKPLxRf7x8vJy6ZFK3ol2ohgn_-0yP7QQA=",
529 def notification_factory do
530 %Pleroma.Notification{
535 def scheduled_activity_factory do
536 %Pleroma.ScheduledActivity{
538 scheduled_at: NaiveDateTime.add(NaiveDateTime.utc_now(), :timer.minutes(60), :millisecond),
539 params: build(:note) |> Map.from_struct() |> Map.get(:data)
543 def registration_factory do
546 %Pleroma.Registration{
551 "name" => "John Doe",
552 "email" => "john@doe.com",
553 "nickname" => "johndoe",
554 "description" => "My bio"
559 def config_factory(attrs \\ %{}) do
561 key: sequence(:key, &String.to_atom("some_key_#{&1}")),
566 &%{another_key: "#{&1}somevalue", another: "#{&1}somevalue"}
569 |> merge_attributes(attrs)
572 def marker_factory do
575 timeline: "notifications",
581 def mfa_token_factory do
583 token: :crypto.strong_rand_bytes(32) |> Base.url_encode64(padding: false),
584 authorization: build(:oauth_authorization),
585 valid_until: NaiveDateTime.add(NaiveDateTime.utc_now(), 60 * 10),
590 def filter_factory do
593 filter_id: sequence(:filter_id, & &1),