henlo from my Psion netBook
message sent from my Psion netBook
" # end # test "it works for incoming announces with actor being inlined (kroeg)" do # data = File.read!("test/fixtures/kroeg-announce-with-inline-actor.json") |> Poison.decode!() # {:ok, %Activity{data: data, local: false}} = Transmogrifier.handle_incoming(data) # assert data["actor"] == "https://puckipedia.com/" # end # test "it works for incoming notices with tag not being an array (kroeg)" do # data = File.read!("test/fixtures/kroeg-array-less-emoji.json") |> Poison.decode!() # {:ok, %Activity{data: data, local: false}} = Transmogrifier.handle_incoming(data) # assert data["object"]["emoji"] == %{ # "icon_e_smile" => "https://puckipedia.com/forum/images/smilies/icon_e_smile.png" # } # data = File.read!("test/fixtures/kroeg-array-less-hashtag.json") |> Poison.decode!() # {:ok, %Activity{data: data, local: false}} = Transmogrifier.handle_incoming(data) # assert "test" in data["object"]["tag"] # end test "it works for incoming notices with url not being a string (prismo)" do data = File.read!("test/fixtures/prismo-url-map.json") |> Poison.decode!() assert {:error, :not_supported} == Transmogrifier.handle_incoming(data) # Pages are not supported # {:ok, %Activity{data: data, local: false}} = Transmogrifier.handle_incoming(data) # assert data["object"]["url"] == "https://prismo.news/posts/83" end test "it works for incoming follow requests" do actor = insert(:actor) data = File.read!("test/fixtures/mastodon-follow-activity.json") |> Poison.decode!() |> Map.put("object", actor.url) {:ok, %Activity{data: data, local: false}} = Transmogrifier.handle_incoming(data) assert data["actor"] == "https://social.tcit.fr/users/tcit" assert data["type"] == "Follow" assert data["id"] == "https://social.tcit.fr/users/tcit#follows/2" actor = Actors.get_actor_with_everything!(actor.id) assert Actor.following?(Actors.get_actor_by_url!(data["actor"], true), actor) end # test "it works for incoming follow requests from hubzilla" do # user = insert(:user) # data = # File.read!("test/fixtures/hubzilla-follow-activity.json") # |> Poison.decode!() # |> Map.put("object", user.ap_id) # |> Utils.normalize_params() # {:ok, %Activity{data: data, local: false}} = Transmogrifier.handle_incoming(data) # assert data["actor"] == "https://hubzilla.example.org/channel/kaniini" # assert data["type"] == "Follow" # assert data["id"] == "https://hubzilla.example.org/channel/kaniini#follows/2" # assert User.following?(User.get_by_ap_id(data["actor"]), user) # end # test "it works for incoming likes" do # %Comment{url: url} = insert(:comment) # data = # File.read!("test/fixtures/mastodon-like.json") # |> Poison.decode!() # |> Map.put("object", url) # {:ok, %Activity{data: data, local: false}} = Transmogrifier.handle_incoming(data) # assert data["actor"] == "http://mastodon.example.org/users/admin" # assert data["type"] == "Like" # assert data["id"] == "http://mastodon.example.org/users/admin#likes/2" # assert data["object"] == url # end # test "it returns an error for incoming unlikes wihout a like activity" do # %Comment{url: url} = insert(:comment) # data = # File.read!("test/fixtures/mastodon-undo-like.json") # |> Poison.decode!() # |> Map.put("object", url) # assert Transmogrifier.handle_incoming(data) == {:error, :not_supported} # end # test "it works for incoming unlikes with an existing like activity" do # comment = insert(:comment) # like_data = # File.read!("test/fixtures/mastodon-like.json") # |> Poison.decode!() # |> Map.put("object", comment.url) # {:ok, %Activity{data: like_data, local: false}} = Transmogrifier.handle_incoming(like_data) # data = # File.read!("test/fixtures/mastodon-undo-like.json") # |> Poison.decode!() # |> Map.put("object", like_data) # |> Map.put("actor", like_data["actor"]) # {:ok, %Activity{data: data, local: false}} = Transmogrifier.handle_incoming(data) # assert data["actor"] == "http://mastodon.example.org/users/admin" # assert data["type"] == "Undo" # assert data["id"] == "http://mastodon.example.org/users/admin#likes/2/undo" # assert data["object"]["id"] == "http://mastodon.example.org/users/admin#likes/2" # end # test "it works for incoming announces" do # data = File.read!("test/fixtures/mastodon-announce.json") |> Poison.decode!() # {:ok, %Activity{data: data, local: false}} = Transmogrifier.handle_incoming(data) # assert data["actor"] == "https://social.tcit.fr/users/tcit" # assert data["type"] == "Announce" # assert data["id"] == # "https://social.tcit.fr/users/tcit/statuses/101188891162897047/activity" # assert data["object"] == # "https://social.tcit.fr/users/tcit/statuses/101188891162897047" # assert %Comment{} = Events.get_comment_from_url(data["object"]) # end # test "it works for incoming announces with an existing activity" do # comment = insert(:comment) # data = # File.read!("test/fixtures/mastodon-announce.json") # |> Poison.decode!() # |> Map.put("object", comment.url) # {:ok, %Activity{data: data, local: false}} = Transmogrifier.handle_incoming(data) # assert data["actor"] == "https://social.tcit.fr/users/tcit" # assert data["type"] == "Announce" # assert data["id"] == # "https://social.tcit.fr/users/tcit/statuses/101188891162897047/activity" # assert data["object"] == comment.url # # assert Activity.get_create_activity_by_object_ap_id(data["object"]).id == activity.id # end test "it works for incoming update activities" do data = File.read!("test/fixtures/mastodon-post-activity.json") |> Poison.decode!() {:ok, %Activity{data: data, local: false}} = Transmogrifier.handle_incoming(data) update_data = File.read!("test/fixtures/mastodon-update.json") |> Poison.decode!() object = update_data["object"] |> Map.put("actor", data["actor"]) |> Map.put("id", data["actor"]) update_data = update_data |> Map.put("actor", data["actor"]) |> Map.put("object", object) {:ok, %Activity{data: data, local: false}} = Transmogrifier.handle_incoming(update_data) {:ok, %Actor{} = actor} = Actors.get_actor_by_url(data["actor"]) assert actor.name == "gargle" assert actor.avatar_url == "https://cd.niu.moe/accounts/avatars/000/033/323/original/fd7f8ae0b3ffedc9.jpeg" assert actor.banner_url == "https://cd.niu.moe/accounts/headers/000/033/323/original/850b3448fa5fd477.png" assert actor.summary == "Some bio
" end # test "it works for incoming update activities which lock the account" do # data = File.read!("test/fixtures/mastodon-post-activity.json") |> Poison.decode!() # {:ok, %Activity{data: data, local: false}} = Transmogrifier.handle_incoming(data) # update_data = File.read!("test/fixtures/mastodon-update.json") |> Poison.decode!() # object = # update_data["object"] # |> Map.put("actor", data["actor"]) # |> Map.put("id", data["actor"]) # |> Map.put("manuallyApprovesFollowers", true) # update_data = # update_data # |> Map.put("actor", data["actor"]) # |> Map.put("object", object) # {:ok, %Activity{data: data, local: false}} = Transmogrifier.handle_incoming(update_data) # user = User.get_cached_by_ap_id(data["actor"]) # assert user.info["locked"] == true # end test "it works for incoming deletes" do %Actor{url: actor_url} = actor = insert(:actor) %Comment{url: comment_url} = insert(:comment, actor: actor) data = File.read!("test/fixtures/mastodon-delete.json") |> Poison.decode!() object = data["object"] |> Map.put("id", comment_url) data = data |> Map.put("object", object) |> Map.put("actor", actor_url) assert Events.get_comment_from_url(comment_url) {:ok, %Activity{local: false}} = Transmogrifier.handle_incoming(data) refute Events.get_comment_from_url(comment_url) end # TODO : make me ASAP # test "it fails for incoming deletes with spoofed origin" do # activity = insert(:note_activity) # data = # File.read!("test/fixtures/mastodon-delete.json") # |> Poison.decode!() # object = # data["object"] # |> Map.put("id", activity.data["object"]["id"]) # data = # data # |> Map.put("object", object) # :error = Transmogrifier.handle_incoming(data) # assert Repo.get(Activity, activity.id) # end # test "it works for incoming unannounces with an existing notice" do # comment = insert(:comment) # announce_data = # File.read!("test/fixtures/mastodon-announce.json") # |> Poison.decode!() # |> Map.put("object", comment.url) # {:ok, %Activity{data: announce_data, local: false}} = # Transmogrifier.handle_incoming(announce_data) # data = # File.read!("test/fixtures/mastodon-undo-announce.json") # |> Poison.decode!() # |> Map.put("object", announce_data) # |> Map.put("actor", announce_data["actor"]) # {:ok, %Activity{data: data, local: false}} = Transmogrifier.handle_incoming(data) # assert data["type"] == "Undo" # assert data["object"]["type"] == "Announce" # assert data["object"]["object"] == comment.url # assert data["object"]["id"] == # "http://mastodon.example.org/users/admin/statuses/99542391527669785/activity" # end test "it works for incomming unfollows with an existing follow" do actor = insert(:actor) follow_data = File.read!("test/fixtures/mastodon-follow-activity.json") |> Poison.decode!() |> Map.put("object", actor.url) {:ok, %Activity{data: _, local: false}} = Transmogrifier.handle_incoming(follow_data) data = File.read!("test/fixtures/mastodon-unfollow-activity.json") |> Poison.decode!() |> Map.put("object", follow_data) {:ok, %Activity{data: data, local: false}} = Transmogrifier.handle_incoming(data) assert data["type"] == "Undo" assert data["object"]["type"] == "Follow" assert data["object"]["object"] == actor.url assert data["actor"] == "https://social.tcit.fr/users/tcit" {:ok, followed} = Actors.get_actor_by_url(data["actor"]) refute Actor.following?(followed, actor) end # test "it works for incoming blocks" do # user = insert(:user) # data = # File.read!("test/fixtures/mastodon-block-activity.json") # |> Poison.decode!() # |> Map.put("object", user.ap_id) # {:ok, %Activity{data: data, local: false}} = Transmogrifier.handle_incoming(data) # assert data["type"] == "Block" # assert data["object"] == user.ap_id # assert data["actor"] == "http://mastodon.example.org/users/admin" # blocker = User.get_by_ap_id(data["actor"]) # assert User.blocks?(blocker, user) # end # test "incoming blocks successfully tear down any follow relationship" do # blocker = insert(:user) # blocked = insert(:user) # data = # File.read!("test/fixtures/mastodon-block-activity.json") # |> Poison.decode!() # |> Map.put("object", blocked.ap_id) # |> Map.put("actor", blocker.ap_id) # {:ok, blocker} = User.follow(blocker, blocked) # {:ok, blocked} = User.follow(blocked, blocker) # assert User.following?(blocker, blocked) # assert User.following?(blocked, blocker) # {:ok, %Activity{data: data, local: false}} = Transmogrifier.handle_incoming(data) # assert data["type"] == "Block" # assert data["object"] == blocked.ap_id # assert data["actor"] == blocker.ap_id # blocker = User.get_by_ap_id(data["actor"]) # blocked = User.get_by_ap_id(data["object"]) # assert User.blocks?(blocker, blocked) # refute User.following?(blocker, blocked) # refute User.following?(blocked, blocker) # end # test "it works for incoming unblocks with an existing block" do # user = insert(:user) # block_data = # File.read!("test/fixtures/mastodon-block-activity.json") # |> Poison.decode!() # |> Map.put("object", user.ap_id) # {:ok, %Activity{data: _, local: false}} = Transmogrifier.handle_incoming(block_data) # data = # File.read!("test/fixtures/mastodon-unblock-activity.json") # |> Poison.decode!() # |> Map.put("object", block_data) # {:ok, %Activity{data: data, local: false}} = Transmogrifier.handle_incoming(data) # assert data["type"] == "Undo" # assert data["object"]["type"] == "Block" # assert data["object"]["object"] == user.ap_id # assert data["actor"] == "http://mastodon.example.org/users/admin" # blocker = User.get_by_ap_id(data["actor"]) # refute User.blocks?(blocker, user) # end # test "it works for incoming accepts which were pre-accepted" do # follower = insert(:user) # followed = insert(:user) # {:ok, follower} = User.follow(follower, followed) # assert User.following?(follower, followed) == true # {:ok, follow_activity} = ActivityPub.follow(follower, followed) # accept_data = # File.read!("test/fixtures/mastodon-accept-activity.json") # |> Poison.decode!() # |> Map.put("actor", followed.ap_id) # object = # accept_data["object"] # |> Map.put("actor", follower.ap_id) # |> Map.put("id", follow_activity.data["id"]) # accept_data = Map.put(accept_data, "object", object) # {:ok, activity} = Transmogrifier.handle_incoming(accept_data) # refute activity.local # assert activity.data["object"] == follow_activity.data["id"] # follower = Repo.get(User, follower.id) # assert User.following?(follower, followed) == true # end # test "it works for incoming accepts which were orphaned" do # follower = insert(:user) # followed = insert(:user, %{info: %{"locked" => true}}) # {:ok, follow_activity} = ActivityPub.follow(follower, followed) # accept_data = # File.read!("test/fixtures/mastodon-accept-activity.json") # |> Poison.decode!() # |> Map.put("actor", followed.ap_id) # accept_data = # Map.put(accept_data, "object", Map.put(accept_data["object"], "actor", follower.ap_id)) # {:ok, activity} = Transmogrifier.handle_incoming(accept_data) # assert activity.data["object"] == follow_activity.data["id"] # follower = Repo.get(User, follower.id) # assert User.following?(follower, followed) == true # end # test "it works for incoming accepts which are referenced by IRI only" do # follower = insert(:user) # followed = insert(:user, %{info: %{"locked" => true}}) # {:ok, follow_activity} = ActivityPub.follow(follower, followed) # accept_data = # File.read!("test/fixtures/mastodon-accept-activity.json") # |> Poison.decode!() # |> Map.put("actor", followed.ap_id) # |> Map.put("object", follow_activity.data["id"]) # {:ok, activity} = Transmogrifier.handle_incoming(accept_data) # assert activity.data["object"] == follow_activity.data["id"] # follower = Repo.get(User, follower.id) # assert User.following?(follower, followed) == true # end # test "it fails for incoming accepts which cannot be correlated" do # follower = insert(:user) # followed = insert(:user, %{info: %{"locked" => true}}) # accept_data = # File.read!("test/fixtures/mastodon-accept-activity.json") # |> Poison.decode!() # |> Map.put("actor", followed.ap_id) # accept_data = # Map.put(accept_data, "object", Map.put(accept_data["object"], "actor", follower.ap_id)) # :error = Transmogrifier.handle_incoming(accept_data) # follower = Repo.get(User, follower.id) # refute User.following?(follower, followed) == true # end # test "it fails for incoming rejects which cannot be correlated" do # follower = insert(:user) # followed = insert(:user, %{info: %{"locked" => true}}) # accept_data = # File.read!("test/fixtures/mastodon-reject-activity.json") # |> Poison.decode!() # |> Map.put("actor", followed.ap_id) # accept_data = # Map.put(accept_data, "object", Map.put(accept_data["object"], "actor", follower.ap_id)) # :error = Transmogrifier.handle_incoming(accept_data) # follower = Repo.get(User, follower.id) # refute User.following?(follower, followed) == true # end # test "it works for incoming rejects which are orphaned" do # follower = insert(:user) # followed = insert(:user, %{info: %{"locked" => true}}) # {:ok, follower} = User.follow(follower, followed) # {:ok, _follow_activity} = ActivityPub.follow(follower, followed) # assert User.following?(follower, followed) == true # reject_data = # File.read!("test/fixtures/mastodon-reject-activity.json") # |> Poison.decode!() # |> Map.put("actor", followed.ap_id) # reject_data = # Map.put(reject_data, "object", Map.put(reject_data["object"], "actor", follower.ap_id)) # {:ok, activity} = Transmogrifier.handle_incoming(reject_data) # refute activity.local # follower = Repo.get(User, follower.id) # assert User.following?(follower, followed) == false # end # test "it works for incoming rejects which are referenced by IRI only" do # follower = insert(:user) # followed = insert(:user, %{info: %{"locked" => true}}) # {:ok, follower} = User.follow(follower, followed) # {:ok, follow_activity} = ActivityPub.follow(follower, followed) # assert User.following?(follower, followed) == true # reject_data = # File.read!("test/fixtures/mastodon-reject-activity.json") # |> Poison.decode!() # |> Map.put("actor", followed.ap_id) # |> Map.put("object", follow_activity.data["id"]) # {:ok, %Activity{data: _}} = Transmogrifier.handle_incoming(reject_data) # follower = Repo.get(User, follower.id) # assert User.following?(follower, followed) == false # end # test "it rejects activities without a valid ID" do # user = insert(:user) # data = # File.read!("test/fixtures/mastodon-follow-activity.json") # |> Poison.decode!() # |> Map.put("object", user.ap_id) # |> Map.put("id", "") # :error = Transmogrifier.handle_incoming(data) # end end describe "prepare outgoing" do test "it turns mentions into tags" do actor = insert(:actor) other_actor = insert(:actor) {:ok, activity} = MobilizonWeb.API.Comments.create_comment( actor.preferred_username, "hey, @#{other_actor.preferred_username}, how are ya? #2hu" ) {:ok, modified} = Transmogrifier.prepare_outgoing(activity.data) object = modified["object"] expected_mention = %{ "href" => other_actor.url, "name" => "@#{other_actor.preferred_username}", "type" => "Mention" } expected_tag = %{ "href" => MobilizonWeb.Endpoint.url() <> "/tags/2hu", "type" => "Hashtag", "name" => "#2hu" } assert Enum.member?(object["tag"], expected_tag) assert Enum.member?(object["tag"], expected_mention) end # test "it adds the sensitive property" do # user = insert(:user) # {:ok, activity} = CommonAPI.post(user, %{"status" => "#nsfw hey"}) # {:ok, modified} = Transmogrifier.prepare_outgoing(activity.data) # assert modified["object"]["sensitive"] # end test "it adds the json-ld context and the conversation property" do actor = insert(:actor) {:ok, activity} = MobilizonWeb.API.Comments.create_comment(actor.preferred_username, "hey") {:ok, modified} = Transmogrifier.prepare_outgoing(activity.data) assert modified["@context"] == Mobilizon.Service.ActivityPub.Utils.make_json_ld_header()["@context"] end test "it sets the 'attributedTo' property to the actor of the object if it doesn't have one" do actor = insert(:actor) {:ok, activity} = MobilizonWeb.API.Comments.create_comment(actor.preferred_username, "hey") {:ok, modified} = Transmogrifier.prepare_outgoing(activity.data) assert modified["object"]["actor"] == modified["object"]["attributedTo"] end test "it strips internal hashtag data" do actor = insert(:actor) {:ok, activity} = MobilizonWeb.API.Comments.create_comment(actor.preferred_username, "#2hu") expected_tag = %{ "href" => MobilizonWeb.Endpoint.url() <> "/tags/2hu", "type" => "Hashtag", "name" => "#2hu" } {:ok, modified} = Transmogrifier.prepare_outgoing(activity.data) assert modified["object"]["tag"] == [expected_tag] end test "it strips internal fields" do actor = insert(:actor) {:ok, activity} = MobilizonWeb.API.Comments.create_comment(actor.preferred_username, "#2hu") {:ok, modified} = Transmogrifier.prepare_outgoing(activity.data) # TODO : When and if custom emoji are implemented, this should be 2 assert length(modified["object"]["tag"]) == 1 assert is_nil(modified["object"]["emoji"]) assert is_nil(modified["object"]["likes"]) assert is_nil(modified["object"]["like_count"]) assert is_nil(modified["object"]["announcements"]) assert is_nil(modified["object"]["announcement_count"]) assert is_nil(modified["object"]["context_id"]) end # describe "actor rewriting" do # test "it fixes the actor URL property to be a proper URI" do # data = %{ # "url" => %{"href" => "http://example.com"} # } # rewritten = Transmogrifier.maybe_fix_user_object(data) # assert rewritten["url"] == "http://example.com" # end # end # describe "actor origin containment" do # test "it rejects objects with a bogus origin" do # {:error, _} = ActivityPub.fetch_object_from_id("https://info.pleroma.site/activity.json") # end # test "it rejects activities which reference objects with bogus origins" do # data = %{ # "@context" => "https://www.w3.org/ns/activitystreams", # "id" => "http://mastodon.example.org/users/admin/activities/1234", # "actor" => "http://mastodon.example.org/users/admin", # "to" => ["https://www.w3.org/ns/activitystreams#Public"], # "object" => "https://info.pleroma.site/activity.json", # "type" => "Announce" # } # :error = Transmogrifier.handle_incoming(data) # end # test "it rejects objects when attributedTo is wrong (variant 1)" do # {:error, _} = ActivityPub.fetch_object_from_id("https://info.pleroma.site/activity2.json") # end # test "it rejects activities which reference objects that have an incorrect attribution (variant 1)" do # data = %{ # "@context" => "https://www.w3.org/ns/activitystreams", # "id" => "http://mastodon.example.org/users/admin/activities/1234", # "actor" => "http://mastodon.example.org/users/admin", # "to" => ["https://www.w3.org/ns/activitystreams#Public"], # "object" => "https://info.pleroma.site/activity2.json", # "type" => "Announce" # } # :error = Transmogrifier.handle_incoming(data) # end # test "it rejects objects when attributedTo is wrong (variant 2)" do # {:error, _} = ActivityPub.fetch_object_from_id("https://info.pleroma.site/activity3.json") # end # test "it rejects activities which reference objects that have an incorrect attribution (variant 2)" do # data = %{ # "@context" => "https://www.w3.org/ns/activitystreams", # "id" => "http://mastodon.example.org/users/admin/activities/1234", # "actor" => "http://mastodon.example.org/users/admin", # "to" => ["https://www.w3.org/ns/activitystreams#Public"], # "object" => "https://info.pleroma.site/activity3.json", # "type" => "Announce" # } # :error = Transmogrifier.handle_incoming(data) # end # end # describe "general origin containment" do # test "contain_origin_from_id() catches obvious spoofing attempts" do # data = %{ # "id" => "http://example.com/~alyssa/activities/1234.json" # } # :error = # Transmogrifier.contain_origin_from_id( # "http://example.org/~alyssa/activities/1234.json", # data # ) # end # test "contain_origin_from_id() allows alternate IDs within the same origin domain" do # data = %{ # "id" => "http://example.com/~alyssa/activities/1234.json" # } # :ok = # Transmogrifier.contain_origin_from_id( # "http://example.com/~alyssa/activities/1234", # data # ) # end # test "contain_origin_from_id() allows matching IDs" do # data = %{ # "id" => "http://example.com/~alyssa/activities/1234.json" # } # :ok = # Transmogrifier.contain_origin_from_id( # "http://example.com/~alyssa/activities/1234.json", # data # ) # end # test "users cannot be collided through fake direction spoofing attempts" do # user = # insert(:user, %{ # nickname: "rye@niu.moe", # local: false, # ap_id: "https://niu.moe/users/rye", # follower_address: User.ap_followers(%User{nickname: "rye@niu.moe"}) # }) # {:error, _} = User.get_or_fetch_by_ap_id("https://n1u.moe/users/rye") # end # test "all objects with fake directions are rejected by the object fetcher" do # {:error, _} = # ActivityPub.fetch_and_contain_remote_object_from_id( # "https://info.pleroma.site/activity4.json" # ) # end end end