How to use String.httpDownload method of com.github.kittinunf.fuel.Fuel class

Best Fuel code snippet using com.github.kittinunf.fuel.Fuel.String.httpDownload

MainActivity.kt

Source:MainActivity.kt Github

copy

Full Screen

1package com.example.fuel2import android.os.Bundle3import android.os.Handler4import android.util.Log5import androidx.appcompat.app.AppCompatActivity6import com.github.kittinunf.fuel.Fuel7import com.github.kittinunf.fuel.core.Method8import com.github.kittinunf.fuel.core.FuelError9import com.github.kittinunf.fuel.core.FileDataPart10import com.github.kittinunf.fuel.core.FuelManager11import com.github.kittinunf.fuel.core.ResponseDeserializable12import com.github.kittinunf.fuel.core.extensions.authentication13import com.github.kittinunf.fuel.core.extensions.cUrlString14import com.github.kittinunf.fuel.coroutines.awaitStringResponseResult15import com.github.kittinunf.fuel.gson.responseObject16import com.github.kittinunf.fuel.httpDelete17import com.github.kittinunf.fuel.httpGet18import com.github.kittinunf.fuel.httpPost19import com.github.kittinunf.fuel.httpPut20import com.github.kittinunf.fuel.livedata.liveDataObject21import com.github.kittinunf.fuel.rx.rxObject22import com.github.kittinunf.fuel.stetho.StethoHook23import com.github.kittinunf.result.Result24import com.google.gson.Gson25import com.google.gson.reflect.TypeToken26import io.reactivex.android.schedulers.AndroidSchedulers27import io.reactivex.disposables.CompositeDisposable28import io.reactivex.schedulers.Schedulers29import kotlinx.android.synthetic.main.activity_main.mainAuxText30import kotlinx.android.synthetic.main.activity_main.mainClearButton31import kotlinx.android.synthetic.main.activity_main.mainGoButton32import kotlinx.android.synthetic.main.activity_main.mainGoCoroutineButton33import kotlinx.android.synthetic.main.activity_main.mainResultText34import kotlinx.coroutines.CoroutineStart35import kotlinx.coroutines.Dispatchers36import kotlinx.coroutines.GlobalScope37import kotlinx.coroutines.launch38import java.io.File39import java.io.Reader40class MainActivity : AppCompatActivity() {41 private val TAG = MainActivity::class.java.simpleName42 private val bag by lazy { CompositeDisposable() }43 override fun onCreate(savedInstanceState: Bundle?) {44 super.onCreate(savedInstanceState)45 setContentView(R.layout.activity_main)46 FuelManager.instance.apply {47 basePath = "http:/​/​httpbin.org"48 baseHeaders = mapOf("Device" to "Android")49 baseParams = listOf("key" to "value")50 hook = StethoHook("Fuel Sample App")51/​/​ addResponseInterceptor { loggingResponseInterceptor() }52 }53 mainGoCoroutineButton.setOnClickListener {54 GlobalScope.launch(Dispatchers.Main, CoroutineStart.DEFAULT) {55 executeCoroutine()56 }57 }58 mainGoButton.setOnClickListener {59 execute()60 }61 mainClearButton.setOnClickListener {62 mainResultText.text = ""63 mainAuxText.text = ""64 }65 }66 override fun onDestroy() {67 super.onDestroy()68 bag.clear()69 }70 private fun execute() {71 httpGet()72 httpPut()73 httpPost()74 httpPatch()75 httpDelete()76 httpDownload()77 httpUpload()78 httpBasicAuthentication()79 httpListResponseObject()80 httpResponseObject()81 httpGsonResponseObject()82 httpCancel()83 httpRxSupport()84 httpLiveDataSupport()85 }86 private suspend fun executeCoroutine() {87 httpGetCoroutine()88 }89 private suspend fun httpGetCoroutine() {90 val (request, response, result) = Fuel.get("/​get", listOf("userId" to "123")).awaitStringResponseResult()91 Log.d(TAG, response.toString())92 Log.d(TAG, request.toString())93 update(result)94 }95 private fun httpCancel() {96 val request = Fuel.get("/​delay/​10")97 .interrupt { Log.d(TAG, it.url.toString() + " is interrupted") }98 .responseString { _, _, _ -> /​* noop */​ }99 Handler().postDelayed({ request.cancel() }, 1000)100 }101 private fun httpResponseObject() {102 "https:/​/​api.github.com/​repos/​kittinunf/​Fuel/​issues/​1"103 .httpGet()104 .also { Log.d(TAG, it.cUrlString()) }105 .responseObject(Issue.Deserializer()) { _, _, result -> update(result) }106 }107 private fun httpListResponseObject() {108 "https:/​/​api.github.com/​repos/​kittinunf/​Fuel/​issues"109 .httpGet()110 .also { Log.d(TAG, it.cUrlString()) }111 .responseObject(Issue.ListDeserializer()) { _, _, result -> update(result) }112 }113 private fun httpGsonResponseObject() {114 "https:/​/​api.github.com/​repos/​kittinunf/​Fuel/​issues/​1"115 .httpGet()116 .also { Log.d(TAG, it.cUrlString()) }117 .responseObject<Issue> { _, _, result -> update(result) }118 }119 private fun httpGet() {120 Fuel.get("/​get", listOf("foo" to "foo", "bar" to "bar"))121 .also { Log.d(TAG, it.cUrlString()) }122 .responseString { _, _, result -> update(result) }123 "/​get"124 .httpGet()125 .also { Log.d(TAG, it.cUrlString()) }126 .responseString { _, _, result -> update(result) }127 }128 private fun httpPut() {129 Fuel.put("/​put", listOf("foo" to "foo", "bar" to "bar"))130 .also { Log.d(TAG, it.cUrlString()) }131 .responseString { _, _, result -> update(result) }132 "/​put"133 .httpPut(listOf("foo" to "foo", "bar" to "bar"))134 .also { Log.d(TAG, it.cUrlString()) }135 .responseString { _, _, result -> update(result) }136 }137 private fun httpPost() {138 Fuel.post("/​post", listOf("foo" to "foo", "bar" to "bar"))139 .also { Log.d(TAG, it.cUrlString()) }140 .responseString { _, _, result -> update(result) }141 "/​post"142 .httpPost(listOf("foo" to "foo", "bar" to "bar"))143 .also { Log.d(TAG, it.cUrlString()) }144 .responseString { _, _, result -> update(result) }145 }146 private fun httpPatch() {147 val manager = FuelManager().apply {148 basePath = "http:/​/​httpbin.org"149 baseHeaders = mapOf("Device" to "Android")150 baseParams = listOf("key" to "value")151 }152 manager.forceMethods = true153 manager.request(Method.PATCH, "/​patch", listOf("foo" to "foo", "bar" to "bar"))154 .also { Log.d(TAG, it.cUrlString()) }155 .responseString { _, _, result -> update(result) }156 }157 private fun httpDelete() {158 Fuel.delete("/​delete", listOf("foo" to "foo", "bar" to "bar"))159 .also { Log.d(TAG, it.cUrlString()) }160 .responseString { _, _, result -> update(result) }161 "/​delete"162 .httpDelete(listOf("foo" to "foo", "bar" to "bar"))163 .also { Log.d(TAG, it.cUrlString()) }164 .responseString { _, _, result -> update(result) }165 }166 private fun httpDownload() {167 val n = 100168 Fuel.download("/​bytes/​${1024 * n}")169 .fileDestination { _, _ -> File(filesDir, "test.tmp") }170 .progress { readBytes, totalBytes ->171 val progress = "$readBytes /​ $totalBytes"172 runOnUiThread { mainAuxText.text = progress }173 Log.v(TAG, progress)174 }175 .also { Log.d(TAG, it.toString()) }176 .responseString { _, _, result -> update(result) }177 }178 private fun httpUpload() {179 Fuel.upload("/​post")180 .add {181 /​/​ create random file with some non-sense string182 val file = File(filesDir, "out.tmp")183 file.writer().use { writer ->184 repeat(100) {185 writer.appendln("abcdefghijklmnopqrstuvwxyz")186 }187 }188 FileDataPart(file)189 }190 .progress { writtenBytes, totalBytes ->191 Log.v(TAG, "Upload: ${writtenBytes.toFloat() /​ totalBytes.toFloat()}")192 }193 .also { Log.d(TAG, it.toString()) }194 .responseString { _, _, result -> update(result) }195 }196 private fun httpBasicAuthentication() {197 val username = "U$3|2|\\|@me"198 val password = "P@$\$vv0|2|)"199 Fuel.get("/​basic-auth/​$username/​$password")200 .authentication()201 .basic(username, password)202 .also { Log.d(TAG, it.cUrlString()) }203 .responseString { _, _, result -> update(result) }204 "/​basic-auth/​$username/​$password".httpGet()205 .authentication()206 .basic(username, password)207 .also { Log.d(TAG, it.cUrlString()) }208 .responseString { _, _, result -> update(result) }209 }210 private fun httpRxSupport() {211 val disposable = "https:/​/​api.github.com/​repos/​kittinunf/​Fuel/​issues/​1"212 .httpGet()213 .rxObject(Issue.Deserializer())214 .subscribeOn(Schedulers.newThread())215 .observeOn(AndroidSchedulers.mainThread())216 .subscribe { result -> Log.d(TAG, result.toString()) }217 bag.add(disposable)218 }219 private fun httpLiveDataSupport() {220 "https:/​/​api.github.com/​repos/​kittinunf/​Fuel/​issues/​1"221 .httpGet()222 .liveDataObject(Issue.Deserializer())223 .observeForever { result -> Log.d(TAG, result.toString()) }224 }225 private fun <T : Any> update(result: Result<T, FuelError>) {226 result.fold(success = {227 mainResultText.append(it.toString())228 }, failure = {229 mainResultText.append(String(it.errorData))230 })231 }232 data class Issue(233 val id: Int = 0,234 val title: String = "",235 val url: String = ""236 ) {237 class Deserializer : ResponseDeserializable<Issue> {238 override fun deserialize(reader: Reader) = Gson().fromJson(reader, Issue::class.java)!!239 }240 class ListDeserializer : ResponseDeserializable<List<Issue>> {241 override fun deserialize(reader: Reader): List<Issue> {242 val type = object : TypeToken<List<Issue>>() {}.type243 return Gson().fromJson(reader, type)244 }245 }246 }247}...

