Contents

module Duke
  class Controller
    extend Forwardable
    def_delegators :controller, :start, :stop, :running?, :pid
    attr_reader :dir, :repo_dir, :timeout, :port

    def self.pid_files
      Dir["#{Config.pid_dir}/*.pid"]
    end

    def initialize(repo_dir, port=nil)
      @dir = Dir.pwd
      @repo_dir = repo_dir
      @port = port
      @timeout = 7
    end

    def port
      @port ||= current_port
    end

    def current_port
      repo_dir_regex = /#{repo_dir}\.(\d+)/
      Controller.pid_files.each do |pid_file|
        return $1.to_i if pid_file =~ repo_dir_regex
      end
      nil
    end

    def identifier
      "#{repo_dir}.#{port}"
    end

    def pid_file
      "#{dir}/#{Config.pid_dir}/#{identifier}.pid"
    end

    def log_file
      "#{dir}/#{Config.log_dir}/#{identifier}.log"
    end

    def ping_command
      lambda { TCPSocket.new(Config.host, port) }
    end

    def controller
      @controller ||= DaemonController.new({
        :identifier    => identifier,
        :start_command => "duke cijoed #{repo_dir} #{port} #{log_file} #{pid_file}",
        :ping_command  => ping_command,
        :pid_file      => pid_file,
        :log_file      => log_file,
        :log_file_activity_timeout => timeout,
        :start_timeout => timeout
      })
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
duke-0.1.4	lib/duke/controller.rb
duke-0.1.3	lib/duke/controller.rb
duke-0.1.2	lib/duke/controller.rb
duke-0.1.1	lib/duke/controller.rb
duke-0.1.0	lib/duke/controller.rb