Add host events to the api and to tipeeestream

Author: hlxid

src/main/scala/org/codeoverflow/chatoverflow/requirement/service/tipeeestream/TipeeestreamConnector.scala

@@ -96,4 +96,5 @@ object TipeeestreamConnector {
   private[tipeeestream] case class FollowEventJSON(json: JSONObject) extends TipeeestreamEventJSON(json)
   private[tipeeestream] case class CheerEventJSON(json: JSONObject) extends TipeeestreamEventJSON(json)
   private[tipeeestream] case class RaidEventJSON(json: JSONObject) extends TipeeestreamEventJSON(json)
+  private[tipeeestream] case class HostEventJSON(json: JSONObject) extends TipeeestreamEventJSON(json)
 }

src/main/scala/org/codeoverflow/chatoverflow/requirement/service/tipeeestream/TipeeestreamListener.scala

@@ -18,6 +18,7 @@ class TipeeestreamListener extends EventManager {
       case "follow" => call(FollowEventJSON(event))
       case "cheer" => call(CheerEventJSON(event))
       case "raid" => call(RaidEventJSON(event))
+      case "hosting" => call(HostEventJSON(event))
       case _ =>
     })
   }

src/main/scala/org/codeoverflow/chatoverflow/requirement/service/tipeeestream/impl/TipeeestreamEventInputImpl.scala

@@ -29,6 +29,7 @@ class TipeeestreamEventInputImpl extends EventInputImpl[TipeeestreamEvent, Tipee
     sourceConnector.get.registerEventHandler(handleExceptions(onDonation))
     sourceConnector.get.registerEventHandler(handleExceptions(onCheer))
     sourceConnector.get.registerEventHandler(handleExceptions(onRaid))
+    sourceConnector.get.registerEventHandler(handleExceptions(onHost))
     true
   }
 
@@ -102,11 +103,21 @@ class TipeeestreamEventInputImpl extends EventInputImpl[TipeeestreamEvent, Tipee
     val user = new User(parameter.getString("username"))
     val time = OffsetDateTime.parse(event.getString("created_at"), DATE_FORMATTER)
     val message = parameter.getString("formattedMessage")
-    val viewers = event.getInt("formattedAmount")
+    val viewers = parameter.getInt("viewers")
     val raid = new TipeeestreamRaid(user, message, viewers, time)
     call(new TipeeestreamRaidEvent(raid))
   }
 
+  private def onHost(eventJson: HostEventJSON): Unit = {
+    val event = eventJson.json
+    val parameter = event.getJSONObject("parameters")
+    val user = new User(parameter.getString("username"))
+    val time = OffsetDateTime.parse(event.getString("created_at"), DATE_FORMATTER)
+    val message = parameter.getString("formattedMessage")
+    val viewers = parameter.getInt("viewers")
+    val host = new TipeeestreamHost(user, message, viewers, time)
+    call(new TipeeestreamHostEvent(host))
+  }
 
   override def stop(): Boolean = {
     sourceConnector.get.unregisterAllEventListeners