2018-08-28 02:20:54 +01:00
|
|
|
defmodule Pleroma.Uploaders.Local do
|
2018-08-28 13:57:41 +01:00
|
|
|
@behaviour Pleroma.Uploaders.Uploader
|
2018-08-28 02:20:54 +01:00
|
|
|
|
2018-08-28 02:45:53 +01:00
|
|
|
alias Pleroma.Web
|
|
|
|
|
2018-08-28 23:48:03 +01:00
|
|
|
def put_file(name, uuid, tmpfile, _content_type, should_dedupe) do
|
2018-08-28 02:45:53 +01:00
|
|
|
upload_folder = get_upload_path(uuid, should_dedupe)
|
2018-08-28 02:20:54 +01:00
|
|
|
url_path = get_url(name, uuid, should_dedupe)
|
|
|
|
|
|
|
|
File.mkdir_p!(upload_folder)
|
|
|
|
|
|
|
|
result_file = Path.join(upload_folder, name)
|
|
|
|
|
|
|
|
if File.exists?(result_file) do
|
2018-08-28 23:48:03 +01:00
|
|
|
File.rm!(tmpfile)
|
2018-08-28 02:20:54 +01:00
|
|
|
else
|
2018-08-28 23:48:03 +01:00
|
|
|
File.cp!(tmpfile, result_file)
|
2018-08-28 02:20:54 +01:00
|
|
|
end
|
|
|
|
|
2018-08-30 02:07:28 +01:00
|
|
|
{:ok, url_path}
|
2018-08-28 02:20:54 +01:00
|
|
|
end
|
|
|
|
|
|
|
|
def upload_path do
|
|
|
|
settings = Application.get_env(:pleroma, Pleroma.Uploaders.Local)
|
|
|
|
Keyword.fetch!(settings, :uploads)
|
|
|
|
end
|
|
|
|
|
|
|
|
defp get_upload_path(uuid, should_dedupe) do
|
|
|
|
if should_dedupe do
|
|
|
|
upload_path()
|
|
|
|
else
|
|
|
|
Path.join(upload_path(), uuid)
|
|
|
|
end
|
|
|
|
end
|
|
|
|
|
|
|
|
defp get_url(name, uuid, should_dedupe) do
|
|
|
|
if should_dedupe do
|
|
|
|
url_for(:cow_uri.urlencode(name))
|
|
|
|
else
|
|
|
|
url_for(Path.join(uuid, :cow_uri.urlencode(name)))
|
|
|
|
end
|
|
|
|
end
|
|
|
|
|
|
|
|
defp url_for(file) do
|
2018-09-01 16:14:14 +01:00
|
|
|
settings = Application.get_env(:pleroma, Pleroma.Uploaders.Local)
|
|
|
|
|
|
|
|
Keyword.get(settings, :uploads_url)
|
|
|
|
|> String.replace("{{file}}", file)
|
|
|
|
|> String.replace("{{base_url}}", Web.base_url())
|
2018-08-28 02:20:54 +01:00
|
|
|
end
|
|
|
|
end
|