94a7353378e2d091d3d7d4d69ca90a4fffe82edb
[akkoma] / 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}
6
7 test "don't insert create notes twice" do
8 incoming = File.read!("test/fixtures/incoming_note_activity.xml")
9 {:ok, [_activity]} = OStatus.handle_incoming(incoming)
10 assert {:ok, [{:error, "duplicate activity"}]} == OStatus.handle_incoming(incoming)
11 end
12
13 test "handle incoming note - GS, Salmon" do
14 incoming = File.read!("test/fixtures/incoming_note_activity.xml")
15 {:ok, [activity]} = OStatus.handle_incoming(incoming)
16
17 assert activity.data["type"] == "Create"
18 assert activity.data["object"]["type"] == "Note"
19 assert activity.data["object"]["id"] == "tag:gs.example.org:4040,2017-04-23:noticeId=29:objectType=note"
20 assert activity.data["published"] == "2017-04-23T14:51:03+00:00"
21 assert activity.data["context"] == "tag:gs.example.org:4040,2017-04-23:objectType=thread:nonce=f09e22f58abd5c7b"
22 assert "http://pleroma.example.org:4000/users/lain3" in activity.data["to"]
23 assert activity.local == false
24 end
25
26 test "handle incoming notes - GS, subscription" do
27 incoming = File.read!("test/fixtures/ostatus_incoming_post.xml")
28 {:ok, [activity]} = OStatus.handle_incoming(incoming)
29
30 assert activity.data["type"] == "Create"
31 assert activity.data["object"]["type"] == "Note"
32 assert activity.data["object"]["actor"] == "https://social.heldscal.la/user/23211"
33 assert activity.data["object"]["content"] == "Will it blend?"
34 end
35
36 test "handle incoming notes with attachments - GS, subscription" do
37 incoming = File.read!("test/fixtures/incoming_websub_gnusocial_attachments.xml")
38 {:ok, [activity]} = OStatus.handle_incoming(incoming)
39
40 assert activity.data["type"] == "Create"
41 assert activity.data["object"]["type"] == "Note"
42 assert activity.data["object"]["actor"] == "https://social.heldscal.la/user/23211"
43 assert activity.data["object"]["attachment"] |> length == 2
44 end
45
46 test "handle incoming notes - Mastodon, salmon, reply" do
47 # It uses the context of the replied to object
48 Repo.insert!(%Object{
49 data: %{
50 "id" => "https://pleroma.soykaf.com/objects/c237d966-ac75-4fe3-a87a-d89d71a3a7a4",
51 "context" => "2hu"
52 }})
53 incoming = File.read!("test/fixtures/incoming_reply_mastodon.xml")
54 {:ok, [activity]} = OStatus.handle_incoming(incoming)
55
56 assert activity.data["type"] == "Create"
57 assert activity.data["object"]["type"] == "Note"
58 assert activity.data["object"]["actor"] == "https://mastodon.social/users/lambadalambda"
59 assert activity.data["context"] == "2hu"
60 end
61
62 test "handle incoming notes - GS, subscription, reply" do
63 incoming = File.read!("test/fixtures/ostatus_incoming_reply.xml")
64 {:ok, [activity]} = OStatus.handle_incoming(incoming)
65
66 assert activity.data["type"] == "Create"
67 assert activity.data["object"]["type"] == "Note"
68 assert activity.data["object"]["actor"] == "https://social.heldscal.la/user/23211"
69 assert activity.data["object"]["content"] == "@<a href=\"https://gs.archae.me/user/4687\" class=\"h-card u-url p-nickname mention\" title=\"shpbot\">shpbot</a> why not indeed."
70 assert activity.data["object"]["inReplyTo"] == "tag:gs.archae.me,2017-04-30:noticeId=778260:objectType=note"
71 end
72
73 test "handle incoming replies" do
74 incoming = File.read!("test/fixtures/incoming_note_activity_answer.xml")
75 {:ok, [activity]} = OStatus.handle_incoming(incoming)
76
77 assert activity.data["type"] == "Create"
78 assert activity.data["object"]["type"] == "Note"
79 assert activity.data["object"]["inReplyTo"] == "http://pleroma.example.org:4000/objects/55bce8fc-b423-46b1-af71-3759ab4670bc"
80 assert "http://pleroma.example.org:4000/users/lain5" in activity.data["to"]
81 end
82
83 describe "new remote user creation" do
84 test "tries to use the information in poco fields" do
85 # TODO make test local
86 uri = "https://social.heldscal.la/user/23211"
87
88 {:ok, user} = OStatus.find_or_make_user(uri)
89
90 user = Repo.get(Pleroma.User, user.id)
91 assert user.name == "Constance Variable"
92 assert user.nickname == "lambadalambda@social.heldscal.la"
93 assert user.local == false
94 assert user.info["uri"] == uri
95 assert user.ap_id == uri
96 assert user.avatar["type"] == "Image"
97
98 {:ok, user_again} = OStatus.find_or_make_user(uri)
99
100 assert user == user_again
101 end
102
103 test "find_make_or_update_user takes an author element and returns an updated user" do
104 # TODO make test local
105 uri = "https://social.heldscal.la/user/23211"
106
107 {:ok, user} = OStatus.find_or_make_user(uri)
108 change = Ecto.Changeset.change(user, %{avatar: nil})
109
110 {:ok, user} = Repo.update(change)
111 refute user.avatar
112
113 doc = XML.parse_document(File.read!("test/fixtures/23211.atom"))
114 [author] = :xmerl_xpath.string('//author[1]', doc)
115 {:ok, user} = OStatus.find_make_or_update_user(author)
116 assert user.avatar["type"] == "Image"
117
118 {:ok, user_again} = OStatus.find_make_or_update_user(author)
119 assert user_again == user
120 end
121 end
122
123 describe "gathering user info from a user id" do
124 test "it returns user info in a hash" do
125 user = "shp@social.heldscal.la"
126
127 # TODO: make test local
128 {:ok, data} = OStatus.gather_user_info(user)
129
130 expected = %{
131 "hub" => "https://social.heldscal.la/main/push/hub",
132 "magic_key" => "RSA.wQ3i9UA0qmAxZ0WTIp4a-waZn_17Ez1pEEmqmqoooRsG1_BvpmOvLN0G2tEcWWxl2KOtdQMCiPptmQObeZeuj48mdsDZ4ArQinexY2hCCTcbV8Xpswpkb8K05RcKipdg07pnI7tAgQ0VWSZDImncL6YUGlG5YN8b5TjGOwk2VG8=.AQAB",
133 "name" => "shp",
134 "nickname" => "shp",
135 "salmon" => "https://social.heldscal.la/main/salmon/user/29191",
136 "subject" => "acct:shp@social.heldscal.la",
137 "topic" => "https://social.heldscal.la/api/statuses/user_timeline/29191.atom",
138 "uri" => "https://social.heldscal.la/user/29191",
139 "host" => "social.heldscal.la",
140 "fqn" => user,
141 "avatar" => %{"type" => "Image", "url" => [%{"href" => "https://social.heldscal.la/avatar/29191-original-20170421154949.jpeg", "mediaType" => "image/jpeg", "type" => "Link"}]}
142 }
143 assert data == expected
144 end
145
146 test "it works with the uri" do
147 user = "https://social.heldscal.la/user/29191"
148
149 # TODO: make test local
150 {:ok, data} = OStatus.gather_user_info(user)
151
152 expected = %{
153 "hub" => "https://social.heldscal.la/main/push/hub",
154 "magic_key" => "RSA.wQ3i9UA0qmAxZ0WTIp4a-waZn_17Ez1pEEmqmqoooRsG1_BvpmOvLN0G2tEcWWxl2KOtdQMCiPptmQObeZeuj48mdsDZ4ArQinexY2hCCTcbV8Xpswpkb8K05RcKipdg07pnI7tAgQ0VWSZDImncL6YUGlG5YN8b5TjGOwk2VG8=.AQAB",
155 "name" => "shp",
156 "nickname" => "shp",
157 "salmon" => "https://social.heldscal.la/main/salmon/user/29191",
158 "subject" => "https://social.heldscal.la/user/29191",
159 "topic" => "https://social.heldscal.la/api/statuses/user_timeline/29191.atom",
160 "uri" => "https://social.heldscal.la/user/29191",
161 "host" => "social.heldscal.la",
162 "fqn" => user,
163 "avatar" => %{"type" => "Image", "url" => [%{"href" => "https://social.heldscal.la/avatar/29191-original-20170421154949.jpeg", "mediaType" => "image/jpeg", "type" => "Link"}]}
164 }
165 assert data == expected
166 end
167 end
168 end