使用 ktor 将文件上传到电报 bot api

Question

我正在使用 kotlin 和 ktor 为电报机器人 API 编写包装器。 我有一个问题 - 找不到上传文件的工作方式。

（来自 tg bot api docs）
发送文件有三种方式（照片、贴纸、音频、媒体等）：

1. 如果文件已经存储在 Telegram 服务器的某个位置，则无需重新上传：每个文件对象都有一个 file_id 字段，只需将此 file_id 作为参数传递，而不是上传。以这种方式发送的文件没有限制。
2. 为 Telegram 提供要发送的文件的 HTTP URL。 Telegram 将下载并发送文件。照片最大为 5 MB，其他类型的内容最大为 20 MB。
3. 使用 multipart/form-data 以通常的方式发布文件，即通过浏览器上传文件。照片最大 10 MB，其他文件最大 50 MB。

第一种和第二种方法我没有任何问题。

现在我有一个丑陋的函数，它向 tg 发出请求并解析答案：

internal suspend inline fun <reified T> makeRequest(token: String, method: TelegramMethod, vararg params: Pair<String, Any?>, files: Map<String, String> = emptyMap()): T {
    try {
        val data: List<PartData> = formData {
            files.forEach { key, fileName ->
                append(key, Files.newInputStream(Paths.get(fileName)).asInput())
            }
        }
        val response = client.submitFormWithBinaryData<HttpResponse>(data) {
            this.method = HttpMethod.Post
            url {
                protocol = URLProtocol("https", 42)
                host = API_HOST
                encodedPath = API_PATH_PATTERN.format(token, method.methodName)
                params.forEach { (name, value) ->
                    if (value != null) { this.parameters[name] = value as String }
                }
            }
        }
        val result = response.receive<String>()
        return parseTelegramAnswer<T>(response, result)
    } catch (e: BadResponseStatusException) {
        val answer = mapper.readValue<TResult<T>>(e.response.content.readUTF8Line()!!)
        throw checkTelegramError(e.response.status, answer)
    }
}

没有文件它可以工作，有文件 - 它不能。 （我认为我做错了一切）

使用示例：

suspend fun getUpdates(offset: Long? = null, limit: Int? = null, timeout: Int? = null, allowedUpdates: List<String>? = null): List<Update> =
        api.makeRequest(
            token,
            TelegramMethod.getUpdates,
            "offset" to offset?.toString(),
            "limit" to limit?.toString(),
            "timeout" to timeout?.toString(),
            "allowed_updates" to allowedUpdates
        )

我已经在不同的文件上对其进行了测试，我发现：

1. 如果我在 17,9 KiB 和 56,6 KiB 之间发送文件，我会从 tg 得到以下错误：Bad Request: wrong URL host

2. 如果我在75,6 KiB 和913,2 KiB 之间发送文件，我会收到错误413 Request Entity Too Large

* 我使用的是sendDocument 方法

使用ktor发送文件的真正方法是什么？

Answer 1

好吧，我终于找到答案了。修复makeRequest函数：

internal suspend inline fun <reified T> makeRequest(token: String, method: TelegramMethod, vararg params: Pair<String, Any?>): T {
    try {
        val response = client.submitForm<HttpResponse> {
            this.method = HttpMethod.Post
            url {
                protocol = URLProtocol.HTTPS
                host = API_HOST
                encodedPath = API_PATH_PATTERN.format(token, method.methodName)
            }
            body = MultiPartFormDataContent(
                    formData {
                        params.forEach { (key, value) ->
                            when (value) {
                                null -> {}
                                is MultipartFile -> append(
                                        key,
                                        value.file.inputStream().asInput(),
                                        Headers.build {
                                            append(HttpHeaders.ContentType, value.mimeType)
                                            append(HttpHeaders.ContentDisposition, "filename=${value.filename}")
                                        }
                                )
                                is FileId -> append(key, value.fileId)
                                else -> append(key, value.toString())
                            }
                        }
                    }
            )
        }
        val result = response.receive<String>()
        val r = parseTelegramAnswer<T>(response, result)
        return r
    } catch (e: BadResponseStatusException) {
        val answer = mapper.readValue<TResult<T>>(e.response.content.readUTF8Line()!!)
        throw checkTelegramError(e.response.status, answer)
    }
}