- def make_poll_data(
- %{"poll" => %{"options" => options, "expires_in" => expires_in}} = data,
- mentions,
- tags
- )
- when is_list(options) and is_integer(expires_in) do
- content_type = get_content_type(data["content_type"])
- # XXX: There is probably a more performant/cleaner way to do this
- {poll, {mentions, tags}} =
- Enum.map_reduce(options, {mentions, tags}, fn option, {mentions, tags} ->
- # TODO: Custom emoji
- {option, mentions_merge, tags_merge} = format_input(option, content_type)
- mentions = mentions ++ mentions_merge
- tags = tags ++ tags_merge
-
- {%{
- "name" => option,
- "type" => "Note",
- "replies" => %{"type" => "Collection", "totalItems" => 0}
- }, {mentions, tags}}
- end)
-
- end_time =
- NaiveDateTime.utc_now()
- |> NaiveDateTime.add(expires_in)
- |> NaiveDateTime.to_iso8601()
-
- poll =
- if Pleroma.Web.ControllerHelper.truthy_param?(data["poll"]["multiple"]) do
- %{"type" => "Question", "anyOf" => poll, "closed" => end_time}
- else
- %{"type" => "Question", "oneOf" => poll, "closed" => end_time}
- end
+ def get_to_and_cc(_user, mentions, _inReplyTo, {:list, _}, _), do: {mentions, []}
+
+ def get_addressed_users(_, to) when is_list(to) do
+ User.get_ap_ids_by_nicknames(to)
+ end
+
+ def get_addressed_users(mentioned_users, _), do: mentioned_users
+
+ def maybe_add_list_data(activity_params, user, {:list, list_id}) do
+ case Pleroma.List.get(list_id, user) do
+ %Pleroma.List{} = list ->
+ activity_params
+ |> put_in([:additional, "bcc"], [list.ap_id])
+ |> put_in([:additional, "listMessage"], list.ap_id)
+ |> put_in([:object, "listMessage"], list.ap_id)
+
+ _ ->
+ activity_params
+ end
+ end
+
+ def maybe_add_list_data(activity_params, _, _), do: activity_params
+
+ def make_poll_data(%{"poll" => %{"expires_in" => expires_in}} = data)
+ when is_binary(expires_in) do
+ # In some cases mastofe sends out strings instead of integers
+ data
+ |> put_in(["poll", "expires_in"], String.to_integer(expires_in))
+ |> make_poll_data()
+ end
+
+ def make_poll_data(%{poll: %{options: options, expires_in: expires_in}} = data)
+ when is_list(options) do
+ limits = Config.get([:instance, :poll_limits])
+
+ with :ok <- validate_poll_expiration(expires_in, limits),
+ :ok <- validate_poll_options_amount(options, limits),
+ :ok <- validate_poll_options_length(options, limits) do
+ {option_notes, emoji} =
+ Enum.map_reduce(options, %{}, fn option, emoji ->
+ note = %{
+ "name" => option,
+ "type" => "Note",
+ "replies" => %{"type" => "Collection", "totalItems" => 0}
+ }
+
+ {note, Map.merge(emoji, Pleroma.Emoji.Formatter.get_emoji_map(option))}
+ end)
+
+ end_time =
+ DateTime.utc_now()
+ |> DateTime.add(expires_in)
+ |> DateTime.to_iso8601()
+
+ key = if truthy_param?(data.poll[:multiple]), do: "anyOf", else: "oneOf"
+ poll = %{"type" => "Question", key => option_notes, "closed" => end_time}
+
+ {:ok, {poll, emoji}}
+ end
+ end
+
+ def make_poll_data(%{"poll" => poll}) when is_map(poll) do
+ {:error, "Invalid poll"}
+ end
+
+ def make_poll_data(_data) do
+ {:ok, {%{}, %{}}}
+ end