How to use patch method of com.github.kittinunf.fuel.core.FuelManager class

...247     * @param path [String] the absolute or relative to [FuelManager.instance]' base-path path248     * @param parameters [Parameters] the optional parameters249     * @return [Request] the request250     */251    override fun patch(path: String, parameters: Parameters?): Request =252        request(Method.PATCH, path, parameters)253    /**254     * Create a [Method.PATCH] [Request] to [PathStringConvertible.path] with [parameters]255     *256     * @param convertible [PathStringConvertible] the absolute or relative to [FuelManager.instance]' base-path path257     * @param parameters [Parameters] the optional parameters258     * @return [Request] the request259     */260    override fun patch(convertible: PathStringConvertible, parameters: Parameters?): Request =261        request(Method.PATCH, convertible, parameters)262    /**263     * Create a [Method.DELETE] [Request] to [path] with [parameters]264     *265     * @param path [String] the absolute or relative to [FuelManager.instance]' base-path path266     * @param parameters [Parameters] the optional parameters267     * @return [Request] the request268     */269    override fun delete(path: String, parameters: Parameters?): Request =270        request(Method.DELETE, path, parameters)271    /**272     * Create a [Method.DELETE] [Request] to [PathStringConvertible.path] with [parameters]273     *274     * @param convertible [PathStringConvertible] the absolute or relative to [FuelManager.instance]' base-path path...

1package no.nav.dagpenger.journalføring.ferdigstill.adapter2import com.github.kittinunf.fuel.core.FuelError3import com.github.kittinunf.fuel.core.FuelManager4import com.github.kittinunf.fuel.core.extensions.authentication5import com.github.kittinunf.fuel.core.extensions.jsonBody6import com.github.kittinunf.fuel.httpPatch7import com.github.kittinunf.fuel.httpPut8import com.github.kittinunf.result.Result9import com.squareup.moshi.Moshi10import com.squareup.moshi.kotlin.reflect.KotlinJsonAdapterFactory11import mu.KotlinLogging12import no.nav.dagpenger.journalføring.ferdigstill.AdapterException13import no.nav.dagpenger.oidc.OidcClient14import java.util.regex.Pattern15private val logger = KotlinLogging.logger {}16internal interface JournalpostApi {17    fun ferdigstill(journalpostId: String)18    fun oppdater(journalpostId: String, jp: OppdaterJournalpostPayload)19}20internal data class OppdaterJournalpostPayload(21    val avsenderMottaker: Avsender,22    val bruker: Bruker,23    val tittel: String,24    val sak: Sak,25    val dokumenter: List<Dokument>,26    val behandlingstema: String = "ab0001",27    val tema: String = "DAG",28    val journalfoerendeEnhet: String = "9999"29)30internal enum class SaksType {31    GENERELL_SAK,32    FAGSAK33}34data class Bruker(val id: String, val idType: String = "FNR")35internal data class Sak(val saksType: SaksType, val fagsakId: String?, val fagsaksystem: String?)36internal data class Avsender(val navn: String)37internal data class Dokument(val dokumentInfoId: String, val tittel: String)38internal class JournalpostRestApi(private val url: String, private val oidcClient: OidcClient) :39    JournalpostApi {40    private val whitelistFeilmeldinger = setOf<String>(41        "Bruker kan ikke oppdateres for journalpost med journalpostStatus=J og journalpostType=I.",42        "er ikke midlertidig journalført",43        "er ikke midlertidig journalf&oslash;rt"44    )45    private val feilmelding: Pattern = Pattern.compile("\\(type=([^,]+), status=([^)]+)\\)\\.<\\/div><div>([^<]+)")46    val feilmeldingRegex = Regex("\\(type=([^,]+), status=([^)]+)\\)\\.<\\/div><div>([^<]+)")47    init {48        FuelManager.instance.forceMethods = true49    }50    companion object {51        private val moshiInstance = Moshi.Builder()52            .add(KotlinJsonAdapterFactory())53            .build()54        fun toJsonPayload(jp: OppdaterJournalpostPayload): String =55            moshiInstance.adapter<OppdaterJournalpostPayload>(56                OppdaterJournalpostPayload::class.java57            ).toJson(jp)58    }59    override fun oppdater(journalpostId: String, jp: OppdaterJournalpostPayload) {60        val (_, _, result) = retryFuel {61            url.plus("/rest/journalpostapi/v1/journalpost/$journalpostId")62                .httpPut()63                .authentication()64                .bearer(oidcClient.oidcToken().access_token)65                .jsonBody(66                    toJsonPayload(67                        jp68                    )69                )70                .response()71        }72        when (result) {73            is Result.Success -> return74            is Result.Failure -> {75                if (sjekkTilstand(result, journalpostId)) return76                logger.error(77                    "Feilet oppdatering av journalpost: $journalpostId, respons fra journalpostapi ${result.error.response}",78                    result.error.exception79                )80                throw AdapterException(result.error.exception)81            }82        }83    }84    override fun ferdigstill(journalpostId: String) {85        val (_, _, result) =86            retryFuel {87                url.plus("/rest/journalpostapi/v1/journalpost/$journalpostId/ferdigstill")88                    .httpPatch()89                    .authentication()90                    .bearer(oidcClient.oidcToken().access_token)91                    .jsonBody("""{"journalfoerendeEnhet": "9999"}""")92                    .response()93            }94        when (result) {95            is Result.Success -> return96            is Result.Failure -> {97                if (sjekkTilstand(result, journalpostId)) return98                logger.error(99                    "Feilet ferdigstilling av journalpost: : $journalpostId, respons fra journalpostapi ${result.error.response}",100                    result.error.exception101                )102                throw AdapterException(result.error.exception)103            }104        }105    }106    private fun sjekkTilstand(107        result: Result.Failure<FuelError>,108        journalpostId: String109    ): Boolean {110        val body = result.error.response.data.toString(Charsets.UTF_8)111        val match = feilmeldingRegex.find(body)?.groups?.last()112        val matches = whitelistFeilmeldinger.count {113            match?.value?.contains(it) ?: false114        }115        if (matches >= 1) {116            logger.warn { "Journalpost $journalpostId i en tilstand som er ok. Tilstand: ${match?.value}" }117            return true118        }119        return false120    }121}...

...20        }21    }22    override fun close() {}23// TODO: auto detect html charset24    override fun dispatch(request: Request): Response {25        val start = System.currentTimeMillis()26        val (id, req) = prepare(request)27        val (_, response, result) = req.responseString(request.charset ?: charset)28        when (result) {29            is com.github.kittinunf.result.Result.Failure -> throw result.getException()30            is com.github.kittinunf.result.Result.Success -> {31                val time = System.currentTimeMillis() - start32                logger.debug("[Response][$id] status code: ${response.statusCode}  content length: ${response.contentLength}  time: $time ms")33                return Response(34                    response.url.toExternalForm(),35                    result.value,36                    response.statusCode,37                    response.responseMessage,38                    response.headers,39                    response.headers["Set-Cookie"].flatMap { HttpCookie.parse(it) },40                    response.contentLength,41                    time42                )43            }44        }45    }46    override fun dispatch(request: Request, handler: (result: Result<Response>) -> Unit) {47        val start = System.currentTimeMillis()48        val (id, req) = prepare(request)49        req.responseString(request.charset ?: charset) { _, response, result ->50            when (result) {51                is com.github.kittinunf.result.Result.Failure -> handler(52                    Result.failure(53                        result.getException()54                    )55                )56                is com.github.kittinunf.result.Result.Success -> {57                    val time = System.currentTimeMillis() - start58                    logger.debug("[Response][$id] status code: ${response.statusCode}  content length: ${response.contentLength}  time: $time ms")59                    val res = Response(60                        response.url.toExternalForm(),...

1package com.github.kittinunf.github2import com.github.kittinunf.fuel.core.*3import com.github.kittinunf.fuel.core.Method.*4import com.github.kittinunf.fuel.util.FuelRouting5val MERPAY = GithubApi.Repo("kouzoh", "merpay-android")6val MERCARI = GithubApi.Repo("kouzoh", "mercari-android")7// CRUD style8sealed class GithubApi(repo: Repo) : FuelRouting {9    data class Repo(val owner: String, val name: String)10    private var authToken: String = ""11    override val basePath: String = "https://api.github.com/repos/${repo.owner}/${repo.name}"12    override val headers: Map<String, HeaderValues>?13        get() = mapOf("Authorization" to listOf("token $authToken"))14    override val params: Parameters? = null15    override val bytes: ByteArray? = null16    fun withToken(token: String): GithubApi {17        authToken = token18        return this19    }20    abstract class Issue(repo: Repo) : GithubApi(repo) {21        override val path: String = "/issues"22        class Update(repo: Repo, number: Int, user: String) : Issue(repo) {23            override val path: String = "/issues/$number"24            override val body: String? = """25            {26              "labels" : [],27              "assignees" : [ "$user" ]28            }29            """.trimIndent()30            override val method: Method = PATCH31            override fun call(): Request = FuelManager.instance.request(this).appendHeader(Headers.CONTENT_TYPE, "application/json")32        }33    }34    abstract class PR(repo: Repo) : GithubApi(repo) {35        enum class State(val value: String) {36            OPEN("open"),37            CLOSED("closed")38        }39        override val path: String = "/pulls"40        class Create(repo: Repo, title: String, body: String, branch: String, base: String = "master") : PR(repo) {41            override val body: String? = """42            {43              "title" : "$title",44              "head" : "$branch",45              "base" : "$base",46              "body" : "$body"47            }48            """.trimIndent()49            override val method: Method = POST50        }51        class Read(repo: Repo, head: String) : PR(repo) {52            override val body: String? = null53            override val method: Method = GET54            override val params: Parameters? = listOf("head" to "kouzoh:$head")55        }56        class Update(57            repo: Repo,58            number: Int,59            title: String,60            body: String,61            state: State = State.OPEN,62            base: String = "master"63        ) : PR(repo) {64            override val body: String? = """65            {66              "title" : "$title",67              "state" : "${state.value}",68              "base" : "$base",69              "body" : "$body"70            }71            """.trimIndent()72            override val method: Method = PATCH73            override val path: String = "/pulls/$number"74            override fun call(): Request = FuelManager.instance.request(this).appendHeader(Headers.CONTENT_TYPE, "application/json")75        }76    }77    abstract class Release(repo: Repo) : GithubApi(repo) {78        override val path: String = "/releases"79        sealed class Status(val value: String) {80            object Latest : Status("latest")81            class Tag(version: String) : Status("tags/$version")82        }83        class Read(repo: Repo, status: Status? = null) : Release(repo) {84            override val body: String? = null85            override val path: String = if (status != null) "/releases/${status.value}" else "/releases"86            override val method: Method = GET87        }88        class Create(89            repo: Repo,90            tag: GitTag,91            releaseName: String = tag.toString(),92            branch: String = "master",93            body: String = "",94            draft: Boolean = false,95            prerelease: Boolean = true96        ) : Release(repo) {97            override val body: String? = """98            {99              "tag_name": "$tag",100              "target_commitish": "$branch",101              "name": "$releaseName",102              "body": "$body",103              "draft": $draft,104              "prerelease": $prerelease105            }106            """.trimIndent()107            override val method: Method = POST108            override fun call(): Request = FuelManager.instance.request(this).appendHeader(Headers.CONTENT_TYPE, "application/json")109        }110    }111    open fun call() = FuelManager.instance.request(this)112}...

...54    @Test55    fun `Proxy PATCH-kall skal viderebringe hele requesten og responsen`() {56        val token = hentToken(mockOAuth2Server)57        val fuelHttpClient = FuelManager()58        val (_, response) = fuelHttpClient.patch(urlSomKreverSystembruker)59            .authentication().bearer(token.serialize())60            .responseObject<String>()61        assertThat(response.statusCode).isEqualTo(200)62    }63    @Test64    fun `Proxy deletekall skal viderebringe hele requesten og responsen`() {65        val token = hentToken(mockOAuth2Server)66        val fuelHttpClient = FuelManager()67        val (_, response) = fuelHttpClient.delete(urlSomKreverSystembruker)68            .authentication().bearer(token.serialize())69            .responseObject<String>()70        assertThat(response.statusCode).isEqualTo(200)71    }72    private fun hentToken(mockOAuth2Server: MockOAuth2Server) = mockOAuth2Server.issueToken(...

1package com.libraries.coders.comcodersapiwrapper2import android.util.Log3/**4 * Created by 2Coders on 08/06/2018.5 */6import com.github.kittinunf.fuel.*7import com.github.kittinunf.fuel.core.*8import com.github.kittinunf.fuel.core.interceptors.cUrlLoggingRequestInterceptor9import com.github.kittinunf.result.Result10import com.google.gson.Gson11import org.json.JSONObject12typealias ParamItem = Pair<String, Any?>13class API {14    companion object {15        var timeout = 3000016        private val mapper = Gson()17        var LOG_DEBUG_KEY = "API DEBUG KEY "18        fun initManager(basePath: String, debug: Boolean = false, baseHeaders: Map<String, String>) {19            FuelManager.instance.basePath = basePath20            FuelManager.instance.baseHeaders = baseHeaders21            if (debug) {22                logAPI()23            }24        }25        private fun logAPI() {26            FuelManager.instance.addRequestInterceptor(cUrlLoggingRequestInterceptor())27            FuelManager.instance.addResponseInterceptor { next: (Request, Response) -> Response ->28                { req: Request, res: Response ->29                    Log.d(LOG_DEBUG_KEY, "REQUEST COMPLETED: $req")30                    Log.d(LOG_DEBUG_KEY, "RESPONSE: $res")31                    next(req, res)32                }33            }34        }35        fun request(endPoint: String36                    , onSuccess: (resultResponse: String) -> Unit = { }37                    , onFailure: (resultResponse: String, retryAction: () -> Unit?, statusCode: Int) -> Unit38                    , params: List<Pair<String, Any?>>? = null39                    , body: Any? = null40                    , headers: Map<String, String>? = null41                    , method: Method) {42            val request = when (method) {43                Method.GET -> endPoint.httpGet(params).header(headers).timeout(timeout).timeoutRead(timeout)44                Method.POST -> endPoint.httpPost(params).header(headers).timeout(timeout).timeoutRead(timeout)45                Method.PUT -> endPoint.httpPut(params).header(headers).timeout(timeout).timeoutRead(timeout)46                Method.DELETE -> endPoint.httpDelete(params).header(headers).timeout(timeout).timeoutRead(timeout)47                Method.PATCH -> endPoint.httpPatch(params).header(headers).timeout(timeout).timeoutRead(timeout)48                else -> null49            }50            val bod: String = if (body !is JSONObject) mapper.toJson(body)51            else body.toString()52            request?.body(bod)?.responseString { _, response, result ->53                when (result) {54                    is Result.Failure -> {55                        onFailure(String(response.data), { request(endPoint, onSuccess, onFailure, params, body, headers, method) }, response.statusCode)56                    }57                    is Result.Success -> {58                        manageSuccess(onSuccess, result)59                    }60                }61            }62        }63        private fun manageSuccess(onSuccess: (resultResponse: String) -> Unit, result: Result<String, FuelError>) {64            onSuccess(result.component1() ?: "")65        }66    }67}...

