Additional tests of collections in mixed behavior

packages/test-base/src/commonTest/kotlin/io/realm/kotlin/test/common/RealmAnyNestedCollectionTests.kt

@@ -573,6 +573,9 @@
         realm.query<JsonStyleRealmObject>("value[*] == 4").find().single().run {
             assertEquals("LIST", id)
         }
+        realm.query<JsonStyleRealmObject>("value[*] == {4, 5, 6}").find().single().run {
+            assertEquals("LIST", id)
+        }
 
         // Matching dictionaries
         realm.query<JsonStyleRealmObject>("value.key1 == 7").find().single().run {
@@ -606,5 +609,11 @@
         realm.query<JsonStyleRealmObject>("value[*].key3[0] == 9").find().single().run {
             assertEquals("EMBEDDED", id)
         }
+        realm.query<JsonStyleRealmObject>("value[0][*] == {4, 5, 6}").find().single().run {
+            assertEquals("EMBEDDED", id)
+        }
+        realm.query<JsonStyleRealmObject>("value[*][*] == {4, 5, 6}").find().single().run {
+            assertEquals("EMBEDDED", id)
+        }
     }
 }

packages/test-base/src/commonTest/kotlin/io/realm/kotlin/test/common/notifications/RealmAnyNestedListNotificationTest.kt

@@ -19,6 +19,8 @@ package io.realm.kotlin.test.common.notifications
 import io.realm.kotlin.Realm
 import io.realm.kotlin.RealmConfiguration
 import io.realm.kotlin.entities.JsonStyleRealmObject
+import io.realm.kotlin.ext.asRealmObject
+import io.realm.kotlin.ext.realmAnyDictionaryOf
 import io.realm.kotlin.ext.realmAnyListOf
 import io.realm.kotlin.ext.realmAnyOf
 import io.realm.kotlin.internal.platform.runBlocking
@@ -30,6 +32,7 @@ import io.realm.kotlin.test.common.utils.DeletableEntityNotificationTests
 import io.realm.kotlin.test.common.utils.FlowableTests
 import io.realm.kotlin.test.platform.PlatformUtils
 import io.realm.kotlin.test.util.receiveOrFail
+import io.realm.kotlin.test.util.trySendOrFail
 import io.realm.kotlin.types.RealmAny
 import kotlinx.coroutines.async
 import kotlinx.coroutines.channels.Channel
@@ -252,4 +255,97 @@ class RealmAnyNestedListNotificationTest : FlowableTests, DeletableEntityNotific
     override fun closeRealmInsideFlowThrows() {
         TODO("Not yet implemented")
     }
+
+    @Test
+    @Ignore // https://github.com/realm/realm-core/issues/7264
+    fun eventsOnObjectChangesInRealmAnyList() {
+        kotlinx.coroutines.runBlocking {
+            val channel = Channel<ListChange<RealmAny?>>(10)
+            val parent =
+                realm.write {
+                    copyToRealm(JsonStyleRealmObject().apply { value = realmAnyListOf() })
+                }
+
+            val listener = async {
+                parent.value!!.asList().asFlow().collect {
+                    channel.trySendOrFail(it)
+                }
+            }
+
+            channel.receiveOrFail(message = "Initial event").let { assertIs<InitialList<*>>(it) }
+
+            realm.write {
+                val asList = findLatest(parent)!!.value!!.asList()
+                println(asList.size)
+                asList.add(
+                    RealmAny.create(JsonStyleRealmObject().apply { id = "CHILD" })
+                )
+            }
+            channel.receiveOrFail(message = "List add").let {
+                assertIs<UpdatedList<*>>(it)
+                assertEquals(1, it.list.size)
+            }
+
+            realm.write {
+                findLatest(parent)!!.value!!.asList()[0]!!.asRealmObject<JsonStyleRealmObject>().value =
+                    RealmAny.create("TEST")
+            }
+            channel.receiveOrFail(message = "Object updated").let {
+                assertIs<UpdatedList<*>>(it)
+                assertEquals(1, it.list.size)
+                assertEquals(
+                    "TEST",
+                    it.list[0]!!.asRealmObject<JsonStyleRealmObject>().value!!.asString()
+                )
+            }
+
+            listener.cancel()
+        }
+    }
+
+    @Test
+    fun eventsOnDictionaryChangesInRealmAnyList() {
+        kotlinx.coroutines.runBlocking {
+            val channel = Channel<ListChange<RealmAny?>>(10)
+            val parent =
+                realm.write {
+                    copyToRealm(JsonStyleRealmObject().apply { value = realmAnyListOf() })
+                }
+
+            val listener = async {
+                parent.value!!.asList().asFlow().collect {
+                    channel.trySendOrFail(it)
+                }
+            }
+
+            channel.receiveOrFail(message = "Initial event").let { assertIs<InitialList<*>>(it) }
+
+            realm.write {
+                val asList = findLatest(parent)!!.value!!.asList()
+                println(asList.size)
+                asList.add(
+                    realmAnyDictionaryOf(
+                        "key1" to "value1"
+                    )
+                )
+            }
+            channel.receiveOrFail(message = "List add").let {
+                assertIs<UpdatedList<*>>(it)
+                assertEquals(1, it.list.size)
+                assertEquals(RealmAny.Type.DICTIONARY, it.list[0]!!.type)
+            }
+
+            realm.write {
+                findLatest(parent)!!.value!!.asList()[0]!!.asDictionary()["key1"] =
+                    RealmAny.create("TEST")
+            }
+            channel.receiveOrFail(message = "Object updated").let {
+                assertIs<UpdatedList<*>>(it)
+                assertEquals(1, it.list.size)
+                assertEquals("TEST", it.list[0]!!.asDictionary()["key1"]!!.asString())
+            }
+
+            listener.cancel()
+        }
+    }
 }