Full Screen

Full Screen

RequestStringExtensionTest.kt

Source:RequestStringExtensionTest.kt Github

copy

Full Screen

1package com.github.kittinunf.fuel2import com.github.kittinunf.fuel.core.FuelError3import com.github.kittinunf.fuel.core.FuelManager4import com.github.kittinunf.fuel.core.Method5import com.github.kittinunf.fuel.core.Request6import com.github.kittinunf.fuel.core.Response7import org.hamcrest.CoreMatchers.notNullValue8import org.hamcrest.CoreMatchers.nullValue9import org.junit.Assert.assertThat10import org.junit.Test11import java.io.File12import java.net.HttpURLConnection13import org.hamcrest.CoreMatchers.`is` as isEqualTo14class RequestStringExtensionTest : BaseTestCase() {15 init {16 FuelManager.instance.basePath = "https:/​/​httpbin.org"17 FuelManager.instance.baseHeaders = mapOf("foo" to "bar")18 FuelManager.instance.baseParams = listOf("key" to "value")19 }20 @Test21 fun httpGet() {22 var request: Request? = null23 var response: Response? = null24 var data: Any? = null25 var error: FuelError? = null26 "/​get".httpGet().responseString { req, res, result ->27 request = req28 response = res29 val (d, err) = result30 data = d31 error = err32 }33 assertThat(request, notNullValue())34 assertThat(response, notNullValue())35 assertThat(error, nullValue())36 assertThat(data, notNullValue())37 val statusCode = HttpURLConnection.HTTP_OK38 assertThat(response?.httpStatusCode, isEqualTo(statusCode))39 }40 @Test41 fun httpPost() {42 var request: Request? = null43 var response: Response? = null44 var data: Any? = null45 var error: FuelError? = null46 "/​post".httpPost().responseString { req, res, result ->47 request = req48 response = res49 val (d, err) = result50 data = d51 error = err52 }53 assertThat(request, notNullValue())54 assertThat(response, notNullValue())55 assertThat(error, nullValue())56 assertThat(data, notNullValue())57 val statusCode = HttpURLConnection.HTTP_OK58 assertThat(response?.httpStatusCode, isEqualTo(statusCode))59 }60 @Test61 fun httpPut() {62 var request: Request? = null63 var response: Response? = null64 var data: Any? = null65 var error: FuelError? = null66 "/​put".httpPut().responseString { req, res, result ->67 request = req68 response = res69 val (d, err) = result70 data = d71 error = err72 }73 assertThat(request, notNullValue())74 assertThat(response, notNullValue())75 assertThat(error, nullValue())76 assertThat(data, notNullValue())77 val statusCode = HttpURLConnection.HTTP_OK78 assertThat(response?.httpStatusCode, isEqualTo(statusCode))79 }80 @Test81 fun httpPatch() {82 var request: Request? = null83 var response: Response? = null84 var data: Any? = null85 var error: FuelError? = null86 "https:/​/​mockbin.org/​request".httpPatch().responseString { req, res, result ->87 request = req88 response = res89 val (d, err) = result90 data = d91 error = err92 }93 assertThat(request, notNullValue())94 assertThat(response, notNullValue())95 assertThat(error, nullValue())96 assertThat(data, notNullValue())97 val statusCode = HttpURLConnection.HTTP_OK98 assertThat(response?.httpStatusCode, isEqualTo(statusCode))99 }100 @Test101 fun httpDelete() {102 var request: Request? = null103 var response: Response? = null104 var data: Any? = null105 var error: FuelError? = null106 "/​delete".httpDelete().responseString { req, res, result ->107 request = req108 response = res109 val (d, err) = result110 data = d111 error = err112 }113 assertThat(request, notNullValue())114 assertThat(response, notNullValue())115 assertThat(error, nullValue())116 assertThat(data, notNullValue())117 val statusCode = HttpURLConnection.HTTP_OK118 assertThat(response?.httpStatusCode, isEqualTo(statusCode))119 }120 @Test121 fun httpDownload() {122 var request: Request? = null123 var response: Response? = null124 var data: Any? = null125 var error: FuelError? = null126 val numberOfBytes = 32768L127 "/​bytes/​$numberOfBytes".httpDownload().destination { response, url ->128 val f = File.createTempFile(numberOfBytes.toString(), null)129 println(f.absolutePath)130 f131 }.responseString { req, res, result ->132 request = req133 response = res134 val (d, err) = result135 data = d136 error = err137 }138 assertThat(request, notNullValue())139 assertThat(response, notNullValue())140 assertThat(error, nullValue())141 assertThat(data, notNullValue())142 val statusCode = HttpURLConnection.HTTP_OK143 assertThat(response?.httpStatusCode, isEqualTo(statusCode))144 }145 @Test146 fun httpUploadWithPut() {147 var request: Request? = null148 var response: Response? = null149 var data: Any? = null150 var error: FuelError? = null151 "/​put".httpUpload(Method.PUT).source { request, url ->152 val dir = System.getProperty("user.dir")153 val currentDir = File(dir, "src/​test/​assets")154 File(currentDir, "lorem_ipsum_long.tmp")155 }.responseString { req, res, result ->156 request = req157 response = res158 val (d, err) = result159 data = d160 error = err161 }162 assertThat(request, notNullValue())163 assertThat(response, notNullValue())164 assertThat(error, nullValue())165 assertThat(data, notNullValue())166 val statusCode = HttpURLConnection.HTTP_OK167 assertThat(response?.httpStatusCode, isEqualTo(statusCode))168 }169 @Test170 fun httpUploadWithPost() {171 var request: Request? = null172 var response: Response? = null173 var data: Any? = null174 var error: FuelError? = null175 "/​post".httpUpload().source { request, url ->176 val dir = System.getProperty("user.dir")177 val currentDir = File(dir, "src/​test/​assets")178 File(currentDir, "lorem_ipsum_long.tmp")179 }.responseString { req, res, result ->180 request = req181 response = res182 val (d, err) = result183 data = d184 error = err185 }186 assertThat(request, notNullValue())187 assertThat(response, notNullValue())188 assertThat(error, nullValue())189 assertThat(data, notNullValue())190 val statusCode = HttpURLConnection.HTTP_OK191 assertThat(response?.httpStatusCode, isEqualTo(statusCode))192 }193}...

