X-Git-Url: https://git.squeep.com/?a=blobdiff_plain;f=lib%2Fpleroma%2Fuploaders%2Fs3.ex;h=40a836460b6f18744cc77058e7ab404e30ac3208;hb=698cb3587cf66f4946c2baab69ecd45f339e1392;hp=ea9e49cbf45fee7e1466f19278ffaeefe1b6f28e;hpb=0df558a6a5f5a5f64de57c91074981429da08764;p=akkoma diff --git a/lib/pleroma/uploaders/s3.ex b/lib/pleroma/uploaders/s3.ex index ea9e49cbf..40a836460 100644 --- a/lib/pleroma/uploaders/s3.ex +++ b/lib/pleroma/uploaders/s3.ex @@ -1,16 +1,19 @@ defmodule Pleroma.Uploaders.S3 do + alias Pleroma.Web.MediaProxy - def put_file(name, uuid, path, content_type, _should_dedupe) do + @behaviour Pleroma.Uploaders.Uploader + def put_file(name, uuid, path, content_type, _should_dedupe) do settings = Application.get_env(:pleroma, Pleroma.Uploaders.S3) bucket = Keyword.fetch!(settings, :bucket) public_endpoint = Keyword.fetch!(settings, :public_endpoint) + force_media_proxy = Keyword.fetch!(settings, :force_media_proxy) {:ok, file_data} = File.read(path) File.rm!(path) - s3_name = "#{uuid}/#{name}" + s3_name = "#{uuid}/#{encode(name)}" {:ok, _} = ExAws.S3.put_object(bucket, s3_name, file_data, [ @@ -19,6 +22,19 @@ defmodule Pleroma.Uploaders.S3 do ]) |> ExAws.request() - "#{public_endpoint}/#{bucket}/#{s3_name}" + url_base = "#{public_endpoint}/#{bucket}/#{s3_name}" + + public_url = + if force_media_proxy do + MediaProxy.url(url_base) + else + url_base + end + + {:ok, public_url} + end + + defp encode(name) do + String.replace(name, ~r/[^0-9a-zA-Z!.*'()_-]/, "-") end end