Use foreground service to perform restore

data/src/main/java/com/moez/QKSMS/repository/BackupRepositoryImpl.kt

@@ -148,13 +148,13 @@ class BackupRepositoryImpl @Inject constructor(
             }
             .map { files -> files.sortedByDescending { file -> file.date } }
 
-    override fun performRestore(backupFile: BackupFile) {
+    override fun performRestore(filePath: String) {
         // If a backupFile or restore is already running, don't do anything
         if (isBackupOrRestoreRunning()) return
 
         restoreProgress.onNext(BackupRepository.Progress.Running(0, "Parsing backup"))
 
-        val file = File(backupFile.path)
+        val file = File(filePath)
         val source = Okio.buffer(Okio.source(file))
 
         val backup = moshi.adapter(Backup::class.java).fromJson(source)

data/src/main/java/com/moez/QKSMS/service/RestoreBackupService.kt

@@ -0,0 +1,105 @@
+/*
+ * Copyright (C) 2017 Moez Bhatti <moez.bhatti@gmail.com>
+ *
+ * This file is part of QKSMS.
+ *
+ * QKSMS is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * QKSMS is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with QKSMS.  If not, see <http://www.gnu.org/licenses/>.
+ */
+package com.moez.QKSMS.service
+
+import android.annotation.SuppressLint
+import android.app.Service
+import android.content.Context
+import android.content.Intent
+import android.os.IBinder
+import androidx.core.app.NotificationManagerCompat
+import androidx.core.content.ContextCompat
+import com.moez.QKSMS.manager.NotificationManager
+import com.moez.QKSMS.repository.BackupRepository
+import dagger.android.AndroidInjection
+import io.reactivex.Observable
+import io.reactivex.schedulers.Schedulers
+import java.util.concurrent.TimeUnit
+import javax.inject.Inject
+
+
+class RestoreBackupService : Service() {
+
+    companion object {
+        private const val NOTIFICATION_ID = -1
+
+        private const val ACTION_START = "com.moez.QKSMS.ACTION_START"
+        private const val ACTION_STOP = "com.moez.QKSMS.ACTION_STOP"
+        private const val EXTRA_FILE_PATH = "com.moez.QKSMS.EXTRA_FILE_PATH"
+
+        fun start(context: Context, filePath: String) {
+            val intent = Intent(context, RestoreBackupService::class.java)
+                    .setAction(ACTION_START)
+                    .putExtra(EXTRA_FILE_PATH, filePath)
+
+            ContextCompat.startForegroundService(context, intent)
+        }
+    }
+
+    @Inject lateinit var backupRepo: BackupRepository
+    @Inject lateinit var notificationManager: NotificationManager
+
+    override fun onCreate() = AndroidInjection.inject(this)
+
+    override fun onBind(intent: Intent?): IBinder? = null
+
+    override fun onStartCommand(intent: Intent, flags: Int, startId: Int): Int {
+        super.onStartCommand(intent, flags, startId)
+        when (intent.action) {
+            ACTION_START -> start(intent)
+            ACTION_STOP -> stop()
+        }
+
+        return Service.START_STICKY
+    }
+
+    @SuppressLint("CheckResult")
+    private fun start(intent: Intent) {
+        val notification = notificationManager.getNotificationForBackup()
+        val notificationManager = NotificationManagerCompat.from(this)
+
+        startForeground(NOTIFICATION_ID, notification.build())
+
+        backupRepo.getRestoreProgress()
+                .sample(200, TimeUnit.MILLISECONDS, true)
+                .subscribeOn(Schedulers.io())
+                .subscribe { progress ->
+                    when (progress) {
+                        is BackupRepository.Progress.Running -> {
+                            notification.setProgress(100, progress.progress, false)
+                            notificationManager.notify(NOTIFICATION_ID, notification.build())
+                        }
+
+                        is BackupRepository.Progress.Idle -> stop()
+                    }
+                }
+
+        // Start the restore
+        Observable.just(intent)
+                .map { it.getStringExtra(EXTRA_FILE_PATH) }
+                .subscribeOn(Schedulers.io())
+                .subscribe(backupRepo::performRestore)
+    }
+
+    private fun stop() {
+        stopForeground(true)
+        stopSelf()
+    }
+
+}