mirror of
https://github.com/InsanusMokrassar/TelegramBotApiLibraries.git
synced 2025-10-26 17:50:20 +00:00
Compare commits
52 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 7c6005bea3 | |||
| 3f6067b34e | |||
| af72bba116 | |||
| 84f04fb1f0 | |||
| 5524fc9fa0 | |||
| d0eebc0ace | |||
| 891dab1f4b | |||
| 9f6895a530 | |||
| 49084169d2 | |||
|
|
684172cc08 | ||
| 1457cfc748 | |||
| 6784a3c49a | |||
| 8ef89a32c7 | |||
| d16de6428a | |||
| 49475a457d | |||
| b8312873b0 | |||
| 3ede07c2a6 | |||
| a0e17a664c | |||
| fc3bf19453 | |||
| 8d1c57700e | |||
| 00c0f0fd6f | |||
| 551eb293ab | |||
| f1b58a889f | |||
| 36a0f9b65b | |||
| 86abe49bc1 | |||
| 5b62bfa7d3 | |||
| d94d847715 | |||
| 91013b914d | |||
| cec4c610f3 | |||
| b9003388b1 | |||
| 6d161c2d78 | |||
| dc63639fee | |||
| 66934c823d | |||
| 90870c225c | |||
| 106d01775c | |||
| cea2f7dc6e | |||
| 7d461edc9b | |||
| c52c6cb633 | |||
| 6db1755ee7 | |||
| ccf60c95ca | |||
| 4057d5167f | |||
| f19664da58 | |||
| 646a551b15 | |||
| a08974e76d | |||
| 30e62041c0 | |||
| be8fe43e76 | |||
| 42f3a064ad | |||
| 34f9d8c0ab | |||
| 6e4fc54a23 | |||
| 674ee28991 | |||
| 4950fd4ed0 | |||
| e3f5ae0b24 |
1
.gitignore
vendored
1
.gitignore
vendored
@@ -1,4 +1,5 @@
|
||||
.idea
|
||||
.kotlin
|
||||
out/*
|
||||
*.iml
|
||||
target
|
||||
|
||||
@@ -18,7 +18,7 @@ allprojects {
|
||||
mavenLocal()
|
||||
mavenCentral()
|
||||
google()
|
||||
maven { url "https://git.inmo.dev/api/packages/InsanusMokrassar/maven" }
|
||||
maven { url "https://nexus.inmo.dev/repository/maven-releases/" }
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
@@ -3,6 +3,7 @@ package dev.inmo.tgbotapi.libraries.cache.admins
|
||||
import korlibs.time.minutes
|
||||
import dev.inmo.tgbotapi.types.IdChatIdentifier
|
||||
import dev.inmo.tgbotapi.types.Seconds
|
||||
import korlibs.time.seconds
|
||||
import kotlinx.coroutines.flow.SharedFlow
|
||||
import kotlinx.serialization.Serializable
|
||||
|
||||
|
||||
@@ -8,6 +8,7 @@ import dev.inmo.tgbotapi.types.*
|
||||
import dev.inmo.tgbotapi.types.chat.ExtendedBot
|
||||
import dev.inmo.tgbotapi.types.chat.member.AdministratorChatMember
|
||||
import dev.inmo.tgbotapi.types.message.abstracts.*
|
||||
import korlibs.time.seconds
|
||||
import kotlinx.serialization.Serializable
|
||||
|
||||
interface DefaultAdminsCacheAPIRepo {
|
||||
|
||||
@@ -38,8 +38,8 @@ fun TelegramBot.createAdminsCacheAPI(
|
||||
{ long("chatId") },
|
||||
{ text("member") },
|
||||
"AdminsTable"
|
||||
).withMapper<IdChatIdentifier, AdministratorChatMember, Identifier, String>(
|
||||
keyFromToTo = { chatId },
|
||||
).withMapper<IdChatIdentifier, AdministratorChatMember, Long, String>(
|
||||
keyFromToTo = { chatId.long },
|
||||
valueFromToTo = { telegramAdminsSerializationFormat.encodeToString(AdministratorChatMember.serializer(), this) },
|
||||
keyToToFrom = { toChatId() },
|
||||
valueToToFrom = { telegramAdminsSerializationFormat.decodeFromString(AdministratorChatMember.serializer(), this) }
|
||||
@@ -49,8 +49,8 @@ fun TelegramBot.createAdminsCacheAPI(
|
||||
{ long("chatId") },
|
||||
{ long("datetime") },
|
||||
"AdminsUpdatesTimesTable"
|
||||
).withMapper<IdChatIdentifier, Long, Identifier, Long>(
|
||||
keyFromToTo = { chatId },
|
||||
).withMapper<IdChatIdentifier, Long, Long, Long>(
|
||||
keyFromToTo = { chatId.long },
|
||||
valueFromToTo = { this },
|
||||
keyToToFrom = { toChatId() },
|
||||
valueToToFrom = { this }
|
||||
@@ -63,8 +63,8 @@ fun TelegramBot.createAdminsCacheAPI(
|
||||
{ long("chatId") },
|
||||
{ text("settings") },
|
||||
"DynamicAdminsCacheSettingsAPI"
|
||||
).withMapper<IdChatIdentifier, AdminsCacheSettings, Identifier, String>(
|
||||
keyFromToTo = { chatId },
|
||||
).withMapper<IdChatIdentifier, AdminsCacheSettings, Long, String>(
|
||||
keyFromToTo = { chatId.long },
|
||||
valueFromToTo = { telegramAdminsSerializationFormat.encodeToString(AdminsCacheSettings.serializer() , this) },
|
||||
keyToToFrom = { toChatId() },
|
||||
valueToToFrom = { telegramAdminsSerializationFormat.decodeFromString(AdminsCacheSettings.serializer() , this) }
|
||||
|
||||
@@ -4,6 +4,7 @@ import dev.inmo.micro_utils.repos.exposed.keyvalue.ExposedKeyValueRepo
|
||||
import dev.inmo.micro_utils.repos.exposed.onetomany.ExposedKeyValuesRepo
|
||||
import dev.inmo.micro_utils.repos.mappers.withMapper
|
||||
import dev.inmo.plagubot.Plugin
|
||||
import dev.inmo.plagubot.database
|
||||
import dev.inmo.tgbotapi.extensions.behaviour_builder.BehaviourContext
|
||||
import dev.inmo.tgbotapi.libraries.cache.admins.micro_utils.DefaultAdminsCacheAPIRepoImpl
|
||||
import dev.inmo.tgbotapi.libraries.cache.admins.micro_utils.DynamicAdminsCacheSettingsAPI
|
||||
@@ -44,7 +45,7 @@ class AdminsPlugin : Plugin {
|
||||
return flow.filterNotNull().first()
|
||||
}
|
||||
|
||||
override fun Module.setupDI(database: Database, params: JsonObject) {
|
||||
override fun Module.setupDI(config: JsonObject) {
|
||||
single { this@AdminsPlugin }
|
||||
val scopeQualifier = named("admins plugin scope")
|
||||
single(scopeQualifier) { CoroutineScope(Dispatchers.IO + SupervisorJob()) }
|
||||
@@ -55,8 +56,8 @@ class AdminsPlugin : Plugin {
|
||||
{ long("chatId") },
|
||||
{ text("member") },
|
||||
"AdminsTable"
|
||||
).withMapper<IdChatIdentifier, AdministratorChatMember, Identifier, String>(
|
||||
keyFromToTo = { chatId },
|
||||
).withMapper<IdChatIdentifier, AdministratorChatMember, Long, String>(
|
||||
keyFromToTo = { chatId.long },
|
||||
valueFromToTo = { telegramAdminsSerializationFormat.encodeToString(this) },
|
||||
keyToToFrom = { toChatId() },
|
||||
valueToToFrom = { telegramAdminsSerializationFormat.decodeFromString(this) }
|
||||
@@ -66,8 +67,8 @@ class AdminsPlugin : Plugin {
|
||||
{ long("chatId") },
|
||||
{ long("datetime") },
|
||||
"AdminsUpdatesTimesTable"
|
||||
).withMapper<IdChatIdentifier, Long, Identifier, Long>(
|
||||
keyFromToTo = { chatId },
|
||||
).withMapper<IdChatIdentifier, Long, Long, Long>(
|
||||
keyFromToTo = { chatId.long },
|
||||
valueFromToTo = { this },
|
||||
keyToToFrom = { toChatId() },
|
||||
valueToToFrom = { this }
|
||||
@@ -82,8 +83,8 @@ class AdminsPlugin : Plugin {
|
||||
{ long("chatId") },
|
||||
{ text("settings") },
|
||||
"DynamicAdminsCacheSettingsAPI"
|
||||
).withMapper<IdChatIdentifier, AdminsCacheSettings, Identifier, String>(
|
||||
keyFromToTo = { chatId },
|
||||
).withMapper<IdChatIdentifier, AdminsCacheSettings, Long, String>(
|
||||
keyFromToTo = { chatId.long },
|
||||
valueFromToTo = { telegramAdminsSerializationFormat.encodeToString(this) },
|
||||
keyToToFrom = { toChatId() },
|
||||
valueToToFrom = { telegramAdminsSerializationFormat.decodeFromString(this) }
|
||||
|
||||
@@ -3,8 +3,7 @@ package dev.inmo.tgbotapi.libraries.cache.media.common
|
||||
import dev.inmo.tgbotapi.requests.abstracts.MultipartFile
|
||||
import io.ktor.utils.io.core.Input
|
||||
import io.ktor.utils.io.core.copyTo
|
||||
import io.ktor.utils.io.streams.asInput
|
||||
import io.ktor.utils.io.streams.asOutput
|
||||
import io.ktor.utils.io.streams.*
|
||||
import java.io.File
|
||||
|
||||
class InFilesMessagesFilesCache<K>(
|
||||
@@ -39,8 +38,8 @@ class InFilesMessagesFilesCache<K>(
|
||||
val file = File(folderFile, fullFileName).apply {
|
||||
delete()
|
||||
}
|
||||
inputAllocator().use { input ->
|
||||
file.outputStream().asOutput().use { output ->
|
||||
inputAllocator().inputStream().use { input ->
|
||||
file.outputStream().use { output ->
|
||||
input.copyTo(output)
|
||||
}
|
||||
}
|
||||
|
||||
@@ -4,7 +4,7 @@ import dev.inmo.micro_utils.repos.*
|
||||
import dev.inmo.micro_utils.repos.mappers.withMapper
|
||||
import dev.inmo.tgbotapi.libraries.cache.media.common.MessagesSimpleCache
|
||||
import dev.inmo.tgbotapi.types.ChatId
|
||||
import dev.inmo.tgbotapi.types.MessageIdentifier
|
||||
import dev.inmo.tgbotapi.types.MessageId
|
||||
import dev.inmo.tgbotapi.types.message.content.MessageContent
|
||||
import kotlinx.serialization.*
|
||||
import kotlinx.serialization.builtins.PairSerializer
|
||||
@@ -47,7 +47,7 @@ class SimpleKeyValueMessageContentCache<K>(
|
||||
|
||||
val chatIdToMessageIdentifierSerializer = PairSerializer(
|
||||
ChatId.serializer(),
|
||||
MessageIdentifier.serializer()
|
||||
MessageId.serializer()
|
||||
)
|
||||
|
||||
val messageContentSerializer = PolymorphicSerializer<MessageContent>(MessageContent::class)
|
||||
@@ -56,9 +56,9 @@ inline fun <K> KeyValueRepo<K, MessageContent>.asMessageContentCache() = SimpleK
|
||||
|
||||
inline fun KeyValueRepo<String, String>.asMessageContentCache(
|
||||
serialFormatCreator: (SerializersModule) -> StringFormat = { Json { serializersModule = it } }
|
||||
): StandardKeyValueRepo<Pair<ChatId, MessageIdentifier>, MessageContent> {
|
||||
): StandardKeyValueRepo<Pair<ChatId, MessageId>, MessageContent> {
|
||||
val serialFormat = serialFormatCreator(MessageContent.serializationModule())
|
||||
return withMapper<Pair<ChatId, MessageIdentifier>, MessageContent, String, String>(
|
||||
return withMapper<Pair<ChatId, MessageId>, MessageContent, String, String>(
|
||||
{ serialFormat.encodeToString(chatIdToMessageIdentifierSerializer, this) },
|
||||
{ serialFormat.encodeToString(messageContentSerializer, this) },
|
||||
{ serialFormat.decodeFromString(chatIdToMessageIdentifierSerializer, this) },
|
||||
@@ -70,9 +70,9 @@ inline fun KeyValueRepo<String, String>.asMessageContentCache(
|
||||
@JsName("stringsKeyValueAsHexMessageContentCache")
|
||||
inline fun KeyValueRepo<String, String>.asMessageContentCache(
|
||||
serialFormatCreator: (SerializersModule) -> BinaryFormat
|
||||
): StandardKeyValueRepo<Pair<ChatId, MessageIdentifier>, MessageContent> {
|
||||
): StandardKeyValueRepo<Pair<ChatId, MessageId>, MessageContent> {
|
||||
val serialFormat = serialFormatCreator(MessageContent.serializationModule())
|
||||
return withMapper<Pair<ChatId, MessageIdentifier>, MessageContent, String, String>(
|
||||
return withMapper<Pair<ChatId, MessageId>, MessageContent, String, String>(
|
||||
{ serialFormat.encodeToHexString(chatIdToMessageIdentifierSerializer, this) },
|
||||
{ serialFormat.encodeToHexString(messageContentSerializer, this) },
|
||||
{ serialFormat.decodeFromHexString(chatIdToMessageIdentifierSerializer, this) },
|
||||
@@ -84,9 +84,9 @@ inline fun KeyValueRepo<String, String>.asMessageContentCache(
|
||||
@JsName("bytesKeyValueAsMessageContentCache")
|
||||
inline fun KeyValueRepo<ByteArray, ByteArray>.asMessageContentCache(
|
||||
serialFormatCreator: (SerializersModule) -> BinaryFormat
|
||||
): StandardKeyValueRepo<Pair<ChatId, MessageIdentifier>, MessageContent> {
|
||||
): StandardKeyValueRepo<Pair<ChatId, MessageId>, MessageContent> {
|
||||
val serialFormat = serialFormatCreator(MessageContent.serializationModule())
|
||||
return withMapper<Pair<ChatId, MessageIdentifier>, MessageContent, ByteArray, ByteArray>(
|
||||
return withMapper<Pair<ChatId, MessageId>, MessageContent, ByteArray, ByteArray>(
|
||||
{ serialFormat.encodeToByteArray(chatIdToMessageIdentifierSerializer, this) },
|
||||
{ serialFormat.encodeToByteArray(messageContentSerializer, this) },
|
||||
{ serialFormat.decodeFromByteArray(chatIdToMessageIdentifierSerializer, this) },
|
||||
|
||||
@@ -6,21 +6,21 @@ kotlin.incremental=true
|
||||
kotlin.incremental.js=true
|
||||
|
||||
|
||||
kotlin_version=1.9.20
|
||||
kotlin_serialisation_core_version=1.6.0
|
||||
kotlin_version=2.1.10
|
||||
kotlin_serialisation_core_version=1.8.0
|
||||
|
||||
github_release_plugin_version=2.4.1
|
||||
github_release_plugin_version=2.5.2
|
||||
|
||||
tgbotapi_version=9.3.0
|
||||
micro_utils_version=0.20.12
|
||||
exposed_version=0.44.1
|
||||
plagubot_version=7.3.0
|
||||
tgbotapi_version=23.1.2
|
||||
micro_utils_version=0.24.5
|
||||
exposed_version=0.58.0
|
||||
plagubot_version=10.3.1
|
||||
|
||||
# Dokka
|
||||
|
||||
dokka_version=1.9.10
|
||||
dokka_version=2.0.0
|
||||
|
||||
# Project data
|
||||
|
||||
group=dev.inmo
|
||||
version=0.16.0
|
||||
version=0.26.2
|
||||
|
||||
2
gradle/wrapper/gradle-wrapper.properties
vendored
2
gradle/wrapper/gradle-wrapper.properties
vendored
@@ -1,5 +1,5 @@
|
||||
distributionBase=GRADLE_USER_HOME
|
||||
distributionPath=wrapper/dists
|
||||
distributionUrl=https\://services.gradle.org/distributions/gradle-8.4-bin.zip
|
||||
distributionUrl=https\://services.gradle.org/distributions/gradle-8.12.1-bin.zip
|
||||
zipStoreBase=GRADLE_USER_HOME
|
||||
zipStorePath=wrapper/dists
|
||||
|
||||
@@ -37,7 +37,6 @@ kotlin {
|
||||
jsTest {
|
||||
dependencies {
|
||||
implementation kotlin('test-js')
|
||||
implementation kotlin('test-junit')
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@@ -50,18 +50,14 @@ publishing {
|
||||
|
||||
}
|
||||
}
|
||||
if (project.hasProperty('GITEA_TOKEN') || System.getenv('GITEA_TOKEN') != null) {
|
||||
if ((project.hasProperty('INMONEXUS_USER') || System.getenv('INMONEXUS_USER') != null) && (project.hasProperty('INMONEXUS_PASSWORD') || System.getenv('INMONEXUS_PASSWORD') != null)) {
|
||||
maven {
|
||||
name = "Gitea"
|
||||
url = uri("https://git.inmo.dev/api/packages/InsanusMokrassar/maven")
|
||||
name = "InmoNexus"
|
||||
url = uri("https://nexus.inmo.dev/repository/maven-releases/")
|
||||
|
||||
credentials(HttpHeaderCredentials) {
|
||||
name = "Authorization"
|
||||
value = project.hasProperty('GITEA_TOKEN') ? project.property('GITEA_TOKEN') : System.getenv('GITEA_TOKEN')
|
||||
}
|
||||
|
||||
authentication {
|
||||
header(HttpHeaderAuthentication)
|
||||
credentials {
|
||||
username = project.hasProperty('INMONEXUS_USER') ? project.property('INMONEXUS_USER') : System.getenv('INMONEXUS_USER')
|
||||
password = project.hasProperty('INMONEXUS_PASSWORD') ? project.property('INMONEXUS_PASSWORD') : System.getenv('INMONEXUS_PASSWORD')
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@@ -1 +1 @@
|
||||
{"licenses":[{"id":"MIT","title":"MIT License","url":"https://opensource.org/licenses/MIT"}],"mavenConfig":{"name":"${project.name}","description":"${project.name}","url":"https://github.com/InsanusMokrassar/TelegramBotApiLibraries","vcsUrl":"https://github.com/InsanusMokrassar/TelegramBotApiLibraries.git","developers":[{"id":"InsanusMokrassar","name":"Ovsiannikov Aleksei","eMail":"ovsyannikov.alexey95@gmail.com"}],"repositories":[{"name":"GithubPackages","url":"https://maven.pkg.github.com/InsanusMokrassar/TelegramBotApiLibraries"},{"name":"Gitea","url":"https://git.inmo.dev/api/packages/InsanusMokrassar/maven","credsType":{"type":"dev.inmo.kmppscriptbuilder.core.models.MavenPublishingRepository.CredentialsType.HttpHeaderCredentials","headerName":"Authorization","headerValueProperty":"GITEA_TOKEN"}},{"name":"sonatype","url":"https://oss.sonatype.org/service/local/staging/deploy/maven2/"}],"gpgSigning":{"type":"dev.inmo.kmppscriptbuilder.core.models.GpgSigning.Optional"}}}
|
||||
{"licenses":[{"id":"MIT","title":"MIT License","url":"https://opensource.org/licenses/MIT"}],"mavenConfig":{"name":"${project.name}","description":"${project.name}","url":"https://github.com/InsanusMokrassar/TelegramBotApiLibraries","vcsUrl":"https://github.com/InsanusMokrassar/TelegramBotApiLibraries.git","developers":[{"id":"InsanusMokrassar","name":"Ovsiannikov Aleksei","eMail":"ovsyannikov.alexey95@gmail.com"}],"repositories":[{"name":"GithubPackages","url":"https://maven.pkg.github.com/InsanusMokrassar/TelegramBotApiLibraries"},{"name":"InmoNexus","url":"https://nexus.inmo.dev/repository/maven-releases/"},{"name":"sonatype","url":"https://oss.sonatype.org/service/local/staging/deploy/maven2/"}],"gpgSigning":{"type":"dev.inmo.kmppscriptbuilder.core.models.GpgSigning.Optional"}}}
|
||||
6
renovate.json
Normal file
6
renovate.json
Normal file
@@ -0,0 +1,6 @@
|
||||
{
|
||||
"$schema": "https://docs.renovatebot.com/renovate-schema.json",
|
||||
"extends": [
|
||||
"config:recommended"
|
||||
]
|
||||
}
|
||||
@@ -2,9 +2,12 @@ package dev.inmo.tgbotapi.libraries.resender
|
||||
|
||||
import dev.inmo.tgbotapi.types.FullChatIdentifierSerializer
|
||||
import dev.inmo.tgbotapi.types.IdChatIdentifier
|
||||
import dev.inmo.tgbotapi.types.MediaGroupId
|
||||
import dev.inmo.tgbotapi.types.MessageId
|
||||
import dev.inmo.tgbotapi.types.message.abstracts.ContentMessage
|
||||
import dev.inmo.tgbotapi.types.message.abstracts.Message
|
||||
import dev.inmo.tgbotapi.types.message.abstracts.PossiblyMediaGroupMessage
|
||||
import dev.inmo.tgbotapi.types.message.content.MediaGroupContent
|
||||
import kotlinx.serialization.Serializable
|
||||
|
||||
@Serializable
|
||||
@@ -12,8 +15,21 @@ data class MessageMetaInfo(
|
||||
@Serializable(FullChatIdentifierSerializer::class)
|
||||
val chatId: IdChatIdentifier,
|
||||
val messageId: MessageId,
|
||||
val group: String? = null
|
||||
)
|
||||
val group: MediaGroupId? = null
|
||||
) {
|
||||
val metaInfo: Message.MetaInfo
|
||||
get() = Message.MetaInfo(chatId, messageId)
|
||||
}
|
||||
|
||||
fun Message.asMessageMetaInfos(): List<MessageMetaInfo> {
|
||||
return if (this is ContentMessage<*>) {
|
||||
(content as? MediaGroupContent<*>) ?.group ?.map {
|
||||
MessageMetaInfo(it.sourceMessage.chat.id, it.sourceMessage.messageId, it.sourceMessage.mediaGroupId)
|
||||
}
|
||||
} else {
|
||||
null
|
||||
} ?: listOf(MessageMetaInfo(chat.id, messageId, (this as? PossiblyMediaGroupMessage<*>) ?.mediaGroupId))
|
||||
}
|
||||
|
||||
operator fun MessageMetaInfo.Companion.invoke(
|
||||
message: Message
|
||||
|
||||
@@ -1,8 +1,11 @@
|
||||
package dev.inmo.tgbotapi.libraries.resender
|
||||
|
||||
import dev.inmo.micro_utils.common.applyDiff
|
||||
import dev.inmo.tgbotapi.bot.TelegramBot
|
||||
import dev.inmo.tgbotapi.requests.ForwardMessage
|
||||
import dev.inmo.tgbotapi.requests.ForwardMessages
|
||||
import dev.inmo.tgbotapi.requests.send.CopyMessage
|
||||
import dev.inmo.tgbotapi.requests.send.CopyMessages
|
||||
import dev.inmo.tgbotapi.requests.send.media.SendMediaGroup
|
||||
import dev.inmo.tgbotapi.types.ChatIdentifier
|
||||
import dev.inmo.tgbotapi.types.IdChatIdentifier
|
||||
@@ -46,9 +49,9 @@ class MessagesResender(
|
||||
targetChatId,
|
||||
bot.execute(
|
||||
CopyMessage(
|
||||
targetChatId,
|
||||
toChatId = targetChatId,
|
||||
fromChatId = messageInfo.chatId,
|
||||
messageId = messageInfo.messageId
|
||||
messageId = messageInfo.messageId,
|
||||
)
|
||||
)
|
||||
)
|
||||
@@ -66,7 +69,7 @@ class MessagesResender(
|
||||
targetChatId,
|
||||
bot.execute(
|
||||
CopyMessage(
|
||||
targetChatId,
|
||||
toChatId = targetChatId,
|
||||
fromChatId = it.chat.id,
|
||||
messageId = it.messageId
|
||||
)
|
||||
@@ -80,13 +83,13 @@ class MessagesResender(
|
||||
else -> {
|
||||
val resultContents = contents.mapNotNull {
|
||||
it to (
|
||||
bot.execute(
|
||||
ForwardMessage(
|
||||
toChatId = cacheChatId,
|
||||
fromChatId = it.chatId,
|
||||
messageId = it.messageId
|
||||
)
|
||||
) as? ContentMessage<*> ?: return@mapNotNull null)
|
||||
bot.execute(
|
||||
ForwardMessage(
|
||||
toChatId = cacheChatId,
|
||||
fromChatId = it.chatId,
|
||||
messageId = it.messageId
|
||||
)
|
||||
) as? ContentMessage<*> ?: return@mapNotNull null)
|
||||
}.mapNotNull { (src, forwardedMessage) ->
|
||||
val forwardedMessageAsMediaPartMessage = forwardedMessage.takeIf {
|
||||
it.content is MediaGroupPartContent
|
||||
@@ -99,7 +102,7 @@ class MessagesResender(
|
||||
targetChatId,
|
||||
bot.execute(
|
||||
CopyMessage(
|
||||
targetChatId,
|
||||
toChatId = targetChatId,
|
||||
fromChatId = forwardedMessage.chat.id,
|
||||
messageId = forwardedMessage.messageId
|
||||
)
|
||||
@@ -115,9 +118,9 @@ class MessagesResender(
|
||||
targetChatId,
|
||||
bot.execute(
|
||||
CopyMessage(
|
||||
targetChatId,
|
||||
it.chat.id,
|
||||
it.messageId
|
||||
toChatId = targetChatId,
|
||||
fromChatId = it.chat.id,
|
||||
messageId = it.messageId
|
||||
)
|
||||
)
|
||||
)
|
||||
|
||||
Reference in New Issue
Block a user