Contents

# The server will be used to make incomming connections possible. The server
# handles the low level networking functions, so that the services don't have
# to deal with them. Because of the way eventmachine works you can have as many
# servers as you want.
#
# @example a server which is available througth 3 connections:
#   EM.run {
#     EM.start_server "localhost", 8000, MarilynRPC::Server
#     EM.start_server "localhost", 8008, MarilynRPC::Server, :secure => true
#     EM.start_unix_domain_server("tmp.socket", MarilynRPC::Server)
#   }
#
module MarilynRPC::Server
  # initalize the server with connection options
  # @param [Hash] options the options passed to the server
  # @option options [Boolean] :secure enable secure transfer for the server
  #   possible values `true` or `false`
  def initialize(options = {})
    @secure = options[:secure]
  end
  
  # Initialize the first recieving envelope for the connection and create the
  # service cache since each connection gets it's own service instance.
  def post_init
    @envelope = MarilynRPC::Envelope.new
    @cache = MarilynRPC::ServiceCache.new
    start_tls if @secure
  end
  
  # Handler for the incoming data. EventMachine compatible.
  # @param [String] data the data that should be parsed into envelopes
  def receive_data(data)
    overhang = @envelope.parse!(data)
    
    # was massage parsed successfully?
    if @envelope.finished?
      # grep the request
      answer = @cache.call(@envelope)
      if answer.is_a? String
        send_data(answer)
      else
        answer.connection = self # pass connection for async responses
      end
      
      # initialize the next envelope
      @envelope.reset!
      receive_data(overhang) if overhang # reenter the data loop
    end
  end
  
  # Handler for client disconnect
  def unbind
    @cache.disconnect!
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
marilyn-rpc-0.0.4	lib/marilyn-rpc/server.rb