mirror of
https://github.com/InsanusMokrassar/TelegramBotApiLibraries.git
synced 2025-10-26 17:50:20 +00:00
Compare commits
36 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| ff99bdd45d | |||
| 2ae7507c01 | |||
| 7b30d95f56 | |||
| bbe9367ef3 | |||
| 6403fe6f5d | |||
| 3cad9ec337 | |||
| 78e5da9db7 | |||
| 74329a8eb2 | |||
| 953df71d9e | |||
| c25f6d522f | |||
| d569f46e48 | |||
| f2731f6e7d | |||
| f10c7412f4 | |||
| a113e6e37e | |||
| 7c6005bea3 | |||
| 3f6067b34e | |||
| af72bba116 | |||
| 84f04fb1f0 | |||
| 5524fc9fa0 | |||
| d0eebc0ace | |||
| 891dab1f4b | |||
| 9f6895a530 | |||
| 49084169d2 | |||
|
|
684172cc08 | ||
| 1457cfc748 | |||
| 6784a3c49a | |||
| 8ef89a32c7 | |||
| d16de6428a | |||
| 49475a457d | |||
| b8312873b0 | |||
| 3ede07c2a6 | |||
| a0e17a664c | |||
| fc3bf19453 | |||
| 8d1c57700e | |||
| 00c0f0fd6f | |||
| 551eb293ab |
1
.gitignore
vendored
1
.gitignore
vendored
@@ -1,4 +1,5 @@
|
||||
.idea
|
||||
.kotlin
|
||||
out/*
|
||||
*.iml
|
||||
target
|
||||
|
||||
17
build.gradle
17
build.gradle
@@ -13,6 +13,23 @@ buildscript {
|
||||
}
|
||||
}
|
||||
|
||||
plugins {
|
||||
id "com.gradleup.nmcp.aggregation" version "$nmcp_version"
|
||||
}
|
||||
|
||||
if ((project.hasProperty('SONATYPE_USER') || System.getenv('SONATYPE_USER') != null) && (project.hasProperty('SONATYPE_PASSWORD') || System.getenv('SONATYPE_PASSWORD') != null)) {
|
||||
nmcpAggregation {
|
||||
centralPortal {
|
||||
username = project.hasProperty('SONATYPE_USER') ? project.property('SONATYPE_USER') : System.getenv('SONATYPE_USER')
|
||||
password = project.hasProperty('SONATYPE_PASSWORD') ? project.property('SONATYPE_PASSWORD') : System.getenv('SONATYPE_PASSWORD')
|
||||
validationTimeout = Duration.ofHours(4)
|
||||
publishingType = System.getenv('PUBLISHING_TYPE') != "" ? System.getenv('PUBLISHING_TYPE') : "USER_MANAGED"
|
||||
}
|
||||
|
||||
publishAllProjectsProbablyBreakingProjectIsolation()
|
||||
}
|
||||
}
|
||||
|
||||
allprojects {
|
||||
repositories {
|
||||
mavenLocal()
|
||||
|
||||
@@ -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()) }
|
||||
|
||||
@@ -1,11 +1,15 @@
|
||||
package dev.inmo.tgbotapi.libraries.cache.media.common
|
||||
|
||||
import dev.inmo.tgbotapi.bot.TelegramBot
|
||||
import dev.inmo.tgbotapi.requests.DeleteMessage
|
||||
import dev.inmo.tgbotapi.requests.DownloadFileStream
|
||||
import dev.inmo.tgbotapi.requests.abstracts.MultipartFile
|
||||
import dev.inmo.tgbotapi.requests.get.GetFile
|
||||
import dev.inmo.tgbotapi.requests.send.media.*
|
||||
import dev.inmo.tgbotapi.types.IdChatIdentifier
|
||||
import dev.inmo.tgbotapi.types.media.*
|
||||
import dev.inmo.tgbotapi.types.message.abstracts.ContentMessage
|
||||
import dev.inmo.tgbotapi.types.message.content.DocumentContent
|
||||
import dev.inmo.tgbotapi.types.message.content.MediaContent
|
||||
import dev.inmo.tgbotapi.types.message.content.MessageContent
|
||||
import dev.inmo.tgbotapi.utils.asInput
|
||||
@@ -58,6 +62,30 @@ class DefaultMessageContentCache<K>(
|
||||
}
|
||||
}
|
||||
|
||||
override suspend fun sendAndSave(
|
||||
k: K,
|
||||
filename: String,
|
||||
inputAllocator: () -> Input
|
||||
): DocumentContent {
|
||||
val sentDocument = bot.execute(
|
||||
SendDocument(
|
||||
filesRefreshingChatId,
|
||||
MultipartFile(filename, inputAllocator),
|
||||
)
|
||||
)
|
||||
save(k, sentDocument.content, filename, inputAllocator)
|
||||
runCatching {
|
||||
bot.execute(
|
||||
DeleteMessage(
|
||||
sentDocument.chat.id,
|
||||
sentDocument.messageId
|
||||
)
|
||||
)
|
||||
}
|
||||
|
||||
return sentDocument.content
|
||||
}
|
||||
|
||||
override suspend fun get(k: K): MessageContent? {
|
||||
val savedSimpleContent = simpleMessageContentCache.get(k) ?: return null
|
||||
|
||||
|
||||
@@ -1,5 +1,7 @@
|
||||
package dev.inmo.tgbotapi.libraries.cache.media.common
|
||||
|
||||
import dev.inmo.tgbotapi.types.message.abstracts.ContentMessage
|
||||
import dev.inmo.tgbotapi.types.message.content.DocumentContent
|
||||
import dev.inmo.tgbotapi.types.message.content.MediaContent
|
||||
import dev.inmo.tgbotapi.types.message.content.MessageContent
|
||||
import io.ktor.utils.io.core.Input
|
||||
@@ -12,6 +14,11 @@ interface MessageContentCache<K> {
|
||||
filename: String,
|
||||
inputAllocator: suspend () -> Input
|
||||
)
|
||||
suspend fun sendAndSave(
|
||||
k: K,
|
||||
filename: String,
|
||||
inputAllocator: () -> Input
|
||||
): DocumentContent
|
||||
|
||||
suspend fun get(k: K): MessageContent?
|
||||
suspend fun contains(k: K): Boolean
|
||||
|
||||
@@ -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)
|
||||
}
|
||||
}
|
||||
|
||||
@@ -6,21 +6,23 @@ kotlin.incremental=true
|
||||
kotlin.incremental.js=true
|
||||
|
||||
|
||||
kotlin_version=1.9.23
|
||||
kotlin_serialisation_core_version=1.6.3
|
||||
kotlin_version=2.1.20
|
||||
kotlin_serialisation_core_version=1.8.1
|
||||
|
||||
github_release_plugin_version=2.5.2
|
||||
|
||||
tgbotapi_version=15.1.0
|
||||
micro_utils_version=0.21.2
|
||||
exposed_version=0.50.1
|
||||
plagubot_version=8.5.0
|
||||
tgbotapi_version=26.0.0
|
||||
micro_utils_version=0.25.8
|
||||
exposed_version=0.61.0
|
||||
plagubot_version=10.6.0
|
||||
|
||||
nmcp_version=0.2.1
|
||||
|
||||
# Dokka
|
||||
|
||||
dokka_version=1.9.20
|
||||
dokka_version=2.0.0
|
||||
|
||||
# Project data
|
||||
|
||||
group=dev.inmo
|
||||
version=0.21.0
|
||||
version=0.26.6
|
||||
|
||||
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.7-bin.zip
|
||||
distributionUrl=https\://services.gradle.org/distributions/gradle-8.13-bin.zip
|
||||
zipStoreBase=GRADLE_USER_HOME
|
||||
zipStorePath=wrapper/dists
|
||||
|
||||
@@ -37,7 +37,6 @@ kotlin {
|
||||
jsTest {
|
||||
dependencies {
|
||||
implementation kotlin('test-js')
|
||||
implementation kotlin('test-junit')
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
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"
|
||||
]
|
||||
}
|
||||
@@ -49,9 +49,9 @@ class MessagesResender(
|
||||
targetChatId,
|
||||
bot.execute(
|
||||
CopyMessage(
|
||||
targetChatId,
|
||||
toChatId = targetChatId,
|
||||
fromChatId = messageInfo.chatId,
|
||||
messageId = messageInfo.messageId
|
||||
messageId = messageInfo.messageId,
|
||||
)
|
||||
)
|
||||
)
|
||||
@@ -69,7 +69,7 @@ class MessagesResender(
|
||||
targetChatId,
|
||||
bot.execute(
|
||||
CopyMessage(
|
||||
targetChatId,
|
||||
toChatId = targetChatId,
|
||||
fromChatId = it.chat.id,
|
||||
messageId = it.messageId
|
||||
)
|
||||
@@ -102,7 +102,7 @@ class MessagesResender(
|
||||
targetChatId,
|
||||
bot.execute(
|
||||
CopyMessage(
|
||||
targetChatId,
|
||||
toChatId = targetChatId,
|
||||
fromChatId = forwardedMessage.chat.id,
|
||||
messageId = forwardedMessage.messageId
|
||||
)
|
||||
@@ -118,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