From 14fa23601c560464a19a55e1b4e530b742df301a Mon Sep 17 00:00:00 2001 From: "Tyler St. Onge" Date: Wed, 29 Jul 2020 22:36:47 -0400 Subject: beginning research into accepting files --- src/main/scala/com/tylerstonge/honeypot/ftp/FtpListener.scala | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) (limited to 'src/main/scala/com/tylerstonge/honeypot/ftp/FtpListener.scala') diff --git a/src/main/scala/com/tylerstonge/honeypot/ftp/FtpListener.scala b/src/main/scala/com/tylerstonge/honeypot/ftp/FtpListener.scala index b988ba3..07557bc 100644 --- a/src/main/scala/com/tylerstonge/honeypot/ftp/FtpListener.scala +++ b/src/main/scala/com/tylerstonge/honeypot/ftp/FtpListener.scala @@ -8,7 +8,11 @@ import akka.io.Tcp._ import akka.io.{IO, Tcp} import akka.util.ByteString -class FtpListener (port: Int) extends Actor { +object FtpListener { + def props(port: Int): Props = Props(new FtpListener(port)) +} + +class FtpListener(port: Int) extends Actor { val log: LoggingAdapter = Logging(context.system, this) IO(Tcp)(context.system) ! Bind(self, new InetSocketAddress("localhost", port)) @@ -17,7 +21,7 @@ class FtpListener (port: Int) extends Actor { case Bound(localAddress) => log.info("listening on {}", localAddress) case CommandFailed(_: Bind) => context.stop(self) - case Connected => + case Connected(_, _) => val handler = context.actorOf(Props[FtpHandler]) val connection = sender() connection ! Register(handler) -- cgit v1.1