blob: e61676361069947b530ae1ca1d905a063362bb50 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
|
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("[", ",", "]")
}
|
