Added Episode duration tracker

app/src/main/java/com/kl3jvi/animity/domain/GetEpisodeInfoUseCase.kt

@@ -15,7 +15,7 @@ class GetEpisodeInfoUseCase @Inject constructor(
  private val playerRepository: PlayerRepository,
  private val ioDispatcher: CoroutineDispatcher
 ) {
- fun fetchEpisodeMediaUrl(url: String) = flow {
+ operator fun invoke(url: String) = flow {
  emit(Resource.Loading())
  try {
  val response = HtmlParser.parseMediaUrl(

app/src/main/java/com/kl3jvi/animity/domain/GetSearchResultUseCase.kt

@@ -1,9 +1,9 @@
 package com.kl3jvi.animity.domain
 
 import com.kl3jvi.animity.model.AnimeMetaModel
+import com.kl3jvi.animity.repository.SearchRepository
 import com.kl3jvi.animity.utils.Constants
 import com.kl3jvi.animity.utils.Resource
-import com.kl3jvi.animity.repository.SearchRepository
 import kotlinx.coroutines.CoroutineDispatcher
 import kotlinx.coroutines.flow.Flow
 import kotlinx.coroutines.flow.flow
@@ -19,37 +19,39 @@ class GetSearchResultUseCase @Inject constructor(
  private val ioDispatcher: CoroutineDispatcher
 ) {
 
- fun getSearchData(searchQuery: String): Flow<Resource<List<AnimeMetaModel>>> = flow {
- try {
- emit(Resource.Loading())
- val response =
- Constants.parseList(
- searchRepository.fetchSearchData(
- Constants.getHeader(),
- searchQuery,
- 1
- ).string(),
- Constants.TYPE_MOVIE
- ).toList()
- emit(
- Resource.Success(
- data = response
+ operator fun invoke(searchQuery: String): Flow<Resource<List<AnimeMetaModel>>> =
+ flow {
+ try {
+ emit(Resource.Loading())
+ val response =
+ Constants.parseList(
+ searchRepository.fetchSearchData(
+ Constants.getHeader(),
+ searchQuery,
+ 1
+ ).string(),
+ Constants.TYPE_MOVIE
+ ).toList()
+ emit(
+ Resource.Success(
+ data = response
+ )
  )
- )
- } catch (e: HttpException) {
- emit(
- Resource.Error(
- message = e.localizedMessage ?: "An unexpected error occurred",
+ } catch (e: HttpException) {
+  emit(
+  Resource.Error(
+  message = e.localizedMessage ?: "An unexpected error occurred",
+ )
  )
- )
- } catch (e: IOException) {
- emit(
- Resource.Error(
- e.localizedMessage ?: "Couldn't reach server. Check your internet connection.",
+ } catch (e: IOException) {
+  emit(
+  Resource.Error(
+  e.localizedMessage
+   ?: "Couldn't reach server. Check your internet connection.",
 
- )
- )
- }
- }.flowOn(ioDispatcher)
+  )
+  )
+  }
+  }.flowOn(ioDispatcher)
 
 }

app/src/main/java/com/kl3jvi/animity/persistence/EpisodeDao.kt

@@ -10,7 +10,7 @@ interface EpisodeDao {
  suspend fun insertEpisode(content: Content)
 
  @Query("SELECT * FROM Content WHERE episodeUrl =:episodeUrl")
- fun getEpisodeContent(episodeUrl: String): Content
+ suspend fun getEpisodeContent(episodeUrl: String): Content
 
  @Update
  suspend fun updateEpisode(content: Content)

app/src/main/java/com/kl3jvi/animity/ui/activities/player/PlayerActivity.kt

@@ -60,6 +60,8 @@ class PlayerActivity : AppCompatActivity() {
  lateinit var episodeNumberLocal: String
  lateinit var episodeUrlLocal: String
  lateinit var content: Content
+
+
  override fun onCreate(savedInstanceState: Bundle?) {
  super.onCreate(savedInstanceState)
  setContentView(viewBinding.root)
@@ -80,7 +82,6 @@ class PlayerActivity : AppCompatActivity() {
  initialisePlayerLayout()
  viewModel.updateEpisodeUrl(getIntentData?.episodeUrl.toString())
 
-
  }
  }
 
@@ -154,6 +155,7 @@ class PlayerActivity : AppCompatActivity() {
  exoPlayer.seekTo(playbackPosition)
  exoPlayer.prepare()
  }
+
  player!!.addListener(object : Player.Listener {
  override fun onPlayerStateChanged(
  playWhenReady: Boolean,
@@ -206,12 +208,18 @@ class PlayerActivity : AppCompatActivity() {
  })
  }
 
+ override fun onBackPressed() {
+ super.onBackPressed()
+ if (::content.isInitialized)
+ insertEpisodeToDatabase(content.copy(watchedDuration = player!!.currentPosition))
+ }
 
  private fun initialisePlayerLayout() {
 
  val backButton = viewBinding.videoView.findViewById<ImageView>(R.id.back)
  backButton.setOnClickListener {
- insertEpisodeToDatabase(content.copy(watchedDuration = player!!.currentPosition))
+ if (::content.isInitialized)
+ insertEpisodeToDatabase(content.copy(watchedDuration = player!!.currentPosition))
  finish()
  }
 
@@ -237,11 +245,6 @@ class PlayerActivity : AppCompatActivity() {
  }
  }
 
- private fun getVideoDurationSeconds(player: ExoPlayer): Long {
- val timeMs = player.duration
- return timeMs / 1000
- }
-
  private fun showQualityDialog() {
  mappedTrackInfo = trackSelector?.currentMappedTrackInfo
  try {

app/src/main/java/com/kl3jvi/animity/ui/activities/player/PlayerViewModel.kt

@@ -28,7 +28,7 @@ class PlayerViewModel @Inject constructor(
 
  @ExperimentalCoroutinesApi
  val videoUrlLiveData = Transformations.switchMap(_vidUrl) { url ->
- getEpisodeInfoUseCase.fetchEpisodeMediaUrl(url).flatMapLatest { episodeInfo ->
+ getEpisodeInfoUseCase(url).flatMapLatest { episodeInfo ->
  getEpisodeInfoUseCase.fetchM3U8(episodeInfo.data?.vidCdnUrl)
  }.asLiveData()
  }
@@ -53,4 +53,5 @@ class PlayerViewModel @Inject constructor(
  }
  }
 
+
 }

app/src/main/java/com/kl3jvi/animity/ui/fragments/details/DetailsFragment.kt

@@ -83,8 +83,7 @@ class DetailsFragment : Fragment() {
  diskCachePolicy(CachePolicy.ENABLED)
  }
  episodeListRecycler.layoutManager = LinearLayoutManager(requireContext())
- episodeAdapter =
- CustomEpisodeAdapter(this@DetailsFragment, animeInfo.title)
+ episodeAdapter = CustomEpisodeAdapter(this@DetailsFragment, animeInfo.title)
  resultTitle.text = animeInfo.title
 
  title = animeInfo.title
@@ -129,6 +128,7 @@ class DetailsFragment : Fragment() {
  }
  }
  info.genre.forEach { data ->
+ binding.genreGroup.removeAllViews()
  val chip = Chip(requireContext())
  chip.apply {
  text = data.genreName
@@ -234,7 +234,6 @@ class DetailsFragment : Fragment() {
  super.onResume()
  if (requireActivity() is MainActivity) {
  (activity as MainActivity?)?.hideBottomNavBar()
- episodeAdapter
  }
  }
 

app/src/main/java/com/kl3jvi/animity/ui/fragments/details/DetailsViewModel.kt

@@ -40,12 +40,9 @@ class DetailsViewModel @Inject constructor(
  }.asLiveData(Dispatchers.Default + viewModelScope.coroutineContext)
  }
 
-
-
-
  @ExperimentalCoroutinesApi
  val downloadEpisodeUrl = Transformations.switchMap(_downloadUrl) { url ->
- getEpisodeInfoUseCase.fetchEpisodeMediaUrl(url).flatMapLatest { episodeInfo ->
+ getEpisodeInfoUseCase(url).flatMapLatest { episodeInfo ->
  getEpisodeInfoUseCase.fetchM3U8(episodeInfo.data?.vidCdnUrl)
  }.asLiveData()
  }

app/src/main/java/com/kl3jvi/animity/ui/fragments/search/SearchViewModel.kt

@@ -3,22 +3,21 @@ package com.kl3jvi.animity.ui.fragments.search
 import androidx.lifecycle.*
 import com.kl3jvi.animity.domain.GetSearchResultUseCase
 import dagger.hilt.android.lifecycle.HiltViewModel
-import kotlinx.coroutines.Dispatchers
+import kotlinx.coroutines.CoroutineDispatcher
 import javax.inject.Inject
 
 @HiltViewModel
 class SearchViewModel @Inject constructor(
  private val getSearchResultUseCase: GetSearchResultUseCase,
+ private val ioDispatcher: CoroutineDispatcher
 ) : ViewModel() {
 
  private val _query = MutableLiveData<String>()
-
  val searchResult = Transformations.switchMap(_query) { query ->
- getSearchResultUseCase.getSearchData(query)
- .asLiveData(Dispatchers.IO + viewModelScope.coroutineContext)
+ getSearchResultUseCase(query).asLiveData(ioDispatcher + viewModelScope.coroutineContext)
  }
 
  fun passQuery(query: String) {
  _query.value = query
  }
-}
+}