Packages

file_storage_api

0.1.1
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 container.ex
Raw

lib/container.ex 

defmodule FileStorageApi.Container do

  @moduledoc """

  Module for handling containers

  """



  @type t :: %__MODULE__{

          name: String.t(),

          files: [FileStorageApi.File.t()],

          max_results: non_neg_integer,

          next_marker: String.t(),

          date: DateTime.t()

        }

  @callback create(String.t()) :: {:ok, map} | {:error, map}

  @type options :: [{:max_results, non_neg_integer} | {:marker, String.t()}]

  @callback list_files(options) :: {:ok, [__MODULE__.t()]} | {:error, map}



  defstruct name: nil, files: [], max_results: nil, next_marker: nil, date: nil



  import FileStorageApi.Base



  @spec create(String.t()) :: any

  def create(container_name) do

    api_module(Container).create(container_name)

  end



  @spec list_files(options) :: Enumerable.t()

  def list_files(options \\ []) do

    filtered_options =

      if Keyword.has_key?(options, :max_results) do

        [max_results: Keyword.fetch!(options, :max_results)]

      else

        []

      end



    Stream.resource(

      fn -> api_module(Container).list_files(options) end,

      fn

        {:ok, %{files: files, next_marker: ""}} ->

          {files, :eos}



        {:ok, %{files: files, next_marker: next_marker}} ->

          {files, api_module(Container).list_files([marker: next_marker] ++ filtered_options)}



        :eos ->

          {:halt, :eos}

      end,

      fn :eos ->

        :ok

      end

    )

  end

end