feat: 屏蔽吧页面的直播广告

app/src/main/java/com/huanchengfly/tieba/post/repository/FrsPageRepository.kt

@@ -1,9 +1,14 @@
 package com.huanchengfly.tieba.post.repository
 
+import com.huanchengfly.tieba.post.App
 import com.huanchengfly.tieba.post.api.TiebaApi
 import com.huanchengfly.tieba.post.api.models.protos.frsPage.FrsPageResponse
+import com.huanchengfly.tieba.post.api.models.protos.threadList.ThreadListResponse
+import com.huanchengfly.tieba.post.api.retrofit.exception.TiebaUnknownException
+import com.huanchengfly.tieba.post.utils.appPreferences
 import kotlinx.coroutines.flow.Flow
 import kotlinx.coroutines.flow.flowOf
+import kotlinx.coroutines.flow.map
 import kotlinx.coroutines.flow.onEach
 
 object FrsPageRepository {
@@ -24,6 +29,35 @@ object FrsPageRepository {
         }
         lastHash = hash
         return TiebaApi.getInstance().frsPage(forumName, page, loadType, sortType, goodClassifyId)
+            .map { response ->
+                if (response.data_ == null) throw TiebaUnknownException
+                val userList = response.data_.user_list
+                val threadList = response.data_.thread_list
+                    .map { threadInfo ->
+                        threadInfo.copy(author = userList.find { it.id == threadInfo.authorId })
+                    }
+                    .filter { !App.INSTANCE.appPreferences.blockVideo || it.videoInfo == null }
+                    .filter { it.threadTypes != 3072 } // 去他妈的直播
+                response.copy(data_ = response.data_.copy(thread_list = threadList))
+            }
             .onEach { lastResponse = it }
     }
+
+    fun threadList(
+        forumId: Long,
+        forumName: String,
+        page: Int,
+        sortType: Int,
+        threadIds: String = "",
+    ): Flow<ThreadListResponse> =
+        TiebaApi.getInstance()
+            .threadList(forumId, forumName, page, sortType, threadIds)
+            .map { response ->
+                if (response.data_ == null) throw TiebaUnknownException
+                val userList = response.data_.user_list
+                val threadList = response.data_.thread_list.map { threadInfo ->
+                    threadInfo.copy(author = userList.find { it.id == threadInfo.authorId })
+                }
+                response.copy(data_ = response.data_.copy(thread_list = threadList))
+            }
 }

app/src/main/java/com/huanchengfly/tieba/post/ui/page/forum/threadlist/ForumThreadListViewModel.kt

@@ -1,11 +1,12 @@
 package com.huanchengfly.tieba.post.ui.page.forum.threadlist
 
 import androidx.compose.runtime.Stable
-import com.huanchengfly.tieba.post.App
 import com.huanchengfly.tieba.post.api.TiebaApi
 import com.huanchengfly.tieba.post.api.models.AgreeBean
 import com.huanchengfly.tieba.post.api.models.protos.ThreadInfo
 import com.huanchengfly.tieba.post.api.models.protos.frsPage.Classify
+import com.huanchengfly.tieba.post.api.models.protos.frsPage.FrsPageResponse
+import com.huanchengfly.tieba.post.api.retrofit.exception.TiebaUnknownException
 import com.huanchengfly.tieba.post.api.retrofit.exception.getErrorCode
 import com.huanchengfly.tieba.post.api.retrofit.exception.getErrorMessage
 import com.huanchengfly.tieba.post.api.updateAgreeStatus
@@ -19,7 +20,6 @@ import com.huanchengfly.tieba.post.arch.UiIntent
 import com.huanchengfly.tieba.post.arch.UiState
 import com.huanchengfly.tieba.post.arch.wrapImmutable
 import com.huanchengfly.tieba.post.repository.FrsPageRepository
-import com.huanchengfly.tieba.post.utils.appPreferences
 import dagger.hilt.android.lifecycle.HiltViewModel
 import kotlinx.coroutines.ExperimentalCoroutinesApi
 import kotlinx.coroutines.flow.Flow
@@ -96,107 +96,76 @@ private class ForumThreadListPartialChangeProducer(val type: ForumThreadListType
             sortType.takeIf { type == ForumThreadListType.Latest } ?: -1,
             goodClassifyId.takeIf { type == ForumThreadListType.Good }
         )
