PowerSync Core/com.powersync.attachments.implementation/AttachmentContextImpl

AttachmentContextImpl

open class AttachmentContextImpl(val db: PowerSyncDatabase, val table: String, logger: Logger, maxArchivedCount: Long) : AttachmentContext

Default implementation of AttachmentContext.

This class provides the standard logic for managing attachments in a SQLite table. Users can override this class if they need custom logic for handling columns or other database operations related to attachments.

Constructors

constructor(db: PowerSyncDatabase, table: String, logger: Logger, maxArchivedCount: Long)

Properties

val db: PowerSyncDatabase

table

val table: String

Functions

clearQueue

open suspend override fun clearQueue()

Helper function to clear the attachment queue Currently only used for testing purposes.

deleteArchivedAttachments

open suspend override fun deleteArchivedAttachments(callback: suspend (attachments: List<Attachment>) -> Unit): Boolean

Delete attachments which have been archived

deleteAttachment

open suspend override fun deleteAttachment(id: String)

Delete the attachment from the attachment queue.

getActiveAttachments

open suspend override fun getActiveAttachments(): List<Attachment>

Gets all the active attachments which require an operation to be performed.

getAttachment

open suspend override fun getAttachment(id: String): Attachment?

Get the attachment from the attachment queue using an ID.

getAttachmentIds

open suspend override fun getAttachmentIds(): List<String>

Get all the ID's of attachments in the attachment queue.

getAttachments

open suspend override fun getAttachments(): List<Attachment>

Get all Attachment records present in the database.

ignoreAttachment

open suspend override fun ignoreAttachment(id: String)

Set the state of the attachment to ignore.

saveAttachment

open suspend override fun saveAttachment(attachment: Attachment): Attachment

Save the attachment to the attachment queue.

saveAttachments

open suspend override fun saveAttachments(attachments: List<Attachment>)

Save the attachments to the attachment queue.

upsertAttachment

open override fun upsertAttachment(attachment: Attachment, context: ConnectionContext): Attachment

Upserts an attachment record synchronously given a database connection context.