class Eye::Config attr_reader :settings, :applications def initialize(settings = {}, applications = {}) @settings = settings @applications = applications end def merge(other_config) Eye::Config.new(@settings.merge(other_config.settings), @applications.merge(other_config.applications)) end def merge!(other_config) @settings.merge!(other_config.settings) @applications.merge!(other_config.applications) end def to_h {:settings => @settings, :applications => @applications} end # raise an error if config wrong def validate! all_processes = processes # Check blank pid_files no_pid_file = all_processes.select{|c| c[:pid_file].blank? } if no_pid_file.present? raise Eye::Dsl::Error, "blank pid_file for: #{no_pid_file.map{|c| c[:name]} * ', '}" end # Check duplicates of the full pid_file dupl_pids = all_processes.each_with_object(Hash.new(0)) do |o, h| ex_pid_file = Eye::System.normalized_file(o[:pid_file], o[:working_dir]) h[ex_pid_file] += 1 end dupl_pids = dupl_pids.select{|k,v| v>1} if dupl_pids.present? raise Eye::Dsl::Error, "duplicate pid_files: #{dupl_pids.inspect}" end # Check duplicates of the full_name dupl_names = all_processes.each_with_object(Hash.new(0)) do |o, h| full_name = "#{o[:application]}:#{o[:group]}:#{o[:name]}" h[full_name] += 1 end dupl_names = dupl_names.select{|k,v| v>1} if dupl_names.present? raise Eye::Dsl::Error, "duplicate names: #{dupl_names.inspect}" end # validate processes with their own validate all_processes.each do |process_cfg| Eye::Process.validate process_cfg end # just to be sure ENV was not removed ENV[''] rescue raise Eye::Dsl::Error.new("ENV is not a hash '#{ENV.inspect}'") end def processes applications.values.map{|e| (e[:groups] || {}).values.map{|c| (c[:processes] || {}).values} }.flatten end def application_names applications.keys end def delete_app(name) applications.delete(name) end def delete_group(name) applications.each do |app_name, app_cfg| (app_cfg[:groups] || {}).delete(name) end end def delete_process(name) applications.each do |app_name, app_cfg| (app_cfg[:groups] || {}).each do |gr_name, gr_cfg| (gr_cfg[:processes] || {}).delete(name) end end end end