logic/com.wire.kalium.logic.data.meeting/MeetingRepository

MeetingRepository

Inheritors

Functions

abstract suspend fun createNewMeeting(meeting: UpsertMeeting, generateOccurrencesFrom: Instant = occurrenceOutdatedThreshold(), generateOccurrencesUntil: Instant = occurrenceGenerationUntil(), transactionContext: CryptoTransactionContext): Either<CoreFailure, CreateNewMeetingResult>

deleteMeeting

abstract suspend fun deleteMeeting(meetingId: MeetingId): Either<CoreFailure, Unit>

deleteMeetingLocally

abstract suspend fun deleteMeetingLocally(meetingId: MeetingId): Either<StorageFailure, Unit>

fetchAndPersistMeeting

abstract suspend fun fetchAndPersistMeeting(meetingId: MeetingId, generateOccurrencesFrom: Instant = occurrenceOutdatedThreshold(), generateOccurrencesUntil: Instant = occurrenceGenerationUntil()): Either<CoreFailure, Meeting>

fetchAndPersistMeetings

abstract suspend fun fetchAndPersistMeetings(transactionContext: CryptoTransactionContext, generateOccurrencesFrom: Instant = occurrenceOutdatedThreshold(), generateOccurrencesUntil: Instant = occurrenceGenerationUntil()): Either<CoreFailure, List<Meeting>>

getMeeting

abstract suspend fun getMeeting(meetingId: MeetingId): Either<StorageFailure, Meeting>

getMeetingRemindersWithin

abstract suspend fun getMeetingRemindersWithin(startInclusive: Instant, endExclusive: Instant): List<MeetingReminder>

getMeetingsByConversationId

abstract suspend fun getMeetingsByConversationId(conversationId: ConversationId): Either<StorageFailure, List<Meeting>>

getNextMeetingReminder

abstract suspend fun getNextMeetingReminder(from: Instant): MeetingReminder?

getNextUnfinishedMeetingOccurrence

abstract suspend fun getNextUnfinishedMeetingOccurrence(meetingId: MeetingId, from: Instant = currentInstant()): Either<StorageFailure, MeetingOccurrence>

getPaginatedMeetingOccurrences

abstract suspend fun getPaginatedMeetingOccurrences(pagingConfig: PagingConfig, startingOffset: Long, from: Instant = currentInstant().asStartOfDay()): Flow<PagingData<MeetingOccurrence>>

handleMeetingFetchAndUpsert

internal suspend fun MeetingRepository.handleMeetingFetchAndUpsert(meetingId: MeetingId, eventLogger: EventProcessingLogger): Either<CoreFailure, Meeting?>

Returns the persisted meeting, or null when the event is skipped because the meeting is missing or unsupported.

observeMeetingOccurrence

abstract suspend fun observeMeetingOccurrence(occurrenceId: String): Flow<MeetingOccurrence?>

observeMeetingReminderChanges

abstract fun observeMeetingReminderChanges(): Flow<Unit>

syncMeetingOccurrences

abstract suspend fun syncMeetingOccurrences(removeOlderThan: Instant = occurrenceOutdatedThreshold(), generateOccurrencesUntil: Instant = occurrenceGenerationUntil()): Either<CoreFailure, Unit>

updateMeeting

abstract suspend fun updateMeeting(meetingId: MeetingId, meeting: UpsertMeeting, generateOccurrencesFrom: Instant = occurrenceOutdatedThreshold(), generateOccurrencesUntil: Instant = occurrenceGenerationUntil(), transactionContext: CryptoTransactionContext): Either<CoreFailure, MLSAdditionResult>