Options to facilitate opts concerns of source, sink implementation

lib/stow/source/extras.ex → lib/stow/options.ex

@@ -1,6 +1,7 @@
-defmodule Stow.Source.Extras do
+defmodule Stow.Options do
   @moduledoc false
   alias Stow.Http.Headers
+
   defstruct headers: %Headers{}
   @type t :: %__MODULE__{headers: Headers.t()}
 end

lib/stow/plug/source.ex

@@ -8,7 +8,7 @@ defmodule Stow.Plug.Source do
   import Plug.Conn, only: [halt: 1, resp: 3]
   import Utils, only: [fetch_uri: 2, put_headers: 3, set_uri_params: 2, update_private: 3]
 
-  @plug_opts [:uri, :extras]
+  @plug_opts [:uri, :options]
   @schemes ["http", "https"]
 
   @impl true
@@ -37,13 +37,13 @@ defmodule Stow.Plug.Source do
 
   defp get_req_headers(conn, opts) do
     fetch_headers(conn.private.stow.source, :req) ||
-      fetch_headers(Keyword.get(opts, :extras), :req) || []
+      fetch_headers(Keyword.get(opts, :options), :req) || []
   end
 
   # to fix: refactor this to the plug utils module
   defp fetch_headers(nil, _type), do: nil
-  defp fetch_headers(%Source{extras: %{headers: %{req: h}}}, :req) when h != [], do: h
-  defp fetch_headers(%Source{extras: %{headers: %{resp: h}}}, :resp) when h != [], do: h
+  defp fetch_headers(%Source{options: %{headers: %{req: h}}}, :req) when h != [], do: h
+  defp fetch_headers(%Source{options: %{headers: %{resp: h}}}, :resp) when h != [], do: h
   defp fetch_headers(%{headers: %{req: h}}, :req) when h != [], do: h
   defp fetch_headers(%{headers: %{resp: h}}, :resp) when h != [], do: h
   defp fetch_headers(%{}, _), do: nil
@@ -54,7 +54,7 @@ defmodule Stow.Plug.Source do
     |> Macro.camelize()
     |> then(fn source -> Module.concat(Source, source) end)
     |> apply(:get, [conn, opts |> Keyword.drop(@plug_opts)])
-    |> update_conn(conn, uri, fetch_headers(Keyword.get(opts, :extras), :resp) || [])
+    |> update_conn(conn, uri, fetch_headers(Keyword.get(opts, :options), :resp) || [])
   end
 
   defp normalise_scheme_name(scheme) when scheme in [:http, :https], do: "http"

lib/stow/source.ex

@@ -5,13 +5,13 @@ defmodule Stow.Source do
 
   alias Stow.Http.Client, as: HttpClient
   alias Stow.Http.Headers
-  alias Stow.Source.Extras
+  alias Stow.Options
 
-  defstruct [:uri, :status, extras: %Extras{}]
+  defstruct [:uri, :status, options: %Options{}]
 
   @type t :: %__MODULE__{
           uri: binary() | nil,
-          extras: Extras.t(),
+          options: Options.t(),
           status: nil | :ok | {:error, term()}
         }
 
@@ -23,7 +23,7 @@ defmodule Stow.Source do
   def new(uri, headers \\ []) do
     %__MODULE__{
       uri: uri,
-      extras: %Extras{
+      options: %Options{
         headers: %Headers{
           req: Keyword.get(headers, :req_headers, []),
           resp: Keyword.get(headers, :resp_headers, [])

test/stow/pipeline/source_sink_test.exs

@@ -89,7 +89,7 @@ defmodule Stow.Pipeline.SourceSinkTest do
                source: %Source{
                  status: :ok,
                  uri: ^src_uri,
-                 extras: %{headers: %{req: [], resp: []}}
+                 options: %{headers: %{req: [], resp: []}}
                },
                sink: %Sink{uri: ^sink_uri, status: :ok}
              } = conn.private.stow

test/stow/plug/source_test.exs

@@ -16,7 +16,7 @@ defmodule Stow.Plug.SourceTest do
 
     plug(Source,
       uri: "http://localhost/path/to/source?foo=bar",
-      extras: %{
+      options: %{
         headers: %{
           req: [{"accept", "text/html"}, {"accept-charset", "utf-8"}],
           resp: [{"server", "apache/2.4.1 (unix)"}, {"cache-control", "max-age=604800"}]
@@ -60,7 +60,7 @@ defmodule Stow.Plug.SourceTest do
       conn =
         Source.call(conn,
           uri: uri,
-          extras: %{
+          options: %{
             headers: %{
               req: context.req_headers,
               resp: context.resp_headers