class Unrestful::RpcController

Attributes

async[R]
job[R]
live[R]
method[R]
request[R]
response[R]
service[R]

Protected Class Methods

after_method(method, options = {}) click to toggle source
# File lib/unrestful/rpc_controller.rb, line 43
def self.after_method(method, options = {})
  self.after_method_callbacks = {method => options}
end
async(async_list) click to toggle source
# File lib/unrestful/rpc_controller.rb, line 55
def self.async(async_list)
  self.async_methods = async_list
end
before_method(method, options = {}) click to toggle source
# File lib/unrestful/rpc_controller.rb, line 39
def self.before_method(method, options = {})
  self.before_method_callbacks = {method => options}
end
live(live_list) click to toggle source
# File lib/unrestful/rpc_controller.rb, line 51
def self.live(live_list)
  self.live_methods = live_list
end
scopes(scope_list) click to toggle source
# File lib/unrestful/rpc_controller.rb, line 47
def self.scopes(scope_list)
  self.assigned_scopes = ActiveSupport::HashWithIndifferentAccess.new(scope_list)
end

Public Instance Methods

after_callbacks() click to toggle source
# File lib/unrestful/rpc_controller.rb, line 25
def after_callbacks
  self.class.after_method_callbacks.each do |k, v|
    self.send(k)
  end
end
before_callbacks() click to toggle source
# File lib/unrestful/rpc_controller.rb, line 18
def before_callbacks
  self.class.before_method_callbacks.each do |k, v|
    # no checks for now
    self.send(k)
  end
end
write(message) click to toggle source
# File lib/unrestful/rpc_controller.rb, line 31
def write(message)
  raise NotLiveError unless live
  msg = message.end_with?("\n") ? message : "#{message}\n"
  response.stream.write msg
end

Protected Instance Methods

fail!(message = "") click to toggle source
# File lib/unrestful/rpc_controller.rb, line 59
def fail!(message = "")
  raise ::Unrestful::FailError, message
end