renamed Redis test from *Test to *Spec + removed requirement to link Actor only after start + refactored Chat sample to use mixin composition of Actor

akka-persistence-redis/src/test/scala/RedisPersistentActorTest.scala

@@ -1,156 +0,0 @@
-package se.scalablesolutions.akka.state
-
-import junit.framework.TestCase
-
-import org.junit.{Test, Before}
-import org.junit.Assert._
-
-import se.scalablesolutions.akka.actor.Transactor
-
-/**
- * A persistent actor based on Redis storage.
- * <p/>
- * Demonstrates a bank account operation consisting of messages that:
- * <li>checks balance <tt>Balance</tt></li>
- * <li>debits amount<tt>Debit</tt></li>
- * <li>debits multiple amounts<tt>MultiDebit</tt></li>
- * <li>credits amount<tt>Credit</tt></li>
- * <p/>
- * Needs a running Redis server.
- * @author <a href="http://debasishg.blogspot.com">Debasish Ghosh</a>
- */
-
-case class Balance(accountNo: String)
-case class Debit(accountNo: String, amount: BigInt, failer: Actor)
-case class MultiDebit(accountNo: String, amounts: List[BigInt], failer: Actor)
-case class Credit(accountNo: String, amount: BigInt)
-case object LogSize
-
-class AccountActor extends Transactor {
-  private val accountState = RedisStorage.newMap
-  private val txnLog = RedisStorage.newVector
-
-  def receive = {
-    // check balance
-    case Balance(accountNo) =>
-      txnLog.add("Balance:%s".format(accountNo).getBytes)
-      reply(BigInt(new String(accountState.get(accountNo.getBytes).get)))
-
-    // debit amount: can fail
-    case Debit(accountNo, amount, failer) =>
-      txnLog.add("Debit:%s %s".format(accountNo, amount.toString).getBytes)
-
-      val m: BigInt =
-      accountState.get(accountNo.getBytes) match {
-        case Some(bytes) => BigInt(new String(bytes))
-        case None => 0
-      }
-      accountState.put(accountNo.getBytes, (m - amount).toString.getBytes)
-      if (amount > m)
-        failer !! "Failure"
-      reply(m - amount)
-
-    // many debits: can fail
-    // demonstrates true rollback even if multiple puts have been done
-    case MultiDebit(accountNo, amounts, failer) =>
-      txnLog.add("MultiDebit:%s %s".format(accountNo, amounts.map(_.intValue).foldLeft(0)(_ + _).toString).getBytes)
-
-      val m: BigInt =
-      accountState.get(accountNo.getBytes) match {
-        case Some(bytes) => BigInt(new String(bytes))
-        case None => 0
-      }
-      var bal: BigInt = 0
-      amounts.foreach {amount =>
-        bal = bal + amount
-        accountState.put(accountNo.getBytes, (m - bal).toString.getBytes)
-      }
-      if (bal > m) failer !! "Failure"
-      reply(m - bal)
-
-    // credit amount
-    case Credit(accountNo, amount) =>
-      txnLog.add("Credit:%s %s".format(accountNo, amount.toString).getBytes)
-
-      val m: BigInt =
-      accountState.get(accountNo.getBytes) match {
-        case Some(bytes) => BigInt(new String(bytes))
-        case None => 0
-      }
-      accountState.put(accountNo.getBytes, (m + amount).toString.getBytes)
-      reply(m + amount)
-
-    case LogSize =>
-      reply(txnLog.length.asInstanceOf[AnyRef])
-  }
-}
-
-@serializable class PersistentFailerActor extends Actor {
-  makeTransactionRequired
-  def receive = {
-    case "Failure" =>
-      throw new RuntimeException("expected")
-  }
-}
-
-class RedisPersistentActorTest extends TestCase {
-  @Test
-  def testSuccessfulDebit = {
-    val bactor = new AccountActor
-    bactor.start
-    val failer = new PersistentFailerActor
-    failer.start
-    bactor !! Credit("a-123", 5000)
-    bactor !! Debit("a-123", 3000, failer)
-    assertEquals(BigInt(2000), (bactor !! Balance("a-123")).get)
-
-    bactor !! Credit("a-123", 7000)
-    assertEquals(BigInt(9000), (bactor !! Balance("a-123")).get)
-
-    bactor !! Debit("a-123", 8000, failer)
-    assertEquals(BigInt(1000), (bactor !! Balance("a-123")).get)
-
-    assertEquals(7, (bactor !! LogSize).get)
-  }
-
-  @Test
-  def testUnsuccessfulDebit = {
-    val bactor = new AccountActor
-    bactor.start
-    bactor !! Credit("a-123", 5000)
-    assertEquals(BigInt(5000), (bactor !! Balance("a-123")).get)
-
-    val failer = new PersistentFailerActor
-    failer.start
-    try {
-      bactor !! Debit("a-123", 7000, failer)
-      fail("should throw exception")
-    } catch { case e: RuntimeException => {}}
-
-    assertEquals(BigInt(5000), (bactor !! Balance("a-123")).get)
-
-    // should not count the failed one
-    assertEquals(3, (bactor !! LogSize).get)
-  }
-
-  @Test
-  def testUnsuccessfulMultiDebit = {
-    val bactor = new AccountActor
-    bactor.start
-    bactor !! Credit("a-123", 5000)
-
-    assertEquals(BigInt(5000), (bactor !! Balance("a-123")).get)
-
-    val failer = new PersistentFailerActor
-    failer.start
-    try {
-      bactor !! MultiDebit("a-123", List(500, 2000, 1000, 3000), failer)
-      fail("should throw exception")
-    } catch { case e: RuntimeException => {}}
-
-    assertEquals(BigInt(5000), (bactor !! Balance("a-123")).get)
-
-    // should not count the failed one
-    assertEquals(3, (bactor !! LogSize).get)
-  }
-}