Full Screen

Full Screen

tasks.kt

Source:tasks.kt Github

copy

Full Screen

1package me.eater.emo.forge2import com.github.kittinunf.fuel.core.FuelError3import com.github.kittinunf.fuel.coroutines.awaitByteArrayResponse4import com.github.kittinunf.fuel.coroutines.awaitString5import com.github.kittinunf.fuel.httpDownload6import com.github.kittinunf.fuel.httpGet7import me.eater.emo.EmoContext8import me.eater.emo.Target9import me.eater.emo.VersionSelector10import me.eater.emo.forge.dto.manifest.v1.Library11import me.eater.emo.forge.dto.manifest.v1.Manifest12import me.eater.emo.forge.dto.promotions.Promotions13import me.eater.emo.utils.Process14import me.eater.emo.utils.await15import me.eater.emo.utils.io16import me.eater.emo.utils.parallel17import org.tukaani.xz.XZInputStream18import java.io.File19import java.io.FileOutputStream20import java.nio.file.Files21import java.nio.file.Paths22import java.nio.file.StandardCopyOption23import java.util.jar.JarEntry24import java.util.jar.JarFile25import java.util.jar.JarOutputStream26import java.util.jar.Pack20027/​**28 * Process that fetches the known versions of Forge, and if needed selects the correct minecraft version29 */​30class FetchForgeVersions : Process<EmoContext> {31 override fun getName() = "forge.fetch_versions"32 override fun getDescription() = "Fetching known Forge versions"33 override suspend fun execute(context: EmoContext) {34 if (context.forgeVersion!!.isStatic()) {35 context.selectedForgeVersion = context.forgeVersion.selector36 return37 }38 val manifest = "https:/​/​files.minecraftforge.net/​maven/​net/​minecraftforge/​forge/​promotions.json"39 .httpGet()40 .awaitString()41 val promotions = Promotions.fromJson(manifest)!!42 val key = when (context.selectedMinecraftVersion) {43 null -> context.forgeVersion.selector44 else -> "${context.selectedMinecraftVersion!!.id}-${context.forgeVersion.selector}"45 }46 if (!promotions.promos.containsKey(key)) {47 throw Error("No forge distribution found for $key")48 }49 promotions.promos.getValue(key).run {50 context.selectedForgeVersion = version51 context.minecraftVersion = VersionSelector(minecraftVersion)52 }53 }54}55/​**56 * Process that fetches the universal Forge jar57 */​58class FetchUniversal : Process<EmoContext> {59 override fun getName() = "forge.v1.fetch_universal"60 override fun getDescription() = "Fetch universal Forge runtime"61 override suspend fun execute(context: EmoContext) {62 val versionTuple = "${context.selectedMinecraftVersion!!.id}-${context.selectedForgeVersion!!}"63 val artifactUrl =64 "https:/​/​files.minecraftforge.net/​maven/​net/​minecraftforge/​forge/​$versionTuple/​forge-$versionTuple-universal.jar"65 io {66 artifactUrl67 .httpDownload()68 .fileDestination { _, _ -> Paths.get(context.installLocation.toString(), "forge.jar").toFile() }69 .await()70 }71 }72}73/​**74 * Process that loads the install manifest from the universal forge jar75 */​76class LoadForgeManifest : Process<EmoContext> {77 override fun getName() = "forge.v1.load_manifest"78 override fun getDescription() = "Loading Forge install manifest"79 override suspend fun execute(context: EmoContext) {80 io {81 val jar = JarFile(Paths.get(context.installLocation.toString(), "forge.jar").toFile())82 val json = String(jar.getInputStream(jar.getJarEntry("version.json")).readBytes())83 context.forgeManifest = Manifest.fromJson(json)!!84 jar.close()85 }86 }87}88/​**89 * Process that fetches the libraries needed for forge90 */​91class FetchForgeLibraries : Process<EmoContext> {92 override fun getName() = "forge.v1.fetch_libraries"93 override fun getDescription() = "Fetching libraries for Forge"94 @ExperimentalUnsignedTypes95 override suspend fun execute(context: EmoContext) {96 parallel((context.forgeManifest!! as Manifest).libraries) {97 if (it.clientreq === null && it.serverreq === null) {98 return@parallel99 }100 val mirror = it.url ?: "https:/​/​libraries.minecraft.net"101 val file = Paths.get(context.installLocation.toString(), "libraries", it.getPath())102 Files.createDirectories(file.parent)103 if (Files.exists(file)) return@parallel104 try {105 (mirror + '/​' + it.getPath())106 .httpDownload()107 .fileDestination { _, _ -> file.toFile() }108 .await()109 } catch (t: Throwable) {110 if (t is FuelError && t.response.statusCode == 404 && it.url != null) {111 tryDownloadingPack(it, file.toFile())112 } else {113 throw t114 }115 }116 }117 if (context.target == Target.Client) {118 val newPath = Paths.get(119 context.installLocation.toString(),120 "libraries/​net/​minecraftforge/​forge",121 "${context.selectedMinecraftVersion!!.id}-${context.selectedForgeVersion!!}",122 "forge-${context.selectedMinecraftVersion!!.id}-${context.selectedForgeVersion!!}.jar"123 )124 Files.createDirectories(newPath.parent)125 Files.move(126 Paths.get(context.installLocation.toString(), "forge.jar"),127 newPath,128 StandardCopyOption.REPLACE_EXISTING129 )130 }131 }132 @ExperimentalUnsignedTypes133 suspend fun tryDownloadingPack(lib: Library, dest: File) {134 val (_, _, data) = ("${lib.url!!}/​${lib.getPath()}.pack.xz")135 .httpGet()136 .awaitByteArrayResponse()137 io {138 val decompressed = XZInputStream(data.inputStream()).readBytes()139 val decompressedLen = decompressed.size140 val blobLen = (decompressed[decompressedLen - 8].toUByte() and 0xFF.toUByte()).toInt() or141 ((decompressed[decompressedLen - 7].toUByte() and 0xFF.toUByte()).toInt() shl 8) or142 ((decompressed[decompressedLen - 6].toUByte() and 0xFF.toUByte()).toInt() shl 16) or143 ((decompressed[decompressedLen - 5].toUByte() and 0xFF.toUByte()).toInt() shl 24)144 val checksums = decompressed.copyOfRange(decompressedLen - blobLen - 8, decompressedLen - 8)145 val jarFile = FileOutputStream(dest)146 val jar = JarOutputStream(jarFile)147 Pack200.newUnpacker().unpack(decompressed.inputStream(0, decompressedLen - blobLen - 8), jar)148 val checksumsEntry = JarEntry("checksums.sha1")149 checksumsEntry.time = 0150 jar.putNextEntry(checksumsEntry)151 jar.write(checksums)152 jar.closeEntry()153 jar.close()154 jarFile.close()155 }156 }157}...

