Pleroma/lib/pleroma/web/mastodon_api/mastodon_api_controller.ex

1225 lines
37 KiB
Elixir
Raw Normal View History

defmodule Pleroma.Web.MastodonAPI.MastodonAPIController do
use Pleroma.Web, :controller
alias Pleroma.{Repo, Object, Activity, User, Notification, Stats}
2017-09-07 08:58:10 +02:00
alias Pleroma.Web
2018-08-14 04:27:28 +02:00
alias Pleroma.Web.MastodonAPI.{StatusView, AccountView, MastodonView, ListView, FilterView}
2017-09-09 13:15:01 +02:00
alias Pleroma.Web.ActivityPub.ActivityPub
2018-05-26 18:16:20 +02:00
alias Pleroma.Web.ActivityPub.Utils
alias Pleroma.Web.CommonAPI
2017-11-12 14:23:05 +01:00
alias Pleroma.Web.OAuth.{Authorization, Token, App}
2018-08-28 10:01:17 +02:00
alias Pleroma.Web.MediaProxy
2017-11-12 14:23:05 +01:00
alias Comeonin.Pbkdf2
2017-09-13 15:55:10 +02:00
import Ecto.Query
2017-11-19 02:22:07 +01:00
require Logger
@httpoison Application.get_env(:pleroma, :httpoison)
action_fallback(:errors)
def create_app(conn, params) do
2018-03-30 15:01:53 +02:00
with cs <- App.register_changeset(%App{}, params) |> IO.inspect(),
{:ok, app} <- Repo.insert(cs) |> IO.inspect() do
res = %{
id: app.id |> to_string,
name: app.client_name,
client_id: app.client_id,
client_secret: app.client_secret,
redirect_uri: app.redirect_uris,
website: app.website
}
json(conn, res)
end
end
def update_credentials(%{assigns: %{user: user}} = conn, params) do
2018-02-25 21:02:44 +01:00
original_user = user
2018-03-30 15:01:53 +02:00
params =
if bio = params["note"] do
Map.put(params, "bio", bio)
else
params
end
2018-03-30 15:01:53 +02:00
params =
if name = params["display_name"] do
Map.put(params, "name", name)
else
2018-03-30 15:01:53 +02:00
params
end
2018-03-30 15:01:53 +02:00
user =
if avatar = params["avatar"] do
with %Plug.Upload{} <- avatar,
{:ok, object} <- ActivityPub.upload(avatar),
change = Ecto.Changeset.change(user, %{avatar: object.data}),
{:ok, user} = User.update_and_set_cache(change) do
user
else
_e -> user
end
else
user
2018-03-30 15:01:53 +02:00
end
user =
if banner = params["header"] do
with %Plug.Upload{} <- banner,
{:ok, object} <- ActivityPub.upload(banner),
new_info <- Map.put(user.info, "banner", object.data),
change <- User.info_changeset(user, %{info: new_info}),
{:ok, user} <- User.update_and_set_cache(change) do
user
else
_e -> user
end
else
2018-03-30 15:01:53 +02:00
user
end
user =
if locked = params["locked"] do
with locked <- locked == "true",
new_info <- Map.put(user.info, "locked", locked),
change <- User.info_changeset(user, %{info: new_info}),
{:ok, user} <- User.update_and_set_cache(change) do
user
else
_e -> user
end
else
user
end
with changeset <- User.update_changeset(user, params),
2018-02-25 21:02:44 +01:00
{:ok, user} <- User.update_and_set_cache(changeset) do
if original_user != user do
CommonAPI.update(user)
end
2018-03-30 15:01:53 +02:00
json(conn, AccountView.render("account.json", %{user: user, for: user}))
else
_e ->
conn
|> put_status(403)
|> json(%{error: "Invalid request"})
end
end
2017-11-19 02:22:07 +01:00
def verify_credentials(%{assigns: %{user: user}} = conn, _) do
account = AccountView.render("account.json", %{user: user, for: user})
2017-09-07 08:58:10 +02:00
json(conn, account)
end
def user(%{assigns: %{user: for_user}} = conn, %{"id" => id}) do
2017-09-13 17:36:02 +02:00
with %User{} = user <- Repo.get(User, id) do
account = AccountView.render("account.json", %{user: user, for: for_user})
2017-09-13 17:36:02 +02:00
json(conn, account)
else
2018-03-30 15:01:53 +02:00
_e ->
conn
|> put_status(404)
|> json(%{error: "Can't find user"})
2017-09-13 17:36:02 +02:00
end
end
2017-09-15 10:26:28 +02:00
@instance Application.get_env(:pleroma, :instance)
@mastodon_api_level "2.5.0"
2017-09-15 10:26:28 +02:00
2017-09-07 08:58:10 +02:00
def masto_instance(conn, _params) do
response = %{
2018-03-30 15:01:53 +02:00
uri: Web.base_url(),
2017-09-15 10:26:28 +02:00
title: Keyword.get(@instance, :name),
description: Keyword.get(@instance, :description),
version: "#{@mastodon_api_level} (compatible; #{Keyword.get(@instance, :version)})",
2017-09-15 10:26:28 +02:00
email: Keyword.get(@instance, :email),
urls: %{
2018-05-05 13:40:31 +02:00
streaming_api: String.replace(Pleroma.Web.Endpoint.static_url(), "http", "ws")
2017-09-15 10:26:28 +02:00
},
2018-03-30 15:01:53 +02:00
stats: Stats.get_stats(),
thumbnail: Web.base_url() <> "/instance/thumbnail.jpeg",
2017-11-20 08:54:47 +01:00
max_toot_chars: Keyword.get(@instance, :limit)
}
2017-09-07 08:58:10 +02:00
json(conn, response)
end
2017-09-09 13:15:01 +02:00
def peers(conn, _params) do
2018-03-30 15:01:53 +02:00
json(conn, Stats.get_peers())
end
defp mastodonized_emoji do
Pleroma.Formatter.get_custom_emoji()
|> Enum.map(fn {shortcode, relative_url} ->
2018-03-30 15:01:53 +02:00
url = to_string(URI.merge(Web.base_url(), relative_url))
%{
"shortcode" => shortcode,
"static_url" => url,
"visible_in_picker" => true,
"url" => url
}
end)
end
def custom_emojis(conn, _params) do
mastodon_emoji = mastodonized_emoji()
2018-03-30 15:01:53 +02:00
json(conn, mastodon_emoji)
end
defp add_link_headers(conn, method, activities, param \\ nil, params \\ %{}) do
last = List.last(activities)
first = List.first(activities)
2018-03-30 15:01:53 +02:00
if last do
min = last.id
max = first.id
2018-03-30 15:01:53 +02:00
{next_url, prev_url} =
if param do
{
mastodon_api_url(
Pleroma.Web.Endpoint,
method,
param,
Map.merge(params, %{max_id: min})
),
mastodon_api_url(
Pleroma.Web.Endpoint,
method,
param,
Map.merge(params, %{since_id: max})
)
2018-03-30 15:01:53 +02:00
}
else
{
mastodon_api_url(
Pleroma.Web.Endpoint,
method,
Map.merge(params, %{max_id: min})
),
mastodon_api_url(
Pleroma.Web.Endpoint,
method,
Map.merge(params, %{since_id: max})
)
2018-03-30 15:01:53 +02:00
}
end
conn
|> put_resp_header("link", "<#{next_url}>; rel=\"next\", <#{prev_url}>; rel=\"prev\"")
else
conn
end
end
2017-09-09 13:15:01 +02:00
def home_timeline(%{assigns: %{user: user}} = conn, params) do
2018-03-30 15:01:53 +02:00
params =
params
|> Map.put("type", ["Create", "Announce"])
|> Map.put("blocking_user", user)
|> Map.put("user", user)
2017-09-17 14:20:54 +02:00
2018-03-30 15:01:53 +02:00
activities =
ActivityPub.fetch_activities([user.ap_id | user.following], params)
|> Enum.reverse()
conn
2017-09-12 09:06:32 +02:00
|> add_link_headers(:home_timeline, activities)
2017-09-12 08:53:21 +02:00
|> render(StatusView, "index.json", %{activities: activities, for: user, as: :activity})
2017-09-09 13:15:01 +02:00
end
def public_timeline(%{assigns: %{user: user}} = conn, params) do
local_only = params["local"] in [true, "True", "true", "1"]
2018-03-30 15:01:53 +02:00
params =
params
|> Map.put("type", ["Create", "Announce"])
|> Map.put("local_only", local_only)
2018-03-30 15:01:53 +02:00
|> Map.put("blocking_user", user)
2017-09-09 13:15:01 +02:00
2018-03-30 15:01:53 +02:00
activities =
ActivityPub.fetch_public_activities(params)
|> Enum.reverse()
2017-09-09 13:15:01 +02:00
2017-09-12 09:06:32 +02:00
conn
|> add_link_headers(:public_timeline, activities, false, %{"local" => local_only})
2017-09-12 09:06:32 +02:00
|> render(StatusView, "index.json", %{activities: activities, for: user, as: :activity})
2017-09-09 13:15:01 +02:00
end
def user_statuses(%{assigns: %{user: reading_user}} = conn, params) do
with %User{} = user <- Repo.get(User, params["id"]) do
# Since Pleroma has no "pinned" posts feature, we'll just set an empty list here
2018-05-06 08:58:59 +02:00
activities =
if params["pinned"] == "true" do
[]
else
ActivityPub.fetch_user_activities(user, reading_user, params)
2018-05-06 08:58:59 +02:00
end
2017-09-10 17:46:43 +02:00
conn
|> add_link_headers(:user_statuses, activities, params["id"])
|> render(StatusView, "index.json", %{
activities: activities,
for: reading_user,
as: :activity
})
2017-09-10 17:46:43 +02:00
end
end
def dm_timeline(%{assigns: %{user: user}} = conn, _params) do
query =
ActivityPub.fetch_activities_query([user.ap_id], %{"type" => "Create", visibility: "direct"})
2018-05-11 04:17:33 +02:00
activities = Repo.all(query)
conn
|> add_link_headers(:dm_timeline, activities)
2018-05-11 04:17:33 +02:00
|> render(StatusView, "index.json", %{activities: activities, for: user, as: :activity})
end
2017-09-09 13:15:01 +02:00
def get_status(%{assigns: %{user: user}} = conn, %{"id" => id}) do
2018-02-18 15:50:34 +01:00
with %Activity{} = activity <- Repo.get(Activity, id),
true <- ActivityPub.visible_for_user?(activity, user) do
try_render(conn, StatusView, "status.json", %{activity: activity, for: user})
2017-09-09 13:15:01 +02:00
end
end
2017-09-10 15:00:13 +02:00
def get_context(%{assigns: %{user: user}} = conn, %{"id" => id}) do
with %Activity{} = activity <- Repo.get(Activity, id),
2018-03-30 15:01:53 +02:00
activities <-
ActivityPub.fetch_activities_for_context(activity.data["context"], %{
"blocking_user" => user,
"user" => user
}),
activities <-
activities |> Enum.filter(fn %{id: aid} -> to_string(aid) != to_string(id) end),
activities <-
activities |> Enum.filter(fn %{data: %{"type" => type}} -> type == "Create" end),
grouped_activities <- Enum.group_by(activities, fn %{id: id} -> id < activity.id end) do
2017-09-10 15:00:13 +02:00
result = %{
2018-03-30 15:01:53 +02:00
ancestors:
StatusView.render(
"index.json",
for: user,
activities: grouped_activities[true] || [],
as: :activity
)
|> Enum.reverse(),
descendants:
StatusView.render(
"index.json",
for: user,
activities: grouped_activities[false] || [],
as: :activity
)
|> Enum.reverse()
2017-09-10 15:00:13 +02:00
}
json(conn, result)
end
end
def post_status(conn, %{"status" => "", "media_ids" => media_ids} = params)
when length(media_ids) > 0 do
params =
params
|> Map.put("status", ".")
post_status(conn, params)
end
2017-11-19 02:22:07 +01:00
def post_status(%{assigns: %{user: user}} = conn, %{"status" => _} = params) do
2018-03-30 15:01:53 +02:00
params =
params
|> Map.put("in_reply_to_status_id", params["in_reply_to_id"])
|> Map.put("no_attachment_links", true)
2017-09-09 13:15:01 +02:00
2018-05-04 20:30:29 +02:00
idempotency_key =
case get_req_header(conn, "idempotency-key") do
[key] -> key
_ -> Ecto.UUID.generate()
end
{:ok, activity} =
Cachex.fetch!(:idempotency_cache, idempotency_key, fn _ -> CommonAPI.post(user, params) end)
2018-05-04 20:30:29 +02:00
try_render(conn, StatusView, "status.json", %{activity: activity, for: user, as: :activity})
2017-09-09 13:15:01 +02:00
end
2017-09-09 13:56:51 +02:00
def delete_status(%{assigns: %{user: user}} = conn, %{"id" => id}) do
with {:ok, %Activity{}} <- CommonAPI.delete(id, user) do
json(conn, %{})
else
_e ->
conn
|> put_status(403)
|> json(%{error: "Can't delete this post"})
end
end
2017-09-09 17:48:57 +02:00
def reblog_status(%{assigns: %{user: user}} = conn, %{"id" => ap_id_or_id}) do
with {:ok, announce, _activity} <- CommonAPI.repeat(ap_id_or_id, user) do
try_render(conn, StatusView, "status.json", %{activity: announce, for: user, as: :activity})
2017-09-09 17:48:57 +02:00
end
end
2017-09-09 18:09:37 +02:00
2018-04-14 09:39:16 +02:00
def unreblog_status(%{assigns: %{user: user}} = conn, %{"id" => ap_id_or_id}) do
with {:ok, _unannounce, %{data: %{"id" => id}}} <- CommonAPI.unrepeat(ap_id_or_id, user),
%Activity{} = activity <- Activity.get_create_activity_by_object_ap_id(id) do
try_render(conn, StatusView, "status.json", %{activity: activity, for: user, as: :activity})
2018-04-14 09:39:16 +02:00
end
end
2017-09-09 18:09:37 +02:00
def fav_status(%{assigns: %{user: user}} = conn, %{"id" => ap_id_or_id}) do
with {:ok, _fav, %{data: %{"id" => id}}} <- CommonAPI.favorite(ap_id_or_id, user),
2017-09-09 18:30:02 +02:00
%Activity{} = activity <- Activity.get_create_activity_by_object_ap_id(id) do
try_render(conn, StatusView, "status.json", %{activity: activity, for: user, as: :activity})
2017-09-09 18:30:02 +02:00
end
end
def unfav_status(%{assigns: %{user: user}} = conn, %{"id" => ap_id_or_id}) do
with {:ok, _, _, %{data: %{"id" => id}}} <- CommonAPI.unfavorite(ap_id_or_id, user),
2017-09-09 18:09:37 +02:00
%Activity{} = activity <- Activity.get_create_activity_by_object_ap_id(id) do
try_render(conn, StatusView, "status.json", %{activity: activity, for: user, as: :activity})
2017-09-09 18:09:37 +02:00
end
end
def notifications(%{assigns: %{user: user}} = conn, params) do
notifications = Notification.for_user(user, params)
2018-03-30 15:01:53 +02:00
result =
Enum.map(notifications, fn x ->
render_notification(user, x)
end)
|> Enum.filter(& &1)
2017-09-12 09:06:32 +02:00
conn
|> add_link_headers(:notifications, notifications)
|> json(result)
end
def get_notification(%{assigns: %{user: user}} = conn, %{"id" => id} = _params) do
with {:ok, notification} <- Notification.get(user, id) do
json(conn, render_notification(user, notification))
else
{:error, reason} ->
conn
|> put_resp_content_type("application/json")
2018-03-27 16:45:38 +02:00
|> send_resp(403, Jason.encode!(%{"error" => reason}))
end
end
def clear_notifications(%{assigns: %{user: user}} = conn, _params) do
Notification.clear(user)
json(conn, %{})
end
def dismiss_notification(%{assigns: %{user: user}} = conn, %{"id" => id} = _params) do
with {:ok, _notif} <- Notification.dismiss(user, id) do
json(conn, %{})
else
{:error, reason} ->
conn
|> put_resp_content_type("application/json")
2018-03-27 16:45:38 +02:00
|> send_resp(403, Jason.encode!(%{"error" => reason}))
end
end
2017-09-13 15:55:10 +02:00
def relationships(%{assigns: %{user: user}} = conn, %{"id" => id}) do
id = List.wrap(id)
2018-03-30 15:01:53 +02:00
q = from(u in User, where: u.id in ^id)
2017-09-13 15:55:10 +02:00
targets = Repo.all(q)
2018-03-30 15:01:53 +02:00
render(conn, AccountView, "relationships.json", %{user: user, targets: targets})
2017-09-13 15:55:10 +02:00
end
def update_media(%{assigns: %{user: _}} = conn, data) do
with %Object{} = object <- Repo.get(Object, data["id"]),
true <- is_binary(data["description"]),
description <- data["description"] do
new_data = %{object.data | "name" => description}
change = Object.change(object, %{data: new_data})
{:ok, _} = Repo.update(change)
2018-03-30 15:01:53 +02:00
data =
new_data
2018-03-30 15:01:53 +02:00
|> Map.put("id", object.id)
2017-09-14 08:08:32 +02:00
2018-03-30 15:01:53 +02:00
render(conn, StatusView, "attachment.json", %{attachment: data})
2017-09-14 08:08:32 +02:00
end
end
def upload(%{assigns: %{user: _}} = conn, %{"file" => file} = data) do
with {:ok, object} <- ActivityPub.upload(file) do
objdata =
if Map.has_key?(data, "description") do
Map.put(object.data, "name", data["description"])
else
object.data
end
change = Object.change(object, %{data: objdata})
{:ok, object} = Repo.update(change)
objdata =
objdata
|> Map.put("id", object.id)
render(conn, StatusView, "attachment.json", %{attachment: objdata})
end
end
def favourited_by(conn, %{"id" => id}) do
2017-11-19 02:22:07 +01:00
with %Activity{data: %{"object" => %{"likes" => likes}}} <- Repo.get(Activity, id) do
2018-03-30 15:01:53 +02:00
q = from(u in User, where: u.ap_id in ^likes)
users = Repo.all(q)
2018-03-30 15:01:53 +02:00
render(conn, AccountView, "accounts.json", %{users: users, as: :user})
else
_ -> json(conn, [])
end
end
def reblogged_by(conn, %{"id" => id}) do
with %Activity{data: %{"object" => %{"announcements" => announces}}} <- Repo.get(Activity, id) do
2018-03-30 15:01:53 +02:00
q = from(u in User, where: u.ap_id in ^announces)
users = Repo.all(q)
2018-03-30 15:01:53 +02:00
render(conn, AccountView, "accounts.json", %{users: users, as: :user})
else
_ -> json(conn, [])
end
end
2017-09-14 13:22:09 +02:00
def hashtag_timeline(%{assigns: %{user: user}} = conn, params) do
local_only = params["local"] in [true, "True", "true", "1"]
2018-03-30 15:01:53 +02:00
params =
params
|> Map.put("type", "Create")
|> Map.put("local_only", local_only)
2018-03-30 15:01:53 +02:00
|> Map.put("blocking_user", user)
2017-09-14 13:22:09 +02:00
2018-03-30 15:01:53 +02:00
activities =
ActivityPub.fetch_public_activities(params)
|> Enum.reverse()
2017-09-14 13:22:09 +02:00
conn
|> add_link_headers(:hashtag_timeline, activities, params["tag"], %{"local" => local_only})
2017-09-14 13:22:09 +02:00
|> render(StatusView, "index.json", %{activities: activities, for: user, as: :activity})
end
2017-09-14 18:30:05 +02:00
# TODO: Pagination
def followers(conn, %{"id" => id}) do
with %User{} = user <- Repo.get(User, id),
{:ok, followers} <- User.get_followers(user) do
2018-03-30 15:01:53 +02:00
render(conn, AccountView, "accounts.json", %{users: followers, as: :user})
2017-09-14 18:30:05 +02:00
end
end
def following(conn, %{"id" => id}) do
with %User{} = user <- Repo.get(User, id),
{:ok, followers} <- User.get_friends(user) do
2018-03-30 15:01:53 +02:00
render(conn, AccountView, "accounts.json", %{users: followers, as: :user})
2017-09-14 18:30:05 +02:00
end
end
2018-05-26 18:03:32 +02:00
def follow_requests(%{assigns: %{user: followed}} = conn, _params) do
with {:ok, follow_requests} <- User.get_follow_requests(followed) do
render(conn, AccountView, "accounts.json", %{users: follow_requests, as: :user})
end
end
2018-05-26 18:16:20 +02:00
def authorize_follow_request(%{assigns: %{user: followed}} = conn, %{"id" => id}) do
with %User{} = follower <- Repo.get(User, id),
{:ok, follower} <- User.maybe_follow(follower, followed),
2018-05-26 18:16:20 +02:00
%Activity{} = follow_activity <- Utils.fetch_latest_follow(follower, followed),
2018-05-26 20:03:23 +02:00
{:ok, follow_activity} <- Utils.update_follow_state(follow_activity, "accept"),
2018-05-26 18:16:20 +02:00
{:ok, _activity} <-
ActivityPub.accept(%{
2018-05-26 20:03:23 +02:00
to: [follower.ap_id],
2018-05-26 18:16:20 +02:00
actor: followed.ap_id,
object: follow_activity.data["id"],
type: "Accept"
}) do
render(conn, AccountView, "relationship.json", %{user: followed, target: follower})
else
{:error, message} ->
conn
|> put_resp_content_type("application/json")
|> send_resp(403, Jason.encode!(%{"error" => message}))
end
end
2018-05-26 20:03:23 +02:00
def reject_follow_request(%{assigns: %{user: followed}} = conn, %{"id" => id}) do
with %User{} = follower <- Repo.get(User, id),
%Activity{} = follow_activity <- Utils.fetch_latest_follow(follower, followed),
{:ok, follow_activity} <- Utils.update_follow_state(follow_activity, "reject"),
{:ok, _activity} <-
ActivityPub.reject(%{
to: [follower.ap_id],
actor: followed.ap_id,
object: follow_activity.data["id"],
type: "Reject"
}) do
render(conn, AccountView, "relationship.json", %{user: followed, target: follower})
else
{:error, message} ->
conn
|> put_resp_content_type("application/json")
|> send_resp(403, Jason.encode!(%{"error" => message}))
end
end
2018-05-26 18:16:20 +02:00
@activitypub Application.get_env(:pleroma, :activitypub)
@follow_handshake_timeout Keyword.get(@activitypub, :follow_handshake_timeout)
2017-10-28 23:07:38 +02:00
def follow(%{assigns: %{user: follower}} = conn, %{"id" => id}) do
with %User{} = followed <- Repo.get(User, id),
{:ok, follower} <- User.maybe_direct_follow(follower, followed),
{:ok, _activity} <- ActivityPub.follow(follower, followed),
{:ok, follower, followed} <-
User.wait_and_refresh(@follow_handshake_timeout, follower, followed) do
2018-03-30 15:01:53 +02:00
render(conn, AccountView, "relationship.json", %{user: follower, target: followed})
2017-10-25 20:02:42 +02:00
else
2017-11-19 02:22:07 +01:00
{:error, message} ->
2017-10-25 20:25:37 +02:00
conn
|> put_resp_content_type("application/json")
2018-03-27 16:45:38 +02:00
|> send_resp(403, Jason.encode!(%{"error" => message}))
2017-09-14 18:30:05 +02:00
end
end
def follow(%{assigns: %{user: follower}} = conn, %{"uri" => uri}) do
2017-10-28 23:07:38 +02:00
with %User{} = followed <- Repo.get_by(User, nickname: uri),
{:ok, follower} <- User.maybe_direct_follow(follower, followed),
2017-11-19 02:22:07 +01:00
{:ok, _activity} <- ActivityPub.follow(follower, followed) do
render(conn, AccountView, "account.json", %{user: followed, for: follower})
2017-10-28 23:07:38 +02:00
else
2017-11-19 02:22:07 +01:00
{:error, message} ->
2017-10-28 23:07:38 +02:00
conn
|> put_resp_content_type("application/json")
2018-03-27 16:45:38 +02:00
|> send_resp(403, Jason.encode!(%{"error" => message}))
2017-10-28 23:07:38 +02:00
end
end
2017-09-14 18:30:05 +02:00
def unfollow(%{assigns: %{user: follower}} = conn, %{"id" => id}) do
with %User{} = followed <- Repo.get(User, id),
{:ok, _activity} <- ActivityPub.unfollow(follower, followed),
{:ok, follower, _} <- User.unfollow(follower, followed) do
2018-03-30 15:01:53 +02:00
render(conn, AccountView, "relationship.json", %{user: follower, target: followed})
2017-09-14 18:30:05 +02:00
end
end
2017-11-03 08:38:05 +01:00
def block(%{assigns: %{user: blocker}} = conn, %{"id" => id}) do
with %User{} = blocked <- Repo.get(User, id),
{:ok, blocker} <- User.block(blocker, blocked),
{:ok, _activity} <- ActivityPub.block(blocker, blocked) do
2018-03-30 15:01:53 +02:00
render(conn, AccountView, "relationship.json", %{user: blocker, target: blocked})
2017-11-03 08:38:05 +01:00
else
2017-11-19 02:22:07 +01:00
{:error, message} ->
2017-11-03 08:38:05 +01:00
conn
|> put_resp_content_type("application/json")
2018-03-27 16:45:38 +02:00
|> send_resp(403, Jason.encode!(%{"error" => message}))
2017-11-03 08:38:05 +01:00
end
end
def unblock(%{assigns: %{user: blocker}} = conn, %{"id" => id}) do
with %User{} = blocked <- Repo.get(User, id),
{:ok, blocker} <- User.unblock(blocker, blocked),
{:ok, _activity} <- ActivityPub.unblock(blocker, blocked) do
2018-03-30 15:01:53 +02:00
render(conn, AccountView, "relationship.json", %{user: blocker, target: blocked})
2017-11-03 08:38:05 +01:00
else
2017-11-19 02:22:07 +01:00
{:error, message} ->
2017-11-03 08:38:05 +01:00
conn
|> put_resp_content_type("application/json")
2018-03-27 16:45:38 +02:00
|> send_resp(403, Jason.encode!(%{"error" => message}))
2017-11-03 08:38:05 +01:00
end
end
2017-11-03 08:51:17 +01:00
# TODO: Use proper query
def blocks(%{assigns: %{user: user}} = conn, _) do
with blocked_users <- user.info["blocks"] || [],
2018-03-30 15:01:53 +02:00
accounts <- Enum.map(blocked_users, fn ap_id -> User.get_cached_by_ap_id(ap_id) end) do
2017-11-03 08:51:17 +01:00
res = AccountView.render("accounts.json", users: accounts, for: user, as: :user)
json(conn, res)
end
end
2018-06-03 21:21:23 +02:00
def domain_blocks(%{assigns: %{user: %{info: info}}} = conn, _) do
json(conn, info["domain_blocks"] || [])
end
def block_domain(%{assigns: %{user: blocker}} = conn, %{"domain" => domain}) do
User.block_domain(blocker, domain)
json(conn, %{})
end
def unblock_domain(%{assigns: %{user: blocker}} = conn, %{"domain" => domain}) do
User.unblock_domain(blocker, domain)
json(conn, %{})
end
def status_search(query) do
fetched =
if Regex.match?(~r/https?:/, query) do
with {:ok, object} <- ActivityPub.fetch_object_from_id(query) do
[Activity.get_create_activity_by_object_ap_id(object.data["id"])]
else
_e -> []
end
end || []
q =
from(
a in Activity,
where: fragment("?->>'type' = 'Create'", a.data),
where: "https://www.w3.org/ns/activitystreams#Public" in a.recipients,
where:
fragment(
"to_tsvector('english', ?->'object'->>'content') @@ plainto_tsquery('english', ?)",
a.data,
^query
),
limit: 20,
order_by: [desc: :id]
)
Repo.all(q) ++ fetched
end
def search2(%{assigns: %{user: user}} = conn, %{"q" => query} = params) do
accounts = User.search(query, params["resolve"] == "true")
statuses = status_search(query)
tags_path = Web.base_url() <> "/tag/"
tags =
String.split(query)
|> Enum.uniq()
|> Enum.filter(fn tag -> String.starts_with?(tag, "#") end)
|> Enum.map(fn tag -> String.slice(tag, 1..-1) end)
|> Enum.map(fn tag -> %{name: tag, url: tags_path <> tag} end)
res = %{
"accounts" => AccountView.render("accounts.json", users: accounts, for: user, as: :user),
"statuses" =>
StatusView.render("index.json", activities: statuses, for: user, as: :activity),
"hashtags" => tags
}
json(conn, res)
end
def search(%{assigns: %{user: user}} = conn, %{"q" => query} = params) do
2017-10-30 19:23:16 +01:00
accounts = User.search(query, params["resolve"] == "true")
2017-09-16 10:42:24 +02:00
statuses = status_search(query)
2018-04-02 16:27:36 +02:00
tags =
String.split(query)
|> Enum.uniq()
|> Enum.filter(fn tag -> String.starts_with?(tag, "#") end)
|> Enum.map(fn tag -> String.slice(tag, 1..-1) end)
2017-09-16 10:42:24 +02:00
res = %{
"accounts" => AccountView.render("accounts.json", users: accounts, for: user, as: :user),
2018-03-30 15:01:53 +02:00
"statuses" =>
StatusView.render("index.json", activities: statuses, for: user, as: :activity),
"hashtags" => tags
2017-09-16 10:42:24 +02:00
}
json(conn, res)
end
2017-10-30 19:23:16 +01:00
def account_search(%{assigns: %{user: user}} = conn, %{"q" => query} = params) do
accounts = User.search(query, params["resolve"] == "true")
res = AccountView.render("accounts.json", users: accounts, for: user, as: :user)
json(conn, res)
end
2017-11-19 02:22:07 +01:00
def favourites(%{assigns: %{user: user}} = conn, _) do
2018-03-30 15:01:53 +02:00
params =
%{}
|> Map.put("type", "Create")
|> Map.put("favorited_by", user.ap_id)
|> Map.put("blocking_user", user)
2018-03-30 15:01:53 +02:00
activities =
ActivityPub.fetch_public_activities(params)
|> Enum.reverse()
conn
|> render(StatusView, "index.json", %{activities: activities, for: user, as: :activity})
end
2018-04-29 15:02:46 +02:00
def get_lists(%{assigns: %{user: user}} = conn, opts) do
lists = Pleroma.List.for_user(user, opts)
res = ListView.render("lists.json", lists: lists)
json(conn, res)
end
def get_list(%{assigns: %{user: user}} = conn, %{"id" => id}) do
2018-04-29 15:02:46 +02:00
with %Pleroma.List{} = list <- Pleroma.List.get(id, user) do
2018-04-29 15:02:46 +02:00
res = ListView.render("list.json", list: list)
json(conn, res)
else
_e -> json(conn, "error")
end
end
def account_lists(%{assigns: %{user: user}} = conn, %{"id" => account_id}) do
lists = Pleroma.List.get_lists_account_belongs(user, account_id)
res = ListView.render("lists.json", lists: lists)
json(conn, res)
end
2018-04-29 15:02:46 +02:00
def delete_list(%{assigns: %{user: user}} = conn, %{"id" => id}) do
2018-04-29 15:02:46 +02:00
with %Pleroma.List{} = list <- Pleroma.List.get(id, user),
2018-04-29 15:02:46 +02:00
{:ok, _list} <- Pleroma.List.delete(list) do
json(conn, %{})
else
_e ->
json(conn, "error")
end
end
def create_list(%{assigns: %{user: user}} = conn, %{"title" => title}) do
with {:ok, %Pleroma.List{} = list} <- Pleroma.List.create(title, user) do
res = ListView.render("list.json", list: list)
json(conn, res)
end
end
def add_to_list(%{assigns: %{user: user}} = conn, %{"id" => id, "account_ids" => accounts}) do
accounts
|> Enum.each(fn account_id ->
2018-04-29 15:02:46 +02:00
with %Pleroma.List{} = list <- Pleroma.List.get(id, user),
2018-04-29 15:02:46 +02:00
%User{} = followed <- Repo.get(User, account_id) do
2018-04-29 15:02:46 +02:00
Pleroma.List.follow(list, followed)
2018-04-29 15:02:46 +02:00
end
end)
json(conn, %{})
end
def remove_from_list(%{assigns: %{user: user}} = conn, %{"id" => id, "account_ids" => accounts}) do
accounts
|> Enum.each(fn account_id ->
2018-04-29 15:02:46 +02:00
with %Pleroma.List{} = list <- Pleroma.List.get(id, user),
2018-04-29 15:02:46 +02:00
%User{} = followed <- Repo.get(Pleroma.User, account_id) do
Pleroma.List.unfollow(list, followed)
end
end)
json(conn, %{})
end
def list_accounts(%{assigns: %{user: user}} = conn, %{"id" => id}) do
2018-04-29 15:02:46 +02:00
with %Pleroma.List{} = list <- Pleroma.List.get(id, user),
2018-04-29 15:02:46 +02:00
{:ok, users} = Pleroma.List.get_following(list) do
render(conn, AccountView, "accounts.json", %{users: users, as: :user})
end
end
def rename_list(%{assigns: %{user: user}} = conn, %{"id" => id, "title" => title}) do
2018-04-29 15:02:46 +02:00
with %Pleroma.List{} = list <- Pleroma.List.get(id, user),
2018-04-29 15:02:46 +02:00
{:ok, list} <- Pleroma.List.rename(list, title) do
res = ListView.render("list.json", list: list)
json(conn, res)
else
_e ->
json(conn, "error")
end
end
def list_timeline(%{assigns: %{user: user}} = conn, %{"list_id" => id} = params) do
2018-04-29 15:02:46 +02:00
with %Pleroma.List{title: title, following: following} <- Pleroma.List.get(id, user) do
2018-04-29 15:02:46 +02:00
params =
params
|> Map.put("type", "Create")
|> Map.put("blocking_user", user)
# we must filter the following list for the user to avoid leaking statuses the user
# does not actually have permission to see (for more info, peruse security issue #270).
following_to =
following
|> Enum.filter(fn x -> x in user.following end)
2018-04-29 15:02:46 +02:00
activities =
ActivityPub.fetch_activities_bounded(following_to, following, params)
2018-04-29 15:02:46 +02:00
|> Enum.reverse()
conn
|> render(StatusView, "index.json", %{activities: activities, for: user, as: :activity})
else
_e ->
conn
|> put_status(403)
|> json(%{error: "Error."})
end
end
2017-11-12 14:23:05 +01:00
def index(%{assigns: %{user: user}} = conn, _params) do
2018-03-30 15:01:53 +02:00
token =
conn
|> get_session(:oauth_token)
2017-11-12 14:23:05 +01:00
if user && token do
mastodon_emoji = mastodonized_emoji()
2018-09-22 04:48:42 +02:00
accounts =
Map.put(%{}, user.id, AccountView.render("account.json", %{user: user, for: user}))
2018-03-30 15:01:53 +02:00
initial_state =
%{
meta: %{
streaming_api_base_url:
String.replace(Pleroma.Web.Endpoint.static_url(), "http", "ws"),
access_token: token,
locale: "en",
domain: Pleroma.Web.Endpoint.host(),
admin: "1",
me: "#{user.id}",
unfollow_modal: false,
boost_modal: false,
delete_modal: true,
auto_play_gif: false,
2018-06-04 17:44:08 +02:00
display_sensitive_media: false,
reduce_motion: false,
max_toot_chars: Keyword.get(@instance, :limit)
2017-11-12 14:23:05 +01:00
},
rights: %{
delete_others_notice: !!user.info["is_moderator"]
},
2018-03-30 15:01:53 +02:00
compose: %{
me: "#{user.id}",
default_privacy: user.info["default_scope"] || "public",
2018-03-30 15:01:53 +02:00
default_sensitive: false
},
media_attachments: %{
accept_content_types: [
".jpg",
".jpeg",
".png",
".gif",
".webm",
".mp4",
".m4v",
"image\/jpeg",
"image\/png",
"image\/gif",
"video\/webm",
"video\/mp4"
]
},
2018-04-10 18:38:52 +02:00
settings:
Map.get(user.info, "settings") ||
%{
onboarded: true,
home: %{
shows: %{
reblog: true,
reply: true
}
},
notifications: %{
alerts: %{
follow: true,
favourite: true,
reblog: true,
mention: true
},
shows: %{
follow: true,
favourite: true,
reblog: true,
mention: true
},
sounds: %{
follow: true,
favourite: true,
reblog: true,
mention: true
}
}
2018-03-30 15:01:53 +02:00
},
push_subscription: nil,
accounts: accounts,
custom_emojis: mastodon_emoji,
char_limit: Keyword.get(@instance, :limit)
}
|> Jason.encode!()
2017-11-12 14:23:05 +01:00
conn
|> put_layout(false)
|> render(MastodonView, "index.html", %{initial_state: initial_state})
else
conn
|> redirect(to: "/web/login")
end
end
def put_settings(%{assigns: %{user: user}} = conn, %{"data" => settings} = _params) do
with new_info <- Map.put(user.info, "settings", settings),
change <- User.info_changeset(user, %{info: new_info}),
{:ok, _user} <- User.update_and_set_cache(change) do
conn
|> json(%{})
2018-04-10 18:38:52 +02:00
else
e ->
conn
|> json(%{error: inspect(e)})
end
end
2017-11-19 02:22:07 +01:00
def login(conn, _) do
2017-11-12 14:23:05 +01:00
conn
|> render(MastodonView, "login.html", %{error: false})
2017-11-12 14:23:05 +01:00
end
defp get_or_make_app() do
with %App{} = app <- Repo.get_by(App, client_name: "Mastodon-Local") do
{:ok, app}
else
_e ->
2018-03-30 15:01:53 +02:00
cs =
App.register_changeset(%App{}, %{
client_name: "Mastodon-Local",
redirect_uris: ".",
scopes: "read,write,follow"
})
2017-11-12 14:23:05 +01:00
Repo.insert(cs)
end
end
2018-03-30 15:01:53 +02:00
def login_post(conn, %{"authorization" => %{"name" => name, "password" => password}}) do
with %User{} = user <- User.get_by_nickname_or_email(name),
2017-11-12 14:23:05 +01:00
true <- Pbkdf2.checkpw(password, user.password_hash),
{:ok, app} <- get_or_make_app(),
{:ok, auth} <- Authorization.create_authorization(app, user),
{:ok, token} <- Token.exchange_token(app, auth) do
conn
|> put_session(:oauth_token, token.token)
2017-11-16 19:47:44 +01:00
|> redirect(to: "/web/getting-started")
else
_e ->
conn
|> render(MastodonView, "login.html", %{error: "Wrong username or password"})
2017-11-12 14:23:05 +01:00
end
end
2017-11-19 13:23:16 +01:00
def logout(conn, _) do
conn
|> clear_session
|> redirect(to: "/")
end
2017-09-14 18:30:05 +02:00
def relationship_noop(%{assigns: %{user: user}} = conn, %{"id" => id}) do
Logger.debug("Unimplemented, returning unmodified relationship")
2018-03-30 15:01:53 +02:00
2017-09-14 18:30:05 +02:00
with %User{} = target <- Repo.get(User, id) do
2018-03-30 15:01:53 +02:00
render(conn, AccountView, "relationship.json", %{user: user, target: target})
2017-09-14 18:30:05 +02:00
end
end
def empty_array(conn, _) do
Logger.debug("Unimplemented, returning an empty array")
json(conn, [])
end
def empty_object(conn, _) do
Logger.debug("Unimplemented, returning an empty object")
json(conn, %{})
end
def render_notification(user, %{id: id, activity: activity, inserted_at: created_at} = _params) do
actor = User.get_cached_by_ap_id(activity.data["actor"])
2018-03-30 15:01:53 +02:00
created_at =
NaiveDateTime.to_iso8601(created_at)
|> String.replace(~r/(\.\d+)?$/, ".000Z", global: false)
2018-09-03 03:58:55 +02:00
2018-09-03 03:52:02 +02:00
id = id |> to_string
2018-03-30 15:01:53 +02:00
case activity.data["type"] do
"Create" ->
2018-03-30 15:01:53 +02:00
%{
2018-09-03 03:52:02 +02:00
id: id,
2018-03-30 15:01:53 +02:00
type: "mention",
created_at: created_at,
account: AccountView.render("account.json", %{user: actor, for: user}),
2018-03-30 15:01:53 +02:00
status: StatusView.render("status.json", %{activity: activity, for: user})
}
"Like" ->
liked_activity = Activity.get_create_activity_by_object_ap_id(activity.data["object"])
2018-03-30 15:01:53 +02:00
%{
2018-09-03 03:52:02 +02:00
id: id,
2018-03-30 15:01:53 +02:00
type: "favourite",
created_at: created_at,
account: AccountView.render("account.json", %{user: actor, for: user}),
2018-03-30 15:01:53 +02:00
status: StatusView.render("status.json", %{activity: liked_activity, for: user})
}
"Announce" ->
announced_activity = Activity.get_create_activity_by_object_ap_id(activity.data["object"])
2018-03-30 15:01:53 +02:00
%{
2018-09-03 03:52:02 +02:00
id: id,
2018-03-30 15:01:53 +02:00
type: "reblog",
created_at: created_at,
account: AccountView.render("account.json", %{user: actor, for: user}),
2018-03-30 15:01:53 +02:00
status: StatusView.render("status.json", %{activity: announced_activity, for: user})
}
"Follow" ->
2018-03-30 15:01:53 +02:00
%{
2018-09-03 03:52:02 +02:00
id: id,
2018-03-30 15:01:53 +02:00
type: "follow",
created_at: created_at,
account: AccountView.render("account.json", %{user: actor, for: user})
2018-03-30 15:01:53 +02:00
}
_ ->
nil
end
end
def get_filters(%{assigns: %{user: user}} = conn, _) do
2018-08-14 04:27:28 +02:00
filters = Pleroma.Filter.get_filters(user)
res = FilterView.render("filters.json", filters: filters)
json(conn, res)
end
def create_filter(
%{assigns: %{user: user}} = conn,
%{"phrase" => phrase, "context" => context} = params
) do
query = %Pleroma.Filter{
user_id: user.id,
phrase: phrase,
context: context,
hide: Map.get(params, "irreversible", nil),
whole_word: Map.get(params, "boolean", true)
# expires_at
}
{:ok, response} = Pleroma.Filter.create(query)
res = FilterView.render("filter.json", filter: response)
json(conn, res)
end
def get_filter(%{assigns: %{user: user}} = conn, %{"id" => filter_id}) do
2018-08-14 04:27:28 +02:00
filter = Pleroma.Filter.get(filter_id, user)
res = FilterView.render("filter.json", filter: filter)
json(conn, res)
end
def update_filter(
%{assigns: %{user: user}} = conn,
%{"phrase" => phrase, "context" => context, "id" => filter_id} = params
) do
query = %Pleroma.Filter{
user_id: user.id,
filter_id: filter_id,
phrase: phrase,
context: context,
hide: Map.get(params, "irreversible", nil),
whole_word: Map.get(params, "boolean", true)
# expires_at
}
{:ok, response} = Pleroma.Filter.update(query)
res = FilterView.render("filter.json", filter: response)
json(conn, res)
end
def delete_filter(%{assigns: %{user: user}} = conn, %{"id" => filter_id}) do
2018-08-14 04:27:28 +02:00
query = %Pleroma.Filter{
user_id: user.id,
filter_id: filter_id
}
{:ok, _} = Pleroma.Filter.delete(query)
2018-08-14 04:27:28 +02:00
json(conn, %{})
end
def errors(conn, _) do
conn
|> put_status(500)
|> json("Something went wrong")
end
2018-07-13 17:21:38 +02:00
2018-07-14 04:41:09 +02:00
@suggestions Application.get_env(:pleroma, :suggestions)
2018-07-13 17:44:18 +02:00
def suggestions(%{assigns: %{user: user}} = conn, _) do
2018-07-18 02:58:59 +02:00
if Keyword.get(@suggestions, :enabled, false) do
2018-07-18 06:36:20 +02:00
api = Keyword.get(@suggestions, :third_party_engine, "")
timeout = Keyword.get(@suggestions, :timeout, 5000)
2018-09-09 06:57:23 +02:00
limit = Keyword.get(@suggestions, :limit, 23)
2018-07-17 09:45:18 +02:00
host =
Application.get_env(:pleroma, Pleroma.Web.Endpoint)
|> Keyword.get(:url)
|> Keyword.get(:host)
user = user.nickname
url = String.replace(api, "{{host}}", host) |> String.replace("{{user}}", user)
with {:ok, %{status_code: 200, body: body}} <-
2018-07-18 06:36:20 +02:00
@httpoison.get(url, [], timeout: timeout, recv_timeout: timeout),
2018-07-17 09:45:18 +02:00
{:ok, data} <- Jason.decode(body) do
data2 =
2018-09-09 06:57:23 +02:00
Enum.slice(data, 0, limit)
2018-07-17 09:45:18 +02:00
|> Enum.map(fn x ->
2018-08-23 04:52:18 +02:00
Map.put(
x,
"id",
case User.get_or_fetch(x["acct"]) do
%{id: id} -> id
_ -> 0
end
)
2018-07-17 09:45:18 +02:00
end)
2018-08-28 10:01:17 +02:00
|> Enum.map(fn x ->
Map.put(x, "avatar", MediaProxy.url(x["avatar"]))
end)
|> Enum.map(fn x ->
Map.put(x, "avatar_static", MediaProxy.url(x["avatar_static"]))
end)
2018-07-15 13:36:26 +02:00
2018-07-17 09:45:18 +02:00
conn
|> json(data2)
else
2018-07-17 10:29:18 +02:00
e -> Logger.error("Could not retrieve suggestions at fetch #{url}, #{inspect(e)}")
2018-07-17 09:45:18 +02:00
end
else
2018-07-17 09:45:18 +02:00
json(conn, [])
end
2018-07-13 17:21:38 +02:00
end
def try_render(conn, renderer, target, params)
when is_binary(target) do
res = render(conn, renderer, target, params)
if res == nil do
conn
|> put_status(501)
|> json(%{error: "Can't display this activity"})
else
res
end
end
def try_render(conn, _, _, _) do
conn
|> put_status(501)
|> json(%{error: "Can't display this activity"})
end
end