X-Git-Url: http://git.squeep.com/?a=blobdiff_plain;f=lib%2Fpleroma%2Fweb%2Fmastodon_api%2Fviews%2Fstatus_view.ex;h=a4539d47efa51bb0d7b4a65ed00ca337be129299;hb=37e5014d3ee571622d324cdadfc2bf7c345cc1fc;hp=cc5c0e9b67aa9c416c2f6d3caa9c6cc75fbfba83;hpb=1bc58230ee16e6a6a809de85c31eb6f0841b16b3;p=akkoma diff --git a/lib/pleroma/web/mastodon_api/views/status_view.ex b/lib/pleroma/web/mastodon_api/views/status_view.ex index cc5c0e9b6..a4539d47e 100644 --- a/lib/pleroma/web/mastodon_api/views/status_view.ex +++ b/lib/pleroma/web/mastodon_api/views/status_view.ex @@ -1,10 +1,83 @@ defmodule Pleroma.Web.MastodonAPI.StatusView do use Pleroma.Web, :view alias Pleroma.Web.MastodonAPI.{AccountView, StatusView} - alias Pleroma.User + alias Pleroma.{User, Activity} + alias Pleroma.Web.CommonAPI.Utils + alias Pleroma.Web.MediaProxy + alias Pleroma.Repo + + # TODO: Add cached version. + defp get_replied_to_activities(activities) do + activities + |> Enum.map(fn + (%{data: %{"type" => "Create", "object" => %{"inReplyTo" => inReplyTo}}}) -> + (inReplyTo != "") && inReplyTo + _ -> nil + end) + |> Enum.filter(&(&1)) + |> Activity.create_activity_by_object_id_query() + |> Repo.all + |> Enum.reduce(%{}, fn(activity, acc) -> Map.put(acc,activity.data["object"]["id"], activity) end) + end def render("index.json", opts) do - render_many(opts.activities, StatusView, "status.json", opts) + replied_to_activities = get_replied_to_activities(opts.activities) + render_many(opts.activities, StatusView, "status.json", Map.put(opts, :replied_to_activities, replied_to_activities)) + end + + def render("status.json", %{activity: %{data: %{"type" => "Announce", "object" => object}} = activity} = opts) do + user = User.get_cached_by_ap_id(activity.data["actor"]) + created_at = Utils.to_masto_date(activity.data["published"]) + + reblogged = Activity.get_create_activity_by_object_ap_id(object) + reblogged = render("status.json", Map.put(opts, :activity, reblogged)) + + mentions = activity.recipients + |> Enum.map(fn (ap_id) -> User.get_cached_by_ap_id(ap_id) end) + |> Enum.filter(&(&1)) + |> Enum.map(fn (user) -> AccountView.render("mention.json", %{user: user}) end) + + %{ + id: to_string(activity.id), + uri: object, + url: nil, # TODO: This might be wrong, check with mastodon. + account: AccountView.render("account.json", %{user: user}), + in_reply_to_id: nil, + in_reply_to_account_id: nil, + reblog: reblogged, + content: reblogged[:content], + created_at: created_at, + reblogs_count: 0, + favourites_count: 0, + reblogged: false, + favourited: false, + muted: false, + sensitive: false, + spoiler_text: "", + visibility: "public", + media_attachments: [], + mentions: mentions, + tags: [], + application: %{ + name: "Web", + website: nil + }, + language: nil, + emojis: [] + } + end + + def get_reply_to(activity, %{replied_to_activities: replied_to_activities}) do + id = activity.data["object"]["inReplyTo"] + replied_to_activities[activity.data["object"]["inReplyTo"]] + end + + def get_reply_to(%{data: %{"object" => object}}, _) do + if object["inReplyTo"] && object["inReplyTo"] != "" do + Activity.get_create_activity_by_object_ap_id(object["inReplyTo"]) + else + nil + end end def render("status.json", %{activity: %{data: %{"object" => object}} = activity} = opts) do @@ -14,9 +87,9 @@ defmodule Pleroma.Web.MastodonAPI.StatusView do announcement_count = object["announcement_count"] || 0 tags = object["tag"] || [] - sensitive = Enum.member?(tags, "nsfw") + sensitive = object["sensitive"] || Enum.member?(tags, "nsfw") - mentions = activity.data["to"] + mentions = activity.recipients |> Enum.map(fn (ap_id) -> User.get_cached_by_ap_id(ap_id) end) |> Enum.filter(&(&1)) |> Enum.map(fn (user) -> AccountView.render("mention.json", %{user: user}) end) @@ -26,16 +99,25 @@ defmodule Pleroma.Web.MastodonAPI.StatusView do attachments = render_many(object["attachment"] || [], StatusView, "attachment.json", as: :attachment) - created_at = (object["published"] || "") - |> String.replace(~r/\.\d+/, "") + created_at = Utils.to_masto_date(object["published"]) + + reply_to = get_reply_to(activity, opts) + reply_to_user = reply_to && User.get_cached_by_ap_id(reply_to.data["actor"]) + + emojis = (activity.data["object"]["emoji"] || []) + |> Enum.map(fn {name, url} -> + name = HtmlSanitizeEx.strip_tags(name) + url = HtmlSanitizeEx.strip_tags(url) + %{ shortcode: name, url: url, static_url: url } + end) %{ - id: activity.id, + id: to_string(activity.id), uri: object["id"], - url: object["external_url"], + url: object["external_url"] || object["id"], account: AccountView.render("account.json", %{user: user}), - in_reply_to_id: object["inReplyToStatusId"], - in_reply_to_account_id: nil, + in_reply_to_id: reply_to && reply_to.id, + in_reply_to_account_id: reply_to_user && reply_to_user.id, reblog: nil, content: HtmlSanitizeEx.basic_html(object["content"]), created_at: created_at, @@ -45,32 +127,50 @@ defmodule Pleroma.Web.MastodonAPI.StatusView do favourited: !!favorited, muted: false, sensitive: sensitive, - spoiler_text: "", - visibility: "public", - media_attachments: attachments, + spoiler_text: object["summary"] || "", + visibility: get_visibility(object), + media_attachments: attachments |> Enum.take(4), mentions: mentions, tags: [], # fix, - application: nil, - language: nil + application: %{ + name: "Web", + website: nil + }, + language: nil, + emojis: emojis } end + def get_visibility(object) do + public = "https://www.w3.org/ns/activitystreams#Public" + to = object["to"] || [] + cc = object["cc"] || [] + cond do + public in to -> "public" + public in cc -> "unlisted" + Enum.any?(to, &(String.contains?(&1, "/followers"))) -> "private" + true -> "direct" + end + end + def render("attachment.json", %{attachment: attachment}) do [%{"mediaType" => media_type, "href" => href} | _] = attachment["url"] type = cond do String.contains?(media_type, "image") -> "image" String.contains?(media_type, "video") -> "video" + String.contains?(media_type, "audio") -> "audio" true -> "unknown" end << hash_id::signed-32, _rest::binary >> = :crypto.hash(:md5, href) %{ - id: attachment["id"] || hash_id, - url: href, + id: to_string(attachment["id"] || hash_id), + url: MediaProxy.url(href), remote_url: href, - preview_url: href, + preview_url: MediaProxy.url(href), + text_url: href, type: type } end