packages/test-base/src/commonTest/kotlin/io/realm/kotlin/test/common/notifications/RealmListNotificationsTests.kt

@@ -21,6 +21,7 @@ import io.realm.kotlin.RealmConfiguration
 import io.realm.kotlin.entities.Sample
 import io.realm.kotlin.entities.list.RealmListContainer
 import io.realm.kotlin.entities.list.listTestSchema
+import io.realm.kotlin.ext.asRealmObject
 import io.realm.kotlin.ext.realmListOf
 import io.realm.kotlin.notifications.DeletedList
 import io.realm.kotlin.notifications.InitialList
@@ -35,6 +36,8 @@ import io.realm.kotlin.test.common.utils.assertIsChangeSet
 import io.realm.kotlin.test.platform.PlatformUtils
 import io.realm.kotlin.test.util.TestChannel
 import io.realm.kotlin.test.util.receiveOrFail
+import io.realm.kotlin.test.util.trySendOrFail
+import io.realm.kotlin.types.RealmAny
 import io.realm.kotlin.types.RealmList
 import kotlinx.coroutines.async
 import kotlinx.coroutines.channels.Channel
@@ -734,6 +737,80 @@ class RealmListNotificationsTests : RealmEntityNotificationTests {
         }
     }
 
+    @Test
+    fun eventsOnObjectChangesInList() {
+        runBlocking {
+            val channel = Channel<ListChange<RealmListContainer>>(10)
+            val parent = realm.write { copyToRealm(RealmListContainer()).apply { stringField = "PARENT" } }
+
+            val listener = async {
+                parent.objectListField.asFlow().collect {
+                    channel.trySendOrFail(it)
+                }
+            }
+
+            channel.receiveOrFail(message = "Initial event").let { assertIs<InitialList<*>>(it) }
+
+            realm.write {
+                findLatest(parent)!!.objectListField.add(
+                    RealmListContainer().apply { stringField = "CHILD" }
+                )
+            }
+            channel.receiveOrFail(message = "List add").let {
+                assertIs<UpdatedList<*>>(it)
+                assertEquals(1, it.list.size)
+            }
+
+            realm.write {
+                findLatest(parent)!!.objectListField[0].stringField = "TEST"
+            }
+            channel.receiveOrFail(message = "Object updated").let {
+                assertIs<UpdatedList<*>>(it)
+                assertEquals(1, it.list.size)
+                assertEquals("TEST", it.list[0].stringField)
+            }
+
+            listener.cancel()
+        }
+    }
+    @Test
+    @Ignore // https://github.com/realm/realm-core/issues/7264
+    fun eventsOnObjectChangesInRealmAnyList() {
+        runBlocking {
+            val channel = Channel<ListChange<RealmAny?>>(10)
+            val parent = realm.write { copyToRealm(RealmListContainer()).apply { stringField = "PARENT" } }
+
+            val listener = async {
+                parent.nullableRealmAnyListField.asFlow().collect {
+                    channel.trySendOrFail(it)
+                }
+            }
+
+            channel.receiveOrFail(message = "Initial event").let { assertIs<InitialList<*>>(it) }
+
+            realm.write {
+                findLatest(parent)!!.nullableRealmAnyListField.add(
+                    RealmAny.create(RealmListContainer().apply { stringField = "CHILD" })
+                )
+            }
+            channel.receiveOrFail(message = "List add").let {
+                assertIs<UpdatedList<*>>(it)
+                assertEquals(1, it.list.size)
+            }
+
+            realm.write {
+                findLatest(parent)!!.nullableRealmAnyListField[0]!!.asRealmObject<RealmListContainer>().stringField = "TEST"
+            }
+            channel.receiveOrFail(message = "Object updated").let {
+                assertIs<UpdatedList<*>>(it)
+                assertEquals(1, it.list.size)
+                assertEquals("TEST", it.list[0]!!.asRealmObject<RealmListContainer>().stringField)
+            }
+
+            listener.cancel()
+        }
+    }
+
     fun RealmList<*>.removeRange(range: IntRange) {
         range.reversed().forEach { index -> removeAt(index) }
     }