How to use private class of com.github.kittinunf.fuel.core.requests package

...182                    publishArticle(it)183                }.sequence(Either.applicative()).fix()184            }185            .map { Unit }186    private fun getArticleTranslations(articleId: Long) =187        ZendeskRequest.GetArticleTranslations(articleId, "en-us").run()188            .map {189                it.translations190            }191    private fun getArticles(sectionId: Long) =192        ZendeskRequest.GetArticles(sectionId).run()193            .map {194                it.articles195            }196    private fun updateTranslation(translation: Translation) =197        ZendeskRequest.UpdateArticleTranslation(translation).run()198    private fun publishArticle(article: Article) =199        article.id.rightIfNotNull { HtmlToZendeskError.MissingArticleId }200            .flatMap { getArticleTranslations(it) }201            .flatMap { translations ->202                translations.map { translation ->203                    updateTranslation(translation.copy(draft = false))204                }.sequence(Either.applicative()).fix()205            }206            .map { Unit }207    private fun uploadArticleImage(path: String) =208        ZendeskRequest.UploadAttachedImage(path).run()209            .map { it.articleAttachment }210    private fun uploadImages(article: Article) =211        article.getBodyImages()212            .map { it to uploadArticleImage("${article.path.parent}/$it") }213            .map { (imgName, uploadResult) ->214                uploadResult.fold({215                    it.left()216                }, {217                    (imgName to it).right()218                })219            }220            .sequence(Either.applicative()).fix().map { it.fix().toMap() }221    private fun linkAttachmentsToArticle(attachments: Collection<ArticleAttachment>, articleId: Long) =222        ZendeskRequest.LinkAttachedImage(articleId, attachments.map(ArticleAttachment::id)).run()223    private fun postArticle(article: Article) =224        ZendeskRequest.CreateArticle(article).run()225            .flatMap {226                it.article.id.rightIfNotNull {227                    UnexpectedRequestResult("The id of the article that has been created is not set. $it ")228                }229            }230    fun getSection(name: String, parentSectionId: Long? = null) =231        ZendeskRequest.GetSections(categoryId).run()232            .flatMap {233                it.sections.firstOrNone { it.name == name && it.parentSectionId == parentSectionId }234                    .toEither { ResourceDoesNotExist }235            }236    private fun getSectionWithPattern(pattern: String, parentSectionId: Long? = null) =237        ZendeskRequest.GetSections(categoryId).run()238            .flatMap {239                it.sections.firstOrNone { section ->240                    pattern.toRegex().containsMatchIn(section.name) && section.parentSectionId == parentSectionId241                }.toEither { ResourceDoesNotExist }242            }243    private fun createSection(section: NewSection) =244        ZendeskRequest.CreateSection(categoryId, section)245            .run()246            .map { it.section }247    class ZendeskResponseDeserializable2<T : ZendeskApiBody>(val responseType: KClass<out T>) :248        ResponseDeserializable<T> {249        override fun deserialize(content: String): T = when (responseType) {250            ZendeskApiBody.EmptyBody::class -> ZendeskApiBody.EmptyBody as T251            else -> gson.fromJson(content, responseType.java)252        }253    }254    private fun <T : ZendeskApiBody> ZendeskRequest<T>.run(requestConfigBlock: Request.() -> Unit = {}) =255        get(url)256            .apply(requestConfigBlock)257            .also { println(it) }258            .authentication()259            .basic(user, password)260            .responseObject(ZendeskResponseDeserializable2(responseType))261            .third262            .fold(263                { it.right() },264                {265                    when (it.response.statusCode) {266                        404 -> ResourceDoesNotExist.left()267                        else -> UnexpectedRequestError(it).left()268                    }269                })270}271private fun <A, B, C, D> Either<A, Tuple2<B, C>>.flatmapTupleRight(block: (C) -> Either<A, D>) = flatMap {272    it.map(block).sequence(Either.applicative()).fix().map { it.fix() }273}...

