From 2321ed22f193a83ad66b3a9361786a1666d564ec Mon Sep 17 00:00:00 2001
From: Isira Seneviratne <isirasen96@gmail.com>
Date: Wed, 8 Feb 2023 06:20:06 +0530
Subject: [PATCH] Restore coroutine context originally used in DownloadService.

---
 .../libretube/services/DownloadService.kt      | 18 ++++++++++++------
 1 file changed, 12 insertions(+), 6 deletions(-)

diff --git a/app/src/main/java/com/github/libretube/services/DownloadService.kt b/app/src/main/java/com/github/libretube/services/DownloadService.kt
index 9fe3f4859..9739926f5 100644
--- a/app/src/main/java/com/github/libretube/services/DownloadService.kt
+++ b/app/src/main/java/com/github/libretube/services/DownloadService.kt
@@ -44,6 +44,8 @@ import java.net.URL
 import kotlinx.coroutines.CancellationException
 import kotlinx.coroutines.Dispatchers
 import kotlinx.coroutines.Job
+import kotlinx.coroutines.SupervisorJob
+import kotlinx.coroutines.asCoroutineDispatcher
 import kotlinx.coroutines.flow.MutableSharedFlow
 import kotlinx.coroutines.flow.SharedFlow
 import kotlinx.coroutines.launch
@@ -52,12 +54,15 @@ import okio.BufferedSink
 import okio.buffer
 import okio.sink
 import okio.source
+import java.util.concurrent.Executors
 
 /**
  * Download service with custom implementation of downloading using [HttpURLConnection].
  */
 class DownloadService : LifecycleService() {
     private val binder = LocalBinder()
+    private val dispatcher = Executors.newSingleThreadExecutor().asCoroutineDispatcher()
+    private val coroutineContext = dispatcher + SupervisorJob()
 
     private lateinit var notificationManager: NotificationManager
     private lateinit var summaryNotificationBuilder: NotificationCompat.Builder
@@ -88,7 +93,7 @@ class DownloadService : LifecycleService() {
         val audioQuality = intent.getStringExtra(IntentData.audioQuality)
         val subtitleCode = intent.getStringExtra(IntentData.subtitleCode)
 
-        lifecycleScope.launch {
+        lifecycleScope.launch(coroutineContext) {
             try {
                 val streams = withContext(Dispatchers.IO) {
                     RetrofitInstance.api.getStreams(videoId)
@@ -149,7 +154,7 @@ class DownloadService : LifecycleService() {
             Database.downloadDao().insertDownloadItem(item)
         }.toInt()
 
-        lifecycleScope.launch {
+        lifecycleScope.launch(coroutineContext) {
             downloadFile(item)
         }
     }
@@ -239,7 +244,7 @@ class DownloadService : LifecycleService() {
                         notificationBuilder
                             .setContentText(
                                 totalRead.formatAsFileSize() + " / " +
-                                    item.downloadSize.formatAsFileSize()
+                                        item.downloadSize.formatAsFileSize()
                             )
                             .setProgress(
                                 item.downloadSize.toInt(),
@@ -265,7 +270,8 @@ class DownloadService : LifecycleService() {
                 sourceByte.close()
                 con.disconnect()
             }
-        } catch (_: Exception) { }
+        } catch (_: Exception) {
+        }
 
         val completed = when {
             totalRead < item.downloadSize -> {
@@ -293,7 +299,7 @@ class DownloadService : LifecycleService() {
         val downloadCount = downloadQueue.valueIterator().asSequence().count { it }
         if (downloadCount >= DownloadHelper.getMaxConcurrentDownloads()) {
             toastFromMainThread(getString(R.string.concurrent_downloads_limit_reached))
-            lifecycleScope.launch {
+            lifecycleScope.launch(coroutineContext) {
                 _downloadFlow.emit(id to DownloadStatus.Paused)
             }
             return
@@ -302,7 +308,7 @@ class DownloadService : LifecycleService() {
         val downloadItem = awaitQuery {
             Database.downloadDao().findDownloadItemById(id)
         }
-        lifecycleScope.launch {
+        lifecycleScope.launch(coroutineContext) {
             downloadFile(downloadItem)
         }
     }