added discord reporter

1 files changed, 4 insertions, 2 deletions

diff --git a/src/main/scala/com/tylerstonge/honeypot/ftp/FtpListener.scala b/src/main/scala/com/tylerstonge/honeypot/ftp/FtpListener.scala
index b7ce337..2f581bd 100644
--- a/src/main/scala/com/tylerstonge/honeypot/ftp/FtpListener.scala
+++ b/src/main/scala/com/tylerstonge/honeypot/ftp/FtpListener.scala
@@ -7,6 +7,7 @@ import akka.event.{Logging, LoggingAdapter}
 import akka.io.Tcp._
 import akka.io.{IO, Tcp}
 import akka.util.ByteString
+import com.tylerstonge.honeypot.messages.MNewConnection
 
 object FtpListener {
   def props(port: Int): Props = Props(new FtpListener(port))
@@ -15,15 +16,16 @@ object FtpListener {
 class FtpListener(port: Int) extends Actor {
 
   val log: LoggingAdapter = Logging(context.system, this)
-  IO(Tcp)(context.system) ! Bind(self, new InetSocketAddress("localhost", port))
+  IO(Tcp)(context.system) ! Bind(self, new InetSocketAddress("0.0.0.0", port))
 
   override def receive: Receive = {
     case Bound(localAddress) =>
       log.info("listening on {}", localAddress)
     case CommandFailed(_: Bind) => context.stop(self)
-    case Connected(_, _) =>
+    case Connected(remote, _) =>
       val connection = sender()
       val handler = context.actorOf(FtpHandler.props(connection), name = "handler")
+      context.system.eventStream.publish(MNewConnection(remote.getHostString))
       connection ! Register(handler)
       connection ! Write(ByteString.apply("220 (vulnFTPd 2.0.1)\n"))
   }