add expects for DocumentReference.snapshots(includeMetadataChanges: Boolean)

implement in js and android

Author: nbransby

build.gradle.kts

@@ -62,7 +62,7 @@ subprojects {
     }
 
     tasks.withType<Sign>().configureEach {
-        onlyIf { !project.gradle.startParameter.taskNames.contains("publishToMavenLocal") }
+        onlyIf { !project.gradle.startParameter.taskNames.any { "MavenLocal" in it } && !project.gradle.startParameter.taskNames.contains("publishToGitHubPackagesRepository") }
     }
 
     tasks {

firebase-common/src/jsMain/kotlin/dev/gitlive/firebase/externals.kt

@@ -454,7 +454,7 @@ external object firebase {
             fun update(field: String, value: Any?, vararg moreFieldsAndValues: Any?): Promise<Unit>
             fun update(field: FieldPath, value: Any?, vararg moreFieldsAndValues: Any?): Promise<Unit>
             fun delete(): Promise<Unit>
-            fun onSnapshot(next: (snapshot: DocumentSnapshot) -> Unit, error: (error: Error) -> Unit): ()->Unit
+            fun onSnapshot(options: Json, next: (snapshot: DocumentSnapshot) -> Unit, error: (error: Error) -> Unit): ()->Unit
         }
 
         open class WriteBatch {

firebase-firestore/src/androidMain/kotlin/dev/gitlive/firebase/firestore/firestore.kt

@@ -10,6 +10,7 @@ import com.google.firebase.firestore.MetadataChanges
 import com.google.firebase.firestore.SetOptions
 import dev.gitlive.firebase.*
 import kotlinx.coroutines.channels.awaitClose
+import kotlinx.coroutines.flow.Flow
 import kotlinx.coroutines.flow.callbackFlow
 import kotlinx.coroutines.runBlocking
 import kotlinx.coroutines.tasks.await
@@ -263,8 +264,11 @@ actual class DocumentReference(val android: com.google.firebase.firestore.Docume
     actual suspend fun get() =
         DocumentSnapshot(android.get().await())
 
-    actual val snapshots get() = callbackFlow<DocumentSnapshot> {
-        val listener = android.addSnapshotListener { snapshot, exception ->
+    actual val snapshots: Flow<DocumentSnapshot> get() = snapshots()
+
+    actual fun snapshots(includeMetadataChanges: Boolean) = callbackFlow {
+        val metadataChanges = if(includeMetadataChanges) MetadataChanges.INCLUDE else MetadataChanges.EXCLUDE
+        val listener = android.addSnapshotListener(metadataChanges) { snapshot, exception ->
             snapshot?.let { trySend(DocumentSnapshot(snapshot)) }
             exception?.let { close(exception) }
         }

firebase-firestore/src/commonMain/kotlin/dev/gitlive/firebase/firestore/firestore.kt

@@ -126,6 +126,7 @@ expect class DocumentReference {
     val path: String
     val snapshots: Flow<DocumentSnapshot>
     val parent: CollectionReference
+    fun snapshots(includeMetadataChanges: Boolean = false): Flow<DocumentSnapshot>
 
     fun collection(collectionPath: String): CollectionReference
     suspend fun get(): DocumentSnapshot

firebase-firestore/src/jsMain/kotlin/dev/gitlive/firebase/firestore/firestore.kt

@@ -8,6 +8,7 @@ import dev.gitlive.firebase.*
 import kotlinx.coroutines.GlobalScope
 import kotlinx.coroutines.await
 import kotlinx.coroutines.channels.awaitClose
+import kotlinx.coroutines.flow.Flow
 import kotlinx.coroutines.flow.callbackFlow
 import kotlinx.coroutines.promise
 import kotlinx.serialization.DeserializationStrategy
@@ -234,8 +235,11 @@ actual class DocumentReference(val js: firebase.firestore.DocumentReference) {
 
     actual suspend fun get() = rethrow { DocumentSnapshot(js.get().await()) }
 
-    actual val snapshots get() = callbackFlow<DocumentSnapshot> {
+    actual val snapshots: Flow<DocumentSnapshot> get() = snapshots()
+
+    actual fun snapshots(includeMetadataChanges: Boolean) = callbackFlow {
         val unsubscribe = js.onSnapshot(
+            json("includeMetadataChanges" to includeMetadataChanges),
             { trySend(DocumentSnapshot(it)) },
             { close(errorToException(it)) }
         )