1 defmodule Pleroma.Uploaders.S3 do
2 alias Pleroma.Web.MediaProxy
4 @behaviour Pleroma.Uploaders.Uploader
6 def put_file(name, uuid, path, content_type, _should_dedupe) do
7 settings = Application.get_env(:pleroma, Pleroma.Uploaders.S3)
8 bucket = Keyword.fetch!(settings, :bucket)
9 public_endpoint = Keyword.fetch!(settings, :public_endpoint)
10 force_media_proxy = Keyword.fetch!(settings, :force_media_proxy)
12 {:ok, file_data} = File.read(path)
16 s3_name = "#{uuid}/#{encode(name)}"
19 ExAws.S3.put_object(bucket, s3_name, file_data, [
21 {:content_type, content_type}
25 url_base = "#{public_endpoint}/#{bucket}/#{s3_name}"
28 if force_media_proxy do
29 MediaProxy.url(url_base)
38 String.replace(name, ~r/[^0-9a-zA-Z!.*'()_-]/, "-")