Full Screen

Full Screen

Models.kt

Source:Models.kt Github

copy

Full Screen

1package com.java.lichenhao2import android.graphics.Bitmap3import android.graphics.BitmapFactory4import android.os.Parcelable5import com.github.kittinunf.fuel.core.FuelError6import com.github.kittinunf.fuel.httpDownload7import com.github.kittinunf.fuel.httpGet8import com.github.kittinunf.result.Result9import com.github.kittinunf.result.map10import com.github.kittinunf.result.success11import com.google.gson.annotations.SerializedName12import kotlinx.android.parcel.IgnoredOnParcel13import kotlinx.android.parcel.Parcelize14import java.io.File15import java.lang.NullPointerException16/​/​ 这些data class里使用List没有任何价值，直接用Array即可17/​/​ 警告的"建议实现equals/​hashCode"不用理，没有实现的类都不会用到这些方法18@Parcelize /​/​ 这玩意真像过程宏啊19data class Response(20 val pageSize: Int, /​/​新闻总页数21 val total: Int, /​/​符合条件的新闻总数22 val `data`: Array<News>,23 val currentPage: Int24) : Parcelable25/​/​ 持久保存的内容26@Parcelize27data class NewsExt(28 val news: News,29 var read: Boolean, /​/​ 已读30 var favorite: Boolean,31 val imageDataList: Array<ByteArray?>, /​/​ 下载的图片具体内容，下标和news.imageList一一对应32 var videoPath: String? /​/​ 下载的视频直接保存到文件中33) : Parcelable {34 constructor(news: News) : this(35 news,36 NewsData.isRead(news),37 NewsData.isFavorite(news),38 arrayOfNulls(news.imageList.size),39 null40 )41 inline fun downloadImage(which: Int, crossinline handler: (Result<Bitmap, FuelError>) -> Unit) {42 imageDataList[which]?.let {43 val bitmap: Bitmap? = BitmapFactory.decodeByteArray(it, 0, it.size)44 if (bitmap != null) {45 handler(Result.success(bitmap))46 } else {47 handler(Result.error(FuelError.wrap(NullPointerException()))) /​/​ 可能是张gif，不支持48 }49 return50 }51 news.imageList[which].httpGet().response { _, _, result ->52 result.map { BitmapFactory.decodeByteArray(it, 0, it.size) }.apply(handler)53 result.success { imageDataList[which] = it }54 }55 }56 /​/​ 调用者保证news.video非空57 /​/​ handler处理的是视频文件名(因为视频播放器库不接受视频内容，只接受url)58 inline fun downloadVideo(crossinline handler: (String) -> Unit) {59 val video = news.video!!60 val videoPath = videoPath ?: run {61 handler(video) /​/​ 如果没有本地下载，则直接播放video网址(这样用户不需要等待)62 val path = "${GLOBAL_CONTEXT.filesDir.absolutePath}/​video${System.currentTimeMillis()}.mp4"63 video.httpDownload().fileDestination { _, _ -> File(path) }.response { _, _, _ ->64 videoPath = path /​/​ 不阻塞，下载好时才设置videoPath65 }66 return67 }68 handler(videoPath) /​/​ 有本地下载，播放文件69 }70 override fun equals(other: Any?) = other is NewsExt && news == other.news71 override fun hashCode() = news.hashCode()72}73/​/​ imageString和video的"为空"，极大概率是空字符串，但也有可能是不存在74@Parcelize75data class News(76 @SerializedName("image")77 val imageString: String?, /​/​新闻插图，可能为空(非空时格式是正常的json数组)78 val publishTime: String, /​/​新闻发布时间，部分新闻由于自身错误可能时间会很大(如9102å¹´)79 val keywords: Array<Keyword>, /​/​关键词80 val language: String, /​/​新闻语言81 val video: String?, /​/​视频，一般为空82 val title: String, /​/​新闻题目83 val `when`: Array<When>, /​/​新闻中相关时间和相关度84 val content: String, /​/​正文85 val persons: Array<Person>, /​/​新闻提及人物，提及次数和在xlore中知识卡片url86 val newsID: String, /​/​新闻ID87 val crawlTime: String, /​/​爬取时间88 val organizations: Array<Organization>, /​/​发布新闻组织89 val publisher: String, /​/​出版者90 val locations: Array<Location>, /​/​新闻提及位置，位置经纬度，提及次数91 val `where`: Array<Where>, /​/​新闻相关位置和相关度92 val category: String, /​/​类别93 val who: Array<Who> /​/​新闻相关人和相关度94) : Parcelable {95 @IgnoredOnParcel96 private var _imageList: List<String>? = null97 val imageList: List<String>98 get() = _imageList ?: run {99 val tmp = (imageString ?: "")100 .replace("[", "").replace("]", "")101 .split(',')102 .map { it.trim() }103 .filter { it.isNotEmpty() }104 _imageList = tmp105 tmp106 }107 override fun equals(other: Any?) = other is News && newsID == other.newsID108 override fun hashCode() = newsID.hashCode()109}110@Parcelize111data class Keyword(112 val score: Float, /​/​关建度113 val word: String /​/​词语114) : Parcelable115@Parcelize116data class When(117 val score: Float,118 val word: String119) : Parcelable120@Parcelize121data class Person(122 val count: Int,123 val linkedURL: String?,124 val mention: String125) : Parcelable126@Parcelize127data class Organization(128 val count: Int,129 val linkedURL: String?,130 val mention: String131) : Parcelable132@Parcelize133data class Location(134 val count: Int,135 val lat: Float,136 val linkedURL: String?,137 val lng: Float,138 val mention: String139) : Parcelable140@Parcelize141data class Where(142 val score: Float,143 val word: String144) : Parcelable145@Parcelize146data class Who(147 val score: Float,148 val word: String149) : Parcelable...

