Add s3 integration

src/main/kotlin/com/pischule/memestv/BotService.kt

@@ -3,6 +3,7 @@ package com.pischule.memestv
 import com.github.kotlintelegrambot.Bot
 import com.github.kotlintelegrambot.bot
 import com.github.kotlintelegrambot.dispatch
+import com.github.kotlintelegrambot.dispatcher.message
 import com.github.kotlintelegrambot.dispatcher.photos
 import com.github.kotlintelegrambot.entities.ChatId
 import com.github.kotlintelegrambot.entities.reaction.ReactionType
@@ -18,7 +19,10 @@ val log = KotlinLogging.logger {}
 @Profile("!test")
 @EnableConfigurationProperties(BotProps::class)
 @Service
-class BotService(val botProps: BotProps) {
+class BotService(
+    private val botProps: BotProps,
+    private val fileUploaderService: FileUploaderService,
+) {
     private lateinit var bot: Bot
 
     @PostConstruct
@@ -26,27 +30,61 @@ class BotService(val botProps: BotProps) {
         bot = bot {
             token = botProps.token
             dispatch {
+                message {
+                    try {
+                        val chatId = message.chat.id
+                        val replyToPhotos = message.replyToMessage
+                            ?.photo
+                            ?.takeIf { it.isNotEmpty() }
+                        if (chatId == botProps.destinationChatId
+                            && message.text?.lowercase() == "this"
+                            && replyToPhotos != null
+                        ) {
+                            val maxResPhoto = replyToPhotos.last().fileId
+                            val fileBytes = bot.downloadFileBytes(maxResPhoto)
+                            fileBytes?.let {
+                                log.info { "Downloaded a file $maxResPhoto from telegram" }
+                                fileUploaderService.uploadFile(it)
+                                log.info { "Uploaded a file $maxResPhoto to s3" }
+                                bot.setMessageReaction(
+                                    chatId = ChatId.fromId(message.chat.id),
+                                    messageId = message.messageId,
+                                    reaction = listOf(ReactionType.Emoji("👍"))
+                                ).onError { error ->
+                                    log.warn { "Failed to react to message: $error" }
+                                }
+                            }
+                        }
+                    } catch (e: Error) {
+                        log.error(e) { "Error while handling message" }
+                    }
+                }
                 photos {
                     val message = this.message
 
+                    if (message.chat.id != botProps.destinationChatId) {
+                        bot.forwardMessage(
+                            chatId = ChatId.fromId(botProps.destinationChatId),
+                            fromChatId = ChatId.fromId(message.chat.id),
+                            messageId = message.messageId,
+                        ).fold(
+                            {
+                                log.info { "Forwarded pictures message: $it" }
+                            },
+                            {
+                                log.error { "Failed to forward message: $it" }
+                            }
+                        )
+                    }
+
                     bot.setMessageReaction(
                         chatId = ChatId.fromId(message.chat.id),
                         messageId = message.messageId,
                         reaction = listOf(ReactionType.Emoji("👀"))
-                    )
+                    ).onError { error ->
+                        log.warn { "Failed to react to message: $error" }
+                    }
 
-                    bot.forwardMessage(
-                        chatId = ChatId.fromId(botProps.destinationChatId),
-                        fromChatId = ChatId.fromId(message.chat.id),
-                        messageId = message.messageId,
-                    ).fold(
-                        {
-                            log.info { "Forwarded pictures message: $it" }
-                        },
-                        {
-                            log.error { "Failed to forward message: $it" }
-                        }
-                    )
                 }
             }
         }

src/main/kotlin/com/pischule/memestv/FileUploaderService.kt

@@ -0,0 +1,21 @@
+package com.pischule.memestv
+
+import aws.sdk.kotlin.services.s3.S3Client
+import aws.sdk.kotlin.services.s3.model.PutObjectRequest
+import aws.smithy.kotlin.runtime.content.ByteStream
+import org.springframework.stereotype.Service
+
+@Service
+class FileUploaderService(
+    private val s3Client: S3Client,
+    private val s3Props: S3Props,
+) {
+
+    suspend fun uploadFile(fileBytes: ByteArray) {
+        s3Client.putObject(PutObjectRequest{
+            body = ByteStream.fromBytes(fileBytes)
+            bucket = s3Props.bucket
+            key = "_.jpeg"
+        })
+    }
+}

src/main/kotlin/com/pischule/memestv/S3Config.kt

@@ -0,0 +1,24 @@
+package com.pischule.memestv
+
+import aws.sdk.kotlin.runtime.auth.credentials.StaticCredentialsProvider
+import aws.sdk.kotlin.services.s3.S3Client
+import aws.smithy.kotlin.runtime.net.url.Url
+import org.springframework.boot.context.properties.EnableConfigurationProperties
+import org.springframework.context.annotation.Bean
+import org.springframework.context.annotation.Configuration
+
+@EnableConfigurationProperties(S3Props::class)
+@Configuration
+class S3Config {
+    @Bean
+    fun s3Client(s3Props: S3Props): S3Client {
+        return S3Client {
+            endpointUrl = Url.parse("https://storage.yandexcloud.net")
+            region = "ru-central1"
+            credentialsProvider = StaticCredentialsProvider {
+                accessKeyId = s3Props.accessKeyId
+                secretAccessKey = s3Props.secretAccessKey
+            }
+        }
+    }
+}

src/main/kotlin/com/pischule/memestv/S3Props.kt

@@ -0,0 +1,10 @@
+package com.pischule.memestv
+
+import org.springframework.boot.context.properties.ConfigurationProperties
+
+@ConfigurationProperties("s3")
+data class S3Props(
+    val accessKeyId: String,
+    val secretAccessKey: String,
+    val bucket: String,
+)