Class: RJR::Nodes::Web
Overview
Web node definition, listen for and invoke json-rpc requests via web requests
Clients should specify the hostname / port when listening for requests and when invoking them.
note the RJR javascript client also supports sending / receiving json-rpc messages over http
Constant Summary collapse
- RJR_NODE_TYPE =
:web
Instance Attribute Summary
Attributes inherited from RJR::Node
#dispatcher, #message_headers, #node_id
Instance Method Summary collapse
-
#initialize(args = {}) ⇒ Web
constructor
Web initializer.
-
#invoke(uri, rpc_method, *args) ⇒ Object
Instructs node to send rpc request, and wait for / return response.
-
#listen ⇒ Object
Instruct Node to start listening for and dispatching rpc requests.
-
#notify(uri, rpc_method, *args) ⇒ Object
Instructs node to send rpc notification (immadiately returns / no response is generated).
-
#send_msg(data, connection) ⇒ Object
Send data using specified http connection.
- #to_s ⇒ Object
Methods inherited from RJR::Node
em, #halt, #join, #node_type, #on, tp
Constructor Details
#initialize(args = {}) ⇒ Web
Web initializer
103 104 105 106 107 |
# File 'lib/rjr/nodes/web.rb', line 103 def initialize(args = {}) super(args) @host = args[:host] @port = args[:port] end |
Instance Method Details
#invoke(uri, rpc_method, *args) ⇒ Object
Instructs node to send rpc request, and wait for / return response
Implementation of RJR::Node#invoke
Do not invoke directly from em event loop or callback as will block the message subscription used to receive responses
152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 |
# File 'lib/rjr/nodes/web.rb', line 152 def invoke(uri, rpc_method, *args) = RequestMessage.new :method => rpc_method, :args => args, :headers => cb = lambda { |http| # TODO handle errors (http.response, http) } @@em.schedule do http = EventMachine::HttpRequest.new(uri).post :body => .to_s, :head => {'content-type' => 'application/json'} http.errback &cb http.callback &cb end # will block until response message is received # TODO optional timeout for response ? result = wait_for_result() if result.size > 2 raise Exception, result[2] end return result[1] end |
#listen ⇒ Object
Instruct Node to start listening for and dispatching rpc requests
Implementation of RJR::Node#listen
134 135 136 137 138 139 |
# File 'lib/rjr/nodes/web.rb', line 134 def listen @@em.schedule do EventMachine::start_server(@host, @port, WebConnection, :rjr_node => self) end self end |
#notify(uri, rpc_method, *args) ⇒ Object
Instructs node to send rpc notification (immadiately returns / no response is generated)
Implementation of RJR::Node#notify
185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 |
# File 'lib/rjr/nodes/web.rb', line 185 def notify(uri, rpc_method, *args) # will block until message is published published_l = Mutex.new published_c = ConditionVariable.new invoked = false = NotificationMessage.new :method => rpc_method, :args => args, :headers => cb = lambda { |arg| published_l.synchronize { invoked = true ; published_c.signal }} @@em.schedule do http = EventMachine::HttpRequest.new(uri).post :body => .to_s, :head => {'content-type' => 'application/json'} http.errback &cb http.callback &cb end published_l.synchronize { published_c.wait published_l unless invoked } nil end |
#send_msg(data, connection) ⇒ Object
Send data using specified http connection
Implementation of RJR::Node#send_msg
116 117 118 119 120 121 122 123 124 125 126 127 128 129 |
# File 'lib/rjr/nodes/web.rb', line 116 def send_msg(data, connection) # we are assuming that since http connections # are not persistant, we should be sending a # response message here @@em.schedule do resp = EventMachine::DelegatedHttpResponse.new(connection) #resp.status = response.result.success ? 200 : 500 resp.status = 200 resp.content = data.to_s resp.content_type "application/json" resp.send_response end end |
#to_s ⇒ Object
109 110 111 |
# File 'lib/rjr/nodes/web.rb', line 109 def to_s "RJR::Nodes::Web<#{@node_id},#{@host},#{@port}>" end |