summaryrefslogtreecommitdiff
path: root/src/main/scala/com/tylerstonge/honeypot/reporter/LogReporter.scala
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/scala/com/tylerstonge/honeypot/reporter/LogReporter.scala')
-rw-r--r--src/main/scala/com/tylerstonge/honeypot/reporter/LogReporter.scala20
1 files changed, 20 insertions, 0 deletions
diff --git a/src/main/scala/com/tylerstonge/honeypot/reporter/LogReporter.scala b/src/main/scala/com/tylerstonge/honeypot/reporter/LogReporter.scala
new file mode 100644
index 0000000..9b3f28f
--- /dev/null
+++ b/src/main/scala/com/tylerstonge/honeypot/reporter/LogReporter.scala
@@ -0,0 +1,20 @@
+package com.tylerstonge.honeypot.reporter
+
+import akka.actor.{Actor, Props}
+import akka.event.{Logging, LoggingAdapter}
+import com.tylerstonge.honeypot.messages.{MFoundFile, MFoundPassword, MFoundUsername}
+
+class LogReporter extends Actor {
+
+ val log: LoggingAdapter = Logging(context.system, this)
+
+ context.system.eventStream.subscribe(self, classOf[MFoundUsername])
+ context.system.eventStream.subscribe(self, classOf[MFoundPassword])
+ context.system.eventStream.subscribe(self, classOf[MFoundFile])
+
+ override def receive: Receive = {
+ case msg: MFoundUsername => log.info(">> REPORTER >> :: {}", msg.username)
+ case msg: MFoundPassword => log.info(">> REPORTER >> :: {}", msg.password)
+ case msg: MFoundFile => log.info(">> REPORTER >> :: {}", msg.filename)
+ }
+}