add stuff

Author: hoc081098

.idea/vcs.xml

@@ -57,6 +57,9 @@ dependencies {
     // Extensions for LiveData
     implementation 'androidx.lifecycle:lifecycle-livedata-ktx:2.3.0-alpha02'
 
+    // Java 8 support
+    implementation "androidx.lifecycle:lifecycle-common-java8:2.3.0-alpha02"
+
     // coroutines
     implementation 'org.jetbrains.kotlinx:kotlinx-coroutines-core:1.3.5'
     implementation 'org.jetbrains.kotlinx:kotlinx-coroutines-android:1.3.5'

app/build.gradle

@@ -2,7 +2,10 @@
 <manifest xmlns:android="http://schemas.android.com/apk/res/android"
     package="com.hoc081098.firestore_coroutinesflow">
 
+    <uses-permission android:name="android.permission.INTERNET" />
+
     <application
+        android:name=".App"
         android:allowBackup="true"
         android:icon="@mipmap/ic_launcher"
         android:label="@string/app_name"

app/src/main/AndroidManifest.xml

@@ -0,0 +1,28 @@
+package com.hoc081098.firestore_coroutinesflow
+
+import android.app.Application
+import com.hoc081098.firestore_coroutinesflow.koin.dataModule
+import com.hoc081098.firestore_coroutinesflow.koin.domainModule
+import com.hoc081098.firestore_coroutinesflow.koin.viewModelModule
+import kotlinx.coroutines.ExperimentalCoroutinesApi
+import org.koin.android.ext.koin.androidContext
+import org.koin.android.ext.koin.androidLogger
+import org.koin.core.context.startKoin
+
+@Suppress("unused")
+@ExperimentalCoroutinesApi
+class App : Application() {
+  override fun onCreate() {
+    super.onCreate()
+
+    startKoin {
+      androidLogger()
+      androidContext(this@App)
+      modules(
+        dataModule,
+        domainModule,
+        viewModelModule,
+      )
+    }
+  }
+}

app/src/main/java/com/hoc081098/firestore_coroutinesflow/App.kt

@@ -0,0 +1,13 @@
+package com.hoc081098.firestore_coroutinesflow
+
+sealed class Lce<out T> {
+  object Loading : Lce<Nothing>()
+  data class Content<out T>(val content: T) : Lce<T>()
+  data class Error<out T>(val exception: Throwable) : Lce<T>()
+
+  companion object Factory {
+    fun <T> content(content: T): Lce<T> = Content(content)
+    fun <T> loading(): Lce<T> = Loading
+    fun <T> error(exception: Throwable): Lce<T> = Error(exception)
+  }
+}

app/src/main/java/com/hoc081098/firestore_coroutinesflow/Lce.kt

@@ -0,0 +1,53 @@
+package com.hoc081098.firestore_coroutinesflow
+
+import android.util.Log
+import android.view.View
+import androidx.fragment.app.Fragment
+import androidx.lifecycle.DefaultLifecycleObserver
+import androidx.lifecycle.Lifecycle
+import androidx.lifecycle.LifecycleOwner
+import androidx.viewbinding.ViewBinding
+import kotlin.properties.ReadOnlyProperty
+import kotlin.reflect.KProperty
+
+class ViewBindingDelegate<T : ViewBinding>(
+  private val fragment: Fragment,
+  private val viewBindingFactory: (View) -> T,
+) : ReadOnlyProperty<Fragment, T> {
+  private var binding: T? = null
+
+  init {
+    fragment.lifecycle.addObserver(object : DefaultLifecycleObserver {
+      override fun onCreate(owner: LifecycleOwner) {
+        fragment.viewLifecycleOwnerLiveData.observe(fragment) { viewLifecycleOwner ->
+          Log.d("###", "$fragment::view::viewLifecycleOwnerLiveData")
+
+          viewLifecycleOwner?.lifecycle?.addObserver(object : DefaultLifecycleObserver {
+            override fun onDestroy(owner: LifecycleOwner) {
+              binding = null
+              viewLifecycleOwner.lifecycle.removeObserver(this)
+              Log.d("###", "$fragment::view::onDestroy")
+            }
+          })
+        }
+      }
+
+      override fun onDestroy(owner: LifecycleOwner) {
+        fragment.lifecycle.removeObserver(this)
+      }
+    })
+  }
+
+  override fun getValue(thisRef: Fragment, property: KProperty<*>): T {
+    binding?.let { return it }
+
+    if (!fragment.viewLifecycleOwner.lifecycle.currentState.isAtLeast(Lifecycle.State.INITIALIZED)) {
+      error("Attempt to get view binding when fragment view is destroyed")
+    }
+
+    return viewBindingFactory(thisRef.requireView()).also { binding = it }
+  }
+}
+
+fun <T : ViewBinding> Fragment.viewBinding(factory: (View) -> T) =
+  ViewBindingDelegate<T>(this, factory)

app/src/main/java/com/hoc081098/firestore_coroutinesflow/ViewBindingDelegate.kt

@@ -0,0 +1,58 @@
+package com.hoc081098.firestore_coroutinesflow.data
+
+import android.util.Log
+import com.google.firebase.firestore.FirebaseFirestore
+import com.google.firebase.firestore.FirebaseFirestoreException
+import com.google.firebase.firestore.Query
+import com.google.firebase.firestore.QuerySnapshot
+import com.hoc081098.firestore_coroutinesflow.data.entity.CategoryEntity
+import com.hoc081098.firestore_coroutinesflow.domain.entity.Category
+import com.hoc081098.firestore_coroutinesflow.domain.repo.CategoryRepo
+import kotlinx.coroutines.CoroutineDispatcher
+import kotlinx.coroutines.Dispatchers
+import kotlinx.coroutines.ExperimentalCoroutinesApi
+import kotlinx.coroutines.channels.awaitClose
+import kotlinx.coroutines.flow.Flow
+import kotlinx.coroutines.flow.callbackFlow
+import kotlinx.coroutines.flow.flowOn
+import kotlinx.coroutines.flow.map
+
+@ExperimentalCoroutinesApi
+class CategoryRepoImpl(
+  private val firestore: FirebaseFirestore,
+  private val ioDispatcher: CoroutineDispatcher = Dispatchers.IO,
+) : CategoryRepo {
+  override fun watchCategories(): Flow<List<Category>> {
+    return firestore
+      .collection("categories")
+      .snapshots()
+      .map { (querySnapshot, exception) ->
+        if (exception !== null) throw exception
+        (querySnapshot ?: return@map emptyList())
+          .documents
+          .mapNotNull { it.toObject(CategoryEntity::class.java)?.toCategory(it.id) }
+      }
+      .flowOn(ioDispatcher)
+  }
+}
+
+private fun CategoryEntity.toCategory(id: String): Category {
+  return Category(
+    name = name,
+    imageUrl = imageUrl,
+    id = id
+  )
+}
+
+@ExperimentalCoroutinesApi
+fun Query.snapshots(): Flow<Pair<QuerySnapshot?, FirebaseFirestoreException?>> {
+  return callbackFlow {
+    val listener = addSnapshotListener { querySnapshot, exception ->
+      offer(querySnapshot to exception)
+    }
+    awaitClose {
+      listener.remove()
+      Log.d("###", "Remove listener $listener")
+    }
+  }
+}

app/src/main/java/com/hoc081098/firestore_coroutinesflow/data/CategoryRepoImpl.kt

@@ -0,0 +1,15 @@
+package com.hoc081098.firestore_coroutinesflow.data.entity
+
+import com.google.firebase.firestore.PropertyName
+
+data class CategoryEntity(
+  @get:PropertyName("name")
+  @set:PropertyName("name")
+  var name: String,
+  @get:PropertyName("imageUrl")
+  @set:PropertyName("imageUrl")
+  var imageUrl: String,
+) {
+  @Suppress("unused")
+  constructor() : this(name = "", imageUrl = "")
+}

app/src/main/java/com/hoc081098/firestore_coroutinesflow/data/entity/CategoryEntity.kt

@@ -0,0 +1,7 @@
+package com.hoc081098.firestore_coroutinesflow.domain.entity
+
+data class Category(
+  val id: String,
+  val name: String,
+  val imageUrl: String,
+)

app/src/main/java/com/hoc081098/firestore_coroutinesflow/domain/entity/Category.kt

@@ -0,0 +1,8 @@
+package com.hoc081098.firestore_coroutinesflow.domain.repo
+
+import com.hoc081098.firestore_coroutinesflow.domain.entity.Category
+import kotlinx.coroutines.flow.Flow
+
+interface CategoryRepo {
+  fun watchCategories(): Flow<List<Category>>
+}