Package dev.inmo.tgbotapi.extensions.utils.updates

Functions

asCommonMessagesFlow

common

fun <T : BaseSentMessageUpdate> Flow<T>.asCommonMessagesFlow(): Flow<CommonMessage<*>>

Will map incoming BaseSentMessageUpdates to CommonMessage from BaseSentMessageUpdate.data

asContentMessagesFlow

common

fun <T : BaseSentMessageUpdate> Flow<T>.asContentMessagesFlow(): Flow<ContentMessage<*>>

Will map incoming BaseSentMessageUpdates to ContentMessage from BaseSentMessageUpdate.data

asDataCallbackQueryFlow

common

fun Flow<CallbackQueryUpdate>.asDataCallbackQueryFlow(): Flow<DataCallbackQuery>

asGameShortNameCallbackQueryFlow

common

fun Flow<CallbackQueryUpdate>.asGameShortNameCallbackQueryFlow(): Flow<GameShortNameCallbackQuery>

asUnknownCallbackQueryFlow

common

fun Flow<CallbackQueryUpdate>.asUnknownCallbackQueryFlow(): Flow<UnknownCallbackQueryType>

asUnknownMessagesFlow

common

fun <T : BaseSentMessageUpdate> Flow<T>.asUnknownMessagesFlow(): Flow<UnknownMessageType>

Will map incoming BaseSentMessageUpdates to UnknownMessageType from BaseSentMessageUpdate.data

chatEvents

common

inline fun <T : BaseSentMessageUpdate> Flow<T>.chatEvents(): Flow<ChatEventMessage<*>>

convertWithMediaGroupUpdates

common

fun List<Update>.convertWithMediaGroupUpdates(): List<Update>

Will convert incoming list of updates to list with MediaGroupUpdates

filterBaseMessageUpdatesByChat

common

fun <T : BaseMessageUpdate> Flow<T>.filterBaseMessageUpdatesByChat(chat: Chat): Flow<T>

Flow.filter incoming BaseMessageUpdates by their ChatId using Chat.id of chat

filterBaseMessageUpdatesByChatId

common

fun <T : BaseMessageUpdate> Flow<T>.filterBaseMessageUpdatesByChatId(chatId: ChatId): Flow<T>

Flow.filter incoming BaseMessageUpdates by their ChatId

filterCommandsInsideTextMessages

common

fun <T : BaseSentMessageUpdate> Flow<T>.filterCommandsInsideTextMessages(commandRegex: Regex): Flow<ContentMessage<TextContent>>

Convert incoming dev.inmo.tgbotapi.types.message.abstracts.ContentMessage.content of messages with fullEntitiesList and check that incoming message contains BotCommandTextSource.

filterCommandsWithArgs

common

fun <T : BaseSentMessageUpdate> Flow<T>.filterCommandsWithArgs(commandRegex: Regex): Flow<Pair<ContentMessage<TextContent>, TextSourcesList>>

Convert incoming dev.inmo.tgbotapi.types.message.abstracts.ContentMessage.content of messages with fullEntitiesList and check that incoming message contains first TextSource as BotCommandTextSource.

filterExactCommands

common

fun <T : BaseSentMessageUpdate> Flow<T>.filterExactCommands(commandRegex: Regex): Flow<ContentMessage<TextContent>>

Convert incoming dev.inmo.tgbotapi.types.message.abstracts.ContentMessage.content of messages with fullEntitiesList and check that incoming message contains ONLY ONE TextSource and that is BotCommandTextSource.

filterSentMediaGroupUpdatesByChat

common

fun <T : SentMediaGroupUpdate> Flow<T>.filterSentMediaGroupUpdatesByChat(chat: Chat): Flow<T>

Flow.filter incoming SentMediaGroupUpdates by their ChatId using Chat.id of chat

filterSentMediaGroupUpdatesByChatId

common

fun <T : SentMediaGroupUpdate> Flow<T>.filterSentMediaGroupUpdatesByChatId(chatId: ChatId): Flow<T>

Flow.filter incoming SentMediaGroupUpdates by their ChatId