Full Screen

Full Screen

Files.kt

Source:Files.kt Github

copy

Full Screen

1package flank.common2import com.github.kittinunf.fuel.Fuel3import com.github.kittinunf.fuel.core.awaitUnit4import com.github.kittinunf.fuel.httpDownload5import java.io.File6import java.io.IOException7import java.nio.file.Files8import java.nio.file.Path9import java.nio.file.Paths10import java.nio.file.StandardCopyOption11val defaultCredentialPath: Path by lazy {12 Paths.get(userHome, ".config/​gcloud/​application_default_credentials.json")13}14val userHome: String by lazy {15 if (isWindows) System.getenv("HOMEPATH") else System.getProperty("user.home")16}17val appDataDirectory: String by lazy {18 if (isWindows) System.getenv("APPDATA") else System.getProperty("user.home")19}20val dotFlank = Paths.get(userHome, ".flank")21fun linkFiles(22 link: String,23 target: String24) {25 if (isWindows) createCopy(target, link)26 else createSymbolicLink(link, target)27}28fun createCopy(sourceDirectoryLocation: String, destinationDirectoryLocation: String) {29 if (destinationDirectoryLocation.fileExists()) {30 deleteDirectory(destinationDirectoryLocation)31 }32 copyDirectory(sourceDirectoryLocation, destinationDirectoryLocation)33}34fun createFileCopy(source: String, destination: String): Path =35 Files.copy(Paths.get(source), Paths.get(destination), StandardCopyOption.REPLACE_EXISTING)36fun copyDirectory(sourceDirectoryLocation: String, destinationDirectoryLocation: String) {37 Files.walk(Paths.get(sourceDirectoryLocation))38 .forEach { source: Path ->39 val destination =40 Paths.get(destinationDirectoryLocation, source.toString().substring(sourceDirectoryLocation.length))41 try {42 Files.copy(source, destination)43 } catch (e: IOException) {44 logLn(e.localizedMessage)45 }46 }47}48fun deleteDirectory(directory: String) {49 if (directory.fileExists()) deleteDirectory(directory.toFile())50}51private fun deleteDirectory(directory: File): Boolean {52 val allContents = directory.listFiles()53 if (allContents != null) {54 for (file in allContents) {55 deleteDirectory(file)56 }57 }58 return directory.delete()59}60fun createSymbolicLink(61 link: String,62 target: String63): Path = Files.createSymbolicLink(64 Paths.get(link).also { linkPath -> if (Files.isSymbolicLink(linkPath)) Files.delete(linkPath) }.toAbsolutePath()65 .normalize(),66 Paths.get(target).toAbsolutePath().normalize()67)68fun createLinkToFile(link: Path, target: Path): Path =69 if (isWindows) createFileCopy(target.toString(), link.toString())70 else Files.createSymbolicLink(link, target.fileName)71fun downloadFile(sourceUrl: String, destination: String) {72 Fuel.download(sourceUrl)73 .fileDestination { _, _ -> File(destination) }74 .responseString()75}76suspend fun String.downloadFile(destination: String) = this.httpDownload().fileDestination { _, _ ->77 Files.createFile(Paths.get(destination)).toFile().also {78 logLn("Ktlint written to: ${it.absolutePath}")79 }80}.awaitUnit()81fun downloadFile(sourceUrl: String, destinationPath: Path) {82 Fuel.download(sourceUrl)83 .fileDestination { _, _ -> destinationPath.toFile() }84 .responseString()85}86fun String.toFile(): File = Paths.get(this).toFile()87fun String.deleteFile() = Paths.get(this).delete()88fun createDirectoryIfNotExist(path: Path) {89 if (Files.notExists(path)) Files.createDirectory(path)90}91fun File.hasAllFiles(fileList: List<String>): Boolean {92 val directoryFiles = list() ?: emptyArray()93 return fileList.all { it in directoryFiles }94}95fun String.fileExists(): Boolean = Paths.get(this).exists()96fun osPathSeparator() = (if (isWindows) "\\" else "/​")97private fun Path.exists(): Boolean = Files.exists(this)98private fun Path.isFile(): Boolean = !Files.isDirectory(this)99private fun Path.delete(): Boolean {100 return if (isFile() && exists()) {101 Files.delete(this)102 true103 } else {104 false105 }106}...