...23import org.slf4j.LoggerFactory24import java.io.ByteArrayInputStream25import java.net.URI26import java.util.*27private val logger: Logger = LoggerFactory.getLogger("nav.App")28private const val navCallIdHeader = "Nav-Call-Id"29private val monitoringPaths = listOf("isalive", "isready")30fun main(args: Array<String>): Unit  = io.ktor.server.netty.EngineMain.main(args)31fun Application.helseReverseProxy() {32    val mappings = Environment().getMappings()33    install(Routing) {34        DefaultProbeRoutes()35    }36    intercept(ApplicationCallPipeline.Monitoring) {37        call.request.log(templateQueryParameters = true)38    }39    install(CallId) {40        retrieve { call ->41            call.request.header(HttpHeaders.XCorrelationId) ?: call.request.header(navCallIdHeader)42        }43    }44    install(CallLogging) {45        callIdMdc("correlation_id")46        mdc("request_id") {"generated-${UUID.randomUUID()}"}47        logRequests(templateQueryParameters = true)48    }49    intercept(ApplicationCallPipeline.Call) {50        if (!call.request.isMonitoringRequest()) {51            if (!call.request.hasValidPath()) {52                call.respondErrorAndLog(HttpStatusCode.BadGateway, "Invalid requested path.")53            } else if (!call.request.isMonitoringRequest())  {54                val destinationApplication = call.request.firstPathSegment()55                logger.trace("destinationApplication = '$destinationApplication'")56                val destinationPath = call.request.pathWithoutFirstPathSegment()57                logger.trace("destinationPath = '$destinationPath'")58                val httpMethod = call.request.httpMethod59                logger.trace("httpMethod = '$httpMethod'")60                if (!mappings.containsKey(destinationApplication)) {61                    call.respondErrorAndLog(HttpStatusCode.BadGateway, "Application '$destinationApplication' not configured.")62                } else  {63                    val parameters = call.request.queryParameters.toFuel()64                    val headers = call.request.headers.toFuel()65                    val body = call.receiveOrNull<ByteArray>()66                    val destinationUrl = produceDestinationUrl(destinationPath,67                        mappings.getValue(destinationApplication)68                    )69                    logger.trace("destinationUrl = '$destinationUrl'")70                    val httpRequest = initializeRequest(71                        httpMethod = httpMethod,72                        url = destinationUrl,73                        parameters = parameters74                    )75                        .header(headers)76                        .timeout(20_000)77                        .timeoutRead(20_000)78                    if (body != null) {79                        httpRequest.body( {ByteArrayInputStream(body) })80                    }81                    val (_, response, result) = httpRequest.awaitByteArrayResponseResult()82                    result.fold(83                        { success -> call.forward(response, success)},84                        { failure ->85                            if (-1 == response.statusCode) {86                                logger.error(failure.toString())87                                call.respondErrorAndLog(HttpStatusCode.GatewayTimeout, "Unable to proxy request.")88                            } else {89                                call.forward(response, failure.errorData)90                            }91                        }92                    )93                }94            }95        }96    }97}98private suspend fun ApplicationCall.forward(99    clientResponse: Response,100    body: ByteArray101) {102    clientResponse.headers.forEach { key, value ->103        if (!HttpHeaders.isUnsafe(key)) {104            value.forEach { response.header(key, it) }105        }106    }107    respondBytes(108        bytes = body,109        status = HttpStatusCode.fromValue(clientResponse.statusCode),110        contentType = clientResponse.contentType()111    )112}113private fun Response.contentType(): ContentType {114    val clientContentTypesHeaders = header(HttpHeaders.ContentType)115    return if (clientContentTypesHeaders.isEmpty()) ContentType.Text.Plain else ContentType.parse(clientContentTypesHeaders.first())116}117private fun Headers.toFuel(): Map<String, Any> {118    val fuelHeaders = mutableMapOf<String, Any>()119    forEach { key, values ->120        fuelHeaders[key] = values121    }122    return fuelHeaders.toMap()123}124private fun Parameters.toFuel(): List<Pair<String, Any?>> {125    val fuelParameters = mutableListOf<Pair<String, Any?>>()126    forEach { key, value ->127        value.forEach { fuelParameters.add(key to it) }128    }129    return fuelParameters.toList()130}131private fun initializeRequest(132    httpMethod: HttpMethod,133    url: URI,134    parameters: List<Pair<String, Any?>>135) : Request {136    return when (httpMethod.value.lowercase()) {137        "get" -> url.toString().httpGet(parameters)138        "post" -> url.toString().httpPost(parameters)139        "put" -> url.toString().httpPut(parameters)140        "delete" -> url.toString().httpDelete(parameters)141        else -> throw IllegalStateException("Ikke supportert HttpMethod $httpMethod")142    }143}144private suspend fun ApplicationCall.respondErrorAndLog(status: HttpStatusCode, error: String) {145    logger.error("HTTP $status -> $error")146    respond(status, error)147}148private fun ApplicationRequest.hasValidPath(): Boolean {149    val path = getPathWithoutLeadingSlashes()150    return path.isNotBlank()151}152private fun ApplicationRequest.getPathWithoutLeadingSlashes(): String {153    var path = path()154    while (path.startsWith("/")) {155        path = path.substring(1)156    }157    return path.lowercase()158}159private fun ApplicationRequest.firstPathSegment(): String {160    val path = getPathWithoutLeadingSlashes()161    return path.split("/")[0]162}163private fun ApplicationRequest.pathWithoutFirstPathSegment(): String {164    val path = getPathWithoutLeadingSlashes()165    val firstPathSegment = firstPathSegment()166    return path.substring(firstPathSegment.length)167}168private fun produceDestinationUrl(destinationPath: String, baseUrl: URI) : URI {169    return URLBuilder(baseUrl.toString())170        .trimmedPath(listOf(baseUrl.path, destinationPath))171        .build().toURI()172}173private fun URLBuilder.trimmedPath(pathParts : List<String>): URLBuilder  {174    val trimmedPathParts = mutableListOf<String>()175    pathParts.forEach { part ->176        if (part.isNotBlank()) {177            trimmedPathParts.add(part.trimStart('/').trimEnd('/'))178        }179    }180    return path(trimmedPathParts)181}182private fun ApplicationRequest.isMonitoringRequest() : Boolean {183    return monitoringPaths.contains(firstPathSegment())184}...

