# Have Jetty log to stdout for the time being.
java.lang.System.setProperty("org.eclipse.jetty.util.log.class", 
    "org.eclipse.jetty.util.log.StdErrLog")

module Mizuno
    class HttpServer
        include_class 'org.eclipse.jetty.server.Server'
        include_class 'org.eclipse.jetty.servlet.ServletContextHandler'
        include_class 'org.eclipse.jetty.servlet.ServletHolder'
        include_class 'org.eclipse.jetty.server.nio.SelectChannelConnector'
        include_class 'org.eclipse.jetty.util.thread.QueuedThreadPool'
        include_class 'org.eclipse.jetty.servlet.DefaultServlet'

        #
        # Provide accessors so we can set a custom logger and a location
        # for static assets.
        #
        class << self
            attr_accessor :logger
        end

        #
        # Start up an instance of Jetty, running a Rack application.
        # Options can be any of the follwing, and are not
        # case-sensitive:
        #
        # :host::
        #     String specifying the IP address to bind to; defaults 
        #     to 0.0.0.0.
        #
        # :port::
        #     String or integer with the port to bind to; defaults 
        #     to 9292.
        #
        # FIXME: Clean up options hash (all downcase, all symbols)
        #
        def self.run(app, options = {})
            # The Jetty server
            @server = Server.new

            options = Hash[options.map { |o| 
                [ o[0].to_s.downcase.to_sym, o[1] ] }]

            # Thread pool
            thread_pool = QueuedThreadPool.new
            thread_pool.min_threads = 5
            thread_pool.max_threads = 50
            @server.set_thread_pool(thread_pool)

            # Connector
            connector = SelectChannelConnector.new
            connector.setPort(options[:port].to_i)
            connector.setHost(options[:host])
            @server.addConnector(connector)

            # Servlet context.
            context = ServletContextHandler.new(nil, "/", 
                ServletContextHandler::NO_SESSIONS)

            # The servlet itself.
            rack_servlet = RackServlet.new
            rack_servlet.rackup(app)
            holder = ServletHolder.new(rack_servlet)
            context.addServlet(holder, "/")

            # Add the context to the server and start.
            @server.set_handler(context)
            puts "Listening on #{connector.getHost}:#{connector.getPort}"
            @server.start

            # Stop the server when we get The Signal.
            trap("SIGINT") { @server.stop and exit }

            # Join with the server thread, so that currently open file
            # descriptors don't get closed by accident.
            # http://www.ruby-forum.com/topic/209252
            @server.join unless options[:embedded]
        end

        #
        # Shuts down an embedded Jetty instance.
        #
        def self.stop
            @server.stop
        end
    end
end

# Register ourselves with Rack when this file gets loaded.
Rack::Handler.register 'mizuno', 'Mizuno::HttpServer'