mirror of
https://git.pleroma.social/pleroma/pleroma.git
synced 2024-05-19 01:58:05 +00:00
0ac010ba3f
This is for streaming media to ffmpeg thumbnailer. The existing implementation relies on undocumented behavior.
Erlang open_port/2 does not officially support passing a string of a file path for opening. The specs clearly state you are to provide one of the following for open_port/2:
{spawn, Command :: string() | binary()} |
{spawn_driver, Command :: string() | binary()} |
{spawn_executable, FileName :: file:name_all()} |
{fd, In :: integer() >= 0, Out :: integer() >= 0}
Our method technically works but is strongly discouraged as it can block the scheduler and dialyzer throws errors as it recognizes we're breaking the contract and some of the functions we wrote may never return.
This is indirectly covered by the Erlang FAQ section "9.12 Why can't I open devices (e.g. a serial port) like normal files?"
https://www.erlang.org/faq/problems#idm1127
71 lines
1.8 KiB
Elixir
71 lines
1.8 KiB
Elixir
# Pleroma: A lightweight social networking server
|
|
# Copyright © 2017-2022 Pleroma Authors <https://pleroma.social/>
|
|
# SPDX-License-Identifier: AGPL-3.0-only
|
|
|
|
defmodule Pleroma.Helpers.MediaHelper do
|
|
@moduledoc """
|
|
Handles common media-related operations.
|
|
"""
|
|
|
|
alias Pleroma.HTTP
|
|
alias Vix.Vips.Operation
|
|
|
|
require Logger
|
|
|
|
def missing_dependencies do
|
|
Enum.reduce([ffmpeg: "ffmpeg"], [], fn {sym, executable}, acc ->
|
|
if Pleroma.Utils.command_available?(executable) do
|
|
acc
|
|
else
|
|
[sym | acc]
|
|
end
|
|
end)
|
|
end
|
|
|
|
def image_resize(url, options) do
|
|
with {:ok, env} <- HTTP.get(url, [], pool: :media),
|
|
{:ok, resized} <-
|
|
Operation.thumbnail_buffer(env.body, options.max_width,
|
|
height: options.max_height,
|
|
size: :VIPS_SIZE_DOWN
|
|
) do
|
|
if options[:format] == "png" do
|
|
Operation.pngsave_buffer(resized, Q: options[:quality])
|
|
else
|
|
Operation.jpegsave_buffer(resized, Q: options[:quality], interlace: true)
|
|
end
|
|
else
|
|
{:error, _} = error -> error
|
|
end
|
|
end
|
|
|
|
# Note: video thumbnail is intentionally not resized (always has original dimensions)
|
|
def video_framegrab(url) do
|
|
with executable when is_binary(executable) <- System.find_executable("ffmpeg"),
|
|
{:ok, env} <- HTTP.get(url, [], pool: :media),
|
|
{:ok, pid} <- StringIO.open(env.body) do
|
|
body_stream = IO.binstream(pid, 1)
|
|
|
|
Exile.stream!(
|
|
[
|
|
executable,
|
|
"-i",
|
|
"pipe:0",
|
|
"-vframes",
|
|
"1",
|
|
"-f",
|
|
"mjpeg",
|
|
"pipe:1"
|
|
],
|
|
input: body_stream,
|
|
ignore_epipe: true,
|
|
stderr: :disable
|
|
)
|
|
|> Enum.into(<<>>)
|
|
else
|
|
nil -> {:error, {:ffmpeg, :command_not_found}}
|
|
{:error, _} = error -> error
|
|
end
|
|
end
|
|
end
|