ExFTP.Storage.FileConnector (ExFTP v1.2.0)

View Source

When storage_connector is ExFTP.Storage.FileConnector, this connector will use the file system of where it is running.

This is the out-of-the-box behavior you'd expect from any FTP server.

🔒 Security

Currently, there is no file access management per user.

Authenticated users perform file system actions as if they were the FTP user

⚙️ Configuration

Keys

Example

  %{
    # ... ,
    storage_connector: ExFTP.Storage.FileConnector,
    storage_config: %{}
  }

👀 See Also

📖 Resources

Summary

Functions

create_write_func(path, connector_state, opts \\ [])

Create a function/1 that writes a stream to storage

delete_directory(path, connector_state)

Deletes a given directory

delete_file(path, connector_state)

Deletes a given file

directory_exists?(path, connector_state)

Whether a given path is an existing directory

get_content(path, connector_state)

Returns a stream to read the raw bytes of an object specified by a given path

get_content_info(path, connector_state)

Returns a ExFTP.StorageConnector.content_info/0 representing a given path

get_directory_contents(path, connector_state)

Returns a list of ExFTP.StorageConnector.content_info/0 representing each object in a given directory

get_working_directory(connector_state)

Returns the current working directory

make_directory(path, connector_state)

Creates a directory, given a path

Functions

create_write_func(path, connector_state, opts \\ [])

@spec create_write_func(
  path :: ExFTP.StorageConnector.path(),
  connector_state :: ExFTP.StorageConnector.connector_state(),
  opts :: list()
) :: function()

Create a function/1 that writes a stream to storage

🏷️ Params

💻 Examples

    @impl StorageConnector
    def create_write_func(path, connector_state, opts \ []) do
      fn stream ->
        fs = File.stream!(path)

        try do
          _ =
            stream
            |> chunk_stream(opts)
            |> Enum.into(fs)

          {:ok, connector_state}
        rescue
          _ ->
            {:error, "Failed to transfer"}
        end
      end
    end

delete_directory(path, connector_state)

@spec delete_directory(
  path :: ExFTP.StorageConnector.path(),
  connector_state :: ExFTP.StorageConnector.connector_state()
) :: {:ok, ExFTP.StorageConnector.connector_state()} | {:error, term()}

Deletes a given directory

🏷️ Params

⤵️ Returns

✅ On Success

  {:ok, connector_state}

❌ On Failure

  {:error, err}

💻 Examples

iex> alias ExFTP.Storage.FileConnector
iex> connector_state = %{current_working_directory: "/"}
iex> dir_to_make = File.cwd!() |> Path.join("new_dir")
iex> {:ok, connector_state} = FileConnector.make_directory(dir_to_make, connector_state)
iex> dir_to_rm = dir_to_make
iex> {:ok, connector_state} = FileConnector.delete_directory(dir_to_rm, connector_state)
iex> FileConnector.directory_exists?(dir_to_rm, connector_state)
false

👀 See Also

📖 Resources

delete_file(path, connector_state)

@spec delete_file(
  path :: ExFTP.StorageConnector.path(),
  connector_state :: ExFTP.StorageConnector.connector_state()
) :: {:ok, ExFTP.StorageConnector.connector_state()} | {:error, term()}

Deletes a given file

🏷️ Params

⤵️ Returns

✅ On Success

  {:ok, connector_state}

❌ On Failure

  {:error, err}

👀 See Also

📖 Resources

directory_exists?(path, connector_state)

@spec directory_exists?(
  path :: ExFTP.StorageConnector.path(),
  connector_state :: ExFTP.StorageConnector.connector_state()
) :: boolean()

Whether a given path is an existing directory

🏷️ Params

⤵️ Returns

✅ On Success

  `true` or `false`

💻 Examples

iex> alias ExFTP.Storage.FileConnector
iex> FileConnector.directory_exists?("/tmp", %{current_working_directory: "/"})
true
iex> FileConnector.directory_exists?("/does-not-exist", %{current_working_directory: "/"})
false

