msfjarvis/compose-lobsters
1
Fork 0
mirror of https://github.com/msfjarvis/compose-lobsters synced 2025-08-17 22:37:03 +05:30
Code Issues Projects Releases Packages Wiki Activity Actions

app: start qualifying infra for hottest posts

Browse source 
Signed-off-by: Harsh Shandilya <me@msfjarvis.dev>
This commit is contained in:
Harsh Shandilya 2021-03-29 11:43:16 +05:30
parent b9c253733e
commit e3c5097035
No known key found for this signature in database
GPG key ID: 366D7BBAD1031E80
4 changed files with 12 additions and 11 deletions
Download patch file Download diff file Expand all files Collapse all files

4
app/src/main/java/dev/msfjarvis/lobsters/data/remote/LobstersPagingSource.kt → app/src/main/java/dev/msfjarvis/lobsters/data/remote/HottestPostsPagingSource.kt
View file

@ -5,7 +5,7 @@ import androidx.paging.PagingState
import dev.msfjarvis.lobsters.data.repo.LobstersRepository import dev.msfjarvis.lobsters.data.repo.LobstersRepository
import dev.msfjarvis.lobsters.model.LobstersPost import dev.msfjarvis.lobsters.model.LobstersPost
class LobstersPagingSource constructor( class HottestPostsPagingSource constructor(
private val lobstersRepository: LobstersRepository, private val lobstersRepository: LobstersRepository,
) : PagingSource<Int, LobstersPost>() { ) : PagingSource<Int, LobstersPost>() {
@ -15,7 +15,7 @@ class LobstersPagingSource constructor(
// Update cache before fetching a list. // Update cache before fetching a list.
// This is done to make sure that we can update the isSaved status of incoming posts. // This is done to make sure that we can update the isSaved status of incoming posts.
lobstersRepository.updateCache() lobstersRepository.updateCache()
val posts = lobstersRepository.fetchPosts(page) val posts = lobstersRepository.fetchHottestPosts(page)
LoadResult.Page( LoadResult.Page(
data = posts, data = posts,

2
app/src/main/java/dev/msfjarvis/lobsters/data/repo/LobstersRepository.kt
View file

@ -26,7 +26,7 @@ class LobstersRepository constructor(
return savedPostsCache.values.toList() return savedPostsCache.values.toList()
} }
suspend fun fetchPosts(page: Int): List<LobstersPost> = withContext(Dispatchers.IO) { suspend fun fetchHottestPosts(page: Int): List<LobstersPost> = withContext(Dispatchers.IO) {
return@withContext lobstersApi.getHottestPosts(page) return@withContext lobstersApi.getHottestPosts(page)
} }

5
app/src/main/java/dev/msfjarvis/lobsters/ui/main/LobstersApp.kt
View file

@ -33,7 +33,8 @@ import kotlinx.coroutines.launch
fun LobstersApp() { fun LobstersApp() {
val viewModel: LobstersViewModel = viewModel() val viewModel: LobstersViewModel = viewModel()
val navController = rememberNavController() val navController = rememberNavController()
val hottestPosts = viewModel.posts.collectAsLazyPagingItems() val hottestPosts = viewModel.hottestPosts.collectAsLazyPagingItems()
val savedPosts by viewModel.savedPosts.collectAsState() val savedPosts by viewModel.savedPosts.collectAsState()
val hottestPostsListState = rememberLazyListState() val hottestPostsListState = rememberLazyListState()
@ -76,7 +77,7 @@ fun LobstersApp() {
modifier = Modifier.padding(bottom = innerPadding.calculateBottomPadding()), modifier = Modifier.padding(bottom = innerPadding.calculateBottomPadding()),
isPostSaved = viewModel::isPostSaved, isPostSaved = viewModel::isPostSaved,
saveAction = viewModel::toggleSave, saveAction = viewModel::toggleSave,
refreshAction = viewModel::reloadPosts, refreshAction = viewModel::reloadHottestPosts,
) )
} }
composable(Destination.Saved.route) { composable(Destination.Saved.route) {

12
app/src/main/java/dev/msfjarvis/lobsters/ui/viewmodel/LobstersViewModel.kt
View file

@ -8,7 +8,7 @@ import androidx.paging.cachedIn
import dagger.hilt.android.lifecycle.HiltViewModel import dagger.hilt.android.lifecycle.HiltViewModel
import dev.msfjarvis.lobsters.data.local.SavedPost import dev.msfjarvis.lobsters.data.local.SavedPost
import dev.msfjarvis.lobsters.data.preferences.ClawPreferences import dev.msfjarvis.lobsters.data.preferences.ClawPreferences
import dev.msfjarvis.lobsters.data.remote.LobstersPagingSource import dev.msfjarvis.lobsters.data.remote.HottestPostsPagingSource
import dev.msfjarvis.lobsters.data.repo.LobstersRepository import dev.msfjarvis.lobsters.data.repo.LobstersRepository
import javax.inject.Inject import javax.inject.Inject
import kotlinx.coroutines.flow.Flow import kotlinx.coroutines.flow.Flow
@ -25,10 +25,10 @@ class LobstersViewModel @Inject constructor(
) : ViewModel() { ) : ViewModel() {
private val _savedPosts = MutableStateFlow<List<SavedPost>>(emptyList()) private val _savedPosts = MutableStateFlow<List<SavedPost>>(emptyList())
val savedPosts = _savedPosts.asStateFlow() val savedPosts = _savedPosts.asStateFlow()
val posts = Pager(PagingConfig(25)) { val hottestPosts = Pager(PagingConfig(25)) {
LobstersPagingSource(lobstersRepository).also { pagingSource = it } HottestPostsPagingSource(lobstersRepository).also { hottestPostsPagingSource = it }
}.flow.cachedIn(viewModelScope) }.flow.cachedIn(viewModelScope)
private var pagingSource: LobstersPagingSource? = null private var hottestPostsPagingSource: HottestPostsPagingSource? = null
init { init {
lobstersRepository.isCacheReady.onEach { ready -> lobstersRepository.isCacheReady.onEach { ready ->
@ -46,8 +46,8 @@ class LobstersViewModel @Inject constructor(
clawPreferences.toggleSortingOrder() clawPreferences.toggleSortingOrder()
} }
fun reloadPosts() { fun reloadHottestPosts() {
pagingSource?.invalidate() hottestPostsPagingSource?.invalidate()
} }
fun toggleSave(post: SavedPost) { fun toggleSave(post: SavedPost) {