persistence/com.wire.kalium.persistence.dao.meeting/MeetingDaoImpl

MeetingDaoImpl

internal class MeetingDaoImpl(meetingsQueries: MeetingsQueries, readDispatcher: ReadDispatcher, writeDispatcher: WriteDispatcher) : MeetingDao

Constructors

constructor(meetingsQueries: MeetingsQueries, readDispatcher: ReadDispatcher, writeDispatcher: WriteDispatcher)

Functions

open suspend override fun deleteMeeting(meetingId: QualifiedIDEntity)

open suspend override fun getMeeting(meetingId: QualifiedIDEntity): MeetingEntity?

getMeetingOccurrenceDetailsFlow

open override fun getMeetingOccurrenceDetailsFlow(occurrenceId: String): Flow<MeetingOccurrenceDetailsEntity?>

getMeetingRemindersWithin

open suspend override fun getMeetingRemindersWithin(startInclusive: Instant, endExclusive: Instant): List<MeetingReminderEntity>

getMeetingsByConversationId

open suspend override fun getMeetingsByConversationId(conversationId: QualifiedIDEntity): List<MeetingEntity>

getNextMeetingReminder

open suspend override fun getNextMeetingReminder(from: Instant): MeetingReminderEntity?

getNextUnfinishedMeetingOccurrenceDetailsId

open suspend override fun getNextUnfinishedMeetingOccurrenceDetailsId(meetingId: QualifiedIDEntity, from: Instant): String?

getPaginatedMeetingOccurrenceDetails

open override fun getPaginatedMeetingOccurrenceDetails(pagingConfig: PagingConfig, startingOffset: Long, from: Instant): KaliumPager<MeetingOccurrenceDetailsEntity>

insertMissingOccurrences

open suspend override fun insertMissingOccurrences(generateOccurrencesWindow: MeetingOccurrencesGenerator.GenerationLimit.Window)

observeMeetingReminderChanges

open override fun observeMeetingReminderChanges(): Flow<Unit>

removeOutdatedMeetings

open suspend override fun removeOutdatedMeetings(olderThan: Instant)

open suspend override fun upsertMeetings(meetings: List<MeetingEntity>, generateOccurrencesWindow: MeetingOccurrencesGenerator.GenerationLimit.Window, removeMeetingsAbsentFromUpsertList: Boolean = false)