Even more logs

Author: simolus3

core/src/commonIntegrationTest/kotlin/com/powersync/AttachmentsTest.kt

@@ -12,6 +12,7 @@ import com.powersync.attachments.createAttachmentsTable
 import com.powersync.db.getString
 import com.powersync.db.schema.Schema
 import com.powersync.db.schema.Table
+import com.powersync.testutils.ActiveDatabaseTest
 import com.powersync.testutils.MockedRemoteStorage
 import com.powersync.testutils.UserRow
 import com.powersync.testutils.databaseTest
@@ -27,7 +28,9 @@ import dev.mokkery.spy
 import dev.mokkery.verifySuspend
 import io.kotest.matchers.shouldBe
 import io.kotest.matchers.shouldNotBe
+import kotlinx.coroutines.flow.Flow
 import kotlinx.coroutines.flow.flowOf
+import kotlinx.coroutines.flow.onEach
 import kotlinx.io.files.Path
 import kotlin.test.Test
 import kotlin.time.Duration.Companion.seconds
@@ -53,6 +56,12 @@ class AttachmentsTest {
             )
         }
 
+    private fun ActiveDatabaseTest.watchAttachmentsTable(): Flow<List<Attachment>> =
+        database
+            .watch("SELECT * FROM attachments") {
+                Attachment.fromCursor(it)
+            }.onEach { logger.i { "attachments table results: $it" } }
+
     suspend fun updateSchema(db: PowerSyncDatabase) {
         db.updateSchema(
             Schema(
@@ -76,11 +85,7 @@ class AttachmentsTest {
                 val remote = spy<RemoteStorage>(MockedRemoteStorage())
 
                 // Monitor the attachments table for testing
-                val attachmentQuery =
-                    database
-                        // language=SQL
-                        .watch("SELECT * FROM attachments") { Attachment.fromCursor(it) }
-                        .testIn(this)
+                val attachmentQuery = watchAttachmentsTable().testIn(this)
 
                 val queue =
                     AttachmentQueue(
@@ -188,11 +193,7 @@ class AttachmentsTest {
                 val remote = spy<RemoteStorage>(MockedRemoteStorage())
 
                 // Monitor the attachments table for testing
-                val attachmentQuery =
-                    database
-                        // language=SQL
-                        .watch("SELECT * FROM attachments") { Attachment.fromCursor(it) }
-                        .testIn(this)
+                val attachmentQuery = watchAttachmentsTable().testIn(this)
 
                 val queue =
                     AttachmentQueue(
@@ -298,11 +299,7 @@ class AttachmentsTest {
                 val remote = spy<RemoteStorage>(MockedRemoteStorage())
 
                 // Monitor the attachments table for testing
-                val attachmentQuery =
-                    database
-                        // language=SQL
-                        .watch("SELECT * FROM attachments") { Attachment.fromCursor(it) }
-                        .testIn(this)
+                val attachmentQuery = watchAttachmentsTable().testIn(this)
 
                 val queue =
                     AttachmentQueue(
@@ -398,11 +395,7 @@ class AttachmentsTest {
                 val remote = spy<RemoteStorage>(MockedRemoteStorage())
 
                 // Monitor the attachments table for testing
-                val attachmentQuery =
-                    database
-                        // language=SQL
-                        .watch("SELECT * FROM attachments") { Attachment.fromCursor(it) }
-                        .testIn(this)
+                val attachmentQuery = watchAttachmentsTable().testIn(this)
 
                 val queue =
                     AttachmentQueue(
@@ -513,10 +506,7 @@ class AttachmentsTest {
                     }
 
                 // Monitor the attachments table for testing
-                val attachmentQuery =
-                    database
-                        .watch("SELECT * FROM attachments") { Attachment.fromCursor(it) }
-                        .testIn(this)
+                val attachmentQuery = watchAttachmentsTable().testIn(this)
 
                 val queue =
                     AttachmentQueue(

core/src/commonMain/kotlin/com/powersync/attachments/implementation/AttachmentContextImpl.kt

@@ -66,6 +66,8 @@ public open class AttachmentContextImpl(
         }
 
         db.writeTransaction { tx ->
+            logger.v { "saveAttachments($attachments)" }
+
             for (attachment in attachments) {
                 upsertAttachment(attachment, tx)
             }

core/src/commonMain/kotlin/com/powersync/attachments/sync/SyncingService.kt

@@ -78,7 +78,7 @@ public open class SyncingService(
                         merge(
                             // Handles manual triggers for sync events
                             syncTriggerFlow.asSharedFlow(),
-                            // Triggers the sync process whenever an underlaying change to the
+                            // Triggers the sync process whenever an underlying change to the
                             // attachments table happens
                             attachmentsService
                                 .watchActiveAttachments(),