Full Screen

Full Screen

UpdateUtil.kt

Source:UpdateUtil.kt Github

copy

Full Screen

1package com.gh0u1l5.wechatmagician.util2import android.app.Activity3import android.content.Context4import android.content.Intent5import android.net.Uri6import android.os.Build7import android.support.v4.content.FileProvider8import android.support.v7.app.AlertDialog9import android.util.Log10import android.webkit.MimeTypeMap11import com.gh0u1l5.wechatmagician.BuildConfig12import com.gh0u1l5.wechatmagician.Global.MAGICIAN_FILE_PROVIDER13import com.gh0u1l5.wechatmagician.R14import com.github.kittinunf.fuel.android.extension.responseJson15import com.github.kittinunf.fuel.httpDownload16import com.github.kittinunf.fuel.httpGet17import com.github.kittinunf.result.Result18import java.io.File19object UpdateUtil {20 private const val TAG = "UpdateUtil"21 private const val UPDATE_SERVER = "http:/​/​www.gh0u1l5.me/​wechat-magician"22 private const val UPDATE_JSON = "$UPDATE_SERVER/​update.json"23 fun checkVersion(activity: Activity) {24/​/​ {25/​/​ "version_code": 51,26/​/​ "address": "./​apks/​WechatMagician-2.8.1.apk",27/​/​ "description": "Test"28/​/​ }29 UPDATE_JSON.httpGet().responseJson { _, _, result ->30 if (result is Result.Failure) {31 return@responseJson32 }33 val version = result.get().obj()34 val versionCode = version["version_code"] as Int35 if (versionCode > BuildConfig.VERSION_CODE) {36 val apkAddress = "$UPDATE_SERVER/​${version["address"]}"37 val description = version["description"] as String38 requireUpdate(activity, apkAddress, description)39 }40 }41 }42 private fun requireUpdate(activity: Activity, apkAddress: String, description: String) {43 activity.runOnUiThread {44 AlertDialog.Builder(activity)45 .setIcon(R.mipmap.ic_launcher)46 .setTitle(R.string.prompt_update_discovered)47 .setMessage(description)48 .setPositiveButton(R.string.button_update, { dialog, _ ->49 downloadAndInstallApk(activity, apkAddress)50 dialog.dismiss()51 })52 .setNegativeButton(R.string.button_cancel, { dialog, _ ->53 dialog.dismiss()54 })55 .show()56 }57 }58 private fun downloadAndInstallApk(context: Context, apkAddress: String) {59 val apkFile = File.createTempFile("temp", ".apk", context.cacheDir)60 apkAddress.httpDownload().destination { _, _ -> apkFile }.response { _, _, result ->61 if (result is Result.Success) {62 installApk(context, apkFile)63 }64 }65 }66 private fun installApk(context: Context, apk: File) {67 try {68 context.startActivity(Intent().apply {69 if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.N) {70 action = Intent.ACTION_INSTALL_PACKAGE71 data = FileProvider.getUriForFile(context, MAGICIAN_FILE_PROVIDER, apk)72 flags = Intent.FLAG_GRANT_READ_URI_PERMISSION73 } else {74 action = Intent.ACTION_VIEW75 data = Uri.fromFile(apk)76 type = MimeTypeMap.getSingleton().getMimeTypeFromExtension("apk")77 flags = Intent.FLAG_ACTIVITY_NEW_TASK78 }79 })80 } catch (t: Throwable) {81 Log.w(TAG, t)82 }83 }84}...

