Sha256: d64218bea7d21d8de5c58ef51fd633d752fd6550667062875ab5c4710c79251a
Contents?: true
Size: 1.8 KB
Versions: 7
Compression:
Stored size: 1.8 KB
Contents
module Souls
class Sync < Thor
desc "conf", "Sync config/souls.rb Endpoint with Google Cloud Run"
def conf
update_conf
update_conf(strain: "api")
end
private
def update_conf(strain: "mother")
require("#{Souls.get_mother_path}/config/souls")
workers = Souls.configuration.workers
Dir.chdir(Souls.get_mother_path.to_s) do
file_path = strain == "mother" ? "config/souls.rb" : "apps/api/config/souls.rb"
new_file_path = "souls.rb"
worker_switch = false
File.open(new_file_path, "w") do |new_line|
File.open(file_path, "r") do |f|
f.each_line do |line|
worker_switch = true if line.include?("config.workers")
next if line.strip == "end"
new_line.write(line) unless worker_switch
next unless worker_switch
new_line.write(" config.workers = [\n")
workers.each_with_index do |worker, i|
base_url = Souls::Gcloud::Run.new.get_endpoint(worker_name: worker[:name])
endpoint = Souls.configuration.endpoint
if (i + 1) == workers.size
new_line.write(<<-TEXT)
{
name: "#{worker[:name]}",
endpoint: "#{base_url.strip}#{endpoint}",
port: #{worker[:port]}
}
TEXT
else
new_line.write(<<-TEXT)
{
name: "#{worker[:name]}",
endpoint: "#{base_url.strip}#{endpoint}",
port: #{worker[:port]}
},
TEXT
end
end
break
end
end
new_line.write(<<~TEXT)
]
end
TEXT
end
FileUtils.rm(file_path)
FileUtils.mv(new_file_path, file_path)
end
end
end
end
Version data entries
7 entries across 7 versions & 1 rubygems