git.squeep.com Git - akkoma/blob - test/web/ostatus/ostatus_test.exs

   1 defmodule Pleroma.Web.OStatusTest do
   2   use Pleroma.DataCase
   3   alias Pleroma.Web.OStatus
   4   alias Pleroma.Web.XML
   5   alias Pleroma.{Object, Repo, User, Activity}
   6   import Pleroma.Factory
   7   import ExUnit.CaptureLog
   8
   9   test "don't insert create notes twice" do
  10     incoming = File.read!("test/fixtures/incoming_note_activity.xml")
  11     {:ok, [activity]} = OStatus.handle_incoming(incoming)
  12     assert {:ok, [activity]} == OStatus.handle_incoming(incoming)
  13   end
  14
  15   test "handle incoming note - GS, Salmon" do
  16     incoming = File.read!("test/fixtures/incoming_note_activity.xml")
  17     {:ok, [activity]} = OStatus.handle_incoming(incoming)
  18     object = Object.normalize(activity.data["object"])
  19
  20     user = User.get_by_ap_id(activity.data["actor"])
  21     assert user.info.note_count == 1
  22     assert activity.data["type"] == "Create"
  23     assert object.data["type"] == "Note"
  24
  25     assert object.data["id"] ==
  26              "tag:gs.example.org:4040,2017-04-23:noticeId=29:objectType=note"
  27
  28     assert activity.data["published"] == "2017-04-23T14:51:03+00:00"
  29     assert object.data["published"] == "2017-04-23T14:51:03+00:00"
  30
  31     assert activity.data["context"] ==
  32              "tag:gs.example.org:4040,2017-04-23:objectType=thread:nonce=f09e22f58abd5c7b"
  33
  34     assert "http://pleroma.example.org:4000/users/lain3" in activity.data["to"]
  35     assert object.data["emoji"] == %{"marko" => "marko.png", "reimu" => "reimu.png"}
  36     assert activity.local == false
  37   end
  38
  39   test "handle incoming notes - GS, subscription" do
  40     incoming = File.read!("test/fixtures/ostatus_incoming_post.xml")
  41     {:ok, [activity]} = OStatus.handle_incoming(incoming)
  42     object = Object.normalize(activity.data["object"])
  43
  44     assert activity.data["type"] == "Create"
  45     assert object.data["type"] == "Note"
  46     assert object.data["actor"] == "https://social.heldscal.la/user/23211"
  47     assert object.data["content"] == "Will it blend?"
  48     user = User.get_cached_by_ap_id(activity.data["actor"])
  49     assert User.ap_followers(user) in activity.data["to"]
  50     assert "https://www.w3.org/ns/activitystreams#Public" in activity.data["to"]
  51   end
  52
  53   test "handle incoming notes with attachments - GS, subscription" do
  54     incoming = File.read!("test/fixtures/incoming_websub_gnusocial_attachments.xml")
  55     {:ok, [activity]} = OStatus.handle_incoming(incoming)
  56     object = Object.normalize(activity.data["object"])
  57
  58     assert activity.data["type"] == "Create"
  59     assert object.data["type"] == "Note"
  60     assert object.data["actor"] == "https://social.heldscal.la/user/23211"
  61     assert object.data["attachment"] |> length == 2
  62     assert object.data["external_url"] == "https://social.heldscal.la/notice/2020923"
  63     assert "https://www.w3.org/ns/activitystreams#Public" in activity.data["to"]
  64   end
  65
  66   test "handle incoming notes with tags" do
  67     incoming = File.read!("test/fixtures/ostatus_incoming_post_tag.xml")
  68     {:ok, [activity]} = OStatus.handle_incoming(incoming)
  69     object = Object.normalize(activity.data["object"])
  70
  71     assert object.data["tag"] == ["nsfw"]
  72     assert "https://www.w3.org/ns/activitystreams#Public" in activity.data["to"]
  73   end
  74
  75   test "handle incoming notes - Mastodon, salmon, reply" do
  76     # It uses the context of the replied to object
  77     Repo.insert!(%Object{
  78       data: %{
  79         "id" => "https://pleroma.soykaf.com/objects/c237d966-ac75-4fe3-a87a-d89d71a3a7a4",
  80         "context" => "2hu"
  81       }
  82     })
  83
  84     incoming = File.read!("test/fixtures/incoming_reply_mastodon.xml")
  85     {:ok, [activity]} = OStatus.handle_incoming(incoming)
  86     object = Object.normalize(activity.data["object"])
  87
  88     assert activity.data["type"] == "Create"
  89     assert object.data["type"] == "Note"
  90     assert object.data["actor"] == "https://mastodon.social/users/lambadalambda"
  91     assert activity.data["context"] == "2hu"
  92     assert "https://www.w3.org/ns/activitystreams#Public" in activity.data["to"]
  93   end
  94
  95   test "handle incoming notes - Mastodon, with CW" do
  96     incoming = File.read!("test/fixtures/mastodon-note-cw.xml")
  97     {:ok, [activity]} = OStatus.handle_incoming(incoming)
  98     object = Object.normalize(activity.data["object"])
  99
 100     assert activity.data["type"] == "Create"
 101     assert object.data["type"] == "Note"
 102     assert object.data["actor"] == "https://mastodon.social/users/lambadalambda"
 103     assert object.data["summary"] == "technologic"
 104     assert "https://www.w3.org/ns/activitystreams#Public" in activity.data["to"]
 105   end
 106
 107   test "handle incoming unlisted messages, put public into cc" do
 108     incoming = File.read!("test/fixtures/mastodon-note-unlisted.xml")
 109     {:ok, [activity]} = OStatus.handle_incoming(incoming)
 110     object = Object.normalize(activity.data["object"])
 111
 112     refute "https://www.w3.org/ns/activitystreams#Public" in activity.data["to"]
 113     assert "https://www.w3.org/ns/activitystreams#Public" in activity.data["cc"]
 114     refute "https://www.w3.org/ns/activitystreams#Public" in object.data["to"]
 115     assert "https://www.w3.org/ns/activitystreams#Public" in object.data["cc"]
 116   end
 117
 118   test "handle incoming retweets - Mastodon, with CW" do
 119     incoming = File.read!("test/fixtures/cw_retweet.xml")
 120     {:ok, [[_activity, retweeted_activity]]} = OStatus.handle_incoming(incoming)
 121     retweeted_object = Object.normalize(retweeted_activity.data["object"])
 122
 123     assert retweeted_object.data["summary"] == "Hey."
 124   end
 125
 126   test "handle incoming notes - GS, subscription, reply" do
 127     incoming = File.read!("test/fixtures/ostatus_incoming_reply.xml")
 128     {:ok, [activity]} = OStatus.handle_incoming(incoming)
 129     object = Object.normalize(activity.data["object"])
 130
 131     assert activity.data["type"] == "Create"
 132     assert object.data["type"] == "Note"
 133     assert object.data["actor"] == "https://social.heldscal.la/user/23211"
 134
 135     assert object.data["content"] ==
 136              "@<a href=\"https://gs.archae.me/user/4687\" class=\"h-card u-url p-nickname mention\" title=\"shpbot\">shpbot</a> why not indeed."
 137
 138     assert object.data["inReplyTo"] ==
 139              "tag:gs.archae.me,2017-04-30:noticeId=778260:objectType=note"
 140
 141     assert "https://www.w3.org/ns/activitystreams#Public" in activity.data["to"]
 142   end
 143
 144   test "handle incoming retweets - GS, subscription" do
 145     incoming = File.read!("test/fixtures/share-gs.xml")
 146     {:ok, [[activity, retweeted_activity]]} = OStatus.handle_incoming(incoming)
 147
 148     assert activity.data["type"] == "Announce"
 149     assert activity.data["actor"] == "https://social.heldscal.la/user/23211"
 150     assert activity.data["object"] == retweeted_activity.data["object"]
 151     assert "https://pleroma.soykaf.com/users/lain" in activity.data["to"]
 152     refute activity.local
 153
 154     retweeted_activity = Repo.get(Activity, retweeted_activity.id)
 155     retweeted_object = Object.normalize(retweeted_activity.data["object"])
 156
 157     assert retweeted_activity.data["type"] == "Create"
 158     assert retweeted_activity.data["actor"] == "https://pleroma.soykaf.com/users/lain"
 159     refute retweeted_activity.local
 160     assert retweeted_object.data["announcement_count"] == 1
 161     assert String.contains?(retweeted_object.data["content"], "mastodon")
 162     refute String.contains?(retweeted_object.data["content"], "Test account")
 163   end
 164
 165   test "handle incoming retweets - GS, subscription - local message" do
 166     incoming = File.read!("test/fixtures/share-gs-local.xml")
 167     note_activity = insert(:note_activity)
 168     user = User.get_cached_by_ap_id(note_activity.data["actor"])
 169
 170     incoming =
 171       incoming
 172       |> String.replace("LOCAL_ID", note_activity.data["object"]["id"])
 173       |> String.replace("LOCAL_USER", user.ap_id)
 174
 175     {:ok, [[activity, retweeted_activity]]} = OStatus.handle_incoming(incoming)
 176
 177     assert activity.data["type"] == "Announce"
 178     assert activity.data["actor"] == "https://social.heldscal.la/user/23211"
 179     assert activity.data["object"] == retweeted_activity.data["object"]["id"]
 180     assert user.ap_id in activity.data["to"]
 181     refute activity.local
 182
 183     retweeted_activity = Repo.get(Activity, retweeted_activity.id)
 184     assert note_activity.id == retweeted_activity.id
 185     assert retweeted_activity.data["type"] == "Create"
 186     assert retweeted_activity.data["actor"] == user.ap_id
 187     assert retweeted_activity.local
 188     assert retweeted_activity.data["object"]["announcement_count"] == 1
 189   end
 190
 191   test "handle incoming retweets - Mastodon, salmon" do
 192     incoming = File.read!("test/fixtures/share.xml")
 193     {:ok, [[activity, retweeted_activity]]} = OStatus.handle_incoming(incoming)
 194     retweeted_object = Object.normalize(retweeted_activity.data["object"])
 195
 196     assert activity.data["type"] == "Announce"
 197     assert activity.data["actor"] == "https://mastodon.social/users/lambadalambda"
 198     assert activity.data["object"] == retweeted_activity.data["object"]
 199
 200     assert activity.data["id"] ==
 201              "tag:mastodon.social,2017-05-03:objectId=4934452:objectType=Status"
 202
 203     refute activity.local
 204     assert retweeted_activity.data["type"] == "Create"
 205     assert retweeted_activity.data["actor"] == "https://pleroma.soykaf.com/users/lain"
 206     refute retweeted_activity.local
 207     refute String.contains?(retweeted_object.data["content"], "Test account")
 208   end
 209
 210   test "handle incoming favorites - GS, websub" do
 211     capture_log(fn ->
 212       incoming = File.read!("test/fixtures/favorite.xml")
 213       {:ok, [[activity, favorited_activity]]} = OStatus.handle_incoming(incoming)
 214
 215       assert activity.data["type"] == "Like"
 216       assert activity.data["actor"] == "https://social.heldscal.la/user/23211"
 217       assert activity.data["object"] == favorited_activity.data["object"]
 218
 219       assert activity.data["id"] ==
 220                "tag:social.heldscal.la,2017-05-05:fave:23211:comment:2061643:2017-05-05T09:12:50+00:00"
 221
 222       refute activity.local
 223       assert favorited_activity.data["type"] == "Create"
 224       assert favorited_activity.data["actor"] == "https://shitposter.club/user/1"
 225
 226       assert favorited_activity.data["object"] ==
 227                "tag:shitposter.club,2017-05-05:noticeId=2827873:objectType=comment"
 228
 229       refute favorited_activity.local
 230     end)
 231   end
 232
 233   test "handle conversation references" do
 234     incoming = File.read!("test/fixtures/mastodon_conversation.xml")
 235     {:ok, [activity]} = OStatus.handle_incoming(incoming)
 236
 237     assert activity.data["context"] ==
 238              "tag:mastodon.social,2017-08-28:objectId=7876885:objectType=Conversation"
 239   end
 240
 241   test "handle incoming favorites with locally available object - GS, websub" do
 242     note_activity = insert(:note_activity)
 243
 244     incoming =
 245       File.read!("test/fixtures/favorite_with_local_note.xml")
 246       |> String.replace("localid", note_activity.data["object"]["id"])
 247
 248     {:ok, [[activity, favorited_activity]]} = OStatus.handle_incoming(incoming)
 249
 250     assert activity.data["type"] == "Like"
 251     assert activity.data["actor"] == "https://social.heldscal.la/user/23211"
 252     assert activity.data["object"] == favorited_activity.data["object"]["id"]
 253     refute activity.local
 254     assert note_activity.id == favorited_activity.id
 255     assert favorited_activity.local
 256   end
 257
 258   test "handle incoming replies" do
 259     incoming = File.read!("test/fixtures/incoming_note_activity_answer.xml")
 260     {:ok, [activity]} = OStatus.handle_incoming(incoming)
 261     object = Object.normalize(activity.data["object"])
 262
 263     assert activity.data["type"] == "Create"
 264     assert object.data["type"] == "Note"
 265
 266     assert object.data["inReplyTo"] ==
 267              "http://pleroma.example.org:4000/objects/55bce8fc-b423-46b1-af71-3759ab4670bc"
 268
 269     assert "http://pleroma.example.org:4000/users/lain5" in activity.data["to"]
 270
 271     assert object.data["id"] ==
 272              "tag:gs.example.org:4040,2017-04-25:noticeId=55:objectType=note"
 273
 274     assert "https://www.w3.org/ns/activitystreams#Public" in activity.data["to"]
 275   end
 276
 277   test "handle incoming follows" do
 278     incoming = File.read!("test/fixtures/follow.xml")
 279     {:ok, [activity]} = OStatus.handle_incoming(incoming)
 280     assert activity.data["type"] == "Follow"
 281
 282     assert activity.data["id"] ==
 283              "tag:social.heldscal.la,2017-05-07:subscription:23211:person:44803:2017-05-07T09:54:48+00:00"
 284
 285     assert activity.data["actor"] == "https://social.heldscal.la/user/23211"
 286     assert activity.data["object"] == "https://pawoo.net/users/pekorino"
 287     refute activity.local
 288
 289     follower = User.get_by_ap_id(activity.data["actor"])
 290     followed = User.get_by_ap_id(activity.data["object"])
 291
 292     assert User.following?(follower, followed)
 293   end
 294
 295   test "handle incoming unfollows with existing follow" do
 296     incoming_follow = File.read!("test/fixtures/follow.xml")
 297     {:ok, [_activity]} = OStatus.handle_incoming(incoming_follow)
 298
 299     incoming = File.read!("test/fixtures/unfollow.xml")
 300     {:ok, [activity]} = OStatus.handle_incoming(incoming)
 301
 302     assert activity.data["type"] == "Undo"
 303
 304     assert activity.data["id"] ==
 305              "undo:tag:social.heldscal.la,2017-05-07:subscription:23211:person:44803:2017-05-07T09:54:48+00:00"
 306
 307     assert activity.data["actor"] == "https://social.heldscal.la/user/23211"
 308     assert is_map(activity.data["object"])
 309     assert activity.data["object"]["type"] == "Follow"
 310     assert activity.data["object"]["object"] == "https://pawoo.net/users/pekorino"
 311     refute activity.local
 312
 313     follower = User.get_by_ap_id(activity.data["actor"])
 314     followed = User.get_by_ap_id(activity.data["object"]["object"])
 315
 316     refute User.following?(follower, followed)
 317   end
 318
 319   describe "new remote user creation" do
 320     test "returns local users" do
 321       local_user = insert(:user)
 322       {:ok, user} = OStatus.find_or_make_user(local_user.ap_id)
 323
 324       assert user == local_user
 325     end
 326
 327     test "tries to use the information in poco fields" do
 328       uri = "https://social.heldscal.la/user/23211"
 329
 330       {:ok, user} = OStatus.find_or_make_user(uri)
 331
 332       user = Repo.get(Pleroma.User, user.id)
 333       assert user.name == "Constance Variable"
 334       assert user.nickname == "lambadalambda@social.heldscal.la"
 335       assert user.local == false
 336       assert user.info.uri == uri
 337       assert user.ap_id == uri
 338       assert user.bio == "Call me Deacon Blues."
 339       assert user.avatar["type"] == "Image"
 340
 341       {:ok, user_again} = OStatus.find_or_make_user(uri)
 342
 343       assert user == user_again
 344     end
 345
 346     test "find_or_make_user sets all the nessary input fields" do
 347       uri = "https://social.heldscal.la/user/23211"
 348       {:ok, user} = OStatus.find_or_make_user(uri)
 349
 350       assert user.info ==
 351                %Pleroma.User.Info{
 352                  id: user.info.id,
 353                  ap_enabled: false,
 354                  background: %{},
 355                  banner: %{},
 356                  blocks: [],
 357                  deactivated: false,
 358                  default_scope: "public",
 359                  domain_blocks: [],
 360                  follower_count: 0,
 361                  is_admin: false,
 362                  is_moderator: false,
 363                  keys: nil,
 364                  locked: false,
 365                  no_rich_text: false,
 366                  note_count: 0,
 367                  settings: nil,
 368                  source_data: %{},
 369                  hub: "https://social.heldscal.la/main/push/hub",
 370                  magic_key:
 371                    "RSA.uzg6r1peZU0vXGADWxGJ0PE34WvmhjUmydbX5YYdOiXfODVLwCMi1umGoqUDm-mRu4vNEdFBVJU1CpFA7dKzWgIsqsa501i2XqElmEveXRLvNRWFB6nG03Q5OUY2as8eE54BJm0p20GkMfIJGwP6TSFb-ICp3QjzbatuSPJ6xCE=.AQAB",
 372                  salmon: "https://social.heldscal.la/main/salmon/user/23211",
 373                  topic: "https://social.heldscal.la/api/statuses/user_timeline/23211.atom",
 374                  uri: "https://social.heldscal.la/user/23211"
 375                }
 376     end
 377
 378     test "find_make_or_update_user takes an author element and returns an updated user" do
 379       uri = "https://social.heldscal.la/user/23211"
 380
 381       {:ok, user} = OStatus.find_or_make_user(uri)
 382       old_name = user.name
 383       old_bio = user.bio
 384       change = Ecto.Changeset.change(user, %{avatar: nil, bio: nil, old_name: nil})
 385
 386       {:ok, user} = Repo.update(change)
 387       refute user.avatar
 388
 389       doc = XML.parse_document(File.read!("test/fixtures/23211.atom"))
 390       [author] = :xmerl_xpath.string('//author[1]', doc)
 391       {:ok, user} = OStatus.find_make_or_update_user(author)
 392       assert user.avatar["type"] == "Image"
 393       assert user.name == old_name
 394       assert user.bio == old_bio
 395
 396       {:ok, user_again} = OStatus.find_make_or_update_user(author)
 397       assert user_again == user
 398     end
 399   end
 400
 401   describe "gathering user info from a user id" do
 402     test "it returns user info in a hash" do
 403       user = "shp@social.heldscal.la"
 404
 405       # TODO: make test local
 406       {:ok, data} = OStatus.gather_user_info(user)
 407
 408       expected = %{
 409         "hub" => "https://social.heldscal.la/main/push/hub",
 410         "magic_key" =>
 411           "RSA.wQ3i9UA0qmAxZ0WTIp4a-waZn_17Ez1pEEmqmqoooRsG1_BvpmOvLN0G2tEcWWxl2KOtdQMCiPptmQObeZeuj48mdsDZ4ArQinexY2hCCTcbV8Xpswpkb8K05RcKipdg07pnI7tAgQ0VWSZDImncL6YUGlG5YN8b5TjGOwk2VG8=.AQAB",
 412         "name" => "shp",
 413         "nickname" => "shp",
 414         "salmon" => "https://social.heldscal.la/main/salmon/user/29191",
 415         "subject" => "acct:shp@social.heldscal.la",
 416         "topic" => "https://social.heldscal.la/api/statuses/user_timeline/29191.atom",
 417         "uri" => "https://social.heldscal.la/user/29191",
 418         "host" => "social.heldscal.la",
 419         "fqn" => user,
 420         "bio" => "cofe",
 421         "avatar" => %{
 422           "type" => "Image",
 423           "url" => [
 424             %{
 425               "href" => "https://social.heldscal.la/avatar/29191-original-20170421154949.jpeg",
 426               "mediaType" => "image/jpeg",
 427               "type" => "Link"
 428             }
 429           ]
 430         },
 431         "subscribe_address" => "https://social.heldscal.la/main/ostatussub?profile={uri}",
 432         "ap_id" => nil
 433       }
 434
 435       assert data == expected
 436     end
 437
 438     test "it works with the uri" do
 439       user = "https://social.heldscal.la/user/29191"
 440
 441       # TODO: make test local
 442       {:ok, data} = OStatus.gather_user_info(user)
 443
 444       expected = %{
 445         "hub" => "https://social.heldscal.la/main/push/hub",
 446         "magic_key" =>
 447           "RSA.wQ3i9UA0qmAxZ0WTIp4a-waZn_17Ez1pEEmqmqoooRsG1_BvpmOvLN0G2tEcWWxl2KOtdQMCiPptmQObeZeuj48mdsDZ4ArQinexY2hCCTcbV8Xpswpkb8K05RcKipdg07pnI7tAgQ0VWSZDImncL6YUGlG5YN8b5TjGOwk2VG8=.AQAB",
 448         "name" => "shp",
 449         "nickname" => "shp",
 450         "salmon" => "https://social.heldscal.la/main/salmon/user/29191",
 451         "subject" => "https://social.heldscal.la/user/29191",
 452         "topic" => "https://social.heldscal.la/api/statuses/user_timeline/29191.atom",
 453         "uri" => "https://social.heldscal.la/user/29191",
 454         "host" => "social.heldscal.la",
 455         "fqn" => user,
 456         "bio" => "cofe",
 457         "avatar" => %{
 458           "type" => "Image",
 459           "url" => [
 460             %{
 461               "href" => "https://social.heldscal.la/avatar/29191-original-20170421154949.jpeg",
 462               "mediaType" => "image/jpeg",
 463               "type" => "Link"
 464             }
 465           ]
 466         },
 467         "subscribe_address" => "https://social.heldscal.la/main/ostatussub?profile={uri}",
 468         "ap_id" => nil
 469       }
 470
 471       assert data == expected
 472     end
 473   end
 474
 475   describe "fetching a status by it's HTML url" do
 476     test "it builds a missing status from an html url" do
 477       capture_log(fn ->
 478         url = "https://shitposter.club/notice/2827873"
 479         {:ok, [activity]} = OStatus.fetch_activity_from_url(url)
 480
 481         assert activity.data["actor"] == "https://shitposter.club/user/1"
 482
 483         assert activity.data["object"] ==
 484                  "tag:shitposter.club,2017-05-05:noticeId=2827873:objectType=comment"
 485       end)
 486     end
 487
 488     test "it works for atom notes, too" do
 489       url = "https://social.sakamoto.gq/objects/0ccc1a2c-66b0-4305-b23a-7f7f2b040056"
 490       {:ok, [activity]} = OStatus.fetch_activity_from_url(url)
 491       assert activity.data["actor"] == "https://social.sakamoto.gq/users/eal"
 492       assert activity.data["object"] == url
 493     end
 494   end
 495
 496   test "it doesn't add nil in the to field" do
 497     incoming = File.read!("test/fixtures/nil_mention_entry.xml")
 498     {:ok, [activity]} = OStatus.handle_incoming(incoming)
 499
 500     assert activity.data["to"] == [
 501              "http://localhost:4001/users/atarifrosch@social.stopwatchingus-heidelberg.de/followers",
 502              "https://www.w3.org/ns/activitystreams#Public"
 503            ]
 504   end
 505
 506   describe "is_representable?" do
 507     test "Note objects are representable" do
 508       note_activity = insert(:note_activity)
 509
 510       assert OStatus.is_representable?(note_activity)
 511     end
 512
 513     test "Article objects are not representable" do
 514       note_activity = insert(:note_activity)
 515
 516       note_object = Object.normalize(note_activity.data["object"])
 517
 518       note_data =
 519         note_object.data
 520         |> Map.put("type", "Article")
 521
 522       cs = Object.change(note_object, %{data: note_data})
 523       {:ok, article_object} = Repo.update(cs)
 524
 525       # the underlying object is now an Article instead of a note, so this should fail
 526       refute OStatus.is_representable?(note_activity)
 527     end
 528   end
 529 end