diff options
author | Jakob Odersky <jodersky@gmail.com> | 2014-01-13 17:40:34 +0100 |
---|---|---|
committer | Jakob Odersky <jodersky@gmail.com> | 2014-01-14 15:43:00 +0100 |
commit | 5c94ee017051d51f51e06a61a8bc4e70a15e36da (patch) | |
tree | 2e48701ebb4177557234dbbd22b3b7058cad36de /flow-samples/flow-samples-terminal/src/main/scala | |
parent | 84f640208ed6e4e155e87ebcb73a82c021174ea7 (diff) | |
download | akka-serial-5c94ee017051d51f51e06a61a8bc4e70a15e36da.tar.gz akka-serial-5c94ee017051d51f51e06a61a8bc4e70a15e36da.tar.bz2 akka-serial-5c94ee017051d51f51e06a61a8bc4e70a15e36da.zip |
enable easier cross-compilation
Diffstat (limited to 'flow-samples/flow-samples-terminal/src/main/scala')
3 files changed, 154 insertions, 0 deletions
diff --git a/flow-samples/flow-samples-terminal/src/main/scala/com/github/jodersky/flow/samples/terminal/ConsoleReader.scala b/flow-samples/flow-samples-terminal/src/main/scala/com/github/jodersky/flow/samples/terminal/ConsoleReader.scala new file mode 100644 index 0000000..c4401e7 --- /dev/null +++ b/flow-samples/flow-samples-terminal/src/main/scala/com/github/jodersky/flow/samples/terminal/ConsoleReader.scala @@ -0,0 +1,33 @@ +package com.github.jodersky.flow.samples.terminal + +import akka.actor._ +import java.io.BufferedReader +import java.io.InputStreamReader + +class ConsoleReader extends Actor { + import context._ + import ConsoleReader._ + + def receive = { + case Read => read() match { + case Some(input) => parent ! ConsoleInput(input) + case None => parent ! EOT + } + } + + def read(): Option[String] = { + val eot = 4 + val line = Console.readLine + if (line == ":q") None else Some(line) + } + +} + +object ConsoleReader { + + case object Read + + case object EOT + case class ConsoleInput(in: String) + +}
\ No newline at end of file diff --git a/flow-samples/flow-samples-terminal/src/main/scala/com/github/jodersky/flow/samples/terminal/Main.scala b/flow-samples/flow-samples-terminal/src/main/scala/com/github/jodersky/flow/samples/terminal/Main.scala new file mode 100644 index 0000000..27686ce --- /dev/null +++ b/flow-samples/flow-samples-terminal/src/main/scala/com/github/jodersky/flow/samples/terminal/Main.scala @@ -0,0 +1,34 @@ +package com.github.jodersky.flow +package samples.terminal + +import com.github.jodersky.flow._ +import akka.actor.ActorSystem +import akka.actor.Props +import akka.actor.actorRef2Scala +import akka.util.ByteString + +object Main { + + def ask(label: String, default: String) = { + print(s"${label} [${default}]: ") + val in = Console.readLine() + println("") + if (in.isEmpty) default else in + } + + def main(args: Array[String]): Unit = { + val port = ask("Device", "/dev/ttyACM0") + val baud = ask("Baud rate", "115200").toInt + val cs = ask("Char size", "8").toInt + val tsb = ask("Use two stop bits", "false").toBoolean + val parity = Parity(ask("Parity (0=None, 1=Odd, 2=Even)", "0").toInt) + + val settings = SerialSettings(port, baud, cs, tsb, parity) + + println("Starting terminal system, enter :q to exit.") + internal.InternalSerial.debug(true) + val system = ActorSystem("flow") + val terminal = system.actorOf(Terminal(settings), name = "terminal") + system.registerOnTermination(println("Stopped terminal system.")) + } +}
\ No newline at end of file diff --git a/flow-samples/flow-samples-terminal/src/main/scala/com/github/jodersky/flow/samples/terminal/Terminal.scala b/flow-samples/flow-samples-terminal/src/main/scala/com/github/jodersky/flow/samples/terminal/Terminal.scala new file mode 100644 index 0000000..3c1eee6 --- /dev/null +++ b/flow-samples/flow-samples-terminal/src/main/scala/com/github/jodersky/flow/samples/terminal/Terminal.scala @@ -0,0 +1,87 @@ +package com.github.jodersky.flow.samples.terminal + +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 +import com.github.jodersky.flow.Parity +import akka.actor.Props +import com.github.jodersky.flow.SerialSettings + +class Terminal(settings: SerialSettings) extends Actor with ActorLogging { + import Terminal._ + import context._ + + val reader = actorOf(Props[ConsoleReader]) + + override def preStart() = { + log.info(s"Requesting manager to open port: ${settings.port}, baud: ${settings.baud}") + IO(Serial) ! Serial.Open(settings) + } + + override def postStop() = { + system.shutdown() + } + + def receive = { + case CommandFailed(cmd, reason) => { + log.error(s"Connection failed, stopping terminal. Reason: ${reason}") + context stop self + } + case Opened(s, _) => { + log.info(s"Port ${s.port} is now open.") + val operator = sender + context become opened(operator) + context watch operator + operator ! Register(self) + reader ! ConsoleReader.Read + } + } + + def opened(operator: ActorRef): Receive = { + + case Received(data) => { + log.info(s"Received data: ${formatData(data)}") + } + + case Wrote(data) => log.info(s"Wrote data: ${formatData(data)}") + + case Closed => { + log.info("Operator closed normally, exiting terminal.") + context unwatch operator + context stop self + } + + case Terminated(`operator`) => { + log.error("Operator crashed, exiting terminal.") + context stop self + } + + case ConsoleReader.EOT => { + log.info("Initiating close.") + operator ! Close + } + + case ConsoleReader.ConsoleInput(input) => { + val data = ByteString(input.getBytes) + operator ! Write(data, Wrote(data)) + reader ! ConsoleReader.Read + } + } + + + +} + +object Terminal { + case class Wrote(data: ByteString) extends Event + + def apply(settings: SerialSettings) = Props(classOf[Terminal], settings) + + private def formatData(data: ByteString) = data.mkString("[", ",", "]") + " " + (new String(data.toArray, "UTF-8")) + +}
\ No newline at end of file |