feat: add region and instance id to logger

VERSION

@@ -1 +1 @@
-0.2.21
+0.2.22

config/config.exs

@@ -22,7 +22,7 @@ config :supavisor, SupavisorWeb.Endpoint,
 # Configures Elixir's Logger
 config :logger, :console,
   format: "$time $metadata[$level] $message\n",
-  metadata: [:request_id, :project, :user]
+  metadata: [:request_id, :project, :user, :region, :instance_id]
 
 # Use Jason for JSON parsing in Phoenix
 config :phoenix, :json_library, Jason

lib/supavisor/application.ex

@@ -9,6 +9,17 @@ defmodule Supavisor.Application do
 
   @impl true
   def start(_type, _args) do
+    primary_config = :logger.get_primary_config()
+
+    :ok =
+      :logger.set_primary_config(
+        :metadata,
+        Enum.into(
+          [region: System.get_env("REGION"), instance_id: System.get_env("INSTANCE_ID")],
+          primary_config.metadata
+        )
+      )
+
     :ok =
       :gen_event.swap_sup_handler(
         :erl_signal_server,

lib/supavisor/client_handler.ex

@@ -107,6 +107,7 @@ defmodule Supavisor.ClientHandler do
     hello = decode_startup_packet(bin)
     Logger.debug("Client startup message: #{inspect(hello)}")
     {user, external_id} = parse_user_info(hello.payload["user"])
+
     Logger.metadata(project: external_id, user: user)
 
     sni_hostname = try_get_sni(sock)

lib/supavisor/db_handler.ex

@@ -30,6 +30,7 @@
   @impl true
   def init(args) do
     Process.flag(:trap_exit, true)
+
     Logger.metadata(project: args.tenant, user: args.user_alias)
 
     data = %{
@@ -74,7 +75,7 @@
         case try_ssl_handshake({:gen_tcp, sock}, auth) do
           {:ok, sock} ->
             # TODO: fix user name
             case send_startup(sock, auth) do
               :ok ->
                 :ok = activate(sock)
                 {:next_state, :authentication, %{data | sock: sock}}

lib/supavisor/manager.ex

@@ -46,6 +46,7 @@ defmodule Supavisor.Manager do
     }
 
     Logger.metadata(project: args.tenant, user: args.user_alias)
+
     Registry.register(Supavisor.Registry.ManagerTables, {args.tenant, args.user_alias}, tid)
 
     {:ok, state}