@@ -18,6 +18,8 @@ defmodule Env do
1818end 
1919
2020app_name  =  System . get_env ( "APP_NAME" ,  "" ) 
21+ 
22+ # Setup Database 
2123default_db_host  =  System . get_env ( "DB_HOST" ,  "127.0.0.1" ) 
2224username  =  System . get_env ( "DB_USER" ,  "postgres" ) 
2325password  =  System . get_env ( "DB_PASSWORD" ,  "postgres" ) 
@@ -27,6 +29,15 @@ db_version = System.get_env("DB_IP_VERSION")
2729slot_name_suffix  =  System . get_env ( "SLOT_NAME_SUFFIX" ) 
2830db_ssl_enabled?  =  Env . get_boolean ( "DB_SSL" ,  false ) 
2931db_ssl_ca_cert  =  System . get_env ( "DB_SSL_CA_CERT" ) 
32+ queue_target  =  Env . get_integer ( "DB_QUEUE_TARGET" ,  5000 ) 
33+ queue_interval  =  Env . get_integer ( "DB_QUEUE_INTERVAL" ,  5000 ) 
34+ pool_size  =  Env . get_integer ( "DB_POOL_SIZE" ,  5 ) 
35+ 
36+ after_connect_query_args  = 
37+   case  System . get_env ( "DB_AFTER_CONNECT_QUERY" )  do 
38+     nil  ->  nil 
39+     query  ->  { Postgrex ,  :query! ,  [ query ,  [ ] ] } 
40+   end 
3041
3142ssl_opts  = 
3243  cond  do 
@@ -80,6 +91,20 @@ socket_options =
8091      end 
8192  end 
8293
94+ config  :realtime ,  Realtime.Repo , 
95+   hostname:  default_db_host , 
96+   username:  username , 
97+   password:  password , 
98+   database:  database , 
99+   port:  port , 
100+   pool_size:  pool_size , 
101+   queue_target:  queue_target , 
102+   queue_interval:  queue_interval , 
103+   parameters:  [ application_name:  "supabase_mt_realtime" ] , 
104+   after_connect:  after_connect_query_args , 
105+   socket_options:  socket_options , 
106+   ssl:  ssl_opts 
107+ 
83108config  :realtime , 
84109  migration_partition_slots:  migration_partition_slots , 
85110  connect_partition_slots:  connect_partition_slots , 
@@ -275,31 +300,6 @@ if config_env() == :prod do
275300    check_origin:  false , 
276301    secret_key_base:  secret_key_base 
277302
278-   # Setup Database 
279-   queue_target  =  Env . get_integer ( "DB_QUEUE_TARGET" ,  5000 ) 
280-   queue_interval  =  Env . get_integer ( "DB_QUEUE_INTERVAL" ,  5000 ) 
281-   pool_size  =  Env . get_integer ( "DB_POOL_SIZE" ,  5 ) 
282- 
283-   after_connect_query_args  = 
284-     case  System . get_env ( "DB_AFTER_CONNECT_QUERY" )  do 
285-       nil  ->  nil 
286-       query  ->  { Postgrex ,  :query! ,  [ query ,  [ ] ] } 
287-     end 
288- 
289-   config  :realtime ,  Realtime.Repo , 
290-     hostname:  default_db_host , 
291-     username:  username , 
292-     password:  password , 
293-     database:  database , 
294-     port:  port , 
295-     pool_size:  pool_size , 
296-     queue_target:  queue_target , 
297-     queue_interval:  queue_interval , 
298-     parameters:  [ application_name:  "supabase_mt_realtime" ] , 
299-     after_connect:  after_connect_query_args , 
300-     socket_options:  socket_options , 
301-     ssl:  ssl_opts 
302- 
303303  alias  Realtime.Repo.Replica 
304304
305305  replica_repos  =  % { 
0 commit comments