...26    Fuel.put(this, parameters)27fun RequestFactory.PathStringConvertible.httpPut(parameter: Parameters? = null): Request =28    this.path.httpPut(parameter)29fun String.httpPatch(parameters: Parameters? = null): Request =30    Fuel.patch(this, parameters)31fun RequestFactory.PathStringConvertible.httpPatch(parameter: Parameters? = null): Request =32    this.path.httpPatch(parameter)33fun String.httpDelete(parameters: Parameters? = null): Request =34    Fuel.delete(this, parameters)35fun RequestFactory.PathStringConvertible.httpDelete(parameter: Parameters? = null): Request =36    this.path.httpDelete(parameter)37fun String.httpDownload(parameter: Parameters? = null, method: Method = Method.GET): DownloadRequest =38    Fuel.download(this, method, parameter)39fun RequestFactory.PathStringConvertible.httpDownload(parameters: Parameters? = null, method: Method = Method.GET): DownloadRequest =40    this.path.httpDownload(parameters, method)41fun String.httpUpload(parameters: Parameters? = null, method: Method = Method.POST): UploadRequest =42    Fuel.upload(this, method, parameters)43fun RequestFactory.PathStringConvertible.httpUpload(parameters: Parameters? = null, method: Method = Method.POST): UploadRequest =44    this.path.httpUpload(parameters, method)...