👀 See Also

📖 Resources

get_content(path, connector_state)

@spec get_content(
  path :: ExFTP.StorageConnector.path(),
  connector_state :: ExFTP.StorageConnector.connector_state()
) :: {:ok, any()} | {:error, term()}

Returns a stream to read the raw bytes of an object specified by a given path

🏷️ Params

⤵️ Returns

✅ On Success

  {:ok, data}

❌ On Failure

  {:error, err}

💻 Examples

iex> alias ExFTP.Storage.FileConnector
iex> connector_state = %{current_working_directory: "/"}
iex> file_to_get_content = File.cwd!() |> File.ls!() |> Enum.filter(&String.contains?(&1,".")) |> hd()
iex> path = Path.join(File.cwd!(), file_to_get_content)
iex> {:ok, _data} = FileConnector.get_content(path, connector_state)

👀 See Also

📖 Resources

get_content_info(path, connector_state)

@spec get_content_info(
  path :: ExFTP.StorageConnector.path(),
  connector_state :: ExFTP.StorageConnector.connector_state()
) :: {:ok, ExFTP.StorageConnector.content_info()} | {:error, term()}

Returns a ExFTP.StorageConnector.content_info/0 representing a given path

🏷️ Params

⤵️ Returns

✅ On Success

  {:ok, %{...}}

❌ On Failure

  {:error, err}

💻 Examples

iex> alias ExFTP.Storage.FileConnector
iex> connector_state = %{current_working_directory: "/"}
iex> file_to_get_info = File.cwd!() |> File.ls!() |> hd()
iex> path = Path.join(File.cwd!(), file_to_get_info)
iex> {:ok, _content_info} = FileConnector.get_content_info(path, connector_state)

👀 See Also

📖 Resources

get_directory_contents(path, connector_state)

@spec get_directory_contents(
  path :: ExFTP.StorageConnector.path(),
  connector_state :: ExFTP.StorageConnector.connector_state()
) :: {:ok, [ExFTP.StorageConnector.content_info()]} | {:error, term()}

Returns a list of ExFTP.StorageConnector.content_info/0 representing each object in a given directory

🏷️ Params

⤵️ Returns

✅ On Success

  {:ok, [%{...}, ...]}

❌ On Failure

  {:error, err}

💻 Examples

iex> alias ExFTP.Storage.FileConnector
iex> connector_state = %{current_working_directory: "/"}
iex> dir = File.cwd!()
iex> {:ok, _content_infos} = FileConnector.get_directory_contents(dir, connector_state)

👀 See Also

📖 Resources

get_working_directory(connector_state)

@spec get_working_directory(
  connector_state :: ExFTP.StorageConnector.connector_state()
) :: String.t()

Returns the current working directory

🏷️ Params

💻 Examples

iex> alias ExFTP.Storage.FileConnector
iex> FileConnector.get_working_directory(%{current_working_directory: "/"})
"/"

👀 See Also

📖 Resources

make_directory(path, connector_state)

@spec make_directory(
  path :: ExFTP.StorageConnector.path(),
  connector_state :: ExFTP.StorageConnector.connector_state()
) :: {:ok, ExFTP.StorageConnector.connector_state()} | {:error, term()}

Creates a directory, given a path

🏷️ Params

⤵️ Returns

✅ On Success

  {:ok, connector_state}

❌ On Failure

  {:error, err}

💻 Examples

iex> alias ExFTP.Storage.FileConnector
iex> connector_state = %{current_working_directory: "/"}
iex> dir_to_make = File.cwd!() |> Path.join("new_dir")
iex> {:ok, connector_state} = FileConnector.make_directory(dir_to_make, connector_state)
iex> FileConnector.directory_exists?(dir_to_make, connector_state)
true
iex> dir_to_rm = dir_to_make
iex> {:ok, connector_state} = FileConnector.delete_directory(dir_to_rm, connector_state)
iex> FileConnector.directory_exists?(dir_to_rm, connector_state)
false

👀 See Also

📖 Resources