Track and show results from Indexing

app/src/main/java/zechs/zplex/data/repository/RemoteLibraryRepository.kt

@@ -10,6 +10,8 @@ import zechs.zplex.data.model.drive.DriveFile
 import zechs.zplex.data.model.entities.Movie
 import zechs.zplex.data.model.entities.Show
 import zechs.zplex.data.remote.RemoteLibrary
+import zechs.zplex.service.IndexingResult
+import zechs.zplex.service.IndexingStateFlow
 import zechs.zplex.utils.SessionManager
 import zechs.zplex.utils.state.Resource
 import zechs.zplex.utils.util.DriveApiQueryBuilder
@@ -18,7 +20,8 @@ import javax.inject.Inject
 class RemoteLibraryRepository @Inject constructor(
     private val driveRepository: DriveRepository,
     private val tmdbRepository: TmdbRepository,
-    private val sessionManager: SessionManager
+    private val sessionManager: SessionManager,
+    private val indexingStateFlow: IndexingStateFlow
 ) : RemoteLibrary {
 
     companion object {
@@ -32,12 +35,16 @@ class RemoteLibraryRepository @Inject constructor(
         val fileId: String
     )
 
+    private val moviesResult = IndexingResult()
+    private val showsResult = IndexingResult()
+
     override suspend fun indexMovies() {
         Log.d(TAG, "Beginning indexing movies...")
 
 
         if (!doesMoviesFolderExist()) {
-            Log.d(TAG, "Movies folder does not exist, skipping show processing.")
+            Log.d(TAG, "Movies folder does not exist, skipping movies processing.")
+            indexingStateFlow.emitErrorIndexingMovies("Movies folder does not exist, skipping movies processing.")
             return
         }
 
@@ -58,9 +65,12 @@ class RemoteLibraryRepository @Inject constructor(
 
             processMovies(driveFiles)
         } else {
+            indexingStateFlow.emitErrorIndexingMovies(driveFilesResult.message ?: "Unknown error")
             Log.d(TAG, "Error getting files: ${driveFilesResult.message ?: "Unknown error"}")
         }
 
+        Log.d(TAG, "Movies indexing result: $moviesResult")
+        indexingStateFlow.emitIndexingResultMovies(moviesResult)
         Log.d(TAG, "Ended indexing movies")
     }
 
@@ -81,7 +91,13 @@ class RemoteLibraryRepository @Inject constructor(
     private suspend fun processMovies(driveFiles: List<DriveFile>) {
         coroutineScope {
             driveFiles
-                .mapNotNull { parseFileName(it) }
+                .mapNotNull {
+                    val parse = parseFileName(it)
+                    if (parse == null) {
+                        moviesResult.indexingErrors++
+                    }
+                    parse
+                }
                 .map { videoInfo -> async(Dispatchers.IO) { processSingleMovie(videoInfo) } }
                 .awaitAll()
             synchronizeLocalMoviesWithRemote(driveFiles)
@@ -107,10 +123,12 @@ class RemoteLibraryRepository @Inject constructor(
             Log.d(TAG, "Movie already exists: ${videoFile.name}, updating videoId.")
             tmdbRepository.upsertMovie(existingMovie.copy(fileId = videoFile.fileId))
         }
+        moviesResult.existingItemsSkipped++
     }
 
     private suspend fun insertNewMovie(videoFile: Info) {
         Log.d(TAG, "New movie: ${videoFile.name}, inserting into the database.")
+        moviesResult.newItemsIndexed++
 
         val movieResponse = tmdbRepository.getMovie(videoFile.tmdbId, appendToQuery = null)
 
@@ -132,6 +150,7 @@ class RemoteLibraryRepository @Inject constructor(
             if (driveFiles.none { driveFile -> driveFile.id == savedMovie.fileId }) {
                 Log.d(TAG, "Deleting movie: ${savedMovie.title} from the database.")
                 tmdbRepository.deleteMovie(savedMovie.id)
+                moviesResult.deleted++
             }
         }
     }
@@ -141,6 +160,7 @@ class RemoteLibraryRepository @Inject constructor(
         Log.d(TAG, "Beginning indexing shows...")
 
         if (!doesShowsFolderExist()) {
+            indexingStateFlow.emitErrorIndexingShows("Shows folder does not exist, skipping show processing.")
             Log.d(TAG, "Shows folder does not exist, skipping show processing.")
             return
         }
@@ -162,9 +182,12 @@ class RemoteLibraryRepository @Inject constructor(
 
             processShows(driveFiles)
         } else {
+            indexingStateFlow.emitErrorIndexingShows(driveFilesResult.message ?: "Unknown error")
             Log.d(TAG, "Error getting files: ${driveFilesResult.message ?: "Unknown error"}")
         }
 
+        Log.d(TAG, "Shows indexing result: $showsResult")
+        indexingStateFlow.emitIndexingResultShows(showsResult)
         Log.d(TAG, "Ended indexing shows")
     }
 
@@ -184,7 +207,11 @@ class RemoteLibraryRepository @Inject constructor(
     private suspend fun processShows(shows: List<DriveFile>) {
         coroutineScope {
             shows
-                .mapNotNull { parseFileName(it, extension = false) }
+                .mapNotNull {
+                    val parse = parseFileName(it, extension = false)
+                    if (parse == null) { showsResult.indexingErrors++ }
+                    parse
+                }
                 .map { videoInfo -> async(Dispatchers.IO) { processSingleShow(videoInfo) } }
                 .awaitAll()
 
@@ -212,11 +239,13 @@ class RemoteLibraryRepository @Inject constructor(
             Log.d(TAG, "Show already exists: ${videoInfo.name}, updating videoId.")
             tmdbRepository.upsertShow(existingShow.copy(fileId = videoInfo.fileId))
         }
+        showsResult.existingItemsSkipped++
     }
 
 
     private suspend fun insertNewShow(videoInfo: Info) {
         Log.d(TAG, "New show: ${videoInfo.name}, inserting into the database.")
+        showsResult.newItemsIndexed++
 
         val showResponse = tmdbRepository.getShow(videoInfo.tmdbId, appendToQuery = null)
 
@@ -238,6 +267,7 @@ class RemoteLibraryRepository @Inject constructor(
         tmdbRepository.getSavedShows().value?.forEach { savedShow ->
             if (shows.none { show -> show.id == savedShow.fileId }) {
                 tmdbRepository.deleteShow(savedShow.id)
+                showsResult.deleted++
             }
         }
     }

app/src/main/java/zechs/zplex/di/ServiceModule.kt

@@ -49,9 +49,10 @@ object ServiceModule {
     fun provideRemoteLibrary(
         driveRepository: DriveRepository,
         tmdbRepository: TmdbRepository,
-        sessionManager: SessionManager
+        sessionManager: SessionManager,
+        indexingStateFlow: IndexingStateFlow
     ): RemoteLibrary {
-        return RemoteLibraryRepository(driveRepository, tmdbRepository, sessionManager,)
+        return RemoteLibraryRepository(driveRepository, tmdbRepository, sessionManager, indexingStateFlow)
     }
 
 }

app/src/main/java/zechs/zplex/service/IndexingServiceStateManager.kt

@@ -30,6 +30,37 @@ class IndexingStateFlow {
         }
     }
 
+    private val _indexingMoviesState = MutableStateFlow<IndexingState>(IndexingState.Checking)
+    val indexingMoviesState = _indexingMoviesState.asStateFlow()
+
+    fun emitErrorIndexingMovies(message: String) {
+        coroutineScope.launch {
+            _indexingMoviesState.value = IndexingState.Error(message)
+        }
+    }
+
+    fun emitIndexingResultMovies(result: IndexingResult) {
+        coroutineScope.launch {
+            _indexingMoviesState.value = IndexingState.Completed(result)
+        }
+    }
+
+    private val _indexingShowsState = MutableStateFlow<IndexingState>(IndexingState.Checking)
+    val indexingShowsState = _indexingShowsState.asStateFlow()
+
+
+    fun emitIndexingResultShows(result: IndexingResult) {
+        coroutineScope.launch {
+            _indexingShowsState.value = IndexingState.Completed(result)
+        }
+    }
+
+    fun emitErrorIndexingShows(message: String) {
+        coroutineScope.launch {
+            _indexingShowsState.value = IndexingState.Error(message)
+        }
+    }
+
 }
 
 sealed interface ServiceState {
@@ -38,6 +69,13 @@ sealed interface ServiceState {
     data class Stopped(val lastRun: String = getTimestamp()) : ServiceState
 }
 
+
+sealed interface IndexingState {
+    data object Checking : IndexingState
+    data class Error(val message: String) : IndexingState
+    data class Completed(val stats: IndexingResult) : IndexingState
+}
+
 private fun getTimestamp() = formatDate(Calendar.getInstance().timeInMillis)
 
 private fun formatDate(timeInMillis: Long): String {
@@ -47,3 +85,10 @@ private fun formatDate(timeInMillis: Long): String {
     val dateFormat = SimpleDateFormat("hh:mm a d MMM, yyyy", Locale.ENGLISH)
     return dateFormat.format(calendar.time)
 }
+
+data class IndexingResult(
+    var newItemsIndexed: Int = 0,
+    var existingItemsSkipped: Int = 0,
+    var indexingErrors: Int = 0,
+    var deleted: Int = 0,
+)

app/src/main/java/zechs/zplex/ui/settings/SettingsFragment.kt

@@ -31,6 +31,7 @@ import zechs.zplex.databinding.FragmentSettingsBinding
 import zechs.zplex.service.RemoteLibraryIndexingService
 import zechs.zplex.service.ServiceState
 import zechs.zplex.ui.settings.dialog.LoadingDialog
+import zechs.zplex.ui.settings.dialog.StatsDialog
 import zechs.zplex.utils.FolderPickerResultContract
 import zechs.zplex.utils.FolderType
 import zechs.zplex.utils.SelectedFolder
@@ -50,6 +51,7 @@ class SettingsFragment : Fragment() {
     private val viewModel by activityViewModels<SettingsViewModel>()
 
     private var loadingDialog: LoadingDialog? = null
+    private val statsDialog by lazy { StatsDialog(requireContext()) }
 
     override fun onCreate(savedInstanceState: Bundle?) {
         super.onCreate(savedInstanceState)
@@ -125,6 +127,7 @@ class SettingsFragment : Fragment() {
         loadingObserver()
         loginStatusObserver()
         indexingServiceObserver()
+        setupIndexingResultObserver()
     }
 
     private fun showFolderPickerDialog(
@@ -312,6 +315,7 @@ class SettingsFragment : Fragment() {
                     Intent(requireContext(), RemoteLibraryIndexingService::class.java)
                 )
             }
+            btnShowDetails.setOnClickListener { statsDialog.show() }
         }
     }
 
@@ -334,7 +338,25 @@ class SettingsFragment : Fragment() {
                     Snackbar.LENGTH_SHORT
                 ).show()
             }
+            btnShowDetails.setOnClickListener {
+                Snackbar.make(
+                    binding.root,
+                    getString(R.string.scanning_in_progress),
+                    Snackbar.LENGTH_SHORT
+                ).show()
+            }
+        }
+    }
+
+    private fun setupIndexingResultObserver() {
+        viewLifecycleOwner.lifecycleScope.launch {
+            repeatOnLifecycle(Lifecycle.State.STARTED) {
+                viewModel.combinedIndexingResult.collect { (movies, shows) ->
+                    statsDialog.updateStats(movies, shows)
+                }
+            }
         }
+
     }
 
     override fun onDestroy() {

app/src/main/java/zechs/zplex/ui/settings/SettingsViewModel.kt

@@ -6,10 +6,15 @@ import dagger.hilt.android.lifecycle.HiltViewModel
 import kotlinx.coroutines.Dispatchers
 import kotlinx.coroutines.async
 import kotlinx.coroutines.awaitAll
+import kotlinx.coroutines.flow.Flow
 import kotlinx.coroutines.flow.MutableStateFlow
+import kotlinx.coroutines.flow.SharingStarted
 import kotlinx.coroutines.flow.asStateFlow
+import kotlinx.coroutines.flow.combine
+import kotlinx.coroutines.flow.stateIn
 import kotlinx.coroutines.launch
 import zechs.zplex.data.repository.TmdbRepository
+import zechs.zplex.service.IndexingState
 import zechs.zplex.service.IndexingStateFlow
 import zechs.zplex.utils.SessionManager
 import javax.inject.Inject
@@ -64,4 +69,13 @@ class SettingsViewModel @Inject constructor(
     val isLoggedIn = sessionManager.isLoggedIn()
     val indexingServiceStatus = indexingStateFlow.serviceState
 
+    val combinedIndexingResult: Flow<Pair<IndexingState, IndexingState>> =
+        indexingStateFlow.indexingMoviesState
+            .combine(indexingStateFlow.indexingShowsState) { movies, shows -> Pair(movies, shows) }
+            .stateIn(
+                viewModelScope,
+                SharingStarted.Eagerly,
+                Pair(IndexingState.Checking, IndexingState.Checking)
+            )
+
 }

app/src/main/java/zechs/zplex/ui/settings/dialog/StatsDialog.kt

@@ -0,0 +1,26 @@
+package zechs.zplex.ui.settings.dialog
+
+import android.app.Dialog
+import android.content.Context
+import android.os.Bundle
+import android.util.Log
+import zechs.zplex.R
+import zechs.zplex.service.IndexingState
+
+class StatsDialog(context: Context) : Dialog(context) {
+
+    companion object {
+        const val TAG = "StatsDialog"
+    }
+
+    override fun onCreate(savedInstanceState: Bundle?) {
+        super.onCreate(savedInstanceState)
+        setTitle("Media library stats")
+        setContentView(R.layout.dialog_loading)
+    }
+
+    fun updateStats(movies: IndexingState, shows: IndexingState) {
+        Log.d(TAG, "updateStats: $movies, $shows")
+    }
+
+}

app/src/main/res/layout/dialog_stats.xml

@@ -0,0 +1,48 @@
+<?xml version="1.0" encoding="utf-8"?>
+<com.google.android.material.card.MaterialCardView xmlns:android="http://schemas.android.com/apk/res/android"
+    xmlns:app="http://schemas.android.com/apk/res-auto"
+    android:layout_width="match_parent"
+    android:layout_height="wrap_content"
+    android:layout_marginStart="16dp"
+    android:layout_marginTop="8dp"
+    android:layout_marginEnd="16dp"
+    android:layout_marginBottom="8dp"
+    android:elevation="16sp"
+    app:cardCornerRadius="48dp">
+
+    <androidx.constraintlayout.widget.ConstraintLayout
+        android:id="@+id/view_loading"
+        android:layout_width="match_parent"
+        android:layout_height="match_parent"
+        android:padding="24dp">
+
+        <ProgressBar
+            android:id="@+id/progressBar2"
+            style="?android:attr/progressBarStyle"
+            android:layout_width="wrap_content"
+            android:layout_height="wrap_content"
+            android:layout_marginStart="16dp"
+            app:layout_constraintBottom_toBottomOf="parent"
+            app:layout_constraintEnd_toStartOf="@+id/textView6"
+            app:layout_constraintHorizontal_bias="0.0"
+            app:layout_constraintStart_toStartOf="parent"
+            app:layout_constraintTop_toTopOf="parent" />
+
+        <TextView
+            android:id="@+id/textView6"
+            android:layout_width="0dp"
+            android:layout_height="wrap_content"
+            android:layout_marginStart="24dp"
+            android:layout_marginEnd="24dp"
+            android:text="@string/please_wait"
+            android:textAlignment="viewStart"
+            android:textColor="@color/textColor"
+            android:textSize="16sp"
+            app:layout_constraintBottom_toBottomOf="@+id/progressBar2"
+            app:layout_constraintEnd_toEndOf="parent"
+            app:layout_constraintHorizontal_bias="0.5"
+            app:layout_constraintStart_toEndOf="@+id/progressBar2"
+            app:layout_constraintTop_toTopOf="@+id/progressBar2" />
+    </androidx.constraintlayout.widget.ConstraintLayout>
+
+</com.google.android.material.card.MaterialCardView>