Merge pull request #845 from prathamk22/Auto_Delete_Expired_Downloads

Auto Delete after 15 days service added

Author: aggarwalpulkit596

app/src/main/java/com/codingblocks/cbonlineapp/dashboard/DashboardActivity.kt

@@ -34,6 +34,11 @@ import com.codingblocks.cbonlineapp.tracks.LearningTracksActivity
 import com.codingblocks.cbonlineapp.util.Components
 import com.codingblocks.cbonlineapp.util.JWTUtils
 import com.codingblocks.cbonlineapp.util.UNAUTHORIZED
+import com.codingblocks.cbonlineapp.util.DELETE_DOWNLOADED_VIDEO
+import com.codingblocks.cbonlineapp.util.DeleteDownloadedFiles
+import java.util.concurrent.TimeUnit
+import com.google.common.util.concurrent.ListenableFuture
+import androidx.work.*
 import com.codingblocks.cbonlineapp.util.extensions.colouriseToolbar
 import com.codingblocks.cbonlineapp.util.extensions.loadImage
 import com.codingblocks.cbonlineapp.util.extensions.observer
@@ -85,6 +90,7 @@ class DashboardActivity : BaseCBActivity(),
         toggle.syncState()
         dashboardNavigation.setNavigationItemSelectedListener(this)
         dashboardBottomNav.setOnNavigationItemSelectedListener(this)
+        checkDownloadDataWM()
         initializeUI(vm.isLoggedIn ?: false)
         vm.errorLiveData.observer(this) { error ->
             when (error) {
@@ -266,6 +272,26 @@ class DashboardActivity : BaseCBActivity(),
         }
     }
 
+    private fun checkDownloadDataWM(){
+        val wm = WorkManager.getInstance()
+
+        //Will get if Auto delete downloaded video request is already started or not
+        val future: ListenableFuture<List<WorkInfo>> = wm.getWorkInfosByTag(DELETE_DOWNLOADED_VIDEO)
+        val list: List<WorkInfo> = future.get()
+
+        //Request to delete video files which expired after 15 days
+        val request: PeriodicWorkRequest =
+            PeriodicWorkRequestBuilder<DeleteDownloadedFiles>(1, TimeUnit.DAYS)
+                .addTag(DELETE_DOWNLOADED_VIDEO)
+                .setBackoffCriteria(BackoffPolicy.EXPONENTIAL, 20, TimeUnit.SECONDS)
+                .build()
+
+        //If found empty then it is not started or cancelled for whatever reason, will add request to start it
+        if(list.isEmpty()){
+            wm.enqueue(request)
+        }
+    }
+
     private fun checkForUpdates() {
         val appUpdateInfoTask = appUpdateManager.appUpdateInfo
 

app/src/main/java/com/codingblocks/cbonlineapp/util/Constants.kt

@@ -105,3 +105,5 @@ const val REFRESH_TOKEN = "refresh_token"
 const val CONTEST_ID = "contestId"
 
 const val CODE_ID = "codeId"
+
+const val DELETE_DOWNLOADED_VIDEO = "deleteDownloadedVideo"

app/src/main/java/com/codingblocks/cbonlineapp/util/DeleteDownloadedFiles.kt

@@ -0,0 +1,36 @@
+package com.codingblocks.cbonlineapp.util
+
+import android.content.Context
+import android.os.Environment
+import androidx.work.CoroutineWorker
+import androidx.work.WorkerParameters
+import com.codingblocks.cbonlineapp.database.ContentDao
+import com.codingblocks.cbonlineapp.database.models.ContentModel
+import org.koin.core.KoinComponent
+import org.koin.core.inject
+import java.io.File
+import java.util.*
+
+class DeleteDownloadedFiles(context: Context, private val workerParameters: WorkerParameters) :
+    CoroutineWorker(context, workerParameters), KoinComponent {
+
+    val contentDao: ContentDao by inject()
+
+    override suspend fun doWork(): Result {
+        val list:List<ContentModel> = contentDao.getDownloads(true)
+
+        list.forEach {item->
+            val folderFile = File(applicationContext.getExternalFilesDir(Environment.getDataDirectory().absolutePath), "/${item.contentLecture.lectureId}")
+            val fileDate = Date(folderFile.lastModified())
+            val expiringDate = Date(fileDate.time + 15)
+
+            //Difference is number of days between expiring date and today.
+            val diff = (expiringDate.time - Date().time)/(24 * 60 * 60 * 1000)
+            if (diff<=0){
+                MediaUtils.deleteRecursive(folderFile)
+                contentDao.updateContentWithVideoId(item.contentLecture.lectureId, 0)
+            }
+        }
+        return Result.success()
+    }
+}

app/src/main/java/com/codingblocks/cbonlineapp/util/DownloadWorker.kt

@@ -41,7 +41,7 @@ class DownloadWorker(context: Context, private val workerParameters: WorkerParam
         applicationContext.getSystemService(Context.NOTIFICATION_SERVICE) as NotificationManager
     }
 
-    val contentDao: ContentDao by inject()
+    private val contentDao: ContentDao by inject()
 
 //    override fun onStopped() {
 //        super.onStopped()
@@ -77,6 +77,7 @@ class DownloadWorker(context: Context, private val workerParameters: WorkerParam
                 setAutoCancel(false)
             }
         )
+
         notificationManager.notify(downloadData.notificationId, downloadData.notificationBuilder.build())
         val response: Response<JsonObject>
         response = withContext(Dispatchers.IO) { CBOnlineLib.api.getOtp(downloadData.videoId, downloadData.sectionId, downloadData.attemptId, true) }