How to use allowRedirects method of com.github.kittinunf.fuel.core.Request class

Best Fuel code snippet using com.github.kittinunf.fuel.core.Request.allowRedirects

DefaultRequest.kt

Source:DefaultRequest.kt

...327     *328     * @note The interceptor must implement this behaviour329     * @note The provided RedirectResponseInterceptor defaults to true330     *331     * @param allowRedirects [Boolean] true if allowing, false if not332     * @return self333     */334    override fun allowRedirects(allowRedirects: Boolean) = request.also {335        it.executionOptions.allowRedirects = allowRedirects336    }337    /**338     * Overwrite [RequestExecutionOptions] http cache usage flag339     *340     * @note [com.github.kittinunf.fuel.core.Client] must implement this behaviour341     * @note The default client sends `Cache-Control: none` if this flag is false, defaults to true342     *343     * @see java.net.HttpURLConnection.setUseCaches344     * @param useHttpCache [Boolean] true if suggest client to allow cached responses, false otherwise345     */346    override fun useHttpCache(useHttpCache: Boolean) = request.also {347        it.executionOptions.useHttpCache = useHttpCache348    }349    /**...

App.kt

Source:App.kt

...149    url: URI,150    parameters: List<Pair<String, Any?>>151): Request {152    return when (httpMethod.value.lowercase()) {153        "get" -> url.toString().httpGet(parameters).allowRedirects(false)154        "post" -> url.toString().httpPost(parameters).allowRedirects(false)155        "put" -> url.toString().httpPut(parameters).allowRedirects(false)156        "delete" -> url.toString().httpDelete(parameters).allowRedirects(false)157        else -> throw IllegalStateException("Ikke supportert HttpMethod $httpMethod")158    }159}160private suspend fun ApplicationCall.respondErrorAndLog(status: HttpStatusCode, error: String) {161    logger.error("HTTP $status -> $error")162    respond(status, error)163}164private fun ApplicationRequest.hasValidPath(): Boolean {165    val path = getPathWithoutLeadingSlashes()166    return path.isNotBlank()167}168private fun ApplicationRequest.getPathWithoutLeadingSlashes(): String {169    var path = path()170    while (path.startsWith("/")) {...

FuelHttpClient.kt

Source:FuelHttpClient.kt

...88            HttpMethod.PATCH -> request.url.httpPatch()89            HttpMethod.DELETE -> request.url.httpDelete()90            HttpMethod.HEAD -> request.url.httpHead()91        }92        req.allowRedirects(request.allowRedirects)93        if (request.cookies.isNotEmpty()) {94            req.header("Cookie", request.cookies.joinToString("&"))95        }96        if (userAgentProvider.hasAny()) {97            req.header("User-Agent", userAgentProvider.select())98        }99        req.header(request.headers.toMap())100        req.timeout(timeout)101        req.timeoutRead(timeoutRead)102        request.body?.let {103            when (it) {104                is TextRequestBody -> req.body(it.text)105                is JsonRequestBody -> req.jsonBody(it.json)106                is BytesRequestBody -> req.body(it.bytes)...

HttpClient.kt

Source:HttpClient.kt

...51    private fun Request.exec(headers: Headers): HttpResponse {52        val (_, response, result) = this53            .header(defaultHeaders + headers)54            .authentication()55            .allowRedirects(autoRedirect)56            .response()57        return createResponse(response, result)58    }59    private fun Request.exec(requestBody: String, headers: Headers): HttpResponse {60        val (_, response, result) = this61            .body(requestBody)62            .header(defaultHeaders + headers)63            .authentication()64            .allowRedirects(autoRedirect)65            .response()66        return createResponse(response, result)67    }68    private fun Request.exec(requestBody: ByteArray, headers: Headers): HttpResponse {69        val (_, response, result) = this70            .body(requestBody)71            .header(defaultHeaders + headers)72            .authentication()73            .allowRedirects(autoRedirect)74            .response()75        return createResponse(response, result)76    }77    private fun createResponse(response: Response, result: Result<ByteArray, FuelError>): HttpResponse {78        val statusCode = response.statusCode79        val hs = response.headers.toMap().mapValues { it.value.joinToString(separator = ", ") }80        val body = when (result) {81            is Result.Success -> ResponseBody(String(result.value), result.value)82            is Result.Failure -> ResponseBody(String(result.error.errorData), result.error.errorData)83        }84        return HttpResponse(statusCode, hs, body)85    }86}87data class HttpResponse(...

HttpUtils.kt

Source:HttpUtils.kt

...20    requestType: RequestType,21    path: String,22    requestBody: Any? = null,23    headers: Map<String, Any> = emptyMap(),24    allowRedirects: Boolean = false,25    parameters: List<Pair<String, String>>? = null26): HttpResponse<T> {27    val url = url(path)28    log.info("Sending $requestType request to $url\nheaders - $headers")29    val request = when (requestType) {30        RequestType.GET -> Fuel.get(url).allowRedirects(allowRedirects)31        RequestType.POST -> {32            when (requestBody) {33                is DataPart -> {34                    Fuel.upload(url, Method.POST, parameters)35                        .add(requestBody)36                        .allowRedirects(allowRedirects)37                        .also {38                            log.info(requestBody.toString())39                        }40                }41                null -> {42                    val contentType = headers["Content-Type"] as String?43                    if (contentType == "multipart/form-data; boundary=<calculated when request is sent>") {44                        Fuel.upload(url, Method.POST, parameters)45                            .allowRedirects(allowRedirects)46                    } else {47                        Fuel.post(url).allowRedirects(allowRedirects)48                    }49                }50                else -> {51                    val json = requestBody.toJson()52                    log.info(json)53                    Fuel.post(url).body(json).allowRedirects(allowRedirects)54                }55            }56        }57        RequestType.PUT -> Fuel.put(url).body(requestBody as ByteArray).allowRedirects(allowRedirects)58        RequestType.OPTIONS -> Fuel.request(Method.OPTIONS, url).allowRedirects(allowRedirects)59    }60    val (_, response, _) = request.header(headers).timeoutRead(50000).response()61    val responseBody = when (T::class) {62        String::class -> response.body()63            .takeIf { !it.isEmpty() }64            ?.asString("application/json; CHARSET=UTF-8")65            ?: ""66        ByteArray::class -> response.body().toByteArray()67        else -> RuntimeException("Unsupported type ${T::class}")68    } as T69    log.info("Received headers: ${response.headers}")70    log.info("Received response: ${response.statusCode}\n${responseBody}")71    if (response.statusCode == -1) {72        throw RuntimeException("Failed to connect to $url, please verify if service is available")...

HttpRequest.kt

Source:HttpRequest.kt

...27            .header(mapOf("Sec-Fetch-Dest" to "empty"))28            .header(mapOf("Accept-Language" to "en,de-DE;q=0.9,de;q=0.8,en-US;q=0.7"))29            .header(mapOf("Transfer-Encoding" to "chunked"))30            .body(arg)31            .allowRedirects(true)32            .responseJson()33        when (result) {34            is Result.Failure -> {35                val ex = result.getException()36                println(ex)37                return ""38            }39            is Result.Success -> {40                val data = result.value.content41                return data42            }43        }44    }45    fun invokePlantUML(arg: String): String {...

Fuel.kt

Source:Fuel.kt

...38            .body(bodyMode(response.body().toStream()))39    }40    private fun Request.toFuel(): com.github.kittinunf.fuel.core.Request =41        FuelFuel.request(Method.valueOf(method.toString()), uri.toString(), emptyList())42            .allowRedirects(false)43            .timeout(timeout.toMillisPart())44            .timeoutRead(timeout.toMillisPart())45            .header(headers.toParametersMap())46            .body(bodyMode(body.stream).stream)47}...

RedirectionInterceptor.kt

Source:RedirectionInterceptor.kt

...16)17fun redirectResponseInterceptor(manager: FuelManager) =18    { next: (Request, Response) -> Response ->19        inner@{ request: Request, response: Response ->20            if (!response.isStatusRedirection || request.executionOptions.allowRedirects == false) {21                return@inner next(request, response)22            }23            val redirectedUrl = response[Headers.LOCATION]24                .ifEmpty { response[Headers.CONTENT_LOCATION] }25                .lastOrNull()26            if (redirectedUrl.isNullOrEmpty()) {27                return@inner next(request, response)28            }29            val newUrl = if (URI(redirectedUrl.split('?').first()).isAbsolute) URL(redirectedUrl) else URL(request.url, redirectedUrl)30            val newMethod = when {31                response.statusCode in redirectStatusWithGets -> Method.GET32                else -> request.method33            }34            val encoding = Encoding(httpMethod = newMethod, urlString = newUrl.toString())...

allowRedirects

Using AI Code Generation

1    .allowRedirects(true)2    .responseString()3    .allowRedirects(false)4    .responseString()5    .allowRedirects { request, response -> true }6    .responseString()7    .allowRedirects { request, response -> false }8    .responseString()9    .allowRedirects { request, response -> response.statusCode == 302 }10    .responseString()11    .allowRedirects { request, response -> response.statusCode == 302 }12    .responseString()13    .allowRedirects { request, response -> response.statusCode == 302 }14    .responseString()

allowRedirects

Using AI Code Generation

1    .allowRedirects(true)2    .responseString()3    .allowRedirects(false)4    .responseString()5    .allowRedirects(true)6    .responseString()7    .allowRedirects(false)8    .responseString()9    .allowRedirects(true)10    .responseString()

allowRedirects

Using AI Code Generation

1.request()2.allowRedirects(true)3.responseString()4.request()5.allowRedirects(false)6.responseString()7.request()8.allowRedirects(3)9.responseString()10.request()11.allowRedirects(3, true)12.responseString()13.request()14.allowRedirects(3, false)15.responseString()16.request()17.allowRedirects(3, true, { response -> response.statusCode == 302 })18.responseString()19.request()20.allowRedirects(3, false, { response -> response.statusCode == 302 })21.responseString()22val (request, response, result) = Fuel.get("

allowRedirects

Using AI Code Generation

1    result.fold({ data ->2        println(data)3    }, { error ->4        println(error)5    })6}7    result.fold({ data ->8        println(data)9    }, { error ->10        println(error)11    })12}13    result.fold({ data ->14        println(data)15    }, { error ->16        println(error)17    })18}19    result.fold({ data ->20        println(data)21    }, { error ->22        println(error)23    })24}25    result.fold({ data ->26        println(data)27    }, { error ->28        println(error)29    })30}31    result.fold({ data ->32        println(data)33    }, { error ->34        println(error)35    })36}

allowRedirects

Using AI Code Generation

1        .allowRedirects(true)2        .responseString()3    println(response.second.statusCode)4        .followRedirects(true)5        .responseString()6    println(response.second.statusCode)7        .redirects(true)8        .responseString()9    println(response.second.statusCode)10        .timeoutRead(10000)11        .responseString()12    println(response.second.statusCode)13        .timeoutConnect(10000)14        .responseString()15    println(response.second.statusCode)16        .timeoutWrite(10000)17        .responseString()18    println(response.second.statusCode)19        .timeoutReadInMillisecond(10000)20        .responseString()21    println(response.second.statusCode)22        .timeoutConnectInMillisecond(10000)23        .responseString()24    println(response.second.statusCode)

allowRedirects

Using AI Code Generation

1fun getRedirectedUrl(url: String): String {2    val response = Fuel.get(url)3        .allowRedirects(false)4        .responseString()5    val redirectedUrl = response.second.url.toString()6}7fun getRedirectedUrl(url: String): String {8    val response = Fuel.get(url)9        .followRedirects(true)10        .responseString()11    val redirectedUrl = response.second.url.toString()12}13fun getRedirectedUrl(url: String): String {14    val response = Fuel.get(url)15        .redirects(10)16        .responseString()17    val redirectedUrl = response.second.url.toString()18}19fun getRedirectedUrl(url: String): String {20    val response = Fuel.get(url)21        .timeoutRead(10000)22        .responseString()23    val redirectedUrl = response.second.url.toString()24}25fun getRedirectedUrl(url: String): String {26    val response = Fuel.get(url)27        .timeoutConnect(10000)28        .responseString()29    val redirectedUrl = response.second.url.toString()30}31fun getRedirectedUrl(url: String): String {32    val response = Fuel.get(url)33        .timeoutRead(10000)34        .timeoutConnect(10000)35        .responseString()36    val redirectedUrl = response.second.url.toString()37}38fun getRedirectedUrl(url: String): String {39    val response = Fuel.get(url)40        .timeoutRead(10000)41        .responseString()

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.