Reorganize other util files

2020-02-02 22:22:54 -05:00
parent faf8f1fbbc
commit 47f5ea881f
123 changed files with 218 additions and 192 deletions
@@ -0,0 +1,10 @@
+package eu.kanade.tachiyomi.util.lang
+
+import kotlinx.coroutines.*
+
+fun launchUI(block: suspend CoroutineScope.() -> Unit): Job =
+        GlobalScope.launch(Dispatchers.Main, CoroutineStart.DEFAULT, block)
+
+@UseExperimental(ExperimentalCoroutinesApi::class)
+fun launchNow(block: suspend CoroutineScope.() -> Unit): Job =
+        GlobalScope.launch(Dispatchers.Main, CoroutineStart.UNDISPATCHED, block)
@@ -0,0 +1,10 @@
+package eu.kanade.tachiyomi.util.lang
+
+import java.text.DateFormat
+import java.util.Date
+
+fun Date.toTimestampString(dateFormatter: DateFormat): String {
+    val date = dateFormatter.format(this)
+    val time = DateFormat.getTimeInstance(DateFormat.SHORT).format(this)
+    return "$date $time"
+}
@@ -0,0 +1,42 @@
+package eu.kanade.tachiyomi.util.lang
+
+import java.security.MessageDigest
+
+object Hash {
+
+    private val chars = charArrayOf('0', '1', '2', '3', '4', '5', '6', '7', '8', '9',
+            'a', 'b', 'c', 'd', 'e', 'f')
+
+    private val MD5 get() = MessageDigest.getInstance("MD5")
+
+    private val SHA256 get() = MessageDigest.getInstance("SHA-256")
+
+    fun sha256(bytes: ByteArray): String {
+        return encodeHex(SHA256.digest(bytes))
+    }
+
+    fun sha256(string: String): String {
+        return sha256(string.toByteArray())
+    }
+
+    fun md5(bytes: ByteArray): String {
+        return encodeHex(MD5.digest(bytes))
+    }
+
+    fun md5(string: String): String {
+        return md5(string.toByteArray())
+    }
+
+    private fun encodeHex(data: ByteArray): String {
+        val l = data.size
+        val out = CharArray(l shl 1)
+        var i = 0
+        var j = 0
+        while (i < l) {
+            out[j++] = chars[(240 and data[i].toInt()).ushr(4)]
+            out[j++] = chars[15 and data[i].toInt()]
+            i++
+        }
+        return String(out)
+    }
+}
@@ -0,0 +1,25 @@
+package eu.kanade.tachiyomi.util.lang
+
+import rx.Observable
+import rx.Scheduler
+import rx.functions.Func1
+import rx.schedulers.Schedulers
+import java.util.concurrent.TimeUnit.MILLISECONDS
+
+class RetryWithDelay(
+        private val maxRetries: Int = 1,
+        private val retryStrategy: (Int) -> Int = { 1000 },
+        private val scheduler: Scheduler = Schedulers.computation()
+) : Func1<Observable<out Throwable>, Observable<*>> {
+
+    private var retryCount = 0
+
+    override fun call(attempts: Observable<out Throwable>) = attempts.flatMap { error ->
+        val count = ++retryCount
+        if (count <= maxRetries) {
+            Observable.timer(retryStrategy(count).toLong(), MILLISECONDS, scheduler)
+        } else {
+            Observable.error(error as Throwable)
+        }
+    }
+}
@@ -0,0 +1,17 @@
+package eu.kanade.tachiyomi.util.lang
+
+import rx.Observable
+import rx.Subscription
+import rx.subscriptions.CompositeSubscription
+
+fun Subscription?.isNullOrUnsubscribed() = this == null || isUnsubscribed
+
+operator fun CompositeSubscription.plusAssign(subscription: Subscription) = add(subscription)
+
+fun <T, U, R> Observable<T>.combineLatest(o2: Observable<U>, combineFn: (T, U) -> R): Observable<R> {
+    return Observable.combineLatest(this, o2, combineFn)
+}
+
+fun Subscription.addTo(subscriptions: CompositeSubscription) {
+    subscriptions.add(this)
+}
@@ -0,0 +1,34 @@
+package eu.kanade.tachiyomi.util.lang
+
+import kotlin.math.floor
+
+/**
+ * Replaces the given string to have at most [count] characters using [replacement] at its end.
+ * If [replacement] is longer than [count] an exception will be thrown when `length > count`.
+ */
+fun String.chop(count: Int, replacement: String = "..."): String {
+    return if (length > count)
+        take(count - replacement.length) + replacement
+    else
+        this
+}
+
+/**
+ * Replaces the given string to have at most [count] characters using [replacement] near the center.
+ * If [replacement] is longer than [count] an exception will be thrown when `length > count`.
+ */
+fun String.truncateCenter(count: Int, replacement: String = "..."): String {
+    if (length <= count)
+        return this
+
+    val pieceLength: Int = floor((count - replacement.length).div(2.0)).toInt()
+
+    return "${take(pieceLength)}$replacement${takeLast(pieceLength)}"
+}
+
+/**
+ * Case-insensitive natural comparator for strings.
+ */
+fun String.compareToCaseInsensitiveNaturalOrder(other: String): Int {
+    return String.CASE_INSENSITIVE_ORDER.then(naturalOrder()).compare(this, other)
+}