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

1package dev.dewy.mojangkt2import com.github.kittinunf.fuel.core.FuelManager3import com.github.kittinunf.fuel.gson.jsonBody4import com.github.kittinunf.fuel.gson.responseObject5import com.github.kittinunf.fuel.httpDelete6import com.github.kittinunf.fuel.httpGet7import com.github.kittinunf.fuel.httpPost8import com.github.kittinunf.fuel.httpPut9import com.github.kittinunf.result.Result10import com.google.gson.Gson11import com.google.gson.JsonObject12import java.util.Base6413import java.util.UUID14import java.util.regex.Pattern15import kotlin.coroutines.resume16import kotlin.coroutines.resumeWithException17import kotlin.coroutines.suspendCoroutine18class MojangKt {19    private val gson = Gson()20    @Suppress("UNUSED")21    var token = ""22        set(value) {23            field = value24            if (value.isEmpty()) {25                FuelManager.instance.baseHeaders = emptyMap()26                return27            }28            FuelManager.instance.baseHeaders = mapOf(29                "Authorization" to "Bearer $value"30            )31        }32    suspend fun getPlayerFromName(name: String): PrimitivePlayer = suspendCoroutine { cont ->33        "https://api.mojang.com/users/profiles/minecraft/$name"34            .httpGet()35            .responseObject<PrimitivePlayer> { _, _, result ->36                when (result) {37                    is Result.Failure -> {38                        cont.resumeWithException(result.getException())39                    }40                    is Result.Success -> {41                        cont.resume(result.value)42                    }43                }44            }45    }46    suspend fun getPlayersFromNames(names: List<String>): List<PrimitivePlayer> = suspendCoroutine { cont ->47        "https://api.mojang.com/profiles/minecraft"48            .httpPost()49            .jsonBody(50                names, gson51            )52            .responseObject<List<PrimitivePlayer>> { _, _, result ->53                when (result) {54                    is Result.Failure -> {55                        cont.resumeWithException(result.getException())56                    }57                    is Result.Success -> {58                        cont.resume(result.value)59                    }60                }61            }62    }63    suspend fun getProfileFromUuid(uuid: String): Profile = suspendCoroutine { cont ->64        "https://sessionserver.mojang.com/session/minecraft/profile/$uuid"65            .httpGet()66            .responseString {_, _, result ->67                when (result) {68                    is Result.Failure -> {69                        cont.resumeWithException(result.getException())70                    }71                    is Result.Success -> {72                        val obj = gson.fromJson(result.value, JsonObject::class.java)73                        val encodedProperties = obj["properties"].asJsonArray[0].asJsonObject["value"].asString74                        val id = obj["id"].asString75                        val name = obj["name"].asString76                        val legacy = obj.has("legacy")77                        var skinUrl = ""78                        var skinType = getSkinType(id)79                        var capeUrl = ""80                        if (encodedProperties != null) {81                            val texturesObj = gson.fromJson(String(Base64.getDecoder()82                                .decode(encodedProperties)), JsonObject::class.java)83                                .getAsJsonObject("textures")84                            val skinObj = texturesObj.getAsJsonObject("SKIN")85                            val capeObj = texturesObj.getAsJsonObject("CAPE")86                            if (skinObj != null) {87                                skinUrl = skinObj["url"].asString88                                skinType = if (skinObj.has("metadata")) SkinType.SLIM else SkinType.DEFAULT89                            }90                            if (capeObj != null) {91                                capeUrl = capeObj["url"].asString92                            }93                        }94                        cont.resume(Profile(PrimitivePlayer(id, name, legacy), Skin(skinUrl, skinType), capeUrl))95                    }96                }97            }98    }99    suspend fun getNameHistory(uuid: String): NameHistory = suspendCoroutine { cont ->100        "https://api.mojang.com/user/profiles/$uuid/names"101            .httpGet()102            .responseObject<List<NameHistoryNode>> { _, _, result ->103                when (result) {104                    is Result.Failure -> {105                        cont.resumeWithException(result.getException())106                    }107                    is Result.Success -> {108                        cont.resume(NameHistory(result.value))109                    }110                }111            }112    }113    suspend fun changeName(name: String) = suspendCoroutine<Unit> { cont ->114        "https://api.minecraftservices.com/minecraft/profile/name/$name"115            .httpPut()116            .response { _, response, result ->117                when (result) {118                    is Result.Failure -> {119                        when (response.statusCode) {120                            400 -> cont.resumeWithException(InvalidNameException("Name must follow Mojang's name rules."))121                            401 -> cont.resumeWithException(UnauthorizedAccessException("Token expired or incorrect."))122                            403 -> cont.resumeWithException(UnavailableNameException("Name either taken or is in some other way unavailable."))123                            500 -> cont.resumeWithException(TimedOutException("Timed out."))124                        }125                    }126                    is Result.Success -> {127                        cont.resume(Unit)128                    }129                }130            }131    }132    suspend fun resetSkin(uuid: String) = suspendCoroutine<Unit> { cont ->133        "https://api.mojang.com/user/profile/$uuid/skin"134            .httpDelete()135            .responseString { _, _, result ->136                when (result) {137                    is Result.Failure -> {138                        cont.resumeWithException(result.getException())139                    }140                    is Result.Success -> {141                        val errorObj = gson.fromJson(result.value, JsonObject::class.java)142                        if (errorObj != null)143                            cont.resumeWithException(MojangApiException("${errorObj["error"].asString}: ${errorObj["errorMessage"].asString}"))144                        else145                            cont.resume(Unit)146                    }147                }148            }149    }150    suspend fun getBlockedServers(): List<String> = suspendCoroutine { cont ->151        "https://sessionserver.mojang.com/blockedservers"152            .httpGet()153            .responseString { _, _, result ->154                when (result) {155                    is Result.Failure -> {156                        cont.resumeWithException(result.getException())157                    }158                    is Result.Success -> {159                        cont.resume(result.value.split("\n"))160                    }161                }162            }163    }164    @Suppress("NAME_SHADOWING")165    private fun getSkinType(uuid: String): SkinType {166        val uuid = UUID.fromString(Pattern.compile("(\\w{8})(\\w{4})(\\w{4})(\\w{4})(\\w{12})")167            .matcher(uuid.replace("-", "")).replaceAll("$1-$2-$3-$4-$5"))168        return if ((uuid.hashCode() and 1) != 0)169            SkinType.SLIM170        else171            SkinType.DEFAULT172    }173}...

