summaryrefslogtreecommitdiff
path: root/src/main/scala/com/tylerstonge/honeypot
diff options
context:
space:
mode:
authorTyler St. Onge <tylertstonge@gmail.com>2020-11-11 09:51:54 -0500
committerTyler St. Onge <tylertstonge@gmail.com>2020-11-11 09:51:54 -0500
commit778faf722c88f38597b5d4a59eee0b4eca12bb6f (patch)
treed4034a347efa9f96f6899d79dae5996d2e80f5d9 /src/main/scala/com/tylerstonge/honeypot
parenta7ba75b1b6ca4faa392cb3e5655fc784687e02ac (diff)
allow akka to generate the name of the handler automaticallyHEADmaster
Diffstat (limited to 'src/main/scala/com/tylerstonge/honeypot')
-rw-r--r--src/main/scala/com/tylerstonge/honeypot/ftp/FtpHandler.scala2
-rw-r--r--src/main/scala/com/tylerstonge/honeypot/ftp/FtpListener.scala2
2 files changed, 2 insertions, 2 deletions
diff --git a/src/main/scala/com/tylerstonge/honeypot/ftp/FtpHandler.scala b/src/main/scala/com/tylerstonge/honeypot/ftp/FtpHandler.scala
index 313bf64..187017b 100644
--- a/src/main/scala/com/tylerstonge/honeypot/ftp/FtpHandler.scala
+++ b/src/main/scala/com/tylerstonge/honeypot/ftp/FtpHandler.scala
@@ -40,7 +40,7 @@ class FtpHandler(client: ActorRef) extends Actor {
val r = new Random()
val p1 = r.nextInt(200)
val p2 = r.nextInt(200)
- fileReceiver = context.actorOf(FtpFileReceiver.props(p1 * 256 + p2, client), name = "passive-connection")
+ fileReceiver = context.actorOf(FtpFileReceiver.props(p1 * 256 + p2, client), name = "passive-connection-" + (p1 * 256 + p2))
Thread.sleep(256)
"227 entering passive mode (127,0,0,1," + p1 + "," + p2 + ")\n"
case "stor" =>
diff --git a/src/main/scala/com/tylerstonge/honeypot/ftp/FtpListener.scala b/src/main/scala/com/tylerstonge/honeypot/ftp/FtpListener.scala
index 2f581bd..9e98a39 100644
--- a/src/main/scala/com/tylerstonge/honeypot/ftp/FtpListener.scala
+++ b/src/main/scala/com/tylerstonge/honeypot/ftp/FtpListener.scala
@@ -24,7 +24,7 @@ class FtpListener(port: Int) extends Actor {
case CommandFailed(_: Bind) => context.stop(self)
case Connected(remote, _) =>
val connection = sender()
- val handler = context.actorOf(FtpHandler.props(connection), name = "handler")
+ val handler = context.actorOf(FtpHandler.props(connection))
context.system.eventStream.publish(MNewConnection(remote.getHostString))
connection ! Register(handler)
connection ! Write(ByteString.apply("220 (vulnFTPd 2.0.1)\n"))