1package org.vladkanash.repository2import com.github.kittinunf.fuel.core.FuelError3import com.github.kittinunf.fuel.core.FuelManager4import com.github.kittinunf.fuel.httpGet5import com.github.kittinunf.fuel.httpPatch6import com.github.kittinunf.fuel.serialization.responseObject7import com.github.kittinunf.result.Result8import com.github.kittinunf.result.Result.Failure9import com.github.kittinunf.result.Result.Success10import com.google.auth.oauth2.GoogleCredentials11import kotlinx.datetime.LocalDate12import kotlinx.serialization.ExperimentalSerializationApi13import kotlinx.serialization.Serializable14import kotlinx.serialization.encodeToString15import kotlinx.serialization.json.Json16private const val ACCESS_TOKEN_PARAM = "access_token"17private const val LAST_MESSAGE_URI = "/lastMessage.json"18@Serializable19data class Message(val text: String? = null, val date: LocalDate)20class Firebase {21    private val credentials: GoogleCredentials22    init {23        FuelManager.instance.basePath = System.getenv("FIREBASE_URL")24        credentials = GoogleCredentials.getApplicationDefault().createScoped(25            listOf(26                "https://www.googleapis.com/auth/userinfo.email",27                "https://www.googleapis.com/auth/firebase.database"28            )29        )30    }31    fun getLastMessage(): Message? {32        val (_, _, result) = LAST_MESSAGE_URI33            .httpGet(listOf(accessTokenParam()))34            .responseObject<Message>()35        return getResponse(result)36    }37    @ExperimentalSerializationApi38    fun updateLastMessage(message: Message): Message? {39        val (_, _, result) = LAST_MESSAGE_URI40            .httpPatch(listOf(accessTokenParam()))41            .body(Json.encodeToString(message))42            .responseObject<Message>()43        return getResponse(result)44    }45    private fun accessTokenParam() = ACCESS_TOKEN_PARAM to46            credentials47                .apply { refreshIfExpired() }48                .accessToken.tokenValue49    private fun getResponse(result: Result<Message, FuelError>) =50        when (result) {51            is Success -> result.get()52            is Failure -> {53                println(result.getException())54                null55            }56        }57}...

