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