API rework

Author: J0B10

src/main/scala/org/codeoverflow/chatoverflow/requirement/EventInputImpl.scala

@@ -0,0 +1,7 @@
+package org.codeoverflow.chatoverflow.requirement.impl
+
+import java.util.function.Consumer
+
+import org.codeoverflow.chatoverflow.api.io.event.Event
+
+private[impl] case class EventHandler[T <: Event](consumer: Consumer[T], clazz: Class[T])

src/main/scala/org/codeoverflow/chatoverflow/requirement/impl/EventHandler.scala

@@ -0,0 +1,31 @@
+package org.codeoverflow.chatoverflow.requirement.impl
+
+import java.util.function.Consumer
+
+import org.codeoverflow.chatoverflow.api.io.event.Event
+import org.codeoverflow.chatoverflow.api.io.input.event.EventInput
+import org.codeoverflow.chatoverflow.connector.Connector
+
+import scala.collection.mutable.ListBuffer
+import scala.reflect.ClassTag
+
+/**
+  * Default implementation for all inputs that provide events.
+  *
+  * The integrated event registry allows registering new Event handlers at any time.
+  * @tparam T the event interface that all events for this EventInput share
+  * @tparam C the connector to which this input belongs
+  */
+abstract class EventInputImpl[T <: Event, C <: Connector](implicit ctc: ClassTag[C]) extends InputImpl[C] with EventInput[T] {
+
+  protected val handlers: ListBuffer[EventHandler[_ <: T]] = ListBuffer[EventHandler[_ <: T]]()
+
+  override def registerEventHandler[S <: T](eventHandler: Consumer[S], eventClass: Class[S]): Unit = {
+    handlers += EventHandler[S](eventHandler, eventClass)
+  }
+
+  protected def call[S <: T](event: S)(implicit cts: ClassTag[S]): Unit = {
+    handlers.filter(handler => handler.clazz == cts.runtimeClass)
+      .foreach(handler => handler.consumer.asInstanceOf[Consumer[S]].accept(event))
+  }
+}

src/main/scala/org/codeoverflow/chatoverflow/requirement/impl/EventInputImpl.scala

@@ -1,8 +1,9 @@
-package org.codeoverflow.chatoverflow.requirement
+package org.codeoverflow.chatoverflow.requirement.impl
 
 import org.codeoverflow.chatoverflow.WithLogger
 import org.codeoverflow.chatoverflow.api.io.input.Input
 import org.codeoverflow.chatoverflow.connector.Connector
+import org.codeoverflow.chatoverflow.requirement.Connection
 
 import scala.reflect.ClassTag
 

src/main/scala/org/codeoverflow/chatoverflow/requirement/InputImpl.scala renamed to src/main/scala/org/codeoverflow/chatoverflow/requirement/impl/InputImpl.scala

@@ -1,8 +1,9 @@
-package org.codeoverflow.chatoverflow.requirement
+package org.codeoverflow.chatoverflow.requirement.impl
 
 import org.codeoverflow.chatoverflow.WithLogger
 import org.codeoverflow.chatoverflow.api.io.output.Output
 import org.codeoverflow.chatoverflow.connector.Connector
+import org.codeoverflow.chatoverflow.requirement.Connection
 
 import scala.reflect.ClassTag