File-based token loader strategy is coming together

.gitignore

@@ -27,4 +27,6 @@ srh-*.tar
 
 .idea/
 
-*.iml
+*.iml
+
+srh-config/

config/config.exs

@@ -0,0 +1,8 @@
+import Config
+
+config :srh,
+       mode: "file",
+       file_path: "srh-config/tokens.json",
+       file_hard_reload: false
+
+import_config "#{config_env()}.exs"

config/dev.exs

@@ -0,0 +1,4 @@
+import Config
+
+config :srh,
+       file_hard_reload: true

config/runtime.exs

@@ -0,0 +1,5 @@
+import Config
+
+config :srh,
+       mode: System.get_env("TOKEN_RESOLUTION_MODE") || "file",
+       file_path: System.get_env("TOKEN_RESOLUTION_FILE_PATH") || "srh-config/tokens.json"

lib/srh/auth/token_resolver.ex

@@ -1,9 +1,38 @@
 defmodule Srh.Auth.TokenResolver do
+  @mode Application.fetch_env!(:srh, :mode)
+  @file_path Application.fetch_env!(:srh, :file_path)
+  @file_hard_reload Application.fetch_env!(:srh, :file_hard_reload)
+
+  @config_file_data nil
+
   def resolve(token) do
+    IO.puts("Resolving token: #{token}")
+
+    do_resolve(@mode, token)
+  end
+
+  defp do_resolve("file", token) do
+    #    if @config_file_data == nil || @file_hard_reload do
+    #      @config_file_data = Jason.decode!(File.read!(@file_path))
+    #      IO.puts("Reloaded config file from disk. #{Jason.encode!(@config_file_data)}")
+    #    end
+
+    config_file_data = Jason.decode!(File.read!(@file_path))
+    IO.puts("Reloaded config file from disk. #{Jason.encode!(config_file_data)}")
+
+    case Map.get(config_file_data, token) do
+      nil ->
+        {:error, "Invalid token"}
+      connection_info ->
+        {:ok, connection_info}
+    end
+  end
+
+  defp do_resolve("redis", token) do
     {
       :ok,
+      # This is done to replicate what will eventually be API endpoints, so they keys are not atoms
       Jason.decode!(
-        # This is done to replicate what will eventually be API endpoints, so they keys are not atoms
         Jason.encode!(
           %{
             srh_id: "1000",

lib/srh/http/base_router.ex

@@ -34,6 +34,7 @@ defmodule Srh.Http.BaseRouter do
         {:ok, data} -> %{code: 200, message: Jason.encode!(data)}
         {:not_found, message} -> %{code: 404, message: message}
         {:malformed_data, message} -> %{code: 400, message: message}
+        {:not_authorized, message} -> %{code: 401, message: message}
         {:server_error, _} -> %{code: 500, message: "An error occurred internally"}
       end
 

lib/srh/http/command_handler.ex

@@ -18,7 +18,7 @@ defmodule Srh.Http.CommandHandler do
     case TokenResolver.resolve(token) do
       {:ok, connection_info} ->
         dispatch_command(command_array, connection_info)
-      {:error, _} -> {:error, "Invalid token"}
+      {:error, msg} -> {:not_authorized, msg}
     end
   end
 

mix.exs

@@ -7,6 +7,7 @@ defmodule Srh.MixProject do
       version: "0.1.0",
       elixir: "~> 1.13",
       start_permanent: Mix.env() == :prod,
+      config_path: "config/config.exs",
       deps: deps()
     ]
   end