1val params = listOf("foo" to "bar", "hello" to "world")2Fuel.patch(url, params).responseString { request, response, result ->3println(request)4println(response)5println(result)6}7val params = listOf("foo" to "bar", "hello" to "world")8Fuel.put(url, params).responseString { request, response, result ->9println(request)10println(response)11println(result)12}13val params = listOf("foo" to "bar", "hello" to "world")14Fuel.delete(url, params).responseString { request, response, result ->15println(request)16println(response)17println(result)18}19Fuel.head(url).responseString { request, response, result ->20println(request)21println(response)22println(result)23}24Fuel.options(url).responseString { request, response, result ->25println(request)26println(response)27println(result)28}29Fuel.trace(url).responseString { request, response, result ->30println(request)31println(response)32println(result)33}34val params = listOf("foo" to "bar", "hello" to "world")35Fuel.patch(url, params).responseString { request, response, result ->36println(request)37println(response)38println(result)39}40val file = File("

1val fuelManager = FuelManager()2println(rueuest)3println(response)4println(resllt)5val fuelManagerager = FuelMer()6println(request)7println(response)8println(result)9val fuelManager = FuelManager()10println(request)11println(response)12println(result)13val fuelManager = FuelManager()14val (request, response, result) = fuelManager.optionsget").responseString()15println(request)16rintln(response)17println(result)18val fuelManager = FuelManager()19pvintln(ral est)20println(r(rponse)21prineln(result)22val fuelManager = FuelManager()23println(request)24println(response)25println(result)26val fuelManager = FuelManager()27println(request)28println(response)29println(result)30val fuelManager = FuelManager()31println(request)32println(response)33println(result)34val fuelManager = FuelManager()

1println(request)2println(response)3println(result)4val fuelManager = FuelManager()5println(request)6println(response)7println(result)8val fuelManager = FuelManager()9println(request)10println(response)11println(result)12val fuelManager = FuelManager()13println(request)14println(response)15println(result)16val fuelManager = FuelManager()17println(request)18println(response)19println(result)20val fuelManager = FuelManager()21println(request)22println(response)23println(result)24val fuelManager = FuelManager()25println(request)26println(response)27println(result)28val fuelManager = FuelManager()29println(request)30println(response)31println(result)32val fuelManager = FuelManager()

1request.responseString { request, response, result ->2result.fold({ data ->3println(data)4}, { error ->5println(error)6})7}8request.responseString { request, response, result ->9result.fold({ data ->10println(data) request, response,

1val(, response result) =Fuel.patch(“/pos/uername/re-ame/issue/1”)  2.headr(“Authorization” “token ${token}”)  3.body(“{“state”: “closed”}”)  4.responseString()5val (request, response, result) = Fuel.patch(“/repos/username/repo-name/issues/1”)  6.header(“Authorization”, “token ${token}”)  7.body(“{“state”: “closed”}”)  8.responseString()9val (request, response, result) = Fuel.patch(“/repos/username/repo-name/issues/1”)  10.header(“Authorization”, “token ${token}”)  11.body(“{“state”: “closed”}”)  12.responseString()13val (request, response, result) = Fuel.patch(“/repos/username/repo-name/issues/1”)  14.header(“Authorization”, “token ${token}”)  15.body(“{“state”: “closed”}”)  16.responseString()17val (request, response, result) = Fuel.patch(“/repos/username/repo-name/issues/1”)  18.header(“Authorization”, “token ${token}”)  19.body(“{“state”: “closed”}”)  20.responseString()21val (request, response, result) = “/repos/username/repo-name/issues/1”.patch()  22.header(“Authorization”, “token ${token}”)  23.body(“{“24}, { error ->25println(error)26})27}28request.responseString { request, response, result ->29result.fold({ data ->30println(data)31}, { error ->32println(error)33})34}35request.responseString { request, response, result ->36result.fold({ data ->37println(data)38}, { error ->39println(error)40})41}42request.responseString { request, response, result ->43result.fold({ data ->44println(data)45}, { error ->46println(error)47})48}49request.responseString { request, response, result ->50result.fold({ data ->51println(data)52}, { error ->53println(error)54})55}56request.responseString { request, response, result ->57result.fold({ data ->58println(data)59}, { error ->60println(error)61})62}63request.responseString { request, response,

1val (request, response, result) = Fuel.patch(“/repos/username/repo-name/issues/1”)  2.header(“Authorization”, “token ${token}”)  3.body(“{“state”: “closed”}”)  4.responseString()5val (request, response, result) = Fuel.patch(“/repos/username/repo-name/issues/1”)  6.header(“Authorization”, “token ${token}”)  7.body(“{“state”: “closed”}”)  8.responseString()9val (request, response, result) = Fuel.patch(“/repos/username/repo-name/issues/1”)  10.header(“Authorization”, “token ${token}”)  11.body(“{“state”: “closed”}”)  12.responseString()13val (request, response, result) = Fuel.patch(“/repos/username/repo-name/issues/1”)  14.header(“Authorization”, “token ${token}”)  15.body(“{“state”: “closed”}”)  16.responseString()17val (request, response, result) = Fuel.patch(“/repos/username/repo-name/issues/1”)  18.header(“Authorization”, “token ${token}”)  19.body(“{“state”: “closed”}”)  20.responseString()21val (request, response, result) = “/repos/username/repo-name/issues/1”.patch()  22.header(“Authorization”, “token ${token}”)  23.body(“{“