Full Screen

Full Screen

ApiWrapper.kt

Source:ApiWrapper.kt Github

copy

Full Screen

1package com.github.firenox89.shinobooru.repo2import android.content.Context3import com.github.firenox89.shinobooru.repo.model.Post4import com.github.firenox89.shinobooru.repo.model.Tag5import com.github.kittinunf.fuel.core.FuelError6import com.github.kittinunf.fuel.core.FuelManager7import com.github.kittinunf.fuel.core.ResponseDeserializable8import com.github.kittinunf.fuel.core.awaitResult9import com.github.kittinunf.fuel.coroutines.awaitObjectResult10import com.github.kittinunf.fuel.httpDownload11import com.github.kittinunf.fuel.httpGet12import com.github.kittinunf.result.Result13import com.google.gson.Gson14import timber.log.Timber15import java.io.File16class ApiWrapper(private val appContext: Context) {17 init {18 /​/​TODO: check if internet is available19 /​/​yande.re does not talk to android user agents...20 FuelManager.instance.baseHeaders = mapOf("User-Agent" to "Java/​1.8.0_112")21 }22 suspend fun requestPost(board: String,23 page: Int,24 tags: String = "",25 limit: Int = 20): Result<List<Post>, FuelError> =26 /​/​TODO: add board dependent request limits, so that we can stop before the board will stop us27 buildPostRequest(board, page, tags, limit).also { Timber.d("request '$it'") }.httpGet().awaitObjectResult(PostDeserializer)28 suspend fun requestTag(board: String, tagName: String): Result<List<Tag>, FuelError> =29 /​/​add protocol if it is missing30 "${board.prepentHttp()}/​tag.json?name=$tagName&limit=0".also {31 Timber.i("Request tag info from board '$board' with name '$tagName'. Request '$it'")32 }.httpGet().awaitObjectResult(TagDeserializer).also { Timber.d("Requested Tags $board, $tagName") }33 private fun String.prepentHttp(): String = if (this.startsWith("http")) this else "https:/​/​$this"34 private fun buildPostRequest(board: String, page: Int, tags: String, limit: Int): String =35 "${board.prepentHttp()}/​post.json?limit=$limit" +36 (if (page > 1) "&page=$page" else "") +37 (if (tags != "") "&tags=$tags" else "")38 suspend fun downloadPost(post: Post, destination: File) =39 post.file_url.httpDownload().fileDestination { _, _ ->40 destination41 }.awaitResult(NoopDeserializer)42 object PostDeserializer : ResponseDeserializable<List<Post>> {43 override fun deserialize(content: String): List<Post> = Gson().fromJson(content, Array<Post>::class.java).toList()44 }45 object TagDeserializer : ResponseDeserializable<List<Tag>> {46 override fun deserialize(content: String): List<Tag> = Gson().fromJson(content, Array<Tag>::class.java).toList()47 }48 object NoopDeserializer : ResponseDeserializable<Unit> {49 override fun deserialize(content: String): Unit = Unit50 }51}...