-            .map { response ->
+            .map<FrsPageResponse, ForumThreadListPartialChange.FirstLoad> { response ->
-                if (response.data_?.page == null) ForumThreadListPartialChange.FirstLoad.Failure(
+                if (response.data_?.page == null) throw TiebaUnknownException
-                    NullPointerException("未知错误")
-                )
-                else {
-                    val userList = response.data_.user_list
-                    val threadList = response.data_.thread_list.map { threadInfo ->
-                        threadInfo.copy(author = userList.find { it.id == threadInfo.authorId })
-                    }.filter { !App.INSTANCE.appPreferences.blockVideo || it.videoInfo == null }
                 ForumThreadListPartialChange.FirstLoad.Success(
-                        threadList.wrapImmutable(),
+                    response.data_.thread_list.wrapImmutable(),
                     response.data_.thread_id_list,
                     (response.data_.forum?.good_classify ?: emptyList()).wrapImmutable(),
                     goodClassifyId.takeIf { type == ForumThreadListType.Good },
                     response.data_.page.has_more == 1
                 )
             }
-            }
             .onStart { emit(ForumThreadListPartialChange.FirstLoad.Start) }
             .catch { emit(ForumThreadListPartialChange.FirstLoad.Failure(it)) }
 
     private fun ForumThreadListUiIntent.Refresh.producePartialChange() =
-        TiebaApi.getInstance().frsPage(
+        FrsPageRepository.frsPage(
             forumName,
             1,
             1,
             sortType.takeIf { type == ForumThreadListType.Latest } ?: -1,
             goodClassifyId.takeIf { type == ForumThreadListType.Good }
         )
-            .map { response ->
+            .map<FrsPageResponse, ForumThreadListPartialChange.Refresh> { response ->
-                if (response.data_?.page == null) ForumThreadListPartialChange.Refresh.Failure(
+                if (response.data_?.page == null) throw TiebaUnknownException
-                    NullPointerException("未知错误")
-                )
-                else {
-                    val userList = response.data_.user_list
-                    val threadList = response.data_.thread_list.map { threadInfo ->
-                        threadInfo.copy(author = userList.find { it.id == threadInfo.authorId })
-                    }
                 ForumThreadListPartialChange.Refresh.Success(
-                        threadList.wrapImmutable(),
+                    response.data_.thread_list.wrapImmutable(),
                     response.data_.thread_id_list,
                     (response.data_.forum?.good_classify ?: emptyList()).wrapImmutable(),
                     goodClassifyId.takeIf { type == ForumThreadListType.Good },
                     response.data_.page.has_more == 1
                 )
             }
-            }
             .onStart { emit(ForumThreadListPartialChange.Refresh.Start) }
             .catch { emit(ForumThreadListPartialChange.Refresh.Failure(it)) }
 
     private fun ForumThreadListUiIntent.LoadMore.producePartialChange(): Flow<ForumThreadListPartialChange.LoadMore> {
         val flow = if (threadListIds.isNotEmpty()) {
             val size = min(threadListIds.size, 30)
-            TiebaApi.getInstance().threadList(
+            FrsPageRepository.threadList(
                 forumId,
                 forumName,
                 currentPage,
                 sortType,
                 threadListIds.subList(0, size).joinToString(separator = ",") { "$it" }
             ).map { response ->
-                if (response.data_ == null) ForumThreadListPartialChange.LoadMore.Failure(
+                if (response.data_ == null) throw TiebaUnknownException
-                    NullPointerException("未知错误")
-                )
-                else {
-                    val userList = response.data_.user_list
-                    val threadList = response.data_.thread_list.map { threadInfo ->
-                        threadInfo.copy(author = userList.find { it.id == threadInfo.authorId })
-                    }
                 ForumThreadListPartialChange.LoadMore.Success(
-                        threadList = threadList.wrapImmutable(),
+                    threadList = response.data_.thread_list.wrapImmutable(),
                     threadListIds = threadListIds.drop(size),
                     currentPage = currentPage,
-                        hasMore = threadList.isNotEmpty()
+                    hasMore = response.data_.thread_list.isNotEmpty()
                 )
             }
-            }
         } else {
-            TiebaApi.getInstance().frsPage(
+            FrsPageRepository.frsPage(
                 forumName,
                 currentPage + 1,
                 2,
                 sortType.takeIf { type == ForumThreadListType.Latest } ?: -1,
                 goodClassifyId.takeIf { type == ForumThreadListType.Good }
-            ).map { response ->
-                if (response.data_ == null) ForumThreadListPartialChange.LoadMore.Failure(
-                    NullPointerException("未知错误")
             )
-                else {
+                .map<FrsPageResponse, ForumThreadListPartialChange.LoadMore> { response ->
-                    val userList = response.data_.user_list
+                    if (response.data_?.page == null) throw TiebaUnknownException
-                    val threadList = response.data_.thread_list.map { threadInfo ->
-                        threadInfo.copy(author = userList.find { it.id == threadInfo.authorId })
-                    }
                     ForumThreadListPartialChange.LoadMore.Success(
-                        threadList = threadList.wrapImmutable(),
+                        threadList = response.data_.thread_list.wrapImmutable(),
                         threadListIds = response.data_.thread_id_list,
                         currentPage = currentPage + 1,
-                        hasMore = threadList.isNotEmpty()
+                        response.data_.page.has_more == 1
                     )
                 }
         }
-        }
         return flow
             .onStart { emit(ForumThreadListPartialChange.LoadMore.Start) }
             .catch { emit(ForumThreadListPartialChange.LoadMore.Failure(it)) }

app/src/main/java/com/huanchengfly/tieba/post/ui/page/thread/ThreadPage.kt

@@ -504,11 +504,8 @@ fun ThreadPage(
         initial = false
     )
 
-    val showFirstPostContent by remember {
-        derivedStateOf { firstPostContentRenders.isNotEmpty() && author != null }
-    }
     val isEmpty by remember {
-        derivedStateOf { data.isEmpty() && !showFirstPostContent }
+        derivedStateOf { data.isEmpty() && firstPost == null }
     }
     val isCollected = remember(thread) {
         thread?.get { collectStatus != 0 } == true
@@ -890,7 +887,7 @@ fun ThreadPage(
                                     modifier = Modifier.fillMaxWidth()
                                 ) {
                                     item(key = "FirstPost") {
-                                        if (showFirstPostContent && firstPost != null) {
+                                        if (firstPost != null) {
                                             Column {
                                                 PostCard(
                                                     postHolder = firstPost!!,