Connect tor tipeeestream socket.io - srsly??? *facepalm*

Author: J0B10

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

@@ -2,7 +2,7 @@ package org.codeoverflow.chatoverflow.requirement.service.tipeeestream
 
 import java.util.Calendar
 
-import io.socket.client.Socket
+import io.socket.client.{IO, Socket}
 import org.codeoverflow.chatoverflow.WithLogger
 import org.codeoverflow.chatoverflow.connector.Connector
 import org.json.JSONObject
@@ -14,6 +14,7 @@ import org.json.JSONObject
   */
 class TipeeestreamConnector(override val sourceIdentifier: String) extends Connector(sourceIdentifier) with WithLogger {
   private val TIMEOUT = 10000
+  private val SOCKET_URL = "https://sso-cf.tipeeestream.com"
   private val tipeeeStreamListener = new TipeeestreamListener
   override protected var requiredCredentialKeys: List[String] = List("apiKey", "username")
   override protected var optionalCredentialKeys: List[String] = List()
@@ -30,8 +31,9 @@ class TipeeestreamConnector(override val sourceIdentifier: String) extends Conne
     * @return if the socket could start successfully
     */
   private def startSocket(): Boolean = {
-    var connected: Option[Boolean] = None
+    @volatile var connected: Option[Boolean] = None
     val thread = Thread.currentThread
+    socket = Some(IO.socket(SOCKET_URL).connect())
     socket.get.on(Socket.EVENT_CONNECT, (_: Any) => {
       logger info "Connected to TipeeStream Socket.io"
       socket.get.emit("join-room", AUTH_OBJECT)
@@ -40,13 +42,14 @@ class TipeeestreamConnector(override val sourceIdentifier: String) extends Conne
         tipeeeStreamListener.onSocketEvent(objects)
       })
       connected = Some(true)
-      connected.notifyAll()
     })
     socket.get.on(Socket.EVENT_CONNECT_ERROR, (e: Any) => {
       logger warn s"Could not connect to TipeeeStream socket:"
-      logger warn e.asInstanceOf[Array[Object]].mkString(",")
+      e match {
+        case array: Array[Any] => logger warn array.mkString(", ")
+        case other => logger warn other.toString
+      }
       connected = Some(false)
-      connected.notifyAll()
     })
     socket.get.on(Socket.EVENT_CONNECT_TIMEOUT, (_: Any) => {
       logger warn s"$sourceIdentifier socket timed out"
@@ -59,7 +62,11 @@ class TipeeestreamConnector(override val sourceIdentifier: String) extends Conne
       }
     })
     val start = Calendar.getInstance.getTimeInMillis
-    while (connected.isEmpty && start + TIMEOUT > Calendar.getInstance.getTimeInMillis) connected.wait(TIMEOUT)
+    try {
+      while (connected.isEmpty && start + TIMEOUT > Calendar.getInstance.getTimeInMillis) Thread.sleep(100)
+    } catch {
+      case _: InterruptedException => //Just resume
+    }
     connected.getOrElse({
       logger warn "Could not connect to TipeeeStream socket: Timed out!"
       false