No OneTemporary
Actions

Authored By

Unknown

Size

18 KB

Referenced Files

None

Subscribers

None

View Options

	diff --git a/lib/pleroma/web/api_spec/operations/pleroma_scrobble_operation.ex b/lib/pleroma/web/api_spec/operations/pleroma_scrobble_operation.ex
	index 68c586b73..141b60533 100644
	--- a/lib/pleroma/web/api_spec/operations/pleroma_scrobble_operation.ex
	+++ b/lib/pleroma/web/api_spec/operations/pleroma_scrobble_operation.ex
	@@ -1,108 +1,108 @@
	# Pleroma: A lightweight social networking server
	# Copyright © 2017-2022 Pleroma Authors <https://pleroma.social/>
	# SPDX-License-Identifier: AGPL-3.0-only

	defmodule Pleroma.Web.ApiSpec.PleromaScrobbleOperation do
	alias OpenApiSpex.Operation
	alias OpenApiSpex.Reference
	alias OpenApiSpex.Schema
	alias Pleroma.Web.ApiSpec.Schemas.Account
	alias Pleroma.Web.ApiSpec.Schemas.VisibilityScope

	import Pleroma.Web.ApiSpec.Helpers

	def open_api_operation(action) do
	operation = String.to_existing_atom("#{action}_operation")
	apply(__MODULE__, operation, [])
	end

	def create_operation do
	%Operation{
	tags: ["Scrobbles"],
	summary: "Creates a new Listen activity for an account",
	security: [%{"oAuth" => ["write"]}],
	operationId: "PleromaAPI.ScrobbleController.create",
	deprecated: true,
	requestBody: request_body("Parameters", create_request(), requried: true),
	responses: %{
	200 => Operation.response("Scrobble", "application/json", scrobble())
	}
	}
	end

	def index_operation do
	%Operation{
	tags: ["Scrobbles"],
	summary: "Requests a list of current and recent Listen activities for an account",
	operationId: "PleromaAPI.ScrobbleController.index",
	deprecated: true,
	parameters: [
	%Reference{"$ref": "#/components/parameters/accountIdOrNickname"} \| pagination_params()
	],
	security: [%{"oAuth" => ["read"]}],
	responses: %{
	200 =>
	Operation.response("Array of Scrobble", "application/json", %Schema{
	type: :array,
	items: scrobble()
	})
	}
	}
	end

	defp create_request do
	%Schema{
	type: :object,
	required: [:title],
	properties: %{
	title: %Schema{type: :string, description: "The title of the media playing"},
	album: %Schema{type: :string, description: "The album of the media playing"},
	artist: %Schema{type: :string, description: "The artist of the media playing"},
	length: %Schema{type: :integer, description: "The length of the media playing"},
	- url: %Schema{type: :string, description: "A URL referencing the media playing"},
	+ externalLink: %Schema{type: :string, description: "A URL referencing the media playing"},
	visibility: %Schema{
	allOf: [VisibilityScope],
	default: "public",
	description: "Scrobble visibility"
	}
	},
	example: %{
	"title" => "Some Title",
	"artist" => "Some Artist",
	"album" => "Some Album",
	"length" => 180_000,
	- "url" => "https://www.last.fm/music/Some+Artist/_/Some+Title"
	+ "externalLink" => "https://www.last.fm/music/Some+Artist/_/Some+Title"
	}
	}
	end

	defp scrobble do
	%Schema{
	type: :object,
	properties: %{
	id: %Schema{type: :string},
	account: Account,
	title: %Schema{type: :string, description: "The title of the media playing"},
	album: %Schema{type: :string, description: "The album of the media playing"},
	artist: %Schema{type: :string, description: "The artist of the media playing"},
	- url: %Schema{type: :string, description: "A URL referencing the media playing"},
	+ externalLink: %Schema{type: :string, description: "A URL referencing the media playing"},
	length: %Schema{
	type: :integer,
	description: "The length of the media playing",
	nullable: true
	},
	created_at: %Schema{type: :string, format: :"date-time"}
	},
	example: %{
	"id" => "1234",
	"account" => Account.schema().example,
	"title" => "Some Title",
	"artist" => "Some Artist",
	"album" => "Some Album",
	"length" => 180_000,
	- "url" => "https://www.last.fm/music/Some+Artist/_/Some+Title",
	+ "externalLink" => "https://www.last.fm/music/Some+Artist/_/Some+Title",
	"created_at" => "2019-09-28T12:40:45.000Z"
	}
	}
	end
	end
	diff --git a/lib/pleroma/web/common_api/activity_draft.ex b/lib/pleroma/web/common_api/activity_draft.ex
	index 00cbacbb4..8910ad5b8 100644
	--- a/lib/pleroma/web/common_api/activity_draft.ex
	+++ b/lib/pleroma/web/common_api/activity_draft.ex
	@@ -1,316 +1,316 @@
	# Pleroma: A lightweight social networking server
	# Copyright © 2017-2022 Pleroma Authors <https://pleroma.social/>
	# SPDX-License-Identifier: AGPL-3.0-only

	defmodule Pleroma.Web.CommonAPI.ActivityDraft do
	alias Pleroma.Activity
	alias Pleroma.Conversation.Participation
	alias Pleroma.Object
	alias Pleroma.Web.ActivityPub.Builder
	alias Pleroma.Web.ActivityPub.Visibility
	alias Pleroma.Web.CommonAPI
	alias Pleroma.Web.CommonAPI.Utils

	import Pleroma.Web.Gettext
	import Pleroma.Web.Utils.Guards, only: [not_empty_string: 1]

	defstruct valid?: true,
	errors: [],
	user: nil,
	params: %{},
	status: nil,
	summary: nil,
	full_payload: nil,
	attachments: [],
	in_reply_to: nil,
	in_reply_to_conversation: nil,
	quote_post: nil,
	visibility: nil,
	expires_at: nil,
	extra: nil,
	emoji: %{},
	content_html: nil,
	mentions: [],
	tags: [],
	to: [],
	cc: [],
	context: nil,
	sensitive: false,
	object: nil,
	preview?: false,
	changes: %{}

	def new(user, params) do
	%__MODULE__{user: user}
	\|> put_params(params)
	end

	def create(user, params) do
	user
	\|> new(params)
	\|> status()
	\|> summary()
	\|> with_valid(&attachments/1)
	\|> full_payload()
	\|> expires_at()
	\|> poll()
	\|> with_valid(&in_reply_to/1)
	\|> with_valid(&in_reply_to_conversation/1)
	\|> with_valid(&quote_post/1)
	\|> with_valid(&visibility/1)
	\|> with_valid(&quoting_visibility/1)
	\|> content()
	\|> with_valid(&to_and_cc/1)
	\|> with_valid(&context/1)
	\|> sensitive()
	\|> with_valid(&object/1)
	\|> preview?()
	\|> with_valid(&changes/1)
	\|> validate()
	end

	def listen(user, params) do
	user
	\|> new(params)
	\|> visibility()
	\|> to_and_cc()
	\|> context()
	\|> listen_object()
	\|> with_valid(&changes/1)
	\|> validate()
	end

	defp listen_object(draft) do
	object =
	draft.params
	- \|> Map.take([:album, :artist, :title, :length, :url])
	+ \|> Map.take([:album, :artist, :title, :length, :externalLink])
	\|> Map.new(fn {key, value} -> {to_string(key), value} end)
	\|> Map.put("type", "Audio")
	\|> Map.put("to", draft.to)
	\|> Map.put("cc", draft.cc)
	\|> Map.put("actor", draft.user.ap_id)

	%__MODULE__{draft \| object: object}
	end

	defp put_params(draft, params) do
	params = Map.put_new(params, :in_reply_to_status_id, params[:in_reply_to_id])
	%__MODULE__{draft \| params: params}
	end

	defp status(%{params: %{status: status}} = draft) do
	%__MODULE__{draft \| status: String.trim(status)}
	end

	defp summary(%{params: params} = draft) do
	%__MODULE__{draft \| summary: Map.get(params, :spoiler_text, "")}
	end

	defp full_payload(%{status: status, summary: summary} = draft) do
	full_payload = String.trim(status <> summary)

	case Utils.validate_character_limit(full_payload, draft.attachments) do
	:ok -> %__MODULE__{draft \| full_payload: full_payload}
	{:error, message} -> add_error(draft, message)
	end
	end

	defp attachments(%{params: params} = draft) do
	attachments = Utils.attachments_from_ids(params, draft.user)
	draft = %__MODULE__{draft \| attachments: attachments}

	case Utils.validate_attachments_count(attachments) do
	:ok -> draft
	{:error, message} -> add_error(draft, message)
	end
	end

	defp in_reply_to(%{params: %{in_reply_to_status_id: ""}} = draft), do: draft

	defp in_reply_to(%{params: %{in_reply_to_status_id: id}} = draft) when is_binary(id) do
	%__MODULE__{draft \| in_reply_to: Activity.get_by_id(id)}
	end

	defp in_reply_to(%{params: %{in_reply_to_status_id: %Activity{} = in_reply_to}} = draft) do
	%__MODULE__{draft \| in_reply_to: in_reply_to}
	end

	defp in_reply_to(draft), do: draft

	defp quote_post(%{params: %{quote_id: id}} = draft) when not_empty_string(id) do
	case Activity.get_by_id_with_object(id) do
	%Activity{} = activity ->
	%__MODULE__{draft \| quote_post: activity}

	_ ->
	draft
	end
	end

	defp quote_post(draft), do: draft

	defp in_reply_to_conversation(draft) do
	in_reply_to_conversation = Participation.get(draft.params[:in_reply_to_conversation_id])
	%__MODULE__{draft \| in_reply_to_conversation: in_reply_to_conversation}
	end

	defp visibility(%{params: params} = draft) do
	case CommonAPI.get_visibility(params, draft.in_reply_to, draft.in_reply_to_conversation) do
	{visibility, "direct"} when visibility != "direct" ->
	add_error(draft, dgettext("errors", "The message visibility must be direct"))

	{visibility, _} ->
	%__MODULE__{draft \| visibility: visibility}
	end
	end

	defp can_quote?(_draft, _object, visibility) when visibility in ~w(public unlisted local) do
	true
	end

	defp can_quote?(draft, object, "private") do
	draft.user.ap_id == object.data["actor"]
	end

	defp can_quote?(_, _, _) do
	false
	end

	defp quoting_visibility(%{quote_post: %Activity{}} = draft) do
	with %Object{} = object <- Object.normalize(draft.quote_post, fetch: false),
	true <- can_quote?(draft, object, Visibility.get_visibility(object)) do
	draft
	else
	_ -> add_error(draft, dgettext("errors", "Cannot quote private message"))
	end
	end

	defp quoting_visibility(draft), do: draft

	defp expires_at(draft) do
	case CommonAPI.check_expiry_date(draft.params[:expires_in]) do
	{:ok, expires_at} -> %__MODULE__{draft \| expires_at: expires_at}
	{:error, message} -> add_error(draft, message)
	end
	end

	defp poll(draft) do
	case Utils.make_poll_data(draft.params) do
	{:ok, {poll, poll_emoji}} ->
	%__MODULE__{draft \| extra: poll, emoji: Map.merge(draft.emoji, poll_emoji)}

	{:error, message} ->
	add_error(draft, message)
	end
	end

	defp content(%{mentions: mentions} = draft) do
	{content_html, mentioned_users, tags} = Utils.make_content_html(draft)

	mentioned_ap_ids =
	Enum.map(mentioned_users, fn {_, mentioned_user} -> mentioned_user.ap_id end)

	mentions =
	mentions
	\|> Kernel.++(mentioned_ap_ids)
	\|> Utils.get_addressed_users(draft.params[:to])

	%__MODULE__{draft \| content_html: content_html, mentions: mentions, tags: tags}
	end

	defp to_and_cc(draft) do
	{to, cc} = Utils.get_to_and_cc(draft)
	%__MODULE__{draft \| to: to, cc: cc}
	end

	defp context(draft) do
	context = Utils.make_context(draft.in_reply_to, draft.in_reply_to_conversation)
	%__MODULE__{draft \| context: context}
	end

	defp sensitive(draft) do
	sensitive = draft.params[:sensitive]
	%__MODULE__{draft \| sensitive: sensitive}
	end

	defp object(draft) do
	emoji = Map.merge(Pleroma.Emoji.Formatter.get_emoji_map(draft.full_payload), draft.emoji)

	# Sometimes people create posts with subject containing emoji,
	# since subjects are usually copied this will result in a broken
	# subject when someone replies from an instance that does not have
	# the emoji or has it under different shortcode. This is an attempt
	# to mitigate this by copying emoji from inReplyTo if they are present
	# in the subject.
	summary_emoji =
	with %Activity{} <- draft.in_reply_to,
	%Object{data: %{"tag" => [_ \| _] = tag}} <- Object.normalize(draft.in_reply_to) do
	Enum.reduce(tag, %{}, fn
	%{"type" => "Emoji", "name" => name, "icon" => %{"url" => url}}, acc ->
	if String.contains?(draft.summary, name) do
	Map.put(acc, name, url)
	else
	acc
	end

	_, acc ->
	acc
	end)
	else
	_ -> %{}
	end

	emoji = Map.merge(emoji, summary_emoji)

	{:ok, note_data, _meta} = Builder.note(draft)

	object =
	note_data
	\|> Map.put("emoji", emoji)
	\|> Map.put("source", %{
	"content" => draft.status,
	"mediaType" => Utils.get_content_type(draft.params[:content_type])
	})
	\|> Map.put("generator", draft.params[:generator])

	%__MODULE__{draft \| object: object}
	end

	defp preview?(draft) do
	preview? = Pleroma.Web.Utils.Params.truthy_param?(draft.params[:preview])
	%__MODULE__{draft \| preview?: preview?}
	end

	defp changes(draft) do
	direct? = draft.visibility == "direct"
	additional = %{"cc" => draft.cc, "directMessage" => direct?}

	additional =
	case draft.expires_at do
	%DateTime{} = expires_at -> Map.put(additional, "expires_at", expires_at)
	_ -> additional
	end

	changes =
	%{
	to: draft.to,
	actor: draft.user,
	context: draft.context,
	object: draft.object,
	additional: additional
	}
	\|> Utils.maybe_add_list_data(draft.user, draft.visibility)

	%__MODULE__{draft \| changes: changes}
	end

	defp with_valid(%{valid?: true} = draft, func), do: func.(draft)
	defp with_valid(draft, _func), do: draft

	defp add_error(draft, message) do
	%__MODULE__{draft \| valid?: false, errors: [message \| draft.errors]}
	end

	defp validate(%{valid?: true} = draft), do: {:ok, draft}
	defp validate(%{errors: [message \| _]}), do: {:error, message}
	end
	diff --git a/lib/pleroma/web/pleroma_api/views/scrobble_view.ex b/lib/pleroma/web/pleroma_api/views/scrobble_view.ex
	index 7a983f8b5..edf0a2390 100644
	--- a/lib/pleroma/web/pleroma_api/views/scrobble_view.ex
	+++ b/lib/pleroma/web/pleroma_api/views/scrobble_view.ex
	@@ -1,38 +1,38 @@
	# Pleroma: A lightweight social networking server
	# Copyright © 2017-2022 Pleroma Authors <https://pleroma.social/>
	# SPDX-License-Identifier: AGPL-3.0-only

	defmodule Pleroma.Web.PleromaAPI.ScrobbleView do
	use Pleroma.Web, :view

	require Pleroma.Constants

	alias Pleroma.Activity
	alias Pleroma.HTML
	alias Pleroma.Object
	alias Pleroma.Web.CommonAPI
	alias Pleroma.Web.CommonAPI.Utils
	alias Pleroma.Web.MastodonAPI.AccountView

	def render("show.json", %{activity: %Activity{data: %{"type" => "Listen"}} = activity} = opts) do
	object = Object.normalize(activity, fetch: false)

	user = CommonAPI.get_user(activity.data["actor"])
	created_at = Utils.to_masto_date(activity.data["published"])

	%{
	id: activity.id,
	account: AccountView.render("show.json", %{user: user, for: opts[:for]}),
	created_at: created_at,
	title: object.data["title"] \|> HTML.strip_tags(),
	artist: object.data["artist"] \|> HTML.strip_tags(),
	album: object.data["album"] \|> HTML.strip_tags(),
	- url: object.data["url"],
	+ externalLink: object.data["externalLink"],
	length: object.data["length"]
	}
	end

	def render("index.json", opts) do
	safe_render_many(opts.activities, __MODULE__, "show.json", opts)
	end
	end
	diff --git a/test/pleroma/web/pleroma_api/controllers/scrobble_controller_test.exs b/test/pleroma/web/pleroma_api/controllers/scrobble_controller_test.exs
	index df12a05ce..be94a02ad 100644
	--- a/test/pleroma/web/pleroma_api/controllers/scrobble_controller_test.exs
	+++ b/test/pleroma/web/pleroma_api/controllers/scrobble_controller_test.exs
	@@ -1,64 +1,64 @@
	# Pleroma: A lightweight social networking server
	# Copyright © 2017-2022 Pleroma Authors <https://pleroma.social/>
	# SPDX-License-Identifier: AGPL-3.0-only

	defmodule Pleroma.Web.PleromaAPI.ScrobbleControllerTest do
	use Pleroma.Web.ConnCase, async: true

	alias Pleroma.Web.CommonAPI

	describe "POST /api/v1/pleroma/scrobble" do
	test "works correctly" do
	%{conn: conn} = oauth_access(["write"])

	conn =
	conn
	\|> put_req_header("content-type", "application/json")
	\|> post("/api/v1/pleroma/scrobble", %{
	"title" => "lain radio episode 1",
	"artist" => "lain",
	"album" => "lain radio",
	"length" => "180000",
	- "url" => "https://www.last.fm/music/lain/lain+radio/lain+radio+episode+1"
	+ "externalLink" => "https://www.last.fm/music/lain/lain+radio/lain+radio+episode+1"
	})

	assert %{"title" => "lain radio episode 1"} = json_response_and_validate_schema(conn, 200)
	end
	end

	describe "GET /api/v1/pleroma/accounts/:id/scrobbles" do
	test "works correctly" do
	%{user: user, conn: conn} = oauth_access(["read"])

	{:ok, _activity} =
	CommonAPI.listen(user, %{
	title: "lain radio episode 1",
	artist: "lain",
	album: "lain radio",
	- url: "https://www.last.fm/music/lain/lain+radio/lain+radio+episode+1"
	+ externalLink: "https://www.last.fm/music/lain/lain+radio/lain+radio+episode+1"
	})

	{:ok, _activity} =
	CommonAPI.listen(user, %{
	title: "lain radio episode 2",
	artist: "lain",
	album: "lain radio",
	- url: "https://www.last.fm/music/lain/lain+radio/lain+radio+episode+2"
	+ externalLink: "https://www.last.fm/music/lain/lain+radio/lain+radio+episode+2"
	})

	{:ok, _activity} =
	CommonAPI.listen(user, %{
	title: "lain radio episode 3",
	artist: "lain",
	album: "lain radio",
	- url: "https://www.last.fm/music/lain/lain+radio/lain+radio+episode+3"
	+ externalLink: "https://www.last.fm/music/lain/lain+radio/lain+radio+episode+3"
	})

	conn = get(conn, "/api/v1/pleroma/accounts/#{user.id}/scrobbles")

	result = json_response_and_validate_schema(conn, 200)

	assert length(result) == 3
	end
	end
	end

File Metadata

Mime Type: text/x-diff
Expires: Thu, Oct 29, 9:06 AM (16 h, 36 m)
Storage Engine: blob
Storage Format: Raw Data
Storage Handle: 1797833
Default Alt Text: (18 KB)

No OneTemporaryActions

View Options

File Metadata

Event Timeline

No OneTemporary
Actions