kavin/LibreTube
1
0
Fork 0
mirror of https://github.com/libre-tube/LibreTube.git synced 2025-04-27 23:40:33 +05:30
Code Issues Projects Releases Wiki Activity

Merge pull request #7141 from FineFindus/feat/update-local-feed-data

Browse Source 
feat(Feed): update local feed data when watching video
This commit is contained in:
Bnyro 2025-03-01 13:41:10 +01:00 committed by GitHub
commit 9f2dadce3a
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
5 changed files with 20 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
app/src/main/java/com/github/libretube/api/SubscriptionHelper.kt
View File

@ -3,6 +3,7 @@ package com.github.libretube.api
import android.content.Context
import com.github.libretube.R
import com.github.libretube.constants.PreferenceKeys
import com.github.libretube.db.obj.SubscriptionsFeedItem
import com.github.libretube.helpers.PreferenceHelper
import com.github.libretube.repo.AccountSubscriptionsRepository
import com.github.libretube.repo.FeedProgress
@ -49,6 +50,7 @@ object SubscriptionHelper {
suspend fun getSubscriptionChannelIds() = subscriptionsRepository.getSubscriptionChannelIds()
suspend fun getFeed(forceRefresh: Boolean, onProgressUpdate: (FeedProgress) -> Unit = {}) =
feedRepository.getFeed(forceRefresh, onProgressUpdate)
suspend fun submitFeedItemChange(feedItem: SubscriptionsFeedItem) = feedRepository.submitFeedItemChange(feedItem)
fun handleUnsubscribe(
context: Context,

4
app/src/main/java/com/github/libretube/db/dao/SubscriptionsFeedDao.kt
View File

@ -4,6 +4,7 @@ import androidx.room.Dao
import androidx.room.Insert
import androidx.room.OnConflictStrategy
import androidx.room.Query
import androidx.room.Update
import com.github.libretube.db.obj.SubscriptionsFeedItem
@Dao
@ -14,6 +15,9 @@ interface SubscriptionsFeedDao {
@Insert(onConflict = OnConflictStrategy.REPLACE)
suspend fun insertAll(feedItems: List<SubscriptionsFeedItem>)
@Update
suspend fun update(feedItem: SubscriptionsFeedItem)
@Query("SELECT EXISTS (SELECT * FROM feedItem WHERE videoId = :videoId)")
suspend fun contains(videoId: String): Boolean

2
app/src/main/java/com/github/libretube/repo/FeedRepository.kt
View File

@ -1,6 +1,7 @@
package com.github.libretube.repo
import com.github.libretube.api.obj.StreamItem
import com.github.libretube.db.obj.SubscriptionsFeedItem
data class FeedProgress(
val currentProgress: Int,
@ -12,4 +13,5 @@ interface FeedRepository {
forceRefresh: Boolean,
onProgressUpdate: (FeedProgress) -> Unit
): List<StreamItem>
suspend fun submitFeedItemChange(feedItem: SubscriptionsFeedItem) {}
}

4
app/src/main/java/com/github/libretube/repo/LocalFeedRepository.kt
View File

@ -35,6 +35,10 @@ class LocalFeedRepository : FeedRepository {
if (filter.isEnabled) tab else null
}.toTypedArray()
override suspend fun submitFeedItemChange(feedItem: SubscriptionsFeedItem) {
DatabaseHolder.Database.feedDao().update(feedItem)
}
override suspend fun getFeed(
forceRefresh: Boolean,
onProgressUpdate: (FeedProgress) -> Unit

9
app/src/main/java/com/github/libretube/services/OnlinePlayerService.kt
View File

@ -14,11 +14,13 @@ import com.github.libretube.R
import com.github.libretube.api.JsonHelper
import com.github.libretube.api.RetrofitInstance
import com.github.libretube.api.StreamsExtractor
import com.github.libretube.api.SubscriptionHelper
import com.github.libretube.api.obj.Segment
import com.github.libretube.api.obj.Streams
import com.github.libretube.constants.IntentData
import com.github.libretube.constants.PreferenceKeys
import com.github.libretube.db.DatabaseHelper
import com.github.libretube.db.DatabaseHolder
import com.github.libretube.enums.PlayerCommand
import com.github.libretube.extensions.parcelable
import com.github.libretube.extensions.setMetadata
@ -138,9 +140,14 @@ open class OnlinePlayerService : AbstractPlayerService() {
PlayingQueue.insertRelatedStreams(streams!!.relatedStreams)
}
// save the current stream to the queue
streams?.toStreamItem(videoId)?.let {
// save the current stream to the queue
PlayingQueue.updateCurrent(it)
// update feed item with newer information, e.g. more up-to-date views
SubscriptionHelper.submitFeedItemChange(
it.toFeedItem()
)
}
withContext(Dispatchers.Main) {