You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
65 lines
1.9 KiB
65 lines
1.9 KiB
package wow.doge.chatto.service
|
|
|
|
import scala.concurrent.ExecutionContext
|
|
import scala.concurrent.ExecutionContext.Implicits.global
|
|
import scala.async.Async.{async, await}
|
|
import sttp.client.json4s._
|
|
import org.json4s._
|
|
import sttp.client._
|
|
import scala.concurrent.Future
|
|
import sttp.client.asynchttpclient.WebSocketHandler
|
|
import javax.inject.Inject
|
|
import scala.async.Async.{async, await}
|
|
import scala.util.Success
|
|
import scala.util.Failure
|
|
import wow.doge.chatto.AppData
|
|
import wow.doge.chatto.types.AppTypes.HttpBackend
|
|
import com.typesafe.scalalogging.LazyLogging
|
|
import org.scalafx.extras._
|
|
import wow.doge.chatto.ApplicationController
|
|
import wow.doge.chatto.UserCredentials
|
|
import javax.inject._
|
|
import wow.doge.chatto.AppDataHandler
|
|
|
|
class UserService @Inject() (appDataHandler: AppDataHandler)(
|
|
implicit backend: HttpBackend
|
|
) extends LazyLogging {
|
|
private implicit lazy val serialization = org.json4s.native.Serialization
|
|
private val domain = "http://localhost:8080"
|
|
private lazy val baseUrl = uri"$domain/api/chat"
|
|
private lazy val authBasicRequest = (credentials: UserCredentials) =>
|
|
basicRequest.auth
|
|
.basic(credentials.username, credentials.password)
|
|
// .header("X-AUTH-TOKEN", appData.credentials.token)
|
|
|
|
def func1() = async {
|
|
val willBeResponse = func2()
|
|
val r = await { willBeResponse }
|
|
r.body.map(println)
|
|
}
|
|
|
|
def func2() =
|
|
basicRequest
|
|
.get(uri"https://httpbin.org/get")
|
|
.response(asJson[HttpBinResponse])
|
|
.send()
|
|
|
|
private def endpoint(uri: String) = uri"$baseUrl/$uri"
|
|
|
|
def getUsers(credentials: UserCredentials) = async {
|
|
println(appDataHandler.appData)
|
|
await {
|
|
authBasicRequest(credentials)
|
|
.get(uri"http://localhost:8080/api/chat/get/users")
|
|
.response(asJson[List[String]])
|
|
.send()
|
|
}
|
|
}
|
|
|
|
}
|
|
|
|
final case class HttpBinResponse(
|
|
url: String,
|
|
origin: String,
|
|
headers: Map[String, String]
|
|
)
|