From 14822e95c4e4841e5a5a55e9f58161f15e1645bc Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Jonas=20Bon=C3=A9r?= <jonasremove@jonasboner.com>
Date: Tue, 8 Jun 2010 20:47:12 +0200
Subject: [PATCH] added redis test from debasish

---
 .../scala/RedisInconsistentSizeBugTest.scala  | 74 +++++++++++++++++++
 1 file changed, 74 insertions(+)
 create mode 100644 akka-persistence/akka-persistence-redis/src/test/scala/RedisInconsistentSizeBugTest.scala

diff --git a/akka-persistence/akka-persistence-redis/src/test/scala/RedisInconsistentSizeBugTest.scala b/akka-persistence/akka-persistence-redis/src/test/scala/RedisInconsistentSizeBugTest.scala
new file mode 100644
index 0000000000..22d294c735
--- /dev/null
+++ b/akka-persistence/akka-persistence-redis/src/test/scala/RedisInconsistentSizeBugTest.scala
@@ -0,0 +1,74 @@
+package se.scalablesolutions.akka.persistence.redis
+
+import sbinary._
+import sbinary.Operations._
+import sbinary.DefaultProtocol._
+
+import se.scalablesolutions.akka.actor.{Actor, ActorRef}
+import se.scalablesolutions.akka.config.OneForOneStrategy
+import Actor._
+import se.scalablesolutions.akka.persistence.common.PersistentVector
+import se.scalablesolutions.akka.stm.Transaction.Global._
+import se.scalablesolutions.akka.config.ScalaConfig._
+import se.scalablesolutions.akka.util.Logging
+
+import java.util.{Calendar, Date}
+
+object Serial {
+  implicit object DateFormat extends Format[Date] {
+    def reads(in : Input) = new Date(read[Long](in))
+    def writes(out: Output, value: Date) = write[Long](out, value.getTime)
+  }
+  case class Name(id: Int, name: String, address: String, dateOfBirth: Date, dateDied: Option[Date])
+  implicit val NameFormat: Format[Name] = asProduct5(Name)(Name.unapply(_).get)
+}
+
+case class GETFOO(s: String)
+case class SETFOO(s: String)
+
+object SampleStorage {
+  class RedisSampleStorage extends Actor {
+    self.lifeCycle = Some(LifeCycle(Permanent))    
+    val EVENT_MAP = "akka.sample.map"
+
+    private var eventMap = atomic { RedisStorage.getMap(EVENT_MAP) }
+
+    import sbinary._
+    import DefaultProtocol._
+    import Operations._
+    import Serial._
+    import java.util.Calendar
+
+    val dtb = Calendar.getInstance.getTime
+    val n = Name(100, "debasish ghosh", "kolkata", dtb, Some(dtb))
+
+    def receive = {
+      case SETFOO(str) =>
+        atomic {
+          eventMap += (str.getBytes, toByteArray[Name](n))
+        }
+        self.reply(str)
+
+      case GETFOO(str) =>
+        val ev = atomic {
+          eventMap.keySet.size
+        }
+        println("************* " + ev)
+        self.reply(ev)
+    }
+  }
+}
+
+import Serial._
+import SampleStorage._
+
+object Runner {
+  def run {
+    val proc = actorOf[RedisSampleStorage]
+    proc.start
+    val i: Option[String] = proc !! SETFOO("debasish")
+    println("i = " + i)
+    val ev: Option[Int] = proc !! GETFOO("debasish")
+    println(ev)
+  }
+}