Add raid events to the api and to tipeeestream

Author: hlxid

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

@@ -95,4 +95,5 @@ object TipeeestreamConnector {
   private[tipeeestream] case class DonationEventJSON(json: JSONObject) extends TipeeestreamEventJSON(json)
   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)
 }

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

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

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

@@ -26,6 +26,7 @@ class TipeeestreamEventInputImpl extends EventInputImpl[TipeeestreamEvent, Tipee
     sourceConnector.get.registerEventHandler(onSubscription _)
     sourceConnector.get.registerEventHandler(onDonation _)
     sourceConnector.get.registerEventHandler(onCheer _)
+    sourceConnector.get.registerEventHandler(onRaid _)
     true
   }
 
@@ -110,14 +111,35 @@ class TipeeestreamEventInputImpl extends EventInputImpl[TipeeestreamEvent, Tipee
       call(new TipeeestreamCheerEvent(cheer))
     } catch {
       case e: JSONException =>
-        logger warn "Error while parsing follow json:"
+        logger warn "Error while parsing cheer json:"
         logger warn s"${e.getClass.getName} - ${e.getMessage}"
       case e: IllegalArgumentException =>
-        logger warn "Error while parsing follow json:"
+        logger warn "Error while parsing cheer json:"
         logger warn s"${e.getClass.getName} - ${e.getMessage}"
     }
   }
 
+  private def onRaid(eventJson: RaidEventJSON): Unit = {
+    try {
+      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 = event.getInt("formattedAmount")
+      val raid = new TipeeestreamRaid(user, message, viewers, time)
+      call(new TipeeestreamRaidEvent(raid))
+    } catch {
+      case e: JSONException =>
+        logger warn "Error while parsing raid json:"
+        logger warn s"${e.getClass.getName} - ${e.getMessage}"
+      case e: IllegalArgumentException =>
+        logger warn "Error while parsing raid json:"
+        logger warn s"${e.getClass.getName} - ${e.getMessage}"
+    }
+  }
+
+
   override def stop(): Boolean = {
     sourceConnector.get.unregisterAllEventListeners
     true