Contents

require 'celluloid/io'
require 'rlyeh/connection'
require 'rlyeh/logger'

module Rlyeh
  class Server
    include Celluloid::IO
    include Rlyeh::Logger

    attr_reader :options, :host, :port
    attr_reader :app_class, :sessions, :server

    def initialize(app_class, options = {})
      @app_class = app_class
      @options = options.dup
      @host = @options.delete(:host) { '127.0.0.1' }
      @port = @options.delete(:port) { 46667 }
      @sessions = {}
      @server = Celluloid::IO::TCPServer.new @host, @port

      info "Rlyeh has emerged on #{@host}:#{@port}"
      async.run
    end

    def finalize
      @server.close
      info 'Rlyeh has sunk...'
    end

    def run
      loop do
        socket = @server.accept
        async.handle_connection socket
      end
    end

    def handle_connection(socket)
      connection = Connection.new(self, socket)
      connection.run
    rescue Exception => e
      crash e
    ensure
      connection.close rescue nil
    end

    def load_session(session_id)
      @sessions[session_id] ||= Rlyeh::Session.new(session_id)
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
rlyeh-0.1.1	lib/rlyeh/server.rb