SSL support

lib/srh/http/base_router.ex

@@ -26,7 +26,10 @@ defmodule Srh.Http.BaseRouter do
   end
 
   match _ do
-    handle_response({:not_found, "SRH: Endpoint not found. SRH might not support this feature yet."}, conn)
+    handle_response(
+      {:not_found, "SRH: Endpoint not found. SRH might not support this feature yet."},
+      conn
+    )
   end
 
   defp do_command_request(conn, success_lambda) do

lib/srh/http/content_type_check_plug.ex

@@ -35,7 +35,10 @@ defmodule Srh.Http.ContentTypeCheckPlug do
         # Return a custom error, ensuring the same format as the other errors
         conn
         |> put_resp_content_type("application/json")
-        |> send_resp(400, Jason.encode!(%{error: "Invalid content type. Expected application/json."}))
+        |> send_resp(
+          400,
+          Jason.encode!(%{error: "Invalid content type. Expected application/json."})
+        )
         |> halt()
     end
   end

lib/srh/redis/client.ex

@@ -3,7 +3,7 @@ defmodule Srh.Redis.Client do
   alias Srh.Redis.ClientRegistry
   alias Srh.Redis.ClientWorker
 
-  @idle_death_time 1000 * 15
+  @idle_death_time 1000 * 60 * 15 # 15 minutes
 
   def start_link(max_connections, connection_info) do
     GenServer.start_link(__MODULE__, {max_connections, connection_info}, [])

lib/srh/redis/client_worker.ex

@@ -62,9 +62,29 @@ defmodule Srh.Redis.ClientWorker do
         } = state
       )
       when is_binary(connection_string) do
+    enable_ssl = String.starts_with?(connection_string, "rediss://")
+
+    socket_opts =
+      case enable_ssl do
+        true ->
+          [
+            customize_hostname_check: [
+              match_fun: :public_key.pkix_verify_hostname_match_fun(:https)
+            ]
+          ]
+
+        false ->
+          []
+      end
+
     # NOTE: Redix only seems to open the connection when the first command is sent
     # This means that this will return :ok even if the connection string may not actually be connectable
-    {:ok, pid} = Redix.start_link(connection_string)
+    {:ok, pid} =
+      Redix.start_link(connection_string,
+        ssl: enable_ssl,
+        socket_opts: socket_opts
+      )
+
     {:noreply, %{state | redix_pid: pid}}
   end