Merge pull request mDialog#6 from damienlevin/master

Added BrandoException

README.md

@@ -41,6 +41,12 @@ Status replies are returned as case objects, such as `Pong` and `Ok`.
 
       // Response: Some(Ok)
 
+Error replies are returned as `Failure`
+
+      brando ! Request("EXPIRE", "1", "key")
+	  
+	  // Response: Failure(brando.BrandoException: ERR value is not an integer or out of range)
+
 Integer replies are returned as `Option[Int]`. 
 
       brando ! Request("SADD", "some-set", "one", "two")

src/main/scala/Brando.scala

@@ -14,6 +14,9 @@ import annotation.tailrec
 
 import ExecutionContext.Implicits.global
 
+private case class BrandoException(message: String) extends Exception(message) {
+  override lazy val toString = "%s: %s\n".format(getClass.getName, message)
+}
 private case class Connect(address: InetSocketAddress)
 private case class CommandAck(sender: ActorRef) extends Tcp.Event
 private object StartProcess

src/main/scala/ReplyParser.scala

@@ -59,7 +59,7 @@ private[brando] trait ReplyParser {
     buffer.take(length) match {
       case ErrorReply(reply) ⇒
         val remainder = buffer.drop(length)
-        Success(Some(Status.Failure(new Exception(reply.utf8String))), remainder)
+        Success(Some(Status.Failure(new BrandoException(reply.utf8String))), remainder)
       case x ⇒
         Failure(buffer)
     }

src/test/scala/BrandoTest.scala

@@ -221,13 +221,15 @@ class BrandoTest extends TestKit(ActorSystem("BrandoTest")) with FunSpec
 
       expectMsgPF(5.seconds) {
         case Status.Failure(e) ⇒
+          assert(e.isInstanceOf[BrandoException])
           assert(e.getMessage === "ERR wrong number of arguments for 'set' command")
       }
 
       brando ! Request("EXPIRE", "1", "key")
 
       expectMsgPF(5.seconds) {
         case Status.Failure(e) ⇒
+          assert(e.isInstanceOf[BrandoException])
           assert(e.getMessage === "ERR value is not an integer or out of range")
       }
     }