Package-level declarations
Functions
Link copied to clipboard
fun <Error class: unknown class>.createAccumulatedUpdatesRetrieverFlow(avoidInlineQueries: Boolean = false, avoidCallbackQueries: Boolean = false, exceptionsHandler: <Error class: unknown class><Unit>? = null, allowedUpdates: List<String>? = ALL_UPDATES_LIST, autoDisableWebhooks: Boolean = true, mediaGroupsDebounceTimeMillis: Long? = 1000): Flow<<Error class: unknown class>>
Link copied to clipboard
suspend fun <Error class: unknown class>.flushAccumulatedUpdates(avoidInlineQueries: Boolean = false, avoidCallbackQueries: Boolean = false, scope: CoroutineScope = CoroutineScope(Dispatchers.Default), allowedUpdates: List<String>? = ALL_UPDATES_LIST, exceptionsHandler: <Error class: unknown class><Unit>? = null, autoDisableWebhooks: Boolean = true, mediaGroupsDebounceTimeMillis: Long? = 1000, updatesReceiver: <Error class: unknown class><<Error class: unknown class>> = {}): <Error class: unknown class>
Link copied to clipboard
fun Route.includeWebhookHandlingInRoute(scope: CoroutineScope, exceptionsHandler: <Error class: unknown class><Unit>? = null, mediaGroupsDebounceTimeMillis: Long = 1000, logger: KSLog = DefaultKTgBotAPIKSLog, block: <Error class: unknown class><Update>)
Allows to include webhook in custom route everywhere in your server
Link copied to clipboard
fun Route.includeWebhookHandlingInRouteWithFlows(scope: CoroutineScope, exceptionsHandler: <Error class: unknown class><Unit>? = null, mediaGroupsDebounceTimeMillis: Long = 1000, logger: KSLog = DefaultKTgBotAPIKSLog, block: FlowsUpdatesFilter.() -> Unit)
Link copied to clipboard
fun <Error class: unknown class>.longPolling(updatesFilter: <Error class: unknown class>, timeoutSeconds: <Error class: unknown class> = 30, scope: CoroutineScope = CoroutineScope(Dispatchers.Default), autoDisableWebhooks: Boolean = true, autoSkipTimeoutExceptions: Boolean = true, mediaGroupsDebounceTimeMillis: Long? = 1000, exceptionsHandler: <Error class: unknown class><Unit>? = null): Job
Will startGettingOfUpdatesByLongPolling using incoming updatesFilter. It is assumed that you ALREADY CONFIGURE all updates receivers, because this method will trigger getting of updates and.
fun <Error class: unknown class>.longPolling(timeoutSeconds: <Error class: unknown class> = 30, scope: CoroutineScope = CoroutineScope(Dispatchers.Default), exceptionsHandler: <Error class: unknown class><Unit>? = null, flowsUpdatesFilterUpdatesKeeperCount: Int = 100, autoDisableWebhooks: Boolean = true, autoSkipTimeoutExceptions: Boolean = true, mediaGroupsDebounceTimeMillis: Long? = 1000, flowUpdatesPreset: <Error class: unknown class>.() -> Unit): Job
Will enable longPolling by creating FlowsUpdatesFilter with flowsUpdatesFilterUpdatesKeeperCount as an argument and applied flowUpdatesPreset. It is assumed that you WILL CONFIGURE all updates receivers in flowUpdatesPreset, because of after flowUpdatesPreset method calling will be triggered getting of updates.
Link copied to clipboard
fun <Error class: unknown class>.longPollingFlow(exceptionsHandler: <Error class: unknown class><Unit>? = null, autoDisableWebhooks: Boolean = true, autoSkipTimeoutExceptions: Boolean = true, mediaGroupsDebounceTimeMillis: Long? = 1000, getUpdatesRequestCreator: (<Error class: unknown class>?) -> <Error class: unknown class>): Flow<<Error class: unknown class>>
Starts a long polling flow to receive updates continuously from the Telegram Bot API.
fun <Error class: unknown class>.longPollingFlow(timeoutSeconds: <Error class: unknown class> = 30, exceptionsHandler: <Error class: unknown class><Unit>? = null, allowedUpdates: List<String>? = ALL_UPDATES_LIST, autoDisableWebhooks: Boolean = true, autoSkipTimeoutExceptions: Boolean = true, mediaGroupsDebounceTimeMillis: Long? = 1000): Flow<<Error class: unknown class>>
Initiates a long polling flow for receiving updates continuously from the Telegram Bot API. This method provides a customized way to handle the retrieval of updates with options to configure timeouts, update types, exception handling, and media group processing.
Link copied to clipboard
fun <Error class: unknown class>.retrieveAccumulatedUpdates(flowsUpdatesFilter: <Error class: unknown class>, avoidInlineQueries: Boolean = false, avoidCallbackQueries: Boolean = false, scope: CoroutineScope = CoroutineScope(Dispatchers.Default), autoDisableWebhooks: Boolean = true, mediaGroupsDebounceTimeMillis: Long? = 1000, exceptionsHandler: <Error class: unknown class><Unit>? = null): <Error class: unknown class>
fun <Error class: unknown class>.retrieveAccumulatedUpdates(avoidInlineQueries: Boolean = false, avoidCallbackQueries: Boolean = false, scope: CoroutineScope = CoroutineScope(Dispatchers.Default), exceptionsHandler: <Error class: unknown class><Unit>? = null, allowedUpdates: List<String>? = ALL_UPDATES_LIST, autoDisableWebhooks: Boolean = true, mediaGroupsDebounceTimeMillis: Long? = 1000, updatesReceiver: <Error class: unknown class><<Error class: unknown class>>): Job
Link copied to clipboard
suspend fun <TEngine : ApplicationEngine, TConfiguration : ApplicationEngine.Configuration> RequestsExecutor.setWebhookInfoAndStartListenWebhooks(listenPort: Int, engineFactory: ApplicationEngineFactory<TEngine, TConfiguration>, setWebhookRequest: SetWebhookRequest, exceptionsHandler: <Error class: unknown class><Unit> = {}, listenHost: String = "0.0.0.0", listenRoute: String = "/", privateKeyConfig: WebhookPrivateKeyConfig? = null, scope: CoroutineScope = CoroutineScope(Executors.newFixedThreadPool(4).asCoroutineDispatcher()), mediaGroupsDebounceTimeMillis: Long = 1000, additionalApplicationEnvironmentConfigurator: ApplicationEnvironmentBuilder.() -> Unit = {}, additionalEngineConfigurator: TConfiguration.() -> Unit = {}, logger: KSLog = Log, block: <Error class: unknown class><Update>): EmbeddedServer<TEngine, TConfiguration>
Setting up ktor server, set webhook info via SetWebhookRequest request.
Link copied to clipboard
fun <Error class: unknown class>.startGettingOfUpdatesByLongPolling(updatesFilter: <Error class: unknown class>, timeoutSeconds: <Error class: unknown class> = 30, exceptionsHandler: <Error class: unknown class><Unit>? = null, scope: CoroutineScope = CoroutineScope(Dispatchers.Default), autoDisableWebhooks: Boolean = true, mediaGroupsDebounceTimeMillis: Long? = 1000, autoSkipTimeoutExceptions: Boolean = true): Job
fun <Error class: unknown class>.startGettingOfUpdatesByLongPolling(timeoutSeconds: <Error class: unknown class> = 30, scope: CoroutineScope = CoroutineScope(Dispatchers.Default), exceptionsHandler: <Error class: unknown class><Unit>? = null, allowedUpdates: List<String>? = ALL_UPDATES_LIST, autoDisableWebhooks: Boolean = true, autoSkipTimeoutExceptions: Boolean = true, mediaGroupsDebounceTimeMillis: Long? = 1000, updatesReceiver: <Error class: unknown class><<Error class: unknown class>>): Job
Link copied to clipboard
fun <TEngine : ApplicationEngine, TConfiguration : ApplicationEngine.Configuration> startListenWebhooks(listenPort: Int, engineFactory: ApplicationEngineFactory<TEngine, TConfiguration>, exceptionsHandler: <Error class: unknown class><Unit>, listenHost: String = "0.0.0.0", listenRoute: String? = null, privateKeyConfig: WebhookPrivateKeyConfig? = null, scope: CoroutineScope = CoroutineScope(Executors.newFixedThreadPool(4).asCoroutineDispatcher()), mediaGroupsDebounceTimeMillis: Long = 1000, additionalApplicationEnvironmentConfigurator: ApplicationEnvironmentBuilder.() -> Unit = {}, additionalEngineConfigurator: TConfiguration.() -> Unit = {}, logger: KSLog = DefaultKTgBotAPIKSLog, block: <Error class: unknown class><Update>): EmbeddedServer<TEngine, TConfiguration>
Setting up ktor server
Link copied to clipboard
fun CoroutineScope.updateHandlerWithMediaGroupsAdaptation(logger: <Error class: unknown class> = DefaultKTgBotAPIKSLog, output: <Error class: unknown class><<Error class: unknown class>>): <Error class: unknown class><<Error class: unknown class>>
fun CoroutineScope.updateHandlerWithMediaGroupsAdaptation(output: <Error class: unknown class><<Error class: unknown class>>, debounceTimeMillis: Long = 1000, logger: <Error class: unknown class> = DefaultKTgBotAPIKSLog): <Error class: unknown class><<Error class: unknown class>>
Create UpdateReceiver object which will correctly accumulate updates and send into output updates which INCLUDE dev.inmo.tgbotapi.types.update.MediaGroupUpdates.MediaGroupUpdates.