Add database primary replica configuration for sidekiqs

Author: praveendhawan

libraries/drivers_worker_sidekiq.rb

@@ -133,6 +133,11 @@ def add_replica_config
         Chef::Log.info('Rewrite Sidekiq database.yml for read-replica')
 
         deploy = node['deploy'][app['shortname']]
+        database = deploy['database']
+        replica_database = deploy['sidekiq_on_replica']&.dup
+        replica_database = database.dup if replica_database.nil?
+        replica_database[:replica] = true
+
         Chef::Log.info(deploy.inspect)
         context.template "#{deploy_dir(app)}/shared/config/database.yml" do
           source 'sidekiq_database.yml.erb'
@@ -141,9 +146,9 @@ def add_replica_config
           group node['deployer']['group']
           owner node['deployer']['user']
           variables(
-            database: deploy['database'],
+            database: database,
             environment: deploy['global']['environment'],
-            sidekiq_on_replica: deploy['sidekiq_on_replica']
+            sidekiq_on_replica: replica_database,
           )
         end
       end

sidekiq_custom/templates/default/sidekiq_database.yml.erb

@@ -1,20 +1,21 @@
 <% (['development', 'production'] + [@environment]).uniq.each do |env| -%>
 <%= env %>:
-  database: <%= @database[:database].to_s.inspect %>
-  encoding: <%= (@database[:encoding] || 'utf8').to_s.inspect %>
-  adapter: <%= @database[:adapter].to_s.inspect %>
-  host: <%= (@database[:host] || 'localhost').to_s.inspect %>
-  username: <%= @database[:username].to_s.inspect %>
-  password: <%= @database[:password].to_s.inspect %>
-  reconnect: <%= @database[:reconnect] ? 'true' : 'false' %>
-  <%- if @database[:pool] -%>
-  pool: <%= @database[:pool].to_i.inspect %>
-  <%- end -%>
-  <%- if @database[:port] -%>
-  port: <%= @database[:port].to_i.inspect %>
-  <%- end -%>
+  primary:
+    database: <%= @database[:database].to_s.inspect %>
+    encoding: <%= (@database[:encoding] || 'utf8').to_s.inspect %>
+    adapter: <%= @database[:adapter].to_s.inspect %>
+    host: <%= (@database[:host] || 'localhost').to_s.inspect %>
+    username: <%= @database[:username].to_s.inspect %>
+    password: <%= @database[:password].to_s.inspect %>
+    reconnect: <%= @database[:reconnect] ? 'true' : 'false' %>
+    <%- if @database[:pool] -%>
+    pool: <%= @database[:pool].to_i.inspect %>
+    <%- end -%>
+    <%- if @database[:port] -%>
+    port: <%= @database[:port].to_i.inspect %>
+    <%- end -%>
   <%- if @sidekiq_on_replica.present? -%>
-  replica:
+  primary_replica:
     host: <%= (@sidekiq_on_replica[:host] || 'localhost').to_s.inspect %>
     username: <%= @sidekiq_on_replica[:username].to_s.inspect %>
     password: <%= @sidekiq_on_replica[:password].to_s.inspect %>
@@ -24,5 +25,8 @@
     <%- if @sidekiq_on_replica[:port] -%>
     port: <%= @sidekiq_on_replica[:port].to_i.inspect %>
     <%- end -%>
+    <%- if @sidekiq_on_replica[:replica] -%>
+    replica: true
+    <%- end -%>
   <% end -%>
 <%- end -%>