Module: DDP::Server::Protocol::RPC

Included in:
DDP::Server::Protocol
Defined in:
lib/ddp/server/protocol/rpc.rb

Overview

Protocol regarding remote procedure calls

Constant Summary collapse

NO_RESULT = 
Object.new

Instance Method Summary collapse

Instance Method Details

#handle_method(id, method, params) ⇒ Object 



18
19
20
21
22
23
24
 
# File 'lib/ddp/server/protocol/rpc.rb', line 18

def handle_method(id, method, params)
  params ||= []
  result = api.invoke_rpc(method, *params)
  send_result(id, result)
rescue => e
  send_error_result(id, e)
end

#handle_rpc ⇒ Object 



8
9
10
11
12
13
14
15
16
 
# File 'lib/ddp/server/protocol/rpc.rb', line 8

def handle_rpc
  case @message['msg']
  when 'method'
    handle_method(@message['id'], @message['method'], @message['params'])
    true
  else
    false
  end
end

#send_error_result(id, error) ⇒ Object 



32
33
34
35
36
37
38
39
40
 
# File 'lib/ddp/server/protocol/rpc.rb', line 32

def send_error_result(id, error)
  message = { msg: 'result', id: id }
  message['error'] = {
    error: error.class.name,
    reason: error.message,
    details: "Backtrace: \n#{error.backtrace.join("\n")}"
  }
  write_message(message)
end

#send_result(id, result = NO_RESULT) ⇒ Object 



26
27
28
29
30
 
# File 'lib/ddp/server/protocol/rpc.rb', line 26

def send_result(id, result = NO_RESULT)
  message = { msg: 'result', id: id }
  message['result'] = result unless result == NO_RESULT
  write_message(message)
end

#send_updated(methods) ⇒ Object 



42
43
44
 
# File 'lib/ddp/server/protocol/rpc.rb', line 42

def send_updated(methods)
  write_message msg: 'updated', methods: methods
end