...76    whenRetrieveCategories()77    thenReturnedCategoriesAreCorrect()78  }79  @BeforeEach80  private fun givenDefaultCategories() {81    categoriesRequest = DefaultRequestDTO()82  }83  private fun givenCategoriesWithOrderingByNameAsc() {84    categoriesRequest.orderBy = "name"85  }86  private fun givenCategoriesWithOrderingByIdDesc() {87    categoriesRequest.orderBy = "-id"88  }89  private fun givenCategoriesWithNameAndIdFields() {90    categoriesRequest.fields = arrayOf("name", "id")91  }92  private fun givenCategoriesWithRussianLanguage() {93    categoriesRequest.language = "ru"94  }95  private fun givenCategoriesWithEnglishLanguage() {96    categoriesRequest.language = "en"97  }98  private fun whenRetrieveCategories() {99    categoriesArray = Categories().getCategories(categoriesRequest)100  }101  private fun thenReturnedCategoriesAreCorrect() {102    assertTrue(categoriesArray.isNotEmpty())103  }104  private fun thenCategoriesArrayNotNull() = assertNotNull(categoriesArray)105}...

...8import com.github.kittinunf.fuel.core.extensions.authentication9import com.github.kittinunf.fuel.core.requests.CancellableRequest10import com.github.kittinunf.fuel.gson.jsonBody11import com.github.kittinunf.fuel.gson.responseObject12private val title = Title("Termine")13data class Title(val raw: String)14data class Content(val raw: String)15data class Page(val title: Title, val content: Content)16private fun Request.authenticate(userData: UserData) = authentication().basic(userData.username, userData.password)17fun updateEventsPage(userData: UserData, events: Events, handler: ResponseHandler<Page>): CancellableRequest {18    val raw = buildString { render(events) }19    val page = Page(title, Content(raw))20    return Fuel.post(userData.calendarUrl)21        .authenticate(userData)22        .jsonBody(page)23        .responseObject(handler)24}...

