Packages

file_storage_api

0.4.0
2.4.0 2.3.4 2.3.3 2.3.2 2.3.1 2.3.0 2.2.1 2.2.0 2.1.4 2.1.2 2.1.1 2.1.0 2.0.1 2.0.0 1.4.2 1.4.1 1.4.0 1.3.8 1.3.7 1.3.6 1.3.5 1.3.4 1.3.3 1.3.2 1.3.0 1.2.1 1.2.0 retired 1.1.0 1.0.0 0.4.1 0.4.0 0.3.3 0.3.2 0.3.1 0.3.0 0.2.1 0.2.0 0.1.2 0.1.1 0.1.0

Package to allow uploading to multiple different asset storage through 1 api. Configurable through env vars.

HexDocs

Current section

Files

Jump to
Readme
40 Versions
6 Dependencies
Dependants
Files
Activity
file_storage_api lib api s3 container.ex
Raw

lib/api/s3/container.ex 

defmodule FileStorageApi.API.S3.Container do

  @moduledoc false

  @behaviour FileStorageApi.Container



  import FileStorageApi.API.S3.Base

  alias ExAws.S3

  alias FileStorageApi.{Container, File}



  @impl true

  def create(container_name, opts) do

    result =

      container_name

      |> S3.put_bucket(region())

      |> request()



    case result do

      {:ok, result} ->

        put_cors(container_name, opts)

        {:ok, result}



      error ->

        error

    end

  end



  @impl true

  def list_files(container_name, options) do

    container_name

    |> S3.list_objects(convert_options(options))

    |> request()

    |> case do

      {:ok, %{body: %{contents: files, max_keys: max_results, next_marker: next_marker}}} ->

        {:ok,

         %Container{

           max_results: max_results,

           next_marker: next_marker,

           files: Enum.map(files, fn file -> struct(File, %{name: file.key, properties: file}) end)

         }}



      error ->

        error

    end

  end



  defp put_cors(bucket, %{cors_policy: cors_policy}) when is_map(cors_policy) or cors_policy == true do

    cors =

      case cors_policy do

        true ->

          [

            %{allowed_methods: ["GET"], allowed_origins: ["*"], allowed_headers: ["*"], max_age_seconds: 3000}

          ]



        %{} = cors_rules ->

          cors_rules

      end



    bucket

    |> S3.put_bucket_cors(cors)

    |> request()

  end



  defp put_cors(bucket, _), do: bucket

end