added subscription model for reporter actors

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)
+  }
+}