system : set

lib/register/system.rb

@@ -33,13 +33,17 @@ def self.put_system(redis)
         '_id' => 'system',
         '_rev' => '0',
 
-        'put' => proc { |args|
-          item = args
-          #lock(item['_id']) do
-            # TODO
-          #end
+        'set' => proc { |args|
+          @redis.set(args['key'], Rufus::Json.encode(args['value']))
         }.to_source,
 
+        #'put' => proc { |args|
+        #  item = args
+        #  lock(item['_id']) do
+        #    # TODO
+        #  end
+        #}.to_source,
+
         'echo' => proc { |args|
           args.collect { |a| a.to_s }.join(' ')
         }.to_source

lib/register/worker.rb

@@ -48,7 +48,7 @@ def run
       @running = true
 
       loop do
-        break if @running = false
+        break if @running == false
         step
       end
     end

spec/system_spec.rb

@@ -24,5 +24,18 @@
       cl.result(ticket).should == [ true, 'hello world' ]
     end
   end
+
+  describe "'set'" do
+
+    it 'sets a value' do
+
+      ticket = cl.call('system', 'set', 'key' => 'x', 'value' => %w[ y z ])
+
+      wo.send(:step)
+
+      cl.result(ticket).should == [ true, 'OK' ]
+      @r.get('x').should == Rufus::Json.encode(%w[ y z ])
+    end
+  end
 end
 

spec/worker_spec.rb

@@ -22,14 +22,11 @@
 
   describe '#step' do
 
-    it 'returns after 1 second when there are no calls' do
-
-      t = Time.now
-
-      wo.send(:step)
-
-      (Time.now - t).should > 1.0
-    end
+    #it 'returns after 1 second when there are no calls' do
+    #  t = Time.now
+    #  wo.send(:step)
+    #  (Time.now - t).should > 1.0
+    #end
 
     it 'process calls' do