Updated requirement library changes to new framework version.

Author: sebinside

src/main/scala/org/codeoverflow/chatoverflow/framework/StringMappingActor.scala

@@ -1,5 +1,6 @@
-package org.codeoverflow.chatoverflow.framework
+package org.codeoverflow.chatoverflow.framework.actors
 
+import akka.actor.Actor
 import org.apache.http.client.methods.HttpGet
 import org.apache.http.impl.client.HttpClientBuilder
 

src/main/scala/org/codeoverflow/chatoverflow/framework/HttpClientActor.scala renamed to src/main/scala/org/codeoverflow/chatoverflow/framework/actors/HttpClientActor.scala

@@ -0,0 +1,12 @@
+package org.codeoverflow.chatoverflow.framework.actors
+
+import akka.actor.Actor
+
+case class Mapping(mapFunc: String => Any, content: String)
+
+class StringMappingActor extends Actor {
+
+  override def receive: Receive = {
+    case m: Mapping => sender ! m.mapFunc(m.content)
+  }
+}

src/main/scala/org/codeoverflow/chatoverflow/framework/actors/StringMappingActor.scala

@@ -1,5 +1,111 @@
 package org.codeoverflow.chatoverflow.requirement.service.twitch.api
 
-class TwitchAPIConnector {
+import akka.actor.{ActorRef, ActorSystem, Props}
+import akka.pattern.ask
+import akka.util.Timeout
+import org.apache.http.HttpEntity
+import org.apache.http.client.methods.HttpGet
+import org.apache.http.client.utils.URIBuilder
+import org.apache.http.util.EntityUtils
+import org.codeoverflow.chatoverflow.WithLogger
+import org.codeoverflow.chatoverflow.connector.Connector
+import org.codeoverflow.chatoverflow.framework.actors.HttpClientActor
 
+import scala.concurrent.Await
+import scala.concurrent.duration._
+
+// FIXME: Chery picked from Class Library Rework, should be reworked, lol
+
+/**
+  * The twitch api connector
+  *
+  * @param sourceIdentifier the name to the twitch account
+  */
+class TwitchAPIConnector(override val sourceIdentifier: String) extends Connector(sourceIdentifier) with WithLogger {
+  private val API_FORMAT: String = "application/vnd.twitchtv.v5+json"
+  private val BASE_URL: String = "https://api.twitch.tv/helix/"
+  private val BASE_URL_v5: String = "https://api.twitch.tv/kraken/"
+  private val actorSystem = ActorSystem("TwitchAPIActorSystem")
+  private val actor: ActorRef = actorSystem.actorOf(Props[HttpClientActor])
+  private var clientID = ""
+  private var oauth = ""
+  requiredCredentialKeys = List(TwitchAPIConnector.credentialsClientID, TwitchAPIConnector.credentialsOauthKey)
+
+  override def getUniqueTypeString: String = this.getClass.getName
+
+  /**
+    * Returns true, if the connector has been already instantiated and is running.
+    */
+  override def isRunning: Boolean = true
+
+  /**
+    * Initializes the connector, e.g. creates a connection with its platform.
+    */
+  override def init(): Boolean = {
+    val oauth = credentials.get.getValue(TwitchAPIConnector.credentialsOauthKey)
+    val clientID = credentials.get.getValue(TwitchAPIConnector.credentialsClientID)
+
+    if (clientID.isEmpty) {
+      logger warn s"key '${TwitchAPIConnector.credentialsClientID}' not found in credentials for '$sourceIdentifier'."
+      false
+    } else {
+      this.clientID = clientID.get
+      if (oauth.isEmpty) {
+        logger warn s"key '${TwitchAPIConnector.credentialsOauthKey}' not found in credentials for '$sourceIdentifier'."
+        false
+      } else {
+        this.oauth = oauth.get
+        true
+      }
+    }
+  }
+
+  def getSubscriptions(channelID: String, offset: Int = 0, newestFirst: Boolean = true): String = {
+    get("channels/" + channelID + "/subscriptions", auth = true, oldAPI = true, Seq(("limit", "100"), ("offset", String.valueOf(offset)), ("direction", if (newestFirst) "desc" else "asc")))
+  }
+
+  def getUser(userLogin: String): String = {
+    get("users", auth = false, oldAPI = false, Seq(("login", userLogin)))
+  }
+
+  def get(uri: String, auth: Boolean, oldAPI: Boolean, queryParams: Seq[(String, String)]): String = {
+    val httpGet = if (auth) getUrlAuth(uri, oldAPI) else getURL(uri, oldAPI)
+    val urlBuilder = new URIBuilder(httpGet.getURI)
+    queryParams.foreach(param => urlBuilder.addParameter(param._1, param._2))
+    httpGet.setURI(urlBuilder.build())
+    implicit val timeout: Timeout = Timeout(5 seconds)
+    val entity = Await.result(actor ? httpGet, timeout.duration).asInstanceOf[HttpEntity]
+    if (entity != null) {
+      EntityUtils.toString(entity, "UTF-8")
+    }
+    else ""
+  }
+
+  def getUrlAuth(uri: String, oldAPI: Boolean): HttpGet = {
+    val get = getURL(uri, oldAPI)
+    get.setHeader("Authorization", oauth)
+    get
+  }
+
+  def getURL(uri: String, oldAPI: Boolean): HttpGet = {
+    val baseUrl = if (oldAPI) BASE_URL_v5 else BASE_URL
+    new HttpGet(baseUrl + uri) {
+      setHeader("Accept", API_FORMAT)
+      setHeader("Client-ID", clientID)
+    }
+  }
+
+  def getFollowers(userID: String): String = {
+    get("users/follows", auth = false, oldAPI = false, Seq(("to_id", userID)))
+  }
+
+  /**
+    * Shuts down the connector, closes its platform connection.
+    */
+  override def shutdown(): Unit = ???
 }
+
+object TwitchAPIConnector {
+  val credentialsOauthKey = "oauth"
+  val credentialsClientID = "clientid"
+}

src/main/scala/org/codeoverflow/chatoverflow/requirement/service/twitch/api/TwitchAPIConnector.scala

@@ -1,34 +1,43 @@
-package org.codeoverflow.chatoverflow.service.twitch.stat.impl
+package org.codeoverflow.chatoverflow.requirement.service.twitch.api.impl
 
-import com.fasterxml.jackson.databind.ObjectMapper
-import org.codeoverflow.chatoverflow.framework.{Mapping, StringMappingActor}
-import org.codeoverflow.chatoverflow.service.twitch.TwitchAPIConnector
+import akka.actor.{ActorRef, ActorSystem, Props}
+import akka.pattern.ask
+import akka.util.Timeout
+import org.codeoverflow.chatoverflow.api.io.input.chat.User
+import org.codeoverflow.chatoverflow.api.io.input.stat.TwitchStatInput
+import org.codeoverflow.chatoverflow.framework.actors.{Mapping, StringMappingActor}
+import org.codeoverflow.chatoverflow.registry.Impl
+import org.codeoverflow.chatoverflow.requirement.Connection
+import org.codeoverflow.chatoverflow.requirement.service.twitch.api.TwitchAPIConnector
 
 import scala.concurrent.Await
 import scala.concurrent.duration._
 
+// FIXME: Chery picked from Class Library Rework, should be reworked, lol
+
 case class UserResult(data: Seq[UserEntity])
 
 case class UserEntity(id: String, login: String, display_name: String, `type`: String, broadcaster_type: String, description: String, profile_image_url: String, offline_image_url: String, view_count: Int)
 
+@Impl(impl = classOf[TwitchStatInput], connector = classOf[TwitchAPIConnector])
 class TwitchStatInputImpl extends Connection[TwitchAPIConnector] with TwitchStatInput {
   private val actorSystem = ActorSystem("TwitchAPIActorSystem")
   private val actor: ActorRef = actorSystem.actorOf(Props[StringMappingActor])
   implicit val timeout: Timeout = Timeout(5 seconds)
 
   override def init(): Unit = {
-    sourceConnector.init()
+    sourceConnector.get.init()
   }
 
   override def getFollowers(userName: String): java.util.List[User] = {
     val userID = getUser(userName).getId
-    val response = sourceConnector.getFollowers(userID)
+    val response = sourceConnector.get.getFollowers(userID)
     println(response)
     null
   }
 
   override def getUser(userName: String): User = {
-    val response = sourceConnector.getUser(userName)
+    val response = sourceConnector.get.getUser(userName)
     println(response)
     val result = Await.result(actor ? Mapping(map[UserResult], response), timeout.duration).asInstanceOf[UserResult]
     if (result.data.nonEmpty) {
@@ -38,14 +47,19 @@ class TwitchStatInputImpl extends Connection[TwitchAPIConnector] with TwitchStat
     else null
   }
 
+  // FIXME: Kicked jackson mapping (deprecated?!), different way needed
   def map[T: Manifest](content: String): Any = {
-    val mapper = new ObjectMapper() with ScalaObjectMapper
-    mapper.registerModule(DefaultScalaModule)
-    mapper.readValue[T](content)
+    //val mapper = new ObjectMapper() with ScalaObjectMapper
+    // mapper.registerModule(DefaultScalaModule)
+    //mapper.readValue[T](content)
   }
 
   override def getSubscribers(userName: String): String = {
     val userID = getUser(userName).getId
-    sourceConnector.getSubscriptions(userID)
+    sourceConnector.get.getSubscriptions(userID)
   }
+
+  override def serialize(): String = ???
+
+  override def deserialize(value: String): Unit = ???
 }