Merge pull request #37 from robertkowalski/put-get

BEP44: put & get

.gitignore

@@ -7,3 +7,4 @@
 /pkg/
 /spec/reports/
 /tmp/
+.DS_Store

.travis.yml

@@ -0,0 +1,9 @@
+language: ruby
+rvm:
+  - ruby
+
+install:
+  - bundle install
+
+script:
+  - bundle exec rspec

README.md

@@ -118,6 +118,20 @@ Sends a single request to a RPC server/worker.
 [Example](https://github.com/bitfinexcom/grenache-ruby-http/blob/master/examples/client.rb).
 
 
+### client.put(data, options)
+
+  - `data`
+    - `:v`: <String> value to store
+  - `options`
+    - `:timeout` Timeout for the request
+
+Puts a value into the DHT.
+
+### client.get(hash)
+  - `hash` <String> Hash of the data to receive
+
+Retrieves a stored value from the DHT via a `hash` <String>.
+
 ### client.listen(key, port, options)
   - `name` <String> Name of the service to announce
   - `port` <Number> Port to listen

examples/client.rb

@@ -1,7 +1,7 @@
 require_relative '../lib/grenache-ruby-http.rb'
 
 
-c = Grenache::Http.new grape_address: "http://127.0.0.1:40002/"
+c = Grenache::Http.new grape_address: "http://127.0.0.1:30001/"
 
 start_time = Time.now
 

examples/put_get.rb

@@ -0,0 +1,18 @@
+require_relative '../lib/grenache-ruby-http.rb'
+
+c = Grenache::Http.new grape_address: "http://127.0.0.1:30001/"
+
+err,res_hash = c.put({ "v" => "pineapple test" })
+if !err
+
+  puts "response, hash is: #{res_hash}"
+else
+  puts err
+end
+
+err,resp = c.get(res_hash)
+if !err
+  puts "response of #{res_hash}: #{resp}"
+else
+  puts err
+end

examples/worker.rb

@@ -11,7 +11,7 @@
   Signal.trap("INT")  { EventMachine.stop }
   Signal.trap("TERM") { EventMachine.stop }
 
-  c = Grenache::Http.new grape_address: "http://127.0.0.1:40002/"
+  c = Grenache::Http.new grape_address: "http://127.0.0.1:30001/"
 
   c.listen('rpc_test', 5004) do |msg|
     #[StandardError.new("Error!"),"hello #{msg.payload}"]

grenache-ruby-http.gemspec

@@ -23,4 +23,5 @@ Gem::Specification.new do |spec|
   spec.add_runtime_dependency "oj", "~> 2.18"
   spec.add_runtime_dependency "thin", "~> 1.7"
 
+  spec.add_development_dependency "rspec", "~> 3.5.0"
 end

lib/grenache/http.rb

@@ -71,6 +71,20 @@ def request(key, payload, params={})
       return [e, nil]
     end
 
+    def put(payload, params={})
+      resp = link.send('put', payload, params)
+      return [nil, resp]
+    rescue Exception => e
+      return [e, nil]
+    end
+
+    def get(t_hash, params={})
+      resp = link.send('get', t_hash, params)
+      return [nil, Oj.dump(resp)]
+    rescue Exception => e
+      return [e, nil]
+    end
+
     private
 
     def tls?