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
- PERSISTENT_NODE =
false
- INDIRECT_NODE =
false
Instance Attribute Summary
Attributes inherited from RJR::Node
#connection_event_handlers, #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
#clear_event_handlers, em, #em, #halt, #indirect?, indirect?, #join, #node_type, #on, persistent?, #persistent?, tp, #tp
Constructor Details
#initialize(args = {}) ⇒ Web
Web initializer
105 106 107 108 109 |
# File 'lib/rjr/nodes/web.rb', line 105 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
154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 |
# File 'lib/rjr/nodes/web.rb', line 154 def invoke(uri, rpc_method, *args) = Messages::Request.new :method => rpc_method, :args => args, :headers => @message_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
136 137 138 139 140 141 |
# File 'lib/rjr/nodes/web.rb', line 136 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
187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 |
# File 'lib/rjr/nodes/web.rb', line 187 def notify(uri, rpc_method, *args) # will block until message is published published_l = Mutex.new published_c = ConditionVariable.new invoked = false = Messages::Notification.new :method => rpc_method, :args => args, :headers => @message_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
118 119 120 121 122 123 124 125 126 127 128 129 130 131 |
# File 'lib/rjr/nodes/web.rb', line 118 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
111 112 113 |
# File 'lib/rjr/nodes/web.rb', line 111 def to_s "RJR::Nodes::Web<#{@node_id},#{@host},#{@port}>" end |