Full Screen

Full Screen

Fuel.kt

Source:Fuel.kt Github

copy

Full Screen

1package com.github.kittinunf.fuel2import com.github.kittinunf.fuel.core.FuelManager3import com.github.kittinunf.fuel.core.Method4import com.github.kittinunf.fuel.core.Parameters5import com.github.kittinunf.fuel.core.Request6import com.github.kittinunf.fuel.core.RequestFactory7import com.github.kittinunf.fuel.core.requests.DownloadRequest8import com.github.kittinunf.fuel.core.requests.UploadRequest9object Fuel : RequestFactory.Convenience by FuelManager.instance {10 var trace = false11 fun trace(function: () -> String) {12 @Suppress("ConstantConditionIf")13 if (trace) println(function())14 }15 fun reset() = FuelManager.instance.reset()16}17fun String.httpGet(parameters: Parameters? = null): Request =18 Fuel.get(this, parameters)19fun RequestFactory.PathStringConvertible.httpGet(parameter: Parameters? = null): Request =20 this.path.httpGet(parameter)21fun String.httpPost(parameters: Parameters? = null): Request =22 Fuel.post(this, parameters)23fun RequestFactory.PathStringConvertible.httpPost(parameters: Parameters? = null): Request =24 this.path.httpPost(parameters)25fun String.httpPut(parameters: Parameters? = null): Request =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)45fun String.httpHead(parameters: Parameters? = null): Request =46 Fuel.head(this, parameters)47fun RequestFactory.PathStringConvertible.httpHead(parameters: Parameters? = null): Request =48 this.path.httpHead(parameters)...

Full Screen

Full Screen

String.httpDownload

Using AI Code Generation

copy

Full Screen

1import com.github.kittinunf.fuel.Fuel2import com.github.kittinunf.result.Result3fun main(args: Array<String>) {4 println("Downloading $url")5 Fuel.get(url).responseString { request, response, result ->6 when (result) {7 is Result.Failure -> {8 println("Error: ${result.getException()}")9 }10 is Result.Success -> {11 println("Got ${result.get().length} bytes")12 }13 }14 }15}16import com.github.kittinunf.fuel.Fuel17import com.github.kittinunf.result.Result18fun main(args: Array<String>) {19 println("Downloading $url")20 Fuel.get(url).responseString { request, response, result ->21 when (result) {22 is Result.Failure -> {23 println("Error: ${result.getException()}")24 }25 is Result.Success -> {26 println("Got ${result.get().length} bytes")27 }28 }29 }30}31import com.github.kittinunf.fuel.Fuel32import com.github.kittinunf.result.Result33fun main(args: Array<String>) {34 println("Downloading $url")35 Fuel.get(url).responseString { request, response, result ->36 when (result) {37 is Result.Failure -> {38 println("Error: ${result.getException()}")39 }40 is Result.Success -> {41 println("Got ${result.get().length} bytes")42 }43 }44 }45}46import com.github.kittinunf.fuel.Fuel47import com.github.kittinunf.result.Result48fun main(args: Array<String>) {49 println("Downloading $url")50 Fuel.get(url).responseString { request, response, result ->51 when (result) {52 is Result.Failure -> {53 println("Error: ${result.getException()}")54 }

Full Screen

Full Screen

String.httpDownload

Using AI Code Generation

copy

Full Screen

1 String fileName = "logo.png";2 String destinationFile = "/​tmp/​" + fileName;3 String urlWithFileName = url + "/​" + fileName;4 File file = new File(destinationFile);5 if (!file.exists()) {6 String result = urlWithFileName.httpDownload().destination { response, url ->7 File.createTempFile("mytempfile", ".tmp")8 }.responseString().second.get()9 println(result)10 }11 import com.github.kittinunf.fuel.Fuel12 import com.github.kittinunf.fuel.core.extensions.authentication13 import com.github.kittinunf.fuel.core.extensions.cUrlString14 import com.github.kittinunf.fuel.core.extensions.responseString15 import com.github.kittinunf.fuel.core.requests.DownloadRequest16 import com.github.kittinunf.fuel.core.requests.Request17 import com.github.kittinunf.fuel.core.requests.cUrlString18 import com.github.kittinunf.fuel.core.requests.responseString19 import com.github.kittinunf.fuel.core.response20 import com.github.kittinunf.fuel.core.responseString21 import com.github.kittinunf.fuel.httpDownload22 import com.github.kittinunf.fuel.httpGet23 import com.github.kittinunf.fuel.httpPost24 import com.github.kittinunf.fuel.httpUpload25 import com.github.kittinunf.fuel.moshi.responseObject26 import com.github.kittinunf.fuel.moshi.responseObject

Full Screen

Full Screen

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.

LambdaTest Learning Hubs:

YouTube

You could also refer to video tutorials over LambdaTest YouTube channel to get step by step demonstration from industry experts.

Run Fuel automation tests on LambdaTest cloud grid

Perform automation testing on 3000+ real desktop and mobile devices online.

... View sample repo... View DocumentationSign up Free
›
_

Most used method in Fuel

Try LambdaTest Now !!

Get 100 minutes of automation test minutes FREE!!

...
Sign up with GoogleSign up with Email
Next-Gen App & Browser Testing Cloud

Was this article helpful?

Helpful

NotHelpful