From 945332ca057383f258c78fd15cbc22f8b8d58a83 Mon Sep 17 00:00:00 2001 From: "Tyler St. Onge" Date: Fri, 24 Jul 2020 14:46:29 -0400 Subject: restructure project and flesh out more commands --- .../com/tylerstonge/honeypot/ftp/FtpListener.scala | 24 +--------------------- 1 file changed, 1 insertion(+), 23 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 460f2f8..3e6606a 100644 --- a/src/main/scala/com/tylerstonge/honeypot/ftp/FtpListener.scala +++ b/src/main/scala/com/tylerstonge/honeypot/ftp/FtpListener.scala @@ -13,7 +13,6 @@ class FtpListener extends Actor { val log: LoggingAdapter = Logging(context.system, this) IO(Tcp)(context.system) ! Bind(self, new InetSocketAddress("localhost", 2121)) - override def receive: Receive = { case Bound(localAddress) => log.info("listening on {}", localAddress) @@ -24,25 +23,4 @@ class FtpListener extends Actor { connection ! Register(handler) connection ! Write(ByteString.apply("220 (vulnFTPd 2.0.1)\n")) } -} - -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 "AUTH SSL" => "500 cmd not recognized\n" - case "USER dropkick" => "200 come on in\n" - case _ => "200 sure\n" - } -} +} \ No newline at end of file -- cgit v1.1