debianize-mobilizon/test/federation/activity_pub/activity_pub_test.exs
Thomas Citharel 4144e9ffd0
Introduce group basic federation, event new page and notifications
Signed-off-by: Thomas Citharel <tcit@tcit.fr>
2020-06-03 16:01:26 +02:00

543 lines
18 KiB
Elixir
Raw Blame History

This file contains invisible Unicode characters

This file contains invisible Unicode characters that are indistinguishable to humans but may be processed differently by a computer. If you think that this is intentional, you can safely ignore this warning. Use the Escape button to reveal them.

# Portions of this file are derived from Pleroma:
# Copyright © 2017-2018 Pleroma Authors <https://pleroma.social>
# SPDX-License-Identifier: AGPL-3.0-only
# Upstream: https://git.pleroma.social/pleroma/pleroma/blob/develop/test/web/activity_pub/activity_pub_test.exs
defmodule Mobilizon.Federation.ActivityPubTest do
use ExVCR.Mock, adapter: ExVCR.Adapter.Hackney
use Mobilizon.DataCase
import Mock
import Mobilizon.Factory
alias Mobilizon.{Actors, Conversations, Events}
alias Mobilizon.Actors.Actor
alias Mobilizon.Resources.Resource
alias Mobilizon.Todos.{Todo, TodoList}
alias Mobilizon.Federation.ActivityPub
alias Mobilizon.Federation.ActivityPub.Utils
alias Mobilizon.Federation.HTTPSignatures.Signature
@activity_pub_public_audience "https://www.w3.org/ns/activitystreams#Public"
setup_all do
HTTPoison.start()
end
describe "setting HTTP signature" do
test "set http signature header" do
actor = insert(:actor)
signature =
Signature.sign(actor, %{
host: "example.com",
"content-length": 15,
digest: %{id: "my_id"} |> Jason.encode!() |> Signature.build_digest(),
"(request-target)": Signature.generate_request_target("POST", "/inbox"),
date: Signature.generate_date_header()
})
assert signature =~ "headers=\"(request-target) content-length date digest host\""
end
end
describe "fetching actor from its url" do
test "returns an actor from nickname" do
use_cassette "activity_pub/fetch_tcit@framapiaf.org" do
assert {:ok, %Actor{preferred_username: "tcit", domain: "framapiaf.org"} = actor} =
ActivityPub.make_actor_from_nickname("tcit@framapiaf.org")
end
end
@actor_url "https://framapiaf.org/users/tcit"
test "returns an actor from url" do
# Initial fetch
use_cassette "activity_pub/fetch_framapiaf.org_users_tcit" do
assert {:ok, %Actor{preferred_username: "tcit", domain: "framapiaf.org"}} =
ActivityPub.get_or_fetch_actor_by_url(@actor_url)
end
# Fetch uses cache if Actors.needs_update? returns false
with_mocks([
{Actors, [:passthrough],
[
get_actor_by_url: fn @actor_url, false ->
{:ok,
%Actor{
preferred_username: "tcit",
domain: "framapiaf.org"
}}
end,
needs_update?: fn _ -> false end
]},
{ActivityPub, [:passthrough],
make_actor_from_url: fn @actor_url, false ->
{:ok,
%Actor{
preferred_username: "tcit",
domain: "framapiaf.org"
}}
end}
]) do
assert {:ok, %Actor{preferred_username: "tcit", domain: "framapiaf.org"}} =
ActivityPub.get_or_fetch_actor_by_url(@actor_url)
assert_called(Actors.needs_update?(:_))
refute called(ActivityPub.make_actor_from_url(@actor_url, false))
end
# Fetch doesn't use cache if Actors.needs_update? returns true
with_mocks([
{Actors, [:passthrough],
[
get_actor_by_url: fn @actor_url, false ->
{:ok,
%Actor{
preferred_username: "tcit",
domain: "framapiaf.org"
}}
end,
needs_update?: fn _ -> true end
]},
{ActivityPub, [:passthrough],
make_actor_from_url: fn @actor_url, false ->
{:ok,
%Actor{
preferred_username: "tcit",
domain: "framapiaf.org"
}}
end}
]) do
assert {:ok, %Actor{preferred_username: "tcit", domain: "framapiaf.org"}} =
ActivityPub.get_or_fetch_actor_by_url(@actor_url)
assert_called(ActivityPub.get_or_fetch_actor_by_url(@actor_url))
assert_called(Actors.get_actor_by_url(@actor_url, false))
assert_called(Actors.needs_update?(:_))
assert_called(ActivityPub.make_actor_from_url(@actor_url, false))
end
end
end
describe "create activities" do
# test "removes doubled 'to' recipients" do
# actor = insert(:actor)
#
# {:ok, activity, _} =
# ActivityPub.create(%{
# to: ["user1", "user1", "user2"],
# actor: actor,
# context: "",
# object: %{}
# })
#
# assert activity.data["to"] == ["user1", "user2"]
# assert activity.actor == actor.url
# assert activity.recipients == ["user1", "user2"]
# end
end
describe "fetching an" do
test "object by url" do
use_cassette "activity_pub/fetch_framapiaf_framasoft_status" do
{:ok, object} =
ActivityPub.fetch_object_from_url(
"https://framapiaf.org/users/Framasoft/statuses/102093631881522097"
)
{:ok, object_again} =
ActivityPub.fetch_object_from_url(
"https://framapiaf.org/users/Framasoft/statuses/102093631881522097"
)
assert object.id == object_again.id
end
end
test "object reply by url" do
use_cassette "activity_pub/fetch_framasoft_framapiaf_reply" do
{:ok, object} =
ActivityPub.fetch_object_from_url("https://mamot.fr/@imacrea/102094441327423790")
assert object.in_reply_to_comment.url ==
"https://framapiaf.org/users/Framasoft/statuses/102093632302210150"
end
end
test "object reply to a video by url" do
use_cassette "activity_pub/fetch_reply_to_framatube" do
{:ok, object} =
ActivityPub.fetch_object_from_url(
"https://diaspodon.fr/users/dada/statuses/100820008426311925"
)
assert object.in_reply_to_comment == nil
end
end
end
describe "deletion" do
test "it creates a delete activity and deletes the original event" do
event = insert(:event)
event = Events.get_public_event_by_url_with_preload!(event.url)
{:ok, delete, _} = ActivityPub.delete(event)
assert delete.data["type"] == "Delete"
assert delete.data["actor"] == event.organizer_actor.url
assert delete.data["object"] == event.url
assert Events.get_event_by_url(event.url) == nil
end
test "it deletes the original event but only locally if needed" do
with_mock Utils,
maybe_federate: fn _ -> :ok end,
lazy_put_activity_defaults: fn args -> args end do
event = insert(:event)
event = Events.get_public_event_by_url_with_preload!(event.url)
{:ok, delete, _} = ActivityPub.delete(event, false)
assert delete.data["type"] == "Delete"
assert delete.data["actor"] == event.organizer_actor.url
assert delete.data["object"] == event.url
assert delete.local == false
assert Events.get_event_by_url(event.url) == nil
assert_called(Utils.maybe_federate(delete))
end
end
test "it creates a delete activity and deletes the original comment" do
comment = insert(:comment)
comment = Conversations.get_comment_from_url_with_preload!(comment.url)
assert is_nil(Conversations.get_comment_from_url(comment.url).deleted_at)
{:ok, delete, _} = ActivityPub.delete(comment)
assert delete.data["type"] == "Delete"
assert delete.data["actor"] == comment.actor.url
assert delete.data["object"] == comment.url
refute is_nil(Conversations.get_comment_from_url(comment.url).deleted_at)
end
end
describe "update" do
@updated_actor_summary "This is an updated actor"
test "it creates an update activity with the new actor data" do
actor = insert(:actor)
actor_data = %{summary: @updated_actor_summary}
{:ok, update, _} = ActivityPub.update(:actor, actor, actor_data, false)
assert update.data["actor"] == actor.url
assert update.data["to"] == [@activity_pub_public_audience]
assert update.data["object"]["id"] == actor.url
assert update.data["object"]["type"] == :Person
assert update.data["object"]["summary"] == @updated_actor_summary
end
@updated_start_time DateTime.utc_now() |> DateTime.truncate(:second)
test "it creates an update activity with the new event data" do
actor = insert(:actor)
event = insert(:event, organizer_actor: actor)
event_data = %{begins_on: @updated_start_time}
{:ok, update, _} = ActivityPub.update(:event, event, event_data)
assert update.data["actor"] == actor.url
assert update.data["to"] == [@activity_pub_public_audience]
assert update.data["object"]["id"] == event.url
assert update.data["object"]["type"] == "Event"
assert update.data["object"]["startTime"] == DateTime.to_iso8601(@updated_start_time)
end
end
describe "create a todo list" do
@todo_list_title "My TODO-list"
test "it creates a todo list" do
with_mock Utils, [:passthrough], maybe_federate: fn _ -> :ok end do
actor = insert(:actor)
group = insert(:group)
{:ok, create_data, %TodoList{url: todo_list_url}} =
ActivityPub.create(:todo_list, %{title: @todo_list_title, actor_id: group.id}, true, %{
"actor" => actor.url
})
assert create_data.local
assert create_data.data["object"]["id"] == todo_list_url
assert create_data.data["object"]["type"] == "TodoList"
assert create_data.data["object"]["title"] == @todo_list_title
assert create_data.data["to"] == [group.url]
assert create_data.data["actor"] == actor.url
assert_called(Utils.maybe_federate(create_data))
end
end
end
describe "create a todo" do
@todo_title "Finish this thing"
test "it creates a todo" do
with_mock Utils, [:passthrough], maybe_federate: fn _ -> :ok end do
actor = insert(:actor)
todo_list = insert(:todo_list)
{:ok, create_data, %Todo{url: todo_url}} =
ActivityPub.create(
:todo,
%{title: @todo_title, todo_list_id: todo_list.id, creator_id: actor.id},
true,
%{"actor" => actor.url}
)
assert create_data.local
assert create_data.data["object"]["id"] == todo_url
assert create_data.data["object"]["type"] == "Todo"
assert create_data.data["object"]["name"] == @todo_title
assert create_data.data["to"] == [todo_list.actor.url]
assert create_data.data["actor"] == actor.url
assert_called(Utils.maybe_federate(create_data))
end
end
end
@resource_url "https://framasoft.org/fr/full"
@resource_title "my resource"
@updated_resource_title "my updated resource"
@folder_title "my folder"
describe "create resources" do
test "it creates a resource" do
with_mock Utils, [:passthrough], maybe_federate: fn _ -> :ok end do
actor = insert(:actor)
group = insert(:group)
{:ok, create_data, %Resource{url: url}} =
ActivityPub.create(
:resource,
%{
title: @resource_title,
creator_id: actor.id,
actor_id: group.id,
parent_id: nil,
resource_url: @resource_url,
type: :link
},
true
)
assert create_data.local
assert create_data.data["type"] == "Create"
assert create_data.data["object"]["id"] == url
assert create_data.data["object"]["type"] == "Document"
assert create_data.data["object"]["name"] == @resource_title
assert create_data.data["object"]["url"] == @resource_url
assert create_data.data["to"] == [group.url]
assert create_data.data["actor"] == actor.url
assert create_data.data["attributedTo"] == [actor.url]
assert_called(Utils.maybe_federate(create_data))
end
end
test "it creates a folder" do
with_mock Utils, [:passthrough], maybe_federate: fn _ -> :ok end do
actor = insert(:actor)
group = insert(:group)
{:ok, create_data, %Resource{url: url}} =
ActivityPub.create(
:resource,
%{
title: @folder_title,
creator_id: actor.id,
actor_id: group.id,
parent_id: nil,
type: :folder
},
true
)
assert create_data.local
assert create_data.data["type"] == "Create"
assert create_data.data["object"]["id"] == url
assert create_data.data["object"]["type"] == "ResourceCollection"
assert create_data.data["object"]["name"] == @folder_title
assert create_data.data["to"] == [group.url]
assert create_data.data["actor"] == actor.url
assert create_data.data["attributedTo"] == [actor.url]
assert_called(Utils.maybe_federate(create_data))
end
end
test "it creates a resource in a folder" do
with_mock Utils, [:passthrough], maybe_federate: fn _ -> :ok end do
actor = insert(:actor)
group = insert(:group)
%Resource{id: parent_id, url: parent_url} =
insert(:resource, type: :folder, resource_url: nil, actor: group)
{:ok, create_data, %Resource{url: url}} =
ActivityPub.create(
:resource,
%{
title: @resource_title,
creator_id: actor.id,
actor_id: group.id,
parent_id: parent_id,
resource_url: @resource_url,
type: :link
},
true
)
assert create_data.local
assert create_data.data["type"] == "Add"
assert create_data.data["target"] == parent_url
assert create_data.data["object"]["id"] == url
assert create_data.data["object"]["type"] == "Document"
assert create_data.data["object"]["name"] == @resource_title
assert create_data.data["object"]["url"] == @resource_url
assert create_data.data["to"] == [group.url]
assert create_data.data["actor"] == actor.url
assert create_data.data["attributedTo"] == [actor.url]
assert_called(Utils.maybe_federate(create_data))
end
end
end
describe "move resources" do
test "rename resource" do
with_mock Utils, [:passthrough], maybe_federate: fn _ -> :ok end do
actor = insert(:actor)
group = insert(:group)
%Resource{} =
resource =
insert(:resource,
resource_url: @resource_url,
actor: group,
creator: actor,
title: @resource_title
)
{:ok, update_data, %Resource{url: url}} =
ActivityPub.update(
:resource,
resource,
%{
title: @updated_resource_title
},
true
)
assert update_data.local
assert update_data.data["type"] == "Update"
assert update_data.data["object"]["id"] == url
assert update_data.data["object"]["type"] == "Document"
assert update_data.data["object"]["name"] == @updated_resource_title
assert update_data.data["object"]["url"] == @resource_url
assert update_data.data["to"] == [group.url]
assert update_data.data["actor"] == actor.url
assert update_data.data["attributedTo"] == [actor.url]
assert_called(Utils.maybe_federate(update_data))
end
end
test "move resource" do
with_mock Utils, [:passthrough], maybe_federate: fn _ -> :ok end do
actor = insert(:actor)
group = insert(:group)
%Resource{} =
resource =
insert(:resource,
resource_url: @resource_url,
actor: group,
creator: actor,
title: @resource_title
)
%Resource{id: parent_id, url: parent_url} =
insert(:resource, type: :folder, resource_url: nil, actor: group)
{:ok, update_data, %Resource{url: url}} =
ActivityPub.move(
:resource,
resource,
%{
parent_id: parent_id
},
true
)
assert update_data.local
assert update_data.data["type"] == "Move"
assert update_data.data["object"]["id"] == url
assert update_data.data["object"]["type"] == "Document"
assert update_data.data["object"]["name"] == @resource_title
assert update_data.data["object"]["url"] == @resource_url
assert update_data.data["to"] == [group.url]
assert update_data.data["actor"] == actor.url
assert update_data.data["origin"] == nil
assert update_data.data["target"] == parent_url
assert_called(Utils.maybe_federate(update_data))
end
end
end
describe "delete resources" do
test "delete resource" do
with_mock Utils, [:passthrough], maybe_federate: fn _ -> :ok end do
actor = insert(:actor)
group = insert(:group)
%Resource{} =
resource =
insert(:resource,
resource_url: @resource_url,
actor: group,
creator: actor,
title: @resource_title
)
{:ok, update_data, %Resource{url: url}} =
ActivityPub.delete(
resource,
true
)
assert update_data.local
assert update_data.data["type"] == "Delete"
assert update_data.data["object"] == url
assert update_data.data["to"] == [group.url]
# TODO : Add actor parameter to ActivityPub.delete/2
# assert update_data.data["actor"] == actor.url
# assert update_data.data["attributedTo"] == [actor.url]
assert_called(Utils.maybe_federate(update_data))
end
end
end
end