Added ability to use multi and pipelined commands along with corr…

…esponding specs

lib/redis/namespace.rb

@@ -210,6 +210,14 @@ def keys(query = nil)
       query.nil? ? super("*") : super
     end
 
+    def multi(&block)
+      namespaced_block(:multi, &block)
+    end
+
+    def pipelined(&block)
+      namespaced_block(:pipelined, &block)
+    end
+
     def method_missing(command, *args, &block)
       handling = COMMANDS[command.to_s] ||
         COMMANDS[ALIASES[command.to_s]]
@@ -268,6 +276,16 @@ def method_missing(command, *args, &block)
     end
 
   private
+
+    def namespaced_block(command, &block)
+      original = @redis
+      redis.send(command) do |r|
+        @redis = r
+        yield self
+      end
+      @redis = original
+    end
+
     def add_namespace(key)
       return key unless key && @namespace
 

spec/redis_spec.rb

@@ -228,6 +228,24 @@
     @namespaced.keys.sort.should == %w( bar baz foo )
   end
 
+  it "should add namepsace to multi blocks" do
+    @namespaced.mapped_hmset "a_hash", {"foo" => "bar"}
+    @namespaced.multi do |r|
+      r.del "a_hash"
+      r.mapped_hmset "a_hash", {"yin" => "yang"}
+    end
+    @namespaced.hgetall("a_hash").should == {"yin" => "yang"}
+  end
+
+  it "should add namespace to pipelined blocks" do
+    @namespaced.mapped_hmset "a_hash", {"foo" => "bar"}
+    @namespaced.pipelined do |r|
+      r.del "a_hash"
+      r.mapped_hmset "a_hash", {"yin" => "yang"}
+    end
+    @namespaced.hgetall("a_hash").should == {"yin" => "yang"}
+  end
+
   it "can change its namespace" do
     @namespaced['foo'].should == nil
     @namespaced['foo'] = 'chris'