Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 3 additions & 1 deletion app/build.gradle.kts
Original file line number Diff line number Diff line change
Expand Up @@ -120,7 +120,9 @@ dependencies {
androidTestImplementation(libs.androidx.ui.test.junit4)
debugImplementation(libs.androidx.ui.tooling)
debugImplementation(libs.androidx.ui.test.manifest)
implementation(libs.android.driver)
implementation(libs.sql.delight)
implementation(libs.sql.delight.paging3)
implementation(libs.paging.compose)
implementation(libs.coroutines.extensions)
implementation(project.dependencies.platform(libs.koin.bom))
implementation(libs.koin.core)
Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1,74 @@
package com.yogeshpaliyal.deepr.data

import androidx.paging.PagingSource
import androidx.paging.PagingState
import com.yogeshpaliyal.deepr.DeeprQueries
import com.yogeshpaliyal.deepr.GetLinksAndTags
import com.yogeshpaliyal.deepr.Tags
import kotlinx.coroutines.Dispatchers
import kotlinx.coroutines.withContext

class AccountPagingSource(
private val deeprQueries: DeeprQueries,
private val searchQuery: String,
private val favouriteFilter: Int,
private val selectedTags: List<Tags>,
private val sortField: String,
private val sortType: String,
) : PagingSource<Int, GetLinksAndTags>() {
override fun getRefreshKey(state: PagingState<Int, GetLinksAndTags>): Int? =
state.anchorPosition?.let { anchorPosition ->
state.closestPageToPosition(anchorPosition)?.prevKey?.plus(state.config.pageSize)
?: state.closestPageToPosition(anchorPosition)?.nextKey?.minus(state.config.pageSize)
}

override suspend fun load(params: LoadParams<Int>): LoadResult<Int, GetLinksAndTags> =
try {
val offset = params.key ?: 0
val limit = params.loadSize

val tagIdsString =
if (selectedTags.isEmpty()) "" else selectedTags.joinToString(",") { it.id.toString() }
val tagCount = selectedTags.size.toLong()

// Fetch data using the paged query
val dataFromPagedQuery =
withContext(Dispatchers.IO) {
deeprQueries
.getLinksAndTagsPaged(
searchQuery = searchQuery,
favouriteFilter = favouriteFilter.toLong(),
tagIdsString = tagIdsString,
tagCount = tagCount,
sortField = sortField,
sortType = sortType,
limit = limit.toLong(),
offset = offset.toLong(),
).executeAsList()
}

val mappedData =
dataFromPagedQuery.map { pagedItem ->
GetLinksAndTags(
id = pagedItem.id,
link = pagedItem.link,
name = pagedItem.name,
createdAt = pagedItem.createdAt,
openedCount = pagedItem.openedCount,
isFavourite = pagedItem.isFavourite,
notes = pagedItem.notes,
lastOpenedAt = pagedItem.lastOpenedAt,
tagsNames = pagedItem.tagsNames,
tagsIds = pagedItem.tagsIds,
)
}

LoadResult.Page(
data = mappedData,
prevKey = if (offset == 0) null else offset - limit,
nextKey = if (mappedData.isEmpty()) null else offset + limit,
)
} catch (e: Exception) {
LoadResult.Error(e)
}
}
Loading