restructure project and flesh out more commands

1 files changed, 27 insertions, 0 deletions

diff --git a/src/main/scala/com/tylerstonge/honeypot/ftp/FtpHandler.scala b/src/main/scala/com/tylerstonge/honeypot/ftp/FtpHandler.scala
new file mode 100644
index 0000000..8a55396
--- /dev/null
+++ b/src/main/scala/com/tylerstonge/honeypot/ftp/FtpHandler.scala
@@ -0,0 +1,27 @@
+package com.tylerstonge.honeypot.ftp
+
+import akka.actor.Actor
+import akka.event.{Logging, LoggingAdapter}
+import akka.io.Tcp.{PeerClosed, Received, Write}
+import akka.util.ByteString
+
+class FtpHandler extends Actor {
+  val log: LoggingAdapter = Logging(context.system, this)
+
+  override def receive: Receive = {
+    case Received(data) =>
+      log.info(">> {}", data.utf8String)
+      sender() ! Write(ByteString.apply(parse(data.utf8String)))
+    case PeerClosed =>
+      log.info("closing connection")
+      context.stop(self)
+  }
+
+  def parse(msg: String): String = msg match {
+    case "USER anonymous\n" => "331 Please specify password.\n"
+    case "PASS password\n" => "230 Login successful.\n"
+    case "PWD\n" => "257 \"/\" is the current directory\n"
+    case "QUIT\n" => "221 Goodbye.\n"
+    case _ => "200 sure\n"
+  }
+}