flowsUpdatesFilter

common

inline fun flowsUpdatesFilter(internalChannelsSizes: Int = 100, block: FlowsUpdatesFilter.() -> Unit): FlowsUpdatesFilter

Non-suspendable function for easy-to-use creating of FlowsUpdatesFilter and applying the block to it

lastUpdateIdentifier

common

fun Update.lastUpdateIdentifier(): UpdateIdentifier

fun List<Update>.lastUpdateIdentifier(): UpdateIdentifier?

onlyBaseChosenInlineResults

common

fun Flow<ChosenInlineResultUpdate>.onlyBaseChosenInlineResults(): Flow<BaseChosenInlineResult>

onlyBaseChosenInlineResultsWithUpdates

common

fun Flow<ChosenInlineResultUpdate>.onlyBaseChosenInlineResultsWithUpdates(): Flow<Pair<UpdateIdentifier, BaseChosenInlineResult>>

onlyBaseInlineQueries

common

fun Flow<InlineQueryUpdate>.onlyBaseInlineQueries(): Flow<BaseInlineQuery>

onlyBaseInlineQueriesWithUpdates

common

fun Flow<InlineQueryUpdate>.onlyBaseInlineQueriesWithUpdates(): Flow<Pair<UpdateIdentifier, BaseInlineQuery>>

onlyBaseMessageUpdates

common

fun Flow<Update>.onlyBaseMessageUpdates(): Flow<BaseMessageUpdate>

onlyEditMediaGroupUpdates

common

fun Flow<MediaGroupUpdate>.onlyEditMediaGroupUpdates(): Flow<EditMediaGroupUpdate>

Converts flow to Flow of EditMediaGroupUpdate

onlyEditMessageUpdates

common

fun Flow<BaseMessageUpdate>.onlyEditMessageUpdates(): Flow<BaseEditMessageUpdate>

Converts flow to Flow of BaseSentMessageUpdate

onlyLocationChosenInlineResults

common

fun Flow<ChosenInlineResultUpdate>.onlyLocationChosenInlineResults(): Flow<LocationChosenInlineResult>

onlyLocationChosenInlineResultsWithUpdates

common

fun Flow<ChosenInlineResultUpdate>.onlyLocationChosenInlineResultsWithUpdates(): Flow<Pair<UpdateIdentifier, LocationChosenInlineResult>>

onlyLocationInlineQueries

common

fun Flow<InlineQueryUpdate>.onlyLocationInlineQueries(): Flow<LocationInlineQuery>

onlyLocationInlineQueriesWithUpdates

common

fun Flow<InlineQueryUpdate>.onlyLocationInlineQueriesWithUpdates(): Flow<Pair<UpdateIdentifier, LocationInlineQuery>>

onlyMediaGroupsUpdates

common

fun Flow<BaseMessageUpdate>.onlyMediaGroupsUpdates(): Flow<MediaGroupUpdate>

Converts flow to Flow of MediaGroupUpdate.

onlySentMediaGroupUpdates

common

fun Flow<MediaGroupUpdate>.onlySentMediaGroupUpdates(): Flow<SentMediaGroupUpdate>

Converts flow to Flow of SentMediaGroupUpdate

onlySentMessageUpdates

common

fun Flow<BaseMessageUpdate>.onlySentMessageUpdates(): Flow<BaseSentMessageUpdate>

Converts flow to Flow of BaseSentMessageUpdate

passportMessages

common

inline fun <T : BaseSentMessageUpdate> Flow<T>.passportMessages(): Flow<PassportMessage>

toEditMediaGroupUpdate

common

fun BaseEditMessageUpdate.toEditMediaGroupUpdate(): EditMediaGroupUpdate

toSentMediaGroupUpdate

common

fun List<BaseSentMessageUpdate>.toSentMediaGroupUpdate(): SentMediaGroupUpdate?

toTelegramUpdate

common

fun String.toTelegramUpdate(): Update

fun JsonElement.toTelegramUpdate(): Update

fun Json.toTelegramUpdate(source: String): Update

fun Json.toTelegramUpdate(source: JsonElement): Update