73 lines
2.4 KiB
Kotlin
73 lines
2.4 KiB
Kotlin
package dev.inmo.tgbotapi.extensions.behaviour_builder
|
|
|
|
import dev.inmo.micro_utils.coroutines.ContextSafelyExceptionHandler
|
|
import dev.inmo.micro_utils.coroutines.ExceptionHandler
|
|
import dev.inmo.tgbotapi.bot.TelegramBot
|
|
import dev.inmo.tgbotapi.extensions.utils.updates.retrieving.longPolling
|
|
import dev.inmo.tgbotapi.extensions.utils.updates.retrieving.startGettingOfUpdatesByLongPolling
|
|
import dev.inmo.tgbotapi.updateshandlers.FlowsUpdatesFilter
|
|
import dev.inmo.tgbotapi.utils.PreviewFeature
|
|
import kotlinx.coroutines.CoroutineScope
|
|
import kotlinx.coroutines.plus
|
|
|
|
/**
|
|
* This function is used in [buildBehaviour] extensions to provide default [CoroutineScope] and allow to avoid all
|
|
* unnecessary parameters except of block
|
|
*/
|
|
expect var defaultCoroutineScopeProvider: () -> CoroutineScope
|
|
|
|
/**
|
|
* Use this method in case you wish to make some additional actions with [flowUpdatesFilter].
|
|
*
|
|
* **WARNING** This method WILL NOT launch any listening of updates. Use something like
|
|
* [startGettingOfUpdatesByLongPolling] or tools for work with webhooks
|
|
*
|
|
* @see [BehaviourContext]
|
|
* @see startGettingOfUpdatesByLongPolling
|
|
*/
|
|
@PreviewFeature
|
|
suspend fun TelegramBot.buildBehaviour(
|
|
flowUpdatesFilter: FlowsUpdatesFilter,
|
|
scope: CoroutineScope = defaultCoroutineScopeProvider(),
|
|
defaultExceptionsHandler: ExceptionHandler<Unit>? = null,
|
|
block: BehaviourContextReceiver<Unit>
|
|
) {
|
|
BehaviourContext(
|
|
this,
|
|
scope.let {
|
|
if (defaultExceptionsHandler == null) {
|
|
it
|
|
} else {
|
|
it + ContextSafelyExceptionHandler(defaultExceptionsHandler)
|
|
}
|
|
},
|
|
flowUpdatesFilter
|
|
).block()
|
|
}
|
|
|
|
/**
|
|
* Use this method to build bot behaviour and run it via long polling. In case you wish to get [FlowsUpdatesFilter] for
|
|
* additional manipulations, you must provide external [FlowsUpdatesFilter] in other [buildBehaviour] function.
|
|
*
|
|
* @see buildBehaviour
|
|
* @see BehaviourContext
|
|
* @see startGettingOfUpdatesByLongPolling
|
|
*/
|
|
@PreviewFeature
|
|
suspend fun TelegramBot.buildBehaviour(
|
|
scope: CoroutineScope = defaultCoroutineScopeProvider(),
|
|
defaultExceptionsHandler: ExceptionHandler<Unit>? = null,
|
|
block: BehaviourContextReceiver<Unit>
|
|
) = FlowsUpdatesFilter().let {
|
|
buildBehaviour(
|
|
it,
|
|
scope,
|
|
defaultExceptionsHandler,
|
|
block
|
|
)
|
|
longPolling(
|
|
it,
|
|
scope = scope
|
|
)
|
|
}
|