Implement serial and twitch test. Closes codeoverflow-org/chatoverflow#42

Author: Jonas

discordtest/src/main/scala/discordTestPlugin.scala

@@ -1,20 +1,28 @@
 package org.codeoverflow.plugins.testall
 
 import org.codeoverflow.chatoverflow.api.plugin.{PluginImpl, PluginManager}
-import org.codeoverflow.plugins.testall.tests.{discordtest, filetest}
+import org.codeoverflow.plugins.testall.tests.{discordtest, filetest, serialtest, twitchtest}
 
 
 class testallPlugin(manager: PluginManager) extends PluginImpl(manager) {
 
   private val tests: Seq[test] = Seq(
     new discordtest(this,
-      require.input.discordChat("reqDiscordIn", "Discord input", true),
-      require.output.discordChat("reqDiscordOut", "Discord output", true),
-      require.parameter.string("reqDiscordChannel", "The id of the channel to which the bot should connect", true)
+      require.input.discordChat("discordIn", "Discord input", true),
+      require.output.discordChat("discordOut", "Discord output", true),
+      require.parameter.string("discordChannel", "The id of the channel to which the bot should connect", true)
     ),
     new filetest(this,
       require.input.file("fileIn", "File input", true),
       require.output.file("fileOut", "File output", true)
+    ),
+    new serialtest(this,
+      require.input.serial("serialIn", "Serial Port input", true),
+      require.output.serial("serialOut", "Serial Port output", true)
+    ),
+    new twitchtest(this,
+      require.input.twitchChat("twitchIn", "Twitch chat input #skate702", true),
+      require.output.twitchChat("twitchOut", "Twitch chat output #skate702", true)
     )
     //Add more tests here!
   )

testall/src/main/scala/org/codeoverflow/plugins/testall/testallPlugin.scala

@@ -2,7 +2,8 @@ package org.codeoverflow.plugins.testall.tests
 
 import java.awt.Color
 
-import org.codeoverflow.chatoverflow.api.io.dto.chat.discord.{DiscordChatMessage, DiscordEmbed}
+import org.codeoverflow.chatoverflow.api.io.dto.chat.discord.DiscordEmbed
+import org.codeoverflow.chatoverflow.api.io.event.chat.discord.{DiscordChatMessageDeleteEvent, DiscordChatMessageEditEvent, DiscordChatMessageReceiveEvent}
 import org.codeoverflow.chatoverflow.api.io.input.chat.DiscordChatInput
 import org.codeoverflow.chatoverflow.api.io.output.chat.DiscordChatOutput
 import org.codeoverflow.chatoverflow.api.io.parameter.StringParameter
@@ -18,7 +19,7 @@ import scala.collection.JavaConverters._
 class discordtest(val plugin: testallPlugin,
                   val in: Requirement[DiscordChatInput],
                   val out: Requirement[DiscordChatOutput],
-                  val channel: Requirement[StringParameter]) extends test(plugin, in, out) {
+                  val channel: Requirement[StringParameter]) extends test(plugin, in, out, channel) {
 
   override def name: String = "Discord test"
 
@@ -27,9 +28,9 @@ class discordtest(val plugin: testallPlugin,
     out.get.setChannel(channel.get.get)
     println(s"Input connected to channel ${in.get().getChannelId}")
     println(s"Output connected to channel ${out.get().getChannelId}")
-    in.get.registerMessageHandler(onMessage)
-    in.get.registerMessageEditHandler(onMessageEdit)
-    in.get.registerMessageDeleteHandler(onMessageDelete)
+    in.get.registerEventHandler(onMessage, classOf[DiscordChatMessageReceiveEvent])
+    in.get.registerChatMessageEditEventHandler(onMessageEdit)
+    in.get.registerChatMessageDeleteEventHandler(onMessageDelete)
     out.get.sendChatMessage("Hey I'm working! \uD83C\uDF89")
     out.get().sendFile("../config/config.xml")
     out.get().sendFile("allowed_file.png")
@@ -41,8 +42,8 @@ class discordtest(val plugin: testallPlugin,
     log("Started successfully")
   }
 
-  def onMessage(message: DiscordChatMessage): Unit = {
-    if (message.getMessage == "/messages") {
+  def onMessage(event: DiscordChatMessageReceiveEvent): Unit = {
+    if (event.getMessage.getMessage == "/messages") {
       var s = "**Recent messages:**\n"
       s += in.get.getLastMessages(1000*60).asScala.mkString("\n")
       s += "\n\n**Recent private messages:**\n"
@@ -52,12 +53,12 @@ class discordtest(val plugin: testallPlugin,
   }
 
 
-  def onMessageEdit(oldMessage: DiscordChatMessage, newMessage: DiscordChatMessage): Unit = {
-    log("Message #${oldMessage.getId} was edited from '$oldMessage' to '$newMessage'")
+  def onMessageEdit(event: DiscordChatMessageEditEvent): Unit = {
+    log(s"Message #${event.getMessage.getId} was edited from '${event.getOldMessage.getMessage}' to '${event.getMessage.getMessage}'")
   }
 
-  def onMessageDelete(message: DiscordChatMessage): Unit = {
-    log("Message #${message.getId} was deleted  (content: $message)")
+  def onMessageDelete(event: DiscordChatMessageDeleteEvent): Unit = {
+    log(s"Message #${event.getMessage.getId} was deleted  (content: ${event.getMessage.getMessage})")
   }
 
   override def loop(): Unit = {}

testall/src/main/scala/org/codeoverflow/plugins/testall/tests/discordtest.scala

@@ -56,5 +56,5 @@ class filetest(val plugin: testallPlugin, val in: Requirement[FileInput], val ou
 
   override def loop(): Unit = {}
 
-  override def shutdown(): Unit = {}
+  override def shutdown(): Unit = log("Stopped")
 }

testall/src/main/scala/org/codeoverflow/plugins/testall/tests/filetest.scala

@@ -0,0 +1,22 @@
+package org.codeoverflow.plugins.testall.tests
+
+import org.codeoverflow.chatoverflow.api.io.input.SerialInput
+import org.codeoverflow.chatoverflow.api.io.output.SerialOutput
+import org.codeoverflow.chatoverflow.api.plugin.configuration.Requirement
+import org.codeoverflow.plugins.testall.{test, testallPlugin}
+
+class serialtest(val plugin: testallPlugin,
+                 val in: Requirement[SerialInput],
+                 val out: Requirement[SerialOutput]) extends test(plugin, in, out) {
+
+  override def name: String = "Serial Connection test"
+
+  override def setup(): Unit = {
+    in.get().registerDataAvailableEventHandler(e => log(e.getAsString))
+    out.get().getPrintStream.println("#Hello World!")
+  }
+
+  override def loop(): Unit = {}
+
+  override def shutdown(): Unit = log("Stopped")
+}

testall/src/main/scala/org/codeoverflow/plugins/testall/tests/serialtest.scala

@@ -0,0 +1,35 @@
+package org.codeoverflow.plugins.testall.tests
+
+import org.codeoverflow.chatoverflow.api.io.event.chat.twitch.TwitchChatMessageReceiveEvent
+import org.codeoverflow.chatoverflow.api.io.input.chat.TwitchChatInput
+import org.codeoverflow.chatoverflow.api.io.output.chat.TwitchChatOutput
+import org.codeoverflow.chatoverflow.api.plugin.configuration.Requirement
+import org.codeoverflow.plugins.testall.{test, testallPlugin}
+
+class twitchtest(val plugin: testallPlugin,
+                 val in: Requirement[TwitchChatInput],
+                 val out: Requirement[TwitchChatOutput]) extends test(plugin, in, out) {
+
+  override def name: String = "Twitch test"
+
+  override def setup(): Unit = {
+    in.get.setChannel("skate702")
+    out.get.setChannel("skate702")
+    in.get.registerChatMessageReceiveEventHandler(onMessage)
+    out.get.sendChatMessage("Say hi to codeoverflow!")
+  }
+
+  private def onMessage(event: TwitchChatMessageReceiveEvent): Unit = {
+    val msg = event.getMessage
+    if (msg.getMessage.toLowerCase.contains("chatoverflow")) {
+      out.get().sendChatMessage(s"Hi ${msg.getAuthor.getDisplayName}!")
+    }
+  }
+
+  override def loop(): Unit = {
+    in.get.getLastMessages(plugin.getLoopInterval)
+      .forEach(msg => log(s"${msg.getAuthor}: ${msg.getMessage}"))
+  }
+
+  override def shutdown(): Unit = log("Stopped")
+}