...77            }78        }79        return result80    }81    override fun deleteIssues(keys: List<String>) {82        for (key in keys) {83            val (_, _, result) = "/rest/api/latest/issue/$key"84                .httpDelete(listOf(Pair("deleteSubtasks", "true")))85                .responseUnit()86            when (result) {87                is Failure -> {88                    logger.error { String(result.error.errorData) }89                    throw JiraClientException("Couldn't delete issue with key $key", result.getException())90                }91                is Success -> {92                    logger.debug { "Issue $key was deleted" }93                }94            }95        }96    }97    override fun createIssues(payload: List<Map<String, Any>>): List<String> {98        val body = mapOf(Pair("issueUpdates", payload))99        val (_, _, result) = "/rest/api/latest/issue/bulk"100            .httpPost()101            .body(Gson().toJson(body))102            .responseObject<HashMap<String, Any>>()103        when (result) {104            is Failure -> {105                logger.error { String(result.error.errorData) }106                throw JiraClientException("Couldn't create issues in bulk", result.getException())...

...53    fun storeProxies(dao: ProxyDao): Job {54        // slow but simple55        return GlobalScope.launch(Dispatchers.IO) {56            val blackList = HttpUtils.getBlackList().filter { it.added > System.currentTimeMillis() - 1000 * 60 * 60 * 24 }57            dao.deleteAll()58            dao.insertAll(blackList)59            dao.insertAll(untrustedProxyList)60            currentProxy?.let {61                it.type = "current"62                dao.insert(it)63            }64        }65    }66    fun loadProxies(dao: ProxyDao): Job {67        return GlobalScope.launch(Dispatchers.IO) {68            HttpUtils.setProxies(dao.getAll())69        }70    }71    suspend fun call4Json(method: HttpMethod, url: String, withProxy: Boolean = false): Json? {...

...47    }48    inline fun <reified T : Any> post(url: String, body: Any): LiveData<NetResp<T>> {49        return doRequest(url.httpPost().jsonBody(body))50    }51    inline fun <reified T : Any> delete(url: String, body: Any): LiveData<NetResp<T>> {52        return doRequest(url.httpDelete().jsonBody(body))53    }54    inline fun <reified T : Any> doRequest(request: Request): LiveData<NetResp<T>> {55        var result: NetResp<T> by Delegates.notNull()56        var resp = MutableLiveData<NetResp<T>>()57        GlobalScope.launch(Dispatchers.Main) {58            request.executionOptions.responseValidator = {59                true60            }61            withContext(Dispatchers.IO) {62                var respObj = request.responseObject<NetResp<T>>()63                if (respObj.third.component2() == null) {64                    val respData = respObj.third.get()65                    respData.httpCode = respObj.second.statusCode...

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}...

1package com.rafaelrain.headbank.javalinbackend2import com.github.kittinunf.fuel.core.FuelManager3import com.github.kittinunf.fuel.core.extensions.jsonBody4import com.github.kittinunf.fuel.httpDelete5import com.github.kittinunf.fuel.httpGet6import com.github.kittinunf.fuel.httpPost7import com.github.kittinunf.fuel.jackson.responseObject8import com.rafaelrain.headbank.javalinbackend.model.Gender9import com.rafaelrain.headbank.javalinbackend.model.User10import com.rafaelrain.headbank.javalinbackend.util.inject11import org.junit.jupiter.api.*12import org.junit.jupiter.api.Assertions.assertEquals13@TestInstance(TestInstance.Lifecycle.PER_CLASS)14@DisplayName("User Tests")15class UserTest {16    private lateinit var application: Application17    @BeforeAll18    fun setup() {19        Application.start()20        application = inject<Application>().value21        FuelManager.instance.basePath = "http://localhost:3333"22    }23    @AfterAll24    fun stop() {25        application.stop()26    }27    @Test28    fun `should get success when creating the user`() {29        assertDoesNotThrow {30            "/users"31                .httpPost()32                .header("key", "defaultKey")33                .jsonBody(34                    """ 35                    {36                        "name": "joaozinho",37                        "gender" : "MALE",38                        "money": "500"39                    }40                """.trimIndent()41                ).response()42        }43    }44    @Test45    fun `should get error for not supply the key`() {46        val (_, _, result) = "/users/joaozinho".httpGet().responseObject<User>()47        assertEquals(401, result.component2()!!.response.statusCode)48    }49    @Test50    fun `should return the user without errors`() {51        val (_, _, result) = "/users/joaozinho"52            .httpGet()53            .header("key", "defaultKey")54            .responseObject<User>()55        assertEquals(56            User("joaozinho", Gender.MALE, 500),57            result.get()58        )59    }60    @Test61    fun `should get error for non-existing user`() {62        val (_, _, result) = "/users/aaaaaaaaa"63            .httpGet()64            .header("key", "defaultKey")65            .responseObject<User>()66        val (_, error) = result67        assertEquals(404, error!!.response.statusCode)68    }69    @Test70    fun `should get no error when deleting a user`() {71        assertDoesNotThrow {72            "/users/joaozinho"73                .httpDelete()74                .header("key", "defaultKey")75                .response()76        }77    }78}...

...34        api.stop()35    }36    @Test @Order(1)37    fun `1 DELETE users removes the specified user`() {38        val (_, responseDelete, resultDelete) = Fuel.delete("users/806122948").responseObject<String>()39        Assertions.assertEquals(204, responseDelete.statusCode)40        val (_, _, resultGet) = Fuel.get("users").responseObject<List<BasicUserAdapter>>()41        Assertions.assertTrue(resultGet.get().none { it.account.cvu == "806122948" })42    }43}...

...28        Fuel.put("/" + "todos" + "/" + capture_id)29            .body(Gson().toJson(body, Todo::class.java))30            .responseObject(handler)31    }32    fun deleteTodosById(capture_id: Int, handler: (Request, Response, Result<Unit, FuelError>) -> Unit) {33        Fuel.delete("/" + "todos" + "/" + capture_id)34            .responseObject(handler)35    }36}...

1import com.github.kittinunf.fuel.core.FuelManager2import com.github.kittinunf.fuel.core.FuelManager3import com.github.kittinunf.fuel.core.FuelManager4import com.github.kittinunf.fuel.core.FuelManager5import com.github.kittinunf.fuel.core.FuelManager6import com.github.kittinunf.fuel.core.FuelManager7import com.github.kittinunf.fuel.core.FuelManager8import com.github.kittinunf.fuel.core.FuelManager9import com.github.kittinunf.fuel.core.FuelManager10import com.github.kittinunf.fuel.core.FuelManager11import com.github.kittinunf.fuel.core.FuelManager12import com.github.kittinunf.fuel.core.FuelManager13import com.github.kittinunf.fuel.core.FuelManager14import com.github.kittinunf.fuel.core.Fuel

1FuelManager.instance.baseHeaders = mapOf("Content-Type" to "application/json; charset=utf-8")2FuelManager.instance.baseParams = listOf("userId" to "2")3FuelManager.instance.baseHeaders = mapOf("Content-Type" to "application/json; charset=utf-8")4FuelManager.instance.baseParams = listOf("userId" to "2")5FuelManager.instance.baseHeaders = mapOf("Content-Type" to "application/json; charset=utf-8")6FuelManager.instance.baseParams = listOf("userId" to "2")7FuelManager.instance.baseHeaders = mapOf("Content-Type" to "application/json; charset=utf-8")8FuelManager.instance.baseParams = listOf("userId" to "2")9FuelManager.instance.baseHeaders = mapOf("Content-Type" to "application/json; charset=utf-8")10FuelManager.instance.baseParams = listOf("userId" to "2")11FuelManager.instance.baseHeaders = mapOf("Content-Type" to "application/json; charset=utf-8")12FuelManager.instance.baseParams = listOf("userId" to "2")13FuelManager.instance.baseHeaders = mapOf("Content-Type" to "application/json; charset=utf-8")14FuelManager.instance.baseParams = listOf("userId" to "2")15FuelManager.instance.baseHeaders = mapOf("Content-Type" to "application/json; charset=utf-8")16FuelManager.instance.baseParams = listOf("userId" to "2")17FuelManager.instance.baseHeaders = mapOf("Content-Type" to "application/json; charset=utf-8")18FuelManager.instance.baseParams = listOf("userId" to "2")19FuelManager.instance.baseHeaders = mapOf("Content-Type" to "application/json; charset=utf-8")

1FuelManager.instance.baseHeaders = mapOf("Content-Type" to "application/json")2FuelManager.instance.baseParams = listOf("format" to "json")3FuelManager.instance.baseHeaders = mapOf("Content-Type" to "application/json")4FuelManager.instance.baseParams = listOf("format" to "json")5FuelManager.instance.baseHeaders = mapOf("Content-Type" to "application/json")6FuelManager.instance.baseParams = listOf("format" to "json")7FuelManager.instance.baseHeaders = mapOf("Content-Type" to "application/json")8FuelManager.instance.baseParams = listOf("format" to "json")9FuelManager.instance.baseHeaders = mapOf("Content-Type" to "application/json")10FuelManager.instance.baseParams = listOf("format" to "json")11FuelManager.instance.baseHeaders = mapOf("Content-Type" to "application/json")12FuelManager.instance.baseParams = listOf("format" to "json")13FuelManager.instance.baseHeaders = mapOf("Content-Type" to "application/json")14FuelManager.instance.baseParams = listOf("format" to "json")15FuelManager.instance.baseHeaders = mapOf("Content-Type" to "application/json")16FuelManager.instance.baseParams = listOf("format" to "json")17FuelManager.instance.baseHeaders = mapOf("Content-Type" to "application/json")18FuelManager.instance.baseParams = listOf("format" to "json")19FuelManager.instance.baseHeaders = mapOf("Content-Type" to "application/json")20FuelManager.instance.baseParams = listOf("format" to "json")21FuelManager.instance.baseHeaders = mapOf("Content-Type" to "application/json")22FuelManager.instance.baseParams = listOf("format" to "json")

1}2}3}4}5}6}7FuelManager.instance.get("/get").response { request, response, result ->8}9FuelManager.instance.post("/post").response { request, response, result ->10}11FuelManager.instance.delete("/delete").response { request, response, result ->12}13FuelManager.instance.put("/put").response { request, response, result ->14}

