Scala: http4s дает 401 несанкционированный для того же запроса, который работает в curl / запросов - PullRequest
0 голосов
/ 14 декабря 2018

Я попробовал следующий код, используя http4s v0.19.0:

import cats.effect._

def usingHttp4s(uri: String, bearerToken: String)(implicit cs: ContextShift[IO]): String = {
    import scala.concurrent.ExecutionContext
    import org.http4s.client.dsl.io._
    import org.http4s.headers._
    import org.http4s.Method._
    import org.http4s._
    import org.http4s.client._


    import org.http4s.client.middleware._

    val blockingEC = ExecutionContext.fromExecutorService(Executors.newFixedThreadPool(5))

    val middlewares = Seq(
      RequestLogger[IO](logHeaders = true, logBody = true, redactHeadersWhen = _ => false)(_),
      FollowRedirect[IO](maxRedirects = 5)(_)
    )

    val client = middlewares.foldRight(JavaNetClientBuilder(blockingEC).create[IO])(_.apply(_))

    val req = GET(
      Uri.unsafeFromString(uri),
      Authorization(Credentials.Token(AuthScheme.Bearer, bearerToken))
    )
    client.expect[String](req).unsafeRunSync()
  }

Я получаю следующую ошибку:

[error] (run-main-0) org.http4s.client.UnexpectedStatus: unexpected HTTP status: 401 Unauthorized
[error] org.http4s.client.UnexpectedStatus: unexpected HTTP status: 401 Unauthorized

Мало того, моя программа никогда не закрывалась (нужно лизакройте некоторый клиент !?) и он также никогда не печатал запрос, хотя я подключил промежуточное программное обеспечение для ведения журналов

Затем я попробовал библиотеку request @ li-haoyi, и это не вернуло ошибку:

def usingLiHaoyiRequest(uri: String, bearerToken: String): String =
    requests.get(uri, headers = Iterable("Authorization" -> s"Bearer $bearerToken")).text()

Приведенный выше код работает для того же uri и того же baseToken, поэтому мой токен не может быть неправильным.Чтобы быть вдвойне уверенным, я попробовал curl:

curl -L -H "Authorization: Bearer ${BEARER}" ${URI}

Эта проблема также возникает в http4s v0.18.19 (даже с явными Json и принимают заголовки):

import io.circle.Json

def usingHttp4s(uri: String, bearerToken: String): Json = {
    import org.http4s.client.dsl.io._
    import org.http4s.headers._
    import org.http4s.Method._
    import org.http4s._
    import org.http4s.client.blaze.Http1Client
    import org.http4s.client.middleware._
    import org.http4s.circe._
    import org.http4s.MediaType._

    val program = for {
      c <- Http1Client[IO]()
      client = FollowRedirect(maxRedirects = 5)(c)
      req = GET(
        Uri.unsafeFromString(uri),
        Authorization(Credentials.Token(AuthScheme.Bearer, bearerToken)),
        Accept(`application/json`)
      )
      res <- client.expect[Json](req)
    } yield res

    program.unsafeRunSync()
  }

Так что мой вопросэто:

  1. Почему оба requests и curl работают, но http4s дает мне 401 за один и тот же запрос?
  2. Почему моя версия http4s никогда не завершается?
  3. Почему промежуточное ПО регистратора запросов не регистрирует запрос?

1 Ответ

0 голосов
/ 17 декабря 2018

Как описано в gitter room , ошибка находится в http4s, который не перенаправляет заголовок авторизации на перенаправления, а как curl и запросы (если пересылка происходит в тот же поддомен).

...