2

我正在使用kotlin和ktor为 telegram-bot-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？

4

1 回答 1

2

好的，我终于找到了答案。固定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)
    }
}
于 2018-12-11T09:18:19.363 回答