bitcoin-atm

StateWatcher.scala

(1414B)

 package inc.pyc.chimera
 package snippet
 
 import System._
 import akka.actor._
 import FSM._
 
 object StateWatcher {
   val watcher = System.system.actorOf(Props[StateWatcher], "ClientWatcher")
 }
 
 /**
  * Snippet to update the machine's data.
  */
 class DataManager extends ChimeraEventRegister {
   val topic = Topic dataUpdate
 }
 
 /**
  * Snippet to update the machine's state.
  */
 class StateManager extends ChimeraEventRegister {
   val topic = Topic stateUpdate
   
   override val postSubscribe = () => {    
     overlord ! SubscribeTransitionCallBack(StateWatcher.watcher)
   }
 }
 
 /**
  * Message to send to client comet.
  */
 case class StateUpdate(from: Option[String], to: String)
 
 /**
  * Watches the state of Overlord to update
  * the client.
  */
 class StateWatcher extends Actor with ActorLogging {
         
   def receive = {
     case DataReply(data) =>
       sendData(data)
       
     case CurrentState(_, state) =>
       requestData
       sendState(None, state.toString)
       
     case Transition(_, oldState, state) =>
       requestData
       sendState(Some(oldState.toString), state.toString)
   }
   
   def sendState(from: Option[String], to: String) {
     client.updateState(StateUpdate(from, to))
   }
   
   def sendData[T >: Data](data: T) {
     client.updateData(data)
   }
   
   def requestData = overlord ! DataRequest
   
   override def postStop: Unit = {
     overlord ! UnsubscribeTransitionCallBack(self)
   }
 }