| 64 |
45
|
|
unprocessable(conn, :body_text)
|
| 65 |
46
|
|
|
| 66 |
47
|
|
true ->
|
| 67 |
|
- |
case fetch_forum(%{"forum" => slug}) do
|
| 68 |
|
- |
{:ok, forum} ->
|
| 69 |
|
- |
case Forum.create_topic(forum, topic_attrs(conn, params)) do
|
| 70 |
|
- |
{:ok, topic} ->
|
| 71 |
|
- |
conn
|
| 72 |
|
- |
|> put_status(:created)
|
| 73 |
|
- |
|> render(:topic,
|
| 74 |
|
- |
topic: topic,
|
| 75 |
|
- |
posts: [first_post(topic)],
|
| 76 |
|
- |
pagination: %{
|
| 77 |
|
- |
page: 1,
|
| 78 |
|
- |
per_page: Forum.posts_per_page(),
|
| 79 |
|
- |
total: 1
|
| 80 |
|
- |
}
|
| 81 |
|
- |
)
|
| 82 |
|
- |
|
| 83 |
|
- |
{:error, %Ecto.Changeset{} = changeset} ->
|
| 84 |
|
- |
conn |> put_status(:unprocessable_entity) |> render(:error, changeset: changeset)
|
| 85 |
|
- |
|
| 86 |
|
- |
_other ->
|
| 87 |
|
- |
conn |> put_status(:conflict) |> json(%{error: "topic_closed"})
|
| 88 |
|
- |
end
|
| 89 |
|
- |
|
| 90 |
|
- |
_missing ->
|
|
48
|
+ |
with {:ok, forum} <- Forum.fetch_readable_forum_by_slug(slug, scope(conn)),
|
|
49
|
+ |
{:ok, topic} <- Forum.create_topic(forum, topic_attrs(conn, params)) do
|
|
50
|
+ |
conn
|
|
51
|
+ |
|> put_status(:created)
|
|
52
|
+ |
|> render(:topic,
|
|
53
|
+ |
topic: topic,
|
|
54
|
+ |
posts: [first_post(topic)],
|
|
55
|
+ |
pagination: %{page: 1, per_page: Forum.posts_per_page(), total: 1}
|
|
56
|
+ |
)
|
|
57
|
+ |
else
|
|
58
|
+ |
{:error, :not_found} ->
|
| 91 |
59
|
|
not_found(conn)
|
|
60
|
+ |
|
|
61
|
+ |
{:error, %Ecto.Changeset{} = changeset} ->
|
|
62
|
+ |
conn |> put_status(:unprocessable_entity) |> render(:error, changeset: changeset)
|
|
63
|
+ |
|
|
64
|
+ |
_closed ->
|
|
65
|
+ |
conflict(conn, "topic_closed")
|
| 92 |
66
|
|
end
|
| 93 |
67
|
|
end
|
| 94 |
68
|
|
end
|
| 95 |
69
|
|
|
| 96 |
70
|
|
def create_post(conn, %{"topic_id" => topic_id, "body_text" => body_text} = params) do
|
| 97 |
71
|
|
if valid_text?(body_text) do
|
| 98 |
|
- |
topic = Forum.get_topic!(topic_id)
|
| 99 |
|
- |
|
| 100 |
|
- |
attrs =
|
| 101 |
|
- |
actor_attrs(conn)
|
| 102 |
|
- |
|> Map.merge(%{
|
| 103 |
|
- |
body_text: body_text,
|
| 104 |
|
- |
idempotency_key: Map.get(params, "idempotency_key") || Ecto.UUID.generate()
|
| 105 |
|
- |
})
|
| 106 |
|
- |
|
| 107 |
|
- |
case Forum.create_post(topic, attrs) do
|
| 108 |
|
- |
{:ok, post} ->
|
| 109 |
|
- |
conn |> put_status(:created) |> render(:post, post: post)
|
| 110 |
|
- |
|
| 111 |
|
- |
_closed ->
|
| 112 |
|
- |
conn |> put_status(:conflict) |> json(%{error: "topic_closed"})
|
|
72
|
+ |
with {:ok, topic} <- Forum.fetch_readable_topic(topic_id, scope(conn)),
|
|
73
|
+ |
{:ok, post} <- Forum.create_post(topic, post_attrs(conn, params)) do
|
|
74
|
+ |
conn |> put_status(:created) |> render(:post, post: post)
|
|
75
|
+ |
else
|
|
76
|
+ |
{:error, :not_found} -> not_found(conn)
|
|
77
|
+ |
_closed -> conflict(conn, "topic_closed")
|
| 113 |
78
|
|
end
|
| 114 |
79
|
|
else
|
| 115 |
80
|
|
unprocessable(conn, :body_text)
|
| 116 |
81
|
|
end
|
| 117 |
|
- |
rescue
|
| 118 |
|
- |
Ecto.NoResultsError -> not_found(conn)
|
| 119 |
82
|
|
end
|
| 120 |
83
|
|
|
|
84
|
+ |
@doc """
|
|
85
|
+ |
Closes, reopens, or pins a topic. Operators only, matching the controls the
|
|
86
|
+ |
web thread offers them.
|
|
87
|
+ |
"""
|
|
88
|
+ |
def update_topic(conn, %{"id" => id} = params) do
|
|
89
|
+ |
with :ok <- ensure_operator(conn),
|
|
90
|
+ |
{:ok, topic} <- Forum.fetch_readable_topic(id, scope(conn)),
|
|
91
|
+ |
{:ok, topic} <- apply_topic_state(topic, params),
|
|
92
|
+ |
{:ok, topic} <- apply_topic_pin(topic, params) do
|
|
93
|
+ |
render_topic(conn, topic, nil)
|
|
94
|
+ |
else
|
|
95
|
+ |
{:error, :forbidden} -> forbidden(conn)
|
|
96
|
+ |
{:error, :not_found} -> not_found(conn)
|
|
97
|
+ |
{:error, :invalid_state} -> unprocessable(conn, :state, ~s(must be "open" or "closed"))
|
|
98
|
+ |
{:error, :invalid_pinned} -> unprocessable(conn, :pinned, "must be a boolean")
|
|
99
|
+ |
{:error, %Ecto.Changeset{} = changeset} -> render_changeset_error(conn, changeset)
|
|
100
|
+ |
end
|
|
101
|
+ |
end
|
|
102
|
+ |
|
|
103
|
+ |
@doc """
|
|
104
|
+ |
Hides or deletes a post. Operators only. Both states are soft: the post row
|
|
105
|
+ |
stays, and the read surfaces stop returning it.
|
|
106
|
+ |
"""
|
|
107
|
+ |
def update_post(conn, %{"id" => id, "state" => state}) do
|
|
108
|
+ |
with :ok <- ensure_operator(conn),
|
|
109
|
+ |
{:ok, post} <- Forum.fetch_post(id),
|
|
110
|
+ |
{:ok, post} <- moderate_post(post, state, conn.assigns.current_user) do
|
|
111
|
+ |
render(conn, :post, post: post)
|
|
112
|
+ |
else
|
|
113
|
+ |
{:error, :forbidden} -> forbidden(conn)
|
|
114
|
+ |
{:error, :not_found} -> not_found(conn)
|
|
115
|
+ |
{:error, :invalid_state} -> unprocessable(conn, :state, post_state_message())
|
|
116
|
+ |
{:error, %Ecto.Changeset{} = changeset} -> render_changeset_error(conn, changeset)
|
|
117
|
+ |
end
|
|
118
|
+ |
end
|
|
119
|
+ |
|
|
120
|
+ |
def update_post(conn, _params), do: unprocessable(conn, :state, post_state_message())
|
|
121
|
+ |
|
| 121 |
122
|
|
def create_claim(conn, %{"actor_ref" => actor_ref}) when is_binary(actor_ref) do
|
| 122 |
123
|
|
case Forum.start_actor_link(conn.assigns.current_user, String.trim(actor_ref), "api_token") do
|
| 123 |
124
|
|
{:ok, link} ->
|
| 124 |
125
|
|
conn |> put_status(:created) |> render(:claim, claim: link)
|
| 125 |
126
|
|
|
| 126 |
127
|
|
{:error, changeset} ->
|
| 127 |
|
- |
conn |> put_status(:unprocessable_entity) |> render(:error, changeset: changeset)
|
|
128
|
+ |
render_changeset_error(conn, changeset)
|
| 128 |
129
|
|
end
|
| 129 |
130
|
|
end
|
| 130 |
131
|
|
|
|
132
|
+ |
def create_claim(conn, _params), do: unprocessable(conn, :actor_ref)
|
|
133
|
+ |
|
| 131 |
134
|
|
def list_claims(conn, _params) do
|
| 132 |
135
|
|
render(conn, :claims, claims: Forum.list_actor_links(conn.assigns.current_user))
|
| 133 |
136
|
|
end
|
| 134 |
137
|
|
|
|
138
|
+ |
@doc "Every claim waiting on review. Operators only."
|
|
139
|
+ |
def pending_claims(conn, _params) do
|
|
140
|
+ |
case ensure_operator(conn) do
|
|
141
|
+ |
:ok -> render(conn, :claims, claims: Forum.list_pending_actor_links())
|
|
142
|
+ |
{:error, :forbidden} -> forbidden(conn)
|
|
143
|
+ |
end
|
|
144
|
+ |
end
|
|
145
|
+ |
|
|
146
|
+ |
@doc "Approves or rejects a pending claim. Operators only."
|
|
147
|
+ |
def update_claim(conn, %{"id" => id, "status" => status}) do
|
|
148
|
+ |
with :ok <- ensure_operator(conn),
|
|
149
|
+ |
{:ok, link} <- Forum.fetch_actor_link(id),
|
|
150
|
+ |
{:ok, link} <- review_claim(link, status) do
|
|
151
|
+ |
render(conn, :claim, claim: link)
|
|
152
|
+ |
else
|
|
153
|
+ |
{:error, :forbidden} -> forbidden(conn)
|
|
154
|
+ |
{:error, :not_found} -> not_found(conn)
|
|
155
|
+ |
{:error, :invalid_status} -> unprocessable(conn, :status, claim_status_message())
|
|
156
|
+ |
{:error, :not_pending} -> conflict(conn, "claim_not_pending")
|
|
157
|
+ |
{:error, %Ecto.Changeset{} = changeset} -> render_changeset_error(conn, changeset)
|
|
158
|
+ |
end
|
|
159
|
+ |
end
|
|
160
|
+ |
|
|
161
|
+ |
def update_claim(conn, _params), do: unprocessable(conn, :status, claim_status_message())
|
|
162
|
+ |
|
|
163
|
+ |
## Reads
|
|
164
|
+ |
|
|
165
|
+ |
defp board_topics(conn, slug, params) do
|
|
166
|
+ |
case Forum.fetch_readable_forum_by_slug(slug, scope(conn)) do
|
|
167
|
+ |
{:ok, forum} ->
|
|
168
|
+ |
page = Forum.parse_page(params["page"])
|
|
169
|
+ |
|
|
170
|
+ |
render(conn, :topics,
|
|
171
|
+ |
topics: Forum.list_topics(forum, page: page),
|
|
172
|
+ |
forum: forum,
|
|
173
|
+ |
query: nil,
|
|
174
|
+ |
pagination: pagination(page, Forum.topics_per_page(), Forum.count_topics(forum))
|
|
175
|
+ |
)
|
|
176
|
+ |
|
|
177
|
+ |
{:error, :not_found} ->
|
|
178
|
+ |
not_found(conn)
|
|
179
|
+ |
end
|
|
180
|
+ |
end
|
|
181
|
+ |
|
|
182
|
+ |
defp search(conn, query, params) do
|
|
183
|
+ |
scope = scope(conn)
|
|
184
|
+ |
|
|
185
|
+ |
case search_board(params["forum"], scope) do
|
|
186
|
+ |
{:ok, forum} ->
|
|
187
|
+ |
page = Forum.parse_page(params["page"])
|
|
188
|
+ |
opts = scope |> Keyword.put(:forum, forum) |> Keyword.put(:page, page)
|
|
189
|
+ |
|
|
190
|
+ |
render(conn, :topics,
|
|
191
|
+ |
topics: Forum.search_topics(query, opts),
|
|
192
|
+ |
forum: forum,
|
|
193
|
+ |
query: query,
|
|
194
|
+ |
pagination:
|
|
195
|
+ |
pagination(
|
|
196
|
+ |
page,
|
|
197
|
+ |
Forum.topics_per_page(),
|
|
198
|
+ |
Forum.count_search_topics(query, Keyword.delete(opts, :page))
|
|
199
|
+ |
)
|
|
200
|
+ |
)
|
|
201
|
+ |
|
|
202
|
+ |
{:error, :not_found} ->
|
|
203
|
+ |
not_found(conn)
|
|
204
|
+ |
end
|
|
205
|
+ |
end
|
|
206
|
+ |
|
|
207
|
+ |
# A search without `forum` crosses every readable board.
|
|
208
|
+ |
defp search_board(slug, scope) when is_binary(slug),
|
|
209
|
+ |
do: Forum.fetch_readable_forum_by_slug(slug, scope)
|
|
210
|
+ |
|
|
211
|
+ |
defp search_board(_slug, _scope), do: {:ok, nil}
|
|
212
|
+ |
|
|
213
|
+ |
defp render_topic(conn, topic, page_param) do
|
|
214
|
+ |
page = Forum.parse_page(page_param)
|
|
215
|
+ |
|
|
216
|
+ |
render(conn, :topic,
|
|
217
|
+ |
topic: topic,
|
|
218
|
+ |
posts: Forum.list_posts(topic, page: page),
|
|
219
|
+ |
pagination: pagination(page, Forum.posts_per_page(), Forum.count_posts(topic))
|
|
220
|
+ |
)
|
|
221
|
+ |
end
|
|
222
|
+ |
|
|
223
|
+ |
## Writes
|
|
224
|
+ |
|
|
225
|
+ |
defp apply_topic_state(topic, %{"state" => state}) when state in ["open", "closed"],
|
|
226
|
+ |
do: Forum.set_topic_state(topic, state)
|
|
227
|
+ |
|
|
228
|
+ |
defp apply_topic_state(_topic, %{"state" => _other}), do: {:error, :invalid_state}
|
|
229
|
+ |
|
|
230
|
+ |
defp apply_topic_state(topic, _params), do: {:ok, topic}
|
|
231
|
+ |
|
|
232
|
+ |
defp apply_topic_pin(topic, %{"pinned" => pinned}) when is_boolean(pinned),
|
|
233
|
+ |
do: Forum.pin_topic(topic, pinned)
|
|
234
|
+ |
|
|
235
|
+ |
defp apply_topic_pin(_topic, %{"pinned" => _other}), do: {:error, :invalid_pinned}
|
|
236
|
+ |
|
|
237
|
+ |
defp apply_topic_pin(topic, _params), do: {:ok, topic}
|
|
238
|
+ |
|
|
239
|
+ |
defp moderate_post(post, "hidden", moderator), do: Forum.hide_post(post, moderator)
|
|
240
|
+ |
|
|
241
|
+ |
defp moderate_post(post, "deleted", moderator), do: Forum.delete_post(post, moderator)
|
|
242
|
+ |
|
|
243
|
+ |
defp moderate_post(_post, _state, _moderator), do: {:error, :invalid_state}
|
|
244
|
+ |
|
|
245
|
+ |
defp review_claim(%{status: "pending"} = link, "linked"), do: Forum.approve_actor_link(link)
|
|
246
|
+ |
|
|
247
|
+ |
defp review_claim(%{status: "pending"} = link, "rejected"), do: Forum.reject_actor_link(link)
|
|
248
|
+ |
|
|
249
|
+ |
defp review_claim(%{status: "pending"}, _status), do: {:error, :invalid_status}
|
|
250
|
+ |
|
|
251
|
+ |
defp review_claim(_link, status) when status in ["linked", "rejected"],
|
|
252
|
+ |
do: {:error, :not_pending}
|
|
253
|
+ |
|
|
254
|
+ |
defp review_claim(_link, _status), do: {:error, :invalid_status}
|
|
255
|
+ |
|
| 135 |
256
|
|
## Helpers
|
| 136 |
257
|
|
|
| 137 |
258
|
|
defp first_post(topic) do
|
| 138 |
259
|
|
case Forum.list_posts(topic) do
|
| 139 |
|
- |
[post | _] -> post
|
|
260
|
+ |
[post | _rest] -> post
|
| 140 |
261
|
|
[] -> nil
|
| 141 |
262
|
|
end
|
| 142 |
263
|
|
end
|
| 143 |
264
|
|
|
| 144 |
|
- |
defp forum_topics_page(forum, params) do
|
| 145 |
|
- |
page = Forum.parse_page(params["page"])
|
| 146 |
|
- |
topics = Forum.list_topics(forum, page: page)
|
| 147 |
|
- |
total = Forum.count_topics(forum)
|
| 148 |
|
- |
{topics, total}
|
| 149 |
|
- |
end
|
|
265
|
+ |
defp scope(conn), do: [operator?: Accounts.admin?(conn.assigns[:current_user])]
|
| 150 |
266
|
|
|
| 151 |
|
- |
defp fetch_forum(%{"forum" => slug}) when is_binary(slug) do
|
| 152 |
|
- |
case Forum.get_forum_by_slug(slug) do
|
| 153 |
|
- |
nil -> {:error, :not_found}
|
| 154 |
|
- |
forum -> {:ok, forum}
|
| 155 |
|
- |
end
|
|
267
|
+ |
defp ensure_operator(conn) do
|
|
268
|
+ |
if Accounts.admin?(conn.assigns[:current_user]), do: :ok, else: {:error, :forbidden}
|
| 156 |
269
|
|
end
|
| 157 |
270
|
|
|
| 158 |
|
- |
defp fetch_forum(_params), do: {:error, :missing_forum}
|
|
271
|
+ |
defp pagination(page, per_page, total),
|
|
272
|
+ |
do: %{page: page, per_page: per_page, total: total}
|
| 159 |
273
|
|
|
| 160 |
274
|
|
defp topic_attrs(conn, params) do
|
| 161 |
275
|
|
actor_attrs(conn)
|