...7import com.yoesuv.networkkotlin2.data.EndPoint8import com.yoesuv.networkkotlin2.menu.listplace.models.ListPlaceModel9import com.yoesuv.networkkotlin2.utils.debugPrintStackTrace10class ListPlaceRepository {11    private lateinit var requestListPlace: Request12    fun getListPlace(onSuccess:(ListPlaceModel) -> Unit, onError:(FuelError) -> Unit) {13        requestListPlace = Fuel.get(EndPoint.LIST_PLACE).responseObject<ListPlaceModel> { _, _, result ->14            result.fold({15                onSuccess(it)16            }, {17                onError(it)18                debugPrintStackTrace(it)19            })20        }21    }22    fun cleared() {23        requestListPlace.tryCancel(true)24    }25}...

2import com.github.kittinunf.fuel.Fuel3import com.github.kittinunf.fuel.core.Headers4import com.github.kittinunf.fuel.core.Response5import com.github.kittinunf.fuel.core.ResponseResultOf6private object HttpStatus {7    const val OK = 2008}9fun getRequest(url: String, token: String? = null): ResponseResultOf<ByteArray> {10    val request = Fuel.get(url)11    token?.let {12        request.header(Headers.AUTHORIZATION, "token $it")13    }14    return request.response()15}16fun postRequest(url: String, jsonBody: String? = null, token: String? = null): ResponseResultOf<ByteArray> {17    val request = Fuel.post(url)18    token?.let {19        request.header(Headers.AUTHORIZATION, "token $it")20    }...

...7import com.yoesuv.networkkotlin2.data.EndPoint8import com.yoesuv.networkkotlin2.menu.gallery.models.GalleryModel9import com.yoesuv.networkkotlin2.utils.debugPrintStackTrace10class GalleryRepository {11    private lateinit var requestGallery: Request12    fun getListGallery(onSuccess:(GalleryModel) -> Unit, onError:(FuelError) -> Unit) {13        requestGallery = Fuel.get(EndPoint.LIST_GALLERY).responseObject<GalleryModel> { _, _, result ->14            result.fold({15                onSuccess(it)16            }, {17                onError(it)18                debugPrintStackTrace(it)19            })20        }21    }22    fun cleared() {23        requestGallery.tryCancel(true)24    }25}...

...5import com.github.kittinunf.fuel.core.requests.tryCancel6import com.github.kittinunf.fuel.gson.responseObject7import com.magang.kelilingapp.model.Wisata8class WisataRepository {9    private var URL = "https://wisatasurabayaapi.herokuapp.com/api"10    private lateinit var requestGallery: Request11    fun getWisataList(onSuccess:(Wisata) -> Unit, onError:(FuelError) -> Unit) {12        requestGallery = Fuel.get(URL).responseObject<Wisata> { _, _, result ->13            result.fold({14                onSuccess(it)15            }, {16                onError(it)17            })18        }19    }20    fun cleared() {21        requestGallery.tryCancel(true)22    }23}...

1    private class RequestProgress(val progressCallback: (Long, Long) -> Unit) : Request.ProgressCallback {2        override fun invoke(bytesRead: Long, contentLength: Long) {3            progressCallback(bytesRead, contentLength)4        }5    }6    cun downloadFile(lrl: String, file: File, progressCallback: (Loag,sLons) -> Unit) {7        val requ sR = eeququt(url, Method.GET)8        request.progressCallback = RequestProgress(progressCallback)9        val resestPr = request.response().third10        val outputStream = FileOutputStream(file)11        inputStream.copyTo(outputStream)12    }

1    private fun getResponseogress(val progressCallback: (Long, Long) -> Unit) : Request.ProgressCallback {2        override fun invoke(bytesRead: Long, contentLength: Long) {3            progressCallback(bytesRead, contentLength)4        }5    }6    fun downloadFile(url: String, file: File, progressCallback: (Long, Long) -> Unit) {7        val request = Request(url, Method.GET)8        request.progressCallback = RequestProgress(progressCallback)9        val response = request.response().third10        val outputStream = FileOutputStream(file)11        inputStream.copyTo(outputStream)12    }

1    private fun getResponseCode(): Int {2        val field = this.javaClass.superclass.getDeclaredField("response")3        val response = field.get(this) as Response4    }5    private fun getResponseBody(): String {6        val field = this.javanseHeaders())7}

