path: root/flow-samples/rwc/src/main/scala/com/github/jodersky/flow/example/SerialHandler.scala

package com.github.jodersky.flow.example

import com.github.jodersky.flow.Serial._
import akka.actor.Actor
import akka.actor.ActorLogging
import akka.actor.ActorRef
import akka.util.ByteString
import akka.io.IO
import com.github.jodersky.flow.Serial
import akka.actor.Terminated

class SerialHandler(port: String, baud: Int) extends Actor with ActorLogging {
  import context._

  log.info(s"Requesting manager to open port: ${port}, baud: ${baud}")
  IO(Serial) ! Serial.Open(self, port, baud)

  def receive = {

    case OpenFailed(_, reason) => {
      log.error(s"Connection failed, stopping handler. Reason: ${reason}")
      context stop self
    }

    case Opened(port) => {
      log.info(s"Port ${port} is now open.")
      context become opened(sender)
    }
  }

  def opened(operator: ActorRef): Receive = {
   
    case Received(data) => {
      log.info("Received data: " + formatData(data))
      log.info("As string: " + new String(data.toArray, "UTF-8"))
    }
    case Wrote(data) => log.info("Got ACK for writing data: " + formatData(data))
    case Closed(None) => {
      log.info("Operator closed normally, exiting handler.")
      context stop self
    }
    case Closed(Some(ex)) => {
      log.info("Operator crashed, exiting handler.")
      context stop self
    }
    case "close" => {
      log.info("Initiating close.")
      operator ! Close
    }
    case data: ByteString => operator ! Write(data, true)
  }

  private def formatData(data: ByteString) = data.mkString("[", ",", "]")

}