diff options
author | rinpatch <rinpatch@sdf.org> | 2018-12-01 18:12:27 +0300 |
---|---|---|
committer | rinpatch <rinpatch@sdf.org> | 2018-12-01 18:12:27 +0300 |
commit | fe2759bc9f2dad044b49f4954693ac09f9368041 (patch) | |
tree | 59dd9c5026f433d976defa303de0d6782d435d1e /lib/pleroma/uploaders/swift | |
parent | ba6e3eba33f16bdd2fede086d5fb5c86201cb57b (diff) | |
parent | 8c3ff06e35e11a40cf4eb35a41a2019b7496e62c (diff) | |
download | pleroma-fe2759bc9f2dad044b49f4954693ac09f9368041.tar.gz |
Attempt to resolve merge conflict
Diffstat (limited to 'lib/pleroma/uploaders/swift')
-rw-r--r-- | lib/pleroma/uploaders/swift/keystone.ex | 47 | ||||
-rw-r--r-- | lib/pleroma/uploaders/swift/swift.ex | 26 | ||||
-rw-r--r-- | lib/pleroma/uploaders/swift/uploader.ex | 15 |
3 files changed, 88 insertions, 0 deletions
diff --git a/lib/pleroma/uploaders/swift/keystone.ex b/lib/pleroma/uploaders/swift/keystone.ex new file mode 100644 index 000000000..e578b3c61 --- /dev/null +++ b/lib/pleroma/uploaders/swift/keystone.ex @@ -0,0 +1,47 @@ +defmodule Pleroma.Uploaders.Swift.Keystone do + use HTTPoison.Base + + def process_url(url) do + Enum.join( + [Pleroma.Config.get!([Pleroma.Uploaders.Swift, :auth_url]), url], + "/" + ) + end + + def process_response_body(body) do + body + |> Poison.decode!() + end + + def get_token() do + settings = Pleroma.Config.get(Pleroma.Uploaders.Swift) + username = Keyword.fetch!(settings, :username) + password = Keyword.fetch!(settings, :password) + tenant_id = Keyword.fetch!(settings, :tenant_id) + + case post( + "/tokens", + make_auth_body(username, password, tenant_id), + ["Content-Type": "application/json"], + hackney: [:insecure] + ) do + {:ok, %HTTPoison.Response{status_code: 200, body: body}} -> + body["access"]["token"]["id"] + + {:ok, %HTTPoison.Response{status_code: _}} -> + "" + end + end + + def make_auth_body(username, password, tenant) do + Poison.encode!(%{ + :auth => %{ + :passwordCredentials => %{ + :username => username, + :password => password + }, + :tenantId => tenant + } + }) + end +end diff --git a/lib/pleroma/uploaders/swift/swift.ex b/lib/pleroma/uploaders/swift/swift.ex new file mode 100644 index 000000000..1e865f101 --- /dev/null +++ b/lib/pleroma/uploaders/swift/swift.ex @@ -0,0 +1,26 @@ +defmodule Pleroma.Uploaders.Swift.Client do + use HTTPoison.Base + + def process_url(url) do + Enum.join( + [Pleroma.Config.get!([Pleroma.Uploaders.Swift, :storage_url]), url], + "/" + ) + end + + def upload_file(filename, body, content_type) do + object_url = Pleroma.Config.get!([Pleroma.Uploaders.Swift, :object_url]) + token = Pleroma.Uploaders.Swift.Keystone.get_token() + + case put("#{filename}", body, "X-Auth-Token": token, "Content-Type": content_type) do + {:ok, %HTTPoison.Response{status_code: 201}} -> + {:ok, {:file, filename}} + + {:ok, %HTTPoison.Response{status_code: 401}} -> + {:error, "Unauthorized, Bad Token"} + + {:error, _} -> + {:error, "Swift Upload Error"} + end + end +end diff --git a/lib/pleroma/uploaders/swift/uploader.ex b/lib/pleroma/uploaders/swift/uploader.ex new file mode 100644 index 000000000..b35b9807b --- /dev/null +++ b/lib/pleroma/uploaders/swift/uploader.ex @@ -0,0 +1,15 @@ +defmodule Pleroma.Uploaders.Swift do + @behaviour Pleroma.Uploaders.Uploader + + def get_file(name) do + {:ok, {:url, Path.join([Pleroma.Config.get!([__MODULE__, :object_url]), name])}} + end + + def put_file(upload) do + Pleroma.Uploaders.Swift.Client.upload_file( + upload.path, + File.read!(upload.tmpfile), + upload.content_type + ) + end +end |