RemoteMediator kullanımı, genellikle uygulamanın internet bağlantısı olmadığında veya düşük bağlantı koşullarında, veriyi yerel depolama ile senkronize tutmak istediğiniz durumlarda tercih edilir. Bu yaklaşım, hem çevrimiçi hem de çevrimdışı kullanıcı deneyimini optimize eder. Peki, bu sistemi nasıl kurarız? İşte temel adımlar ve dikkat edilmesi gereken noktalar:
İlk olarak, RemoteMediator sınıfını extend ederek özelleştirilmiş bir mediator oluşturursunuz. Bu sınıf, sayfalama sırasında veri kaynağını kontrol eder ve hem uzak API'den hem de yerel veritabanından veri almayı yönetir. Offline modda, API erişimi mümkün değilse, doğrudan yerel veri kaynağına yönlendirilir. Bu durumda, aşağıdaki temel yapı devreye girer:
- Veri Kaynağı Entegrasyonu: RemoteMediator'un
load() fonksiyonunda, ilk olarak API çağrısı yapılmaya çalışılır. Eğer başarılıysa, alınan veriler yerel depolamaya kaydedilir. API erişimi başarısızsa veya bağlantı yoksa, doğrudan yerel veritabanındaki veriler kullanılır.
- Yerel Depolama ve Sorgu: Room veya başka bir yerel veritabanı kullanıyorsanız,
load() fonksiyonunda çevrimdışı modda veri sorgusunu yaparsınız. Bu, API çağrısı başarısız olduğunda otomatik devreye girer ve kullanıcılara en güncel verinin yerel kopyası sunulur.
- Sayfalama ve Senkronizasyon: API'den gelen yeni veriler, yerel veritabanına kaydedilir ve Paging kütüphanesi bu veriyi kullanarak sayfalar halinde sunum yapar. Offline modda, API'den veri alınamadığı için, yalnızca yerel veriler kullanılır. Bu, uygulamanın durmaksızın çalışmasını sağlar.
- Örnek Uygulama: Kotlin dilinde, RemoteMediator sınıfını şöyle tasarlayabilirsiniz:
CODE
class MyRemoteMediator(
private val database: AppDatabase,
private val apiService: ApiService
) : RemoteMediator() {
override suspend fun load(
loadType: LoadType,
state: PagingState
): MediatorResult {
return try {
val response = withContext(Dispatchers.IO) {
apiService.fetchData(page = getPageIndex(loadType, state))
}
// API başarısız olursa, catch bloğuna düşer
if (response.isSuccessful) {
val data = response.body() ?: emptyList()
database.withTransaction {
if (loadType == LoadType.REFRESH) {
database.dataDao().clearAll()
}
database.dataDao().insertAll(data)
}
MediatorResult.Success(endOfPaginationReached = data.isEmpty())
} else {
// API başarısızsa veya bağlantı yoksa, yerel veriyi kullan
MediatorResult.Success(endOfPaginationReached = true)
}
} catch (e: Exception) {
// Bağlantı hatası veya diğer istisnalar
MediatorResult.Success(endOfPaginationReached = true)
}
}
private fun getPageIndex(loadType: LoadType, state: PagingState): Int {
// Sayfa indeksini belirleme mantığı
return 1 // Basit örnek
}
}
ENDCODE
Bu yapı ile, internet bağlantısı olmadığında bile uygulama yerel veriyi kullanmaya devam eder. Ayrıca, bağlantı yeniden sağlandığında API'den güncellemeler alınarak veri senkronize edilir.
Son olarak, offline pagination kullanımında önemli olan, yerel verinin güncel tutulması ve kullanıcıların kesintisiz deneyim yaşaması için uygun senkronizasyon stratejileri geliştirmektir. Bu noktada, veri tutarlılığı ve performans arasında denge kurmak kritik öneme sahiptir.
