Contents

# coding: utf-8
# frozen_string_literal: true

module MicroRb
  class HandlerManager
    attr_reader :handlers, :rpc_methods, :endpoints

    def initialize
      @handlers    = []
      @rpc_methods = {}
      @endpoints   = []
    end

    def add_handler(handler)
      validate_handler(handler)
      add_rpc_method(handler)
      add_endpoints(handler)

      handlers << handler.name
    end

    def rpc_method(method)
      rpc_methods[method.to_sym].clone
    end

    def rpc_method?(method)
      rpc_methods.key?(method.to_sym)
    end

    def rpc_method_response(method)
      rpc_method(method).owner::Response.new
    end

    def rpc_method_request(method, params)
      rpc_method(method).owner::Request.new(*params)
    end

    def call_rpc_method(method, params)
      rpc_method(method)
        .call(request: rpc_method_request(method, params),
              response: rpc_method_response(method))
    end

    private

    def validate_handler(handler)
      raise "Handler must be of type MicroRb::Handler got #{handler.class}" unless handler.is_a?(MicroRb::Handler)
      raise "Handler #{handler.name} has already been registered." if handlers.include?(handler.name)
      raise "Handler #{handler.name} is invalid." unless handler.valid?
    end

    def add_rpc_method(handler)
      rpc_methods[handler.full_rpc_name.to_sym] = handler.method(handler.rpc_method)
    end

    def add_endpoints(handler)
      @endpoints << handler.endpoint_structure
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
micro-rb-0.1.0.rc3	lib/micro/handler_manager.rb
micro-rb-0.1.0.rc2	lib/micro/handler_manager.rb