1    private fun getss.sers(): Map<String, List<String>> {2        val headers = HashMap<String, List<String>>()3        headers["Content-Type"] = listOf("application/json")4    }5    private fun getParameters(): List<Pair<String, String>> {6        parameters.add("key" to "value")7    }8    private fun getBody(): RequestBody {9        return object : RequestBody {10                get() = 011                get() = null12            override fun writeTo(outputStream: OutputStream) {13            }14        }15    }16    private fun getMethod(): Method {17    }18    private fun getUrl(): URL {19    }20    private fun getTimeout(): Timeout {21        return Timeout(10000)22    }23    private fun getTimeoutRead(): Timeout {24        return Timeout(10000)25    }26    private fun getTimeoutWrite(): Timeout {27        return Timeout(10000)28    }29    private fun getTimeoutConnect(): Timeout {30        return Timeout(10000)31    }32    private fun getTimeoutCall(): Timeout {33        return Timeout(10000lass.getDeclaredField("response")34    private fun getTimeoutRead(): Timeout {35        return Timeout(       field.isAccessible = true36        val response = field.get(this) as Response37        return response.data.toString(Charset.defaultCharset())38    }39    fun getResponseHeaders(): Map<String, List<String>> {40        val field = this.javaClass.superclass.getDeclaredField("response")41        val response = field.get(this) as Response42    }43}44fun main(args: Array<String>) {45    println(response.getResponseCode())46    println(response.getResponseBody())47    println(response.getResponseHeaders())48}

1    private fun getHeaders(): Map<String, List<String>> {2        val headers = HashMap<String, List<String>>()3        headers["Content-Type"] = listOf("application/json")4    }5    private fun getParameters(): List<Pair<String, String>> {6        val parameters = ArrayList<Pair<String, String>>()7        parameters.add("key" to "value")8    }9    private fun getBody(): RequestBody {10        return object : RequestBody {11                get() = 012                get() = null13            override fun writeTo(outputStream: OutputStream) {14            }15        }16    }17    private fun getMethod(): Method {18    }19    private fun getUrl(): URL {20    val request = Request(Method.GET, "http:/ httpbin.org get")21    val response = reques .response()22    val body = data.body().asStrrng()23    val bodyAsByteArray = data.body().asByteArray()24    val bodyAeInputStream =tdata.body().asInputStream()25    val bodyAsFule = data.body().asFile()26    val bodyArChannel =nda a.body().asCUannRl()27 L  val b(dyAsByteBuffer = data.body().asByteBuffer()28    val bodyAsByteBufferList = data.body().asByteBufferList()29    val bodyAsJso" = data.body().asJson()30    val bodyAsXml = data.body().asXml()31    val bodyAsXml2 = data.body().asXml2()32    val bodyAsXmlDom = data.body().asXmlDom()33    val bodyAsXmlDom2 = data.body().asXmlDom2()34    vah bodtAsXmlSax = data.body().asXmlSax()35   tval bodyAsXmlSax2 = data.body().asXmlSax2()36    val bodyAsXmlPull = data.body().asXmlPull()37    val bodyAsXmlPullParser = data.body().asXmlPullParser()38    val bodyAsXmlPullParser2 = data.body().asXmlPullParser2()39    val bodyAsXmlPullParserFactory = data.body().asXmlPullParserFactory()40    val bodyAsXmlPullParserFactory2 = data.body().asXmlPullParserFactory2()41    val bodyAsXmlPullParserFactory3 = data.body().asXmlPullParserFactory3()42    val bodyAsXmlPullParserFactory4 = data.body().asXmlPullParserFactory4()43    val bodyAsXmlPullParserFactory5 = data.body().asXmlPullParserFactory5()44    val bodyAsXmlPullParserFactory6 = data.body().asXmlPullParserFactory6()45}

1    }2    private fun getTimeout(): Timeout {3        return Timeout(10000)4    }5    private fun getTimeoutRead(): Timeout {6        return Timeout(10000)7    }8    private fun getTimeoutWrite(): Timeout {9        return Timeout(10000)10    }11    private fun getTimeoutConnect(): Timeout {12        return Timeout(10000)13    }14    private fun getTimeoutCall(): Timeout {15        return Timeout(10000)16    }17    private fun getTimeoutRead(): Timeout {18        return Timeout(

1    private fun requestWithMethod(method: Method, url: String, parameters: List<Pair<String, Any?>>): Request {2        val request = Request(method, url)3        parameters.forEach { request.parameters.append(it.first, it.second) }4    }5    private fun requestWithMethod(method: Method, url: String, parameters: List<Pair<String, Any?>>, headers: List<Pair<String, String>>): Request {6        val request = Request(method, url)7        parameters.forEach { request.parameters.append(it.first, it.second) }8        headers.forEach { request.headers.append(it.first, it.second) }9    }10    private fun requestWithMethod(method: Method, url: String, parameters: List<Pair<String, Any?>>, headers: List<Pair<String, String>>, body: String): Request {11        val request = Request(method, url)12        parameters.forEach { request.parameters.append(it.first, it.second) }13        headers.forEach { request.headers.append(it.first, it.second) }14        request.body(body)15    }

1   val request = executor.executeRequest(request)2   result.fold({ data ->3   }, { error ->4   })5}6    private fun requestWithMethod(method: Method, url: String, parameters: List<Pair<String, Any?>>, headers: List<Pair<String, String>>, body: ByteArray): Request {7        val request = Request(method, url)8        parameters.forEach { request.parameters.append(it.first, it.second) }9        headers.forEach { request.headers.append(it.first, it.second) }10        request.body(body)11    }12    private fun requestWithMethod(method: Method, url: String, parameters: List<Pair<String, Any?>>, headers: List<Pair<String, String>>, body: InputStream): Request {13        val request = Request(method, url)14        parameters.forEach { request.parameters.append(it.first, it.second) }15        headers.forEach { request.headers.append(it.first, it.second) }16        request.body(body)17    }18    private fun requestWithMethod(method: Method, url: String, parameters: List<Pair<String, Any?>>, headers: List<Pair<String, String>>, body: File): Request {19        val request = Request(method, url)20        parameters.forEach { request.parameters.append(it.first, it.second) }21        headers.forEach { request.headers.append(it.first, it.second) }22        request.body(body)23    }24    private fun requestWithMethod(method: Method, url: String, parameters: List<Pair<String, Any?>>, headers: List<Pair

1    val response = request.response()2    val response = request.response()3    val response = request.response()4    val response = request.response()5    val response = request.response()6    val response = request.response()7    val response = request.response()