Added the MOVE command to finagle-redis.

finagle-redis/src/main/scala/com/twitter/finagle/redis/KeyCommands.scala

@@ -64,6 +64,21 @@ trait Keys { self: BaseClient =>
       case EmptyMBulkReply()    => Future.Nil
     }
 
+  /**
+   *  Move key from the currently selected database to the specified destination
+   *  database. When key already exists in the destination database, or it does
+   *  not exist in the source database, it does nothing.
+   *
+   *  @param key, db
+   *  @return true if key was moved.
+   *          false if key was not moved for any reason.
+   *  @see http://redis.io/commands/move
+   */
+   def move(key: ChannelBuffer, db: ChannelBuffer): Future[JBoolean] =
+     doRequest(Move(key,db)) {
+       case IntegerReply(n) => Future.value(n == 1)
+     }
+
   /**
    * Set a key's time to live in milliseconds.
    *

finagle-redis/src/main/scala/com/twitter/finagle/redis/protocol/Command.scala

@@ -20,6 +20,7 @@ object Commands {
   val EXPIRE    = "EXPIRE"
   val EXPIREAT  = "EXPIREAT"
   val KEYS      = "KEYS"
+  val MOVE      = "MOVE"
   val PERSIST   = "PERSIST"
   val PEXPIRE   = "PEXPIRE"
   val PEXPIREAT = "PEXPIREAT"
@@ -140,6 +141,7 @@ object Commands {
     EXPIRE            -> {Expire(_)},
     EXPIREAT          -> {ExpireAt(_)},
     KEYS              -> {Keys(_)},
+    MOVE              -> {Move(_)},
     PERSIST           -> {Persist(_)},
     PEXPIRE           -> {PExpire(_)},
     PEXPIREAT         -> {PExpireAt(_)},
@@ -269,11 +271,13 @@ object Commands {
 }
 
 object CommandBytes {
+  // Key Commands
   val DEL               = StringToChannelBuffer("DEL")
   val EXISTS            = StringToChannelBuffer("EXISTS")
   val EXPIRE            = StringToChannelBuffer("EXPIRE")
   val EXPIREAT          = StringToChannelBuffer("EXPIREAT")
   val KEYS              = StringToChannelBuffer("KEYS")
+  val MOVE              = StringToChannelBuffer("MOVE")
   val PERSIST           = StringToChannelBuffer("PERSIST")
   val PEXPIRE           = StringToChannelBuffer("PEXPIRE")
   val PEXPIREAT         = StringToChannelBuffer("PEXPIREAT")

finagle-redis/src/main/scala/com/twitter/finagle/redis/protocol/commands/Keys.scala

@@ -71,6 +71,20 @@ object Keys {
   def apply(args: Seq[Array[Byte]]) = new Keys(ChannelBuffers.wrappedBuffer(args.head))
 }
 
+case class Move(key: ChannelBuffer, db: ChannelBuffer) extends StrictKeyCommand {
+  def command = Commands.MOVE
+  RequireClientProtocol(db != null && db.readableBytes > 0, "Database must be specified")
+  def toChannelBuffer =
+    RedisCodec.toUnifiedFormat(Seq(CommandBytes.MOVE, key, db))
+}
+object Move {
+  def apply(args: Seq[Array[Byte]]) = {
+    val list = trimList(args, 2, "MOVE")
+    new Move(ChannelBuffers.wrappedBuffer(list(0)),
+      ChannelBuffers.wrappedBuffer(list(1)))
+  }
+}
+
 case class Persist(key: ChannelBuffer) extends StrictKeyCommand {
   def command = Commands.PERSIST
   def toChannelBuffer = RedisCodec.toUnifiedFormat(Seq(CommandBytes.PERSIST, key))

finagle-redis/src/test/scala/com/twitter/finagle/redis/NaggatiSpec.scala

@@ -59,6 +59,11 @@ class NaggatiSpec extends SpecificationWithJUnit {
           "KEYS" >> {
             codec(wrap("KEYS h?llo\r\n")) mustEqual List(Keys("h?llo"))
           }
+          "MOVE" >> {
+            codec(wrap("MOVE\r\n")) must throwA[ClientError]
+            codec(wrap("MOVE boo\r\n")) must throwA[ClientError]
+            codec(wrap("MOVE boo moo \r\n")) mustEqual List(Move(boo, moo))
+          }
           "PERSIST" >> {
             codec(wrap("PERSIST\r\n")) must throwA[ClientError]
             codec(wrap("PERSIST foo\r\n")) mustEqual List(Persist("foo"))