1FuelManager.instance.baseHeaders = mapOf("Content-Type" to "application/json")2FuelManager.instance.baseParams = listOf("foo" to "bar")3val (request, response, result) = "/posts/1".httpDelete().responseString()4"/posts/1".httpDelete().responseString { request, response, result ->5}6"/posts/1".httpDelete(listOf("foo" to "bar")).responseString { request, response, result ->7}8"/posts/1".httpDelete(listOf("foo" to "bar"), headers = mapOf("Content-Type" to "application/json")).responseString { request, response, result ->9}10}11}12}

1FuelManager.instance.baseHeaders = mapOf("Content-Type" to "application/json")2FuelManager.instance.baseParams = listOf("userId" to 1)3Fuel.delete("posts/1").responseString { request, response, result ->4    println(request)5    println(response)6    println(result.get())7}8    println(request)9    println(response)10    println(result.get())11}12FuelManager.instance.baseHeaders = mapOf("Content-Type" to "application/json")13Fuel.delete("posts/1").responseString { request, response, result ->14    println(request)15    println(response)16    println(result.get())17}18FuelManager.instance.baseHeaders = mapOf("Content-Type" to "application/json")19FuelManager.instance.baseParams = listOf("userId" to 1)20Fuel.delete("posts/1").responseString { request, response, result ->21    println(request)22    println(response)23    println(result.get())24}25FuelManager.instance.baseHeaders = mapOf("Content-Type" to "application/json")26FuelManager.instance.baseParams = listOf("userId" to 1)27Fuel.delete("posts/1").timeout(5000).responseString { request, response, result ->28    println(request)29    println(response)30    println(result.get())31}32FuelManager.instance.baseHeaders = mapOf("Content-Type" to "application/json")

1FuelManager.instance.delete(url, params, headers)2FuelManager.instance.delete(url, params, headers, handler)3FuelManager.instance.delete(url, params, headers, handler, progressHandler)4FuelManager.instance.delete(url, params, headers, handler, progressHandler, tag)5FuelManager.instance.delete(url, params, headers, handler, progressHandler, tag, timeout)6FuelManager.instance.delete(url, params, headers, handler, progressHandler, tag, timeout, timeoutRead)7FuelManager.instance.delete(url, params, headers, handler, progressHandler, tag, timeout, timeoutRead, timeoutWrite)8FuelManager.instance.delete(url, params, headers, handler, progressHandler, tag, timeout, timeoutRead, timeoutWrite, followRedirects)9FuelManager.instance.delete(url, params, headers, handler, progressHandler, tag, timeout, timeoutRead, timeoutWrite, followRedirects, allowRedirects)10FuelManager.instance.delete(url, params, headers, handler, progressHandler, tag, timeout, timeoutRead, timeoutWrite, followRedirects, allowRedirects, socketFactory)11FuelManager.instance.delete(url, params, headers, handler, progressHandler, tag, timeout, timeoutRead, timeoutWrite, followRedirects, allowRedirects, socketFactory, hostnameVerifier)