module Daemonizer
  class Engine
    attr_reader :config

    def initialize(config, debug = false)
      @config = config
      GDC.set "#{Process.pid}/monitor"
    end
    
    def start!
      @pm = ProcessManager.new(@config)

      init_block = Proc.new do
        begin
          @pm.start_workers do |process_id|
            @config.handler.worker_id = process_id
            @config.handler.workers_count = @config.workers
            @config.handler.after_fork
            @config.handler.start
          end
        rescue Exception => e
          log_error(e)
        end
      end

      begin
        if @config.cow_friendly
          if GC.respond_to?(:copy_on_write_friendly=)
          	GC.copy_on_write_friendly = true
          	Daemonizer.logger.info "Enabling COW-friendly feature"
          else
          	Daemonizer.logger.info "COW-friendly feature is not supported by currently used ruby version"
          end
        end
        Daemonizer.logger.info "Workers count is #{config.workers}"
        @config.handler.logger = Daemonizer.logger
        @config.handler.prepare(init_block)
      rescue Exception => e
        log_error(e)
      end
      # Start monitoring loop
      
      setup_signals
      @pm.monitor_workers
    end

    def debug!
      Daemonizer.init_console_logger('console')
      @config.handler.logger = Daemonizer.logger
      
      init_block = Proc.new do
        begin
          @config.handler.worker_id = 1
          @config.handler.workers_count = 1
          @config.handler.start
        rescue Exception => e
          log_error(e)
        end
      end

      begin
        @config.handler.prepare(init_block)
      rescue Exception => e
        log_error(e)
      end
    end
    
    def log_error(e)
      Daemonizer.logger.fatal e.to_s
      Daemonizer.logger.fatal "#{e.class}: #{e}\n" + e.backtrace.join("\n")
    end

    private
      def setup_signals
        stop = proc {
          Daemonizer.logger.info "Received a signal... stopping..."
          @pm.start_shutdown!
        }

        trap('TERM', stop)
        trap('INT', stop)
        trap('EXIT', stop)
      end

  end
end